[
https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410738#comment-17410738
]
Yun Gao edited comment on FLINK-24162 at 9/6/21, 5:04 PM:
----------------------------------------------------------
Hi [~roman]~ I have also noticed the configuration ~ but it did not take
effective since it is seemed to be filtered in and not pass to the JM. If we
instead set the configuration directly to the minicluster, the test would fail
deterministically~ I'm still checking if it is due to we are using
TestStreamEnvironment or it is in fact common for all the
StreamExecutionEnvironmennt~
was (Author: gaoyunhaii):
Hi [~roman]~I have also noticed the configuration~ but it did not take
effective since it is seemed to be filtered in and not pass to the JM. If we
instead set the configuration directly to the minicluster, the test would fail
deterministically~ I'm still checking if it is due to we are using
TestStreamEnvironment or it is in fact common for all the
StreamExecutionEnvironmennt~
> PartiallyFinishedSourcesITCase fails due to assertion error in
> DrainingValidator.validateOperatorLifecycle
> ----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-24162
> URL: https://issues.apache.org/jira/browse/FLINK-24162
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.14.0, 1.15.0
> Reporter: Xintong Song
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.14.0, 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23526&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28&t=ea7cf968-e585-52cb-e0fc-f48de023a7ca&l=4639
> {code}
> Sep 03 23:17:11 [ERROR] Tests run: 6, Failures: 1, Errors: 0, Skipped: 0,
> Time elapsed: 19.233 s <<< FAILURE! - in
> org.apache.flink.runtime.operators.lifecycle.PartiallyFinishedSourcesITCase
> Sep 03 23:17:11 [ERROR] test[simple graph SINGLE_SUBTASK, failover: true]
> Time elapsed: 2.27 s <<< FAILURE!
> Sep 03 23:17:11 java.lang.AssertionError
> Sep 03 23:17:11 at org.junit.Assert.fail(Assert.java:87)
> Sep 03 23:17:11 at org.junit.Assert.assertTrue(Assert.java:42)
> Sep 03 23:17:11 at org.junit.Assert.assertFalse(Assert.java:65)
> Sep 03 23:17:11 at org.junit.Assert.assertFalse(Assert.java:75)
> Sep 03 23:17:11 at
> org.apache.flink.runtime.operators.lifecycle.validation.DrainingValidator.validateOperatorLifecycle(DrainingValidator.java:56)
> Sep 03 23:17:11 at
> org.apache.flink.runtime.operators.lifecycle.validation.TestOperatorLifecycleValidator.lambda$checkOperatorsLifecycle$1(TestOperatorLifecycleValidator.java:52)
> Sep 03 23:17:11 at java.util.HashMap.forEach(HashMap.java:1289)
> Sep 03 23:17:11 at
> org.apache.flink.runtime.operators.lifecycle.validation.TestOperatorLifecycleValidator.checkOperatorsLifecycle(TestOperatorLifecycleValidator.java:47)
> Sep 03 23:17:11 at
> org.apache.flink.runtime.operators.lifecycle.PartiallyFinishedSourcesITCase.test(PartiallyFinishedSourcesITCase.java:94)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
