[flink] branch master updated: [FLINK-30424][DataStream API] Add source operator addSplits log when restore from state

[jqin]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 528186b62da [FLINK-30424][DataStream API] Add source operator 
addSplits log when restore from state
528186b62da is described below

commit 528186b62da92ecde0fa308f1df0cc6f95495f4d
Author: Ran Tao <chucheng...@gmail.com>
AuthorDate: Thu Dec 15 13:18:32 2022 +0800

    [FLINK-30424][DataStream API] Add source operator addSplits log when 
restore from state
---
 .../java/org/apache/flink/streaming/api/operators/SourceOperator.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
index 817d19dd795..3e962596e66 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
@@ -333,6 +333,7 @@ public class SourceOperator<OUT, SplitT extends 
SourceSplit> extends AbstractStr
         // restore the state if necessary.
         final List<SplitT> splits = 
CollectionUtil.iterableToList(readerState.get());
         if (!splits.isEmpty()) {
+            LOG.info("Restoring state for {} split(s) to reader.", 
splits.size());
             sourceReader.addSplits(splits);
         }