[jira] [Updated] (FLINK-27631) Datastream job combined with table job

2022-05-16 Thread waywtdcc (Jira)


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

waywtdcc updated FLINK-27631:
-
Affects Version/s: 1.13.6
   (was: 1.14.4)

> Datastream job combined with table job
> --
>
> Key: FLINK-27631
> URL: https://issues.apache.org/jira/browse/FLINK-27631
> Project: Flink
>  Issue Type: Bug
>  Components: API / DataStream, Table SQL / API
>Affects Versions: 1.13.6
>Reporter: waywtdcc
>Priority: Major
> Attachments: image-2022-05-16-14-57-09-836.png
>
>
> Datastream job combined with table job
> One datastream, write two sink, one uses datastream API: datastream 
> addSink(..); After another SQL: insert is used, it is converted to another 
> table_ table from table1; Perform the task like this without using 
> streamexecutionenvironment Execute() executes the addsink operator task, but 
> cannot execute the SQL task; Do not use streamtableenvironment Executesql(), 
> but the addsink operator task will not be executed. If two 
> streamexecutionenvironment Execute() and streamtableenvironment If 
> executesql() is written, two tasks will be executed. Is there any way to put 
> two sink in one task?
>  
> !image-2022-05-16-14-57-09-836.png!



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


[jira] [Updated] (FLINK-27631) Datastream job combined with table job

2022-05-16 Thread waywtdcc (Jira)


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

waywtdcc updated FLINK-27631:
-
Affects Version/s: 1.14.4
   (was: 1.13.6)

> Datastream job combined with table job
> --
>
> Key: FLINK-27631
> URL: https://issues.apache.org/jira/browse/FLINK-27631
> Project: Flink
>  Issue Type: Bug
>  Components: API / DataStream, Table SQL / API
>Affects Versions: 1.14.4
>Reporter: waywtdcc
>Priority: Major
> Attachments: image-2022-05-16-14-57-09-836.png
>
>
> Datastream job combined with table job
> One datastream, write two sink, one uses datastream API: datastream 
> addSink(..); After another SQL: insert is used, it is converted to another 
> table_ table from table1; Perform the task like this without using 
> streamexecutionenvironment Execute() executes the addsink operator task, but 
> cannot execute the SQL task; Do not use streamtableenvironment Executesql(), 
> but the addsink operator task will not be executed. If two 
> streamexecutionenvironment Execute() and streamtableenvironment If 
> executesql() is written, two tasks will be executed. Is there any way to put 
> two sink in one task?
>  
> !image-2022-05-16-14-57-09-836.png!



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


[jira] [Updated] (FLINK-27631) Datastream job combined with table job

2022-05-16 Thread waywtdcc (Jira)


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

waywtdcc updated FLINK-27631:
-
Description: 
Datastream job combined with table job

One datastream, write two sink, one uses datastream API: datastream 
addSink(..); After another SQL: insert is used, it is converted to another 
table_ table from table1; Perform the task like this without using 
streamexecutionenvironment Execute() executes the addsink operator task, but 
cannot execute the SQL task; Do not use streamtableenvironment Executesql(), 
but the addsink operator task will not be executed. If two 
streamexecutionenvironment Execute() and streamtableenvironment If executesql() 
is written, two tasks will be executed. Is there any way to put two sink in one 
task?

 

!image-2022-05-16-14-57-09-836.png!

  was:
Datastream job combined with table job

One datastream, write two sink, one uses datastream API: datastream 
addSink(..); After another SQL: insert is used, it is converted to another 
table_ table from table1; Can these two writes be put into one task?

 

!image-2022-05-16-14-57-09-836.png!


> Datastream job combined with table job
> --
>
> Key: FLINK-27631
> URL: https://issues.apache.org/jira/browse/FLINK-27631
> Project: Flink
>  Issue Type: Bug
>  Components: API / DataStream, Table SQL / API
>Affects Versions: 1.13.6
>Reporter: waywtdcc
>Priority: Major
> Attachments: image-2022-05-16-14-57-09-836.png
>
>
> Datastream job combined with table job
> One datastream, write two sink, one uses datastream API: datastream 
> addSink(..); After another SQL: insert is used, it is converted to another 
> table_ table from table1; Perform the task like this without using 
> streamexecutionenvironment Execute() executes the addsink operator task, but 
> cannot execute the SQL task; Do not use streamtableenvironment Executesql(), 
> but the addsink operator task will not be executed. If two 
> streamexecutionenvironment Execute() and streamtableenvironment If 
> executesql() is written, two tasks will be executed. Is there any way to put 
> two sink in one task?
>  
> !image-2022-05-16-14-57-09-836.png!



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