[GitHub] [flink] yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

2019-10-30 Thread GitBox
yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#discussion_r340525877 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -577,171 +474,101

[GitHub] [flink] zentol commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

2019-10-30 Thread GitBox
zentol commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340526135 ## File path:

[jira] [Assigned] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

2019-10-30 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-14439: Assignee: Gary Yao > RestartPipelinedRegionStrategy leverage tracked partition availability for

[GitHub] [flink] yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

2019-10-30 Thread GitBox
yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#discussion_r340525435 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -26,25 +26,20 @@

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-30 Thread GitBox
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r340517441 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-30 Thread GitBox
kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r340515896 ## File path:

[jira] [Commented] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

2019-10-30 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962887#comment-16962887 ] Gary Yao commented on FLINK-14439: -- As discussed offline, I think it's better to add a parameter to

[jira] [Comment Edited] (FLINK-14529) Compile-jdk11 fails in nightly end-to-end test

2019-10-30 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962884#comment-16962884 ] Yu Li edited comment on FLINK-14529 at 10/30/19 10:05 AM: -- Resolved by Andrey's

[jira] [Closed] (FLINK-14529) Compile-jdk11 fails in nightly end-to-end test

2019-10-30 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-14529. - Resolution: Resolved Resolved by the commit in FLINK-14522, more specific, usage of sun.misc.Cleaner is

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[jira] [Commented] (FLINK-14529) Compile-jdk11 fails in nightly end-to-end test

2019-10-30 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962881#comment-16962881 ] Yu Li commented on FLINK-14529: --- I didn't see the same issue in recent builds, so I think we could close

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340522208 ## File path:

[jira] [Assigned] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-13702: Assignee: Dawid Wysakowicz > BaseMapSerializerTest.testDuplicate fails on Travis

[jira] [Commented] (FLINK-12527) Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

2019-10-30 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962876#comment-16962876 ] vinoyang commented on FLINK-12527: -- [~gjy] I will also start this cleanup work. > Remove

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

2019-10-30 Thread GitBox
azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340513720 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

2019-10-30 Thread GitBox
azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340519053 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

2019-10-30 Thread GitBox
azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340507724 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

2019-10-30 Thread GitBox
azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340512777 ## File path:

[GitHub] [flink] zentol merged pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

2019-10-30 Thread GitBox
zentol merged pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] GJL commented on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

2019-10-30 Thread GitBox
GJL commented on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-547818573 Merging. This is an automated message

[jira] [Updated] (FLINK-12147) InfluxDB throws errors if metric value is NaN/infinity

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12147: - Release Note: The InfluxDBReporter now silently skips NaN / Inf fields. > InfluxDB

[jira] [Updated] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

2019-10-30 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14572: - Description: {noformat} java.lang.AssertionError: Expected: is but: was at

[jira] [Created] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

2019-10-30 Thread Gary Yao (Jira)
Gary Yao created FLINK-14572: Summary: BlobsCleanupITCase failed in Travis stage core - scheduler_ng Key: FLINK-14572 URL: https://issues.apache.org/jira/browse/FLINK-14572 Project: Flink Issue

[jira] [Closed] (FLINK-12147) InfluxDB throws errors if metric value is NaN/infinity

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12147. Fix Version/s: 1.10.0 Resolution: Fixed master:

[jira] [Updated] (FLINK-12147) InfluxDB throws errors if metric value is NaN/infinity

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12147: - Issue Type: Improvement (was: Bug) > InfluxDB throws errors if metric value is

[jira] [Updated] (FLINK-12147) InfluxDB throws errors if metric value is NaN/infinity

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12147: - Summary: InfluxDB throws errors if metric value is NaN/infinity (was: Error for

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340513313 ## File path:

[jira] [Reopened] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins,influxDB unsuport POSITIVE_INFINITY or NEGATIVE_INFINITY

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-12147: -- > Error for monitor kafka metrics when Use influxDB metric plugins,influxDB > unsuport

[jira] [Assigned] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins,influxDB unsuport POSITIVE_INFINITY or NEGATIVE_INFINITY

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-12147: Assignee: Piotr Przybylski > Error for monitor kafka metrics when Use influxDB

[GitHub] [flink] zentol closed pull request #8513: [FLINK-12147] [metrics] Error for monitor kafka metrics when Use influxDB metr…

2019-10-30 Thread GitBox
zentol closed pull request #8513: [FLINK-12147] [metrics] Error for monitor kafka metrics when Use influxDB metr… URL: https://github.com/apache/flink/pull/8513 This is an automated message from the Apache Git Service. To

[GitHub] [flink] zentol merged pull request #10020: [FLINK-12147] [metrics] Update influxdb-java to remove writes of invalid values to InfluxDB

2019-10-30 Thread GitBox
zentol merged pull request #10020: [FLINK-12147] [metrics] Update influxdb-java to remove writes of invalid values to InfluxDB URL: https://github.com/apache/flink/pull/10020 This is an automated message from the Apache Git

[GitHub] [flink] zentol commented on issue #8513: [FLINK-12147] [metrics] Error for monitor kafka metrics when Use influxDB metr…

2019-10-30 Thread GitBox
zentol commented on issue #8513: [FLINK-12147] [metrics] Error for monitor kafka metrics when Use influxDB metr… URL: https://github.com/apache/flink/pull/8513#issuecomment-547817126 Subsumed by #10020. This is an automated

[jira] [Closed] (FLINK-11405) Add maxExceptions query parameter

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11405. Fix Version/s: 1.10.0 Resolution: Fixed master:

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : FAILURE

[GitHub] [flink] zentol merged pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

2019-10-30 Thread GitBox
zentol merged pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-11405) Add maxExceptions query parameter

2019-10-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11405: - Summary: Add maxExceptions query parameter (was: rest api can show more exceptions by

[GitHub] [flink] flinkbot edited a comment on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context URL: https://github.com/apache/flink/pull/10041#issuecomment-547782526 ## CI report: * 34cb6034520e8d233c005c6a5f35ead6e590c31f : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction URL: https://github.com/apache/flink/pull/10040#issuecomment-547782455 ## CI report: * 02d52c4bd0528e813c682c13d8477a162d3edcc1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : FAILURE

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

2019-10-30 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962842#comment-16962842 ] Arvid Heise commented on FLINK-14544: - Small update: Found the issue and will provide a fix later.

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : FAILURE

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340504515 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340507045 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340506966 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340505127 ## File path:

[jira] [Updated] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

2019-10-30 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14439: Description: In current region failover when using DefaultScheduler, most of the input result partition

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340504434 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340505330 ## File path:

[GitHub] [flink] thorntree commented on issue #5430: [FLINK-8605] [rest] Enable job cancellation from the web UI

2019-10-30 Thread GitBox
thorntree commented on issue #5430: [FLINK-8605] [rest] Enable job cancellation from the web UI URL: https://github.com/apache/flink/pull/5430#issuecomment-547809234 why i cancel one job,but it cancle all jobs? This is an

[GitHub] [flink] zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-547807637 Thanks for the updates @wsry, and the codes are becoming better now. I only left

[jira] [Closed] (FLINK-14430) BaseArraySerializerTest.testDuplicate fails on travis

2019-10-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-14430. Resolution: Duplicate > BaseArraySerializerTest.testDuplicate fails on travis >

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340498024 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-510415691 ## CI report: * 2b6f431f4f281936034418c8ce64e2e1ba10bd5f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[GitHub] [flink] JingsongLi commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread GitBox
JingsongLi commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-547801504 > 08:05:11.129 [ERROR] Tests run: 3752, Failures: 6, Errors: 0, Skipped:

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : FAILURE

[GitHub] [flink] GJL commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

2019-10-30 Thread GitBox
GJL commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r340491299 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
dawidwys commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340491142 ## File path:

[jira] [Commented] (FLINK-14462) Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-30 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962818#comment-16962818 ] Zili Chen commented on FLINK-14462: --- Thanks for your insights. I will start progress now. > Remove

[jira] [Created] (FLINK-14571) flink connector for redis

2019-10-30 Thread xiaodao (Jira)
xiaodao created FLINK-14571: --- Summary: flink connector for redis Key: FLINK-14571 URL: https://issues.apache.org/jira/browse/FLINK-14571 Project: Flink Issue Type: New Feature

[GitHub] [flink] dawidwys commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-30 Thread GitBox
dawidwys commented on a change in pull request #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#discussion_r340488084 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340487755 ## File path:

[jira] [Commented] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

2019-10-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962815#comment-16962815 ] Piotr Nowojski commented on FLINK-14382: > So we will need to set the `FLINK_PLUGIN_DIR`

[GitHub] [flink] dawidwys commented on issue #4725: [FLINK-7689] [Streaming Connectors] Added metrics to JDBCOutputFormat in order to be able to m…

2019-10-30 Thread GitBox
dawidwys commented on issue #4725: [FLINK-7689] [Streaming Connectors] Added metrics to JDBCOutputFormat in order to be able to m… URL: https://github.com/apache/flink/pull/4725#issuecomment-547794401 Hi @asicoe, Sorry for the lack of activity in the PR. Let me know if you are still

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340485069 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340484430 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-510415691 ## CI report: * 2b6f431f4f281936034418c8ce64e2e1ba10bd5f : FAILURE

[GitHub] [flink] flinkbot commented on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

2019-10-30 Thread GitBox
flinkbot commented on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context URL: https://github.com/apache/flink/pull/10041#issuecomment-547782526 ## CI report: * 34cb6034520e8d233c005c6a5f35ead6e590c31f : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction URL: https://github.com/apache/flink/pull/10040#issuecomment-547782455 ## CI report: * 02d52c4bd0528e813c682c13d8477a162d3edcc1 : PENDING

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340482750 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-546907883 ## CI report: * 0af01dfef17a8ebcafd92137f87a96023258e124 : SUCCESS

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340481455 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

2019-10-30 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340481331 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-546298071 ## CI report: * 05bdcf84ff2300835a3ae51b52b534a1a1e94024 : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340480226 ## File path:

[GitHub] [flink] KurtYoung commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread GitBox
KurtYoung commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-547789865 08:05:11.129 [ERROR] Tests run: 3752, Failures: 6, Errors: 0, Skipped: 17

[GitHub] [flink] xuyang1706 commented on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
xuyang1706 commented on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-547788706 > Thanks for the contribution @xuyang1706 . I left a few comments with more higher level questions. >

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340478205 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340478205 ## File path:

[jira] [Commented] (FLINK-14570) KeyedStateBootstrapFunction missed onTimer callback method to fire timer

2019-10-30 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962805#comment-16962805 ] vinoyang commented on FLINK-14570: -- [~sjwiesman] [~aljoscha] WDYT? > KeyedStateBootstrapFunction

[jira] [Created] (FLINK-14570) KeyedStateBootstrapFunction missed onTimer callback method to fire timer

2019-10-30 Thread vinoyang (Jira)
vinoyang created FLINK-14570: Summary: KeyedStateBootstrapFunction missed onTimer callback method to fire timer Key: FLINK-14570 URL: https://issues.apache.org/jira/browse/FLINK-14570 Project: Flink

[GitHub] [flink] wuchong commented on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
wuchong commented on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-547785124 @KurtYoung Thanks for reviewing , I updated the pull request.

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-30 Thread GitBox
wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340474974 ## File path:

[jira] [Created] (FLINK-14569) use flink to deal with batch task,when parallelism granter than 1, always 1 or 2 records loss

2019-10-30 Thread kk (Jira)
kk created FLINK-14569: -- Summary: use flink to deal with batch task,when parallelism granter than 1, always 1 or 2 records loss Key: FLINK-14569 URL: https://issues.apache.org/jira/browse/FLINK-14569 Project:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-30 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340474221 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#discussion_r340473016 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#discussion_r340472955 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#discussion_r340472984 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

2019-10-30 Thread GitBox
xuyang1706 commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#discussion_r340473036 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

2019-10-30 Thread GitBox
flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] docete commented on a change in pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

2019-10-30 Thread GitBox
docete commented on a change in pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#discussion_r340472333 ## File path:

[GitHub] [flink] flinkbot commented on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

2019-10-30 Thread GitBox
flinkbot commented on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context URL: https://github.com/apache/flink/pull/10041#issuecomment-547782526 ## CI report: * 34cb6034520e8d233c005c6a5f35ead6e590c31f : UNKNOWN Bot commands

<    1   2   3   4   5   6   7   >