diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
index 06c29c781bc6..624bea163ffa 100644
--- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
+++ b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -1580,7 +1580,6 @@ class BeamModulePlugin implements Plugin<Project> {
             "NullableWildcard",
             "StringCharset",
             "SuperCallToObjectMethod",
-            "UnnecessaryLongToIntConversion",
             "UnusedVariable",
             // intended suppressions emerged in newer protobuf versions
             "AutoValueBoxedValues",
diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/config/StreamingEngineComputationConfigFetcher.java b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/config/StreamingEngineComputationConfigFetcher.java
index 0f50c04d1f0b..6ade84403713 100644
--- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/config/StreamingEngineComputationConfigFetcher.java
+++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/config/StreamingEngineComputationConfigFetcher.java
@@ -181,7 +181,7 @@ private StreamingGlobalConfig createPipelineConfig(StreamingConfigTask config) {
     if (config.getMaxWorkItemCommitBytes() != null
         && config.getMaxWorkItemCommitBytes() > 0
         && config.getMaxWorkItemCommitBytes() <= Integer.MAX_VALUE) {
-      operationalLimits.setMaxWorkItemCommitBytes(config.getMaxWorkItemCommitBytes().intValue());
+      operationalLimits.setMaxWorkItemCommitBytes(config.getMaxWorkItemCommitBytes());
     }
 
     if (config.getOperationalLimits() != null) {
diff --git a/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaRunnerWithTransformMetrics.java b/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaRunnerWithTransformMetrics.java
index dc660ce85af5..49143a5b10bb 100644
--- a/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaRunnerWithTransformMetrics.java
+++ b/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaRunnerWithTransformMetrics.java
@@ -245,7 +245,7 @@ public void testSamzaInputAndOutputMetricOp() {
     // Latency must be positive
     assertTrue(latency.getSnapshot().getAverage() > 0);
     // Cache size must be 0
-    assertEquals(0, cacheSize.getValue().intValue());
+    assertEquals(0L, cacheSize.getValue().longValue());
   }
 
   @Test
@@ -318,6 +318,6 @@ public void testSamzaInputAndOutputGBKMetricOp() {
     // Latency must be positive
     assertTrue(latency.getSnapshot().getAverage() > 0);
     // Cache size must be 0
-    assertEquals(0, cacheSize.getValue().intValue());
+    assertEquals(0L, cacheSize.getValue().longValue());
   }
 }
diff --git a/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaTransformMetricsRegistry.java b/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaTransformMetricsRegistry.java
index f94543ef809e..75f6ddd5fefa 100644
--- a/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaTransformMetricsRegistry.java
+++ b/runners/samza/src/test/java/org/apache/beam/runners/samza/metrics/TestSamzaTransformMetricsRegistry.java
@@ -102,7 +102,7 @@ public void testSamzaTransformMetricsRegistryForNonShuffleOperators() {
             .get("dummy-pvalue.out")
             .containsKey(watermarkMessage.getTimestamp()));
     // Cache size must be 0
-    assertEquals(0, cacheSize.getValue().intValue());
+    assertEquals(0L, cacheSize.getValue().longValue());
   }
 
   @Test
@@ -186,6 +186,6 @@ public Instant maxTimestamp() {
     // Check the latency metric is same
     assertTrue(1000 == latency.getSnapshot().getAverage());
     // Cache size must be 0
-    assertEquals(0, cacheSize.getValue().intValue());
+    assertEquals(0L, cacheSize.getValue().longValue());
   }
 }
diff --git a/sdks/java/io/pulsar/src/test/java/org/apache/beam/sdk/io/pulsar/PulsarIOIT.java b/sdks/java/io/pulsar/src/test/java/org/apache/beam/sdk/io/pulsar/PulsarIOIT.java
index d3b8cea7d899..2acacd1a2b6e 100644
--- a/sdks/java/io/pulsar/src/test/java/org/apache/beam/sdk/io/pulsar/PulsarIOIT.java
+++ b/sdks/java/io/pulsar/src/test/java/org/apache/beam/sdk/io/pulsar/PulsarIOIT.java
@@ -188,7 +188,7 @@ public void testReadFromSimpleTopic() throws PulsarClientException {
         break;
       }
     }
-    assertEquals(inputsMock.size(), (int) recordsCount);
+    assertEquals(inputsMock.size(), recordsCount);
   }
 
   @Test