[iceberg] branch master updated: Flink: Add branch to successful commit logs

[stevenwu]

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

stevenwu 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 7184691a60 Flink: Add branch to successful commit logs
7184691a60 is described below

commit 7184691a60e2ac21dfd6b22fba56d2fe60f9af51
Author: Amogh Jahagirdar <jaham...@amazon.com>
AuthorDate: Mon Feb 27 14:12:04 2023 -0800

    Flink: Add branch to successful commit logs
---
 .../main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
 
b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
index 0ddbce9929..e11975b3ef 100644
--- 
a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
+++ 
b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
@@ -407,9 +407,10 @@ class IcebergFilesCommitter extends 
AbstractStreamOperator<Void>
     operation.commit(); // abort is automatically called if this fails.
     long durationMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - 
startNano);
     LOG.info(
-        "Committed {} to table: {}, checkpointId {} in {} ms",
+        "Committed {} to table: {}, branch: {}, checkpointId {} in {} ms",
         description,
         table.name(),
+        branch,
         checkpointId,
         durationMs);
     committerMetrics.commitDuration(durationMs);