[iceberg] branch master updated: Fix minor compilation warnings (#8758)

[etudenhoefner]

This is an automated email from the ASF dual-hosted git repository.

etudenhoefner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 103038db4f Fix minor compilation warnings (#8758)
103038db4f is described below

commit 103038db4f60e96cd24d7f6e5710954a7a53ff78
Author: Naveen Kumar <nk1...@gmail.com>
AuthorDate: Tue Oct 10 17:47:49 2023 +0530

    Fix minor compilation warnings (#8758)
---
 core/src/jmh/java/org/apache/iceberg/metrics/CountersBenchmark.java     | 2 +-
 .../apache/iceberg/flink/sink/shuffle/DataStatisticsCoordinator.java    | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

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 f9a5a46cf3..1350950d48 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 class CountersBenchmark {
       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 fcfd798842..477567779d 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 @@ class DataStatisticsCoordinator<D extends DataStatistics<D, 
S>, S> implements Op
     }
   }
 
+  @SuppressWarnings("FutureReturnValueIgnored")
   private void sendDataStatisticsToSubtasks(
       long checkpointId, DataStatistics<D, S> globalDataStatistics) {
     callInCoordinatorThread(