[GitHub] [flink] flinkbot commented on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

flinkbot commented on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1020817984 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

[jira] [Updated] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

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

[GitHub] [flink] RocMarshal opened a new pull request #18492: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

RocMarshal opened a new pull request #18492: URL: https://github.com/apache/flink/pull/18492 ## What is the purpose of the change Translate datastream/formats/parquet.md page into Chinese. ## Brief change log Translate datastream/formats/parquet.md pa

[jira] [Updated] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page.

[ https://issues.apache.org/jira/browse/FLINK-25800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25800: --- Labels: pull-request-available (was: ) > Update wrong links in the datastream/execution_mod

[GitHub] [flink] RocMarshal opened a new pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

RocMarshal opened a new pull request #18491: URL: https://github.com/apache/flink/pull/18491 ## What is the purpose of the change Update wrong links in the datastream/execution_mode.md page. ## Brief change log Update wrong links in the datastream/execution_m

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

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

[jira] [Updated] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page.

[ https://issues.apache.org/jira/browse/FLINK-25800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25800: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Update wrong links in the dat

[jira] [Created] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page.

RocMarshal created FLINK-25800: -- Summary: Update wrong links in the datastream/execution_mode.md page. Key: FLINK-25800 URL: https://issues.apache.org/jira/browse/FLINK-25800 Project: Flink Iss

[jira] [Updated] (FLINK-25799) Translate table/filesystem.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25799: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Translate table/filesystem.md

[jira] [Created] (FLINK-25799) Translate table/filesystem.md page into Chinese.

RocMarshal created FLINK-25799: -- Summary: Translate table/filesystem.md page into Chinese. Key: FLINK-25799 URL: https://issues.apache.org/jira/browse/FLINK-25799 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-25798) Translate datastream/formats/text_files.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25798: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Translate datastream/formats/

[jira] [Created] (FLINK-25798) Translate datastream/formats/text_files.md page into Chinese.

RocMarshal created FLINK-25798: -- Summary: Translate datastream/formats/text_files.md page into Chinese. Key: FLINK-25798 URL: https://issues.apache.org/jira/browse/FLINK-25798 Project: Flink Is

[jira] [Updated] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25797: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Translate datastream/formats/

[jira] [Created] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

RocMarshal created FLINK-25797: -- Summary: Translate datastream/formats/parquet.md page into Chinese. Key: FLINK-25797 URL: https://issues.apache.org/jira/browse/FLINK-25797 Project: Flink Issue

[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: * ddf6b397383be3096f061ee5f292c6bf0b204fa6 Azure: [FAILURE](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

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

[jira] [Comment Edited] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481536#comment-17481536 ] RocMarshal edited comment on FLINK-25738 at 1/25/22, 4:48 AM:

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

sap1ens commented on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1020808128 Great, 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 comm

[jira] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481536#comment-17481536 ] RocMarshal commented on FLINK-25738: I checked docs/content.zh/docs/deployment/files

[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 * b4803c1d8c0492316000c796a5f37e0427d61563 Azure: [CANCELED](https://dev.azure.com/apache-

[jira] [Assigned] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25171: -- Assignee: shouzuo meng > When the DDL statement was executed, the column names of the Derived

[jira] [Closed] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-25171. -- Fix Version/s: 1.15.0 1.14.4 (was: 1.14.0) Resolution:

[GitHub] [flink] flinkbot edited a comment on pull request #18470: [FLINK-25774][network] Restrict the maximum number of buffers can be used per result partition for sort-shuffle

flinkbot edited a comment on pull request #18470: URL: https://github.com/apache/flink/pull/18470#issuecomment-1020036276 ## CI report: * decf33d57cf16564786d77240287fb1aeb034b39 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * 1cc4394ed63adc3729cc13c2ef7aebebdf0d4e87 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18487: [FLINK-25788][Table SQL / API] Add show connectors command

flinkbot edited a comment on pull request #18487: URL: https://github.com/apache/flink/pull/18487#issuecomment-1020369201 ## CI report: * f21ff12e6f34e59cc11d951088135d9e017ce9b8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18488: [FLINK-24041][connector] Fixing reversed insertion of failed requests

flinkbot edited a comment on pull request #18488: URL: https://github.com/apache/flink/pull/18488#issuecomment-1020394995 ## CI report: * 78e08b716545affbb0d76bfbd836332a3d2a7e96 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25704) Performance regression on 18.01.2022 in batch network benchmarks

[ https://issues.apache.org/jira/browse/FLINK-25704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reassigned FLINK-25704: --- Assignee: Yingjie Cao > Performance regression on 18.01.2022 in batch network benchmarks >

[jira] [Commented] (FLINK-25704) Performance regression on 18.01.2022 in batch network benchmarks

[ https://issues.apache.org/jira/browse/FLINK-25704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481531#comment-17481531 ] Yingjie Cao commented on FLINK-25704: - After some analysis, I found that these tests

[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: * 813bf185c6d59236e078f25146340c53d3d88b98 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481468#comment-17481468 ] Yun Gao edited comment on FLINK-18356 at 1/25/22, 4:05 AM: --- Wi

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] godfreyhe closed pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

godfreyhe closed pull request #18017: URL: https://github.com/apache/flink/pull/18017 -- 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-unsub

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: * 74d1e741ca802ee8375d34b015a040b8c63286cf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: * 74d1e741ca802ee8375d34b015a040b8c63286cf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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-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] dengziming commented on a change in pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

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] galenwarren commented on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

galenwarren commented on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1020781392 @xintongsong Thanks. @sap1ens FYI, the serializer version change will go in with this PR. -- This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18486: [Test Only] Checks the memory usage for flink-table/flink-table-planner ci pipeline

flinkbot edited a comment on pull request #18486: URL: https://github.com/apache/flink/pull/18486#issuecomment-1020338268 ## CI report: * 54126b0e8379955ad9ea97da4377bf7be490a1b0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1020104543 ## CI report: * 3ade9719b565beeacf7761ab71d5abb7ba62e62a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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-1020772870 > ## CI report: > * [3ade971](https://github.com/apache/flink/commit/3ade9719b565beeacf7761ab71d5abb7ba62e62a) Azure: [FAILURE](https://dev.azure.com/apache-flink/984

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

galenwarren commented on a change in pull request #18489: URL: https://github.com/apache/flink/pull/18489#discussion_r791329772 ## 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] 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-1020772870 > ## CI report: > * [3ade971](https://github.com/apache/flink/commit/3ade9719b565beeacf7761ab71d5abb7ba62e62a) Azure: [FAILURE](https://dev.azure.com/apache-flink/984

[jira] [Closed] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-25758. Fix Version/s: 1.15.0 Resolution: Fixed Fixed via: - master (1.15): 1a6e3387fdf974a05488f1b

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

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] zuston commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

zuston commented on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-1020775523 Thanks @gaoyunhaii and @Myasuka again :) -- 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #18485: [FLINK-25791][table-planner] Compact ObjectIdentifier json representation

flinkbot edited a comment on pull request #18485: URL: https://github.com/apache/flink/pull/18485#issuecomment-1020338030 ## CI report: * cea34e5e3bb33d04c0564286514f879ce4046b1d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18475: URL: https://github.com/apache/flink/pull/18475#issuecomment-1020104543 ## CI report: * 3ade9719b565beeacf7761ab71d5abb7ba62e62a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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-1020772870 > ## CI report: > * [3ade971](https://github.com/apache/flink/commit/3ade9719b565beeacf7761ab71d5abb7ba62e62a) Azure: [FAILURE](https://dev.azure.com/apache-flink/984

[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-1020772870 > ## CI report: > * [3ade971](https://github.com/apache/flink/commit/3ade9719b565beeacf7761ab71d5abb7ba62e62a) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1

[GitHub] [flink] flinkbot edited a comment on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * 82871d3416aefbce86d6e32e3e26a51c12841534 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[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-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] galenwarren commented on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

galenwarren commented on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1020770497 @xintongsong Thanks for making the serializer version change. I'm only seeing it in `GSCommitRecoverableSerializer`, were you also planning to change it in `GSResum

[GitHub] [flink] flinkbot edited a comment on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * 82871d3416aefbce86d6e32e3e26a51c12841534 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[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

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

[jira] [Created] (FLINK-25796) Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

Yingjie Cao created FLINK-25796: --- Summary: Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance Key: FLINK-25796 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Assigned] (FLINK-25796) Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

[ https://issues.apache.org/jira/browse/FLINK-25796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reassigned FLINK-25796: --- Assignee: Yingjie Cao > Avoid record copy for result partition of sort-shuffle if there are

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #18474: [FLINK-25786][network] Adjust the generation of subpartition data storage order for sort-shuffle from random shuffle to rand

TanYuxin-tyx commented on a change in pull request #18474: URL: https://github.com/apache/flink/pull/18474#discussion_r791322643 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -492,10 +490,13 @@ publi

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

flinkbot edited a comment on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 ## CI report: * 572d143d54fb5f9c87c5e251e3c2e1816a0249ed Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18452: URL: https://github.com/apache/flink/pull/18452#issuecomment-1019527627 ## CI report: * d9507c8a77a6674f949c2f19e0f75c2419b87396 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

galenwarren commented on pull request #18489: URL: https://github.com/apache/flink/pull/18489#issuecomment-1020764001 Please let me know if there's anything else you would suggest I change in terms of the implementation, besides what you've already suggested, and then I'll look at unit tes

[jira] [Closed] (FLINK-25520) Implement "ALTER TABLE ... COMPACT" SQL

[ https://issues.apache.org/jira/browse/FLINK-25520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25520. Resolution: Fixed master: 25e07a7dc96e9e8ad4fec2a0b8f36664f44495ef c8dce176e4576cf55aeef4c79252c

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

galenwarren commented on a change in pull request #18489: URL: https://github.com/apache/flink/pull/18489#discussion_r791320371 ## 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] JingsongLi closed pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi closed pull request #18394: URL: https://github.com/apache/flink/pull/18394 -- 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-unsu

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

galenwarren commented on a change in pull request #18489: URL: https://github.com/apache/flink/pull/18489#discussion_r791320218 ## 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 #18458: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

flinkbot edited a comment on pull request #18458: URL: https://github.com/apache/flink/pull/18458#issuecomment-1019767867 ## CI report: * 572d143d54fb5f9c87c5e251e3c2e1816a0249ed Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * dafb491becd249f55bef64d9cf5276d692dd75f7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

galenwarren commented on a change in pull request #18489: URL: https://github.com/apache/flink/pull/18489#discussion_r791317887 ## 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] 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-1020759975 @galenwarren, > Instead of moving the dependency management to flink-parent, could we duplicate the same dependency-management entries in flink-dist? That might be a

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

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

[jira] [Assigned] (FLINK-25329) Improvement of execution graph store in flink session cluster for jobs

[ https://issues.apache.org/jira/browse/FLINK-25329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-25329: -- Assignee: Shammon > Improvement of execution graph store in flink session cluster for jobs >

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

flinkbot edited a comment on pull request #18456: URL: https://github.com/apache/flink/pull/18456#issuecomment-1019691654 ## CI report: * dafb491becd249f55bef64d9cf5276d692dd75f7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18409: [hotfix][dist] Fix that flink-gs-fs-hadoop not included in flink-dist

flinkbot edited a comment on pull request #18409: URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626 ## CI report: * 74c02f4b21ad4488b0466a748114e26f15495c4e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] KarmaGYZ commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

KarmaGYZ commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1020757804 Thanks for your review @XComp . These days, @zjureel and I do the investigation on whether this PR would cause FLINK-18356. As @xintongsong comments, we try to not expose two

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r791314908 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[GitHub] [flink] flinkbot edited a comment on pull request #18470: [FLINK-25774][network] Restrict the maximum number of buffers can be used per result partition for sort-shuffle

flinkbot edited a comment on pull request #18470: URL: https://github.com/apache/flink/pull/18470#issuecomment-1020036276 ## CI report: * decf33d57cf16564786d77240287fb1aeb034b39 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r791314908 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r791313073 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

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

flinkbot edited a comment on pull request #18490: URL: https://github.com/apache/flink/pull/18490#issuecomment-1020751414 ## CI report: * 0b17412ebe9b3b32233c36516fec6aed5865170d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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] flinkbot edited a comment on pull request #18470: [FLINK-25774][network] Restrict the maximum number of buffers can be used per result partition for sort-shuffle

flinkbot edited a comment on pull request #18470: URL: https://github.com/apache/flink/pull/18470#issuecomment-1020036276 ## CI report: * decf33d57cf16564786d77240287fb1aeb034b39 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 ## CI report: * b42032867fb8a31ac9dd068ec1ae0f35f477952c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * bf9ffe09e2eec6f03c9c1c5f18cf95b323088549 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r791311410 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[GitHub] [flink] curcur commented on a change in pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

curcur commented on a change in pull request #18431: URL: https://github.com/apache/flink/pull/18431#discussion_r791311410 ## File path: docs/content/docs/ops/state/state_backends.md ## @@ -325,6 +325,126 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFa

[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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18412: [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

flinkbot edited a comment on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201 ## CI report: * b42032867fb8a31ac9dd068ec1ae0f35f477952c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] wsry commented on pull request #18470: [FLINK-25774][network] Restrict the maximum number of buffers can be used per result partition for sort-shuffle

wsry commented on pull request #18470: URL: https://github.com/apache/flink/pull/18470#issuecomment-1020750943 @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 co

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481506#comment-17481506 ] Xintong Song commented on FLINK-25577: -- Thanks [~galenwarren]. This release note lo

[jira] [Updated] (FLINK-25696) Introduce metadataConsumer to InitContext in Sink

[ https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25696: - Description: In Table Store, we want to get the offsets of kafka writer, only the offset return

[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

flinkbot commented on pull request #18490: URL: https://github.com/apache/flink/pull/18490#issuecomment-1020750446 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] wsry commented on pull request #15302: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

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] wsry closed pull request #15302: [FLINK-21789][network] Make FileChannelManagerImpl#getNextPathNum select data directories fairly

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

<    1   2   3   4   5   6   7   8   9   10   >