[ 
https://issues.apache.org/jira/browse/FLINK-12507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-12507:
-----------------------------------
    Labels: pull-request-available  (was: )

> 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
>            Priority: Major
>              Labels: pull-request-available
>
> 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)

Reply via email to