[GitHub] [flink] echauchot removed a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

echauchot removed a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994955391 @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] flinkbot edited a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

flinkbot edited a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994592321 ## CI report: * Unknown: [CANCELED](TBD) * be9c303bfc87bb5522259061b713052a3e26451b Azure:

[jira] [Updated] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

[ https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TongMeng updated FLINK-25332: - Description: The UDF I used just returns a float, the first four data it returns 1.0, 2.0, 3.0 and

[jira] [Created] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

TongMeng created FLINK-25332: Summary: When using Pyflink Table API, 'where' clause seems to work incorrectly Key: FLINK-25332 URL: https://issues.apache.org/jira/browse/FLINK-25332 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

flinkbot edited a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994592321 ## CI report: * Unknown: [CANCELED](TBD) * be9c303bfc87bb5522259061b713052a3e26451b Azure:

[GitHub] [flink] echauchot commented on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

echauchot commented on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994955391 @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] twalthr commented on a change in pull request #18108: [FLINK-25282][table-planner][table-runtime] Move every runtime dependency from planner to runtime

twalthr commented on a change in pull request #18108: URL: https://github.com/apache/flink/pull/18108#discussion_r769789892 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/PaddingLeftMapFunction.java ## @@ -0,0 +1,52

[GitHub] [flink] echauchot removed a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

echauchot removed a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994656225 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

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

[GitHub] [flink] echauchot commented on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

echauchot commented on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994952541 @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] echauchot commented on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

echauchot commented on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994950822 @zentol thanks for the review. I addressed all your comments and squashed. PTAL. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] echauchot commented on a change in pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

echauchot commented on a change in pull request #18115: URL: https://github.com/apache/flink/pull/18115#discussion_r769781993 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java

[GitHub] [flink-web] zentol commented on a change in pull request #489: Add 1.11.6/1.12.7/1.13.5/1.14.2 releases

zentol commented on a change in pull request #489: URL: https://github.com/apache/flink-web/pull/489#discussion_r769779467 ## File path: _posts/2021-12-16-log4j-patch-releases.md ## @@ -0,0 +1,100 @@ +--- +layout: post +title: "Apache Flink Log4j emergency releases" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

flinkbot edited a comment on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-994556266 ## CI report: * 163245e6c628a06bc5ce593d014e1588262aae60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot edited a comment on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * 371aa42965f5a2e4bc677af258d8eb042a8c39e0 Azure:

[jira] [Updated] (FLINK-25317) ApplicationDispatcherBootstrapITCase blocked on azure

[ https://issues.apache.org/jira/browse/FLINK-25317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-25317: -- Fix Version/s: 1.14.3 (was: 1.14.2) > ApplicationDispatcherBootstrapITCase blocked on

[GitHub] [flink] zentol commented on a change in pull request #18105: [FLINK-17510][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

zentol commented on a change in pull request #18105: URL: https://github.com/apache/flink/pull/18105#discussion_r769774278 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java ## @@ -0,0

[jira] [Updated] (FLINK-25331) Allow testcontainer tests to run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25331: - Description: Tests using testcontainers for Flink are currently locked to Java 8. >

[jira] [Created] (FLINK-25331) Allow testcontainer tests to run on Java 11

Chesnay Schepler created FLINK-25331: Summary: Allow testcontainer tests to run on Java 11 Key: FLINK-25331 URL: https://issues.apache.org/jira/browse/FLINK-25331 Project: Flink Issue

[GitHub] [flink] zentol commented on a change in pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

zentol commented on a change in pull request #18115: URL: https://github.com/apache/flink/pull/18115#discussion_r769771688 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ##

[GitHub] [flink] zentol commented on a change in pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

zentol commented on a change in pull request #18115: URL: https://github.com/apache/flink/pull/18115#discussion_r769771688 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ##

[GitHub] [flink-web] carp84 commented on a change in pull request #489: Add 1.11.6/1.12.7/1.13.5/1.14.2 releases

carp84 commented on a change in pull request #489: URL: https://github.com/apache/flink-web/pull/489#discussion_r769769314 ## File path: _posts/2021-12-16-log4j-patch-releases.md ## @@ -0,0 +1,100 @@ +--- +layout: post +title: "Apache Flink Log4j emergency releases" +date:

[GitHub] [flink] zentol commented on a change in pull request #18123: [FLINK-24846][streaming] Guava import fix in AsyncWaitOperatorTest

zentol commented on a change in pull request #18123: URL: https://github.com/apache/flink/pull/18123#discussion_r769770749 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java ## @@ -65,12 +65,13 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

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

[GitHub] [flink] flinkbot edited a comment on pull request #18108: [FLINK-25282][table-planner][table-runtime] Move every runtime dependency from planner to runtime

flinkbot edited a comment on pull request #18108: URL: https://github.com/apache/flink/pull/18108#issuecomment-993777362 ## CI report: * 83574e4046c47d1e07798a5e2e33fd57d6b1a598 Azure:

[GitHub] [flink] flinkbot commented on pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

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

[GitHub] [flink] flinkbot edited a comment on pull request #18108: [FLINK-25282][table-planner][table-runtime] Move every runtime dependency from planner to runtime

flinkbot edited a comment on pull request #18108: URL: https://github.com/apache/flink/pull/18108#issuecomment-993777362 ## CI report: * 83574e4046c47d1e07798a5e2e33fd57d6b1a598 Azure:

[GitHub] [flink] flinkbot commented on pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

flinkbot commented on pull request #18124: URL: https://github.com/apache/flink/pull/18124#issuecomment-994922340 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-25251) Docker image should use Java 11 by default

[ https://issues.apache.org/jira/browse/FLINK-25251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25251: - Release Note: The default Java version in the Flink docker images is now Java 11. There

[GitHub] [flink] flinkbot edited a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

flinkbot edited a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-994686917 ## CI report: * d8e09a1643cb2fffc9bf3c836dbfb20a9114f26b Azure:

[GitHub] [flink] zentol opened a new pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

zentol opened a new pull request #18124: URL: https://github.com/apache/flink/pull/18124 We now wait for resources / create the EG in the CREATED job status, which is more in line with the behavior of the default scheduler. -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-24824) AdaptiveScheduler#getJobStatus never returns CREATED

[ https://issues.apache.org/jira/browse/FLINK-24824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24824: --- Labels: pull-request-available (was: ) > AdaptiveScheduler#getJobStatus never returns

[GitHub] [flink] flinkbot edited a comment on pull request #18064: [FLINK-25223][connectors/elasticsearch] Limit Elasticsearch testcontainer memory allocation

flinkbot edited a comment on pull request #18064: URL: https://github.com/apache/flink/pull/18064#issuecomment-989847295 ## CI report: * f9fdec56780cc9b0699a49eab813c087f0c68b34 Azure:

[jira] [Commented] (FLINK-24420) Casting to a "narrower" type doesn't throw exception but follows Java overflow

[ https://issues.apache.org/jira/browse/FLINK-24420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460043#comment-17460043 ] Timo Walther commented on FLINK-24420: -- I would vote for OVERFLOW for the legacy mode and FAIL for

[GitHub] [flink] fapaul commented on pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

fapaul commented on pull request #18043: URL: https://github.com/apache/flink/pull/18043#issuecomment-994912555 @dmvk @AHeise thanks for your fruitful feedback. I tried addressing most of your comments and left responses for the rest. PTAL -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

flinkbot edited a comment on pull request #18043: URL: https://github.com/apache/flink/pull/18043#issuecomment-987929568 ## CI report: * 96f31d59d0ee603523617b599ff37889c6ffa20e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

flinkbot edited a comment on pull request #17761: URL: https://github.com/apache/flink/pull/17761#issuecomment-965943227 ## CI report: * aed5a582711e95a77e5de82f3b0dc4ade1b6c0e3 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

fapaul commented on a change in pull request #18043: URL: https://github.com/apache/flink/pull/18043#discussion_r769739549 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java ## @@ -169,12 +242,42 @@ public static void

[GitHub] [flink] flinkbot edited a comment on pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

flinkbot edited a comment on pull request #18043: URL: https://github.com/apache/flink/pull/18043#issuecomment-987929568 ## CI report: * 96f31d59d0ee603523617b599ff37889c6ffa20e Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18043: [FLINK-25206] Add configuration option to disable configuration in user programs

fapaul commented on a change in pull request #18043: URL: https://github.com/apache/flink/pull/18043#discussion_r769736111 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java ## @@ -789,4 +790,50 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * d143a927289d7f6a88851d6db732169c4752ff6e Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

CrynetLogistics commented on a change in pull request #18013: URL: https://github.com/apache/flink/pull/18013#discussion_r769726040 ## File path:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

CrynetLogistics commented on a change in pull request #18013: URL: https://github.com/apache/flink/pull/18013#discussion_r769725439 ## File path:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

gaoyunhaii commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r769431697 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/SparseVectorTypeInfo.java ## @@ -0,0 +1,85 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-25227) Comparing the equality of the same (boxed) numeric values returns false

[ https://issues.apache.org/jira/browse/FLINK-25227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460027#comment-17460027 ] Marios Trivyzas commented on FLINK-25227: - I also agree to fix the issue with the boxed types

[GitHub] [flink] flinkbot edited a comment on pull request #18108: [FLINK-25282][table-planner][table-runtime] Move every runtime dependency from planner to runtime

flinkbot edited a comment on pull request #18108: URL: https://github.com/apache/flink/pull/18108#issuecomment-993777362 ## CI report: * 83574e4046c47d1e07798a5e2e33fd57d6b1a598 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

flinkbot edited a comment on pull request #17774: URL: https://github.com/apache/flink/pull/17774#issuecomment-966933536 ## CI report: * 5b2d45a98d0f46a8d72f62b501c2b34908f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18123: [FLINK-24846][streaming] Guava import fix in AsyncWaitOperatorTest

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

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * d8ce847c1c9638366b1afd0d1e30740fca436cd7 Azure:

[GitHub] [flink] alpreu commented on pull request #18117: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

alpreu commented on pull request #18117: URL: https://github.com/apache/flink/pull/18117#issuecomment-994852970 > @alpreu I am merging can you also create the backport to 1.14? I'll create the backport and assign you the PR -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #18122: [FLINK-24846][streaming] Ignoring completing async operator record if…

flinkbot edited a comment on pull request #18122: URL: https://github.com/apache/flink/pull/18122#issuecomment-994843664 ## CI report: * cd507cfbeabd89f145ab7580d8431d13daa8 Azure:

[GitHub] [flink] flinkbot commented on pull request #18123: [FLINK-24846][streaming] Guava import fix in AsyncWaitOperatorTest

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

[GitHub] [flink] flinkbot edited a comment on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

flinkbot edited a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994592321 ## CI report: * 833e93cae14f1398530d66f36f536015c7629c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * cee493f0c7ff22bb13e7a7a9a6c67ecb10b292d0 Azure:

[GitHub] [flink] flinkbot commented on pull request #18123: [FLINK-24846][streaming] Guava import fix in AsyncWaitOperatorTest

flinkbot commented on pull request #18123: URL: https://github.com/apache/flink/pull/18123#issuecomment-994847466 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] [Commented] (FLINK-25326) KafkaUtil.createKafkaContainer log levels are not set correctly

[ https://issues.apache.org/jira/browse/FLINK-25326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459997#comment-17459997 ] Fabian Paul commented on FLINK-25326: - Merged in master: 28eb197c5b7a07b9615eef1ce58459b8b5d5b9b2 >

[jira] [Updated] (FLINK-25326) KafkaUtil.createKafkaContainer log levels are not set correctly

[ https://issues.apache.org/jira/browse/FLINK-25326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25326: Fix Version/s: 1.15.0 > KafkaUtil.createKafkaContainer log levels are not set correctly >

[GitHub] [flink] fapaul merged pull request #18117: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

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

[jira] [Updated] (FLINK-25326) KafkaUtil.createKafkaContainer log levels are not set correctly

[ https://issues.apache.org/jira/browse/FLINK-25326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25326: Affects Version/s: 1.14.0 > KafkaUtil.createKafkaContainer log levels are not set correctly >

[GitHub] [flink] fapaul commented on pull request #18117: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

fapaul commented on pull request #18117: URL: https://github.com/apache/flink/pull/18117#issuecomment-994845108 @alpreu I am merging can you also create the backport to 1.14? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot commented on pull request #18122: [FLINK-24846][streaming] Ignoring completing async operator record if…

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

[GitHub] [flink] akalash opened a new pull request #18123: [FLINK-24846][streaming] Guava import fix in AsyncWaitOperatorTest

akalash opened a new pull request #18123: URL: https://github.com/apache/flink/pull/18123 ## What is the purpose of the change This PR fixes the import of guava in AsyncWaitOperatorTest ## Does this pull request potentially affect one of the following parts: -

[GitHub] [flink] flinkbot edited a comment on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

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

[GitHub] [flink] flinkbot commented on pull request #18122: [FLINK-24846][streaming] Ignoring completing async operator record if…

flinkbot commented on pull request #18122: URL: https://github.com/apache/flink/pull/18122#issuecomment-994842018 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 #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * cee493f0c7ff22bb13e7a7a9a6c67ecb10b292d0 Azure:

[GitHub] [flink] akalash opened a new pull request #18122: [FLINK-24846][streaming] Ignoring completing async operator record if…

akalash opened a new pull request #18122: URL: https://github.com/apache/flink/pull/18122 … mailbox is closed already ## What is the purpose of the change Backport of https://github.com/apache/flink/pull/17965 ## Does this pull request potentially affect one of the

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * ac179499cd39e4d3c8abea70dbb6209a45f6dee3 Azure:

[GitHub] [flink] matriv commented on a change in pull request #18107: [FLINK-17151][table] Align Calcite's and Flink's SYMBOL types

matriv commented on a change in pull request #18107: URL: https://github.com/apache/flink/pull/18107#discussion_r769670627 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java ## @@ -21,52 +21,57 @@ import

[GitHub] [flink] alpreu commented on a change in pull request #18117: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

alpreu commented on a change in pull request #18117: URL: https://github.com/apache/flink/pull/18117#discussion_r769669465 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java ## @@ -56,16 +56,16 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * ac179499cd39e4d3c8abea70dbb6209a45f6dee3 Azure:

[GitHub] [flink] afedulov commented on pull request #18072: [FLINK-23375][connector/jdbc] Build proper JDBC test jar.

afedulov commented on pull request #18072: URL: https://github.com/apache/flink/pull/18072#issuecomment-994831148 @fapaul It was a user request, not sure about the background. I saw that we generate them in some of the connectors and assumed that we generally expose those. I will clarify

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot edited a comment on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * 99a93ac3491caebf575c1bf641b612d8d2010c4f Azure:

[jira] [Commented] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459965#comment-17459965 ] Martijn Visser commented on FLINK-25210: [~affe] I've assigned it to you >

[jira] [Assigned] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25210: -- Assignee: Yufei Zhang > PulsarSource(Un)OrderedE2ECase is broken >

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot edited a comment on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * 99a93ac3491caebf575c1bf641b612d8d2010c4f Azure:

[jira] [Commented] (FLINK-23375) Flink connector jdbc tests jar is almost empty

[ https://issues.apache.org/jira/browse/FLINK-23375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459964#comment-17459964 ] Alexander Fedulov commented on FLINK-23375: --- Hi [~maver1ck], could you describe in which

[GitHub] [flink] flinkbot edited a comment on pull request #18117: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

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

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot edited a comment on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * 99a93ac3491caebf575c1bf641b612d8d2010c4f Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

dannycranmer commented on a change in pull request #18013: URL: https://github.com/apache/flink/pull/18013#discussion_r769634451 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/pom.xml ## @@ -0,0 +1,130 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Comment Edited] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459916#comment-17459916 ] Piotr Nowojski edited comment on FLINK-24846 at 12/15/21, 1:57 PM: ---

[jira] [Updated] (FLINK-24846) AsyncWaitOperator fails during stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24846: --- Fix Version/s: 1.13.6 > AsyncWaitOperator fails during stop-with-savepoint >

[GitHub] [flink] flinkbot edited a comment on pull request #18064: [FLINK-25223][connectors/elasticsearch] Limit Elasticsearch testcontainer memory allocation

flinkbot edited a comment on pull request #18064: URL: https://github.com/apache/flink/pull/18064#issuecomment-989847295 ## CI report: * 293c0e5d20e7e2904ac7d399906346bad27e8a99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

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

[GitHub] [flink] dannycranmer commented on pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

dannycranmer commented on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-994805219 Superseded by https://github.com/apache/flink/pull/18013 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] dannycranmer closed pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

dannycranmer closed pull request #17345: URL: https://github.com/apache/flink/pull/17345 -- 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 #18105: [FLINK-17510][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

fapaul commented on a change in pull request #18105: URL: https://github.com/apache/flink/pull/18105#discussion_r769636652 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18115: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

flinkbot edited a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994592321 ## CI report: * Unknown: [CANCELED](TBD) * 833e93cae14f1398530d66f36f536015c7629c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * c19158e316f30c51317558d2eead210aca728f55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * d143a927289d7f6a88851d6db732169c4752ff6e Azure:

[GitHub] [flink] zentol commented on a change in pull request #18105: [FLINK-17510][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

zentol commented on a change in pull request #18105: URL: https://github.com/apache/flink/pull/18105#discussion_r769630863 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18026: [FLINK-20188][Connectors/FileSystem,Documentation] Add Documentation …

flinkbot edited a comment on pull request #18026: URL: https://github.com/apache/flink/pull/18026#issuecomment-986738097 ## CI report: * b5cf7407b6c04e474d820d5a334a44fc0b0a48bf Azure:

[jira] [Assigned] (FLINK-25187) Apply padding for BINARY()

[ https://issues.apache.org/jira/browse/FLINK-25187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas reassigned FLINK-25187: --- Assignee: Marios Trivyzas > Apply padding for BINARY() >

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * d143a927289d7f6a88851d6db732169c4752ff6e Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18117: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

fapaul commented on a change in pull request #18117: URL: https://github.com/apache/flink/pull/18117#discussion_r769627343 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java ## @@ -56,16 +56,16 @@ private

[GitHub] [flink] MartijnVisser commented on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

MartijnVisser commented on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-994793413 @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 #18026: [FLINK-20188][Connectors/FileSystem,Documentation] Add Documentation …

flinkbot edited a comment on pull request #18026: URL: https://github.com/apache/flink/pull/18026#issuecomment-986738097 ## CI report: * b5cf7407b6c04e474d820d5a334a44fc0b0a48bf Azure:

[GitHub] [flink] MonsterChenzhuo commented on pull request #18026: [FLINK-20188][Connectors/FileSystem,Documentation] Add Documentation …

MonsterChenzhuo commented on pull request #18026: URL: https://github.com/apache/flink/pull/18026#issuecomment-994790161 @MartijnVisser I have made a series of modifications according to your suggestions, and you can see if they meet your requirements -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[GitHub] [flink] jelly-1203 commented on a change in pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

jelly-1203 commented on a change in pull request #18017: URL: https://github.com/apache/flink/pull/18017#discussion_r769618830 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableLikeUtil.java ## @@ -426,6 +433,14 @@

<    1   2   3   4   5   6   7   8   9   >