zentol commented on pull request #14921:
URL: https://github.com/apache/flink/pull/14921#issuecomment-778100878
The DeclarativeSchedulerClusterITCase can currently fail because runIfState
_sometimes_ does not run in the main thread.
```
16490 [pool-4-thread-1] WARN
org.apache.flink.runtime.rpc.MainThreadValidatorUtil [] - Violation of main
thread constraint detected: expected <Thread[main,5,main]> but running in
<Thread[pool-4-thread-1,5,main]>.
java.lang.Exception: Violation of main thread constraint detected: expected
<Thread[main,5,main]> but running in <Thread[pool-4-thread-1,5,main]>.
at
org.apache.flink.runtime.rpc.MainThreadValidatorUtil.isRunningInExpectedThread(MainThreadValidatorUtil.java:73)
~[classes/:?]
at
org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter.lambda$new$0(ComponentMainThreadExecutorServiceAdapter.java:54)
~[test-classes/:?]
at
org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter.assertRunningInMainThread(ComponentMainThreadExecutorServiceAdapter.java:84)
~[test-classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.assertRunningInJobMasterMainThread(ExecutionGraph.java:1469)
~[classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.transitionState(ExecutionGraph.java:1052)
~[classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.transitionState(ExecutionGraph.java:1044)
~[classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.transitionToRunning(ExecutionGraph.java:834)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.DeclarativeScheduler.createExecutionGraphWithAvailableResources(DeclarativeScheduler.java:580)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.WaitingForResources.createExecutionGraphWithAvailableResources(WaitingForResources.java:109)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.WaitingForResources.resourceTimeout(WaitingForResources.java:103)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.DeclarativeScheduler.runIfState(DeclarativeScheduler.java:870)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.DeclarativeScheduler.lambda$runIfState$20(DeclarativeScheduler.java:885)
~[classes/:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
16492 [pool-4-thread-1] ERROR
org.apache.flink.runtime.util.FatalExitExceptionHandler [] - FATAL: Thread
'pool-4-thread-1' produced an uncaught exception. Stopping the process...
java.lang.AssertionError: null
at
org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter.lambda$new$0(ComponentMainThreadExecutorServiceAdapter.java:54)
~[test-classes/:?]
at
org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter.assertRunningInMainThread(ComponentMainThreadExecutorServiceAdapter.java:84)
~[test-classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.assertRunningInJobMasterMainThread(ExecutionGraph.java:1469)
~[classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.transitionState(ExecutionGraph.java:1052)
~[classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.transitionState(ExecutionGraph.java:1044)
~[classes/:?]
at
org.apache.flink.runtime.executiongraph.ExecutionGraph.transitionToRunning(ExecutionGraph.java:834)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.DeclarativeScheduler.createExecutionGraphWithAvailableResources(DeclarativeScheduler.java:580)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.WaitingForResources.createExecutionGraphWithAvailableResources(WaitingForResources.java:109)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.WaitingForResources.resourceTimeout(WaitingForResources.java:103)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.DeclarativeScheduler.runIfState(DeclarativeScheduler.java:870)
~[classes/:?]
at
org.apache.flink.runtime.scheduler.declarative.DeclarativeScheduler.lambda$runIfState$20(DeclarativeScheduler.java:885)
~[classes/:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
