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

[vi...@apache.org]

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 <wx...@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);