[GitHub] [flink] MartijnVisser commented on pull request #18634: [FLINK-25961] [connectors] Remove transport client from Elasticsearch/7 connectors (tests only)

2022-03-29 Thread GitBox
MartijnVisser commented on pull request #18634: URL: https://github.com/apache/flink/pull/18634#issuecomment-1082699828 @reta The only thing that is suboptimal here is the commit message; while it starts with `[FLINK-25961] [connectors]` it would be better to include the actual connector y

[GitHub] [flink] flinkbot edited a comment on pull request #19273: [FLINK-25256][streaming] Externally induced sources replay barriers received over RPC instead of inventing them out of thin air. [1.1

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19273: URL: https://github.com/apache/flink/pull/19273#issuecomment-1082308938 ## CI report: * 8e8ce56d109d02065f6f68fbb478180207016a9b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26879) LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

2022-03-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26879: - Parent: FLINK-26653 Issue Type: Sub-task (was: Bug) > LogStartupMode.LATEST and LogStar

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request #75: [FLINK-26100] Add link to document website in README

2022-03-29 Thread GitBox
yunfengzhou-hub opened a new pull request #75: URL: https://github.com/apache/flink-ml/pull/75 This PR adds a link to Flink ML's document website in README.md. The added content is referenced from Flink repo's README. -- This is an automated message from the Apache Git Service. To respon

[jira] [Updated] (FLINK-26920) Job executes failed with "The configured managed memory fraction for Python worker process must be within (0, 1], was: %s."

2022-03-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26920: Summary: Job executes failed with "The configured managed memory fraction for Python worker process must b

[jira] [Closed] (FLINK-26879) LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

2022-03-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26879. Resolution: Fixed master: d1a8b6fe2113654f3ba107969b3373ae459b4c5d > LogStartupMode.LATEST and Lo

[GitHub] [flink-table-store] JingsongLi merged pull request #65: [FLINK-26879] Fix that LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

2022-03-29 Thread GitBox
JingsongLi merged pull request #65: URL: https://github.com/apache/flink-table-store/pull/65 -- 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: issue

[jira] [Created] (FLINK-26920) It reported "The configured managed memory fraction for Python worker process must be within (0, 1], was: %s."

2022-03-29 Thread Dian Fu (Jira)
Dian Fu created FLINK-26920: --- Summary: It reported "The configured managed memory fraction for Python worker process must be within (0, 1], was: %s." Key: FLINK-26920 URL: https://issues.apache.org/jira/browse/FLINK-269

[jira] [Updated] (FLINK-26898) Introduce creating table document for table store

2022-03-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26898: --- Labels: pull-request-available (was: ) > Introduce creating table document for table store

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #66: [FLINK-26898] Introduce creating table document for table store

2022-03-29 Thread GitBox
LadyForest commented on a change in pull request #66: URL: https://github.com/apache/flink-table-store/pull/66#discussion_r837342493 ## File path: docs/content/docs/development/create-table.md ## @@ -0,0 +1,153 @@ +--- +title: "Create Table" +weight: 2 +type: docs +aliases: +-

[GitHub] [flink] flinkbot edited a comment on pull request #19269: [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

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

[GitHub] [flink] flinkbot edited a comment on pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1082595206 ## CI report: * dd080fe4c62df22212af4b5b75eb8f6755a43f40 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-web] infoverload commented on a change in pull request #516: Tidying up snapshots

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #516: URL: https://github.com/apache/flink-web/pull/516#discussion_r838152506 ## File path: _posts/2022-04-01-tidying-snapshots-up.md ## @@ -0,0 +1,213 @@ +--- +layout: post +title: "Tidying up snapshots" +date: 2022-04-01T00:

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838148551 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838148790 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink] flinkbot edited a comment on pull request #19276: [FLINK-26882][tests] Fix unstable RescaleCheckpointManuallyITCase

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

[jira] [Commented] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-29 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514452#comment-17514452 ] Yun Tang commented on FLINK-26882: -- First of all, thanks very much for [~akalashnikov]'

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838146254 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838146254 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #71: [FLINK-26443] Add benchmark framework

2022-03-29 Thread GitBox
yunfengzhou-hub commented on pull request #71: URL: https://github.com/apache/flink-ml/pull/71#issuecomment-1082653503 Thanks for the comments. I have updated the PR according to the comments. -- This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838146254 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

2022-03-29 Thread GitBox
yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r838146291 ## File path: flink-ml-benchmark/README.md ## @@ -0,0 +1,261 @@ +# Flink ML Benchmark Guideline + +This document provides instructions about how to r

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

2022-03-29 Thread GitBox
yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r838146133 ## File path: flink-ml-benchmark/README.md ## @@ -0,0 +1,261 @@ +# Flink ML Benchmark Guideline + +This document provides instructions about how to r

[GitHub] [flink] flinkbot commented on pull request #19276: [FLINK-26882][tests] Fix unstable RescaleCheckpointManuallyITCase

2022-03-29 Thread GitBox
flinkbot commented on pull request #19276: URL: https://github.com/apache/flink/pull/19276#issuecomment-1082652854 ## CI report: * f36dddbeccdeed5a0d55656f5c8db27afd750952 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838144602 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838144107 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[jira] [Created] (FLINK-26919) Table API program compiles field with "Cannot resolve field [a], input field list:[EXPR$0]"

2022-03-29 Thread Dian Fu (Jira)
Dian Fu created FLINK-26919: --- Summary: Table API program compiles field with "Cannot resolve field [a], input field list:[EXPR$0]" Key: FLINK-26919 URL: https://issues.apache.org/jira/browse/FLINK-26919 Pro

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838143218 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838142903 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink] Myasuka opened a new pull request #19276: [FLINK-26882][tests] Fix unstable RescaleCheckpointManuallyITCase

2022-03-29 Thread GitBox
Myasuka opened a new pull request #19276: URL: https://github.com/apache/flink/pull/19276 ## What is the purpose of the change Fix unstable `RescaleCheckpointManuallyITCase` via ensuring contents of state within SubtaskIndexFlatMapper are all included in the last checkpoint. #

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838141023 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838140153 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" +date: 2022-03-17 16:00:00

[GitHub] [flink-web] infoverload commented on a change in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

2022-03-29 Thread GitBox
infoverload commented on a change in pull request #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r838139849 ## File path: _posts/2022-03-16-async-sink-base.md ## @@ -0,0 +1,138 @@ +--- +layout: post +title: "Asynchronous Base Sink" Review comment: ``

[GitHub] [flink] flinkbot edited a comment on pull request #19269: [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19269: URL: https://github.com/apache/flink/pull/19269#issuecomment-1081793711 ## CI report: * 3e77dc114261cc91cc80159c95fa27e74b25b8ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19269: [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19269: URL: https://github.com/apache/flink/pull/19269#issuecomment-1081793711 ## CI report: * 3e77dc114261cc91cc80159c95fa27e74b25b8ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19268: [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

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

[GitHub] [flink] flinkbot edited a comment on pull request #19268: [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

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

[GitHub] [flink] wanglijie95 edited a comment on pull request #19266: [hotfix][doc] Modify spelling error in elastic_scaling.md

2022-03-29 Thread GitBox
wanglijie95 edited a comment on pull request #19266: URL: https://github.com/apache/flink/pull/19266#issuecomment-1082595991 Thanks for your fix @Myracle, and thanks for review @MartijnVisser , can you help to pick this change to release 1.15? Because the release 1.15 also has this problem

[jira] [Commented] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

2022-03-29 Thread cjjxfli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514427#comment-17514427 ] cjjxfli commented on FLINK-24031: - *I have the same problem.*   2022-03-21 03:41:55,535

[GitHub] [flink] flinkbot edited a comment on pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

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

[GitHub] [flink] wanglijie95 edited a comment on pull request #19266: [hotfix][doc] Modify spelling error in elastic_scaling.md

2022-03-29 Thread GitBox
wanglijie95 edited a comment on pull request #19266: URL: https://github.com/apache/flink/pull/19266#issuecomment-1082595991 Thanks for your fix @Myracle, and thanks for your review @MartijnVisser , can you help to pick this change to release 1.15? Because the release 1.15 also has this pr

[GitHub] [flink] wanglijie95 commented on pull request #19266: [hotfix][doc] Modify spelling error in elastic_scaling.md

2022-03-29 Thread GitBox
wanglijie95 commented on pull request #19266: URL: https://github.com/apache/flink/pull/19266#issuecomment-1082595991 Thanks for your fix @Myracle, and thanks for your review@MartijnVisser, can you help to pick this change to release 1.15? Because the release 1.15 also has this problem.

[GitHub] [flink] flinkbot commented on pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-03-29 Thread GitBox
flinkbot commented on pull request #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1082595206 ## CI report: * dd080fe4c62df22212af4b5b75eb8f6755a43f40 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2022-03-29 Thread GitBox
baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-1082593810 @RocMarshal @zentol @AHeise PTAL thx -- 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] Thesharing commented on a change in pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-03-29 Thread GitBox
Thesharing commented on a change in pull request #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r838093153 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -618,12 +620,16 @@ private void runJob(JobManagerR

[jira] [Updated] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-03-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24491: --- Labels: pull-request-available (was: ) > ExecutionGraphInfo may not be archived when the di

[GitHub] [flink] Thesharing opened a new pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-03-29 Thread GitBox
Thesharing opened a new pull request #19275: URL: https://github.com/apache/flink/pull/19275 ## Brief change log With this change, the job won't be terminated until the archiving of its ExecutionGraphInfo finishes or a timeout happens. The timeout is set to be the same as the value

[GitHub] [flink] shizhengchao commented on pull request #19268: [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 sinc

2022-03-29 Thread GitBox
shizhengchao commented on pull request #19268: URL: https://github.com/apache/flink/pull/19268#issuecomment-1082591227 There seems to be no JUnit 5 in release-1.14,so I'm going to switch back to JUnit 4. same for release-1.13 -- This is an automated message from the Apache Git Service.

[jira] [Created] (FLINK-26918) Add documentation build to Github Actions

2022-03-29 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26918: Summary: Add documentation build to Github Actions Key: FLINK-26918 URL: https://issues.apache.org/jira/browse/FLINK-26918 Project: Flink Issue Type: Sub-tas

[jira] [Comment Edited] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect

2022-03-29 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514050#comment-17514050 ] shizhengchao edited comment on FLINK-26033 at 3/30/22, 3:06 AM: --

[GitHub] [flink] shizhengchao edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since

2022-03-29 Thread GitBox
shizhengchao edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1081797123 @PatrickRen I combined multiple commits into one,and created another 2 PRs to cherry-pick the commit onto release-1.13 and release-1.14 -- This is an automated me

[GitHub] [flink] imaffe closed pull request #19274: WIP: [Table] Pulsar Table Connector

2022-03-29 Thread GitBox
imaffe closed pull request #19274: URL: https://github.com/apache/flink/pull/19274 -- 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 commented on pull request #19274: WIP: [Table] Pulsar Table Connector

2022-03-29 Thread GitBox
flinkbot commented on pull request #19274: URL: https://github.com/apache/flink/pull/19274#issuecomment-1082569848 ## CI report: * f53e254ef2bc6db1316b9a3ba55b267d5f07e5a3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] imaffe opened a new pull request #19274: WIP: [Table] Pulsar Table Connector

2022-03-29 Thread GitBox
imaffe opened a new pull request #19274: URL: https://github.com/apache/flink/pull/19274 Cherry-picked [FLINK-25686] because wanted to use the PulsarDeserializationSchema interface. Will ignore it when merging into develop. [DO NOT MERGE: modify PulsarMessage to support keyBytes()]

[jira] [Commented] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-03-29 Thread cjjxfli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514408#comment-17514408 ] cjjxfli commented on FLINK-25735: - Hello, Zichen Liu. I would like to transfer it to Chi

[GitHub] [flink] flinkbot edited a comment on pull request #19268: [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

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

[jira] [Assigned] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-03-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-24491: --- Assignee: Zhilong Hong > ExecutionGraphInfo may not be archived when the dispatcher terminates > --

[jira] [Updated] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-03-29 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-24491: - Affects Version/s: 1.14.4 1.13.6 (was: 1.14.0)

[jira] [Commented] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-03-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514406#comment-17514406 ] Zhu Zhu commented on FLINK-24491: - Thanks for reporting this problem and offering to fix

[jira] [Comment Edited] (FLINK-26397) Chinese Translation - Add documentation for Kinesis firehose Table Api

2022-03-29 Thread cjjxfli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514402#comment-17514402 ] cjjxfli edited comment on FLINK-26397 at 3/30/22, 2:44 AM: --- He

[jira] [Commented] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-03-29 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514404#comment-17514404 ] Zhilong Hong commented on FLINK-24491: -- Hi, [~zhuzh], I'd like to take this JIRA. W

[jira] [Commented] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

2022-03-29 Thread cjjxfli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514405#comment-17514405 ] cjjxfli commented on FLINK-25737: - Hello, Zichen Liu. I would like to transfer it to Chi

[GitHub] [flink] flinkbot edited a comment on pull request #19269: [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19269: URL: https://github.com/apache/flink/pull/19269#issuecomment-1081793711 ## CI report: * 3e77dc114261cc91cc80159c95fa27e74b25b8ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-03-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-24491: Fix Version/s: 1.16.0 (was: 1.15.0) (was: 1.13.7)

[jira] [Commented] (FLINK-26397) Chinese Translation - Add documentation for Kinesis firehose Table Api

2022-03-29 Thread cjjxfli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514402#comment-17514402 ] cjjxfli commented on FLINK-26397: - Hello, [Anton Kalashnikov|https://issues.apache.org/

[GitHub] [flink] flinkbot edited a comment on pull request #19268: [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19268: URL: https://github.com/apache/flink/pull/19268#issuecomment-1081772063 ## CI report: * d4f374237b21aab93f5d185cb2d1e15a29c9c537 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19268: [FLINK-26033][BP-1.14][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19268: URL: https://github.com/apache/flink/pull/19268#issuecomment-1081772063 ## CI report: * d4f374237b21aab93f5d185cb2d1e15a29c9c537 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-web] liuzhuang2017 opened a new pull request #521: [hotfix][docs] Fix link tags typo.

2022-03-29 Thread GitBox
liuzhuang2017 opened a new pull request #521: URL: https://github.com/apache/flink-web/pull/521 [hotfix][docs] Fix link tags typo. -- 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-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

2022-03-29 Thread GitBox
yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r838060042 ## File path: flink-ml-dist/src/main/flink-ml-bin/bin/flink-ml-benchmark.sh ## @@ -0,0 +1,61 @@ +#!/usr/bin/env bash +###

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

2022-03-29 Thread GitBox
yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r838059820 ## File path: flink-ml-benchmark/README.md ## @@ -0,0 +1,261 @@ +# Flink ML Benchmark Guideline + +This document provides instructions about how to r

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #71: [FLINK-26443] Add benchmark framework

2022-03-29 Thread GitBox
yunfengzhou-hub commented on a change in pull request #71: URL: https://github.com/apache/flink-ml/pull/71#discussion_r838059470 ## File path: flink-ml-benchmark/README.md ## @@ -0,0 +1,261 @@ +# Flink ML Benchmark Guideline + +This document provides instructions about how to r

[GitHub] [flink] flinkbot edited a comment on pull request #19269: [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19269: URL: https://github.com/apache/flink/pull/19269#issuecomment-1081793711 ## CI report: * 8b18e74cec71c9c480bb747fb2f77a55f675ca2a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect

2022-03-29 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514050#comment-17514050 ] shizhengchao edited comment on FLINK-26033 at 3/30/22, 2:24 AM: --

[GitHub] [flink] shizhengchao edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since

2022-03-29 Thread GitBox
shizhengchao edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1081797123 @PatrickRen I combined multiple commits into one,and created another 2 PRs to cherry-pick the commit onto release-1.13 and release-1.14 master: 2049f849a130e73875

[GitHub] [flink] flinkbot edited a comment on pull request #19269: [FLINK-26033][BP-1.13][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 s

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #19269: URL: https://github.com/apache/flink/pull/19269#issuecomment-1081793711 ## CI report: * 8b18e74cec71c9c480bb747fb2f77a55f675ca2a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] shizhengchao edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since

2022-03-29 Thread GitBox
shizhengchao edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1081797123 @PatrickRen I combined multiple commits into one,and created another 2 PRs to cherry-pick the commit onto release-1.13 and release-1.14 master: 2049f849a130e73875

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 9ddc19d5d88145649fcc1adae809cd7f8524b138 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-29 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 217349f0fb67a58c79664f9ae0067618c821b800 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink-web] liuzhuang2017 closed pull request #520: fix link tags typo

2022-03-29 Thread GitBox
liuzhuang2017 closed pull request #520: URL: https://github.com/apache/flink-web/pull/520 -- 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-u

[GitHub] [flink-web] liuzhuang2017 commented on pull request #520: fix link tags typo

2022-03-29 Thread GitBox
liuzhuang2017 commented on pull request #520: URL: https://github.com/apache/flink-web/pull/520#issuecomment-1082482640 [hotfix][docs] Fix link tags typo -- 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-web] liuzhuang2017 closed pull request #520: fix link tags typo

2022-03-29 Thread GitBox
liuzhuang2017 closed pull request #520: URL: https://github.com/apache/flink-web/pull/520 -- 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-u

[jira] [Updated] (FLINK-25616) Support VectorAssembler in FlinkML

2022-03-29 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25616: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Closed] (FLINK-26092) JsonAggregationFunctionsITCase fails with NPE when using RocksDB

2022-03-29 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-26092. - > JsonAggregationFunctionsITCase fails with NPE when using RocksDB > ---

[jira] [Updated] (FLINK-26092) JsonAggregationFunctionsITCase fails with NPE when using RocksDB

2022-03-29 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26092: -- Affects Version/s: 1.16.0 (was: 1.14.3) > JsonAggregationFu

[jira] [Resolved] (FLINK-26092) JsonAggregationFunctionsITCase fails with NPE when using RocksDB

2022-03-29 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-26092. --- Fix Version/s: 1.15.0 1.16.0 Resolution: Fixed Fix merged

[GitHub] [flink] rkhachatryan commented on pull request #19249: [FLINK-26092][table-runtime] Fix `JSON_OBJECTAGG` when emitting `NULL`

2022-03-29 Thread GitBox
rkhachatryan commented on pull request #19249: URL: https://github.com/apache/flink/pull/19249#issuecomment-1082412095 The test failure is likely unrelated: ``` Mar 29 18:37:08 [ERROR] pure virtual method called Mar 29 18:37:08 [ERROR] terminate called without an active exception

  1   2   3   4   5   >