You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/08/09 09:18:48 UTC

[flink] branch release-1.9 updated: [FLINK-13645][table-planner-blink] Fix Error in code-gen when using blink planner in scala shell

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new 65b5243  [FLINK-13645][table-planner-blink] Fix Error in code-gen when using blink planner in scala shell
65b5243 is described below

commit 65b52437588589061e4e7b868bed677a810b3574
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Thu Aug 8 11:43:58 2019 +0800

    [FLINK-13645][table-planner-blink] Fix Error in code-gen when using blink planner in scala shell
    
    This closes #9389
---
 .../org/apache/flink/table/planner/codegen/CodeGeneratorContext.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/CodeGeneratorContext.scala b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGeneratorContext.scala
index 4244fd0..8c47cb7 100644
--- a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGeneratorContext.scala
+++ b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGeneratorContext.scala
@@ -592,7 +592,7 @@ class CodeGeneratorContext(val tableConfig: TableConfig) {
     val byteArray = InstantiationUtil.serializeObject(obj)
     val objCopy: AnyRef = InstantiationUtil.deserializeObject(
       byteArray,
-      obj.getClass.getClassLoader)
+      Thread.currentThread().getContextClassLoader)
     references += objCopy
 
     reusableMemberStatements.add(s"private transient $fieldTypeTerm $fieldTerm;")