Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Cleaning up

Browse source
This commit is contained in:
Lee moon soo 2015-05-11 19:43:52 +02:00
parent f2a66df49e
commit 27fc306a35
1 changed files with 0 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
flink/src/main/java/org/apache/zeppelin/flink/FlinkInterpreter.java
View file

@ -19,7 +19,6 @@ package org.apache.zeppelin.flink;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLClassLoader;
@ -29,7 +28,6 @@ import java.util.Map;
import java.util.Properties;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.client.program.Client;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster;
import org.apache.zeppelin.interpreter.Interpreter;
@ -56,12 +54,10 @@ public class FlinkInterpreter extends Interpreter {
private Settings settings;
private ByteArrayOutputStream out;
private FlinkIMain imain;
private File classDir;
private Map<String, Object> binder;
private ExecutionEnvironment env;
private Configuration flinkConf;
private LocalFlinkMiniCluster localFlinkCluster;
private Client client;
public FlinkInterpreter(Properties property) {
super(property);
@ -235,7 +231,6 @@ public class FlinkInterpreter extends Interpreter {
linesToRun[lines.length] = "print(\"\")";
Console.setOut(out);
System.setOut(new PrintStream(out));
out.reset();
Code r = null;