[ZEPPELIN-6004] ConcurrentModificationException in zeppelin-client UpdateStreamSqlJob buildResult

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.11.0
• Component/s: zeppelin-client
• Assignee: Unassigned
• Reporter: zhengyuan
• Created: 18/Mar/24 09:00
• Updated: 18/Mar/24 09:00

Description

//代码占位符
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); 

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)