[ 
https://issues.apache.org/jira/browse/FLINK-5490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022834#comment-16022834
 ] 

Deepak Marathe commented on FLINK-5490:
---------------------------------------

Closed and reopened the pull request, as the CI build failed seemingly because 
of network issues.
 
{quote}
[INFO] Building flink-examples-streaming 1.4-SNAPSHOT
[INFO] ------------------------------------------------------------------------
[INFO] Downloading: 
https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-dependency-plugin/2.9/maven-dependency-plugin-2.9.pom
May 24, 2017 10:48:51 AM 
org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec 
execute
INFO: I/O exception (java.net.SocketException) caught when processing request 
to {s}->https://repo.maven.apache.org:443: Connection reset
May 24, 2017 10:48:51 AM 
org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec 
execute
INFO: Retrying request to {s}->https://repo.maven.apache.org:443
May 24, 2017 10:48:51 AM 
org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec 
execute
INFO: I/O exception (java.net.SocketException) caught when processing request 
to {s}->https://repo.maven.apache.org:443: Connection reset
May 24, 2017 10:48:51 AM 
org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec 
execute
INFO: Retrying request to {s}->https://repo.maven.apache.org:443
May 24, 2017 10:48:51 AM 
org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec 
execute
INFO: I/O exception (java.net.SocketException) caught when processing request 
to {s}->https://repo.maven.apache.org:443: Connection reset
May 24, 2017 10:48:51 AM 
org.apache.maven.wagon.providers.http.httpclient.impl.execchain.RetryExec 
execute
INFO: Retrying request to {s}->https://repo.maven.apache.org:443
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO] 
[INFO] force-shading ...................................... SUCCESS [  9.674 s]
[INFO] flink .............................................. SUCCESS [ 10.506 s]
[INFO] flink-annotations .................................. SUCCESS [ 11.990 s]
[INFO] flink-shaded-hadoop ................................ SUCCESS [  0.666 s]
[INFO] flink-shaded-hadoop2 ............................... SUCCESS [ 18.089 s]
[INFO] flink-shaded-hadoop2-uber .......................... SUCCESS [ 15.561 s]
[INFO] flink-shaded-include-yarn-tests .................... SUCCESS [ 22.208 s]
[INFO] flink-shaded-curator ............................... SUCCESS [  0.293 s]
[INFO] flink-shaded-curator-recipes ....................... SUCCESS [  3.807 s]
[INFO] flink-shaded-curator-test .......................... SUCCESS [  1.877 s]
[INFO] flink-metrics ...................................... SUCCESS [  0.201 s]
[INFO] flink-metrics-core ................................. SUCCESS [  3.323 s]
[INFO] flink-test-utils-parent ............................ SUCCESS [  0.228 s]
[INFO] flink-test-utils-junit ............................. SUCCESS [  1.197 s]
[INFO] flink-core ......................................... SUCCESS [ 33.048 s]
[INFO] flink-java ......................................... SUCCESS [ 14.245 s]
[INFO] flink-runtime ...................................... SUCCESS [07:43 min]
[INFO] flink-optimizer .................................... SUCCESS [  9.404 s]
[INFO] flink-clients ...................................... SUCCESS [ 10.795 s]
[INFO] flink-streaming-java ............................... SUCCESS [01:14 min]
[INFO] flink-test-utils ................................... SUCCESS [  8.713 s]
[INFO] flink-scala ........................................ SUCCESS [01:06 min]
[INFO] flink-runtime-web .................................. SUCCESS [ 14.791 s]
[INFO] flink-examples-batch ............................... SUCCESS [ 22.360 s]
[INFO] flink-connectors ................................... SUCCESS [  0.270 s]
[INFO] flink-hadoop-compatibility ......................... SUCCESS [ 26.131 s]
[INFO] flink-avro ......................................... SUCCESS [ 20.002 s]
[INFO] flink-contrib ...................................... SUCCESS [  0.295 s]
[INFO] flink-statebackend-rocksdb ......................... SUCCESS [  1.502 s]
[INFO] flink-tests ........................................ SUCCESS [11:03 min]
[INFO] flink-streaming-scala .............................. SUCCESS [01:01 min]
[INFO] flink-libraries .................................... SUCCESS [  0.200 s]
[INFO] flink-table ........................................ SUCCESS [03:22 min]
[INFO] flink-jdbc ......................................... SUCCESS [  0.729 s]
[INFO] flink-hbase ........................................ SUCCESS [ 47.838 s]
[INFO] flink-hcatalog ..................................... SUCCESS [ 10.695 s]
[INFO] flink-metrics-jmx .................................. SUCCESS [  3.416 s]
[INFO] flink-connector-kafka-base ......................... SUCCESS [  7.068 s]
[INFO] flink-connector-kafka-0.8 .......................... SUCCESS [  3.731 s]
[INFO] flink-connector-kafka-0.9 .......................... SUCCESS [  3.857 s]
[INFO] flink-connector-kafka-0.10 ......................... SUCCESS [  1.699 s]
[INFO] flink-connector-elasticsearch-base ................. SUCCESS [  4.803 s]
[INFO] flink-connector-elasticsearch ...................... SUCCESS [ 11.896 s]
[INFO] flink-connector-elasticsearch2 ..................... SUCCESS [ 16.505 s]
[INFO] flink-connector-rabbitmq ........................... SUCCESS [  0.538 s]
[INFO] flink-connector-twitter ............................ SUCCESS [  2.470 s]
[INFO] flink-connector-nifi ............................... SUCCESS [  0.994 s]
[INFO] flink-connector-cassandra .......................... SUCCESS [02:05 min]
[INFO] flink-connector-filesystem ......................... SUCCESS [ 25.567 s]
[INFO] flink-connector-kinesis ............................ SUCCESS [ 15.893 s]
[INFO] flink-connector-elasticsearch5 ..................... SUCCESS [ 17.636 s]
[INFO] flink-examples-streaming ........................... FAILURE [  0.035 s]
{quote}


> ContextEnvironment.getExecutionPlan() clears Sinks
> --------------------------------------------------
>
>                 Key: FLINK-5490
>                 URL: https://issues.apache.org/jira/browse/FLINK-5490
>             Project: Flink
>          Issue Type: Bug
>          Components: Client
>            Reporter: Robert Schmidtke
>            Priority: Trivial
>
> Getting the execution plan via the ExecutionEnvironment causes the sinks to 
> be cleared, effectively resulting in the situation that it is impossible to 
> first obtain the execution plan, and then execute it. Passing false to 
> https://github.com/apache/flink/blob/master/flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java#L68
>  should fix this.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to