From e302c6bc12c7eb764781898fdee8ee302ef4ec10 Mon Sep 17 00:00:00 2001
From: wangxianghu <wxhjsxz@126.com>
Date: Sat, 23 Jan 2021 10:27:40 +0800
Subject: [PATCH] [HUDI-1453] Fix NPE using HoodieFlinkStreamer to etl data
 from kafka to hudi (#2474)

---
 .../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 58cad4ef8..75c766837 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
@@ -109,7 +109,7 @@ public class InstantGenerateOperator extends AbstractStreamOperator<HoodieRecord
     fs = FSUtils.getFs(cfg.targetBasePath, serializableHadoopConf.get());
 
     if (isMain) {
-      TaskContextSupplier taskContextSupplier = new FlinkTaskContextSupplier(runtimeContext);
+      TaskContextSupplier taskContextSupplier = new FlinkTaskContextSupplier(null);
 
       // writeClient
       writeClient = new HoodieFlinkWriteClient(new HoodieFlinkEngineContext(taskContextSupplier), StreamerUtil.getHoodieClientConfig(cfg), true);