[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392545#comment-16392545 ] ASF GitHub Bot commented on FLINK-8756: --- Github user GJL commented on the issue:

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

2018-03-08 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5573 You can use `git commit -m "Trigger build" --allow-empty` to trigger a build. ---

[jira] [Commented] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

2018-03-08 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392520#comment-16392520 ] mingleizhang commented on FLINK-8894: - Hi, [~gjy] I want to reproduce this issue on my

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392290#comment-16392290 ] ASF GitHub Bot commented on FLINK-: --- GitHub user kailashhd opened a pull request

[GitHub] flink pull request #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS S...

2018-03-08 Thread kailashhd
GitHub user kailashhd opened a pull request: https://github.com/apache/flink/pull/5663 [FLINK-] [Kinesis Connectors] Update the AWS SDK for flink kinesis connector ## What is the purpose of the change Updating the AWS Java SDK in order to be able to use new features lik

[jira] [Updated] (FLINK-8554) Upgrade AWS SDK

2018-03-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8554: -- Description: AWS SDK 1.11.271 fixes a lot of bugs. One of which would exhibit the following: {code} Caused by:

[jira] [Commented] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391820#comment-16391820 ] ASF GitHub Bot commented on FLINK-8887: --- Github user zentol commented on the issue:

[GitHub] flink issue #5657: [FLINK-8887][tests] Add single retry in MiniClusterClient

2018-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5657 merging. ---

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391814#comment-16391814 ] ASF GitHub Bot commented on FLINK-8756: --- Github user zentol commented on the issue:

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

2018-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5573 @yanghua This test failure is unrelated, you can ignore it. ---

[jira] [Commented] (FLINK-8729) Migrate JSONGenerator from Sling to Jackson

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391811#comment-16391811 ] ASF GitHub Bot commented on FLINK-8729: --- Github user zentol commented on the issue:

[GitHub] flink issue #5554: [FLINK-8729][streaming] Refactor JSONGenerator to use jac...

2018-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5554 merging. ---

[jira] [Commented] (FLINK-8860) SlotManager spamming log files

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391808#comment-16391808 ] ASF GitHub Bot commented on FLINK-8860: --- Github user zentol commented on the issue:

[GitHub] flink issue #5637: [FLINK-8860][flip6] stop SlotManager spamming logs for ev...

2018-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5637 merging. ---

[jira] [Commented] (FLINK-8800) Set Logging to TRACE for org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391807#comment-16391807 ] ASF GitHub Bot commented on FLINK-8800: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5594: [FLINK-8800][REST] Reduce logging of all requests ...

2018-03-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5594#discussion_r173266836 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/AbstractHandler.java --- @@ -84,8 +84,8 @@ protected AbstractHandler( @Over

[jira] [Commented] (FLINK-8889) Do not override config values in TestBaseUtils#startCluster

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391806#comment-16391806 ] ASF GitHub Bot commented on FLINK-8889: --- Github user zentol commented on the issue:

[GitHub] flink issue #5651: [FLINK-8889][tests] Do not override cluster config values

2018-03-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5651 merging. ---

[jira] [Updated] (FLINK-8901) YARN application name for Flink (per-job) submissions claims it is using only 1 TaskManager

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8901: Priority: Blocker (was: Major) > YARN application name for Flink (per-job) submissions clai

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391619#comment-16391619 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on the issue

[GitHub] flink issue #5656: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5656 rebased ---

[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

2018-03-08 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8902: Labels: flip6 (was: ) > Re-scaling job sporadically fails with KeeperException > --

[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

2018-03-08 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8902: Description: *Description* Re-scaling a job with {{bin/flink modify -p }} sporadically fails with a {{Keep

[jira] [Created] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

2018-03-08 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8902: --- Summary: Re-scaling job sporadically fails with KeeperException Key: FLINK-8902 URL: https://issues.apache.org/jira/browse/FLINK-8902 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391566#comment-16391566 ] Nico Kruber commented on FLINK-8900: Let me elaborate a bit more since this also partl

[jira] [Commented] (FLINK-8797) Port AbstractOperatorRestoreTestBase to MiniClusterResource

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391561#comment-16391561 ] ASF GitHub Bot commented on FLINK-8797: --- Github user aljoscha commented on the issue

[GitHub] flink issue #5589: [FLINK-8797] Port AbstractOperatorRestoreTestBase to Mini...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5589 @zentol rebased ---

[jira] [Updated] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8900: --- Labels: flip-6 (was: ) > YARN FinalStatus always shows as KILLED with Flip-6 > --

[jira] [Updated] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8900: --- Labels: (was: flip-6) > YARN FinalStatus always shows as KILLED with Flip-6 > --

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391556#comment-16391556 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #5656: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5656#discussion_r173227736 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -223,6 +224,81 @@ } } +

[jira] [Created] (FLINK-8901) YARN application name for Flink (per-job) submissions claims it is using only 1 TaskManager

2018-03-08 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8901: -- Summary: YARN application name for Flink (per-job) submissions claims it is using only 1 TaskManager Key: FLINK-8901 URL: https://issues.apache.org/jira/browse/FLINK-8901

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391533#comment-16391533 ] Aljoscha Krettek commented on FLINK-8487: - ITCase added on release-1.4 in 72b3ddad

[jira] [Reopened] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-8856: - Should be fixed for 1.4.3 as well > Move all interrupt() calls to TaskCanceler >

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391534#comment-16391534 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on the issue

[jira] [Updated] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8900: --- Labels: flip-6 (was: ) > YARN FinalStatus always shows as KILLED with Flip-6 > --

[jira] [Updated] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8856: Affects Version/s: 1.4.2 1.4.0 1.4.1 > Move all interr

[jira] [Updated] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8856: Fix Version/s: 1.4.3 > Move all interrupt() calls to TaskCanceler >

[GitHub] flink issue #5654: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5654 merged ---

[jira] [Created] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8900: -- Summary: YARN FinalStatus always shows as KILLED with Flip-6 Key: FLINK-8900 URL: https://issues.apache.org/jira/browse/FLINK-8900 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8883. - Resolution: Fixed Fixed in - 1.5.0 via afd2404d634a03cc4cd017b63745c74e5281896c - 1.6.0 via 1d

[jira] [Resolved] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8884. - Resolution: Fixed Fixed in - 1.5.0 via 071e29143c303d63e9908fb1ef6faa447c48d27e - 1.6.0 via dd

[jira] [Closed] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8883. --- > ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal > -

[jira] [Closed] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8884. --- > The DispatcherThreadFactory should register uncaught exception handlers > --

[jira] [Closed] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8856. --- > Move all interrupt() calls to TaskCanceler > -- > >

[jira] [Resolved] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8856. - Resolution: Fixed Fixed in - 1.5.0 via 36dccdc520c676ca2c53046cad4ec80c351068b7 - 1.6.0 via 1e

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391512#comment-16391512 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha closed the pull reques

[GitHub] flink pull request #5655: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5655 ---

[jira] [Created] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

2018-03-08 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8899: -- Summary: Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException Key: FLINK-8899 URL: https://issues.apache.org/jira/browse/FLINK-8899 Project: Fl

[jira] [Updated] (FLINK-8898) Materialize time indicators in conditions of LogicalFilter

2018-03-08 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-8898: --- Description: Currently, {{RelTimeIndicatorConverter}} do not materialize time indicators in condition

[jira] [Created] (FLINK-8898) Materialize time indicators in conditions of LogicalFilter

2018-03-08 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-8898: -- Summary: Materialize time indicators in conditions of LogicalFilter Key: FLINK-8898 URL: https://issues.apache.org/jira/browse/FLINK-8898 Project: Flink Issue Ty

[jira] [Created] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError

2018-03-08 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8897: -- Summary: Rowtime materialization causes "mismatched type" AssertionError Key: FLINK-8897 URL: https://issues.apache.org/jira/browse/FLINK-8897 Project: Flink Is

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391429#comment-16391429 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha closed the pull reques

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391428#comment-16391428 ] Aljoscha Krettek commented on FLINK-8487: - ITCase added on release-1.3 in b6cfe7ba

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5654 ---

[jira] [Updated] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8487: Fix Version/s: 1.3.3 > State loss after multiple restart attempts >

[jira] [Assigned] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8487: --- Assignee: Aljoscha Krettek > State loss after multiple restart attempts > ---

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391333#comment-16391333 ] ASF GitHub Bot commented on FLINK-8428: --- Github user hequn8128 commented on the issu

[GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l...

2018-03-08 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/5327 Hi @twalthr @walterddr The latest update refactors interfaces and functions to make code more friendly to right/full joins. The code of right/full joins are also ready and can be reached from

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391314#comment-16391314 ] Stefan Richter commented on FLINK-8882: --- Got to double check again, maybe the proble

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391311#comment-16391311 ] Stephan Ewen commented on FLINK-8882: - Seems strange indeed. Feels also not good to no

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391304#comment-16391304 ] ASF GitHub Bot commented on FLINK-5479: --- Github user StephanEwen commented on the is

[GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5634 Just saw a good comment from @EronWright > I think the ideal would be that idleness would occur only for tail reads, i.e. due to a timeout from `kafkaConsumer.poll(pollTimeout)`. In othe

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391300#comment-16391300 ] Stefan Richter commented on FLINK-8882: --- It seems like the problem was introduced by

[jira] [Commented] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391298#comment-16391298 ] ASF GitHub Bot commented on FLINK-8856: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391297#comment-16391297 ] ASF GitHub Bot commented on FLINK-8856: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #5658: [FLINK-8856] [TaskManager] Move all cancellation i...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5658#discussion_r173170798 --- Diff: flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java --- @@ -81,12 +81,15 @@ public static String stringifyException(final Throwable

[GitHub] flink pull request #5658: [FLINK-8856] [TaskManager] Move all cancellation i...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5658#discussion_r173171090 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/DispatcherThreadFactory.java --- @@ -18,6 +18,8 @@ package org.apache

[jira] [Assigned] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8867: --- Assignee: Stefan Richter > Rocksdb checkpointing failing with fs.default-scheme: hdfs

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-03-08 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391274#comment-16391274 ] Wind commented on FLINK-8785: - [~Zentol] You mean the exception should be caught instead of be

[jira] [Updated] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8867: Priority: Blocker (was: Major) > Rocksdb checkpointing failing with fs.default-scheme: hdfs

[jira] [Updated] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8867: Fix Version/s: (was: 1.4.3) > Rocksdb checkpointing failing with fs.default-scheme: hdfs

[GitHub] flink pull request #5656: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5656#discussion_r173164690 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,333 @@ +/* + * Licensed

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391268#comment-16391268 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in

[GitHub] flink issue #5654: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5654 @StephanEwen pushed some changes ---

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391261#comment-16391261 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-8893) NPE when netty try to allocate directBuffer

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391248#comment-16391248 ] Nico Kruber commented on FLINK-8893: I looked at the merged commits in Netty but the f

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391225#comment-16391225 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391226#comment-16391226 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391224#comment-16391224 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173148163 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricGroup.java --- @@ -87,9 +89,27 @@ * @param gauge gauge

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173149289 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporterV2.java --- @@ -0,0 +1,89 @@ +/* + *

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173150593 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -23,6 +23,7 @@ import org.apache.flink.metrics.Gauge

[jira] [Assigned] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties

2018-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8536: --- Assignee: (was: Timo Walther) > Improve CSVTableSourceFactory to support all descriptor p

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391200#comment-16391200 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391198#comment-16391198 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173146108 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/NumberGauge.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391201#comment-16391201 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391199#comment-16391199 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173146558 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/StringGauge.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173146575 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/NumberGauge.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173147513 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java --- @@ -460,4 +474,77 @@ protected GenericMetricG

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391186#comment-16391186 ] Stephan Ewen commented on FLINK-8895: - I don't think we need to do anything special he

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391171#comment-16391171 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173143151 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + * Licensed

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391169#comment-16391169 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173142937 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + * Licensed

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173142759 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + * Licensed

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391167#comment-16391167 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391163#comment-16391163 ] ASF GitHub Bot commented on FLINK-8854: --- GitHub user twalthr opened a pull request:

  1   2   >