[jira] [Updated] (FLINK-26637) Document Basic Concepts and Architecture

2022-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26637: --- Labels: pull-request-available (was: ) > Document Basic Concepts and Architecture > ---

[jira] [Commented] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506735#comment-17506735 ] Yang Wang commented on FLINK-26639: --- Is this a step in "Creating a Flink Kubernetes Op

[GitHub] [flink] XComp merged pull request #19075: [FLINK-26500][runtime][test] Increases the deadline to wait for parallelism

2022-03-15 Thread GitBox
XComp merged pull request #19075: URL: https://github.com/apache/flink/pull/19075 -- 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.

[jira] [Commented] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-03-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506736#comment-17506736 ] Yun Gao commented on FLINK-25233: - I'll first move this issue to 1.16 since it seems to

[jira] [Updated] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-03-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25233: Affects Version/s: 1.15.0 (was: 1.16.0) > UpsertKafkaTableITCase.testAggregate

[jira] [Updated] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-03-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25233: Affects Version/s: 1.16.0 > UpsertKafkaTableITCase.testAggregate fails on AZP > --

[jira] [Updated] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-03-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25233: Fix Version/s: 1.16.0 (was: 1.15.0) > UpsertKafkaTableITCase.testAggregate fails on

[jira] [Updated] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-03-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25233: Affects Version/s: 1.16.0 (was: 1.15.0) > UpsertKafkaTableITCase.testAggregate

[GitHub] [flink] XComp merged pull request #19088: [FLINK-26500][BP-1.15][runtime][test] Increases the deadline to wait for parallelism

2022-03-15 Thread GitBox
XComp merged pull request #19088: URL: https://github.com/apache/flink/pull/19088 -- 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] XComp merged pull request #19076: [BP-1.14][FLINK-26500][runtime][test] Increases the deadline to wait for parallelism

2022-03-15 Thread GitBox
XComp merged pull request #19076: URL: https://github.com/apache/flink/pull/19076 -- 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.

[jira] [Resolved] (FLINK-26500) AdaptiveSchedulerClusterITCase.testAutomaticScaleUp failed on azure

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26500. --- Fix Version/s: 1.15.0 1.16.0 1.14.5 Resolution:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * afdaf43f43e70634a9df988f9a141144fb9b0918 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] twalthr closed pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

2022-03-15 Thread GitBox
twalthr closed pull request #18980: URL: https://github.com/apache/flink/pull/18980 -- 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

[jira] [Commented] (FLINK-26640) Consider changing flinkVersion to enum type or removing it completely

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506742#comment-17506742 ] Yang Wang commented on FLINK-26640: --- Given that we could not guarantee the internal in

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * fd8d787ed420aea973486d1e98af4670e266f30f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Created] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

2022-03-15 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-26645: --- Summary: Pulsar Source subscribe to a single topic partition will consume all partitions from that topic Key: FLINK-26645 URL: https://issues.apache.org/jira/browse/FLINK-26645

[GitHub] [flink] flinkbot edited a comment on pull request #19077: drop flink-sql-parser-hive module

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

[jira] [Created] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-26646: - Summary: Flink kubernetes operator helm template is broken Key: FLINK-26646 URL: https://issues.apache.org/jira/browse/FLINK-26646 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-26220) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on Azure Pipelines

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506744#comment-17506744 ] Matthias Pohl commented on FLINK-26220: --- This one also failed on a 1.14 backport:

[jira] [Updated] (FLINK-26220) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on Azure Pipelines

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26220: -- Affects Version/s: 1.14.4 > KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on Azure

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506745#comment-17506745 ] Yang Wang commented on FLINK-26646: --- cc [~gyfora]  > Flink kubernetes operator helm t

[GitHub] [flink] flinkbot edited a comment on pull request #19091: [BP-1.15][docs] Update wrong links in the datastream/execution_mode.md page.

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

[jira] [Comment Edited] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506745#comment-17506745 ] Yang Wang edited comment on FLINK-26646 at 3/15/22, 7:28 AM: -

[GitHub] [flink] imaffe opened a new pull request #19092: WIP: [FLINK-26645][Connector/Pulsar] Fix Pulsar source subscriber consume from all partitions when only subscribed to 1 partition

2022-03-15 Thread GitBox
imaffe opened a new pull request #19092: URL: https://github.com/apache/flink/pull/19092 ## What is the purpose of the change Fix FLINK-26645: When users specify only consume from 1 partition but the source consumes from all partitions. ## Brief change log -

[jira] [Commented] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2022-03-15 Thread xuxiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506747#comment-17506747 ] xuxiang commented on FLINK-25188: - We need to run pyflink on a linux arm server, looking

[jira] [Updated] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

2022-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26645: --- Labels: pull-request-available (was: ) > Pulsar Source subscribe to a single topic partitio

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-15 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506748#comment-17506748 ] Yingjie Cao commented on FLINK-26568: - I can not find any problem in the stack, I wi

[GitHub] [flink] paul8263 closed pull request #16109: [hotfix][connector-kafka] Fixed typo of the method name constructKafk…

2022-03-15 Thread GitBox
paul8263 closed pull request #16109: URL: https://github.com/apache/flink/pull/16109 -- 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-unsubs

[jira] [Commented] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506749#comment-17506749 ] Matthias Pohl commented on FLINK-26621: --- The same error was observed on a 1.14 bac

[jira] [Updated] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26621: -- Affects Version/s: 1.14.4 > flink-tests failed on azure due to Error occurred in starting fork

[GitHub] [flink] XComp commented on pull request #19082: [FLINK-26596][BP-1.14][runtime][test] Adds leadership loss handling

2022-03-15 Thread GitBox
XComp commented on pull request #19082: URL: https://github.com/apache/flink/pull/19082#issuecomment-1067659895 Errors in ci are unrelated: * FLINK-26220 * FLINK-26621 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] XComp merged pull request #19080: [FLINK-26121][BP-1.14][runtime] Adds clearUnhandledEvents() method

2022-03-15 Thread GitBox
XComp merged pull request #19080: URL: https://github.com/apache/flink/pull/19080 -- 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.

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506750#comment-17506750 ] Gyula Fora commented on FLINK-26646: when do you get this error? > Flink kubernetes

[GitHub] [flink] flinkbot commented on pull request #19092: WIP: [FLINK-26645][Connector/Pulsar] Fix Pulsar source subscriber consume from all partitions when only subscribed to 1 partition

2022-03-15 Thread GitBox
flinkbot commented on pull request #19092: URL: https://github.com/apache/flink/pull/19092#issuecomment-1067660495 ## CI report: * 7294f936a7361d9d3e5fdb2ddb87bd323a97ed2b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26121: -- Affects Version/s: 1.14.4 > ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterR

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506753#comment-17506753 ] Yang Wang commented on FLINK-26646: --- If you run the same command, I think you could re

[jira] [Comment Edited] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506752#comment-17506752 ] Matthias Pohl edited comment on FLINK-26121 at 3/15/22, 7:38 AM: -

[jira] [Resolved] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26121. --- Fix Version/s: 1.14.5 Resolution: Fixed 1.14: 2ecc3614201526a1cbb8bd3e5cee44d3f1f5b42

[jira] [Updated] (FLINK-26596) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

2022-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26596: -- Affects Version/s: 1.14.4 > ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterR

[GitHub] [flink-table-store] leonardBang opened a new pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
leonardBang opened a new pull request #44: URL: https://github.com/apache/flink-table-store/pull/44 * 1 Remove unnecessary html link tags * 2 Fix 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] XComp commented on pull request #19082: [FLINK-26596][BP-1.14][runtime][test] Adds leadership loss handling

2022-03-15 Thread GitBox
XComp commented on pull request #19082: URL: https://github.com/apache/flink/pull/19082#issuecomment-1067663904 rebased `release-1.14` after the [FLINK-26121 backport PR](https://github.com/apache/flink/pull/19080) was merged -- This is an automated message from the Apache Git Service. T

[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-03-15 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506755#comment-17506755 ] Yingjie Cao commented on FLINK-26568: - BTW, since 1.15, the sort-shuffle implementat

[GitHub] [flink] flinkbot edited a comment on pull request #19092: WIP: [FLINK-26645][Connector/Pulsar] Fix Pulsar source subscriber consume from all partitions when only subscribed to 1 partition

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

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506757#comment-17506757 ] Gyula Fora commented on FLINK-26646: for me this works correctly, could be a helm ve

[jira] [Closed] (FLINK-26421) Cleanup EnvironmentSettings and only use ConfigOptions

2022-03-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-26421. Fix Version/s: 1.15.0 Release Note: flink-conf.yaml and other configuration from outer layers

[jira] [Updated] (FLINK-26421) Propagate executor config to TableConfig

2022-03-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-26421: - Summary: Propagate executor config to TableConfig (was: Cleanup EnvironmentSettings and only us

[GitHub] [flink] wangyang0918 commented on a change in pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

2022-03-15 Thread GitBox
wangyang0918 commented on a change in pull request #18854: URL: https://github.com/apache/flink/pull/18854#discussion_r826665717 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java ## @@ -250,6 +243,32 @@ public v

[jira] [Updated] (FLINK-26421) Propagate executor config to TableConfig

2022-03-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-26421: - Description: * integrate Configuration into EnvironmentSettings * EnvironmentSettings should o

[GitHub] [flink] flinkbot edited a comment on pull request #19082: [FLINK-26596][BP-1.14][runtime][test] Adds leadership loss handling

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

[GitHub] [flink] flinkbot edited a comment on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19090: [BP-1.14][docs] Update wrong links in the datastream/execution_mode.md page.

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19090: URL: https://github.com/apache/flink/pull/19090#issuecomment-1067583371 ## CI report: * 11ef66762336f4bb29cc8a9d47df859aa0cab1f9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26647) Can not add extra config files on native Kubernetes

2022-03-15 Thread Zhe Wang (Jira)
Zhe Wang created FLINK-26647: Summary: Can not add extra config files on native Kubernetes Key: FLINK-26647 URL: https://issues.apache.org/jira/browse/FLINK-26647 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26528. -- Resolution: Fixed merged: ec2e0a11eda5e05619e683b4a661ac4875142bc2 > Trigger the updateControl when t

[GitHub] [flink] Myasuka commented on a change in pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

2022-03-15 Thread GitBox
Myasuka commented on a change in pull request #19051: URL: https://github.com/apache/flink/pull/19051#discussion_r826677119 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java ## @@ -145,

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
JingsongLi commented on a change in pull request #44: URL: https://github.com/apache/flink-table-store/pull/44#discussion_r826676368 ## File path: README.md ## @@ -1,19 +1,19 @@ -# FLink Table Store +# Flink Table Store Flink Table Store is a unified streaming and batch stor

[jira] [Updated] (FLINK-26647) Can not add extra config files on native Kubernetes

2022-03-15 Thread Zhe Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhe Wang updated FLINK-26647: - Description: When using native Kubernetes mode (both session and application), predefine FLINK_CONF_DIR

[GitHub] [flink] metaswirl opened a new pull request #19093: [FLINK-24960][yarn]enable log line of YarnClusterDescriptor

2022-03-15 Thread GitBox
metaswirl opened a new pull request #19093: URL: https://github.com/apache/flink/pull/19093 Enable log line to debug future instances of YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskMa

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

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

[jira] [Commented] (FLINK-26634) Update Chinese version of Elasticsearch connector docs

2022-03-15 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506768#comment-17506768 ] Alexander Preuss commented on FLINK-26634: -- Hi [~chenzihao] you can open the PR

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-15 Thread GitBox
ZhangChaoming commented on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1067685766 @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 sp

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506769#comment-17506769 ] Yang Wang commented on FLINK-26646: --- Hmm... It works with v3.8.0. > Flink kubernetes

[GitHub] [flink] MartijnVisser merged pull request #19090: [BP-1.14][docs] Update wrong links in the datastream/execution_mode.md page.

2022-03-15 Thread GitBox
MartijnVisser merged pull request #19090: URL: https://github.com/apache/flink/pull/19090 -- 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] MartijnVisser merged pull request #19091: [BP-1.15][docs] Update wrong links in the datastream/execution_mode.md page.

2022-03-15 Thread GitBox
MartijnVisser merged pull request #19091: URL: https://github.com/apache/flink/pull/19091 -- 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] [Closed] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page.

2022-03-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25800. -- Fix Version/s: 1.15.0 1.16.0 1.14.5 Resolution: Fi

[GitHub] [flink] Myasuka merged pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

2022-03-15 Thread GitBox
Myasuka merged pull request #18840: URL: https://github.com/apache/flink/pull/18840 -- 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

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

2022-03-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506771#comment-17506771 ] Martijn Visser commented on FLINK-25800: Fixed in release-1.15: 3b7eac6ca52d4dc0

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506772#comment-17506772 ] Gyula Fora commented on FLINK-26646: Maybe there is another way to do this check cor

[jira] [Updated] (FLINK-26320) Update hive doc for 1 m->1 min

2022-03-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26320: --- Fix Version/s: 1.15.0 (was: 1.16.0) > Update hive doc for 1 m->1 min

[jira] [Updated] (FLINK-25761) Translate Avro format page into Chinese.

2022-03-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25761: --- Fix Version/s: 1.15.0 (was: 1.16.0) > Translate Avro format page into

[GitHub] [flink] MartijnVisser commented on pull request #18982: [FLINK-26334][datastream] Fix getWindowStartWithOffset in TimeWindow.java

2022-03-15 Thread GitBox
MartijnVisser commented on pull request #18982: URL: https://github.com/apache/flink/pull/18982#issuecomment-1067689211 @zjuwangg Unfortunately this is not my expertise, so I can't review and merge it. -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506776#comment-17506776 ] Yang Wang commented on FLINK-26646: --- Yes. Maybe we could explicitly set the {{.Values.

[GitHub] [flink] golden-yang opened a new pull request #19094: [FLINK-26642][connector/pulsar] Fix support for non-partitioned topic

2022-03-15 Thread GitBox
golden-yang opened a new pull request #19094: URL: https://github.com/apache/flink/pull/19094 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring the

[jira] [Updated] (FLINK-26642) Pulsar sink fails with non-partitioned topic

2022-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26642: --- Labels: pull-request-available (was: ) > Pulsar sink fails with non-partitioned topic > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * fd8d787ed420aea973486d1e98af4670e266f30f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink-table-store] leonardBang commented on a change in pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
leonardBang commented on a change in pull request #44: URL: https://github.com/apache/flink-table-store/pull/44#discussion_r826693355 ## File path: README.md ## @@ -1,19 +1,19 @@ -# FLink Table Store +# Flink Table Store Flink Table Store is a unified streaming and batch sto

[jira] [Commented] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506778#comment-17506778 ] Gyula Fora commented on FLINK-26646: yes, let's do that and then we can avoid using

[GitHub] [flink-table-store] leonardBang commented on a change in pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
leonardBang commented on a change in pull request #44: URL: https://github.com/apache/flink-table-store/pull/44#discussion_r826694081 ## File path: README.md ## @@ -1,19 +1,19 @@ -# FLink Table Store +# Flink Table Store Flink Table Store is a unified streaming and batch sto

[GitHub] [flink] rkhachatryan commented on a change in pull request #19079: [FLINK-26573][test] Do not resolve the metadata file which is in prog…

2022-03-15 Thread GitBox
rkhachatryan commented on a change in pull request #19079: URL: https://github.com/apache/flink/pull/19079#discussion_r826697410 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationTestBase.java ## @@ -234,6 +235,25 @@ pr

[jira] [Commented] (FLINK-26642) Pulsar sink fails with non-partitioned topic

2022-03-15 Thread goldenyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506782#comment-17506782 ] goldenyang commented on FLINK-26642: [~affe] Thanks. Please take a look, we tried to

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

2022-03-15 Thread Niklas Semmler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506780#comment-17506780 ] Niklas Semmler commented on FLINK-24960: [~mapohl] and I debugged this some more

[GitHub] [flink-table-store] leonardBang commented on a change in pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
leonardBang commented on a change in pull request #44: URL: https://github.com/apache/flink-table-store/pull/44#discussion_r826700940 ## File path: README.md ## @@ -1,19 +1,19 @@ -# FLink Table Store +# Flink Table Store Flink Table Store is a unified streaming and batch sto

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18983: [FLINK-25543][flink-yarn] [JUnit5 Migration] Module: flink-yarn

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

[GitHub] [flink] flinkbot edited a comment on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

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

[GitHub] [flink-table-store] leonardBang commented on a change in pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
leonardBang commented on a change in pull request #44: URL: https://github.com/apache/flink-table-store/pull/44#discussion_r826701551 ## File path: README.md ## @@ -1,19 +1,19 @@ -# FLink Table Store +# Flink Table Store Flink Table Store is a unified streaming and batch sto

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-03-15 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506786#comment-17506786 ] Yao Zhang commented on FLINK-25916: --- Hi all, I think one potential point might be the

[GitHub] [flink] flinkbot edited a comment on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #19082: [FLINK-26596][BP-1.14][runtime][test] Adds leadership loss handling

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

[GitHub] [flink] flinkbot edited a comment on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 103331d5386317a184e7f363fa490a43842b8915 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] link3280 commented on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

2022-03-15 Thread GitBox
link3280 commented on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1067705775 @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 specifi

[jira] [Updated] (FLINK-25528) support state processor api to create native savepoint

2022-03-15 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-25528: - Summary: support state processor api to create native savepoint (was: support state processor api to cr

[jira] [Resolved] (FLINK-25528) support state processor api to create checkpoint

2022-03-15 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-25528. -- Resolution: Fixed Merged in master: a0d31c5e0914d8e759917a72ca7b667d3db2f1d2 > support state processo

[GitHub] [flink] rkhachatryan commented on a change in pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

2022-03-15 Thread GitBox
rkhachatryan commented on a change in pull request #19051: URL: https://github.com/apache/flink/pull/19051#discussion_r826709921 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-15 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * c53142c8b103fd6da55bb95d600d59a01e1f3198 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

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

[jira] [Comment Edited] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-03-15 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506786#comment-17506786 ] Yao Zhang edited comment on FLINK-25916 at 3/15/22, 8:41 AM: -

[jira] [Comment Edited] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-03-15 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506786#comment-17506786 ] Yao Zhang edited comment on FLINK-25916 at 3/15/22, 8:41 AM: -

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
JingsongLi commented on a change in pull request #44: URL: https://github.com/apache/flink-table-store/pull/44#discussion_r826710166 ## File path: README.md ## @@ -1,19 +1,19 @@ -# FLink Table Store +# Flink Table Store Flink Table Store is a unified streaming and batch stor

[jira] [Assigned] (FLINK-26646) Flink kubernetes operator helm template is broken

2022-03-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26646: -- Assignee: Gyula Fora > Flink kubernetes operator helm template is broken > --

[GitHub] [flink-table-store] leonardBang merged pull request #44: [hotfix][docs] Remove unnecessary html link tags and fix typo

2022-03-15 Thread GitBox
leonardBang merged pull request #44: URL: https://github.com/apache/flink-table-store/pull/44 -- 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: issu

  1   2   3   4   5   6   >