[GitHub] [flink] flinkbot commented on pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

flinkbot commented on pull request #14693: URL: https://github.com/apache/flink/pull/14693#issuecomment-762669697 ## CI report: * 58b45f883dfd13a36efbf22b17a487fd28d94d90 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rmetzger commented on a change in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

rmetzger commented on a change in pull request #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r559978485 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/FailureListener.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apach

[GitHub] [flink] wangyang0918 commented on pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

wangyang0918 commented on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-762671877 I have run a Flink application on minikube with setting the owner reference of JobManager deployment to a new created service(e.g. my-test-svc). After the service is delete

[GitHub] [flink] rmetzger commented on a change in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

rmetzger commented on a change in pull request #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r559979096 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java ## @@ -98,11 +103,26 @@ pu

[GitHub] [flink] flinkbot edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 88b27b180a90899b60afbfd12c2930939f76a3a4 UNKNOWN * 51794ed8d24485bee01645ee15e7ecc1b8d13f8f Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21012: --- Fix Version/s: (was: 1.12.3) 1.12.2 > AvroFileFormatFactory uses non-

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21022: --- Fix Version/s: (was: 1.12.3) 1.12.2 > flink-connector-es add onSucces

[GitHub] [flink] flinkbot edited a comment on pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

flinkbot edited a comment on pull request #14692: URL: https://github.com/apache/flink/pull/14692#issuecomment-762669595 ## CI report: * 48ef644b381d5f9f0dd030857fcaab5e80ab4a97 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

flinkbot edited a comment on pull request #14693: URL: https://github.com/apache/flink/pull/14693#issuecomment-762669697 ## CI report: * 58b45f883dfd13a36efbf22b17a487fd28d94d90 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21023) Task Manager uses the container dir of Job Manager when running flink job on yarn-cluster.

[ https://issues.apache.org/jira/browse/FLINK-21023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tang Yan updated FLINK-21023: - Description: I want to try to use option  -yt(yarnship) to distribute my config files to Yarn cluster,

[jira] [Updated] (FLINK-21023) Task Manager uses the container dir of Job Manager when running flink job on yarn-cluster.

[ https://issues.apache.org/jira/browse/FLINK-21023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tang Yan updated FLINK-21023: - Description: I want to try to use option  -yt(yarnship) to distribute my config files to Yarn cluster,

[jira] [Updated] (FLINK-21023) Task Manager uses the container dir of Job Manager when running flink job on yarn-cluster.

[ https://issues.apache.org/jira/browse/FLINK-21023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tang Yan updated FLINK-21023: - Component/s: Deployment / YARN > Task Manager uses the container dir of Job Manager when running flink j

[jira] [Created] (FLINK-21023) Task Manager uses the container dir of Job Manager when running flink job on yarn-cluster.

Tang Yan created FLINK-21023: Summary: Task Manager uses the container dir of Job Manager when running flink job on yarn-cluster. Key: FLINK-21023 URL: https://issues.apache.org/jira/browse/FLINK-21023 Pr

[GitHub] [flink] flinkbot edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

flinkbot edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 88b27b180a90899b60afbfd12c2930939f76a3a4 UNKNOWN * 51794ed8d24485bee01645ee15e7ecc1b8d13f8f Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20495: - Priority: Blocker (was: Major) > Elasticsearch6DynamicSinkITCase Hang > ---

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267746#comment-17267746 ] Xintong Song commented on FLINK-20811: -- Thanks you both for offering to contribute,

[jira] [Created] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

Matthias created FLINK-21024: Summary: Dynamic properties get exposed to job's main method if user parameters are passed Key: FLINK-21024 URL: https://issues.apache.org/jira/browse/FLINK-21024 Project: Fl

[jira] [Updated] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21024: - Description: A bug was identified in the [user ML|http://apache-flink-user-mailing-list-archive.2336050

[jira] [Created] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

Dawid Wysakowicz created FLINK-21025: Summary: SQLClientHBaseITCase fails when untarring HBase Key: FLINK-21025 URL: https://issues.apache.org/jira/browse/FLINK-21025 Project: Flink Issue

[GitHub] [flink] rmetzger opened a new pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

rmetzger opened a new pull request #14694: URL: https://github.com/apache/flink/pull/14694 ## What is the purpose of the change Increase stability of java e2e tests This is an automated message from the Apa

[jira] [Updated] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21024: - Attachment: WordCount.jar > Dynamic properties get exposed to job's main method if user parameters are

[jira] [Commented] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267755#comment-17267755 ] Dawid Wysakowicz commented on FLINK-21025: -- Could be related to https://issues.

[GitHub] [flink] flinkbot commented on pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

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

[jira] [Commented] (FLINK-19132) Failed to start jobs for consuming Secure Kafka after cluster restart

[ https://issues.apache.org/jira/browse/FLINK-19132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267757#comment-17267757 ] Suo L. commented on FLINK-19132: See the same issue, 1.10.2 + k8s, temporary solved by r

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267759#comment-17267759 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], I would follow your sug

[jira] [Assigned] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20811: Assignee: Venkata S Muppalla > Support HTTP paths for yarn ship files/archives >

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267762#comment-17267762 ] Xintong Song commented on FLINK-20811: -- [~nicholasjiang], thanks for your understan

[jira] [Created] (FLINK-21026) Align column list specification with Hive in INSERT statement

Zhenghua Gao created FLINK-21026: Summary: Align column list specification with Hive in INSERT statement Key: FLINK-21026 URL: https://issues.apache.org/jira/browse/FLINK-21026 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14689: [FLINK-20500][upsert-kafka] Fix temporal join test

flinkbot edited a comment on pull request #14689: URL: https://github.com/apache/flink/pull/14689#issuecomment-762595621 ## CI report: * 7421043232e94c67d4e44020b8a5a319a3e95a09 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

flinkbot commented on pull request #14694: URL: https://github.com/apache/flink/pull/14694#issuecomment-762699714 ## CI report: * 1c8e22e046a15d442e4d0bcdec73c6ea5b4a3f2d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21024: - Affects Version/s: 1.12.1 > Dynamic properties get exposed to job's main method if user parameters are

[jira] [Updated] (FLINK-21026) Align column list specification with Hive in INSERT statement

[ https://issues.apache.org/jira/browse/FLINK-21026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-21026: - Description: HIVE-9481 allows column list specification in INSERT statement. The syntax is: {cod

[jira] [Updated] (FLINK-21026) Align column list specification with Hive in INSERT statement

[ https://issues.apache.org/jira/browse/FLINK-21026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-21026: - Description: HIVE-9481 allows column list specification in INSERT statement. The syntax is: {cod

[jira] [Updated] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21024: - Description: A bug was identified in the [user ML|http://apache-flink-user-mailing-list-archive.2336050

[jira] [Updated] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21024: - Description: A bug was identified in the [user ML|http://apache-flink-user-mailing-list-archive.2336050

[GitHub] [flink] YuvalItzchakov commented on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

YuvalItzchakov commented on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-762709238 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] weizheng-cloud opened a new pull request #14695: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

weizheng-cloud opened a new pull request #14695: URL: https://github.com/apache/flink/pull/14695 …rocess ## What is the purpose of the change *add onSuccess handler after bulk process for user to override to do some other logic, for ex* ## Brief change log

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21022: --- Labels: pull-request-available (was: ) > flink-connector-es add onSuccess handler after bul

[GitHub] [flink] flinkbot edited a comment on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-759451108 ## CI report: * 5ba2774d208ac12b1a0d6e67c426cf06211d4e21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * f2db6f3e6c725c09b24e919ea6cc45537be86d35 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

flinkbot edited a comment on pull request #14694: URL: https://github.com/apache/flink/pull/14694#issuecomment-762699714 ## CI report: * 1c8e22e046a15d442e4d0bcdec73c6ea5b4a3f2d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

flinkbot edited a comment on pull request #14693: URL: https://github.com/apache/flink/pull/14693#issuecomment-762669697 ## CI report: * 58b45f883dfd13a36efbf22b17a487fd28d94d90 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14695: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

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

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: (was: 1.12.0) > flink-connector-es add onSuccess handler after bulk process for

[GitHub] [flink] tillrohrmann commented on a change in pull request #14686: [FLINK-6042][runtime] Adds exception history

tillrohrmann commented on a change in pull request #14686: URL: https://github.com/apache/flink/pull/14686#discussion_r560025485 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java ## @@ -270,9 +270,22 @@ private void restartTasks

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Fix Version/s: (was: 1.12.2) 1.11.4 > flink-connector-es add onSuccess handler

[jira] [Commented] (FLINK-20992) Checkpoint cleanup can kill JobMaster

[ https://issues.apache.org/jira/browse/FLINK-20992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267775#comment-17267775 ] Till Rohrmann commented on FLINK-20992: --- I don't think that FLINK-18290 is impossi

[jira] [Assigned] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception

[ https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-20944: - Assignee: Yang Wang > Launching in application mode requesting a ClusterIP rest service

[GitHub] [flink] YuvalItzchakov commented on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

YuvalItzchakov commented on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-762718369 @wuchong Can I re-run the CI tests? This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267780#comment-17267780 ] Xintong Song commented on FLINK-21024: -- I think the problem is that, `standalone-jo

[jira] [Comment Edited] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267780#comment-17267780 ] Xintong Song edited comment on FLINK-21024 at 1/19/21, 9:37 AM: --

[jira] [Comment Edited] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267780#comment-17267780 ] Xintong Song edited comment on FLINK-21024 at 1/19/21, 9:37 AM: --

[jira] [Assigned] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21024: Assignee: Xintong Song > Dynamic properties get exposed to job's main method if user para

[GitHub] [flink] flinkbot edited a comment on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-759451108 ## CI report: * 5ba2774d208ac12b1a0d6e67c426cf06211d4e21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * f2db6f3e6c725c09b24e919ea6cc45537be86d35 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

tillrohrmann commented on a change in pull request #14692: URL: https://github.com/apache/flink/pull/14692#discussion_r560039104 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -125,6 +121,16 @@ public String getC

[GitHub] [flink] flinkbot commented on pull request #14695: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

flinkbot commented on pull request #14695: URL: https://github.com/apache/flink/pull/14695#issuecomment-762724470 ## CI report: * 598af596abeef70bb8cb3f456fc956dce5758035 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21008: -- Affects Version/s: 1.11.3 1.12.1 > ClusterEntrypoint#shutDownAsync may

[jira] [Updated] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21008: -- Fix Version/s: 1.13.0 > ClusterEntrypoint#shutDownAsync may not be fully executed > --

[jira] [Updated] (FLINK-21011) Separate the implementation of StreamExecIntervalJoin

[ https://issues.apache.org/jira/browse/FLINK-21011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-21011: Summary: Separate the implementation of StreamExecIntervalJoin (was: Separete the implementation

[jira] [Reopened] (FLINK-21011) Separate the implementation of StreamExecIntervalJoin

[ https://issues.apache.org/jira/browse/FLINK-21011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu reopened FLINK-21011: - > Separate the implementation of StreamExecIntervalJoin > --

[jira] [Updated] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21008: -- Priority: Critical (was: Major) > ClusterEntrypoint#shutDownAsync may not be fully executed >

[jira] [Commented] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267793#comment-17267793 ] Till Rohrmann commented on FLINK-21008: --- Is the problem that deregistering the app

[GitHub] [flink] weizheng-cloud opened a new pull request #14696: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

weizheng-cloud opened a new pull request #14696: URL: https://github.com/apache/flink/pull/14696 ## What is the purpose of the change *add onSuccess handler after bulk process for user to override to do some other logic, for ex* ## Brief change log *add onSu

[GitHub] [flink] flinkbot edited a comment on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-759451108 ## CI report: * 5ba2774d208ac12b1a0d6e67c426cf06211d4e21 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 1c605546a2ac429e1c475eea6f80a75d0326c7bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14685: [FLINK-21010] Separate the implementation of StreamExecJoin

flinkbot edited a comment on pull request #14685: URL: https://github.com/apache/flink/pull/14685#issuecomment-762256472 ## CI report: * 0a5fff76d69da75391ceb25e470173bae504e1c9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

flinkbot edited a comment on pull request #14693: URL: https://github.com/apache/flink/pull/14693#issuecomment-762669697 ## CI report: * 58b45f883dfd13a36efbf22b17a487fd28d94d90 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14695: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

flinkbot edited a comment on pull request #14695: URL: https://github.com/apache/flink/pull/14695#issuecomment-762724470 ## CI report: * 598af596abeef70bb8cb3f456fc956dce5758035 UNKNOWN * 2e99153d8828c74be95b3b452f664eaf558125fe UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot commented on pull request #14696: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #14683: [FLINK-20992][checkpointing] Tolerate checkpoint cleanup failures

tillrohrmann commented on a change in pull request #14683: URL: https://github.com/apache/flink/pull/14683#discussion_r560057569 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java ## @@ -62,8 +62,15 @@ public void cleanCheckpo

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267799#comment-17267799 ] Venkata S Muppalla commented on FLINK-20811: Thanks [~xintongsong] and [~Zhe

[GitHub] [flink] tillrohrmann commented on a change in pull request #14683: [FLINK-20992][checkpointing] Tolerate checkpoint cleanup failures

tillrohrmann commented on a change in pull request #14683: URL: https://github.com/apache/flink/pull/14683#discussion_r560061568 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCleanerTest.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the

[GitHub] [flink] tillrohrmann commented on a change in pull request #14683: [FLINK-20992][checkpointing] Tolerate checkpoint cleanup failures

tillrohrmann commented on a change in pull request #14683: URL: https://github.com/apache/flink/pull/14683#discussion_r560057569 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java ## @@ -62,8 +62,15 @@ public void cleanCheckpo

[GitHub] [flink] tillrohrmann closed pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

tillrohrmann closed pull request #14666: URL: https://github.com/apache/flink/pull/14666 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 g

[jira] [Closed] (FLINK-17085) Remove FlinkKubeClient#handleException since it does not do anything

[ https://issues.apache.org/jira/browse/FLINK-17085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-17085. - Fix Version/s: 1.13.0 Resolution: Fixed Fixed via 674edcf2f46761c8949f72aa2be13b1b6303115

[jira] [Commented] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267804#comment-17267804 ] Yang Wang commented on FLINK-21008: --- You are right. Deregistering the application from

[GitHub] [flink] zentol commented on a change in pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

zentol commented on a change in pull request #14694: URL: https://github.com/apache/flink/pull/14694#discussion_r560067499 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/AbstractDownloadCache.java ## @@ -128,7

[GitHub] [flink] zentol commented on a change in pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

zentol commented on a change in pull request #14694: URL: https://github.com/apache/flink/pull/14694#discussion_r560067730 ## File path: tools/azure-pipelines/jobs-template.yml ## @@ -199,7 +199,7 @@ jobs: condition: not(eq(variables['SKIP'], '1')) - task: Cache@2

[GitHub] [flink] zentol commented on a change in pull request #14694: [FLINK-19158][e2e] Fix wget timeout mechanism and cache config

zentol commented on a change in pull request #14694: URL: https://github.com/apache/flink/pull/14694#discussion_r560068264 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/CommandLineWrapper.java ## @@ -45,6 +46,11 @@

[GitHub] [flink] zentol merged pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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

[jira] [Closed] (FLINK-19656) Automatically replace delimiter in metric name components

[ https://issues.apache.org/jira/browse/FLINK-19656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19656. Resolution: Fixed master: 559ed01976df3bfcb450e03114220b2b71eee90c 56dbc24367979fdf9bd3f83

[GitHub] [flink] zentol commented on a change in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

zentol commented on a change in pull request #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r560072956 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/FailureListener.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[GitHub] [flink] wangyang0918 commented on a change in pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

wangyang0918 commented on a change in pull request #14692: URL: https://github.com/apache/flink/pull/14692#discussion_r560073139 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -125,6 +121,16 @@ public String getC

[GitHub] [flink] zentol commented on a change in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

zentol commented on a change in pull request #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r560072956 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/FailureListener.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache

[jira] [Comment Edited] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267804#comment-17267804 ] Yang Wang edited comment on FLINK-21008 at 1/19/21, 10:31 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #14633: [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined

flinkbot edited a comment on pull request #14633: URL: https://github.com/apache/flink/pull/14633#issuecomment-759451108 ## CI report: * 4740cf1d2d0a16700698f5f2108ee4a310d942dd UNKNOWN * 65bd73bc66714cfdd687947f0b1c464ed976cd64 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * e02d849c359db923aa91235d9756f055cb44c362 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 1c605546a2ac429e1c475eea6f80a75d0326c7bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14685: [FLINK-21010] Separate the implementation of StreamExecJoin

flinkbot edited a comment on pull request #14685: URL: https://github.com/apache/flink/pull/14685#issuecomment-762256472 ## CI report: * 0a5fff76d69da75391ceb25e470173bae504e1c9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14693: [FLINK-19446][canal][json] canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

flinkbot edited a comment on pull request #14693: URL: https://github.com/apache/flink/pull/14693#issuecomment-762669697 ## CI report: * 58b45f883dfd13a36efbf22b17a487fd28d94d90 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14689: [FLINK-20500][upsert-kafka] Fix temporal join test

flinkbot edited a comment on pull request #14689: URL: https://github.com/apache/flink/pull/14689#issuecomment-762595621 ## CI report: * 7421043232e94c67d4e44020b8a5a319a3e95a09 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14696: [FLINK-21022] [flink-connector-es] add onSuccess handler after bulk process

flinkbot commented on pull request #14696: URL: https://github.com/apache/flink/pull/14696#issuecomment-762754413 ## CI report: * 8bf9de1dc18bce85e63697b063fd75c992e61fbe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267817#comment-17267817 ] Matthias commented on FLINK-21024: -- Interesting finding. Thanks for looking into that,

[jira] [Created] (FLINK-21027) Add isKeyValueImmutable() method to KeyedStateBackend interface

Jark Wu created FLINK-21027: --- Summary: Add isKeyValueImmutable() method to KeyedStateBackend interface Key: FLINK-21027 URL: https://issues.apache.org/jira/browse/FLINK-21027 Project: Flink Issue

[jira] [Commented] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267821#comment-17267821 ] Till Rohrmann commented on FLINK-21008: --- I see, then an alternative solution would

[GitHub] [flink] tillrohrmann commented on a change in pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

tillrohrmann commented on a change in pull request #14692: URL: https://github.com/apache/flink/pull/14692#discussion_r560082524 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -125,6 +121,16 @@ public String getC

[jira] [Created] (FLINK-21028) Streaming application didn't stop properly

Theo Diefenthal created FLINK-21028: --- Summary: Streaming application didn't stop properly Key: FLINK-21028 URL: https://issues.apache.org/jira/browse/FLINK-21028 Project: Flink Issue Type:

[GitHub] [flink] wangyang0918 commented on a change in pull request #14692: [FLINK-20944][k8s] Do not resolve the rest endpoint address when the service exposed type is ClusterIP

wangyang0918 commented on a change in pull request #14692: URL: https://github.com/apache/flink/pull/14692#discussion_r560084849 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -125,6 +121,16 @@ public String getC

[GitHub] [flink] dawidwys commented on a change in pull request #14660: [FLINK-20971][table-api-java] Support calling SQL expressions in Table API

dawidwys commented on a change in pull request #14660: URL: https://github.com/apache/flink/pull/14660#discussion_r560069421 ## File path: docs/dev/table/functions/systemFunctions.md ## @@ -5636,6 +5638,21 @@ STRING.sha2(INT) {% highlight java %} +callSql(STRING)

  1   2   3   4   >