[GitHub] [flink] xintongsong commented on pull request #13719: [FLINK-19689] Fix TaskExecutorProcessSpecContainerResourcePriorityAdapterTest.

2020-10-21 Thread GitBox
xintongsong commented on pull request #13719: URL: https://github.com/apache/flink/pull/13719#issuecomment-713611707 Thanks for the review, @tillrohrmann. Merging this since the AZP has given green light. This is an

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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13708: URL: https://github.com/apache/flink/pull/13708#issuecomment-712987715 ## CI report: * 7790ddd65711253a6e55e9908edd541db30b4b70 Azure:

[GitHub] [flink] flinkbot commented on pull request #13730: [FLINK-19552][coordination] Consider only available input location preferences for slot profile in pipelined region scheduling

2020-10-21 Thread GitBox
flinkbot commented on pull request #13730: URL: https://github.com/apache/flink/pull/13730#issuecomment-713612417 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] xintongsong closed pull request #13719: [FLINK-19689] Fix TaskExecutorProcessSpecContainerResourcePriorityAdapterTest.

2020-10-21 Thread GitBox
xintongsong closed pull request #13719: URL: https://github.com/apache/flink/pull/13719 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

[GitHub] [flink] flinkbot edited a comment on pull request #13709: [FLINK-19401][checkpointing] Download checkpoints only if needed

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13709: URL: https://github.com/apache/flink/pull/13709#issuecomment-712988228 ## CI report: * Unknown: [CANCELED](TBD) * 6af74f96aa6de790a7d28afd6d438ed8959da4be Azure:

[GitHub] [flink] azagrebin commented on pull request #13730: [FLINK-19552][coordination] Consider only available input location preferences for slot profile in pipelined region scheduling

2020-10-21 Thread GitBox
azagrebin commented on pull request #13730: URL: https://github.com/apache/flink/pull/13730#issuecomment-713615180 I also working on an integration test. `PipelinedRegionSchedulingConcurrentFailureTest`, suggested in #13628, reproduces the exact original problem which is a combination

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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13713: URL: https://github.com/apache/flink/pull/13713#issuecomment-713269298 ## CI report: * 4017f4b8968a54313a85109a71cbda072265892b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13726: [BP-1.11][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13726: URL: https://github.com/apache/flink/pull/13726#issuecomment-713567666 ## CI report: * c673d6c2530a3484e2a315301d0eee7154a3a5d9 Azure:

[GitHub] [flink] zentol commented on a change in pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

2020-10-21 Thread GitBox
zentol commented on a change in pull request #13722: URL: https://github.com/apache/flink/pull/13722#discussion_r509342239 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java ## @@ -0,0 +1,461 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13725: [FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13725: URL: https://github.com/apache/flink/pull/13725#issuecomment-713560830 ## CI report: * a606f618ea3fb7bf179657a060c47ee32b55e514 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13727: [BP-1.10][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13727: URL: https://github.com/apache/flink/pull/13727#issuecomment-713572668 ## CI report: * c2ae5ba37a69ad1f40f585421d38edb30d40c0fa Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/191431633) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #13724: [FLINK-19581][orc] Introduce Orc ColumnarRow File source bulk Format

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13724: URL: https://github.com/apache/flink/pull/13724#issuecomment-713528928 ## CI report: * bf777e65a831b6c6ee8f1c22ae8f6a232ee87deb UNKNOWN * f619476bce3df1f3cff0b0579a0888a98d5312cb Azure:

[GitHub] [flink] flinkbot commented on pull request #13728: [FLINK-19657][yarn][tests] Whitelist common error in logs

2020-10-21 Thread GitBox
flinkbot commented on pull request #13728: URL: https://github.com/apache/flink/pull/13728#issuecomment-713625914 ## CI report: * f1dbe28be83f5992c4b259a8edcb4b8855d9e310 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19395) Replace SqlConversionException with either TableException or ValidationException

2020-10-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218330#comment-17218330 ] Timo Walther commented on FLINK-19395: -- Sorry, [~ShawnHx] sometimes it takes a while until PR are

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

2020-10-21 Thread GitBox
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

[GitHub] [flink] maxmzkr commented on a change in pull request #13725: [FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
maxmzkr commented on a change in pull request #13725: URL: https://github.com/apache/flink/pull/13725#discussion_r509370138 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java ## @@ -203,6 +207,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13634: [FLINK-19629]Fix NullPointException in avro format as null value on MAP type

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13634: URL: https://github.com/apache/flink/pull/13634#issuecomment-708376086 ## CI report: * d719acbd86db08cb920aac511e4ef0e82720469f Azure:

[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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * 12f743654fc694b682b29faf2b82311a24914f73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13699: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13699: URL: https://github.com/apache/flink/pull/13699#issuecomment-712700391 ## CI report: * 30c315c3eed0e0f32ceb06d3f7c64375c54c5014 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13723: [FlINK-19688][network] Don't cache InterruptedExceptions in PartitionRequestClientFactory

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13723: URL: https://github.com/apache/flink/pull/13723#issuecomment-713526541 ## CI report: * 18772dddf0714c8ee47354a40d70f70ab9ac6387 Azure:

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

2020-10-21 Thread GitBox
curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r509191005 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,105 @@ +/* +

[GitHub] [flink] zentol commented on pull request #13514: [FLINK-19468][DataStream API] Metrics return empty when data stream / operator name contains "+"

2020-10-21 Thread GitBox
zentol commented on pull request #13514: URL: https://github.com/apache/flink/pull/13514#issuecomment-713499526 I'm not truly suggesting to _remove_ the existing replacements, because as you said that may break existing setups. The same however could be said about replacing more

[jira] [Created] (FLINK-19752) Convert BigDicimal TypeInformation to DataTypes error

2020-10-21 Thread AT-Fieldless (Jira)
AT-Fieldless created FLINK-19752: Summary: Convert BigDicimal TypeInformation to DataTypes error Key: FLINK-19752 URL: https://issues.apache.org/jira/browse/FLINK-19752 Project: Flink Issue

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

2020-10-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19747. Resolution: Fixed master: 091a2ae2e172cd80a5a7638a11329c7077573d4e > Move Predicate classes to

[GitHub] [flink] flinkbot edited a comment on pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13614: URL: https://github.com/apache/flink/pull/13614#issuecomment-707710438 ## CI report: * f51a6098947a0967f0dadc32903bf1288fb48941 UNKNOWN * a70ae897b37437579d8aab2ba3a744553a08feea Azure:

[GitHub] [flink] flinkbot commented on pull request #13723: [FlINK-19688][network] Don't cache InterruptedExceptions in PartitionRequestClientFactory

2020-10-21 Thread GitBox
flinkbot commented on pull request #13723: URL: https://github.com/apache/flink/pull/13723#issuecomment-713508588 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13721: URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063 ## CI report: * a62fac38c52dfc3c949dcd301d7f8f33b1ef0a3a Azure:

[GitHub] [flink] flinkbot commented on pull request #13724: [FLINK-19581][orc] Introduce Orc ColumnarRow File source bulk Format

2020-10-21 Thread GitBox
flinkbot commented on pull request #13724: URL: https://github.com/apache/flink/pull/13724#issuecomment-713514997 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] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

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

[GitHub] [flink] flinkbot edited a comment on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 268d260399e598943726839a254f004a61f5ba66 UNKNOWN * 5e6777513ec8c76457561937786fcba5a4d1d5af UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 7311b0d12d19a645391ea0359a9aa6318806363b UNKNOWN * 79714f02f700aebe4a65dff017deba6dc9d911d9 Azure:

[jira] [Updated] (FLINK-18415) Support TableResult#collect in the Python Table API to align with the Java Table API

2020-10-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18415: Fix Version/s: 1.12.0 > Support TableResult#collect in the Python Table API to align with the Java >

[jira] [Closed] (FLINK-18415) Support TableResult#collect in the Python Table API to align with the Java Table API

2020-10-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18415. --- Resolution: Fixed Merged to master via 2e5ce09d7450208355c57151a487f5e05cf1520f > Support

[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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * Unknown: [CANCELED](TBD) * 12f743654fc694b682b29faf2b82311a24914f73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13721: URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063 ## CI report: * a62fac38c52dfc3c949dcd301d7f8f33b1ef0a3a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13722: URL: https://github.com/apache/flink/pull/13722#issuecomment-713509789 ## CI report: * 6e0d0cc61b72e86cdbca8f29684148e364a11240 Azure:

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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509231284 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -0,0 +1,209 @@ +/* + * Licensed

[GitHub] [flink] flinkbot commented on pull request #13724: [FLINK-19581][orc] Introduce Orc ColumnarRow File source bulk Format

2020-10-21 Thread GitBox
flinkbot commented on pull request #13724: URL: https://github.com/apache/flink/pull/13724#issuecomment-713528928 ## CI report: * bf777e65a831b6c6ee8f1c22ae8f6a232ee87deb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19629) Avro format cause NullPointException，as null value in MAP type's value type

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218265#comment-17218265 ] Jark Wu commented on FLINK-19629: - Thanks for the reminder. Will review it. > Avro format cause

[jira] [Commented] (FLINK-19557) Issue retrieving leader after zookeeper session reconnect

2020-10-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218264#comment-17218264 ] Till Rohrmann commented on FLINK-19557: --- The stale leader address should get resolved as soon as a

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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509238124 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -0,0 +1,209 @@ +/* + * Licensed

[jira] [Commented] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

2020-10-21 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218266#comment-17218266 ] Qingsheng Ren commented on FLINK-19750: --- Sure [~jark] , I'll create a PR about this. Thank you~ >

[GitHub] [flink] flinkbot commented on pull request #13727: [BP-1.10][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
flinkbot commented on pull request #13727: URL: https://github.com/apache/flink/pull/13727#issuecomment-713534943 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Assigned] (FLINK-19657) YARNSessionCapacitySchedulerITCase.checkForProhibitedLogContents: netty failed with java.io.IOException: Broken pipe

2020-10-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19657: -- Assignee: Robert Metzger >

[jira] [Updated] (FLINK-19751) Fix document error for GroupBy Window Aggregation

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19751: Summary: Fix document error for GroupBy Window Aggregation (was: document error for GroupBy Window

[jira] [Updated] (FLINK-19751) Fix document error for GroupBy Window Aggregation

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19751: Component/s: Table SQL / API Documentation > Fix document error for GroupBy Window

[jira] [Commented] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

2020-10-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218273#comment-17218273 ] Till Rohrmann commented on FLINK-19699: --- I'd suggest to close this issue as cannot reproduce until

[jira] [Closed] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

2020-10-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19699. -- Resolution: Cannot Reproduce Yes, that's a good idea. Closing ticket for now ... >

[GitHub] [flink] flinkbot commented on pull request #13727: [BP-1.10][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
flinkbot commented on pull request #13727: URL: https://github.com/apache/flink/pull/13727#issuecomment-713572668 ## CI report: * c2ae5ba37a69ad1f40f585421d38edb30d40c0fa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509281041 ## 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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509289570 ## 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

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

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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509296824 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionServiceTest.java ## @@ -0,0

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

2020-10-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-19718: -- Observe two days first > HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure >

[GitHub] [flink] flinkbot edited a comment on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 268d260399e598943726839a254f004a61f5ba66 UNKNOWN * 5e6777513ec8c76457561937786fcba5a4d1d5af UNKNOWN *

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

2020-10-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19718. Resolution: Fixed > HiveTableSourceITCase.testStreamPartitionRead is not stable on Azure >

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

2020-10-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218245#comment-17218245 ] Jingsong Lee commented on FLINK-19718: -- master: 700f07aa449d7bf7c7f68ed70b8d33779ae25b69 Feel free

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

2020-10-21 Thread GitBox
godfreyhe commented on pull request #13707: URL: https://github.com/apache/flink/pull/13707#issuecomment-713505230 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

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

2020-10-21 Thread GitBox
JingsongLi merged pull request #13715: URL: https://github.com/apache/flink/pull/13715 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot commented on pull request #13725: [FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
flinkbot commented on pull request #13725: URL: https://github.com/apache/flink/pull/13725#issuecomment-713531780 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-19749) Improve documentation for "Column Operations" in Table API page

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19749: Summary: Improve documentation for "Column Operations" in Table API page (was: document error) >

[jira] [Updated] (FLINK-19749) Improve documentation for "Column Operations" in Table API page

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19749: Component/s: Table SQL / API Documentation > Improve documentation for "Column

[jira] [Commented] (FLINK-19749) document error

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218260#comment-17218260 ] Jark Wu commented on FLINK-19749: - I would suggest "if add columns name is the same" => "if the added

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

2020-10-21 Thread GitBox
wuchong commented on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-713539091 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

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

2020-10-21 Thread GitBox
QingdongZeng3 commented on pull request #13690: URL: https://github.com/apache/flink/pull/13690#issuecomment-713547160 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 268d260399e598943726839a254f004a61f5ba66 UNKNOWN * 5e6777513ec8c76457561937786fcba5a4d1d5af UNKNOWN *

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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13690: URL: https://github.com/apache/flink/pull/13690#issuecomment-712304240 ## CI report: * Unknown: [CANCELED](TBD) * 563501f776b532c88a7e3a5d3b180cb76bdf094c UNKNOWN Bot commands The @flinkbot bot supports the

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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13717: URL: https://github.com/apache/flink/pull/13717#issuecomment-713367394 ## CI report: * 52a481ff6c475c882922a7f4095723af7950cf5c UNKNOWN * 0b43b529385f617abdf97df7a8c6922a9c68fba9 Azure:

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

2020-10-21 Thread GitBox
tillrohrmann commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509258549 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -0,0 +1,209 @@ +/* + * Licensed

[GitHub] [flink] wuchong commented on a change in pull request #13634: [FLINK-19629]Fix NullPointException in avro format as null value on MAP type

2020-10-21 Thread GitBox
wuchong commented on a change in pull request #13634: URL: https://github.com/apache/flink/pull/13634#discussion_r509264169 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java ## @@ -198,4 +198,38 @@

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

2020-10-21 Thread GitBox
rkhachatryan commented on a change in pull request #13709: URL: https://github.com/apache/flink/pull/13709#discussion_r509267021 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreTest.java ## @@ -58,6 +66,54 @@

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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509276361 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java ## @@ -249,4 +265,69 @@ public

[GitHub] [flink] godfreyhe commented on pull request #13692: [FLINK-19624][table-planner-blink] Update deadlock break-up algorithm to cover more cases

2020-10-21 Thread GitBox
godfreyhe commented on pull request #13692: URL: https://github.com/apache/flink/pull/13692#issuecomment-713576815 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] shizhengchao commented on a change in pull request #13634: [FLINK-19629]Fix NullPointException in avro format as null value on MAP type

2020-10-21 Thread GitBox
shizhengchao commented on a change in pull request #13634: URL: https://github.com/apache/flink/pull/13634#discussion_r509294398 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java ## @@ -198,4 +198,38

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

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

[GitHub] [flink-docker] zentol merged pull request #11: [FLINK-17167] Add HistoryServer option

2020-10-21 Thread GitBox
zentol merged pull request #11: URL: https://github.com/apache/flink-docker/pull/11 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

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

2020-10-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-19745. Resolution: Fixed Merged in master: 333eb8ebf116756911dc7e1da59489b5cd9ea475 > Supplement

[jira] [Closed] (FLINK-17167) Extend entry point script and docs with history server mode

2020-10-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17167. Resolution: Fixed dev-master: f343c0d80280c7f9c64f7b830e235562697ec8d6 > Extend entry

[jira] [Updated] (FLINK-17167) Add Docker History Server support

2020-10-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17167: - Summary: Add Docker History Server support (was: Extend entry point script and docs

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

2020-10-21 Thread GitBox
zhijiangW merged 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 above to

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

2020-10-21 Thread GitBox
JingsongLi merged pull request #13714: URL: https://github.com/apache/flink/pull/13714 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13523: URL: https://github.com/apache/flink/pull/13523#issuecomment-701325670 ## CI report: * b5bcd004fd5105229faaa61c205ee7c596298f8b Azure:

[GitHub] [flink] flinkbot commented on pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

2020-10-21 Thread GitBox
flinkbot commented on pull request #13722: URL: https://github.com/apache/flink/pull/13722#issuecomment-713509789 ## CI report: * 6e0d0cc61b72e86cdbca8f29684148e364a11240 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-10-21 Thread GitBox
AHeise commented on a change in pull request #13709: URL: https://github.com/apache/flink/pull/13709#discussion_r509211683 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java ## @@ -143,6 +145,10 @@ public void

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

2020-10-21 Thread GitBox
dianfu closed pull request #12902: URL: https://github.com/apache/flink/pull/12902 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] rmetzger commented on pull request #13723: [FlINK-19688][network] Don't cache InterruptedExceptions in PartitionRequestClientFactory

2020-10-21 Thread GitBox
rmetzger commented on pull request #13723: URL: https://github.com/apache/flink/pull/13723#issuecomment-713525013 I have verified that the change is fixing the problem I initially reported with my test setup. I'll leave a full review to somebody more familiar with the network stack.

[GitHub] [flink] flinkbot edited a comment on pull request #13707: [FLINK-19737][table] Introduce TableOperatorWrapperGenerator to translate transformation DAG in a multiple-input node to TableOperato

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13707: URL: https://github.com/apache/flink/pull/13707#issuecomment-712937023 ## CI report: * f3f1c3c2277c20f9be0f6b2e490e5fa74807e9da UNKNOWN * Unknown: [CANCELED](TBD) * 022b84ab6402143d4660e2f2348ea85e08d6649d Azure:

[jira] [Commented] (FLINK-19557) Issue retrieving leader after zookeeper session reconnect

2020-10-21 Thread Max Mizikar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218257#comment-17218257 ] Max Mizikar commented on FLINK-19557: - In our fork, we went with the second approach mostly because

[GitHub] [flink] tillrohrmann opened a new pull request #13725: [FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
tillrohrmann opened a new pull request #13725: URL: https://github.com/apache/flink/pull/13725 ## What is the purpose of the change We have to trigger the LeaderRetrievalListener notification upon reconnecting to ZooKeeper because the NodeCache might not trigger the nodeChanged

[jira] [Updated] (FLINK-19557) Issue retrieving leader after zookeeper session reconnect

2020-10-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19557: --- Labels: pull-request-available (was: ) > Issue retrieving leader after zookeeper session

[GitHub] [flink] tillrohrmann opened a new pull request #13726: [BP-1.11][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

2020-10-21 Thread GitBox
tillrohrmann opened a new pull request #13726: URL: https://github.com/apache/flink/pull/13726 Backport of #13725 to `release-1.11`. This is an automated message from the Apache Git Service. To respond to the message, please

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

2020-10-21 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509240356 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -0,0 +1,209 @@ +/* + * Licensed

[jira] [Assigned] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

2020-10-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19750: --- Assignee: Qingsheng Ren > Deserializer is not opened in Kafka consumer when restoring from state >

[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

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * cadf9a2a13d3113395f199431881fff216b9a50a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13723: [FlINK-19688][network] Don't cache InterruptedExceptions in PartitionRequestClientFactory

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13723: URL: https://github.com/apache/flink/pull/13723#issuecomment-713526541 ## CI report: * 18772dddf0714c8ee47354a40d70f70ab9ac6387 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13724: [FLINK-19581][orc] Introduce Orc ColumnarRow File source bulk Format

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13724: URL: https://github.com/apache/flink/pull/13724#issuecomment-713528928 ## CI report: * bf777e65a831b6c6ee8f1c22ae8f6a232ee87deb UNKNOWN * f619476bce3df1f3cff0b0579a0888a98d5312cb UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #13721: [FLINK-19694][table] Support Upsert ChangelogMode for ScanTableSource

2020-10-21 Thread GitBox
flinkbot edited a comment on pull request #13721: URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063 ## CI report: * aa2f9d0e9038b1b1423cffedb68eb71123b1ae46 Azure:

[jira] [Updated] (FLINK-19657) YARNSessionCapacitySchedulerITCase.checkForProhibitedLogContents: netty failed with java.io.IOException: Broken pipe

2020-10-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19657: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] rmetzger opened a new pull request #13728: [FLINK-19657][yarn][tests] Whitelist common error in logs

2020-10-21 Thread GitBox
rmetzger opened a new pull request #13728: URL: https://github.com/apache/flink/pull/13728 ## What is the purpose of the change Whitelist a common error message, which can occur if the JobManager is shutting down faster than the TaskManager on YARN. See FLINK-19657 for a

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

2020-10-21 Thread GitBox
rkhachatryan commented on a change in pull request #13709: URL: https://github.com/apache/flink/pull/13709#discussion_r509265695 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java ## @@ -143,6 +145,10 @@ public

<    1   2   3   4   5   6   >