[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

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

[GitHub] flink issue #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITCase to ...

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

[jira] [Assigned] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-04-03 Thread Jiayi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi reassigned FLINK-6924: Assignee: Jiayi (was: zjuwangg) > ADD LOG(X) supported in TableAPI > > >

[jira] [Assigned] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-04-03 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8953: - Assignee: Renjie Liu > Resolve unresolved field references in FieldComputer expressions > ---

[jira] [Updated] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9088: -- Component/s: Streaming Connectors > Upgrade Nifi connector dependency to 1.6.0 > ---

[jira] [Comment Edited] (FLINK-8971) Create general purpose testing job

2018-04-03 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421148#comment-16421148 ] mingleizhang edited comment on FLINK-8971 at 4/4/18 1:49 AM: -

[jira] [Updated] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9091: -- Component/s: Build System > Failure while enforcing releasability in building flink-json module > --

[jira] [Updated] (FLINK-8933) Avoid calling Class#newInstance

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8933: -- Description: Class#newInstance is deprecated starting in Java 9 - https://bugs.openjdk.java.net/browse/JDK-6850

[jira] [Commented] (FLINK-9127) Filesystem State Backend logged incorrectly

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

[GitHub] flink pull request #5810: [FLINK-9127] [Core] Filesystem State Backend logge...

2018-04-03 Thread skidder
GitHub user skidder opened a pull request: https://github.com/apache/flink/pull/5810 [FLINK-9127] [Core] Filesystem State Backend logged incorrectly ## What is the purpose of the change This pull-request fixes a message logged when during startup of the Flink Task-Manager a

[jira] [Created] (FLINK-9127) Filesystem State Backend logged incorrectly

2018-04-03 Thread Scott Kidder (JIRA)
Scott Kidder created FLINK-9127: --- Summary: Filesystem State Backend logged incorrectly Key: FLINK-9127 URL: https://issues.apache.org/jira/browse/FLINK-9127 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

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

[GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys

2018-04-03 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5808 cc @StephanEwen @aljoscha ---

[jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424625#comment-16424625 ] Steven Zhen Wu edited comment on FLINK-9061 at 4/3/18 9:43 PM: -

[jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424625#comment-16424625 ] Steven Zhen Wu edited comment on FLINK-9061 at 4/3/18 9:24 PM: -

[jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424625#comment-16424625 ] Steven Zhen Wu edited comment on FLINK-9061 at 4/3/18 9:23 PM: -

[jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424625#comment-16424625 ] Steven Zhen Wu edited comment on FLINK-9061 at 4/3/18 9:23 PM: -

[jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424625#comment-16424625 ] Steven Zhen Wu edited comment on FLINK-9061 at 4/3/18 9:22 PM: -

[jira] [Commented] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424625#comment-16424625 ] Steven Zhen Wu commented on FLINK-9061: --- [~jgrier] [~StephanEwen] Here are our thin

[jira] [Commented] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

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

[jira] [Updated] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8697: Fix Version/s: 1.6.0 > Rename DummyFlinkKafkaConsumer in Kinesis tests > ---

[GitHub] flink pull request #5809: [FLINK-8697] [Kinesis Connector] Rename DummyFlink...

2018-04-03 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5809 [FLINK-8697] [Kinesis Connector] Rename DummyFlinkKafkaConsumer in KinesisDataFetcherTest ## What is the purpose of the change `DummyFlinkKafkaConsumer` in `KinesisDataFetcherTest` should

[jira] [Assigned] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests

2018-04-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-8697: --- Assignee: Bowen Li > Rename DummyFlinkKafkaConsumer in Kinesis tests > --

[jira] [Commented] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance

2018-04-03 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424552#comment-16424552 ] Steven Zhen Wu commented on FLINK-9061: --- it seems that S3 walk through the prefix fr

[GitHub] flink pull request #5797: [FLINK-9104][doc]Re-generate REST API documentatio...

2018-04-03 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5797#discussion_r178913403 --- Diff: flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java --- @@ -258,6 +265,37 @@ private static String createMessageHtmlEntr

[jira] [Commented] (FLINK-9104) Re-generate REST API documentation for FLIP-6

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

[GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3117 @ShashwatRastogi-Reflektion I'm not entirely sure, but one thing you could try is to explicitly disable chaining (`StreamExecutionEnvironment#disableOperatorChaining`). This way the ID of each operat

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

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

[jira] [Commented] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-04-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424252#comment-16424252 ] Piotr Nowojski commented on FLINK-9010: --- No, I didn't experience any issues.  > NoR

[GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes

2018-04-03 Thread ShashwatRastogi-Reflektion
Github user ShashwatRastogi-Reflektion commented on the issue: https://github.com/apache/flink/pull/3117 @zentol I am using flink 1.3.2. Normally, I don't use `--allowNonRestoredState` and I get an error while restarting the job. After using this `allowNonRestoredState` the job sta

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424244#comment-16424244 ] ASF GitHub Bot commented on FLINK-5480: --- Github user ShashwatRastogi-Reflektion comm

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424237#comment-16424237 ] Ted Yu commented on FLINK-9087: --- [~NicoK]: Since you were recently working on related code,

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

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

[GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3117 @ShashwatRastogi-Reflektion It's a bit odd that there are different ID's shown, I will have to look into that. It may be that one display accounts for the uid while the other one doesn't; in any case

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

2018-04-03 Thread Triones Deng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424169#comment-16424169 ] Triones Deng commented on FLINK-9087: - [~yuzhih...@gmail.com]   when i run the test. i

[jira] [Created] (FLINK-9126) Ability for CassandraInputFormat to output data into a Custom Cassandra Annotated Pojo

2018-04-03 Thread Jeffrey Carter (JIRA)
Jeffrey Carter created FLINK-9126: - Summary: Ability for CassandraInputFormat to output data into a Custom Cassandra Annotated Pojo Key: FLINK-9126 URL: https://issues.apache.org/jira/browse/FLINK-9126

[jira] [Commented] (FLINK-9076) Make credit-based floating buffers optional

2018-04-03 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424137#comment-16424137 ] Nico Kruber commented on FLINK-9076: The max can already be configured via {{taskmana

[jira] [Updated] (FLINK-9076) Make credit-based floating buffers optional

2018-04-03 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9076: --- Description: Currently, floating buffers (per gate) are always required in case credit-based flow con

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424128#comment-16424128 ] ASF GitHub Bot commented on FLINK-5480: --- Github user ShashwatRastogi-Reflektion comm

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424125#comment-16424125 ] Nico Kruber commented on FLINK-8707: I still need to look at the detailed logs you two

[GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes

2018-04-03 Thread ShashwatRastogi-Reflektion
Github user ShashwatRastogi-Reflektion commented on the issue: https://github.com/apache/flink/pull/3117 Hey @zentol Thank you for replying back. I was trying to do exactly the same thing, but I think I am messing something up that is why it isn't working in my case.

[jira] [Closed] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

2018-04-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6567. Resolution: Fixed Fix Version/s: (was: 1.6.0) 1.5.0 Fixed via master:

[jira] [Closed] (FLINK-9094) AccumulatorLiveITCase unstable on Travis

2018-04-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9094. Resolution: Fixed Fix Version/s: 1.5.0 Fixed via master: 78c3d9b0c657bf06a712ce453edb02da13fa

[jira] [Commented] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

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

[jira] [Commented] (FLINK-9094) AccumulatorLiveITCase unstable on Travis

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

[GitHub] flink pull request #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsT...

2018-04-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5782 ---

[GitHub] flink pull request #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase

2018-04-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5771 ---

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

2018-04-03 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424091#comment-16424091 ] Sihua Zhou commented on FLINK-9120: --- Hi [~dhirajpraj] sorry for the delay reply, I was b

[jira] [Commented] (FLINK-9076) Make credit-based floating buffers optional

2018-04-03 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424083#comment-16424083 ] Piotr Nowojski commented on FLINK-9076: --- [~NicoK], do you mean max should be configu

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178836145 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java --- @@ -107,4 +131,12 @@ public int getAttemptNumber() { public S

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424060#comment-16424060 ] ASF GitHub Bot commented on FLINK-8982: --- Github user florianschmidt1994 commented on

[GitHub] flink issue #5807: [FLINK-8982][E2E Tests] Add test for known failure of que...

2018-04-03 Thread florianschmidt1994
Github user florianschmidt1994 commented on the issue: https://github.com/apache/flink/pull/5807 Thanks! I addressed the changes in the last two commits ---

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827723 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/EmailInformation.java --- @@ -0,0 +1,

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178828967 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsBugPoc.java --- @@ -0,0 +1,133 @@

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178828372 --- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh --- @@ -37,6 +37,14 @@ echo "Flink distribution directory: $FLINK_DIR" EXIT_CODE=0

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827995 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/LabelSurrogate.java --- @@ -0,0 +1,65

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827936 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/LabelSurrogate.java --- @@ -0,0 +1,65

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178829164 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsBugPoc.java --- @@ -0,0 +1,133 @@

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827415 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/EmailInformation.java --- @@ -0,0 +1,

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827698 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/EmailInformation.java --- @@ -0,0 +1,

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827543 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/EmailInformation.java --- @@ -0,0 +1,

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5807#discussion_r178827678 --- Diff: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/EmailInformation.java --- @@ -0,0 +1,

[jira] [Commented] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed

2018-04-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424042#comment-16424042 ] ASF GitHub Bot commented on FLINK-9078: --- Github user florianschmidt1994 commented on

[GitHub] flink pull request #5762: [FLINK-9078][E2ETests] Add test that verifies corr...

2018-04-03 Thread florianschmidt1994
Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5762#discussion_r178828282 --- Diff: flink-end-to-end-tests/flink-avro-classloading-test/src/main/avro/user.avsc --- @@ -0,0 +1,9 @@ +{ + "type": "record", +

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

2018-04-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424035#comment-16424035 ] Till Rohrmann commented on FLINK-9120: -- Hi [~dhirajpraj], the logs show that the JM

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

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

[GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ...

2018-04-03 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5808 [FLINK-8835] [taskmanager] Fix TaskManager config keys ## What is the purpose of the change Fix TaskManager config keys to make it easier for users. ## Brief change log

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178824035 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java --- @@ -107,4 +131,12 @@ public int getAttemptNumber() { public Str

[jira] [Comment Edited] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424006#comment-16424006 ] Alon Galant edited comment on FLINK-8707 at 4/3/18 1:24 PM: He

[jira] [Comment Edited] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424006#comment-16424006 ] Alon Galant edited comment on FLINK-8707 at 4/3/18 1:22 PM: He

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424006#comment-16424006 ] Alon Galant commented on FLINK-8707: Hey,  I have a similar problem, this is my threa

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

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

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

2018-04-03 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178819991 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java --- @@ -107,4 +131,12 @@ public int getAttemptNumber() { public S

[jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alon Galant updated FLINK-8707: --- Attachment: lsof.txt > Excessive amount of files opened by flink task manager > --

[jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alon Galant updated FLINK-8707: --- Attachment: lsofp.txt lsof.txt ll.txt > Excessive amount of files open

[jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alon Galant updated FLINK-8707: --- Attachment: lsofp.txt > Excessive amount of files opened by flink task manager > -

[jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-04-03 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alon Galant updated FLINK-8707: --- Attachment: ll.txt > Excessive amount of files opened by flink task manager >

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

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

[GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3117 @ShashwatRastogi-Reflektion 1. For each task to load from the savepoint S1: * Determine the existing hash by searching for the task ID in the logs/UI * Set the uidHash for that task to

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

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

[GitHub] flink issue #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITCase to ...

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5766 @tillrohrmann Could you take another look? I moved the blob upload into a separate method, ---

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

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

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

2018-04-03 Thread florianschmidt1994
GitHub user florianschmidt1994 opened a pull request: https://github.com/apache/flink/pull/5807 [FLINK-8982][E2E Tests] Add test for known failure of queryable state ## What is the purpose of the change Add an end-to-end test to verify that the changes that @kl0u introduced in

[jira] [Commented] (FLINK-9094) AccumulatorLiveITCase unstable on Travis

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

[jira] [Commented] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

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

[GitHub] flink issue #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsTest

2018-04-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5782 Thanks for the review @zentol. Merging this PR. ---

[GitHub] flink issue #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase

2018-04-03 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5771 Thanks for the review @zentol. Merging this PR. ---

[jira] [Updated] (FLINK-8835) Fix TaskManager config keys

2018-04-03 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8835: Description: Many new config keys in the TaskManager don't follow the proper naming scheme. We need

  1   2   3   >