[jira] [Created] (FLINK-22742) Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException

[Shang Yuanchun (Jira)]

Caizhi Weng created FLINK-22742:
-----------------------------------

             Summary: Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException
                 Key: FLINK-22742
                 URL: https://issues.apache.org/jira/browse/FLINK-22742
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Runtime
    Affects Versions: 1.13.0, 1.12.0, 1.14.0
            Reporter: Caizhi Weng


Add the following test case to {{org.apache.flink.table.api.TableEnvironmentITCase}} to reproduce this bug.

{code:scala}
@Test
def myTest(): Unit = {
  val id1 = TestValuesTableFactory.registerData(
    Seq(Row.of("abc", LocalDateTime.of(2000, 1, 1, 0, 0))))
  val ddl1 =
    s"""
       |CREATE TABLE Ta (
       |  id VARCHAR,
       |  ts TIMESTAMP,
       |  proc AS PROCTIME()
       |) WITH (
       |  'connector' = 'values',
       |  'data-id' = '$id1',
       |  'bounded' = 'true'
       |)
       |""".stripMargin
  tEnv.executeSql(ddl1)

  val id2 = TestValuesTableFactory.registerData(
    Seq(Row.of("abc", LocalDateTime.of(2000, 1, 2, 0, 0))))
  val ddl2 =
    s"""
       |CREATE TABLE Tb (
       |  id VARCHAR,
       |  ts TIMESTAMP
       |) WITH (
       |  'connector' = 'values',
       |  'data-id' = '$id2',
       |  'bounded' = 'true'
       |)
       |""".stripMargin
  tEnv.executeSql(ddl2)

  val it = tEnv.executeSql(
    """
      |SELECT * FROM Ta AS t1
      |INNER JOIN Tb FOR SYSTEM_TIME AS OF t1.proc AS t2
      |ON t1.id = t2.id
      |WHERE CAST(coalesce(t1.ts, t2.ts) AS VARCHAR) >= CONCAT(DATE_FORMAT(t1.proc, 'yyyy-MM-dd'), ' 00:00:00')
      |""".stripMargin).collect()

  while (it.hasNext) {
    System.out.println(it.next())
  }
}
{code}

The exception stack is
{code}
/* 1 */
/* 2 */      public class JoinTableFuncCollector$25 extends org.apache.flink.table.runtime.collector.TableFunctionCollector {
/* 3 */
/* 4 */        org.apache.flink.table.data.GenericRowData out = new org.apache.flink.table.data.GenericRowData(2);
/* 5 */org.apache.flink.table.data.utils.JoinedRowData joinedRow$9 = new org.apache.flink.table.data.utils.JoinedRowData();
/* 6 */
/* 7 */private final org.apache.flink.table.data.binary.BinaryStringData str$17 = org.apache.flink.table.data.binary.BinaryStringData.fromString("yyyy-MM-dd");
/* 8 */          
/* 9 */private static final java.util.TimeZone timeZone =
/* 10 */                 java.util.TimeZone.getTimeZone("Asia/Shanghai");
/* 11 */
/* 12 */private final org.apache.flink.table.data.binary.BinaryStringData str$20 = org.apache.flink.table.data.binary.BinaryStringData.fromString(" 00:00:00");
/* 13 */          
/* 14 */
/* 15 */        public JoinTableFuncCollector$25(Object[] references) throws Exception {
/* 16 */          
/* 17 */        }
/* 18 */
/* 19 */        @Override
/* 20 */        public void open(org.apache.flink.configuration.Configuration parameters) throws Exception {
/* 21 */          
/* 22 */        }
/* 23 */
/* 24 */        @Override
/* 25 */        public void collect(Object record) throws Exception {
/* 26 */          org.apache.flink.table.data.RowData in1 = (org.apache.flink.table.data.RowData) getInput();
/* 27 */          org.apache.flink.table.data.RowData in2 = (org.apache.flink.table.data.RowData) record;
/* 28 */          
/* 29 */          org.apache.flink.table.data.binary.BinaryStringData field$7;
/* 30 */boolean isNull$7;
/* 31 */org.apache.flink.table.data.TimestampData field$8;
/* 32 */boolean isNull$8;
/* 33 */org.apache.flink.table.data.TimestampData field$10;
/* 34 */boolean isNull$10;
/* 35 */boolean isNull$13;
/* 36 */org.apache.flink.table.data.binary.BinaryStringData result$14;
/* 37 */org.apache.flink.table.data.TimestampData field$15;
/* 38 */boolean isNull$15;
/* 39 */org.apache.flink.table.data.TimestampData result$16;
/* 40 */boolean isNull$18;
/* 41 */org.apache.flink.table.data.binary.BinaryStringData result$19;
/* 42 */boolean isNull$21;
/* 43 */org.apache.flink.table.data.binary.BinaryStringData result$22;
/* 44 */boolean isNull$23;
/* 45 */boolean result$24;
/* 46 */          isNull$15 = in1.isNullAt(2);
/* 47 */field$15 = null;
/* 48 */if (!isNull$15) {
/* 49 */  field$15 = in1.getTimestamp(2, 3);
/* 50 */}
/* 51 */isNull$8 = in2.isNullAt(1);
/* 52 */field$8 = null;
/* 53 */if (!isNull$8) {
/* 54 */  field$8 = in2.getTimestamp(1, 6);
/* 55 */}
/* 56 */isNull$7 = in2.isNullAt(0);
/* 57 */field$7 = org.apache.flink.table.data.binary.BinaryStringData.EMPTY_UTF8;
/* 58 */if (!isNull$7) {
/* 59 */  field$7 = ((org.apache.flink.table.data.binary.BinaryStringData) in2.getString(0));
/* 60 */}
/* 61 */isNull$10 = in1.isNullAt(1);
/* 62 */field$10 = null;
/* 63 */if (!isNull$10) {
/* 64 */  field$10 = in1.getTimestamp(1, 6);
/* 65 */}
/* 66 */          
/* 67 */
/* 68 */
/* 69 */boolean result$11 = !isNull$10;
/* 70 */org.apache.flink.table.data.TimestampData result$12 = null;
/* 71 */boolean isNull$12;
/* 72 */if (result$11) {
/* 73 */  
/* 74 */  isNull$12 = isNull$10;
/* 75 */  if (!isNull$12) {
/* 76 */    result$12 = field$10;
/* 77 */  }
/* 78 */}
/* 79 */else {
/* 80 */  
/* 81 */  isNull$12 = isNull$8;
/* 82 */  if (!isNull$12) {
/* 83 */    result$12 = field$8;
/* 84 */  }
/* 85 */}
/* 86 */isNull$13 = isNull$12;
/* 87 */result$14 = org.apache.flink.table.data.binary.BinaryStringData.EMPTY_UTF8;
/* 88 */if (!isNull$13) {
/* 89 */  
/* 90 */  result$14 = org.apache.flink.table.data.binary.BinaryStringData.fromString(org.apache.flink.table.runtime.functions.SqlDateTimeUtils.timestampToString(result$12, 6));
/* 91 */  isNull$13 = (result$14 == null);
/* 92 */}
/* 93 */
/* 94 */
/* 95 */
/* 96 */result$16 = org.apache.flink.table.data.TimestampData.fromEpochMillis(
/* 97 */  ctx.timerService().currentProcessingTime());
/* 98 */
/* 99 */isNull$18 = false || false;
/* 100 */result$19 = org.apache.flink.table.data.binary.BinaryStringData.EMPTY_UTF8;
/* 101 */if (!isNull$18) {
/* 102 */  
/* 103 */  result$19 = org.apache.flink.table.data.binary.BinaryStringData.fromString(
/* 104 */org.apache.flink.table.runtime.functions.SqlDateTimeUtils.dateFormat(result$16, ((org.apache.flink.table.data.binary.BinaryStringData) str$17).toString(), timeZone)
/* 105 */           );
/* 106 */  isNull$18 = (result$19 == null);
/* 107 */}
/* 108 */
/* 109 */
/* 110 */result$22 = org.apache.flink.table.data.binary.BinaryStringDataUtil.concat(( isNull$18 ) ? null : (result$19), ( false ) ? null : (((org.apache.flink.table.data.binary.BinaryStringData) str$20)));
/* 111 */isNull$21 = (result$22 == null);
/* 112 */if (isNull$21) {
/* 113 */  result$22 = org.apache.flink.table.data.binary.BinaryStringData.EMPTY_UTF8;
/* 114 */}
/* 115 */      
/* 116 */isNull$23 = isNull$13 || isNull$21;
/* 117 */result$24 = false;
/* 118 */if (!isNull$23) {
/* 119 */  
/* 120 */  result$24 = ((result$14 == null) ? ((result$22 == null) ? 0 : -1) : ((result$22 == null) ? 1 : (result$14.compareTo(result$22)))) >= 0;
/* 121 */  
/* 122 */}
/* 123 */
/* 124 */if (result$24) {
/* 125 */  
/* 126 */
/* 127 */
/* 128 */
/* 129 */
/* 130 */if (isNull$7) {
/* 131 */  out.setField(0, null);
/* 132 */} else {
/* 133 */  out.setField(0, field$7);
/* 134 */}
/* 135 */          
/* 136 */
/* 137 */
/* 138 */if (isNull$8) {
/* 139 */  out.setField(1, null);
/* 140 */} else {
/* 141 */  out.setField(1, field$8);
/* 142 */}
/* 143 */          
/* 144 */        
/* 145 */joinedRow$9.replace(in1, out);
/* 146 */joinedRow$9.setRowKind(in1.getRowKind());
/* 147 */outputResult(joinedRow$9);
/* 148 */      
/* 149 */}
/* 150 */
/* 151 */        }
/* 152 */
/* 153 */        @Override
/* 154 */        public void close() throws Exception {
/* 155 */          
/* 156 */        }
/* 157 */      }
/* 158 */    


java.lang.RuntimeException: Failed to fetch next result

        at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
        at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
        at org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370)
        at org.apache.flink.table.api.TableEnvironmentITCase.myTest(TableEnvironmentITCase.scala:129)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
        at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
        at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
        at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
        at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
        at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:239)
        at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
        at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
        at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
        at org.junit.rules.RunRules.evaluate(RunRules.java:20)
        at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
        at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
        at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
        at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
        at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
        at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
        at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
        at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
        at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
        at org.junit.runners.Suite.runChild(Suite.java:128)
        at org.junit.runners.Suite.runChild(Suite.java:27)
        at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
        at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
        at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
        at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
        at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
        at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
        at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
        at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
        at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
        at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:230)
        at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:58)
Caused by: java.io.IOException: Failed to fetch job execution result
        at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:177)
        at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:120)
        at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
        ... 39 more
Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
        at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
        at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)
        at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:175)
        ... 41 more
Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
        at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
        at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
        at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602)
        at java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:614)
        at java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1983)
        at org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:134)
        at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:174)
        ... 41 more
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
        at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:207)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:197)
        at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:188)
        at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:677)
        at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
        at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
        at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
        at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
        at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
        at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
        at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
        at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
        at akka.actor.ActorCell.invoke(ActorCell.scala:561)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
        at akka.dispatch.Mailbox.run(Mailbox.scala:225)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
        at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.RuntimeException: Could not instantiate generated class 'JoinTableFuncCollector$25'
        at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:59)
        at org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.open(LookupJoinRunner.java:63)
        at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
        at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
        at org.apache.flink.streaming.api.operators.ProcessOperator.open(ProcessOperator.java:56)
        at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:437)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:582)
        at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:562)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537)
        at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
        at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.flink.util.FlinkRuntimeException: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.
        at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:76)
        at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:80)
        at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:53)
        ... 13 more
Caused by: org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
        at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74)
        ... 15 more
Caused by: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.
        at org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:89)
        at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
        at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
        ... 18 more
Caused by: org.codehaus.commons.compiler.CompileException: Line 97, Column 6: Unknown variable or type "ctx"
        at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12211)
        at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6860)
        at org.codehaus.janino.UnitCompiler.access$13600(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$22.visitPackage(UnitCompiler.java:6472)
        at org.codehaus.janino.UnitCompiler$22.visitPackage(UnitCompiler.java:6469)
        at org.codehaus.janino.Java$Package.accept(Java.java:4248)
        at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
        at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6855)
        at org.codehaus.janino.UnitCompiler.access$14200(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$22$2$1.visitAmbiguousName(UnitCompiler.java:6497)
        at org.codehaus.janino.UnitCompiler$22$2$1.visitAmbiguousName(UnitCompiler.java:6494)
        at org.codehaus.janino.Java$AmbiguousName.accept(Java.java:4224)
        at org.codehaus.janino.UnitCompiler$22$2.visitLvalue(UnitCompiler.java:6494)
        at org.codehaus.janino.UnitCompiler$22$2.visitLvalue(UnitCompiler.java:6490)
        at org.codehaus.janino.Java$Lvalue.accept(Java.java:4148)
        at org.codehaus.janino.UnitCompiler$22.visitRvalue(UnitCompiler.java:6490)
        at org.codehaus.janino.UnitCompiler$22.visitRvalue(UnitCompiler.java:6469)
        at org.codehaus.janino.Java$Rvalue.accept(Java.java:4116)
        at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
        at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9026)
        at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7106)
        at org.codehaus.janino.UnitCompiler.access$15800(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$22$2.visitMethodInvocation(UnitCompiler.java:6517)
        at org.codehaus.janino.UnitCompiler$22$2.visitMethodInvocation(UnitCompiler.java:6490)
        at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073)
        at org.codehaus.janino.UnitCompiler$22.visitRvalue(UnitCompiler.java:6490)
        at org.codehaus.janino.UnitCompiler$22.visitRvalue(UnitCompiler.java:6469)
        at org.codehaus.janino.Java$Rvalue.accept(Java.java:4116)
        at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
        at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9026)
        at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7106)
        at org.codehaus.janino.UnitCompiler.access$15800(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$22$2.visitMethodInvocation(UnitCompiler.java:6517)
        at org.codehaus.janino.UnitCompiler$22$2.visitMethodInvocation(UnitCompiler.java:6490)
        at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073)
        at org.codehaus.janino.UnitCompiler$22.visitRvalue(UnitCompiler.java:6490)
        at org.codehaus.janino.UnitCompiler$22.visitRvalue(UnitCompiler.java:6469)
        at org.codehaus.janino.Java$Rvalue.accept(Java.java:4116)
        at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
        at org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9237)
        at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9123)
        at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9025)
        at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5062)
        at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4423)
        at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4396)
        at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073)
        at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396)
        at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662)
        at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3792)
        at org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3754)
        at org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3734)
        at org.codehaus.janino.Java$Assignment.accept(Java.java:4477)
        at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3734)
        at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2360)
        at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1494)
        at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1487)
        at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2874)
        at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
        at org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
        at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3388)
        at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1357)
        at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
        at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822)
        at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432)
        at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215)
        at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
        at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
        at org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
        at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406)
        at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378)
        at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237)
        at org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
        at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
        at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
        at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
        at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
        at org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:86)
        ... 24 more
{code}

This is because {{LookupJoinCodeGenerator#generateTableFunctionCollectorForJoinTable}} doesn't add a {{ctx}} member to its generated class.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)