diff --git a/core/src/jmh/java/org/apache/iceberg/metrics/CountersBenchmark.java b/core/src/jmh/java/org/apache/iceberg/metrics/CountersBenchmark.java
index f9a5a46cf3a0..1350950d4874 100644
--- a/core/src/jmh/java/org/apache/iceberg/metrics/CountersBenchmark.java
+++ b/core/src/jmh/java/org/apache/iceberg/metrics/CountersBenchmark.java
@@ -56,7 +56,7 @@ public void defaultCounterMultipleThreads(Blackhole blackhole) {
       Tasks.range(WORKER_POOL_SIZE)
           .executeWith(workerPool)
           .run(
-              (id) -> {
+              id -> {
                 for (int operation = 0; operation < NUM_OPERATIONS; operation++) {
                   counter.increment(INCREMENT_AMOUNT);
                 }
diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
index fcfd79884265..477567779dec 100644
--- a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
+++ b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java
@@ -172,6 +172,7 @@ private void handleDataStatisticRequest(int subtask, DataStatisticsEvent<D, S> e
     }
   }
 
+  @SuppressWarnings("FutureReturnValueIgnored")
   private void sendDataStatisticsToSubtasks(
       long checkpointId, DataStatistics<D, S> globalDataStatistics) {
     callInCoordinatorThread(