From a54550d94f2973f5e6c73ce4c3bb9eaba8aff711 Mon Sep 17 00:00:00 2001
From: luokey <854194341@qq.com>
Date: Wed, 27 Jan 2021 21:00:20 +0800
Subject: [PATCH] [MINOR]Fix NPE when using HoodieFlinkStreamer with multi
 parallelism (#2492)

---
 .../java/org/apache/hudi/operator/InstantGenerateOperator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java b/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
index 75c766837..103aef514 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/operator/InstantGenerateOperator.java
@@ -78,7 +78,7 @@ public class InstantGenerateOperator extends AbstractStreamOperator<HoodieRecord
   private static final String DELIMITER = "_";
   private static final String INSTANT_MARKER_FOLDER_NAME = ".instant_marker";
   private transient boolean isMain = false;
-  private transient AtomicLong recordCounter = new AtomicLong(0);
+  private AtomicLong recordCounter = new AtomicLong(0);
   private StreamingRuntimeContext runtimeContext;
   private int indexOfThisSubtask;