[GitHub] [flink] flinkbot edited a comment on pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * be93b585eabdaba6a77da99623c0b4d6fe26b18a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 3106843ca012891cf1d66a58972e5800b7e75791 Azure:

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

flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * be93b585eabdaba6a77da99623c0b4d6fe26b18a Azure:

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

flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * be93b585eabdaba6a77da99623c0b4d6fe26b18a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * ba14f53fc37cbd60b25c0addfa925f4e1be39768 Azure:

[GitHub] [flink] slinkydeveloper commented on pull request #18287: [FLINK-17321][table] Add support casting of map to map and multiset to multiset

slinkydeveloper commented on pull request #18287: URL: https://github.com/apache/flink/pull/18287#issuecomment-1007282991 @snuyanzin I rather prefer that the multiset e2e casting gets worked out in a separate issue, as it requires significant more testing to check that it works throughout

[GitHub] [flink] twalthr commented on a change in pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

twalthr commented on a change in pull request #18274: URL: https://github.com/apache/flink/pull/18274#discussion_r780160827 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeJsonSerializer.java ## @@

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

flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * 317d5e9013cc571510f8cbd77bb7b6bba8aded2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * ba14f53fc37cbd60b25c0addfa925f4e1be39768 Azure:

[jira] [Updated] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

[ https://issues.apache.org/jira/browse/FLINK-5325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5325: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-5409) Separate Job API from the Runtime

[ https://issues.apache.org/jira/browse/FLINK-5409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5409: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-22764) Disable Values Source node in streaming plan optimization

[ https://issues.apache.org/jira/browse/FLINK-22764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22764: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-5301) Can't upload job via Web UI when using a proxy

[ https://issues.apache.org/jira/browse/FLINK-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5301: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-5284) Make output of bucketing sink compatible with other processing framework like mapreduce

[ https://issues.apache.org/jira/browse/FLINK-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5284: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17196: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[GitHub] [flink] flinkbot commented on pull request #18295: [hotfix][rpc] Use AtomicLong#getAndIncrement to simplify increment number

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

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 8b30dbb1acd4bffe0c4c5d25b669705deb19463e Azure:

[jira] [Updated] (FLINK-5351) Make the TypeExtractor support functions with more than 2 inputs

[ https://issues.apache.org/jira/browse/FLINK-5351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5351: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

[ https://issues.apache.org/jira/browse/FLINK-5572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5572: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * ba14f53fc37cbd60b25c0addfa925f4e1be39768 Azure:

[GitHub] [flink] Myracle opened a new pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

Myracle opened a new pull request #18296: URL: https://github.com/apache/flink/pull/18296 ## What is the purpose of the change *When the config high-availability.zookeeper.client.tolerate-suspended-connections is default false, the appMaster will failover once zk leader changes. In

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * 31108c79f41b48c4dfe2eca5d65da3986375ebf8 Azure:

[jira] [Updated] (FLINK-25568) Add Elasticsearch 7 Source Connector

[ https://issues.apache.org/jira/browse/FLINK-25568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25568: --- Labels: pull-request-available (was: ) > Add Elasticsearch 7 Source Connector >

[jira] [Created] (FLINK-25571) Update Elasticsearch Sink to use decomposed interfaces

Fabian Paul created FLINK-25571: --- Summary: Update Elasticsearch Sink to use decomposed interfaces Key: FLINK-25571 URL: https://issues.apache.org/jira/browse/FLINK-25571 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #18300: Update H2 to 2.0.206 to address CVE-2021-42392.

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

[GitHub] [flink] dmvk commented on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

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

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

flinkbot edited a comment on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1007423214 ## CI report: * 263332284671263487781ebdc8f0be10b0d925d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18298: [FLINK-25307][Test] Print the curl logs is querying dispatcher startup failed

flinkbot edited a comment on pull request #18298: URL: https://github.com/apache/flink/pull/18298#issuecomment-1007324030 ## CI report: * 80b4a2f2d56846b57a9244a9c855539cc248415e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * 403ea9f347767bce5b70345d6ace7918dc937642 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

twalthr commented on a change in pull request #18283: URL: https://github.com/apache/flink/pull/18283#discussion_r780311184 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java ## @@ -1035,8 +1124,62 @@ private String

[jira] [Updated] (FLINK-25578) Graduate Sink V1 interfaces to PublicEvolving and deprecate them

[ https://issues.apache.org/jira/browse/FLINK-25578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25578: Description: In the discussion of FLIP-191 we decided to not break existing sinks and give them

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r780327971 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -130,11 +130,11 @@ public JobGraphStore

[GitHub] [flink] twalthr commented on a change in pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

twalthr commented on a change in pull request #18283: URL: https://github.com/apache/flink/pull/18283#discussion_r780333584 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java ## @@

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470702#comment-17470702 ] David Morávek commented on FLINK-25577: --- That's a great news [~galenwarren], I've missed this

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 718ea97838ff10191544cc7460d3c18380b0e119 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 718ea97838ff10191544cc7460d3c18380b0e119 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 718ea97838ff10191544cc7460d3c18380b0e119 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * 4ba5f9d62347ac14dab7e19c0d8a01229d9f5558 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure:

[jira] [Updated] (FLINK-25569) Introduce decomposed Sink V2 interfaces

[ https://issues.apache.org/jira/browse/FLINK-25569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25569: --- Labels: pull-request-available (was: ) > Introduce decomposed Sink V2 interfaces >

[GitHub] [flink] fapaul commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

fapaul commented on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007548874 @gaoyunhaii do you also want to have a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] afedulov edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-1007555875 @fapaul I addressed all of the comments. The only remaining open points from my perspective: - clarify if imposing a strict `Serializable` requirement on the

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 412c841f3d189760b03f5f6458cc4a5340ec45fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 412c841f3d189760b03f5f6458cc4a5340ec45fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 48ef241f71a24b22119387a02a126613e388a748 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

flinkbot edited a comment on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1007423214 ## CI report: * 263332284671263487781ebdc8f0be10b0d925d0 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r780319993 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java ## @@ -92,34 +99,61 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #18287: [FLINK-17321][table] Add support casting of map to map and multiset to multiset

flinkbot edited a comment on pull request #18287: URL: https://github.com/apache/flink/pull/18287#issuecomment-1006572849 ## CI report: * 99096432609f559ded33520e48c75fce7aeb22da Azure:

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1007508085 I'm assuming that we'll need some docs here as well. [Here](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/filesystems/s3/) are the similar docs for

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470705#comment-17470705 ] Galen Warren commented on FLINK-25577: -- Why don't we leave it open, just so that it doesn't get

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470731#comment-17470731 ] David Morávek commented on FLINK-25577: --- Sounds good, thanks for taking care of this ;) > Update

[jira] [Commented] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470741#comment-17470741 ] Junfan Zhang commented on FLINK-25564: -- I can't reproduce this in my local machine, and you?

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 412c841f3d189760b03f5f6458cc4a5340ec45fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 744b699a82b4640652050eb75eecaf78b2f10c2c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 4390d75502395f2898e0838827e466b35f45a50f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 412c841f3d189760b03f5f6458cc4a5340ec45fc Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

MartijnVisser commented on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1007628177 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18282: [FLINK-25553][filesystem][mapr] Remove MapR filesystem

flinkbot edited a comment on pull request #18282: URL: https://github.com/apache/flink/pull/18282#issuecomment-1006362444 ## CI report: * 42e08103d22665b32fdec43a99cef38c6e537f4c Azure:

[GitHub] [flink] cuibo01 commented on pull request #18279: FLINK-25535 The JVM parameter does not take effect

cuibo01 commented on pull request #18279: URL: https://github.com/apache/flink/pull/18279#issuecomment-1007267850 > Thanks for creating this PR @cuibo01. I think the fix itself is good. I am wondering whether it actually fixes a problem. Did you observe a problem with splitting `-D

[GitHub] [flink] flinkbot commented on pull request #18294: FLINK-25565 Read Parquet INT64 timestamp

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

[GitHub] [flink] flinkbot edited a comment on pull request #18282: [FLINK-25553][filesystem][mapr] Remove MapR filesystem

flinkbot edited a comment on pull request #18282: URL: https://github.com/apache/flink/pull/18282#issuecomment-1006362444 ## CI report: * fa6ff983571af8e053c4b9522a77668e7186 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18295: [hotfix][rpc] Use AtomicLong#getAndIncrement to simplify increment number

flinkbot edited a comment on pull request #18295: URL: https://github.com/apache/flink/pull/18295#issuecomment-1007309008 ## CI report: * a938fb3509589cfa2abed09a54d677ad65afa3f2 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

fapaul commented on a change in pull request #18201: URL: https://github.com/apache/flink/pull/18201#discussion_r780186335 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TwoInputStreamOperatorFactory.java ## @@ -0,0 +1,31 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 8b30dbb1acd4bffe0c4c5d25b669705deb19463e Azure:

[GitHub] [flink] flinkbot commented on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

flinkbot commented on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1007312371 ## CI report: * 16eed821099b21c4d7f0f440c8d3f70babccfff5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25307: --- Labels: pull-request-available stale-critical test-stability (was: stale-critical

[GitHub] [flink] gaoyunhaii opened a new pull request #18298: [FLINK-25307][Test] Print the curl logs is querying dispatcher startup failed

gaoyunhaii opened a new pull request #18298: URL: https://github.com/apache/flink/pull/18298 ## What is the purpose of the change This PR outputs the detailed `curl` log if the querying to dispatcher failed. ## Brief change log -

[GitHub] [flink] flinkbot edited a comment on pull request #18298: [FLINK-25307][Test] Print the curl logs is querying dispatcher startup failed

flinkbot edited a comment on pull request #18298: URL: https://github.com/apache/flink/pull/18298#issuecomment-1007324030 ## CI report: * 80b4a2f2d56846b57a9244a9c855539cc248415e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * 9c09a873c7a7659910523ce39a5a87bad3500a13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18299: [FLINK-25311][core] Fix deal with delimited compressed file not correctly

flinkbot edited a comment on pull request #18299: URL: https://github.com/apache/flink/pull/18299#issuecomment-1007336354 ## CI report: * bc776911e40e4ce9a4bc4d2394da2b833738ddd8 Azure:

[jira] [Updated] (FLINK-25567) Casting of Multisets to Multisets

[ https://issues.apache.org/jira/browse/FLINK-25567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-25567: Description: There is a lack of multiset support which also probably should be fixed It

[GitHub] [flink] flinkbot edited a comment on pull request #18297: [FLINK-25395][state] Don't discard shared state on TM

flinkbot edited a comment on pull request #18297: URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142 ## CI report: * 7407da5e58ed7e7d093ddfd048e08583a5b5f49e Azure:

[GitHub] [flink] deadwind4 commented on a change in pull request #18033: [FLINK-25141][connector/elasticsearch][docs] Add sink parallelism option

deadwind4 commented on a change in pull request #18033: URL: https://github.com/apache/flink/pull/18033#discussion_r780231023 ## File path:

[jira] [Created] (FLINK-25569) Introduce decomposed Sink V2 interfaces

Fabian Paul created FLINK-25569: --- Summary: Introduce decomposed Sink V2 interfaces Key: FLINK-25569 URL: https://issues.apache.org/jira/browse/FLINK-25569 Project: Flink Issue Type: Sub-task

[GitHub] [flink] twalthr commented on a change in pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

twalthr commented on a change in pull request #18283: URL: https://github.com/apache/flink/pull/18283#discussion_r779547250 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java ##

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

flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * 2a61cd825f421777b5420b90fdc54193ea76b79a Azure:

[GitHub] [flink] Chromico opened a new pull request #18300: Update H2 to 2.0.206 to address CVE-2021-42392.

Chromico opened a new pull request #18300: URL: https://github.com/apache/flink/pull/18300 https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2021-42392 -- 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] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * b4374fe4d5a3b17be90682ae2a469c39c24039e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18296: [FLINK-25486][Runtime/Coordination] Fix the bug that flink will lost state when zookeeper leader changes

flinkbot edited a comment on pull request #18296: URL: https://github.com/apache/flink/pull/18296#issuecomment-1007312371 ## CI report: * 16eed821099b21c4d7f0f440c8d3f70babccfff5 Azure:

[jira] [Resolved] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25239. --- Resolution: Fixed Merged into master as 08ae5ce1193168b3264090e17ba3dbfa1205f84e.

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 9f800b453598a8cbf015583929e5fabda9fedbf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * b4374fe4d5a3b17be90682ae2a469c39c24039e3 Azure:

[GitHub] [flink] deadwind4 edited a comment on pull request #18300: Update H2 to 2.0.206 to address CVE-2021-42392.

deadwind4 edited a comment on pull request #18300: URL: https://github.com/apache/flink/pull/18300#issuecomment-1007421253 https://github.com/apache/flink/pull/18301 duplicated -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

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

flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * 2a61cd825f421777b5420b90fdc54193ea76b79a Azure:

[GitHub] [flink] fapaul commented on pull request #18285: [FLINK-21407][docs][formats] Move MongoDb to formats section in release 1.14

fapaul commented on pull request #18285: URL: https://github.com/apache/flink/pull/18285#issuecomment-1007432142 @MartijnVisser @echauchot It would be great to know what this PR is supposed to do and read some background information in the PR description. I cannot really understand the

[GitHub] [flink] flinkbot edited a comment on pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

flinkbot edited a comment on pull request #18105: URL: https://github.com/apache/flink/pull/18105#issuecomment-993417620 ## CI report: * c5ad80fd807793fdb7086954cd519599ad224c38 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18298: [FLINK-25307][Test] Print the curl logs is querying dispatcher startup failed

flinkbot edited a comment on pull request #18298: URL: https://github.com/apache/flink/pull/18298#issuecomment-1007324030 ## CI report: * 80b4a2f2d56846b57a9244a9c855539cc248415e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

flinkbot edited a comment on pull request #18288: URL: https://github.com/apache/flink/pull/18288#issuecomment-1006578426 ## CI report: * 1ff05c08e7b9ebf3e3ae028c692a82dbf55e4786 Azure:

[GitHub] [flink] echauchot commented on pull request #18285: [FLINK-21407][docs][formats] Move MongoDb to formats section in release 1.14

echauchot commented on pull request #18285: URL: https://github.com/apache/flink/pull/18285#issuecomment-1007475056 @fapaul sorry, the discussion was left in the [ticket](https://issues.apache.org/jira/browse/FLINK-21407). The aim of the PR is to fix a doc issue where `MongoDb` was

[GitHub] [flink] MartijnVisser commented on pull request #18285: [FLINK-21407][docs][formats] Move MongoDb to formats section in release 1.14

MartijnVisser commented on pull request #18285: URL: https://github.com/apache/flink/pull/18285#issuecomment-1007473477 @fapaul Previous PRs added MongoDb as a format for DataStream. However, it was added under Connectors, not under Connectors > Formats. This PR moves the documentation to

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18182: [FLINK-25341][table-planner] Add StructuredToStringCastRule to support user POJO toString implementation

slinkydeveloper commented on a change in pull request #18182: URL: https://github.com/apache/flink/pull/18182#discussion_r780322101 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/StructuredToStringCastRule.java ##

[jira] [Assigned] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25471: Assignee: Yao Zhang > wrong result if table transfrom to DataStream then keyby sum in

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 9f800b453598a8cbf015583929e5fabda9fedbf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 9f800b453598a8cbf015583929e5fabda9fedbf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 9f800b453598a8cbf015583929e5fabda9fedbf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * 4ba5f9d62347ac14dab7e19c0d8a01229d9f5558 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * 718ea97838ff10191544cc7460d3c18380b0e119 Azure:

  1   2   3   4   5   >