cfmcgrady commented on PR #4333:
URL: https://github.com/apache/kyuubi/pull/4333#issuecomment-1441438302

   sorry for wrongly locally testing before, this is a breaking change for 
submitting multi-line python snippets.
   
   
   <details>
   <summary>log</summary>
   
   ```
   0: jdbc:hive2://192.168.205.128:10009/> for i in [1, 2, 3]:
   . . . . . . . . . . . . . . . . . . . >     print(i);
   2023-02-23 17:26:12.280 INFO org.apache.kyuubi.operation.ExecuteStatement: 
Processing anonymous's query[d70621de-5a0b-4253-8f3f-a4c51cacc806]: 
PENDING_STATE -> RUNNING_STATE, statement:
   for i in [1, 2, 3]:
   print(i)
   23/02/23 17:26:13 INFO ExecutePython: Processing anonymous's 
query[209c8f29-3e06-4ce6-9271-f2ce396741ba]: PENDING_STATE -> RUNNING_STATE, 
statement:
   for i in [1, 2, 3]:
   print(i)
   23/02/23 17:26:13 INFO ExecutePython:
              Spark application name: 
kyuubi_USER_SPARK_SQL_anonymous_default_f7512afe-f0b3-449e-bf45-164af364616b
                    application ID: local-1677144339509
                    application web UI: http://192.168.205.128:59896
                    master: local[*]
                    deploy mode: client
                    version: 3.3.1
              Start time: 2023-02-23T17:25:37.933
              User: anonymous
   23/02/23 17:26:13 INFO DAGScheduler: Asked to cancel job group 
209c8f29-3e06-4ce6-9271-f2ce396741ba
   23/02/23 17:26:13 ERROR ExecutePython: Error operating ExecutePython: 
org.apache.kyuubi.KyuubiSQLException: Interpret error:
   for i in [1, 2, 3]:
   print(i)
    
Some(PythonResponse(execute_reply,PythonResponseContent(null,IndentationError,expected
 an indented block (<stdin>, line 2),List(  File "<stdin>", line 2
   ,     print(i)
   ,         ^
   , IndentationError: expected an indented block
   ),error)))
           at 
org.apache.kyuubi.KyuubiSQLException$.apply(KyuubiSQLException.scala:69)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.$anonfun$executePython$1(ExecutePython.scala:96)
           at 
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.withLocalProperties(ExecutePython.scala:160)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.org$apache$kyuubi$engine$spark$operation$ExecutePython$$executePython(ExecutePython.scala:81)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython$$anon$1.run(ExecutePython.scala:111)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   
   org.apache.kyuubi.KyuubiSQLException: Interpret error:
   for i in [1, 2, 3]:
   print(i)
    
Some(PythonResponse(execute_reply,PythonResponseContent(null,IndentationError,expected
 an indented block (<stdin>, line 2),List(  File "<stdin>", line 2
   ,     print(i)
   ,         ^
   , IndentationError: expected an indented block
   ),error)))
           at 
org.apache.kyuubi.KyuubiSQLException$.apply(KyuubiSQLException.scala:69)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.$anonfun$executePython$1(ExecutePython.scala:96)
           at 
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.withLocalProperties(ExecutePython.scala:160)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.org$apache$kyuubi$engine$spark$operation$ExecutePython$$executePython(ExecutePython.scala:81)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython$$anon$1.run(ExecutePython.scala:111)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   23/02/23 17:26:13 INFO ExecutePython: Processing anonymous's 
query[209c8f29-3e06-4ce6-9271-f2ce396741ba]: RUNNING_STATE -> ERROR_STATE, time 
taken: 0.01 seconds
   2023-02-23 17:26:13.096 INFO org.apache.kyuubi.operation.ExecuteStatement: 
Query[d70621de-5a0b-4253-8f3f-a4c51cacc806] in ERROR_STATE
   2023-02-23 17:26:13.103 INFO org.apache.kyuubi.operation.ExecuteStatement: 
Processing anonymous's query[d70621de-5a0b-4253-8f3f-a4c51cacc806]: 
RUNNING_STATE -> ERROR_STATE, time taken: 0.823 seconds
   Error: org.apache.kyuubi.KyuubiSQLException: 
org.apache.kyuubi.KyuubiSQLException: Error operating ExecutePython: 
org.apache.kyuubi.KyuubiSQLException: Interpret error:
   for i in [1, 2, 3]:
   print(i)
    
Some(PythonResponse(execute_reply,PythonResponseContent(null,IndentationError,expected
 an indented block (<stdin>, line 2),List(  File "<stdin>", line 2
   ,     print(i)
   ,         ^
   , IndentationError: expected an indented block
   ),error)))
           at 
org.apache.kyuubi.KyuubiSQLException$.apply(KyuubiSQLException.scala:69)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.$anonfun$executePython$1(ExecutePython.scala:96)
           at 
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.withLocalProperties(ExecutePython.scala:160)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.org$apache$kyuubi$engine$spark$operation$ExecutePython$$executePython(ExecutePython.scala:81)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython$$anon$1.run(ExecutePython.scala:111)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   
           at 
org.apache.kyuubi.KyuubiSQLException$.apply(KyuubiSQLException.scala:69)
           at 
org.apache.kyuubi.engine.spark.operation.SparkOperation$$anonfun$onError$1.applyOrElse(SparkOperation.scala:188)
           at 
org.apache.kyuubi.engine.spark.operation.SparkOperation$$anonfun$onError$1.applyOrElse(SparkOperation.scala:172)
           at 
scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:38)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.$anonfun$executePython$1(ExecutePython.scala:99)
           at 
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.withLocalProperties(ExecutePython.scala:160)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.org$apache$kyuubi$engine$spark$operation$ExecutePython$$executePython(ExecutePython.scala:81)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython$$anon$1.run(ExecutePython.scala:111)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: org.apache.kyuubi.KyuubiSQLException: Interpret error:
   for i in [1, 2, 3]:
   print(i)
    
Some(PythonResponse(execute_reply,PythonResponseContent(null,IndentationError,expected
 an indented block (<stdin>, line 2),List(  File "<stdin>", line 2
   ,     print(i)
   ,         ^
   , IndentationError: expected an indented block
   ),error)))
           at 
org.apache.kyuubi.KyuubiSQLException$.apply(KyuubiSQLException.scala:69)
           at 
org.apache.kyuubi.engine.spark.operation.ExecutePython.$anonfun$executePython$1(ExecutePython.scala:96)
           ... 9 more
   
           at 
org.apache.kyuubi.KyuubiSQLException$.apply(KyuubiSQLException.scala:69)
           at 
org.apache.kyuubi.operation.ExecuteStatement.waitStatementComplete(ExecuteStatement.scala:129)
           at 
org.apache.kyuubi.operation.ExecuteStatement.$anonfun$runInternal$1(ExecuteStatement.scala:161)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748) (state=,code=0)
   
   ```
   </details>


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to