[jira] [Commented] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338185#comment-17338185 ] Piotr Nowojski commented on FLINK-22088: [~gaoyunhaii], as I understand the impact of this issue

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338184#comment-17338184 ] Guowei Ma commented on FLINK-22457: ---

[jira] [Commented] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338183#comment-17338183 ] Guowei Ma commented on FLINK-22548: ---

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

[ https://issues.apache.org/jira/browse/FLINK-22520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338182#comment-17338182 ] Guowei Ma commented on FLINK-22520: ---

[jira] [Commented] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338180#comment-17338180 ] Guowei Ma commented on FLINK-22312: ---

[jira] [Comment Edited] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma edited comment on FLINK-22546 at 5/3/21, 5:29 AM:

[jira] [Commented] (FLINK-22466) KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost

[ https://issues.apache.org/jira/browse/FLINK-22466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338179#comment-17338179 ] Guowei Ma commented on FLINK-22466: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * 99b6589927379fc741472b0c60054909e2947dda Azure:

[jira] [Commented] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338178#comment-17338178 ] Guowei Ma commented on FLINK-22312: ---

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338177#comment-17338177 ] Guowei Ma commented on FLINK-22480: ---

[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338176#comment-17338176 ] Guowei Ma commented on FLINK-21538: ---

[jira] [Commented] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338175#comment-17338175 ] Guowei Ma commented on FLINK-22312: ---

[jira] [Reopened] (FLINK-21032) JsonFileCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reopened FLINK-21032: --- found another case in the 1.13 branch

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338173#comment-17338173 ] Guowei Ma commented on FLINK-22266: ---

[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338172#comment-17338172 ] Guowei Ma commented on FLINK-21538: ---

[jira] [Commented] (FLINK-22419) testScheduleRunAsync fail

[ https://issues.apache.org/jira/browse/FLINK-22419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338170#comment-17338170 ] Guowei Ma commented on FLINK-22419: ---

[jira] [Commented] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338171#comment-17338171 ] Piotr Nowojski commented on FLINK-21952: How would you propose [~gaoyunhaii] to solve this? >

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

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338168#comment-17338168 ] Guowei Ma commented on FLINK-20495: ---

[jira] [Comment Edited] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma edited comment on FLINK-22546 at 5/3/21, 5:02 AM:

[jira] [Comment Edited] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma edited comment on FLINK-22546 at 5/3/21, 5:00 AM:

[jira] [Commented] (FLINK-18444) KafkaITCase failing with "Failed to send data to Kafka: This server does not host this topic-partition"

[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338167#comment-17338167 ] Guowei Ma commented on FLINK-18444: ---

[jira] [Commented] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.

[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338166#comment-17338166 ] Guowei Ma commented on FLINK-22333: ---

[jira] [Commented] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

[ https://issues.apache.org/jira/browse/FLINK-22464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338165#comment-17338165 ] Guowei Ma commented on FLINK-22464: ---

[jira] [Commented] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs

[ https://issues.apache.org/jira/browse/FLINK-22465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338164#comment-17338164 ] Guowei Ma commented on FLINK-22465: ---

[jira] [Comment Edited] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma edited comment on FLINK-22546 at 5/3/21, 4:52 AM:

[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=17338162#comment-17338162 ] Guowei Ma commented on FLINK-20498: ---

[GitHub] [flink] pnowojski commented on a change in pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

pnowojski commented on a change in pull request #15820: URL: https://github.com/apache/flink/pull/15820#discussion_r624872007 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1619,6 +1617,50 @@ public void

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338161#comment-17338161 ] Guowei Ma commented on FLINK-22457: ---

[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=17338160#comment-17338160 ] Guowei Ma commented on FLINK-20498: ---

[jira] [Commented] (FLINK-21063) ElasticsearchSinkITCase fails while setting up ES cluster

[ https://issues.apache.org/jira/browse/FLINK-21063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338158#comment-17338158 ] Guowei Ma commented on FLINK-21063: --- just for report

[jira] [Closed] (FLINK-21548) keyBy operation produces skewed record distribution for low-cardinality keys

[ https://issues.apache.org/jira/browse/FLINK-21548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21548. -- Resolution: Not A Bug > keyBy operation produces skewed record distribution for

[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=17338157#comment-17338157 ] Guowei Ma commented on FLINK-17274: ---

[jira] [Created] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

Guowei Ma created FLINK-22548: - Summary: UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException Key: FLINK-22548 URL:

[jira] [Comment Edited] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma edited comment on FLINK-22546 at 5/3/21, 4:29 AM:

[jira] [Created] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

Guowei Ma created FLINK-22547: - Summary: OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail Key: FLINK-22547 URL: https://issues.apache.org/jira/browse/FLINK-22547

[jira] [Comment Edited] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma edited comment on FLINK-22546 at 5/3/21, 4:25 AM:

[jira] [Commented] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338156#comment-17338156 ] Guowei Ma commented on FLINK-22312: ---

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338154#comment-17338154 ] Guowei Ma commented on FLINK-22266: ---

[jira] [Commented] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338155#comment-17338155 ] Guowei Ma commented on FLINK-22546: ---

[jira] [Created] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed

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

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

Guowei Ma created FLINK-22545: - Summary: JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost Key: FLINK-22545 URL: https://issues.apache.org/jira/browse/FLINK-22545

[GitHub] [flink] flinkbot edited a comment on pull request #15716: [FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15716: URL: https://github.com/apache/flink/pull/15716#issuecomment-82440 ## CI report: * b5559a35836d27b05b7d28d8ce85e0bbe1478372 UNKNOWN * f332a24011760c65dcb68fe3471db2839e223045 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * fc5462983f934e936049f37389210dd7bddb5bf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * fc5462983f934e936049f37389210dd7bddb5bf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15716: [FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15716: URL: https://github.com/apache/flink/pull/15716#issuecomment-82440 ## CI report: * b5559a35836d27b05b7d28d8ce85e0bbe1478372 UNKNOWN * 88328376874012785f1dc2fbeb789e5ce749e689 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15716: [FLINK-22368] Deque channel after releasing on EndOfPartition

flinkbot edited a comment on pull request #15716: URL: https://github.com/apache/flink/pull/15716#issuecomment-82440 ## CI report: * b5559a35836d27b05b7d28d8ce85e0bbe1478372 UNKNOWN * 88328376874012785f1dc2fbeb789e5ce749e689 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15742: [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

flinkbot edited a comment on pull request #15742: URL: https://github.com/apache/flink/pull/15742#issuecomment-826101386 ## CI report: * 2aa2e313fc30f618bba7919d3d15065ab9782909 Azure:

[GitHub] [flink-web] dawidwys closed pull request #439: Add release 1.13.0 links

dawidwys closed pull request #439: URL: https://github.com/apache/flink-web/pull/439 -- 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,

[GitHub] [flink] flinkbot edited a comment on pull request #15742: [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

flinkbot edited a comment on pull request #15742: URL: https://github.com/apache/flink/pull/15742#issuecomment-826101386 ## CI report: * 984327897d7e0b57ea366ad6ecc8369e94f9ea6f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15742: [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

flinkbot edited a comment on pull request #15742: URL: https://github.com/apache/flink/pull/15742#issuecomment-826101386 ## CI report: * 984327897d7e0b57ea366ad6ecc8369e94f9ea6f Azure:

[jira] [Comment Edited] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337299#comment-17337299 ] Piotr Nowojski edited comment on FLINK-17170 at 5/2/21, 10:58 AM: -- I