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

2022-01-10 Thread GitBox
alpreu commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r780959595 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/GlobalCommitter.java ## @@ -57,11 +57,12 @@ GlobalCommT combine(List

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

2022-01-10 Thread GitBox
alpreu commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r780968532 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] dmvk commented on a change in pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

2022-01-10 Thread GitBox
dmvk commented on a change in pull request #18059: URL: https://github.com/apache/flink/pull/18059#discussion_r780300834 ## File path: docs/content/docs/deployment/filesystems/gcs.md ## @@ -68,7 +68,7 @@ You must include the following jars in Flink's `lib` directory to

[jira] [Resolved] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

2022-01-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-25224. --- Resolution: Fixed > Upgrade the minimal supported hadoop version to 2.8.5 >

[jira] [Commented] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

2022-01-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471759#comment-17471759 ] Matthias Pohl commented on FLINK-25224: --- master:

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966453 ## CI report: * c7fd105b0ddb325adf89aa90e864d272ff19fce1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * c6106bd7df67e7e41b3cfd6a45b82149622f074b Azure:

[GitHub] [flink] matriv commented on pull request #18221: [FLINK-24803][table-planner] Fix cast BINARY/VARBINARY to STRING

2022-01-10 Thread GitBox
matriv commented on pull request #18221: URL: https://github.com/apache/flink/pull/18221#issuecomment-1008678390 Postgres uses a hexademical representation: ``` postgres=# select '\000\001\034\127'::bytea::varchar(20); varchar \x00011c57 (1 row) ```

[jira] [Updated] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

2022-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25280: --- Labels: pull-request-available (was: ) > KafkaPartitionSplitReaderTest failed on azure due

[jira] [Commented] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

2022-01-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471795#comment-17471795 ] Till Rohrmann commented on FLINK-22602: --- Should we upgrade to 1.12.2? cc [~MartijnVisser] and

[GitHub] [flink] flinkbot commented on pull request #18311: [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run

2022-01-10 Thread GitBox
flinkbot commented on pull request #18311: URL: https://github.com/apache/flink/pull/18311#issuecomment-1008683024 ## CI report: * ac91b58ea839b06d802f1017a106c63c47a9bd7e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-25141) Elasticsearch connector customize sink parallelism

2022-01-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471810#comment-17471810 ] Fabian Paul commented on FLINK-25141: - Merged in master: 85606600b3303bb908e866fce8337867dd09dae5 >

[jira] [Updated] (FLINK-25141) Elasticsearch connector customize sink parallelism

2022-01-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25141: Affects Version/s: 1.15.0 > Elasticsearch connector customize sink parallelism >

[jira] [Resolved] (FLINK-25141) Elasticsearch connector customize sink parallelism

2022-01-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25141. - Resolution: Fixed > Elasticsearch connector customize sink parallelism >

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure:

[jira] [Created] (FLINK-25588) Add jdk8 and datetime module to jackson shaded

2022-01-10 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-25588: --- Summary: Add jdk8 and datetime module to jackson shaded Key: FLINK-25588 URL: https://issues.apache.org/jira/browse/FLINK-25588 Project: Flink

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

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

[GitHub] [flink] MartijnVisser commented on pull request #18307: Update match_recognize.md

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #18307: URL: https://github.com/apache/flink/pull/18307#issuecomment-1008726775 @SteNicholas Sure, but the Chinese translation also has the same error which we should fix at the same time. -- This is an automated message from the Apache Git

[GitHub] [flink] JingsongLi merged pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2022-01-10 Thread GitBox
JingsongLi merged pull request #18219: URL: https://github.com/apache/flink/pull/18219 -- 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 #18313: Update match_recognize.md

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18313: URL: https://github.com/apache/flink/pull/18313#issuecomment-1008743407 ## CI report: * 9e65f5754e07a6f0f31839cf297369c439098ef4 Azure:

[jira] [Updated] (FLINK-25581) Jobmanager does not archive completed jobs

2022-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25581: - Component/s: Runtime / Coordination > Jobmanager does not archive completed jobs >

[GitHub] [flink] SteNicholas edited a comment on pull request #18307: Update match_recognize.md

2022-01-10 Thread GitBox
SteNicholas edited a comment on pull request #18307: URL: https://github.com/apache/flink/pull/18307#issuecomment-1008759345 @jxjgssylsg , could you please update the Chinese document in this pull request? And close the pull request #18313. -- This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

2022-01-10 Thread GitBox
flinkbot commented on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 0cb7e0c49e9b417f460573885d6d7ba483f18ba1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure:

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471761#comment-17471761 ] Yun Gao commented on FLINK-23956: -

[jira] [Commented] (FLINK-24498) KafkaShuffleITCase fails with "The topic metadata failed to propagate to Kafka broker"

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471762#comment-17471762 ] Yun Gao commented on FLINK-24498: - I'll first close this issue since it seems to be duplicated with

[jira] [Assigned] (FLINK-25387) Introduce ExecNodeMetadata annotation and tooling

2022-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25387: Assignee: Marios Trivyzas > Introduce ExecNodeMetadata annotation and tooling >

[jira] [Updated] (FLINK-25387) Introduce ExecNodeMetadata annotation and tooling

2022-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25387: - Description: Introduce annotation: {code} @ExecNodeMetadata(   // main information   name =

[jira] [Updated] (FLINK-25387) Introduce ExecNodeMetadata annotation and tooling

2022-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25387: - Description: Introduce annotation: {code} @ExecNodeMetadata(   // main information   name =

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

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1008674192 @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 #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

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

[GitHub] [flink] flinkbot commented on pull request #18311: [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run

2022-01-10 Thread GitBox
flinkbot commented on pull request #18311: URL: https://github.com/apache/flink/pull/18311#issuecomment-1008684147 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-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

2022-01-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471791#comment-17471791 ] Till Rohrmann commented on FLINK-25564: --- I didn't try to reproduce it yet. Maybe a good step could

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

2022-01-10 Thread GitBox
XComp commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1008698672 @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

[GitHub] [flink] fapaul merged pull request #18033: [FLINK-25141][connector/elasticsearch][docs] Add sink parallelism option

2022-01-10 Thread GitBox
fapaul merged pull request #18033: URL: https://github.com/apache/flink/pull/18033 -- 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] [Closed] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-10 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-25508. Resolution: Invalid > Flink Batch mode, cluster shutdown early. > - > >

[jira] [Reopened] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-10 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd reopened FLINK-25508: -- > Flink Batch mode, cluster shutdown early. > - > > Key:

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1008704247 Thanks @tillrohrmann Could you help review again? I have fixed previous CI failure and the latest failure looks unrelated with this PR. By the way, i can't comment

[jira] [Updated] (FLINK-25141) Elasticsearch connector customize sink parallelism

2022-01-10 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Affects Version/s: (was: 1.15.0) > Elasticsearch connector customize sink parallelism >

[GitHub] [flink] flinkbot edited a comment on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966453 ## CI report: * 6c44648f7f54009a3b03f4308fea6bb619e4c0ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure:

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

2022-01-10 Thread GitBox
gaoyunhaii commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781025719 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * 683c8e4796bb01ba4789a1edc1cb465fae8b0547 Azure:

[jira] [Updated] (FLINK-25588) Add jdk8 and datetime module to jackson shaded

2022-01-10 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25588: Description: Add modules jdk8 and jsr310 to jackson shaded.

[GitHub] [flink-shaded] slinkydeveloper opened a new pull request #108: [FLINK-25588] Add Jackson JDK8 types to shaded jackson

2022-01-10 Thread GitBox
slinkydeveloper opened a new pull request #108: URL: https://github.com/apache/flink-shaded/pull/108 ## Changes: * Use the Jackson BOM * Add Jackson jdk8 and javatime modules to the shaded jackson Signed-off-by: slinkydeveloper -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * 683c8e4796bb01ba4789a1edc1cb465fae8b0547 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18182: [FLINK-25341][table-planner] Add StructuredToStringCastRule to support user POJO toString implementation

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18182: URL: https://github.com/apache/flink/pull/18182#issuecomment-999702547 ## CI report: * 4507f24ded0379ab48d81af5f7174febefd0c67a Azure:

[GitHub] [flink] flinkbot commented on pull request #18313: Update match_recognize.md

2022-01-10 Thread GitBox
flinkbot commented on pull request #18313: URL: https://github.com/apache/flink/pull/18313#issuecomment-1008742920 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 commented on pull request #18313: Update match_recognize.md

2022-01-10 Thread GitBox
flinkbot commented on pull request #18313: URL: https://github.com/apache/flink/pull/18313#issuecomment-1008743407 ## CI report: * 9e65f5754e07a6f0f31839cf297369c439098ef4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] SteNicholas commented on pull request #18307: Update match_recognize.md

2022-01-10 Thread GitBox
SteNicholas commented on pull request #18307: URL: https://github.com/apache/flink/pull/18307#issuecomment-1008759345 @jxjgssylsg , could you please update the Chinese document? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-25590) Logging warning of insufficient memory for all configured buffers

2022-01-10 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-25590: - Summary: Logging warning of insufficient memory for all configured buffers Key: FLINK-25590 URL: https://issues.apache.org/jira/browse/FLINK-25590 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #18182: [FLINK-25341][table-planner] Add StructuredToStringCastRule to support user POJO toString implementation

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18182: URL: https://github.com/apache/flink/pull/18182#issuecomment-999702547 ## CI report: * be8c623aec0de2dd4a7b9f0a8baf083112053e1c Azure:

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471764#comment-17471764 ] Yun Gao commented on FLINK-23956: -

[jira] (FLINK-24498) KafkaShuffleITCase fails with "The topic metadata failed to propagate to Kafka broker"

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24498 ] Yun Gao deleted comment on FLINK-24498: - was (Author: gaoyunhaii): I'll first close this issue since it seems to be duplicated with https://issues.apache.org/jira/browse/FLINK-23956. Let's move

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

2022-01-10 Thread GitBox
KarmaGYZ commented on a change in pull request #18303: URL: https://github.com/apache/flink/pull/18303#discussion_r780953755 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/PeriodicTaskScheduledExecutor.java ## @@ -0,0 +1,95 @@ +/* + *

[jira] [Updated] (FLINK-25588) Add jdk8 and datetime module to jackson shaded

2022-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25588: - Fix Version/s: shaded-15.0 > Add jdk8 and datetime module to jackson shaded >

[GitHub] [flink] jxjgssylsg opened a new pull request #18313: Update match_recognize.md

2022-01-10 Thread GitBox
jxjgssylsg opened a new pull request #18313: URL: https://github.com/apache/flink/pull/18313 The example of “Time constraint” omits a comma. ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather

[jira] [Closed] (FLINK-25178) Throw exception when managed table sink needs checkpointing

2022-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25178. Resolution: Fixed master: 5b16a8fd26d189e07b0dee498161b8ba9b555e08 > Throw exception when

[GitHub] [flink] flinkbot commented on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

2022-01-10 Thread GitBox
flinkbot commented on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761426 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] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-10 Thread GitBox
XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r781090363 ## File path: flink-core/src/main/java/org/apache/flink/util/function/QuintFunction.java ## @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-25587) HiveCatalogITCase crashed on Azure with exit code 239

2022-01-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-25587: --- Summary: HiveCatalogITCase crashed on Azure with exit code 239 Key: FLINK-25587 URL: https://issues.apache.org/jira/browse/FLINK-25587 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25587) HiveCatalogITCase crashed on Azure with exit code 239

2022-01-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471758#comment-17471758 ] Yun Gao commented on FLINK-25587: - Perhaps also cc [~lzljs3620320]~ > HiveCatalogITCase crashed on

[GitHub] [flink] liufangqi commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

2022-01-10 Thread GitBox
liufangqi commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-100864 @XComp @dmvk , THX for all of your efforts! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

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

2022-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25388: Assignee: Marios Trivyzas > Add annotation to all StreamExec nodes >

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

2022-01-10 Thread GitBox
slinkydeveloper commented on a change in pull request #18287: URL: https://github.com/apache/flink/pull/18287#discussion_r780981547 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -1142,14

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

2022-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25388: - Description: - Add an annotation to very ExecNode that we currently support - Identify consumed

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

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r780984277 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * c6106bd7df67e7e41b3cfd6a45b82149622f074b Azure:

[GitHub] [flink] PatrickRen opened a new pull request #18311: [FLINK-25280[connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run

2022-01-10 Thread GitBox
PatrickRen opened a new pull request #18311: URL: https://github.com/apache/flink/pull/18311 ## What is the purpose of the change This pull request disables log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run ## Brief change log

[GitHub] [flink] matriv commented on pull request #18221: [FLINK-24803][table-planner] Fix cast BINARY/VARBINARY to STRING

2022-01-10 Thread GitBox
matriv commented on pull request #18221: URL: https://github.com/apache/flink/pull/18221#issuecomment-1008680825 @twalthr @wuchong I don't have strong opinion here, either with the current approach or the hex representation for the standard CAST to a string data type, and of course

[GitHub] [flink] BruceWong96 commented on a change in pull request #18293: [FLINK-25560][Connectors/HBase] Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versio

2022-01-10 Thread GitBox
BruceWong96 commented on a change in pull request #18293: URL: https://github.com/apache/flink/pull/18293#discussion_r781018539 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/table/HBaseConnectorOptions.java ## @@

[GitHub] [flink] BruceWong96 commented on a change in pull request #18293: [FLINK-25560][Connectors/HBase] Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versio

2022-01-10 Thread GitBox
BruceWong96 commented on a change in pull request #18293: URL: https://github.com/apache/flink/pull/18293#discussion_r781018019 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/table/HBaseConnectorOptions.java ## @@

[GitHub] [flink] flinkbot commented on pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
flinkbot commented on pull request #18312: URL: https://github.com/apache/flink/pull/18312#issuecomment-1008688761 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-22602) Upgrade parquet to 1.12.0 due to CVEs

2022-01-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22602: -- Priority: Critical (was: Minor) > Upgrade parquet to 1.12.0 due to CVEs >

[GitHub] [flink] BruceWong96 commented on a change in pull request #18293: [FLINK-25560][Connectors/HBase] Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versio

2022-01-10 Thread GitBox
BruceWong96 commented on a change in pull request #18293: URL: https://github.com/apache/flink/pull/18293#discussion_r781018019 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/table/HBaseConnectorOptions.java ## @@

[GitHub] [flink] vahmed-hamdy commented on a change in pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-10 Thread GitBox
vahmed-hamdy commented on a change in pull request #17907: URL: https://github.com/apache/flink/pull/17907#discussion_r781029925 ## File path: flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/resources/filter-large-orders.sql ## @@ -36,10 +36,10 @@ CREATE TABLE

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

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

[jira] [Commented] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

2022-01-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471836#comment-17471836 ] Martijn Visser commented on FLINK-22602: We should at least upgrade to the latest version to

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

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

[jira] [Updated] (FLINK-25588) Add jdk8 and datetime module to jackson shaded

2022-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25588: --- Labels: pull-request-available (was: ) > Add jdk8 and datetime module to jackson shaded >

[GitHub] [flink] CrynetLogistics opened a new pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

2022-01-10 Thread GitBox
CrynetLogistics opened a new pull request #18314: URL: https://github.com/apache/flink/pull/18314 ## What is the purpose of the change *Allows users to write to KDF directly through this sink based on the unified sink (FLIP-141).* ## Brief change log *(for

[GitHub] [flink] flinkbot edited a comment on pull request #18182: [FLINK-25341][table-planner] Add StructuredToStringCastRule to support user POJO toString implementation

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18182: URL: https://github.com/apache/flink/pull/18182#issuecomment-999702547 ## CI report: * be8c623aec0de2dd4a7b9f0a8baf083112053e1c Azure:

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1008631939 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure:

[GitHub] [flink] XComp merged pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

2022-01-10 Thread GitBox
XComp merged pull request #18059: URL: https://github.com/apache/flink/pull/18059 -- 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] XComp commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

2022-01-10 Thread GitBox
XComp commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-1008637413 Thanks for your contribution @liufangqi . I'm going to merge the changes into `master`. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-25587) HiveCatalogITCase crashed on Azure with exit code 239

2022-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471768#comment-17471768 ] Jingsong Lee commented on FLINK-25587: -- CC: [~jark] [~luoyuxia]  > HiveCatalogITCase crashed on

[jira] [Assigned] (FLINK-25389) Update JSON plan with new ExecNodeMetadata

2022-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25389: Assignee: Marios Trivyzas > Update JSON plan with new ExecNodeMetadata >

[GitHub] [flink] liufangqi commented on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

2022-01-10 Thread GitBox
liufangqi commented on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-1008662267 @dmvk @AHeise Hi, as the issue [https://issues.apache.org/jira/browse/FLINK-25224] and the pull request [https://github.com/apache/flink/pull/18059] was sloved and merged,

[jira] [Commented] (FLINK-25280) KafkaPartitionSplitReaderTest failed on azure due to Offsets out of range with no configured reset policy for partitions

2022-01-10 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471784#comment-17471784 ] Qingsheng Ren commented on FLINK-25280: --- I think this is caused by the same reason of FLINK-22198

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

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

[GitHub] [flink] nyingping opened a new pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
nyingping opened a new pull request #18312: URL: https://github.com/apache/flink/pull/18312 Update copyright year for the master branch. -- 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 #18311: [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18311: URL: https://github.com/apache/flink/pull/18311#issuecomment-1008683024 ## CI report: * 6d9cda7d8a3b8e002ed7d9685d9e76322604ad7d UNKNOWN Bot commands The @flinkbot bot supports the following commands: -

[GitHub] [flink] flinkbot commented on pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
flinkbot commented on pull request #18312: URL: https://github.com/apache/flink/pull/18312#issuecomment-1008686402 ## CI report: * 93dbd0a2c4f931c1248c2c4ae23175af1115e6ce UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18312: URL: https://github.com/apache/flink/pull/18312#issuecomment-1008686402 ## CI report: * 93dbd0a2c4f931c1248c2c4ae23175af1115e6ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18311: [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18311: URL: https://github.com/apache/flink/pull/18311#issuecomment-1008683024 ## CI report: * 6d9cda7d8a3b8e002ed7d9685d9e76322604ad7d Azure:

[jira] [Closed] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-10 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-25508. Resolution: Won't Do > Flink Batch mode, cluster shutdown early. > - > >

[GitHub] [flink] fapaul commented on a change in pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #17937: URL: https://github.com/apache/flink/pull/17937#discussion_r781031713 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderTestBase.java

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

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

[GitHub] [flink] MartijnVisser commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.0 due to CVEs

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008719386 @cuibo01 Could you upgrade to the latest version of the Parquet dependencies? I see that 1.12.2 is now released. -- This is an automated message from the Apache Git

  1   2   3   4   5   6   >