diff --git a/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java b/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java
index 1a0469a034d..10d12dbb5b9 100644
--- a/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java
+++ b/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java
@@ -138,8 +138,10 @@ public InterpreterResult interpret(String cmd, InterpreterContext contextInterpr
       return new InterpreterResult(Code.SUCCESS, "");
     }
     String output = sendCommandToPython(cmd);
-    return new InterpreterResult(Code.SUCCESS, output.replaceAll(">>>", "")
-        .replaceAll("\\.\\.\\.", "").trim());
+
+    // TODO(zjffdu), we should not do string replacement operation in the result, as it is
+    // possible that the output contains the kind of pattern itself, e.g. print("...")
+    return new InterpreterResult(Code.SUCCESS, output.replaceAll("\\.\\.\\.", ""));
   }
 
   @Override
diff --git a/python/src/main/java/org/apache/zeppelin/python/PythonProcess.java b/python/src/main/java/org/apache/zeppelin/python/PythonProcess.java
index a6712240f46..8eaf5e74dd8 100644
--- a/python/src/main/java/org/apache/zeppelin/python/PythonProcess.java
+++ b/python/src/main/java/org/apache/zeppelin/python/PythonProcess.java
@@ -21,12 +21,11 @@
 import org.slf4j.LoggerFactory;
 
 import java.io.BufferedReader;
-import java.io.BufferedWriter;
 import java.io.InputStream;
-import java.io.OutputStream;
 import java.io.IOException;
-import java.io.OutputStreamWriter;
 import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.io.OutputStream;
 import java.lang.reflect.Field;
 
 /**
@@ -35,11 +34,11 @@
  */
 
 public class PythonProcess {
-
-  Logger logger = LoggerFactory.getLogger(PythonProcess.class);
+  private static final Logger logger = LoggerFactory.getLogger(PythonProcess.class);
+  private static final String STATEMENT_END = "*!?flush reader!?*";
   InputStream stdout;
   OutputStream stdin;
-  BufferedWriter writer;
+  PrintWriter writer;
   BufferedReader reader;
   Process process;
   private String binPath;
@@ -56,7 +55,7 @@ public void open() throws IOException {
     process = builder.start();
     stdout = process.getInputStream();
     stdin = process.getOutputStream();
-    writer = new BufferedWriter(new OutputStreamWriter(stdin));
+    writer = new PrintWriter(stdin, true);
     reader = new BufferedReader(new InputStreamReader(stdout));
     try {
       pid = findPid();
@@ -92,25 +91,23 @@ public void interrupt() throws IOException {
   }
 
   public String sendAndGetResult(String cmd) throws IOException {
-
-    writer.write(cmd + "\n\n");
-    writer.write("print (\"*!?flush reader!?*\")\n\n");
-    writer.flush();
-
-    String output = "";
-    String line;
-    while (!(line = reader.readLine()).contains("*!?flush reader!?*")) {
+    writer.println(cmd);
+    writer.println();
+    writer.println("\"" + STATEMENT_END + "\"");
+    StringBuilder output = new StringBuilder();
+    String line = null;
+    while (!(line = reader.readLine()).contains(STATEMENT_END)) {
       logger.debug("Readed line from python shell : " + line);
       if (line.equals("...")) {
         logger.warn("Syntax error ! ");
-        output += "Syntax error ! ";
+        output.append("Syntax error ! ");
         break;
       }
 
-      output += "\r" + line + "\n";
+      output.append(line + "\n");
     }
 
-    return output;
+    return output.toString();
 
   }
 
diff --git a/python/src/main/resources/bootstrap.py b/python/src/main/resources/bootstrap.py
index e225f0362cb..f08420a3933 100644
--- a/python/src/main/resources/bootstrap.py
+++ b/python/src/main/resources/bootstrap.py
@@ -25,14 +25,13 @@
 except ImportError:
     import io as io
 
-sys.displayhook = lambda x: None
-
 def intHandler(signum, frame):  # Set the signal handler
     print ("Paragraph interrupted")
     raise KeyboardInterrupt()
 
 signal.signal(signal.SIGINT, intHandler)
-
+# set prompt as empty string so that java side don't need to remove the prompt.
+sys.ps1=""
 
 def help():
     print ('%html')
diff --git a/python/src/test/java/org/apache/zeppelin/python/PythonInterpreterTest.java b/python/src/test/java/org/apache/zeppelin/python/PythonInterpreterTest.java
index 35f4e2b4c4c..b33d2386948 100644
--- a/python/src/test/java/org/apache/zeppelin/python/PythonInterpreterTest.java
+++ b/python/src/test/java/org/apache/zeppelin/python/PythonInterpreterTest.java
@@ -132,7 +132,7 @@ public void testPy4JInstalled() {
      */
 
     try {
-      when(mockPythonProcess.sendAndGetResult(eq("\n\nimport py4j\n"))).thenReturn(">>>");
+      when(mockPythonProcess.sendAndGetResult(eq("\n\nimport py4j\n"))).thenReturn("");
     } catch (IOException e) {
       e.printStackTrace();
     }
@@ -157,7 +157,7 @@ public void testPy4JInstalled() {
   public void testClose() {
 
     try {
-      when(mockPythonProcess.sendAndGetResult(eq("\n\nimport py4j\n"))).thenReturn(">>>");
+      when(mockPythonProcess.sendAndGetResult(eq("\n\nimport py4j\n"))).thenReturn("");
     } catch (IOException e) {
       e.printStackTrace();
     }
@@ -222,11 +222,11 @@ private String answerFromPythonMock(InvocationOnMock invocationOnMock) {
       String output = "";
 
       for (int i = 0; i < lines.length; i++) {
-        output += ">>>" + lines[i];
+        output += lines[i];
       }
       return output;
     } else {
-      return ">>>";
+      return "";
     }
   }