[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * e081fecba324a0e35017f4b89cc0499c9112a768 Azure:

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

2020-10-22 Thread GitBox
QingdongZeng3 commented on pull request #13690: URL: https://github.com/apache/flink/pull/13690#issuecomment-714257949 Hi Robert, I have pass the CI ，would you help to review my code？Thanks! This is an automated message

[GitHub] [flink] gaoyunhaii opened a new pull request #13740: [FLINK-19758][filesystem] Implement a new unified file sink based on the new sink API

2020-10-22 Thread GitBox
gaoyunhaii opened a new pull request #13740: URL: https://github.com/apache/flink/pull/13740 ## What is the purpose of the change This pull requests implementations a new File sink based on the new sink API. ## Brief change log

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

2020-10-22 Thread GitBox
QingdongZeng3 edited a comment on pull request #13690: URL: https://github.com/apache/flink/pull/13690#issuecomment-714257949 Hi Robert, I have pass the CI ，would you help to review my code？Thanks! @rmetzger This is

[jira] [Updated] (FLINK-19758) Implement a new unified File Sink based on the new Sink API

2020-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19758: --- Labels: pull-request-available (was: ) > Implement a new unified File Sink based on the

[GitHub] [flink] gaoyunhaii commented on pull request #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

2020-10-22 Thread GitBox
gaoyunhaii commented on pull request #11326: URL: https://github.com/apache/flink/pull/11326#issuecomment-714271222 Very thanks @aljoscha ! I'll close this PR. This is an automated message from the Apache Git Service. To

[GitHub] [flink] gaoyunhaii closed pull request #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

2020-10-22 Thread GitBox
gaoyunhaii closed pull request #11326: URL: https://github.com/apache/flink/pull/11326 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] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-22 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577 > * Visilibity in normal case: none of the felds written in `releaseView` are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2` can see some

[jira] [Updated] (FLINK-19626) Introduce multi-input operator construction algorithm

2020-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19626: --- Labels: pull-request-available (was: ) > Introduce multi-input operator construction

[GitHub] [flink] TsReaper opened a new pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-22 Thread GitBox
TsReaper opened a new pull request #13742: URL: https://github.com/apache/flink/pull/13742 ## What is the purpose of the change As multiple input exec nodes have been introduced, we're going to construct multiple input operators by a new construction algorithm. This PR introduces

[GitHub] [flink] flinkbot edited a comment on pull request #13703: [FLINK-19696] Add runtime batch committer operators for the new sink API

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13703: URL: https://github.com/apache/flink/pull/13703#issuecomment-712821004 ## CI report: * 5166271f74497afddca3a7f350b8191e2a843298 Azure:

[jira] [Closed] (FLINK-16218) Chinese character is garbled when reading from MySQL using JDBC source

2020-10-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16218. --- Fix Version/s: (was: 1.11.3) (was: 1.10.3) (was: 1.12.0)

[jira] [Commented] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster

2020-10-22 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218839#comment-17218839 ] Till Rohrmann commented on FLINK-19761: --- Thanks for creating this issue [~xuannan]. How will this

[jira] [Assigned] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time"

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19136: -- Assignee: Robert Metzger > MetricsAvailabilityITCase.testReporter failed with "Could

[GitHub] [flink] AHeise merged pull request #13733: (1.10 backport) [FLINK-19401][checkpointing] Download checkpoints only if needed

2020-10-22 Thread GitBox
AHeise merged pull request #13733: URL: https://github.com/apache/flink/pull/13733 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] [Created] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog

2020-10-22 Thread jackylau (Jira)
jackylau created FLINK-19765: Summary: flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog Key: FLINK-19765 URL: https://issues.apache.org/jira/browse/FLINK-19765

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r509983937 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortBuffer.java ## @@ -0,0 +1,96 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-19738) Remove the `getCommitter` from the `AbstractStreamingCommitterOperator`

2020-10-22 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-19738. - Fix Version/s: 1.12.0 Resolution: Resolved > Remove the `getCommitter` from the

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

2020-10-22 Thread GitBox
gm7y8 edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-714289878 @XComp You are welcome! I have also verified fix with Word Count job

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

2020-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509942532 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionService.java ## @@ -0,0 +1,219 @@

[jira] [Closed] (FLINK-14406) Add metric for managed memory

2020-10-22 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-14406. --- Fix Version/s: 1.12.0 Release Note: New metrics are available to monitor managed

[GitHub] [flink] flinkbot commented on pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-22 Thread GitBox
flinkbot commented on pull request #13742: URL: https://github.com/apache/flink/pull/13742#issuecomment-714296461 ## CI report: * 37cba38abc15a3ee7d1193644be564c0c75ac4c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13741: [FLINK-19680][checkpointing] Announce timeoutable CheckpointBarriers

2020-10-22 Thread GitBox
flinkbot commented on pull request #13741: URL: https://github.com/apache/flink/pull/13741#issuecomment-714295796 ## CI report: * 8a68242a90fd180fcd0b4b4c60b5e1e49136c00f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-10-22 Thread GitBox
vthinkxie commented on a change in pull request #13458: URL: https://github.com/apache/flink/pull/13458#discussion_r50994 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.html ## @@ -21,6 +21,8 @@

[jira] [Created] (FLINK-19762) Selecting Job-ID in web UI covers more than the ID

2020-10-22 Thread Matthias (Jira)
Matthias created FLINK-19762: Summary: Selecting Job-ID in web UI covers more than the ID Key: FLINK-19762 URL: https://issues.apache.org/jira/browse/FLINK-19762 Project: Flink Issue Type: Bug

[GitHub] [flink] shizhengchao opened a new pull request #13743: [FLINK-19629][Formats]Fix the NPE of avro format, when there is a nul…

2020-10-22 Thread GitBox
shizhengchao opened a new pull request #13743: URL: https://github.com/apache/flink/pull/13743 …l entry to the map ## What is the purpose of the change This pull request fixs the NPE in avro format when there is a null entry to the map. ## Brief change log

[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-22 Thread GitBox
flinkbot edited a comment on pull request #13726: URL: https://github.com/apache/flink/pull/13726#issuecomment-713567666 ## CI report: * c673d6c2530a3484e2a315301d0eee7154a3a5d9 Azure:

[jira] [Commented] (FLINK-19688) Flink batch job fails because of InterruptedExceptions from network stack

2020-10-22 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218855#comment-17218855 ] Roman Khachatryan commented on FLINK-19688: --- https://github.com/apache/flink/pull/13723 >

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

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

[jira] [Closed] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources / emitted by sinks

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-7286. - Fix Version/s: (was: 1.12.0) Resolution: Duplicate Closed as duplicate of

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13736: URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394 ## CI report: * 259c893dcb4b5692df54cfe7739f95d9e34096e6 Azure:

[jira] [Closed] (FLINK-19759) DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable

2020-10-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19759. --- Fix Version/s: (was: 1.12.0) Resolution: Fixed Just noticed that it's already fixed in

[jira] [Created] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

2020-10-22 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-19760: - Summary: Make the `GlobalCommitter` a standalone interface that does not extend the `Committer` Key: FLINK-19760 URL: https://issues.apache.org/jira/browse/FLINK-19760

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

2020-10-22 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577 > * Visilibity in normal case: none of the felds written in `releaseView` are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2` can see some

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

2020-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #13725: URL: https://github.com/apache/flink/pull/13725#discussion_r509929799 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java ## @@ -170,7 +174,6 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13740: [FLINK-19758][filesystem] Implement a new unified file sink based on the new sink API

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13740: URL: https://github.com/apache/flink/pull/13740#issuecomment-714266782 ## CI report: * af69ad89405936040b55d54acb0ef18e6141e5ad Azure:

[GitHub] [flink] XComp commented on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-22 Thread GitBox
XComp commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-714288781 Thanks, @gm7y8 . It looks good from my side. @vthinkxie: Could you have a brief look over the frontend code diff? I guess there have been some changes after your last review.

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

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

[GitHub] [flink] flinkbot commented on pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-22 Thread GitBox
flinkbot commented on pull request #13742: URL: https://github.com/apache/flink/pull/13742#issuecomment-714288929 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-17159) ES6 ElasticsearchSinkITCase unstable

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

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

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

[GitHub] [flink] flinkbot commented on pull request #13743: [FLINK-19629][Formats]Fix the NPE of avro format, when there is a nul…

2020-10-22 Thread GitBox
flinkbot commented on pull request #13743: URL: https://github.com/apache/flink/pull/13743#issuecomment-714308277 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] shizhengchao commented on pull request #13743: [FLINK-19629][Formats]Fix the NPE of avro format, when there is a nul…

2020-10-22 Thread GitBox
shizhengchao commented on pull request #13743: URL: https://github.com/apache/flink/pull/13743#issuecomment-714308295 Hi @wuchong , this is the hotfix in release-1.11, could you help me reivew this :) This is an automated

[jira] [Commented] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

2020-10-22 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218843#comment-17218843 ] Timo Walther commented on FLINK-18811: -- [~pnowojski] could you find someone to help reviewing this

[jira] [Resolved] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

2020-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19401. - Resolution: Fixed > Job stuck in restart loop due to excessive checkpoint recoveries which

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

2020-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218851#comment-17218851 ] Arvid Heise commented on FLINK-19401: - Merged into release-1.11 as

[jira] [Closed] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time"

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19136. -- Resolution: Cannot Reproduce > MetricsAvailabilityITCase.testReporter failed with "Could not

[jira] [Commented] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time"

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218869#comment-17218869 ] Robert Metzger commented on FLINK-19136: The logs of TM and JM both do not look suspicious. I'm

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

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

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

2020-10-22 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577 > * Visilibity in normal case: none of the felds written in `releaseView` are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2` can see some

[GitHub] [flink] flinkbot edited a comment on pull request #13678: [FLINK-19586] Add stream committer operators for new Sink API

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13678: URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155 ## CI report: * Unknown: [CANCELED](TBD) * 463b5c8ed21f93caaeb7b938aa9e72abb35619b2 UNKNOWN * 2ba5bda5c5a15c370c231e1cedfa03fd0bc0b41b Azure:

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

2020-10-22 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577 > * Visilibity in normal case: none of the felds written in `releaseView` are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2` can see some

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * ee73393a13c999be626f7b8b98a170be88a093d9 Azure:

[GitHub] [flink] flinkbot commented on pull request #13740: [FLINK-19758][filesystem] Implement a new unified file sink based on the new sink API

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

[GitHub] [flink] pnowojski opened a new pull request #13741: [FLINK-19680][checkpointing] Announce timeoutable CheckpointBarriers

2020-10-22 Thread GitBox
pnowojski opened a new pull request #13741: URL: https://github.com/apache/flink/pull/13741 This PR adds `CheckpointBarrierAnnouncement` messages ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency):

[jira] [Updated] (FLINK-19680) Add CheckpointBarrierAnnouncement priority message

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

[jira] [Commented] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster

2020-10-22 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218826#comment-17218826 ] Xuannan Su commented on FLINK-19761: cc [~trohrmann] [~azagrebin] [~zjwang] I'd love to hear your

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

2020-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r509937977 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -104,6 +106,67 @@ KubernetesWatch

[jira] [Created] (FLINK-19763) Missing test MetricUtilsTest.testNonHeapMetricUsageNotStatic

2020-10-22 Thread Matthias (Jira)
Matthias created FLINK-19763: Summary: Missing test MetricUtilsTest.testNonHeapMetricUsageNotStatic Key: FLINK-19763 URL: https://issues.apache.org/jira/browse/FLINK-19763 Project: Flink Issue

[GitHub] [flink] AHeise merged pull request #13734: (1.11 backport) [FLINK-19401][checkpointing] Download checkpoints only if needed

2020-10-22 Thread GitBox
AHeise merged pull request #13734: URL: https://github.com/apache/flink/pull/13734 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] [Commented] (FLINK-19688) Flink batch job fails because of InterruptedExceptions from network stack

2020-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218858#comment-17218858 ] Arvid Heise commented on FLINK-19688: - Merged into master as

[GitHub] [flink] flinkbot edited a comment on pull request #13741: [FLINK-19680][checkpointing] Announce timeoutable CheckpointBarriers

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13741: URL: https://github.com/apache/flink/pull/13741#issuecomment-714295796 ## CI report: * 8a68242a90fd180fcd0b4b4c60b5e1e49136c00f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13742: URL: https://github.com/apache/flink/pull/13742#issuecomment-714296461 ## CI report: * 37cba38abc15a3ee7d1193644be564c0c75ac4c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13736: URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394 ## CI report: * 111ec785929a0742b46ea98408f585aa03314b1d Azure:

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

2020-10-22 Thread GitBox
AHeise merged pull request #13723: URL: https://github.com/apache/flink/pull/13723 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] flinkbot edited a comment on pull request #13727: [BP-1.10][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

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

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

2020-10-22 Thread GitBox
AHeise commented on a change in pull request #13723: URL: https://github.com/apache/flink/pull/13723#discussion_r509969318 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -58,6 +59,38 @@

[jira] [Closed] (FLINK-14242) Collapse task names in job graph visualization if too long

2020-10-22 Thread Yadong Xie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Xie closed FLINK-14242. -- Resolution: Fixed > Collapse task names in job graph visualization if too long >

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r509983577 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #13743: [FLINK-19629][Formats]Fix the NPE of avro format, when there is a nul…

2020-10-22 Thread GitBox
flinkbot commented on pull request #13743: URL: https://github.com/apache/flink/pull/13743#issuecomment-714332320 ## CI report: * 60d9d786803903b37709700a16c01bc6f7bef003 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-19757) TimeStampData can cause time inconsistent problem

2020-10-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218809#comment-17218809 ] Jark Wu edited comment on FLINK-19757 at 10/22/20, 6:55 AM: Hi

[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-22 Thread GitBox
wuchong commented on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-714275903 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] azagrebin closed pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

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

[jira] [Commented] (FLINK-19554) Unified testing framework for connectors

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218837#comment-17218837 ] Robert Metzger commented on FLINK-19554: What's the difference of this testing framework

[GitHub] [flink] godfreyhe commented on a change in pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

2020-10-22 Thread GitBox
godfreyhe commented on a change in pull request #13696: URL: https://github.com/apache/flink/pull/13696#discussion_r509945463 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkNotNullEnforcer.java ## @@ -0,0

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

2020-10-22 Thread GitBox
vthinkxie commented on a change in pull request #13458: URL: https://github.com/apache/flink/pull/13458#discussion_r50994 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.html ## @@ -21,6 +21,8 @@

[jira] [Assigned] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18117: -- Assignee: Robert Metzger > "Kerberized YARN per-job on Docker test" fails with

[GitHub] [flink] rmetzger commented on pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-10-22 Thread GitBox
rmetzger commented on pull request #13208: URL: https://github.com/apache/flink/pull/13208#issuecomment-714316318 Maybe I'll take over this pull request. Since the 1.12 release is coming up, it would be nice to address this issue.

[jira] [Updated] (FLINK-18676) Update version of aws to support use of default constructor of "WebIdentityTokenCredentialsProvider"

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18676: --- Component/s: (was: Connectors / FileSystem) FileSystems > Update

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r509989145 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + *

[jira] [Commented] (FLINK-19757) TimeStampData can cause time inconsistent problem

2020-10-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218784#comment-17218784 ] xiaogang zhou commented on FLINK-19757: --- [~jark] the ideal that TimestampData and LocalDataTime

[GitHub] [flink] flinkbot edited a comment on pull request #13678: [FLINK-19586] Add stream committer operators for new Sink API

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13678: URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155 ## CI report: * Unknown: [CANCELED](TBD) * 463b5c8ed21f93caaeb7b938aa9e72abb35619b2 UNKNOWN * 2ba5bda5c5a15c370c231e1cedfa03fd0bc0b41b 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-22 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:

[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-22 Thread GitBox
flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * 0c876d6befc487412629e6a1e8883fa5fbeb31e6 Azure:

[jira] [Commented] (FLINK-19757) TimeStampData can cause time inconsistent problem

2020-10-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218821#comment-17218821 ] xiaogang zhou commented on FLINK-19757: --- Hi [~jark] ， My point is using LocalDateTime to represent

[jira] [Created] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster

2020-10-22 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-19761: -- Summary: Add lookup method for registered ShuffleDescriptor in ShuffleMaster Key: FLINK-19761 URL: https://issues.apache.org/jira/browse/FLINK-19761 Project: Flink

[GitHub] [flink] godfreyhe commented on pull request #13694: [FLINK-19720][table-api] Introduce new Providers and parallelism API

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

[GitHub] [flink] gm7y8 commented on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-10-22 Thread GitBox
gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-714289878 @XComp You are welcome! I have also verified fix with Word Count job ![Uploading Screen Shot 2020-10-22 at 12.23.01 AM.png…]()

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

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

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

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

[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-22 Thread GitBox
flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * 0c876d6befc487412629e6a1e8883fa5fbeb31e6 Azure:

[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-22 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:

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

2020-10-22 Thread GitBox
wangyang0918 removed a comment on pull request #13644: URL: https://github.com/apache/flink/pull/13644#issuecomment-713591200 @tillrohrmann I have gone though all your comments and will update the PR soon. Just two quick points need to confirm with you. * Do you think we should not

[jira] [Commented] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218836#comment-17218836 ] Robert Metzger commented on FLINK-17159: Uff. So I was really not able to even reproduce this

[GitHub] [flink] flinkbot edited a comment on pull request #13703: [FLINK-19696] Add runtime batch committer operators for the new sink API

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13703: URL: https://github.com/apache/flink/pull/13703#issuecomment-712821004 ## CI report: * 5166271f74497afddca3a7f350b8191e2a843298 Azure:

[jira] [Resolved] (FLINK-19688) Flink batch job fails because of InterruptedExceptions from network stack

2020-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19688. - Resolution: Fixed > Flink batch job fails because of InterruptedExceptions from network stack >

[jira] [Created] (FLINK-19764) Add More Metrics to TaskManager in Web UI

2020-10-22 Thread Yadong Xie (Jira)
Yadong Xie created FLINK-19764: -- Summary: Add More Metrics to TaskManager in Web UI Key: FLINK-19764 URL: https://issues.apache.org/jira/browse/FLINK-19764 Project: Flink Issue Type:

[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-22 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] flinkbot edited a comment on pull request #13727: [BP-1.10][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

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

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

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

  1   2   3   4   5   >