File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
java/org/apache/zeppelin/rest Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -140,7 +140,7 @@ public void pySparkTest() throws IOException {
140140 waitForFinish (p );
141141 assertEquals (Status .FINISHED , p .getStatus ());
142142 assertEquals ("55\n " , p .getResult ().message ());
143-
143+ LOG . info ( "*************************result:" + p . getResult (). message ());
144144 // run sqlContext test
145145 p .setText ("%pyspark from pyspark.sql import Row\n " +
146146 "df=sqlContext.createDataFrame([Row(name='Alice', age=20)])\n " +
@@ -149,7 +149,7 @@ public void pySparkTest() throws IOException {
149149 waitForFinish (p );
150150 assertEquals (Status .FINISHED , p .getStatus ());
151151 assertEquals ("1\n " , p .getResult ().message ());
152-
152+ LOG . info ( "*************************result:" + p . getResult (). message ());
153153 if (sparkVersion >= 20 ) {
154154 // run SparkSession test
155155 p .setText ("%pyspark from pyspark.sql import Row\n " +
@@ -159,6 +159,7 @@ public void pySparkTest() throws IOException {
159159 waitForFinish (p );
160160 assertEquals (Status .FINISHED , p .getStatus ());
161161 assertEquals ("1\n " , p .getResult ().message ());
162+ LOG .info ("*************************result:" + p .getResult ().message ());
162163 }
163164 }
164165 ZeppelinServer .notebook .removeNote (note .getId (), null );
Original file line number Diff line number Diff line change @@ -43,4 +43,4 @@ log4j.logger.DataNucleus.Datastore=ERROR
4343# Log all JDBC parameters
4444log4j.logger.org.hibernate.type =ALL
4545
46-
46+ log4j.logger.org.apache.zeppelin.interpreter = DEBUG
You can’t perform that action at this time.
0 commit comments