tillrohrmann commented on a change in pull request #10491:
[FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…
URL: https://github.com/apache/flink/pull/10491#discussion_r357308569
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java
##########
@@ -68,19 +66,4 @@ private static Configuration
validateAndGetConfiguration(final Configuration con
effectiveConfiguration.set(DeploymentOptions.ATTACHED, true);
return effectiveConfiguration;
}
-
- /**
- * Executes the JobGraph of the on a mini cluster of ClusterUtil with a
user
- * specified name.
- *
- * @return The result of the job execution, containing elapsed time and
accumulators.
- */
- @Override
- public JobExecutionResult execute(StreamGraph streamGraph) throws
Exception {
- try {
- return super.execute(streamGraph);
- } finally {
- transformations.clear();
- }
- }
Review comment:
I think the problem is that this method has not been annotated with
`@Internal`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
