[jira] [Created] (FLINK-12507) Fix AsyncLookupJoin doesn't close all generated ResultFutures

[Shang Yuanchun (Jira)]

Jark Wu created FLINK-12507:
-------------------------------

             Summary: Fix AsyncLookupJoin doesn't close all generated ResultFutures
                 Key: FLINK-12507
                 URL: https://issues.apache.org/jira/browse/FLINK-12507
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Runtime
            Reporter: Jark Wu
            Assignee: Jark Wu


There is a fragile test in AsyncLookupJoinITCase, that not all the udfs are closed at the end.

{code:java}
02:40:48.787 [ERROR] Tests run: 22, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 47.098 s <<< FAILURE! - in org.apache.flink.table.runtime.stream.sql.AsyncLookupJoinITCase
02:40:48.791 [ERROR] testAsyncJoinTemporalTableWithUdfFilter[StateBackend=HEAP](org.apache.flink.table.runtime.stream.sql.AsyncLookupJoinITCase)  Time elapsed: 1.266 s  <<< FAILURE!
java.lang.AssertionError: expected:<0> but was:<2>
        at org.apache.flink.table.runtime.stream.sql.AsyncLookupJoinITCase.testAsyncJoinTemporalTableWithUdfFilter(AsyncLookupJoinITCase.scala:268)

02:40:48.794 [ERROR] testAsyncJoinTemporalTableWithUdfFilter[StateBackend=ROCKSDB](org.apache.flink.table.runtime.stream.sql.AsyncLookupJoinITCase)  Time elapsed: 1.033 s  <<< FAILURE!
java.lang.AssertionError: expected:<0> but was:<2>
        at org.apache.flink.table.runtime.stream.sql.AsyncLookupJoinITCase.testAsyncJoinTemporalTableWithUdfFilter(AsyncLookupJoinITCase.scala:268)
{code}




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)