[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-04-09 Thread Aljoscha Krettek (Jira) 


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

Aljoscha Krettek updated FLINK-16533:
-
Fix Version/s: (was: 1.11.0)

> ExecutionEnvironment supports execution of existing plan
> 
>
> Key: FLINK-16533
> URL: https://issues.apache.org/jira/browse/FLINK-16533
> Project: Flink
>  Issue Type: Sub-task
>  Components: Client / Job Submission
>Reporter: godfrey he
>Priority: Major
>  Labels: pull-request-available
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> Currently, {{ExecutionEnvironment}} only supports executing the plan 
> generated by self.
> FLIP-84 proposes {{TableEnvironment}} can only trigger the table program and 
> the {{StreamExecutionEnvironment}}/{{ExecutionEnvironment}} can only trigger 
> {{DataStream}}/{{DataSet}} program. This requires that 
> {{ExecutionEnvironment}} can execute the plan generated by 
> {{TableEnvironment}}. We propose to add two methods in  
> {{ExecutionEnvironment}}: (which are similar to 
> {{StreamExecutionEnvironment}}#execute(StreamGraph) and 
> {{StreamExecutionEnvironment}}#executeAsync(StreamGraph))
> {code:java}
> public class ExecutionEnvironment {
> @Internal
> public JobExecutionResult execute(Plan plan) throws Exception {
> .
> }
> @Internal
> public JobClient executeAsync(Plan plan) throws Exception {
> .
> }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-11 Thread ASF GitHub Bot (Jira) 


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

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

> ExecutionEnvironment supports execution of existing plan
> 
>
> Key: FLINK-16533
> URL: https://issues.apache.org/jira/browse/FLINK-16533
> Project: Flink
>  Issue Type: Sub-task
>  Components: Client / Job Submission
>Reporter: godfrey he
>Priority: Major
>  Labels: pull-request-available
> Fix For: 1.11.0
>
>
> Currently, {{ExecutionEnvironment}} only supports executing the plan 
> generated by self.
> FLIP-84 proposes {{TableEnvironment}} can only trigger the table program and 
> the {{StreamExecutionEnvironment}}/{{ExecutionEnvironment}} can only trigger 
> {{DataStream}}/{{DataSet}} program. This requires that 
> {{ExecutionEnvironment}} can execute the plan generated by 
> {{TableEnvironment}}. We propose to add two methods in  
> {{ExecutionEnvironment}}: (which are similar to 
> {{StreamExecutionEnvironment}}#execute(StreamGraph) and 
> {{StreamExecutionEnvironment}}#executeAsync(StreamGraph))
> {code:java}
> public class ExecutionEnvironment {
> @Internal
> public JobExecutionResult execute(Plan plan) throws Exception {
> .
> }
> @Internal
> public JobClient executeAsync(Plan plan) throws Exception {
> .
> }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-11 Thread godfrey he (Jira) 


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

godfrey he updated FLINK-16533:
---
Description: 
Currently, {{ExecutionEnvironment}} only supports executing the plan generated 
by self.
FLIP-84 proposes {{TableEnvironment}} can only trigger the table program and 
the {{StreamExecutionEnvironment}}/{{ExecutionEnvironment}} can only trigger 
{{DataStream}}/{{DataSet}} program. This requires that {{ExecutionEnvironment}} 
can execute the plan generated by {{TableEnvironment}}. We propose to add two 
methods in  {{ExecutionEnvironment}}: (which are similar to 
{{StreamExecutionEnvironment}}#execute(StreamGraph) and 
{{StreamExecutionEnvironment}}#executeAsync(StreamGraph))

{code:java}
public class ExecutionEnvironment {
@Internal
public JobExecutionResult execute(Plan plan) throws Exception {
.
}

@Internal
public JobClient executeAsync(Plan plan) throws Exception {
.
}
}
{code}






  was:
Currently, {{ExecutionEnvironment}} only supports executing the plan generated 
by self.
FLIP-84 proposes {{TableEnvironment}} can only trigger the table program and 
the {{StreamExecutionEnvironment}}/{{ExecutionEnvironment}} can only trigger 
{{DataStream}}/{{DataSet}} program. This requires that {{ExecutionEnvironment}} 
can execute the plan generated by {{TableEnvironment}}. We propose to add two 
methods in  {{ExecutionEnvironment}}: (which is similar to 
{{StreamExecutionEnvironment}}#execute(StreamGraph) and 
{{StreamExecutionEnvironment}}#executeAsync(StreamGraph))

{code:java}
public class ExecutionEnvironment {
@Internal
public JobExecutionResult execute(Plan plan) throws Exception {
.
}

@Internal
public JobClient executeAsync(Plan plan) throws Exception {
.
}
}
{code}







> ExecutionEnvironment supports execution of existing plan
> 
>
> Key: FLINK-16533
> URL: https://issues.apache.org/jira/browse/FLINK-16533
> Project: Flink
>  Issue Type: Sub-task
>  Components: Client / Job Submission
>Reporter: godfrey he
>Priority: Major
> Fix For: 1.11.0
>
>
> Currently, {{ExecutionEnvironment}} only supports executing the plan 
> generated by self.
> FLIP-84 proposes {{TableEnvironment}} can only trigger the table program and 
> the {{StreamExecutionEnvironment}}/{{ExecutionEnvironment}} can only trigger 
> {{DataStream}}/{{DataSet}} program. This requires that 
> {{ExecutionEnvironment}} can execute the plan generated by 
> {{TableEnvironment}}. We propose to add two methods in  
> {{ExecutionEnvironment}}: (which are similar to 
> {{StreamExecutionEnvironment}}#execute(StreamGraph) and 
> {{StreamExecutionEnvironment}}#executeAsync(StreamGraph))
> {code:java}
> public class ExecutionEnvironment {
> @Internal
> public JobExecutionResult execute(Plan plan) throws Exception {
> .
> }
> @Internal
> public JobClient executeAsync(Plan plan) throws Exception {
> .
> }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-10 Thread godfrey he (Jira) 


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

godfrey he updated FLINK-16533:
---
Summary: ExecutionEnvironment supports execution of existing plan  (was: 
ExecutionEnvironment supports executing plan)

> ExecutionEnvironment supports execution of existing plan
> 
>
> Key: FLINK-16533
> URL: https://issues.apache.org/jira/browse/FLINK-16533
> Project: Flink
>  Issue Type: Sub-task
>  Components: Client / Job Submission
>Reporter: godfrey he
>Priority: Major
> Fix For: 1.11.0
>
>
> Currently, {{ExecutionEnvironment}} only supports executing the plan 
> generated by self.
> FLIP-84 proposes {{TableEnvironment}} can only trigger the table program and 
> the {{StreamExecutionEnvironment}}/{{ExecutionEnvironment}} can only trigger 
> {{DataStream}}/{{DataSet}} program. This requires that 
> {{ExecutionEnvironment}} can execute the plan generated by 
> {{TableEnvironment}}. We propose to add two methods in  
> {{ExecutionEnvironment}}: (which is similar to 
> {{StreamExecutionEnvironment}}#execute(StreamGraph) and 
> {{StreamExecutionEnvironment}}#executeAsync(StreamGraph))
> {code:java}
> public class ExecutionEnvironment {
> @Internal
> public JobExecutionResult execute(Plan plan) throws Exception {
> .
> }
> @Internal
> public JobClient executeAsync(Plan plan) throws Exception {
> .
> }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)