You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2019/07/31 11:54:45 UTC
[flink] 04/06: [hotfix][table-planner-blink] Update Blink's
ExpressionReducer classloading to Flink's behavior
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4bb72d0396051a422b628b22242256f28574e36e
Author: Timo Walther <tw...@apache.org>
AuthorDate: Mon Jul 29 11:44:49 2019 +0200
[hotfix][table-planner-blink] Update Blink's ExpressionReducer classloading to Flink's behavior
---
.../org/apache/flink/table/planner/codegen/ExpressionReducer.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExpressionReducer.scala b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExpressionReducer.scala
index 57b6fa0..bb5ff90 100644
--- a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExpressionReducer.scala
+++ b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExpressionReducer.scala
@@ -96,7 +96,7 @@ class ExpressionReducer(
resultType,
EMPTY_ROW_TYPE)
- val function = generatedFunction.newInstance(getClass.getClassLoader)
+ val function = generatedFunction.newInstance(Thread.currentThread().getContextClassLoader)
val richMapFunction = function match {
case r: RichMapFunction[GenericRow, GenericRow] => r
case _ => throw new TableException("RichMapFunction[GenericRow, GenericRow] required here")