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);