leekeiabstraction commented on code in PR #29418:
URL: https://github.com/apache/flink/pull/29418#discussion_r4208189897
##########
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/CodeGenOperatorFactory.java:
##########
@@ -36,9 +37,13 @@ public CodeGenOperatorFactory(GeneratedClass<? extends
StreamOperator<OUT>> gene
@Override
public <T extends StreamOperator<OUT>> T createStreamOperator(
StreamOperatorParameters<OUT> parameters) {
+ final ClassLoader userCodeClassLoader =
+ parameters.getContainingTask().getUserCodeClassLoader();
+ // one-shot background Janino warm-up (the first cold compile on a TM
is not sped up)
+ CompileUtils.warmUp();
Review Comment:
+1 on it being a static block in CompileUtils. We'd still need to trigger
the classloading (and static block run) of CompileUtils somewhere though.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
