lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Revert "[HUDI-2799] Fix the classloader of flink write task (#4042)" (#4069)

Browse Source 
This reverts commit 8281cbf762.
This commit is contained in:
Danny Chan
2021-11-24 12:01:18 +08:00
committed by GitHub
parent 0cf2f103e0
commit 323be33f18
3 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java
View File

@@ -111,8 +111,6 @@ public class BulkInsertWriteFunction<I>
@Override @Override
public void open(Configuration parameters) throws IOException { public void open(Configuration parameters) throws IOException {
// always use the user classloader
Thread.currentThread().setContextClassLoader(getRuntimeContext().getUserCodeClassLoader());
this.taskID = getRuntimeContext().getIndexOfThisSubtask(); this.taskID = getRuntimeContext().getIndexOfThisSubtask();
this.metaClient = StreamerUtil.createMetaClient(this.config); this.metaClient = StreamerUtil.createMetaClient(this.config);
this.writeClient = StreamerUtil.createWriteClient(this.config, getRuntimeContext()); this.writeClient = StreamerUtil.createWriteClient(this.config, getRuntimeContext());

2
hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java
View File

@@ -125,8 +125,6 @@ public abstract class AbstractStreamWriteFunction<I>
@Override @Override
public void initializeState(FunctionInitializationContext context) throws Exception { public void initializeState(FunctionInitializationContext context) throws Exception {
// always use the user classloader
Thread.currentThread().setContextClassLoader(getRuntimeContext().getUserCodeClassLoader());
this.taskID = getRuntimeContext().getIndexOfThisSubtask(); this.taskID = getRuntimeContext().getIndexOfThisSubtask();
this.metaClient = StreamerUtil.createMetaClient(this.config); this.metaClient = StreamerUtil.createMetaClient(this.config);
this.writeClient = StreamerUtil.createWriteClient(this.config, getRuntimeContext()); this.writeClient = StreamerUtil.createWriteClient(this.config, getRuntimeContext());

2
hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactFunction.java
View File

@@ -75,8 +75,6 @@ public class CompactFunction extends ProcessFunction<CompactionPlanEvent, Compac
@Override @Override
public void open(Configuration parameters) throws Exception { public void open(Configuration parameters) throws Exception {
// always use the user classloader
Thread.currentThread().setContextClassLoader(getRuntimeContext().getUserCodeClassLoader());
this.taskID = getRuntimeContext().getIndexOfThisSubtask(); this.taskID = getRuntimeContext().getIndexOfThisSubtask();
this.writeClient = StreamerUtil.createWriteClient(conf, getRuntimeContext()); this.writeClient = StreamerUtil.createWriteClient(conf, getRuntimeContext());
if (this.asyncCompaction) { if (this.asyncCompaction) {