[jira] [Created] (FLINK-27638) failed to join with table function

["Spongebob (Jira)" <ji...@apache.org>]

Spongebob created FLINK-27638:
---------------------------------

             Summary: failed to join with table function
                 Key: FLINK-27638
                 URL: https://issues.apache.org/jira/browse/FLINK-27638
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API
    Affects Versions: 1.14.3
            Reporter: Spongebob
         Attachments: image-2022-05-16-19-08-25-477.png, image-2022-05-16-19-08-50-286.png

# regiseter one table function named `GET_STREAMING_MODEL_SINK_FILTER`
 # create two flinksql complexible DML that both inner join with the table functioin.
 # schedule the two DML in one submission based on statementSet.

atfer these steps I found that the table function was run on one exclusive task and it turned to be finished in serveral seconds. And the two DML had not any output after the inner join with that table function.

Appendix `image-2022-05-16-19-08-25-477.png` shows the schedule graph of this situation. And appendix `image-2022-05-16-19-08-50-286.png` shows the expected graph when using table function.

!image-2022-05-16-19-08-25-477.png!

 

!image-2022-05-16-19-08-50-286.png!



--
This message was sent by Atlassian Jira
(v8.20.7#820007)