[GitHub] [flink] flinkbot edited a comment on pull request #18509: [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18509: URL: https://github.com/apache/flink/pull/18509#issuecomment-1021313694 ## CI report: * 892bdf21c8191f8b2356c26aca4a262a5a27ae9f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * ef2b24b71a3cc3ed707b71184158e9033abdedad Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * 4d4b6ef9bf6c75d3dbbe3d64b58eb5ffcc218ebf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-18356) Exit code 137 returned from process

2022-01-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-18356: Assignee: Chesnay Schepler > Exit code 137 returned from process > --

[GitHub] [flink] dmvk opened a new pull request #18511: [FLINK-25673] Harden AdaptiveSchedulerITCase by introducing MiniClust…

2022-01-25 Thread GitBox
dmvk opened a new pull request #18511: URL: https://github.com/apache/flink/pull/18511 Fixes race conditions related to freeing of the slot resources when reusing the MiniCluster between multiple tests. https://issues.apache.org/jira/browse/FLINK-25673 -- This is an automated mess

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481909#comment-17481909 ] Piotr Nowojski commented on FLINK-25728: Thanks for reporting and analysing the

[jira] [Updated] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

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

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * ef2b24b71a3cc3ed707b71184158e9033abdedad Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] vahmed-hamdy opened a new pull request #18512: [hotfix][connector/base] changing failed requests handler to accept List in AsyncSinkWriter

2022-01-25 Thread GitBox
vahmed-hamdy opened a new pull request #18512: URL: https://github.com/apache/flink/pull/18512 ## What is the purpose of the change Changing `submitRequests` in `AsyncSinkWriter` to accept `List` instead of a `Collection` ## Brief change log - Chang

[jira] [Created] (FLINK-25809) Introduce test infra for building FLIP-190 tests

2022-01-25 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-25809: --- Summary: Introduce test infra for building FLIP-190 tests Key: FLINK-25809 URL: https://issues.apache.org/jira/browse/FLINK-25809 Project: Flink

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * 4d4b6ef9bf6c75d3dbbe3d64b58eb5ffcc218ebf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot commented on pull request #18511: URL: https://github.com/apache/flink/pull/18511#issuecomment-1021336919 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 pr

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

2022-01-25 Thread GitBox
flinkbot commented on pull request #18510: URL: https://github.com/apache/flink/pull/18510#issuecomment-1021336953 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 pr

[GitHub] [flink] flinkbot commented on pull request #18512: [hotfix][connector/base] changing failed requests handler to accept List in AsyncSinkWriter

2022-01-25 Thread GitBox
flinkbot commented on pull request #18512: URL: https://github.com/apache/flink/pull/18512#issuecomment-1021340293 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 pr

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * 4df25a7dddbc72a36798c4fdcd495614290dfd3c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * 4d4b6ef9bf6c75d3dbbe3d64b58eb5ffcc218ebf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot commented on pull request #18510: URL: https://github.com/apache/flink/pull/18510#issuecomment-1021344276 ## CI report: * 06a7c87735c0314c8dfbb599e761708f61e34c92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-01-25 Thread GitBox
flinkbot commented on pull request #18511: URL: https://github.com/apache/flink/pull/18511#issuecomment-1021344455 ## CI report: * 034c29f216b935723cfb59584ed1149ff671d0a0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18512: [hotfix][connector/base] changing failed requests handler to accept List in AsyncSinkWriter

2022-01-25 Thread GitBox
flinkbot commented on pull request #18512: URL: https://github.com/apache/flink/pull/18512#issuecomment-1021344642 ## CI report: * 18179cd7b5c28433ae7502e9ab2b0b12ff1665ad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-25810) [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams.

2022-01-25 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-25810: --- Summary: [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams. Key: FLINK-25810 URL: https://issues.apache.org/jira/browse/FLINK-25810 Project: Flink

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * 4d4b6ef9bf6c75d3dbbe3d64b58eb5ffcc218ebf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18511: URL: https://github.com/apache/flink/pull/18511#issuecomment-1021344455 ## CI report: * 15a5b34cf1893338febec8b55f840dd642165c72 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@fl

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18512: URL: https://github.com/apache/flink/pull/18512#issuecomment-1021344642 ## CI report: * 18179cd7b5c28433ae7502e9ab2b0b12ff1665ad Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18510: [FLINK-18356][tests] Disable fork-reuse for table-planner

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18510: URL: https://github.com/apache/flink/pull/18510#issuecomment-1021344276 ## CI report: * 06a7c87735c0314c8dfbb599e761708f61e34c92 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25699) Use HashMap for MAP value constructors

2022-01-25 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481922#comment-17481922 ] Francesco Guardiani commented on FLINK-25699: - {quote}In theory both could b

[jira] [Comment Edited] (FLINK-25699) Use HashMap for MAP value constructors

2022-01-25 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481922#comment-17481922 ] Francesco Guardiani edited comment on FLINK-25699 at 1/25/22, 4:14 PM: ---

[jira] [Updated] (FLINK-25810) [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams.

2022-01-25 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-25810: Description: h2. Motivation *User stories:* As a Flink user, I’d like to have an uber-jar for kin

[GitHub] [flink] flinkbot edited a comment on pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18388: URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179 ## CI report: * 197cb1c9be6b942d40c90caf3318d8de77ba3208 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18511: URL: https://github.com/apache/flink/pull/18511#issuecomment-1021344455 ## CI report: * 15a5b34cf1893338febec8b55f840dd642165c72 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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.

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * 6ac66f07be10e8c320e77b89e41fc6ba17b1571e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25810) [FLIP-171] Add Uber-jar for sql connector for KinesisDataStreams.

2022-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25810: --- Labels: pull-request-available (was: ) > [FLIP-171] Add Uber-jar for sql connector for Kine

[GitHub] [flink] metaswirl commented on a change in pull request #18511: [FLINK-25673] Harden AdaptiveSchedulerITCase by introducing MiniClust…

2022-01-25 Thread GitBox
metaswirl commented on a change in pull request #18511: URL: https://github.com/apache/flink/pull/18511#discussion_r791892512 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java ## @@ -99,15 +101,29 @@ public void before() thro

[GitHub] [flink] twalthr closed pull request #18464: [FLINK-25769][table] Add internal functions and basic function versioning

2022-01-25 Thread GitBox
twalthr closed pull request #18464: URL: https://github.com/apache/flink/pull/18464 -- 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: issues-unsubsc

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

2022-01-25 Thread GitBox
pnowojski commented on a change in pull request #18475: URL: https://github.com/apache/flink/pull/18475#discussion_r791869485 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java ## @@ -55,17 +77,24 @@ public

[jira] [Closed] (FLINK-25769) Add internal functions and basic function versioning

2022-01-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25769. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: commit 72ed6b8f59a7cb200eb872bf8d

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * 07cec81a669917e2eb1531b2c054e04110781dfe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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.

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18468: URL: https://github.com/apache/flink/pull/18468#issuecomment-1019969068 ## CI report: * 6ac66f07be10e8c320e77b89e41fc6ba17b1571e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * e6d959da396523b05fdc25889fd2f1859857c70e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
wsry closed pull request #15302: URL: https://github.com/apache/flink/pull/15302 -- 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: issues-unsubscr..

[GitHub] [flink] flinkbot edited a comment on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1019527627 -- 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

[GitHub] [flink] HuangXingBo commented on a change in pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

2022-01-25 Thread GitBox
HuangXingBo commented on a change in pull request #18418: URL: https://github.com/apache/flink/pull/18418#discussion_r791473431 ## File path: flink-python/src/main/java/org/apache/flink/python/PythonOptions.java ## @@ -214,4 +214,25 @@ + "in

[GitHub] [flink] fapaul commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-01-25 Thread GitBox
fapaul commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r791763232 ## File path: flink-connectors/flink-connector-elasticsearch7/pom.xml ## @@ -91,6 +91,14 @@ under the License.

[GitHub] [flink] curcur commented on pull request #18223: [FLINK-25423][state-processor-api] Enable loading state backend via configuration in state processor api

2022-01-25 Thread GitBox
curcur commented on pull request #18223: URL: https://github.com/apache/flink/pull/18223#issuecomment-1021053692 @rkhachatryan would you please help review this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #18499: [hotfix][docs] Fixed error for Hive ZH docs.

2022-01-25 Thread GitBox
flinkbot commented on pull request #18499: URL: https://github.com/apache/flink/pull/18499#issuecomment-1020917616 -- 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 unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #18506: [FLINK-25805][table-planner] Use the DataType compact representation by default when using default conversion classes

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18506: URL: https://github.com/apache/flink/pull/18506#issuecomment-1021193813 ## CI report: * 31ecf11d9be5d256921dc0ae5b33e682c671a023 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] dianfu commented on a change in pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

2022-01-25 Thread GitBox
dianfu commented on a change in pull request #18418: URL: https://github.com/apache/flink/pull/18418#discussion_r790681717 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/CommonPythonUtil.java ## @@ -158,6 +158,2

[GitHub] [flink] flinkbot edited a comment on pull request #18456: [FLINK-21790][network] Shuffle data directories to make directory selection of different TaskManagers fairer

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 -- 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

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

2022-01-25 Thread GitBox
dengziming commented on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-1020782737 Thank you @alpreu for your suggestions, done! PTAL again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink] fapaul edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

2022-01-25 Thread GitBox
fapaul edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1020262180 > I don't think we need to put it inside the mailbox, it would be very performance intensive, it's a per record operation. A callback consumer, which I think has asynchro

[GitHub] [flink] matriv commented on pull request #18479: [FLINK-25387] Introduce ExecNodeMetadata

2022-01-25 Thread GitBox
matriv commented on pull request #18479: URL: https://github.com/apache/flink/pull/18479#issuecomment-1021300386 FYI, the `consumedOptions` in the annotation is not populated yet, will be done with a followup commit, or followup PR. -- This is an automated message from the Apache Git Ser

[GitHub] [flink] flinkbot commented on pull request #18495: [hotfix] [docs] Updated doc with flink image name and tag

2022-01-25 Thread GitBox
flinkbot commented on pull request #18495: URL: https://github.com/apache/flink/pull/18495#issuecomment-1020843477 -- 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 unsubs

[GitHub] [flink] rkhachatryan commented on pull request #18223: [FLINK-25423][state-processor-api] Enable loading state backend via configuration in state processor api

2022-01-25 Thread GitBox
rkhachatryan commented on pull request #18223: URL: https://github.com/apache/flink/pull/18223#issuecomment-1021195246 No problem @curcur, I'll take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[GitHub] [flink] flinkbot edited a comment on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020820553 -- 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

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

2022-01-25 Thread GitBox
flinkbot commented on pull request #18490: URL: https://github.com/apache/flink/pull/18490#issuecomment-1020750446 -- 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 unsubs

[GitHub] [flink] tillrohrmann commented on pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-25 Thread GitBox
tillrohrmann commented on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1020379351 I will merge this PR once AZP gives green light. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] flinkbot edited a comment on pull request #18503: [FLINK-25331][tests] FlinkImageBuilder checks for Java 17

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18503: URL: https://github.com/apache/flink/pull/18503#issuecomment-1021048687 ## CI report: * 7097d061789080c31131fd093db5277465028c69 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-01-25 Thread GitBox
galenwarren commented on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1020770497 -- 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 uns

[GitHub] [flink] flinkbot edited a comment on pull request #18481: [FLINK-25307][test] Change e2e nodename used to 127.0.0.1 and add debug information

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18481: URL: https://github.com/apache/flink/pull/18481#issuecomment-1020251442 -- 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

[GitHub] [flink] JingsongLi commented on pull request #16207: [FLINK-23031][table-runtime]Make processing time trigger dont repeat itself when no new element come in

2022-01-25 Thread GitBox
JingsongLi commented on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-1020852457 CC: @wuchong -- 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 co

[GitHub] [flink] xintongsong commented on a change in pull request #18489: [FLINK-25790][flink-gs-fs-hadoop] Support authentication via core-site.xml in GCS FileSystem plugin

2022-01-25 Thread GitBox
xintongsong commented on a change in pull request #18489: URL: https://github.com/apache/flink/pull/18489#discussion_r791304149 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/GSFileSystem.java ## @@ -39,17 +45,67 @@ GSFileSystem(

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 -- 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

[jira] [Commented] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-25 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang commented on FLINK-25728: - That's correct. A bunch *CompletableFuture* instances

[GitHub] [flink] xintongsong commented on a change in pull request #18417: [FLINK-15455][network] Enabled tcp connection reuse across multi jobs.

2022-01-25 Thread GitBox
xintongsong commented on a change in pull request #18417: URL: https://github.com/apache/flink/pull/18417#discussion_r791620680 ## File path: flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java ## @@ -286,6 +286,26 @@

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-25 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:39 PM: --- Th

[GitHub] [flink-statefun] tillrohrmann commented on a change in pull request #284: [FLINK-25775] Add Javascript SDK documentation

2022-01-25 Thread GitBox
tillrohrmann commented on a change in pull request #284: URL: https://github.com/apache/flink-statefun/pull/284#discussion_r791504850 ## File path: docs/content/docs/sdk/js.md ## @@ -0,0 +1,267 @@ +--- +title: JavaScript +weight: 2 +type: docs +aliases: + - /sdk/js.html +--- +

[GitHub] [flink] MartijnVisser commented on a change in pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-25 Thread GitBox
MartijnVisser commented on a change in pull request #18430: URL: https://github.com/apache/flink/pull/18430#discussion_r791784252 ## File path: docs/content/docs/deployment/filesystems/gcs.md ## @@ -50,57 +48,66 @@ env.getCheckpointConfig().setCheckpointStorage("gs:///"); `

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18511: URL: https://github.com/apache/flink/pull/18511#issuecomment-1021344455 -- 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

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-25 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM: --- Th

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-25 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM: --- Th

[GitHub] [flink] deadwind4 commented on pull request #18454: [hotfix][connector/pulsar] Fix typo in JavaDocs example.

2022-01-25 Thread GitBox
deadwind4 commented on pull request #18454: URL: https://github.com/apache/flink/pull/18454#issuecomment-1020906388 @syhily Could you review this? Thanks a lot. -- 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 #18412: [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 -- 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

[jira] [Comment Edited] (FLINK-25728) Potential memory leaks in StreamMultipleInputProcessor

2022-01-25 Thread pc wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481944#comment-17481944 ] pc wang edited comment on FLINK-25728 at 1/25/22, 4:40 PM: --- Th

[GitHub] [flink] xintongsong closed pull request #18452: [FLINK-25758][flink-gs-fs-hadoop] Fix licensing issues

2022-01-25 Thread GitBox
xintongsong closed pull request #18452: URL: https://github.com/apache/flink/pull/18452 -- 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: issues-uns

[GitHub] [flink] flinkbot edited a comment on pull request #18368: [FLINK-18356][Azure] Enforce memory limits for docker containers

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18368: URL: https://github.com/apache/flink/pull/18368#issuecomment-1013194055 ## CI report: * 74a00fd69ea3321fded40d1b6bafae149523ed75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18501: [FLINK-25348][build] Clear japicmp exclusions

2022-01-25 Thread GitBox
flinkbot commented on pull request #18501: URL: https://github.com/apache/flink/pull/18501#issuecomment-1021033444 -- 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 unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 -- 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

[GitHub] [flink] wanglijie95 commented on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-25 Thread GitBox
wanglijie95 commented on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1020983443 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 specif

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

2022-01-25 Thread GitBox
Aitozi commented on pull request #18461: URL: https://github.com/apache/flink/pull/18461#issuecomment-1020771452 I will solve the conflict first -- 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 t

[GitHub] [flink] flinkbot commented on pull request #18492: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

2022-01-25 Thread GitBox
flinkbot commented on pull request #18492: URL: https://github.com/apache/flink/pull/18492#issuecomment-1020819365 -- 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 unsubs

[GitHub] [flink] metaswirl commented on a change in pull request #18511: [FLINK-25673] Harden AdaptiveSchedulerITCase by introducing MiniClust…

2022-01-25 Thread GitBox
metaswirl commented on a change in pull request #18511: URL: https://github.com/apache/flink/pull/18511#discussion_r791892512 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java ## @@ -99,15 +101,29 @@ public void before() thro

[GitHub] [flink] wangyang0918 commented on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

2022-01-25 Thread GitBox
wangyang0918 commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1020753728 @XComp > But I don't understand you claim that it make sense to have the REST suffix included in KubernetesLabel. I cannot even find a place where we use the clusterId

[GitHub] [flink] galenwarren commented on a change in pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-25 Thread GitBox
galenwarren commented on a change in pull request #18430: URL: https://github.com/apache/flink/pull/18430#discussion_r791256107 ## File path: docs/content/docs/deployment/filesystems/gcs.md ## @@ -50,57 +48,40 @@ env.getCheckpointConfig().setCheckpointStorage("gs:///"); ```

[GitHub] [flink] flinkbot commented on pull request #18508: [FLINK-25808][rest][docs] JsonTypeInfo property uses valid java identier

2022-01-25 Thread GitBox
flinkbot commented on pull request #18508: URL: https://github.com/apache/flink/pull/18508#issuecomment-1021290369 -- 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 unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #18472: [FLINK-25783][docs-zh] Translate azure_table_storage.md page into Chinese.

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18472: URL: https://github.com/apache/flink/pull/18472#issuecomment-1020057651 -- 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

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

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18512: URL: https://github.com/apache/flink/pull/18512#issuecomment-1021344642 ## CI report: * 18179cd7b5c28433ae7502e9ab2b0b12ff1665ad Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18497: [FLINK-25290][tests] add table tests for connector testframe

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18497: URL: https://github.com/apache/flink/pull/18497#issuecomment-1020875715 -- 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

[GitHub] [flink] jelly-1203 commented on pull request #18493: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

2022-01-25 Thread GitBox
jelly-1203 commented on pull request #18493: URL: https://github.com/apache/flink/pull/18493#issuecomment-1020840973 thanks -- 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.

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

2022-01-25 Thread GitBox
dengziming commented on a change in pull request #18145: URL: https://github.com/apache/flink/pull/18145#discussion_r791334012 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java ## @@ -281,27 +

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

2022-01-25 Thread GitBox
wsry commented on pull request #15302: URL: https://github.com/apache/flink/pull/15302#issuecomment-1020750288 Dropped. -- 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

[GitHub] [flink] flinkbot commented on pull request #18494: [FLINK-25307][DEBUG-ONLY] Add debug message

2022-01-25 Thread GitBox
flinkbot commented on pull request #18494: URL: https://github.com/apache/flink/pull/18494#issuecomment-1020833025 -- 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 unsubs

[GitHub] [flink] deadwind4 commented on a change in pull request #18388: [FLINK-25530][python][connector/pulsar] Support Pulsar source connector in Python DataStream API.

2022-01-25 Thread GitBox
deadwind4 commented on a change in pull request #18388: URL: https://github.com/apache/flink/pull/18388#discussion_r791295394 ## File path: flink-connectors/pom.xml ## @@ -105,6 +105,7 @@ under the License. flink-sql-connector-hive-3.1.2

[GitHub] [flink] imaffe commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-01-25 Thread GitBox
imaffe commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r791349039 ## File path: flink-connectors/flink-connector-pulsar/pom.xml ## @@ -163,13 +202,22 @@ under the License. -

[GitHub] [flink] fapaul commented on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-25 Thread GitBox
fapaul commented on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1021113345 @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 #18485: [FLINK-25791][table-planner] Compact ObjectIdentifier json representation

2022-01-25 Thread GitBox
flinkbot edited a comment on pull request #18485: URL: https://github.com/apache/flink/pull/18485#issuecomment-1020338030 -- 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

<    1   2   3   4   5   6   7   8   9   >