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)
