[
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)