[FLINK-16427][api] Don't throw ProgramInvocationException in RemoteSt…

…reamEnvironment

ProgramInvocationException is in flink-clients and we want to eventually
turn around the dependencies, that is flink-clients should depend on
flink-streaming-java (or some streaming translation package) and not the
other way round, as it currently is.

flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java

@@ -21,7 +21,6 @@
 import org.apache.flink.annotation.PublicEvolving;
 import org.apache.flink.api.common.JobExecutionResult;
 import org.apache.flink.api.java.RemoteEnvironmentConfigUtils;
-import org.apache.flink.client.program.ProgramInvocationException;
 import org.apache.flink.configuration.ConfigUtils;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.DeploymentOptions;
@@ -215,16 +214,7 @@ private static Configuration getEffectiveConfiguration(
 
  @Override
  public JobExecutionResult execute(StreamGraph streamGraph) throws Exception {
- try {
- return super.execute(streamGraph);
- }
- catch (ProgramInvocationException e) {
- throw e;
- }
- catch (Exception e) {
- String term = e.getMessage() == null ? "." : (": " + e.getMessage());
- throw new ProgramInvocationException("The program execution failed" + term, e);
- }
+ return super.execute(streamGraph);
  }
 
  @Override