[jira] [Created] (ZEPPELIN-6004) ConcurrentModificationException in zeppelin-client UpdateStreamSqlJob buildResult

["zhengyuan (Jira)" <ji...@apache.org>]

zhengyuan created ZEPPELIN-6004:
-----------------------------------

             Summary: ConcurrentModificationException in zeppelin-client UpdateStreamSqlJob buildResult
                 Key: ZEPPELIN-6004
                 URL: https://issues.apache.org/jira/browse/ZEPPELIN-6004
             Project: Zeppelin
          Issue Type: Bug
          Components: zeppelin-client
    Affects Versions: 0.11.0
            Reporter: zhengyuan


{code:java}
//代码占位符
String paragraphId = zClient.addParagraph(noteId, "the first paragraph", this.getTestSql());
 zClient.submitNote(noteId);
 NoteResult noteResult = zClient.waitUntilNoteFinished(noteId);
 System.out.println("Submit note and the note result: " + noteResult); {code}
detail logs:

----------------------------------------

Submit note and the note result: NoteResult{noteId='2JTW2E269', isRunning=false, paragraphResultList=[ParagraphResult{paragraphId='paragraph_1710750700587_868085398', status=ERROR, results=Result{type='TEXT', data='Fail to run sql command: select * from v_meta_attr_processing_3
java.lang.RuntimeException: Fail to run update type stream job
    at org.apache.zeppelin.flink.FlinkStreamSqlInterpreter.callInnerSelect(FlinkStreamSqlInterpreter.java:93)
    at org.apache.zeppelin.flink.FlinkStreamSqlInterpreter.lambda$open$0(FlinkStreamSqlInterpreter.java:48)
    at org.apache.zeppelin.flink.Flink116SqlInterpreter.callStreamInnerSelect(Flink116SqlInterpreter.java:446)
    at org.apache.zeppelin.flink.Flink116SqlInterpreter.callSelect(Flink116SqlInterpreter.java:430)
    at org.apache.zeppelin.flink.Flink116SqlInterpreter.callOperation(Flink116SqlInterpreter.java:290)
    at org.apache.zeppelin.flink.Flink116SqlInterpreter.runSqlList(Flink116SqlInterpreter.java:236)
    at org.apache.zeppelin.flink.Flink116Shims.runSqlList(Flink116Shims.java:394)
    at org.apache.zeppelin.flink.FlinkStreamSqlInterpreter.runSqlList(FlinkStreamSqlInterpreter.java:102)
    at org.apache.zeppelin.flink.FlinkSqlInterpreter.internalInterpret(FlinkSqlInterpreter.java:58)
    at org.apache.zeppelin.interpreter.AbstractInterpreter.interpret(AbstractInterpreter.java:55)
    at org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:108)
    at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:877)
    at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:769)
    at org.apache.zeppelin.scheduler.Job.run(Job.java:186)
    at org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:135)
    at org.apache.zeppelin.scheduler.ParallelScheduler.lambda$runJobInScheduler$0(ParallelScheduler.java:46)
    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: java.io.IOException: Fail to run stream sql job
    at org.apache.zeppelin.flink.sql.AbstractStreamSqlJob.run(AbstractStreamSqlJob.java:165)
    at org.apache.zeppelin.flink.sql.AbstractStreamSqlJob.run(AbstractStreamSqlJob.java:109)
    at org.apache.zeppelin.flink.FlinkStreamSqlInterpreter.callInnerSelect(FlinkStreamSqlInterpreter.java:91)
    ... 18 more
Caused by: java.util.ConcurrentModificationException
    at java.util.ArrayList.sort(ArrayList.java:1466)
    at org.apache.zeppelin.flink.sql.UpdateStreamSqlJob.buildResult(UpdateStreamSqlJob.java:91)
    at org.apache.zeppelin.flink.sql.UpdateStreamSqlJob.refresh(UpdateStreamSqlJob.java:105)
    at org.apache.zeppelin.flink.sql.AbstractStreamSqlJob.run(AbstractStreamSqlJob.java:159)



--
This message was sent by Atlassian Jira
(v8.20.10#820010)