[GitHub] [flink] flinkbot edited a comment on pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

flinkbot edited a comment on pull request #18418: URL: https://github.com/apache/flink/pull/18418#issuecomment-1017307428 ## CI report: * 4e95ae2d0e8a2e2a2e3d85640d5ab125e86ede6c Azure:

[GitHub] [flink] SteNicholas commented on a change in pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

SteNicholas commented on a change in pull request #18513: URL: https://github.com/apache/flink/pull/18513#discussion_r792381026 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java ## @@

[GitHub] [flink] dawidwys commented on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

dawidwys commented on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1021948494 Sorry for nitpicking. Could we please pay more attention to PRs description? We should serve as an example if we require contributors to fill it in. -- This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

flinkbot edited a comment on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021030168 ## CI report: * 8a5911c18ec1611371a6257381205cce11d720a3 Azure:

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482307#comment-17482307 ] Zhu Zhu commented on FLINK-25649: - I took a look at the logs. Looks to me the problem is the slow leader

[jira] [Comment Edited] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482307#comment-17482307 ] Zhu Zhu edited comment on FLINK-25649 at 1/26/22, 7:40 AM: --- I took a look at

[GitHub] [flink] flinkbot edited a comment on pull request #18514: [FLINK-25816][changelog] Refactor the logic of notifying materialization id to nested state backend

flinkbot edited a comment on pull request #18514: URL: https://github.com/apache/flink/pull/18514#issuecomment-1021939543 ## CI report: * db5af6253d30f1e4e782269f07a24eeb72a9857f Azure:

[GitHub] [flink] LadyForest commented on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

LadyForest commented on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021941457 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot commented on pull request #18514: [FLINK-25816][changelog] Refactor the logic of notifying materialization id to nested state backend

flinkbot commented on pull request #18514: URL: https://github.com/apache/flink/pull/18514#issuecomment-1021939543 ## CI report: * db5af6253d30f1e4e782269f07a24eeb72a9857f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18514: [FLINK-25816][changelog] Refactor the logic of notifying materialization id to nested state backend

flinkbot commented on pull request #18514: URL: https://github.com/apache/flink/pull/18514#issuecomment-1021938589 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18504: [hotfix][azure] fix ArchUnit flag

flinkbot edited a comment on pull request #18504: URL: https://github.com/apache/flink/pull/18504#issuecomment-1021053731 ## CI report: * 187e515b3c9d3a773cc3e05cf0b3575f49385f08 Azure:

[jira] [Updated] (FLINK-25816) Changelog keyed state backend would come across NPE during notification

[ https://issues.apache.org/jira/browse/FLINK-25816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25816: --- Labels: pull-request-available (was: ) > Changelog keyed state backend would come across

[GitHub] [flink] Myasuka opened a new pull request #18514: [FLINK-25816][changelog] Refactor the logic of notifying materialization id to nested state backend

Myasuka opened a new pull request #18514: URL: https://github.com/apache/flink/pull/18514 ## What is the purpose of the change Correct the logic of FLINK-25524, and add tests to cover this case. ## Brief change log ## Verifying this change This change

[GitHub] [flink] flinkbot edited a comment on pull request #18504: [hotfix][azure] fix ArchUnit flag

flinkbot edited a comment on pull request #18504: URL: https://github.com/apache/flink/pull/18504#issuecomment-1021053731 ## CI report: * 187e515b3c9d3a773cc3e05cf0b3575f49385f08 Azure:

[GitHub] [flink] wsry commented on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

wsry commented on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-1021918232 @wanglijie95 Thanks for the update. Changes LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

flinkbot edited a comment on pull request #18513: URL: https://github.com/apache/flink/pull/18513#issuecomment-1021915660 ## CI report: * 38ad98b2e10ec448d765d59c0e7c23a61f1050a3 Azure:

[GitHub] [flink] flinkbot commented on pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

flinkbot commented on pull request #18513: URL: https://github.com/apache/flink/pull/18513#issuecomment-1021915660 ## CI report: * 38ad98b2e10ec448d765d59c0e7c23a61f1050a3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

flinkbot commented on pull request #18513: URL: https://github.com/apache/flink/pull/18513#issuecomment-1021915163 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25753: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] ruanhang1993 opened a new pull request #18513: [FLINK-25753][tests] Fix KafkaTableITCase.testStartFromGroupOffsetsLatest

ruanhang1993 opened a new pull request #18513: URL: https://github.com/apache/flink/pull/18513 ## What is the purpose of the change This pull request fix the test `KafkaTableITCase.testStartFromGroupOffsetsLatest`. ## Brief change log - Add some sleep time before

[jira] [Commented] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482282#comment-17482282 ] Hang Ruan commented on FLINK-25753: --- This test contains 3 phases: # insert data # flink job starts

[GitHub] [flink] flinkbot edited a comment on pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

flinkbot edited a comment on pull request #18461: URL: https://github.com/apache/flink/pull/18461#issuecomment-1019901761 ## CI report: * Unknown: [CANCELED](TBD) * d1b89b6f6e2a065fa456d804c185e23fc596f2be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

flinkbot edited a comment on pull request #18461: URL: https://github.com/apache/flink/pull/18461#issuecomment-1019901761 ## CI report: * Unknown: [CANCELED](TBD) * d1b89b6f6e2a065fa456d804c185e23fc596f2be UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] Aitozi commented on pull request #18461: [FLINK-20830][Kubernetes]Add type of Headless_Cluster_IP for external…

Aitozi commented on pull request #18461: URL: https://github.com/apache/flink/pull/18461#issuecomment-1021887135 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * 4df25a7dddbc72a36798c4fdcd495614290dfd3c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * 4df25a7dddbc72a36798c4fdcd495614290dfd3c Azure:

[GitHub] [flink] wanglijie95 commented on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

wanglijie95 commented on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-1021878402 Squashed commits. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * a6dbd924ac2ed76531a8fbce84bf37887bd51c14 Azure:

[jira] [Commented] (FLINK-25700) flinksql Cascading Window TVF Aggregation exception

[ https://issues.apache.org/jira/browse/FLINK-25700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482226#comment-17482226 ] Jing Zhang commented on FLINK-25700: [~simen]I agree with [~wenlong.lwl]it's not a bug. The

[jira] [Closed] (FLINK-25700) flinksql Cascading Window TVF Aggregation exception

[ https://issues.apache.org/jira/browse/FLINK-25700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-25700. -- Resolution: Not A Bug > flinksql Cascading Window TVF Aggregation exception >

[GitHub] [flink] flinkbot edited a comment on pull request #18483: [FLINK-24041][connectors] Removed public setter for elementConverter in As…

flinkbot edited a comment on pull request #18483: URL: https://github.com/apache/flink/pull/18483#issuecomment-1020286441 ## CI report: * dcee5a182d039ad0df770fb7b06528a1ba1a9f19 Azure:

[GitHub] [flink] JingsongLi merged pull request #18438: [hotfix][filesystem] Fix the typo in InProgressFileWriter

JingsongLi merged pull request #18438: URL: https://github.com/apache/flink/pull/18438 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 9aa4b3ae66483526e9236993c37b451d802a883a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * e7827ee1a27bf459ce67e861dc9d0bf90691c2fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[GitHub] [flink-web] sjwiesman commented on a change in pull request #501: Release announcement for Statefun 3.2.0

sjwiesman commented on a change in pull request #501: URL: https://github.com/apache/flink-web/pull/501#discussion_r792293548 ## File path: _posts/2022-01-27-release-statefun-3.2.0.md ## @@ -0,0 +1,111 @@ +--- +layout: post +title: "Stateful Functions 3.2.0 Release

[jira] [Commented] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482211#comment-17482211 ] Huang Xingbo commented on FLINK-25768: -- [~gaoyunhaii] Thanks a lot for reporting this. But I think

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[jira] [Created] (FLINK-25816) Changelog keyed state backend would come across NPE during notification

Yun Tang created FLINK-25816: Summary: Changelog keyed state backend would come across NPE during notification Key: FLINK-25816 URL: https://issues.apache.org/jira/browse/FLINK-25816 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[jira] [Commented] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482208#comment-17482208 ] Yun Gao commented on FLINK-25813: - Perhaps cc [~twalthr]~ > TableITCase.testCollectWithClose failed on

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482207#comment-17482207 ] Yun Gao commented on FLINK-24119: -

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482206#comment-17482206 ] Yun Gao commented on FLINK-23956: -

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482204#comment-17482204 ] Yun Gao commented on FLINK-25771: -

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[GitHub] [flink] wpc009 removed a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 removed a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021815826 The `release-1.14` branch can not pass the CI pipeline neither. Check this out. https://dev.azure.com/wpc009/Flink/_build/results?buildId=5=results What can

[GitHub] [flink] wpc009 edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021815826 The `release-1.14` branch can not pass the CI pipeline neither. Check this out. https://dev.azure.com/wpc009/Flink/_build/results?buildId=5=results What can I

[GitHub] [flink] wpc009 edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021815826 The `release-1.14` branch can not pass the CI pipeline neither. Check this out. https://dev.azure.com/wpc009/Flink/_build/results?buildId=5=results -- This is

[jira] [Created] (FLINK-25815) PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout

Yun Gao created FLINK-25815: --- Summary: PulsarSourceITCase.testTaskManagerFailure failed on azure due to timeout Key: FLINK-25815 URL: https://issues.apache.org/jira/browse/FLINK-25815 Project: Flink

[GitHub] [flink] wpc009 removed a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 removed a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021816172 Maybe I should push to `release-1.14` branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[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=17482203#comment-17482203 ] Yun Gao commented on FLINK-20928: -

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[jira] [Created] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

Yun Gao created FLINK-25814: --- Summary: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed Key: FLINK-25814 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 55dc41adb405ef5b55f78a3c0ebc12c3dcba8e90 Azure:

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482200#comment-17482200 ] Yun Gao commented on FLINK-16908: -

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16908: Affects Version/s: 1.14.3 > FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while >

[jira] [Commented] (FLINK-25281) Azure failed due to python tests "tox check failed"

[ https://issues.apache.org/jira/browse/FLINK-25281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482199#comment-17482199 ] Yun Gao commented on FLINK-25281: -

[GitHub] [flink] gaoyunhaii closed pull request #18510: [FLINK-18356][tests] Disable fork-reuse for table-planner

gaoyunhaii closed pull request #18510: URL: https://github.com/apache/flink/pull/18510 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * f883156429a6510b06a05e58ddd77fb8e0554516 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #18510: [FLINK-18356][tests] Disable fork-reuse for table-planner

gaoyunhaii commented on pull request #18510: URL: https://github.com/apache/flink/pull/18510#issuecomment-1021817194 LGTM, the ci-table would increased by ~ 15 mins, which would be acceptable as this is a temporary fix. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] wpc009 commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021816172 Maybe I should push to `release-1.14` branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] wpc009 edited a comment on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021815826 The master branch can not pass the CI pipeline neither. Check this out. https://dev.azure.com/wpc009/Flink/_build/results?buildId=5=results -- This is an

[GitHub] [flink] wpc009 commented on pull request #18475: [FLINK-25728] Protential memory leaks in StreamMultipleInputProcessor

wpc009 commented on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1021815826 The master branch can not pass the CI pipeline either. Check this out. https://dev.azure.com/wpc009/Flink/_build/results?buildId=5=results -- This is an automated

[jira] [Updated] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25813: Labels: test-stability (was: ) > TableITCase.testCollectWithClose failed on azure >

[jira] [Created] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

Yun Gao created FLINK-25813: --- Summary: TableITCase.testCollectWithClose failed on azure Key: FLINK-25813 URL: https://issues.apache.org/jira/browse/FLINK-25813 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 7937706340bfa394537cc62380693fa12abe3d38 Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #14: [FLINK-25803] Implement partition and bucket filter in FileStoreScanImpl

JingsongLi commented on a change in pull request #14: URL: https://github.com/apache/flink-table-store/pull/14#discussion_r791597053 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreScanImpl.java ## @@ -109,34 +176,72 @@

[GitHub] [flink] JingsongLi commented on pull request #18490: [FLINK-25794][sql-runtime] Clean cache after memory segments in it after they are released to MemoryManager

JingsongLi commented on pull request #18490: URL: https://github.com/apache/flink/pull/18490#issuecomment-1021804321 > Thanks @JingsongLi , I think I miss the operations in `MemoryManager` :( And another issue is in `BinaryHashTableTest.testBinaryHashBucketAreaNotEnoughMem`, there's no

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * f9955ef3952b0111eb413a2417e32f53aa0feb91 Azure:

[jira] [Assigned] (FLINK-25653) Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock

[ https://issues.apache.org/jira/browse/FLINK-25653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reassigned FLINK-25653: --- Assignee: Yuxin Tan > Move buffer recycle in SortMergeSubpartitionReader out of lock to

[GitHub] [flink] flinkbot edited a comment on pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

flinkbot edited a comment on pull request #17485: URL: https://github.com/apache/flink/pull/17485#issuecomment-943315428 ## CI report: * 9bd3feac7400f1ad0f6e14c1d37308cc9ff95011 Azure:

[jira] [Closed] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directories fairly

[ https://issues.apache.org/jira/browse/FLINK-21789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-21789. --- Resolution: Fixed > Make FileChannelManagerImpl#getNextPathNum select data directories fairly >

[jira] [Commented] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directories fairly

[ https://issues.apache.org/jira/browse/FLINK-21789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482187#comment-17482187 ] Yingjie Cao commented on FLINK-21789: - Merged into master via 

[GitHub] [flink] flinkbot edited a comment on pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

flinkbot edited a comment on pull request #18418: URL: https://github.com/apache/flink/pull/18418#issuecomment-1017307428 ## CI report: * 4e95ae2d0e8a2e2a2e3d85640d5ab125e86ede6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

flinkbot edited a comment on pull request #18418: URL: https://github.com/apache/flink/pull/18418#issuecomment-1017307428 ## CI report: * 4e95ae2d0e8a2e2a2e3d85640d5ab125e86ede6c Azure:

[GitHub] [flink] wsry closed pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

wsry closed pull request #18458: URL: https://github.com/apache/flink/pull/18458 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] wsry commented on pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

wsry commented on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1021795271 @TanYuxin-tyx Thanks for the contribution. Changes LGTM. Merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #18512: [FLINK-25811][hotfix][connector/base] changing failed requests handler to accept List in AsyncSinkWriter

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

[jira] [Closed] (FLINK-21790) Shuffle data directories to make directory selection of different TaskManagers fairer

[ https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-21790. --- Resolution: Fixed > Shuffle data directories to make directory selection of different >

[jira] [Commented] (FLINK-21790) Shuffle data directories to make directory selection of different TaskManagers fairer

[ https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482184#comment-17482184 ] Yingjie Cao commented on FLINK-21790: - Merged via 30d128d5cb99a8e5315f44303081521863bb616d on

[GitHub] [flink] wsry closed pull request #18456: [FLINK-21790][network] Shuffle data directories to make directory selection of different TaskManagers fairer

wsry closed pull request #18456: URL: https://github.com/apache/flink/pull/18456 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

[ https://issues.apache.org/jira/browse/FLINK-25475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482183#comment-17482183 ] ChangjiGuo commented on FLINK-25475: Hi, [~xuyangzhong]. Thanks for your reply! Similar to this kind

[GitHub] [flink] xintongsong closed pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

xintongsong closed pull request #18409: URL: https://github.com/apache/flink/pull/18409 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

flinkbot edited a comment on pull request #18479: URL: https://github.com/apache/flink/pull/18479#issuecomment-1020172062 ## CI report: * 03c350a4ffcb9db0fe01e9f109db58f6d59be813 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

flinkbot edited a comment on pull request #18479: URL: https://github.com/apache/flink/pull/18479#issuecomment-1020172062 ## CI report: * f3a4e6d5b7b5a91ba436a0d5bf70a2c323c7b458 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18427: [FLINK-25386][table] Harden table persisted plan

flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 228aec25fa06571e6e00e886da22e2598ca632b5 Azure:

[GitHub] [flink] xintongsong commented on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

xintongsong commented on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1021778799 For the record, I've added exclusions for `grpc` artifacts in the `flink-dist` pom, as @zentol suggested offline. This fixes the dependency resolving error without forcing

[GitHub] [flink] flinkbot edited a comment on pull request #18447: FLINK-25762 - [Deployment/kubernetes] Move JVM system properties args after log_settings

flinkbot edited a comment on pull request #18447: URL: https://github.com/apache/flink/pull/18447#issuecomment-1019286035 ## CI report: * 7084488fe09954c84d459bb698bc188b1aaed2dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18468: [FLINK-25810][connector/kinesis]Adding Kinesis data streams sql uber-jar and end to end test.

flinkbot edited a comment on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * c9ca1ae40dd0845541df78dc73eb6cad2a227ad6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

flinkbot edited a comment on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021030168 ## CI report: * 8a5911c18ec1611371a6257381205cce11d720a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18500: [FLINK-25312][hive] HiveCatalog supports Flink's managed table

flinkbot edited a comment on pull request #18500: URL: https://github.com/apache/flink/pull/18500#issuecomment-1021030168 ## CI report: * 8a5911c18ec1611371a6257381205cce11d720a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 5b563c6cc8147b9b4a5def1291ba7b71602e0b07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 5b563c6cc8147b9b4a5def1291ba7b71602e0b07 Azure:

[GitHub] [flink] dengziming commented on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

dengziming commented on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-1021746483 Thanks for your patience @fapaul , Done! 欄 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #18512: [FLINK-25811][hotfix][connector/base] changing failed requests handler to accept List in AsyncSinkWriter

flinkbot edited a comment on pull request #18512: URL: https://github.com/apache/flink/pull/18512#issuecomment-1021344642 ## CI report: * 18179cd7b5c28433ae7502e9ab2b0b12ff1665ad Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18511: [FLINK-25673] Harden AdaptiveSchedulerITCase by introducing MiniClust…

flinkbot edited a comment on pull request #18511: URL: https://github.com/apache/flink/pull/18511#issuecomment-1021344455 ## CI report: * 15a5b34cf1893338febec8b55f840dd642165c72 Azure:

  1   2   3   4   5   6   7   8   9   >