[jira] [Updated] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication

[ https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19723: --- Labels: pull-request-available (was: ) > The retry mechanism of jdbc connector has the risk

[GitHub] [flink] flinkbot commented on pull request #13717: [FLINK-19723][Connector/JDBC] Solve the problem of repeated data submission in the failure retry

flinkbot commented on pull request #13717: URL: https://github.com/apache/flink/pull/13717#issuecomment-713353033 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] flinkbot commented on pull request #13716: [FLINK-19706][table-runtime] Add WARN logs when hive table partition …

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

[GitHub] [flink] flinkbot edited a comment on pull request #13713: [FLINK-19733][python] Make fast_operation and slow_operation produce functions consistent

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

[GitHub] [flink] flinkbot edited a comment on pull request #13715: [FLINK-19747][orc] Move Predicate classes to OrcFilters

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

[GitHub] [flink] shizhengchao opened a new pull request #13717: [Flink 19723][Connector/JDBC] Solve the problem of repeated data submission in the failure retry

shizhengchao opened a new pull request #13717: URL: https://github.com/apache/flink/pull/13717 ## What is the purpose of the change for example, if statement.executeBatch() failur for some reason, but the "statement" was not closed in the retry, there is a risk of data dupli

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

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

[GitHub] [flink] flinkbot edited a comment on pull request #13665: [FLINK-19232][python] Support MapState and MapView in PyFlink.

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

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #13709: [FLINK-19401][checkpointing] Download checkpoints only if needed

Jiayi-Liao commented on a change in pull request #13709: URL: https://github.com/apache/flink/pull/13709#discussion_r509010157 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java ## @@ -143,6 +145,10 @@ public vo

[GitHub] [flink] flinkbot edited a comment on pull request #13523: [FLINK-15981][network] Implement FileRegion way to shuffle file-based blocking partition in network stack

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

[jira] [Updated] (FLINK-19741) InternalTimeServiceManager fails to restore due to corrupt reads if there are other users of raw keyed state streams

[ https://issues.apache.org/jira/browse/FLINK-19741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-19741: Description: h2. *Diagnosis* Currently, when restoring a {{InternalTimeServiceMan

[GitHub] [flink] flinkbot commented on pull request #13716: [FLINK-19706][table-runtime] Add WARN logs when hive table partition …

flinkbot commented on pull request #13716: URL: https://github.com/apache/flink/pull/13716#issuecomment-713346694 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-19748) StateFun's UnboundedFeedbackLogger should call startNewKeyGroup for all assigned key groups

[ https://issues.apache.org/jira/browse/FLINK-19748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-19748: Description: Currently, on commit the {{UnboundedFeedbackLogger}} only calls {{st

[jira] [Created] (FLINK-19748) StateFun's UnboundedFeedbackLogger should call startNewKeyGroup for all assigned key groups

Tzu-Li (Gordon) Tai created FLINK-19748: --- Summary: StateFun's UnboundedFeedbackLogger should call startNewKeyGroup for all assigned key groups Key: FLINK-19748 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Updated] (FLINK-19706) Add WARN logs when hive table partition has existed before commit in `MetastoreCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19706: --- Labels: pull-request-available (was: ) > Add WARN logs when hive table partition has existe

[GitHub] [flink] shouweikun opened a new pull request #13716: [FLINK-19706][table-runtime] Add WARN logs when hive table partition …

shouweikun opened a new pull request #13716: URL: https://github.com/apache/flink/pull/13716 …has existed before commit ## What is the purpose of the change Add WARN logs when the partition has existed before current partition commit in order to make users be aware of

[GitHub] [flink] curcur commented on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-713341581 Thanks @rkhachatryan so much for the great question on how different threads access the same view (in other words, threading model in netty + task thread interaction on view). Th

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-713341581 Thanks @rkhachatryan so much for the great question on how different threads access the same view (in other words, threading model in netty + task thread interaction on vi

[GitHub] [flink] flinkbot commented on pull request #13715: [FLINK-19747][orc] Move Predicate classes to OrcFilters

flinkbot commented on pull request #13715: URL: https://github.com/apache/flink/pull/13715#issuecomment-713341319 ## CI report: * 5ae18d50185461516bf70e842e7d07272a20 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13713: [FLINK-19733][python] Make fast_operation and slow_operation produce functions consistent

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

[GitHub] [flink] TsReaper commented on a change in pull request #13707: [FLINK-19737][table] Introduce TableOperatorWrapperGenerator to translate transformation DAG in a multiple-input node to TableOp

TsReaper commented on a change in pull request #13707: URL: https://github.com/apache/flink/pull/13707#discussion_r508990188 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/TableOperatorWrapper.java ## @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509017125 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/TestingFlinkKubeClient.java ## @@ -103,6 +121,52 @@ public Kuber

[GitHub] [flink] zhijiangW removed a comment on pull request #13523: [FLINK-15981][network] Implement FileRegion way to shuffle file-based blocking partition in network stack

zhijiangW removed a comment on pull request #13523: URL: https://github.com/apache/flink/pull/13523#issuecomment-711483920 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #13665: [FLINK-19232][python] Support MapState and MapView in PyFlink.

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

[GitHub] [flink] flinkbot commented on pull request #13715: [FLINK-19747][orc] Move Predicate classes to OrcFilters

flinkbot commented on pull request #13715: URL: https://github.com/apache/flink/pull/13715#issuecomment-713328329 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-19747) Move Predicate classes to OrcFilters

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

[GitHub] [flink] JingsongLi opened a new pull request #13715: [FLINK-19747][orc] Move Predicate classes to OrcFilters

JingsongLi opened a new pull request #13715: URL: https://github.com/apache/flink/pull/13715 ## What is the purpose of the change `OrcSplitReader` will be a legacy class, it will be removed. ## Verifying this change This change is a trivial rework / code cleanup with

[jira] [Created] (FLINK-19747) Move Predicate classes to OrcFilters

Jingsong Lee created FLINK-19747: Summary: Move Predicate classes to OrcFilters Key: FLINK-19747 URL: https://issues.apache.org/jira/browse/FLINK-19747 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #13690: [FLINK-16595][YARN]support more HDFS nameServices in yarn mode when security enabled. Is…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13680: [FLINK-19553] [ Runtime / Web Frontend] The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to

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

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218121#comment-17218121 ] Dian Fu commented on FLINK-19483: - Fixed in master via 2a9af7f6275166c1671bd495dc092b984

[jira] [Closed] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19483. --- Resolution: Fixed > PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File > exists: '

[GitHub] [flink] dianfu merged pull request #13702: [FLINK-19483][python][e2] Remove conda install zip

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

[GitHub] [flink] flinkbot edited a comment on pull request #13680: [FLINK-19553] [ Runtime / Web Frontend] The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to

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

[GitHub] [flink] flinkbot edited a comment on pull request #13702: [FLINK-19483][python][e2] Remove conda install zip

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508997664 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java ## @@ -0,0 +1,80 @@ +/* +

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508995602 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionService.java ## @@ -0,0 +1,219 @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508995324 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionService.java ## @@ -0,0 +1,219 @@

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508994663 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionService.java ## @@ -0,0 +1,219 @@

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508994167 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -219,6 +230,71 @@ public Kuber

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508993402 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderRetrievalServiceTest.java ## @@ -0,0 +1,89

[GitHub] [flink] flinkbot edited a comment on pull request #13714: [FLINK-19718][hive] HiveTableSourceITCase.testStreamPartitionRead is not stable

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

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,so I'm not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question,So it's not asking for support to debug

[GitHub] [flink] pyscala commented on pull request #13680: [FLINK-19553] [ Runtime / Web Frontend] The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-

pyscala commented on pull request #13680: URL: https://github.com/apache/flink/pull/13680#issuecomment-713305996  @Myasuka Done

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question, So it's not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Description: I know the solution for my following question, So it's not asking for support to debug

[jira] [Updated] (FLINK-19746) Why delete support for "as" function

[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-19746: --- Affects Version/s: 1.11.0 Description: *I know the solution for my following question, So

[jira] [Created] (FLINK-19746) Why delete for

appleyuchi created FLINK-19746: -- Summary: Why delete for Key: FLINK-19746 URL: https://issues.apache.org/jira/browse/FLINK-19746 Project: Flink Issue Type: Bug Reporter: appleyuchi

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508989034 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesHaServices.java ## @@ -0,0 +1,137 @@ +/* + * Lic

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508988440 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -104,6 +106,67 @@ KubernetesWatch wat

[GitHub] [flink] flinkbot commented on pull request #13714: [FLINK-19718][hive] HiveTableSourceITCase.testStreamPartitionRead is not stable

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508986718 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/KubeClientFactory.java ## @@ -71,7 +73,12 @@ public static Flink

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508986296 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionService.java ## @@ -0,0 +1,219 @@

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508985458 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java ## @@ -0,0 +1,227 @@ +/* + * Li

[GitHub] [flink] flinkbot commented on pull request #13714: [FLINK-19718][hive] HiveTableSourceITCase.testStreamPartitionRead is not stable

flinkbot commented on pull request #13714: URL: https://github.com/apache/flink/pull/13714#issuecomment-713290085 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-19706) Add WARN logs when hive table partition has existed before commit in `MetastoreCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19706: Summary: Add WARN logs when hive table partition has existed before commit in `MetastoreCo

[jira] [Updated] (FLINK-19718) HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure

[ https://issues.apache.org/jira/browse/FLINK-19718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19718: --- Labels: pull-request-available (was: ) > HiveTableSourceITCase.testStreamPartitionRead is n

[GitHub] [flink] JingsongLi opened a new pull request #13714: [FLINK-19718][hive] HiveTableSourceITCase.testStreamPartitionRead is not stable

JingsongLi opened a new pull request #13714: URL: https://github.com/apache/flink/pull/13714 ## What is the purpose of the change Here are some instances: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=7845&view=logs&j=fc5181b0-e452-5c8f-68de-10

[jira] [Updated] (FLINK-19745) Supplement micro-benchmark for bounded blocking partition in remote channel case

[ https://issues.apache.org/jira/browse/FLINK-19745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19745: --- Labels: pull-request-available (was: ) > Supplement micro-benchmark for bounded blocking pa

[GitHub] [flink-benchmarks] zhijiangW opened a new pull request #4: [FLINK-19745][network] Supplement micro-benchmark for bounded blocking partition in remote channel case

zhijiangW opened a new pull request #4: URL: https://github.com/apache/flink-benchmarks/pull/4 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Updated] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19706: Description: dfHi all,       Recently we have been devoted to using Hive Streaming Writin

[jira] [Commented] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218094#comment-17218094 ] Jingsong Lee commented on FLINK-19706: -- If we do strict check, I recommend late eve

[jira] [Updated] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-19706: Description: Hi all,       Recently we have been devoted to using Hive Streaming Writing

[jira] [Assigned] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19706: Assignee: Lsw_aka_laplace > Introduce `Repeated Partition Commit Check` in > `org.apache

[jira] [Created] (FLINK-19745) Supplement micro-benchmark for bounded blocking partition in remote channel case

Zhijiang created FLINK-19745: Summary: Supplement micro-benchmark for bounded blocking partition in remote channel case Key: FLINK-19745 URL: https://issues.apache.org/jira/browse/FLINK-19745 Project: Fli

[GitHub] [flink] leonardBang commented on a change in pull request #13708: [FLINK-19734][table-planner-blink] Replace 'collection' connector by 'values' connector for temporal join plan tests

leonardBang commented on a change in pull request #13708: URL: https://github.com/apache/flink/pull/13708#discussion_r508971859 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/TemporalJoinTest.xml ## @@

[jira] [Commented] (FLINK-19740) Error in to_pandas for table containing event time: class java.time.LocalDateTime cannot be cast to class java.sql.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-19740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218090#comment-17218090 ] Nicholas Jiang commented on FLINK-19740: cc [~dian.fu] > Error in to_pandas for

[jira] [Created] (FLINK-19744) Support Nebula Graph Connector

darion yaphet created FLINK-19744: - Summary: Support Nebula Graph Connector Key: FLINK-19744 URL: https://issues.apache.org/jira/browse/FLINK-19744 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on pull request #13713: [FLINK-19733][python] Make fast_operation and slow_operation produce functions consistent

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

[GitHub] [flink] flinkbot edited a comment on pull request #13457: [FLINK-8357] Use rolling logs as default

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

[GitHub] [flink] danny0405 commented on a change in pull request #13331: [FLINK-19079][table-runtime] Import rowtime deduplicate operator

danny0405 commented on a change in pull request #13331: URL: https://github.com/apache/flink/pull/13331#discussion_r508472527 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecDeduplicate.scala ##

[jira] [Commented] (FLINK-19692) Can't restore feedback channel from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218077#comment-17218077 ] Antti Kaikkonen commented on FLINK-19692: - Thanks for investigating and identify

[jira] [Commented] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218074#comment-17218074 ] Leonard Xu commented on FLINK-18570: The same reason with my previous investigation,

[GitHub] [flink] flinkbot commented on pull request #13713: [FLINK-19733][python] Make fast_operation and slow_operation produce functions consistent

flinkbot commented on pull request #13713: URL: https://github.com/apache/flink/pull/13713#issuecomment-713269298 ## CI report: * 75ac685135eac8dde548c3d04d96502964d68cf2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

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

[jira] [Commented] (FLINK-19718) HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure

[ https://issues.apache.org/jira/browse/FLINK-19718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218070#comment-17218070 ] Jingsong Lee commented on FLINK-19718: -- Thanks for reporting this issue, I think we

[jira] [Assigned] (FLINK-19718) HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure

[ https://issues.apache.org/jira/browse/FLINK-19718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19718: Assignee: Jingsong Lee > HiveTableSourceITCase.testStreamPartitionRead is not stable on A

[GitHub] [flink] flinkbot commented on pull request #13713: [FLINK-19733][python] Make fast_operation and slow_operation produce functions consistent

flinkbot commented on pull request #13713: URL: https://github.com/apache/flink/pull/13713#issuecomment-713264885 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-19733) Make fast_operation and slow_operation produce functions consistent

[ https://issues.apache.org/jira/browse/FLINK-19733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19733: --- Labels: pull-request-available (was: ) > Make fast_operation and slow_operation produce fun

[GitHub] [flink] HuangXingBo opened a new pull request #13713: [FLINK-19733][python] Make fast_operation and slow_operation produce functions consistent

HuangXingBo opened a new pull request #13713: URL: https://github.com/apache/flink/pull/13713 ## What is the purpose of the change *This pull request will make fast_operation and slow_operation produce functions consistent* ## Brief change log - *make the generate

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

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

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

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

[GitHub] [flink] kylemeow commented on a change in pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resoluti

kylemeow commented on a change in pull request #13706: URL: https://github.com/apache/flink/pull/13706#discussion_r508957417 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerLocation.java ## @@ -150,28 +166,48 @@ public String addressSt

[GitHub] [flink] kylemeow commented on a change in pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resoluti

kylemeow commented on a change in pull request #13706: URL: https://github.com/apache/flink/pull/13706#discussion_r508956726 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -606,7 +608,12 @@ private void releaseEmptyTaskManager

[GitHub] [flink] kylemeow commented on a change in pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resoluti

kylemeow commented on a change in pull request #13706: URL: https://github.com/apache/flink/pull/13706#discussion_r508956321 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -606,7 +608,12 @@ private void releaseEmptyTaskManager

[GitHub] [flink] kylemeow commented on a change in pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resoluti

kylemeow commented on a change in pull request #13706: URL: https://github.com/apache/flink/pull/13706#discussion_r508955384 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -308,6 +308,19 @@ .defaultVal

[GitHub] [flink] pyscala commented on pull request #13680: [FLINK-19553] [ Runtime / Web Frontend] The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-

pyscala commented on pull request #13680: URL: https://github.com/apache/flink/pull/13680#issuecomment-713257351 > Thanks for your update, I think we should also include date information for trigger timestamp, please update related code and offer the updated UI with your new changes.

[jira] [Closed] (FLINK-19605) Implement cumulative windowing for window aggregate operator

[ https://issues.apache.org/jira/browse/FLINK-19605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19605. --- Resolution: Fixed Implemented in master: 9423cf1cf2e7a96d5017e641e52d7acaabf39333 > Implement cumulative wi

[GitHub] [flink] wuchong merged pull request #13650: [FLINK-19605][table-runtime-blink] Implement cumulative windowing for window aggregate operator

wuchong merged pull request #13650: URL: https://github.com/apache/flink/pull/13650 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #13650: [FLINK-19605][table-runtime-blink] Implement cumulative windowing for window aggregate operator

wuchong commented on pull request #13650: URL: https://github.com/apache/flink/pull/13650#issuecomment-713255813 The failed Azure is the unstable e2e tests. This change shouldn't affect e2e part. Merging... This is a

[GitHub] [flink] dianfu commented on a change in pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

dianfu commented on a change in pull request #12902: URL: https://github.com/apache/flink/pull/12902#discussion_r508938695 ## File path: flink-python/pyflink/table/table_result.py ## @@ -151,6 +156,45 @@ def get_result_kind(self): """ return ResultKind._from_

  1   2   3   4   5   6   >