[flink] 02/04: [hotfix][table-planner] Use scala isInstanceOf to check lookup function type instead of one-level parent class compartion in LookupJoinCodeGenerator

[godfrey]

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

godfrey pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit fa6d62dd6bbaa3876656a97ff519e37f9a3f0730
Author: lincoln lee <lincoln.8...@gmail.com>
AuthorDate: Tue Aug 9 16:59:00 2022 +0800

    [hotfix][table-planner] Use scala isInstanceOf to check lookup function 
type instead of one-level parent class compartion in LookupJoinCodeGenerator
    
    This bug can be reproduced by 
AsyncLookupJoinITCase#testAsyncJoinTemporalTableWithLookupThresholdWithInsufficientRetry
 when caching is disabled in FLINK-28849
    
    This closes #20482
---
 .../apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala
 
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala
index bc2fb42b4c4..8f1818af6a5 100644
--- 
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala
+++ 
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala
@@ -250,10 +250,7 @@ object LookupJoinCodeGenerator {
         val defaultOutputDataType = callContext.getOutputDataType.get()
 
         val outputClass =
-          if (
-            udf.getClass.getSuperclass == classOf[LookupFunction]
-            || udf.getClass.getSuperclass == classOf[AsyncLookupFunction]
-          ) {
+          if (udf.isInstanceOf[LookupFunction] || 
udf.isInstanceOf[AsyncLookupFunction]) {
             Some(classOf[RowData])
           } else {
             toScala(extractSimpleGeneric(baseClass, udf.getClass, 0))