[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

flinkbot edited a comment on pull request #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1023343281 ## CI report: * cb9026e16e2c1cbcc8901399fc9780593895324d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388]

flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 608aae7635c45c7c7f391add2a816423623ebd35 Azure:

[GitHub] [flink] flinkbot commented on pull request #18624: [FLINK-25388]

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

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 6fd33395a404f92403867186a1beefa5f67bbf0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18540: [hotfix][table-planner][table-api-java][docs] Move topn cache config option

flinkbot edited a comment on pull request #18540: URL: https://github.com/apache/flink/pull/18540#issuecomment-1023208881 ## CI report: * 75f4a34a011be059d5af2412764bdd5d7b49253e Azure:

[jira] [Commented] (FLINK-25930) Remove identity casting from ScalarOperatorGens

[ https://issues.apache.org/jira/browse/FLINK-25930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486581#comment-17486581 ] Marios Trivyzas commented on FLINK-25930: - [~slinkydeveloper] Those are the calls to the

[GitHub] [flink] flinkbot commented on pull request #18624: [FLINK-25388]

flinkbot commented on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029172528 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 #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

flinkbot edited a comment on pull request #18612: URL: https://github.com/apache/flink/pull/18612#issuecomment-1028184927 ## CI report: * 54d2712f829412110a7b71254710a7d1a8ea38b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18540: [hotfix][table-planner][table-api-java][docs] Move topn cache config option

flinkbot edited a comment on pull request #18540: URL: https://github.com/apache/flink/pull/18540#issuecomment-1023208881 ## CI report: * 75f4a34a011be059d5af2412764bdd5d7b49253e Azure:

[jira] [Updated] (FLINK-25388) Add annotation to all StreamExec nodes

[ https://issues.apache.org/jira/browse/FLINK-25388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25388: --- Labels: pull-request-available (was: ) > Add annotation to all StreamExec nodes >

[GitHub] [flink] matriv opened a new pull request #18624: [FLINK-25388]

matriv opened a new pull request #18624: URL: https://github.com/apache/flink/pull/18624 ## 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 them on

[jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-25949: Description: h2. Description As captured by {{KinesisFirehoseITCase}} merged in

[GitHub] [flink] flinkbot edited a comment on pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

flinkbot edited a comment on pull request #18612: URL: https://github.com/apache/flink/pull/18612#issuecomment-1028184927 ## CI report: * 54d2712f829412110a7b71254710a7d1a8ea38b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 520877266d0eb19a4226a1955def724f164cd59c Azure:

[GitHub] [flink] fapaul commented on pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on pull request #18612: URL: https://github.com/apache/flink/pull/18612#issuecomment-1029157240 @JingGe Thanks for your comments I addressed all of them -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] fapaul commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798725902 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/InitContextInitializationContextAdapter.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18623: [FLINK-25892][test] archunit tests for connectors test code

flinkbot edited a comment on pull request #18623: URL: https://github.com/apache/flink/pull/18623#issuecomment-1029147536 ## CI report: * dfae1d3b6859e900b6ab9d90453237d8505e6c79 Azure:

[jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-25949: Description: Default protocol overriden in {{KinesisFirehoseSinkBuilder}} is instance of

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * b17f9ea2be31bd504ae46d7fc5d3934c6398f78f Azure:

[jira] [Created] (FLINK-25952) Savepoint on S3 are not relocatable even if entropy injection is not enabled

Dawid Wysakowicz created FLINK-25952: Summary: Savepoint on S3 are not relocatable even if entropy injection is not enabled Key: FLINK-25952 URL: https://issues.apache.org/jira/browse/FLINK-25952

[GitHub] [flink] fapaul commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798727583 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java ## @@ -57,7 +54,9 @@ * @see

[GitHub] [flink] fapaul commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798725902 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/InitContextInitializationContextAdapter.java ## @@

[GitHub] [flink] flinkbot commented on pull request #18623: [FLINK-25892][test] archunit tests for connectors test code

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

[GitHub] [flink] flinkbot edited a comment on pull request #18620: [FLINK-25879][BP 1.13][Docs] Track used search terms in Matomo

flinkbot edited a comment on pull request #18620: URL: https://github.com/apache/flink/pull/18620#issuecomment-1029017598 ## CI report: * 048f5b514a1e5f9526a8c6d8db661f1bbbe2f722 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 0e44e6d55fb788e744c50884b06a792acacfd63b Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798723894 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java ## @@ -65,7 +69,9 @@ * *

[GitHub] [flink] fapaul commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798722058 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java ## @@ -86,45 +85,48 @@

[GitHub] [flink] fapaul commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

fapaul commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798722386 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java ## @@ -86,45 +85,48 @@

[jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-25949: Fix Version/s: (was: 1.15.0) > [FLIP-171] Kinesis Firehose sink builder falls back to wrong

[jira] [Commented] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486561#comment-17486561 ] Danny Cranmer commented on FLINK-25949: --- [~chalixar] please update description and issue links >

[jira] [Resolved] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-25949. --- Resolution: Fixed > [FLIP-171] Kinesis Firehose sink builder falls back to wrong http

[GitHub] [flink] dannycranmer merged pull request #18617: [FLINK-25949][connector/firehose] Fixing wrong Http protocol default value for kinesisfirehoseSinkBuilder

dannycranmer merged pull request #18617: URL: https://github.com/apache/flink/pull/18617 -- 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:

[GitHub] [flink] flinkbot commented on pull request #18623: [FLINK-25892][test] archunit tests for connectors test code

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

[jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-25949: -- Fix Version/s: 1.15.0 > [FLIP-171] Kinesis Firehose sink builder falls back to wrong http

[jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-25949: -- Affects Version/s: (was: 1.15.0) > [FLIP-171] Kinesis Firehose sink builder falls back to

[jira] [Assigned] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol.

[ https://issues.apache.org/jira/browse/FLINK-25949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-25949: - Assignee: Ahmed Hamdy > [FLIP-171] Kinesis Firehose sink builder falls back to wrong

[jira] [Updated] (FLINK-25892) Develop ArchUnit test for connectors

[ https://issues.apache.org/jira/browse/FLINK-25892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25892: --- Labels: pull-request-available (was: ) > Develop ArchUnit test for connectors >

[GitHub] [flink] flinkbot edited a comment on pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

flinkbot edited a comment on pull request #18621: URL: https://github.com/apache/flink/pull/18621#issuecomment-1029064847 ## CI report: * f42e5523be2251b3d7e7973a11cc49237a3f49c8 Azure:

[GitHub] [flink] JingGe opened a new pull request #18623: [FLINK-25892][test] archunit tests for connectors test code

JingGe opened a new pull request #18623: URL: https://github.com/apache/flink/pull/18623 ## What is the purpose of the change Add ArchUnit tests for the test code of each connector. This is the follow-up PR for the ticket FLINK-25220. ## Brief change log - Add

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 094559bb04127d51d4ec5d8e287ef4d13ff7cdf9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18582: [FLINK-24780][table-planner] Port time/date/timestamp casts to new structure

flinkbot edited a comment on pull request #18582: URL: https://github.com/apache/flink/pull/18582#issuecomment-1026892619 ## CI report: * 4300cc5f88ee784f347bf456f57137463195e0a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 0e44e6d55fb788e744c50884b06a792acacfd63b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18622: [hotfix] Replace deprecated usages of untyped `defaultValue` and `noDefaultValue`

flinkbot edited a comment on pull request #18622: URL: https://github.com/apache/flink/pull/18622#issuecomment-1029125411 ## CI report: * d06d3f24d7afd1077750fb12df662ffefce16e7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

flinkbot edited a comment on pull request #18621: URL: https://github.com/apache/flink/pull/18621#issuecomment-1029064847 ## CI report: * f42e5523be2251b3d7e7973a11cc49237a3f49c8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

flinkbot edited a comment on pull request #18539: URL: https://github.com/apache/flink/pull/18539#issuecomment-1023172522 ## CI report: * e8bcbfd5a48fd8d3ca48ef7803867569214e0dbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 78c5075dd300c8e74705afbb13b10377da61865a Azure:

[GitHub] [flink] flinkbot commented on pull request #18622: [hotfix] Replace deprecated usages of untyped `defaultValue` and `noDefaultValue`

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

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

flinkbot edited a comment on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917 ## CI report: * 73d6041d03ae0ec8cd5c508bad0443dd1e2390f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 78c5075dd300c8e74705afbb13b10377da61865a Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

dawidwys commented on a change in pull request #18539: URL: https://github.com/apache/flink/pull/18539#discussion_r798699282 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointFormatITCase.java ## @@ -111,14 +111,35 @@

[GitHub] [flink] dawidwys commented on a change in pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

dawidwys commented on a change in pull request #18539: URL: https://github.com/apache/flink/pull/18539#discussion_r798699282 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointFormatITCase.java ## @@ -111,14 +111,35 @@

[GitHub] [flink] flinkbot commented on pull request #18622: [hotfix] Replace deprecated usages of untyped `defaultValue` and `noDefaultValue`

flinkbot commented on pull request #18622: URL: https://github.com/apache/flink/pull/18622#issuecomment-1029121252 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 #18617: [FLINK-25949][connector/firehose] Fixing wrong Http protocol default value for kinesisfirehoseSinkBuilder

flinkbot edited a comment on pull request #18617: URL: https://github.com/apache/flink/pull/18617#issuecomment-1028963829 ## CI report: * 7c0159fa3d148cd8e97d302155382f10e1325101 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

flinkbot edited a comment on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917 ## CI report: * 73d6041d03ae0ec8cd5c508bad0443dd1e2390f5 Azure:

[GitHub] [flink] matriv opened a new pull request #18622: [hotfix] Replace deprecated usages of untyped `defaultValue` and `noDefaultValue`

matriv opened a new pull request #18622: URL: https://github.com/apache/flink/pull/18622 Add types to `ConfigOptions` and replace usages of the untyped methods `defaultValue` and `noDefaultValue` with the corresponding typed ones. -- This is an automated message from the Apache

[GitHub] [flink] infoverload commented on a change in pull request #18353: [FLINK-25129][docs]project configuation changes in docs

infoverload commented on a change in pull request #18353: URL: https://github.com/apache/flink/pull/18353#discussion_r798691818 ## File path: docs/content/docs/dev/configuration/maven.md ## @@ -0,0 +1,175 @@ +--- +title: "Using Maven" +weight: 2 +type: docs +--- + + +# How to

[GitHub] [flink] flinkbot edited a comment on pull request #18616: [FLINK-21752] NullPointerException on restore in PojoSerializer

flinkbot edited a comment on pull request #18616: URL: https://github.com/apache/flink/pull/18616#issuecomment-1028944590 ## CI report: * 857b3cd779538fbc21a89733dcd0360345b12c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

flinkbot edited a comment on pull request #18575: URL: https://github.com/apache/flink/pull/18575#issuecomment-1025993745 ## CI report: * de720988f611ead1b45bca07376452efedcab76d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18575: [FLINK-25827][task] Fix potential memory leak in SourceOperator when using CompletableFuture.anyOf

flinkbot edited a comment on pull request #18575: URL: https://github.com/apache/flink/pull/18575#issuecomment-1025993745 ## CI report: * de720988f611ead1b45bca07376452efedcab76d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

flinkbot edited a comment on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025854469 ## CI report: * c1357301d91600e02d3b62dcd6c0aeb1ae961ba9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

flinkbot edited a comment on pull request #18606: URL: https://github.com/apache/flink/pull/18606#issuecomment-1027976880 ## CI report: * 2775c81d533d6bb3843e042c22dc1437963206ad Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot edited a comment on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

flinkbot edited a comment on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025854469 ## CI report: * c1357301d91600e02d3b62dcd6c0aeb1ae961ba9 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

JingGe commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798561215 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java ## @@ -86,45 +85,48 @@

[GitHub] [flink] JingGe commented on a change in pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

JingGe commented on a change in pull request #18612: URL: https://github.com/apache/flink/pull/18612#discussion_r798580046 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java ## @@ -65,7 +69,9 @@ * *

[GitHub] [flink] slinkydeveloper commented on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

slinkydeveloper commented on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1029081840 I reverted the removal of `ExecNodeGraphValidator`, as it seems like because of legacy tables, `TemporalTableSourceSpec` can be initiated with empty

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 0e44e6d55fb788e744c50884b06a792acacfd63b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[jira] [Updated] (FLINK-25926) Update org.postgresql:postgresql to 42.3.2

[ https://issues.apache.org/jira/browse/FLINK-25926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25926: --- Labels: pull-request-available (was: ) > Update org.postgresql:postgresql to 42.3.2 >

[GitHub] [flink] flinkbot edited a comment on pull request #18604: [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.2

flinkbot edited a comment on pull request #18604: URL: https://github.com/apache/flink/pull/18604#issuecomment-1027886359 ## CI report: * 0e44e6d55fb788e744c50884b06a792acacfd63b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] dmvk commented on a change in pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

dmvk commented on a change in pull request #18536: URL: https://github.com/apache/flink/pull/18536#discussion_r798585861 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -206,10 +208,19 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

flinkbot edited a comment on pull request #18621: URL: https://github.com/apache/flink/pull/18621#issuecomment-1029064847 ## CI report: * f42e5523be2251b3d7e7973a11cc49237a3f49c8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * cbe7ec9af0a796017cfb3c3c60e9b743afc27232 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

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

[GitHub] [flink] flinkbot commented on pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

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

[GitHub] [flink] flinkbot commented on pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

flinkbot commented on pull request #18621: URL: https://github.com/apache/flink/pull/18621#issuecomment-1029064341 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 #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 094559bb04127d51d4ec5d8e287ef4d13ff7cdf9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 094559bb04127d51d4ec5d8e287ef4d13ff7cdf9 Azure:

[jira] [Updated] (FLINK-25932) Introduce ExecNodeContext.generateUid()

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

[GitHub] [flink] slinkydeveloper opened a new pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

slinkydeveloper opened a new pull request #18621: URL: https://github.com/apache/flink/pull/18621 ## What is the purpose of the change This PR makes sure every transformation has a deterministic uid, required to restore previous savepoints. ## Brief change log * Add

[GitHub] [flink] MartijnVisser commented on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

MartijnVisser commented on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1029056101 @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] zentol merged pull request #18614: [hotfix][table-planner] Remove org.reflections from NOTICE

zentol merged pull request #18614: URL: https://github.com/apache/flink/pull/18614 -- 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:

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

fapaul commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r798579396 ## File path: flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 ## @@ -113,6 +113,11

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

flinkbot edited a comment on pull request #18606: URL: https://github.com/apache/flink/pull/18606#issuecomment-1027976880 ## CI report: * 19a163b2c9d281336f36fccf0a8ba51e13ef46d6 Azure:

[jira] [Created] (FLINK-25951) Implement Matomo on JavaDocs

Martijn Visser created FLINK-25951: -- Summary: Implement Matomo on JavaDocs Key: FLINK-25951 URL: https://issues.apache.org/jira/browse/FLINK-25951 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

flinkbot edited a comment on pull request #18606: URL: https://github.com/apache/flink/pull/18606#issuecomment-1027976880 ## CI report: * 19a163b2c9d281336f36fccf0a8ba51e13ef46d6 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #18539: [FLINK-25745] Support RocksDB incremental native savepoints

pnowojski commented on a change in pull request #18539: URL: https://github.com/apache/flink/pull/18539#discussion_r798600159 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointFormatITCase.java ## @@ -111,14 +111,35 @@

<    1   2   3   4   5   >