lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR]Fix NPE when using HoodieFlinkStreamer with multi parallelism (#2492)

Browse Source
This commit is contained in:
luokey
2021-01-27 21:00:20 +08:00
committed by GitHub
parent c8ee40f8ae
commit a54550d94f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
View File

@@ -78,7 +78,7 @@ public class InstantGenerateOperator extends AbstractStreamOperator<HoodieRecord
private static final String DELIMITER = "_"; private static final String DELIMITER = "_";
private static final String INSTANT_MARKER_FOLDER_NAME = ".instant_marker"; private static final String INSTANT_MARKER_FOLDER_NAME = ".instant_marker";
private transient boolean isMain = false; private transient boolean isMain = false;
private transient AtomicLong recordCounter = new AtomicLong(0); private AtomicLong recordCounter = new AtomicLong(0);
private StreamingRuntimeContext runtimeContext; private StreamingRuntimeContext runtimeContext;
private int indexOfThisSubtask; private int indexOfThisSubtask;