[GitHub] [flink] wangxlong commented on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-10 Thread GitBox
wangxlong commented on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572918616 It is failed in python molule. I run travis again. This is a

[GitHub] [flink] wangxlong commented on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-10 Thread GitBox
wangxlong commented on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572918665 @flinkbot run travis This is an automated message from the Ap

[GitHub] [flink] flinkbot edited a comment on issue #10730: [FLINK-14802][orc][hive] Multi vectorized read version support for hive orc read

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10730: [FLINK-14802][orc][hive] Multi vectorized read version support for hive orc read URL: https://github.com/apache/flink/pull/10730#issuecomment-569879082 ## CI report: * 753a9d8bd5705954a67133f2780617ac936a8737 Travis: [FAILURE](https://t

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012507#comment-17012507 ] Yuan Mei edited comment on FLINK-14163 at 1/10/20 8:10 AM: --- He

[jira] [Updated] (FLINK-15497) Streaming TopN operator doesn't reduce outputs when rank number is not required

2020-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15497: --- Labels: pull-request-available (was: ) > Streaming TopN operator doesn't reduce outputs whe

[GitHub] [flink] beyond1920 opened a new pull request #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

2020-01-10 Thread GitBox
beyond1920 opened a new pull request #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN URL: https://github.com/apache/flink/pull/10823 ## What is the purpose of the change As we described in the doc: https://ci.apache.org/

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2020-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15152: --- Labels: checkpoint pull-request-available scheduler (was: checkpoint scheduler) > Job runn

[GitHub] [flink] klion26 opened a new pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

2020-01-10 Thread GitBox
klion26 opened a new pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824 ## What is the purpose of the change Restart `CheckpointCoordinator` if `StopWithSavepoint` failed.

[GitHub] [flink] flinkbot commented on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

2020-01-10 Thread GitBox
flinkbot commented on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN URL: https://github.com/apache/flink/pull/10823#issuecomment-572922918 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012507#comment-17012507 ] Yuan Mei edited comment on FLINK-14163 at 1/10/20 8:16 AM: --- He

[GitHub] [flink] flinkbot commented on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

2020-01-10 Thread GitBox
flinkbot commented on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572923526 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[jira] [Assigned] (FLINK-15534) YARNSessionCapacitySchedulerITCase#perJobYarnClusterWithParallelism failed due to NPE

2020-01-10 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-15534: - Component/s: Deployment / YARN Assignee: Yang Wang Thanks for the confirmation [~fly_in_gis]! Su

[GitHub] [flink] flinkbot edited a comment on issue #10813: [FLINK-15515][hive][doc] Document that Hive connector should be used …

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10813: [FLINK-15515][hive][doc] Document that Hive connector should be used … URL: https://github.com/apache/flink/pull/10813#issuecomment-572552590 ## CI report: * 4bd2e6020e98ae9336152787a3fb76ad349c75b9 Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis: [PENDING](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot commented on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

2020-01-10 Thread GitBox
flinkbot commented on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae UNKNOWN Bot comma

[GitHub] [flink] flinkbot commented on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

2020-01-10 Thread GitBox
flinkbot commented on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN URL: https://github.com/apache/flink/pull/10823#issuecomment-572926510 ## CI report: * 98b6f5aa1f7623e1aba1d1531a0a2973dbdc5873 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-572897310 ## CI report: * 6a9eb6f6b70dc406a0c2285da4b02b17a18e4c7b Travis: [SUCCESS](https://travis-ci.c

[jira] [Created] (FLINK-15547) Support access to Hive avro table

2020-01-10 Thread Rui Li (Jira)
Rui Li created FLINK-15547: -- Summary: Support access to Hive avro table Key: FLINK-15547 URL: https://issues.apache.org/jira/browse/FLINK-15547 Project: Flink Issue Type: Task Components:

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 Travis: [CANCELE

[jira] [Updated] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15533: - Fix Version/s: 1.10.0 > Writing DataStream as text file fails due to output path already exists

[jira] [Updated] (FLINK-15547) Support access to Hive avro table

2020-01-10 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-15547: --- Description: Reading from a Hive avro table gets: {noformat} Caused by: java.lang.NoSuchMethodError: org.ap

[GitHub] [flink] zhuzhurk opened a new pull request #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-10 Thread GitBox
zhuzhurk opened a new pull request #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825 ## What is the purpose of the change In JobResult#createFrom it sets the latest gl

[jira] [Updated] (FLINK-15522) Misleading root cause exception when cancelling the job

2020-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15522: --- Labels: pull-request-available (was: ) > Misleading root cause exception when cancelling th

[GitHub] [flink] flinkbot commented on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-10 Thread GitBox
flinkbot commented on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572929813 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #10730: [FLINK-14802][orc][hive] Multi vectorized read version support for hive orc read

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10730: [FLINK-14802][orc][hive] Multi vectorized read version support for hive orc read URL: https://github.com/apache/flink/pull/10730#issuecomment-569879082 ## CI report: * 753a9d8bd5705954a67133f2780617ac936a8737 Travis: [FAILURE](https://t

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

2020-01-10 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012578#comment-17012578 ] Aljoscha Krettek commented on FLINK-15514: -- Yes, that also makes sense. > Bump

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

2020-01-10 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012581#comment-17012581 ] Aljoscha Krettek commented on FLINK-13613: -- Yes, moving them to a central locat

[GitHub] [flink] AHeise opened a new pull request #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

2020-01-10 Thread GitBox
AHeise opened a new pull request #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826 Unchanged forward port of https://github.com/apache/flink/pull/10816 .

[GitHub] [flink] flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN URL: https://github.com/apache/flink/pull/10823#issuecomment-572926510 ## CI report: * 98b6f5aa1f7623e1aba1d1531a0a2973dbdc5873 Travis

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis: [PENDING](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] twalthr closed pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-10 Thread GitBox
twalthr closed pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-10 Thread GitBox
flinkbot commented on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: * 7d66fc50c8749017788386efb2908ae2087ad7fa UNKNO

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae Travis: [PENDING](ht

[GitHub] [flink] flinkbot commented on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

2020-01-10 Thread GitBox
flinkbot commented on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826#issuecomment-572938301 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[jira] [Closed] (FLINK-15009) Add a utility for creating type inference logic via reflection

2020-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15009. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.11.0: [FLINK-15009][table-common] Improv

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

2020-01-10 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012590#comment-17012590 ] vinoyang commented on FLINK-13613: -- bq. Yes, moving them to a central location could be

[jira] [Commented] (FLINK-15509) Use sql cilents create view occur Unexpected exception

2020-01-10 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012596#comment-17012596 ] Zhenghua Gao commented on FLINK-15509: -- What about validate data type mismatch in t

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-10 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012601#comment-17012601 ] Andrey Zagrebin commented on FLINK-14163: - [~chesnay] [~zhuzh] [~ym] I think we

[GitHub] [flink] flinkbot edited a comment on issue #10730: [FLINK-14802][orc][hive] Multi vectorized read version support for hive orc read

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10730: [FLINK-14802][orc][hive] Multi vectorized read version support for hive orc read URL: https://github.com/apache/flink/pull/10730#issuecomment-569879082 ## CI report: * 753a9d8bd5705954a67133f2780617ac936a8737 Travis: [FAILURE](https://t

[jira] [Commented] (FLINK-15509) Use sql cilents create view occur Unexpected exception

2020-01-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012608#comment-17012608 ] Jingsong Lee commented on FLINK-15509: -- [~docete] If you are talking about that the

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis: [FAILURE](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis: [SUCCESS](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot commented on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

2020-01-10 Thread GitBox
flinkbot commented on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826#issuecomment-572950777 ## CI report: * 4c10a80b7326d1d99c2d89fb2cc423c32bb04afe UNKNOWN Bot commands The @flin

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: * 7d66fc50c8749017788386efb2908ae2087ad7f

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 Travis: [CANCELE

[jira] [Created] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

2020-01-10 Thread wangsan (Jira)
wangsan created FLINK-15548: --- Summary: Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator Key: FLINK-15548 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633 ] Kostas Kloudas commented on FLINK-15533: Hi [~lirui], I tried it on the {{master

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633 ] Kostas Kloudas edited comment on FLINK-15533 at 1/10/20 9:45 AM: -

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633 ] Kostas Kloudas edited comment on FLINK-15533 at 1/10/20 9:58 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis: [FAILURE](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN URL: https://github.com/apache/flink/pull/10823#issuecomment-572926510 ## CI report: * 98b6f5aa1f7623e1aba1d1531a0a2973dbdc5873 Travis

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826#issuecomment-572950777 ## CI report: * 4c10a80b7326d1d99c2d89fb2cc423c32bb04afe Travis: [PENDING](https://travis-ci.co

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365150036 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/main/java/org/apache/flink/tests/util/hive/Y

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365137287 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/main/java/org/apache/flink/tests/util/hive/Y

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365152997 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/main/resources/docker-hive-hadoop-cluster/bo

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365143456 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/main/java/org/apache/flink/tests/util/hive/Y

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365154431 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/main/resources/docker-hive-hadoop-cluster/bo

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365148227 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/main/java/org/apache/flink/tests/util/hive/Y

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

2020-01-10 Thread GitBox
lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365160531 ## File path: flink-end-to-end-tests/flink-connector-hive-test/src/test/java/org/apache/flink/connectors/hive/H

[GitHub] [flink] twalthr closed pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

2020-01-10 Thread GitBox
twalthr closed pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781 This is an automated message from the Apache Git Servic

[jira] [Created] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-10 Thread caojian0613 (Jira)
caojian0613 created FLINK-15549: --- Summary: integer overflow in SpillingResettableMutableObjectIterator Key: FLINK-15549 URL: https://issues.apache.org/jira/browse/FLINK-15549 Project: Flink Is

[jira] [Closed] (FLINK-15281) Map Flink's TypeInference to Calcite's interfaces

2020-01-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15281. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.11.0: 21d1c659ca3627259d2b274dce9f5c9492

[jira] [Updated] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-10 Thread caojian0613 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caojian0613 updated FLINK-15549: Description: The SpillingResettableMutableObjectIterator has a data overflow problem if the  numbe

[GitHub] [flink] TsReaper commented on a change in pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-01-10 Thread GitBox
TsReaper commented on a change in pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#discussion_r365168981 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/a

[jira] [Created] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2020-01-10 Thread Yun Tang (Jira)
Yun Tang created FLINK-15550: Summary: testCancelTaskExceptionAfterTaskMarkedFailed failed on azure Key: FLINK-15550 URL: https://issues.apache.org/jira/browse/FLINK-15550 Project: Flink Issue T

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-10 Thread GitBox
ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r365171167 ## File path: flink-runtime/src/main/java/org/apache/flink

[GitHub] [flink] ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-10 Thread GitBox
ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-572982657 Hi @pnowojski , thanks for patiently reviewing. I have addressed most of the comments

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis: [FAILURE](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: * 7d66fc50c8749017788386efb2908ae2087ad7f

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

2020-01-10 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012720#comment-17012720 ] Yu Li commented on FLINK-12785: --- Fixed via master: 6df2e0e6db6d58819fcec9a9dd1e9cf1c632af0

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

2020-01-10 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012723#comment-17012723 ] Yu Li commented on FLINK-12785: --- [~klion26] Please add some release notes about the newly

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis: [FAILURE](https://travis-ci

[GitHub] [flink] jrthe42 opened a new pull request #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProc

2020-01-10 Thread GitBox
jrthe42 opened a new pull request #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827 ## What is the purpose of the change `Le

[jira] [Updated] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

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

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596 ## CI report: * 3198d4f64415b0d257733b7d214dece64c392081 Travis: [FAILUR

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: * 7d66fc50c8749017788386efb2908ae2087ad7f

[GitHub] [flink] flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826#issuecomment-572950777 ## CI report: * 4c10a80b7326d1d99c2d89fb2cc423c32bb04afe Travis: [SUCCESS](https://travis-ci.co

[GitHub] [flink] flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOpe

2020-01-10 Thread GitBox
flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827#issuecomment-572996855 Thanks a lot for your contribu

[GitHub] [flink] zhijiangW merged pull request #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

2020-01-10 Thread GitBox
zhijiangW merged pull request #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826 This is an automated message from the Apache Git Service. To respond

[jira] [Comment Edited] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

2020-01-10 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012387#comment-17012387 ] zhijiang edited comment on FLINK-15355 at 1/10/20 11:29 AM:

[jira] [Commented] (FLINK-15529) Update upgrade compatibility table (docs/ops/upgrading.md) for 1.10.0

2020-01-10 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012748#comment-17012748 ] Congxian Qiu(klion26) commented on FLINK-15529: --- Currently. I've tested us

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012755#comment-17012755 ] Yangze Guo commented on FLINK-15549: Same issue is also exist in _SpillingResettable

[GitHub] [flink] klion26 commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2020-01-10 Thread GitBox
klion26 commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-573001668 @carp84 @StephanEwen thanks for review and merging

[GitHub] [flink] zentol merged pull request #10817: [FLINK-15542][legal] Move NOTICE entry for lz4-java

2020-01-10 Thread GitBox
zentol merged pull request #10817: [FLINK-15542][legal] Move NOTICE entry for lz4-java URL: https://github.com/apache/flink/pull/10817 This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] zentol merged pull request #10818: [FLINK-15543][legal] Remove Apache Camel NOTICE entries

2020-01-10 Thread GitBox
zentol merged pull request #10818: [FLINK-15543][legal] Remove Apache Camel NOTICE entries URL: https://github.com/apache/flink/pull/10818 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-15542) lz4-java licensing is incorrect

2020-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15542. Resolution: Fixed master: 75cded93430f9c1fbb325e95c2c4795451199ae4 1.10: a274c0296b93fb4d0

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-10 Thread GitBox
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596 ## CI report: * 3198d4f64415b0d257733b7d214dece64c392081 Travis: [FAILUR

[jira] [Closed] (FLINK-15543) Apache Camel not bundled but listed in flink-dist NOTICE

2020-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15543. Resolution: Fixed master: 7ec228a5225eda68701f6a6b5713727ed5232eb9 1.10: 2a7f96b18732430d9

[GitHub] [flink] flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOpe

2020-01-10 Thread GitBox
flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827#issuecomment-573006993 ## CI report: * 63d

[jira] [Created] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

2020-01-10 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-15551: -- Summary: Streaming File Sink s3 end-to-end test FAIL Key: FLINK-15551 URL: https://issues.apache.org/jira/browse/FLINK-15551 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

2020-01-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012777#comment-17012777 ] Leonard Xu commented on FLINK-15551: CC:[~gjy]  > Streaming File Sink s3 end-to-end

[jira] [Updated] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

2020-01-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15551: --- Description: This issue happens in latest release-1.10 branch[1], this issue is similar to FLINK-1

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-10 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012781#comment-17012781 ] Rui Li commented on FLINK-15533: Hi [~kkl0u], just confirmed the job succeeds if I write

[jira] [Assigned] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-15431: Assignee: Benchao Li > Add numLateRecordsDropped/lateRecordsDroppedRate/watermark

[GitHub] [flink] dawidwys commented on issue #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread GitBox
dawidwys commented on issue #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator URL: https://github.com/apache/flink/pull/10713#issuecomment-573013933 Hi @libenchao I added a comment in the corresponding JIRA. Let's discuss the scope

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012783#comment-17012783 ] Dawid Wysakowicz commented on FLINK-15431: -- Hi [~libenchao], I think it makes

[jira] [Closed] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

2020-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15551. Fix Version/s: (was: 1.10.0) Resolution: Duplicate > Streaming File Sink s3 end

[GitHub] [flink] dawidwys commented on issue #9050: [FLINK-13181][Table]Add Builder to build CsvTableSink instances

2020-01-10 Thread GitBox
dawidwys commented on issue #9050: [FLINK-13181][Table]Add Builder to build CsvTableSink instances URL: https://github.com/apache/flink/pull/9050#issuecomment-573014543 Hi @hehuiyuan, Could you rebase the change to the current master? Moreover I don't think we need a whole IT case

[jira] [Updated] (FLINK-12040) Remove unused akka dependencies in pom.xml

2020-01-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12040: - Fix Version/s: 1.8.4 > Remove unused akka dependencies in pom.xml >

  1   2   3   >