[jira] (FLINK-27555) Performance regression in schedulingDownstreamTasks on 02.05.2022

[ https://issues.apache.org/jira/browse/FLINK-27555 ] Guowei Ma deleted comment on FLINK-27555: --- was (Author: maguowei): Thanks [~roman] for letting this. I notice that [~zhuzh]  have make some changed recently. So would you like to have a look!

[jira] [Commented] (FLINK-27555) Performance regression in schedulingDownstreamTasks on 02.05.2022

[ https://issues.apache.org/jira/browse/FLINK-27555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534120#comment-17534120 ] Guowei Ma commented on FLINK-27555: --- Thanks [~roman] for letting this. I notice that [

[jira] [Commented] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors

[ https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528704#comment-17528704 ] Guowei Ma commented on FLINK-27424: --- Would you like to enable the debug log and share

[jira] [Commented] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors

[ https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528692#comment-17528692 ] Guowei Ma commented on FLINK-27424: --- Thanks for your information. But are you sure th

[jira] [Comment Edited] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors

[ https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528604#comment-17528604 ] Guowei Ma edited comment on FLINK-27424 at 4/27/22 7:34 AM:

[jira] [Comment Edited] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors

[ https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528604#comment-17528604 ] Guowei Ma edited comment on FLINK-27424 at 4/27/22 7:34 AM:

[jira] [Commented] (FLINK-27424) StreamExecutionEnvironment.readFile() api monitor file directory errors

[ https://issues.apache.org/jira/browse/FLINK-27424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528604#comment-17528604 ] Guowei Ma commented on FLINK-27424: --- Hi, [~zhangqw152]  IMHO I do not think this is a

[jira] [Commented] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528478#comment-17528478 ] Guowei Ma commented on FLINK-27420: --- Thanks [~baugarten] for reporting this. cc [~xtso

[jira] [Updated] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-27420: -- Component/s: Runtime / Coordination > Suspended SlotManager fail to reregister metrics when started ag

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528052#comment-17528052 ] Guowei Ma commented on FLINK-27377: --- # Thanks [~yittg]  for your detailed explanation

[jira] [Updated] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-27377: -- Component/s: Connectors / FileSystem Runtime / Coordination > Job master blocks on ma

[jira] [Updated] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-27377: -- Issue Type: Improvement (was: Bug) > Job master blocks on marking vertex finished > -

[jira] [Updated] (FLINK-27406) After canceling the job, it is falsely reported as a job failure.

[ https://issues.apache.org/jira/browse/FLINK-27406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-27406: -- Labels: usability (was: ) > After canceling the job, it is falsely reported as a job failure. > -

[jira] [Commented] (FLINK-27377) Job master blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527925#comment-17527925 ] Guowei Ma commented on FLINK-27377: --- Hi, [~yittg] Thanks for your detail explanation.

[jira] [Created] (FLINK-27406) After canceling the job, it is falsely reported as a job failure.

Guowei Ma created FLINK-27406: - Summary: After canceling the job, it is falsely reported as a job failure. Key: FLINK-27406 URL: https://issues.apache.org/jira/browse/FLINK-27406 Project: Flink

[jira] [Commented] (FLINK-27377) Job manager blocks on marking vertex finished

[ https://issues.apache.org/jira/browse/FLINK-27377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527324#comment-17527324 ] Guowei Ma commented on FLINK-27377: --- Hi [~yittg] thanks for your reporting. Afaik the

[jira] [Assigned] (FLINK-25697) Support HTTPS for Prometheus Push Gateway

[ https://issues.apache.org/jira/browse/FLINK-25697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-25697: - Assignee: Mason Chen > Support HTTPS for Prometheus Push Gateway >

[jira] [Assigned] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader

[ https://issues.apache.org/jira/browse/FLINK-25053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-25053: - Assignee: Lijie Wang > Document how to use the usrlib to load code in the user code class loade

[jira] [Comment Edited] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1785#comment-1785 ] Guowei Ma edited comment on FLINK-24767 at 11/16/21, 11:27 AM: ---

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1785#comment-1785 ] Guowei Ma commented on FLINK-24767: --- {code:java} env.setRuntimeMode(RuntimeExecutionMo

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444280#comment-17444280 ] Guowei Ma commented on FLINK-24767: --- I think it might be that in the Batch execution m

[jira] [Comment Edited] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426451#comment-17426451 ] Guowei Ma edited comment on FLINK-22096 at 10/9/21, 4:46 AM: -

[jira] [Assigned] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-22096: - Assignee: Yuxin Tan > ServerTransportErrorHandlingTest.testRemoteClose fail >

[jira] [Commented] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426451#comment-17426451 ] Guowei Ma commented on FLINK-22096: --- Thank [~tanyuxin] for your attention. I will assi

[jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN

[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422627#comment-17422627 ] Guowei Ma commented on FLINK-13247: --- Hi [~dangshazi]  I am glad you are interested in

[jira] [Resolved] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma resolved FLINK-23235. --- Assignee: Guowei Ma Resolution: Fixed > SinkITCase.writerAndCommitterAndGlobalCommitterExecute

[jira] [Comment Edited] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379068#comment-17379068 ] Guowei Ma edited comment on FLINK-23235 at 7/13/21, 2:58 AM: -

[jira] [Updated] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-23235: -- Fix Version/s: 1.14.0 > SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails >

[jira] [Commented] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379068#comment-17379068 ] Guowei Ma commented on FLINK-23235: --- Fix in release-1.13: 92398d42498e61554566ab2dcfd8

[jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378836#comment-17378836 ] Guowei Ma commented on FLINK-22672: --- Thanks [~jinxing6...@126.com]and [~kevin.cyj] for

[jira] [Closed] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20950. - > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with > "AssertionError" > -

[jira] [Resolved] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma resolved FLINK-20950. --- Resolution: Fixed > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with > "A

[jira] [Commented] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377791#comment-17377791 ] Guowei Ma commented on FLINK-23235: --- I thought about it again. In fact, we only need t

[jira] [Commented] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377240#comment-17377240 ] Guowei Ma commented on FLINK-23235: --- Investigated the reason for this problem: At pres

[jira] [Updated] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-23235: -- Attachment: screenshot-1.png > SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode f

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351476#comment-17351476 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22779) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException

Guowei Ma created FLINK-22779: - Summary: KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException Key: FLINK-22779 URL: https://issues.apache.org/jira/browse/FLINK-22779

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351455#comment-17351455 ] Guowei Ma commented on FLINK-22545: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22756) DispatcherTest.testJobStatusIsShownDuringTermination fail

[ https://issues.apache.org/jira/browse/FLINK-22756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351453#comment-17351453 ] Guowei Ma commented on FLINK-22756: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

Guowei Ma created FLINK-22775: - Summary: CassandraConnectorITCase.testCassandraTableSink Fail Key: FLINK-22775 URL: https://issues.apache.org/jira/browse/FLINK-22775 Project: Flink Issue Type: Bu

[jira] [Issue Comment Deleted] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22593: -- Comment: was deleted (was: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=183

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351443#comment-17351443 ] Guowei Ma commented on FLINK-22593: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351442#comment-17351442 ] Guowei Ma commented on FLINK-22593: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20420: -- Affects Version/s: 1.14.0 > ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds >

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351441#comment-17351441 ] Guowei Ma commented on FLINK-20420: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349764#comment-17349764 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22756) DispatcherTest.testJobStatusIsShownDuringTermination fail

Guowei Ma created FLINK-22756: - Summary: DispatcherTest.testJobStatusIsShownDuringTermination fail Key: FLINK-22756 URL: https://issues.apache.org/jira/browse/FLINK-22756 Project: Flink Issue Typ

[jira] [Commented] (FLINK-22382) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-22382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349760#comment-17349760 ] Guowei Ma commented on FLINK-22382: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349747#comment-17349747 ] Guowei Ma commented on FLINK-22593: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349746#comment-17349746 ] Guowei Ma commented on FLINK-20928: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22755) SequenceStreamingFileSinkITCase.testWriteSequenceFile fail

Guowei Ma created FLINK-22755: - Summary: SequenceStreamingFileSinkITCase.testWriteSequenceFile fail Key: FLINK-22755 URL: https://issues.apache.org/jira/browse/FLINK-22755 Project: Flink Issue Ty

[jira] [Updated] (FLINK-22738) org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on docker container removal

[ https://issues.apache.org/jira/browse/FLINK-22738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22738: -- Affects Version/s: 1.14.0 > org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output fo

[jira] [Updated] (FLINK-22738) org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on docker container removal

[ https://issues.apache.org/jira/browse/FLINK-22738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22738: -- Summary: org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due t

[jira] [Commented] (FLINK-22738) org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on docker container removal

[ https://issues.apache.org/jira/browse/FLINK-22738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349745#comment-17349745 ] Guowei Ma commented on FLINK-22738: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

[ https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349062#comment-17349062 ] Guowei Ma commented on FLINK-22194: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

Guowei Ma created FLINK-22739: - Summary: CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException Key: FLINK-22739 URL: https://issues.apache.org/jira/browse/FLINK-22739 Projec

[jira] [Comment Edited] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349026#comment-17349026 ] Guowei Ma edited comment on FLINK-22613 at 5/21/21, 7:56 AM: -

[jira] [Created] (FLINK-22738) org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on downloading docker image

Guowei Ma created FLINK-22738: - Summary: org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on downloading docker image Key: FLINK-22738 URL: https://issues.apache.

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349026#comment-17349026 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20950: -- Labels: test-stability (was: stale-assigned test-stability) > SinkITCase.writerAndGlobalCommitterExec

[jira] [Updated] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20950: -- Affects Version/s: 1.14.0 > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349022#comment-17349022 ] Guowei Ma commented on FLINK-20950: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349024#comment-17349024 ] Guowei Ma commented on FLINK-20950: --- I would find the time to fix this next week. > S

[jira] [Created] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

Guowei Ma created FLINK-22735: - Summary: HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out Key: FLINK-22735 URL: https://issues.apache.org/jira/browse/FLINK-22735

[jira] [Commented] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs

[ https://issues.apache.org/jira/browse/FLINK-22520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349019#comment-17349019 ] Guowei Ma commented on FLINK-22520: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22366) HiveSinkCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348054#comment-17348054 ] Guowei Ma commented on FLINK-22366: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348049#comment-17348049 ] Guowei Ma edited comment on FLINK-22704 at 5/20/21, 4:46 AM: -

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348052#comment-17348052 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-22692) CheckpointStoreITCase.testRestartOnRecoveryFailure fails with RuntimeException

[ https://issues.apache.org/jira/browse/FLINK-22692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347278#comment-17347278 ] Guowei Ma edited comment on FLINK-22692 at 5/20/21, 4:44 AM: -

[jira] [Created] (FLINK-22720) UpsertKafkaTableITCase.testAggregate fail due to ConcurrentModificationException

Guowei Ma created FLINK-22720: - Summary: UpsertKafkaTableITCase.testAggregate fail due to ConcurrentModificationException Key: FLINK-22720 URL: https://issues.apache.org/jira/browse/FLINK-22720 Project: F

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348050#comment-17348050 ] Guowei Ma commented on FLINK-22702: --- KafkaSourceITCase.testValueOnlyDeserializer fail

[jira] [Updated] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22702: -- Affects Version/s: 1.14.0 > KafkaSourceITCase.testRedundantParallelism failed > --

[jira] [Updated] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22704: -- Affects Version/s: 1.14.0 > ZooKeeperHaServicesTest.testCleanupJobData failed > --

[jira] [Commented] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348049#comment-17348049 ] Guowei Ma commented on FLINK-22704: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348047#comment-17348047 ] Guowei Ma commented on FLINK-22593: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348016#comment-17348016 ] Guowei Ma commented on FLINK-20495: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348015#comment-17348015 ] Guowei Ma commented on FLINK-22613: --- 1.12 https://dev.azure.com/apache-flink/apache-fl

[jira] [Updated] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20498: -- Affects Version/s: 1.12.3 > SQLClientSchemaRegistryITCase.testReading test timed out after 12 > m

[jira] [Commented] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348013#comment-17348013 ] Guowei Ma commented on FLINK-20498: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22710) ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed

Guowei Ma created FLINK-22710: - Summary: ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed Key: FLINK-22710 URL: https://issues.apache.org/jira/browse/FLINK-22710 Project: Flink

[jira] [Created] (FLINK-22705) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar

Guowei Ma created FLINK-22705: - Summary: SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar Key: FLINK-22705 URL: https://issues.apache.org/jira/browse/FLINK-22705

[jira] [Comment Edited] (FLINK-22692) CheckpointStoreITCase.testRestartOnRecoveryFailure fails with RuntimeException

[ https://issues.apache.org/jira/browse/FLINK-22692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347278#comment-17347278 ] Guowei Ma edited comment on FLINK-22692 at 5/19/21, 3:30 AM: -

[jira] [Reopened] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reopened FLINK-22197: --- happens again https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=18108&view=logs&j=f

[jira] [Comment Edited] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347276#comment-17347276 ] Guowei Ma edited comment on FLINK-22613 at 5/19/21, 3:26 AM: -

[jira] [Updated] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

[ https://issues.apache.org/jira/browse/FLINK-22704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22704: -- Labels: test-stability (was: ) > ZooKeeperHaServicesTest.testCleanupJobData failed >

[jira] [Created] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed

Guowei Ma created FLINK-22704: - Summary: ZooKeeperHaServicesTest.testCleanupJobData failed Key: FLINK-22704 URL: https://issues.apache.org/jira/browse/FLINK-22704 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-22692) CheckpointStoreITCase.testRestartOnRecoveryFailure fails with RuntimeException

[ https://issues.apache.org/jira/browse/FLINK-22692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347278#comment-17347278 ] Guowei Ma commented on FLINK-22692: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-22703) SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed

[ https://issues.apache.org/jira/browse/FLINK-22703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22703: -- Component/s: Runtime / Checkpointing > SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheck

[jira] [Created] (FLINK-22703) SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed

Guowei Ma created FLINK-22703: - Summary: SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed Key: FLINK-22703 URL: https://issues.apache.org/jira/browse/FLINK-22703 Project: Flink

[jira] [Created] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

Guowei Ma created FLINK-22702: - Summary: KafkaSourceITCase.testRedundantParallelism failed Key: FLINK-22702 URL: https://issues.apache.org/jira/browse/FLINK-22702 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347276#comment-17347276 ] Guowei Ma commented on FLINK-22613: --- just for reporting https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

[ https://issues.apache.org/jira/browse/FLINK-21329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347274#comment-17347274 ] Guowei Ma commented on FLINK-21329: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344321#comment-17344321 ] Guowei Ma commented on FLINK-20495: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344306#comment-17344306 ] Guowei Ma commented on FLINK-20420: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

Guowei Ma created FLINK-22662: - Summary: YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail Key: FLINK-22662 URL: https://issues.apache.org/jira/browse/FLINK-22662 Project: Flink

[jira] [Commented] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344305#comment-17344305 ] Guowei Ma commented on FLINK-22195: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344303#comment-17344303 ] Guowei Ma commented on FLINK-17274: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344280#comment-17344280 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344257#comment-17344257 ] Guowei Ma commented on FLINK-22198: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344248#comment-17344248 ] Guowei Ma edited comment on FLINK-22593 at 5/14/21, 2:35 AM: -

  1   2   3   4   5   6   7   8   9   10   >