[GitHub] [flink] JingGe commented on a change in pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

JingGe commented on a change in pull request #18014: URL: https://github.com/apache/flink/pull/18014#discussion_r766559338 ## File path: flink-test-utils-parent/flink-connector-test-utils/pom.xml ## @@ -54,6 +54,12 @@ compile +

[GitHub] [flink] fapaul commented on a change in pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

fapaul commented on a change in pull request #17892: URL: https://github.com/apache/flink/pull/17892#discussion_r766567926 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkContainers.java ## @@

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[jira] [Created] (FLINK-25255) Consider/design implementing State Processor API (FC)

Piotr Nowojski created FLINK-25255: -- Summary: Consider/design implementing State Processor API (FC) Key: FLINK-25255 URL: https://issues.apache.org/jira/browse/FLINK-25255 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

flinkbot edited a comment on pull request #18065: URL: https://github.com/apache/flink/pull/18065#issuecomment-989924620 ## CI report: * 498a34307bf310ae23f63fc248e6660ab2a6d248 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18074: [FLINK-24728][table-runtime-blink] Close output stream in batch SQL file sink

flinkbot edited a comment on pull request #18074: URL: https://github.com/apache/flink/pull/18074#issuecomment-990667453 ## CI report: * b2a248d6fde42448bc03842f9f0949fb547d7ad2 Azure:

[jira] [Commented] (FLINK-25252) Check whether Kafka E2E tests could be run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457011#comment-17457011 ] Martijn Visser commented on FLINK-25252: [~fpaul] Didn't we already do this bump and should we

[GitHub] [flink] JingGe commented on a change in pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

JingGe commented on a change in pull request #18014: URL: https://github.com/apache/flink/pull/18014#discussion_r766559338 ## File path: flink-test-utils-parent/flink-connector-test-utils/pom.xml ## @@ -54,6 +54,12 @@ compile +

[jira] [Updated] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25240: - Affects Version/s: 1.13.0 (was: 1.14.0) > Update log4j2

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

zhipeng93 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766506565 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -22,13 +22,84 @@ /** A utility class that provides BLAS routines

[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_r766554432 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableLikeUtil.java ## @@ -426,6 +433,14 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17893: [FLINK-24987][Configuration] Add explicit enum value NO_EXTERNAL_CHECKPOINTS as default for ExternalizedCheckpointRetention

flinkbot edited a comment on pull request #17893: URL: https://github.com/apache/flink/pull/17893#issuecomment-977732141 ## CI report: * 2726130b4747ffd1c1419a06dca339b319ad8acc 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_r766552204 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableLikeUtil.java ## @@ -426,6 +433,14 @@

[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_r766551836 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableLikeUtil.java ## @@ -426,6 +433,14 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

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

[GitHub] [flink] flinkbot edited a comment on pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

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

[jira] [Commented] (FLINK-25252) Check whether Kafka E2E tests could be run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457024#comment-17457024 ] Fabian Paul commented on FLINK-25252: - Most of the tests are unfortunately still using a

[jira] [Updated] (FLINK-25254) Default Completed Job List is not ordered by time in web page

[ https://issues.apache.org/jira/browse/FLINK-25254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25254: --- Priority: Minor (was: Major) > Default Completed Job List is not ordered by time in web

[jira] [Commented] (FLINK-25249) Reimplement KafkaSourceTestEnv with KafkaContainer

[ https://issues.apache.org/jira/browse/FLINK-25249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457023#comment-17457023 ] Yuepeng Pan commented on FLINK-25249: - Good idea.  [~renqs]  Sounds great to me. [~arvid] What do

[jira] [Updated] (FLINK-25254) Default Completed Job List is not ordered by time in web page

[ https://issues.apache.org/jira/browse/FLINK-25254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25254: Description: The completed jobs are not ordered by time in 1.14.0. Although we can order them by click the Start

[GitHub] [flink] flinkbot edited a comment on pull request #18073: [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files

flinkbot edited a comment on pull request #18073: URL: https://github.com/apache/flink/pull/18073#issuecomment-990667419 ## CI report: * f64443b76b0bc0ac8ab9bfbb4b88f5a24f2f000d Azure:

[jira] [Created] (FLINK-25254) Default Completed Job List is not ordered by time in web page

Liu created FLINK-25254: --- Summary: Default Completed Job List is not ordered by time in web page Key: FLINK-25254 URL: https://issues.apache.org/jira/browse/FLINK-25254 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18075: [FLINK-25241][architecture-tests] Ensure CI fails when violations are resolved

flinkbot edited a comment on pull request #18075: URL: https://github.com/apache/flink/pull/18075#issuecomment-990709436 ## CI report: * fe38dffce317de46c8b0e34f7bdc64fb72ad81fa Azure:

[jira] [Comment Edited] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457010#comment-17457010 ] Chesnay Schepler edited comment on FLINK-17510 at 12/10/21, 9:57 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[jira] [Updated] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25240: - Issue Type: Improvement (was: Bug) > Update log4j2 version to 2.15.0 >

[jira] [Assigned] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25240: Assignee: Ada Wong > Update log4j2 version to 2.15.0 >

[jira] [Updated] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25240: - Fix Version/s: 1.15.0 1.14.1 1.13.4 > Update

[jira] [Updated] (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:all-tabpanel ] ASF GitHub Bot updated FLINK-25227: --- Labels: pull-request-available (was: ) > Comparing the equality of the same (boxed)

[GitHub] [flink] flinkbot edited a comment on pull request #18076: [FLINK-25227][table-runtime] Boxed numeric type should be considered when generating code for equality checking

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

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] tsreaper opened a new pull request #18076: [FLINK-25227][table-runtime] Boxed numeric type should be considered when generating code for equality checking

tsreaper opened a new pull request #18076: URL: https://github.com/apache/flink/pull/18076 ## What is the purpose of the change Currently generated Java code for equality checking does not consider boxed Java types. This PR fixes this issue. ## Brief change log -

[GitHub] [flink] flinkbot commented on pull request #18076: [FLINK-25227][table-runtime] Boxed numeric type should be considered when generating code for equality checking

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

[GitHub] [flink] flinkbot commented on pull request #18076: [FLINK-25227][table-runtime] Boxed numeric type should be considered when generating code for equality checking

flinkbot commented on pull request #18076: URL: https://github.com/apache/flink/pull/18076#issuecomment-990790402 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] [Assigned] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-17510: Assignee: Chesnay Schepler > StreamingKafkaITCase. testKafka timeouts on

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

slinkydeveloper commented on a change in pull request #18065: URL: https://github.com/apache/flink/pull/18065#discussion_r766517676 ## File path: flink-table/flink-table-api-bridge-common/src/main/java/org/apache/flink/table/api/bridge/internal/BaseStreamTableEnvironmentImpl.java

[jira] [Assigned] (FLINK-21603) SQLClientKafkaITCase failed due to unexpected end of file

[ https://issues.apache.org/jira/browse/FLINK-21603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-21603: Assignee: Chesnay Schepler > SQLClientKafkaITCase failed due to unexpected end

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457010#comment-17457010 ] Chesnay Schepler commented on FLINK-17510: -- I will re-enable this test for a bit to see if our

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

slinkydeveloper commented on a change in pull request #18065: URL: https://github.com/apache/flink/pull/18065#discussion_r766516674 ## File path: flink-table/flink-table-api-bridge-common/src/main/java/org/apache/flink/table/api/bridge/internal/BaseStreamTableEnvironmentImpl.java

[jira] [Assigned] (FLINK-21796) SQLClientKafkaITCase.testKafka fails to download Kafka

[ https://issues.apache.org/jira/browse/FLINK-21796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-21796: Assignee: Chesnay Schepler > SQLClientKafkaITCase.testKafka fails to download

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457001#comment-17457001 ] Till Rohrmann commented on FLINK-20195: --- Thanks for the logs [~keatspeeks]. [~chesnay] found the

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

flinkbot edited a comment on pull request #17892: URL: https://github.com/apache/flink/pull/17892#issuecomment-977710431 ## CI report: * ce361075a76f0207d04c7bb580ced4c5194d73e1 Azure:

[jira] [Assigned] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-20195: Assignee: Chesnay Schepler > Jobs endpoint returns duplicated jobs >

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[jira] [Created] (FLINK-25252) Check whether Kafka E2E tests could be run on Java 11

Chesnay Schepler created FLINK-25252: Summary: Check whether Kafka E2E tests could be run on Java 11 Key: FLINK-25252 URL: https://issues.apache.org/jira/browse/FLINK-25252 Project: Flink

[jira] [Created] (FLINK-25253) An ClassNotFoundException of missing Hadoop class occurred when submitting to yarn

ghost synth created FLINK-25253: --- Summary: An ClassNotFoundException of missing Hadoop class occurred when submitting to yarn Key: FLINK-25253 URL: https://issues.apache.org/jira/browse/FLINK-25253

[GitHub] [flink] flinkbot edited a comment on pull request #18009: [FLINK-25126][kafka] Reset internal transaction state of FlinkKafkaIn…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18057: [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests

flinkbot edited a comment on pull request #18057: URL: https://github.com/apache/flink/pull/18057#issuecomment-91710 ## CI report: * 0474f6a36575f92dede3f42424ee46ffddc7d0ac Azure:

[jira] [Created] (FLINK-25251) Docker image should use Java 11 by default

Chesnay Schepler created FLINK-25251: Summary: Docker image should use Java 11 by default Key: FLINK-25251 URL: https://issues.apache.org/jira/browse/FLINK-25251 Project: Flink Issue

[jira] [Created] (FLINK-25250) Consider Java 11 as default version on CI

Chesnay Schepler created FLINK-25250: Summary: Consider Java 11 as default version on CI Key: FLINK-25250 URL: https://issues.apache.org/jira/browse/FLINK-25250 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18057: [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests

flinkbot edited a comment on pull request #18057: URL: https://github.com/apache/flink/pull/18057#issuecomment-91710 ## CI report: * 0474f6a36575f92dede3f42424ee46ffddc7d0ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18009: [FLINK-25126][kafka] Reset internal transaction state of FlinkKafkaIn…

flinkbot edited a comment on pull request #18009: URL: https://github.com/apache/flink/pull/18009#issuecomment-985559926 ## CI report: * 5c4d26077434251817218d0d712c3c0fc44ef101 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: * 678071d7b3368fcbcef7c851d84ac8b93056bbdf Azure:

[jira] [Created] (FLINK-25249) Reimplement KafkaSourceTestEnv with KafkaContainer

Qingsheng Ren created FLINK-25249: - Summary: Reimplement KafkaSourceTestEnv with KafkaContainer Key: FLINK-25249 URL: https://issues.apache.org/jira/browse/FLINK-25249 Project: Flink Issue

[jira] [Updated] (FLINK-13719) Update Yarn E2E test docker image to run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-13719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13719: - Parent: FLINK-25244 Issue Type: Sub-task (was: Technical Debt) > Update Yarn

[jira] [Created] (FLINK-25248) Deprecate components that inherently require Java 8

Chesnay Schepler created FLINK-25248: Summary: Deprecate components that inherently require Java 8 Key: FLINK-25248 URL: https://issues.apache.org/jira/browse/FLINK-25248 Project: Flink

[jira] [Created] (FLINK-25247) Inform users about deprecation

Chesnay Schepler created FLINK-25247: Summary: Inform users about deprecation Key: FLINK-25247 URL: https://issues.apache.org/jira/browse/FLINK-25247 Project: Flink Issue Type: Sub-task

[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: * 678071d7b3368fcbcef7c851d84ac8b93056bbdf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * 92f5f7c95542c9a08863324d5c885106e554a6c2 Azure:

[jira] [Commented] (FLINK-25126) FlinkKafkaInternalProducer state is not reset if transaction finalization fails

[ https://issues.apache.org/jira/browse/FLINK-25126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456985#comment-17456985 ] Fabian Paul commented on FLINK-25126: - Merged release-1.14: dccd7f08cde2b13ba4549c94ebbc04ff2c0c5152

[GitHub] [flink] fapaul merged pull request #18069: [FLINK-25126][kafka] Reset internal transaction state of FlinkKafkaIn…

fapaul merged pull request #18069: URL: https://github.com/apache/flink/pull/18069 -- 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 edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * 92f5f7c95542c9a08863324d5c885106e554a6c2 Azure:

[jira] [Commented] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

[ https://issues.apache.org/jira/browse/FLINK-24528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456984#comment-17456984 ] zoucao commented on FLINK-24528: +1, the same problem we occurred. > Flink HBase Asyc Lookup throw NPE

[jira] [Created] (FLINK-25246) Run benchmarks on Java 11

Chesnay Schepler created FLINK-25246: Summary: Run benchmarks on Java 11 Key: FLINK-25246 URL: https://issues.apache.org/jira/browse/FLINK-25246 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25245) Allow Kubernetes E2E tests to run on Java 11

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

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

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

[jira] [Assigned] (FLINK-25131) Update sql client to ship flink-table-planner-loader instead of flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-25131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-25131: --- Assignee: Francesco Guardiani > Update sql client to ship

[jira] [Assigned] (FLINK-25129) Update docs and examples to use flink-table-planner-loader instead of flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-25129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-25129: --- Assignee: Francesco Guardiani > Update docs and examples to use

[jira] [Assigned] (FLINK-25130) Update flink-table-uber to ship flink-table-planner-loader instead of flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-25130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-25130: --- Assignee: Francesco Guardiani > Update flink-table-uber to ship

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456979#comment-17456979 ] ranqiqiang commented on FLINK-14902: Hello, we are going to use  "AsyncJdbcLookupFunction" , but we

[jira] [Created] (FLINK-25244) Deprecate Java 8 support

Chesnay Schepler created FLINK-25244: Summary: Deprecate Java 8 support Key: FLINK-25244 URL: https://issues.apache.org/jira/browse/FLINK-25244 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #18063: [FLINK-24413] Apply trimming & padding when CASTing to CHAR/VARCHAR

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

[GitHub] [flink] flinkbot edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

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

[GitHub] [flink] twalthr commented on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

twalthr commented on pull request #17217: URL: https://github.com/apache/flink/pull/17217#issuecomment-990745078 @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 specific

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456965#comment-17456965 ] Matthias Pohl commented on FLINK-24341: --- The build of my most-recent comment does contain an

[GitHub] [flink-shaded] zentol commented on pull request #107: [FLINK-25145] Add Zookeeper 3.6

zentol commented on pull request #107: URL: https://github.com/apache/flink-shaded/pull/107#issuecomment-990740416 > Would it really make things that more complex? I didn't say that complexity would shoot threw the roof. Just that it's _more_. How do you ensure that

[jira] [Commented] (FLINK-23946) Application mode fails fatally when being shut down

[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456959#comment-17456959 ] Till Rohrmann commented on FLINK-23946: --- Merged into 1.14.1 via

[GitHub] [flink] tillrohrmann merged pull request #18066: [FLINK-23946][BP-1.14] Application mode should shutdown gracefully on…

tillrohrmann merged pull request #18066: URL: https://github.com/apache/flink/pull/18066 -- 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] [Commented] (FLINK-24794) AZP kills docker containers with exit code 137 (maybe OOM)

[ https://issues.apache.org/jira/browse/FLINK-24794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456957#comment-17456957 ] Till Rohrmann commented on FLINK-24794: --- Another instance:

[GitHub] [flink] flinkbot edited a comment on pull request #18072: [FLINK-23375][connector/jdbc] Build proper JDBC test jar.

flinkbot edited a comment on pull request #18072: URL: https://github.com/apache/flink/pull/18072#issuecomment-990433487 ## CI report: * c697d5522a724787b7259d776309fbe0ef689601 Azure:

[jira] [Created] (FLINK-25243) Fabric8FlinkKubeClientITCase.testCheckAndUpdateConfigMapConcurrently

Till Rohrmann created FLINK-25243: - Summary: Fabric8FlinkKubeClientITCase.testCheckAndUpdateConfigMapConcurrently Key: FLINK-25243 URL: https://issues.apache.org/jira/browse/FLINK-25243 Project:

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456956#comment-17456956 ] Till Rohrmann commented on FLINK-20928: --- Another instance:

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456952#comment-17456952 ] Chesnay Schepler commented on FLINK-24341: -- What IllegalStateException? > PyFlink Table test

[GitHub] [flink] flinkbot edited a comment on pull request #18061: [FLINK-25239][connector/jdbc] delete useless variables

flinkbot edited a comment on pull request #18061: URL: https://github.com/apache/flink/pull/18061#issuecomment-989698410 ## CI report: * fbda9265b2aed8dce1d938148bf66d2bb99d93d0 Azure:

[jira] [Commented] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456950#comment-17456950 ] PJ Fanning commented on FLINK-25240: 2.15.0 is released to maven central -

[GitHub] [flink] flinkbot edited a comment on pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

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

[GitHub] [flink] flinkbot edited a comment on pull request #18065: [FLINK-25229][table] Introduce flink-table-api-bridge-common

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

[GitHub] [flink] flinkbot edited a comment on pull request #17893: [FLINK-24987][Configuration] Add explicit enum value NO_EXTERNAL_CHECKPOINTS as default for ExternalizedCheckpointRetention

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

[GitHub] [flink] flinkbot edited a comment on pull request #17893: [FLINK-24987][Configuration] Add explicit enum value NO_EXTERNAL_CHECKPOINTS as default for ExternalizedCheckpointRetention

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

[jira] [Commented] (FLINK-24794) AZP kills docker containers with exit code 137 (maybe OOM)

[ https://issues.apache.org/jira/browse/FLINK-24794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456939#comment-17456939 ] Matthias Pohl commented on FLINK-24794: --- I'm linking FLINK-24341 because there is another issue

[GitHub] [flink] JingGe commented on pull request #18071: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.13

JingGe commented on pull request #18071: URL: https://github.com/apache/flink/pull/18071#issuecomment-990717210 @AHeise there were some conflicts while doing the cp. Would you please to double check, thanks. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] JingGe commented on pull request #18070: [FLINK-24077][hbase2/HBaseConnectorITCase] fix flaky tests backport to 1.14

JingGe commented on pull request #18070: URL: https://github.com/apache/flink/pull/18070#issuecomment-990716232 @AHeise would you please help merging this PR, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456936#comment-17456936 ] Matthias Pohl commented on FLINK-24341: --- Another failure like that occurred in

<    1   2   3   4   5   6   >