[hudi] branch master updated: [HUDI-1453] Fix NPE using HoodieFlinkStreamer to etl data from kafka to hudi (#2474)

[vinoyang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new e302c6b  [HUDI-1453] Fix NPE using HoodieFlinkStreamer to etl data 
from kafka to hudi (#2474)
e302c6b is described below

commit e302c6bc12c7eb764781898fdee8ee302ef4ec10
Author: wangxianghu <wxhj...@126.com>
AuthorDate: Sat Jan 23 10:27:40 2021 +0800

    [HUDI-1453] Fix NPE using HoodieFlinkStreamer to etl data from kafka to 
hudi (#2474)
---
 .../src/main/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 58cad4e..75c7668 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);