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)

Reply via email to