lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

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

Browse Source
This commit is contained in:
wangxianghu
2021-01-23 10:27:40 +08:00
committed by GitHub
parent d3ea0f957e
commit e302c6bc12
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

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