[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[jira] [Closed] (FLINK-24668) Pulsar consumption data repeated output

[ https://issues.apache.org/jira/browse/FLINK-24668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-24668. -- Resolution: Cannot Reproduce [~余嘉悦]  Since we don't have the necessary information to reproduc

[jira] [Updated] (FLINK-20733) Introduce the upsert-pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-20733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20733: --- Component/s: Connectors / Pulsar (was: Connectors / Common) > Introduce

[jira] [Commented] (FLINK-24246) Bump Pulsar to 2.9.0

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477634#comment-17477634 ] Martijn Visser commented on FLINK-24246: [~affe]  [~syhily] Will you pick up thi

[jira] [Updated] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25686: --- Issue Type: Technical Debt (was: New Feature) > Support Pulsar Schema evolution in Pulsar C

[jira] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686 ] Martijn Visser deleted comment on FLINK-25686: was (Author: martijnvisser): [~affe]  [~syhily] Will you pick up this ticket before the Flink 1.15 release branch is cut (on February 6th)?

[jira] [Commented] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477633#comment-17477633 ] Martijn Visser commented on FLINK-25686: [~affe]  [~syhily] Will you pick up thi

[GitHub] [flink] flinkbot edited a comment on pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

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

[jira] [Assigned] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-25686: --- Assignee: Yufei Zhang > Support Pulsar Schema evolution in Pulsar Connector > -

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

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

[GitHub] [flink] flinkbot edited a comment on pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

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

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #11: [FLINK-25687] DropDelete is incorrect in CompactManager when outputLevel is zero

tsreaper commented on a change in pull request #11: URL: https://github.com/apache/flink-table-store/pull/11#discussion_r786480063 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/CompactManager.java ## @@ -75,7 +75,8 @@ pu

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[jira] [Updated] (FLINK-25687) DropDelete is incorrect in CompactManager when outputLevel is zero

[ https://issues.apache.org/jira/browse/FLINK-25687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25687: --- Labels: pull-request-available (was: ) > DropDelete is incorrect in CompactManager when out

[GitHub] [flink-table-store] JingsongLi opened a new pull request #11: [FLINK-25687] DropDelete is incorrect in CompactManager when outputLevel is zero

JingsongLi opened a new pull request #11: URL: https://github.com/apache/flink-table-store/pull/11 When output level is zero, there may be have other files in level 0, we can not drop delete. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[jira] [Created] (FLINK-25687) DropDelete is incorrect in CompactManager when outputLevel is zero

Jingsong Lee created FLINK-25687: Summary: DropDelete is incorrect in CompactManager when outputLevel is zero Key: FLINK-25687 URL: https://issues.apache.org/jira/browse/FLINK-25687 Project: Flink

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

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

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17098: [FLINK-15648][flink-kubernetes] Support to configure limit for CPU & memory

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

[jira] [Closed] (FLINK-24899) Enable data compression for blocking shuffle by default

[ https://issues.apache.org/jira/browse/FLINK-24899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-24899. --- Resolution: Fixed > Enable data compression for blocking shuffle by default > --

[jira] [Commented] (FLINK-24899) Enable data compression for blocking shuffle by default

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

[GitHub] [flink] wsry closed pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

wsry closed pull request #17814: URL: https://github.com/apache/flink/pull/17814 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr..

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #17098: [FLINK-15648][flink-kubernetes] Support to configure limit for CPU & memory

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

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

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

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

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

zhuzhurk commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r786442228 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -159,50 +162,79 @@ public stati

[GitHub] [flink] wangyang0918 commented on a change in pull request #17098: [FLINK-15648][flink-kubernetes] Support to configure limit for CPU & memory

wangyang0918 commented on a change in pull request #17098: URL: https://github.com/apache/flink/pull/17098#discussion_r786443356 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/parameters/KubernetesJobManagerParameters.java ## @@ -122,6 +122

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18380: [FLINK-25676][python] Support set_description in DataStream API

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

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[jira] [Closed] (FLINK-25073) Introduce Tree Mode description for job vertex

[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25073. --- Resolution: Fixed Merged on master via f2d03b0baea08ed59eabb72afad6ebcc4c525036 > Introduce Tree Mode descr

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

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

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

[jira] [Commented] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477605#comment-17477605 ] Yufei Zhang commented on FLINK-25686: - Please assign this ticket to me [~fpaul] ~ Th

[jira] [Created] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

Yufei Zhang created FLINK-25686: --- Summary: Support Pulsar Schema evolution in Pulsar Connector Key: FLINK-25686 URL: https://issues.apache.org/jira/browse/FLINK-25686 Project: Flink Issue Type:

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] gaoyunhaii closed pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

gaoyunhaii closed pull request #17938: URL: https://github.com/apache/flink/pull/17938 -- 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] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

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

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r786444064 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java #

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

ruanhang1993 commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r786443847 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java ## @@ -

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

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

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

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

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

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

[jira] [Assigned] (FLINK-15648) Support to configure limit for CPU and memory requirement

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-15648: - Assignee: Denis Nutiu > Support to configure limit for CPU and memory requirement > ---

[jira] [Updated] (FLINK-25684) Support enhanced show databases syntax

[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25684: --- Labels: pull-request-available (was: ) > Support enhanced show databases syntax > -

[GitHub] [flink] ZhangChaoming opened a new pull request #18386: [FLINK-25684][table] Support enhanced show databases syntax

ZhangChaoming opened a new pull request #18386: URL: https://github.com/apache/flink/pull/18386 ## What is the purpose of the change Enhanced `show databases` statement like ` show databasesfrom like 'db%' ` has been supported broadly in many popular SQL engine like Spark SQL

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

flinkbot edited a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1013081147 ## CI report: * Unknown: [CANCELED](TBD) * 51ec010668d8237bb8e02de3848126a9a7f19620 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-462

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] 1996fanrui removed a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui removed a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1015007385 @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

[GitHub] [flink] 1996fanrui commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1015094837 @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 speci

[jira] [Created] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact

Xuannan Su created FLINK-25685: -- Summary: RestClusterClient gets stuck on submitting job with local user artifact Key: FLINK-25685 URL: https://issues.apache.org/jira/browse/FLINK-25685 Project: Flink

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzh updated FLINK-25683: Summary: wrong result if table transfrom to DataStream then window process in batch mode (was: wrong resu

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477584#comment-17477584 ] zhangzh commented on FLINK-25683: - hi @[~paul8263]  ： I found a new problem similar to F

[jira] [Updated] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25509: - Description: This feature is needed to migrate applications which uses KafkaDeserializationSchema::isEn

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzh updated FLINK-25683: Attachment: TableToDataStreamBatchWindowTest.scala > wrong result if table transfrom to DataStream then wi

[jira] [Commented] (FLINK-25684) Support enhanced show databases syntax

[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477583#comment-17477583 ] Moses commented on FLINK-25684: --- cc [~jark]  > Support enhanced show databases syntax > -

[jira] [Created] (FLINK-25684) Support enhanced show databases syntax

Moses created FLINK-25684: - Summary: Support enhanced show databases syntax Key: FLINK-25684 URL: https://issues.apache.org/jira/browse/FLINK-25684 Project: Flink Issue Type: Improvement Co

[jira] [Updated] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25509: - Summary: FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records (was:

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzh updated FLINK-25683: Attachment: (was: TableToDataStreamBatchWindowTest.scala) > wrong result if table transfrom to DataStr

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzh updated FLINK-25683: Description: I have 5 line datas, i first need to transform current data with SQL then mix current data an

[GitHub] [flink] wsry commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1015082277 @1996fanrui Maybe rebasing the latest master can make the tests pass. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzh updated FLINK-25683: Description: I have 5 line datas, i first need to transform current data with SQL then mix current data an

[GitHub] [flink] MartijnVisser commented on pull request #18366: [FLINK-25656][Kinesis] Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency fr

MartijnVisser commented on pull request #18366: URL: https://github.com/apache/flink/pull/18366#issuecomment-1015080853 @dannycranmer Will you merge this? -- 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

[GitHub] [flink] MartijnVisser commented on pull request #18367: [FLINK-25657][Kinesis] Upgrade com.amazonaws:amazon-kinesis-client dependency from 1.14.1 to 1.14.7

MartijnVisser commented on pull request #18367: URL: https://github.com/apache/flink/pull/18367#issuecomment-1015080680 @dannycranmer Will you merge this? -- 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

[jira] [Commented] (FLINK-25562) hive sql connector 依赖冲突

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477571#comment-17477571 ] Martijn Visser commented on FLINK-25562: [~luoyuxia] The documentation mentions

[jira] [Commented] (FLINK-25560) Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versions in changelog mode

[ https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477570#comment-17477570 ] Martijn Visser commented on FLINK-25560: [~Bruce Wong] If I look at your PR, the

[jira] [Commented] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477569#comment-17477569 ] Martijn Visser commented on FLINK-25070: Thanks for clarifying [~wenlong.lwl] 

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[jira] [Created] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

zhangzh created FLINK-25683: --- Summary: wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode Key: FLINK-25683 URL: https://issues.apache.org/jira/browse/FLINK-25683

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #18385: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot commented on pull request #18385: [FLINK-22643][network] Reuse tpc connections between taskmanagers

flinkbot commented on pull request #18385: URL: https://github.com/apache/flink/pull/18385#issuecomment-1015053663 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot edited a comment on pull request #18384: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] 1996fanrui opened a new pull request #18385: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui opened a new pull request #18385: URL: https://github.com/apache/flink/pull/18385 ## What is the purpose of the change Reuse tpc connections between taskmanagers ## Brief change log Reuse tpc connections between taskmanagers. ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

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

[GitHub] [flink] flinkbot commented on pull request #18384: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

  1   2   3   4   5   6   7   >