[jira] [Commented] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-04-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423582#comment-16423582 ] Till Rohrmann commented on FLINK-8771: -- Unblocking 1.5.0 from this issue. > Upgrade

[jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-04-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8771: - Priority: Major (was: Blocker) > Upgrade scalastyle to 1.0.0 > --- > >

[GitHub] flink pull request #5778: [FLINK-8979] (part 1) Make Kafka end-to-end tests ...

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

[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=16423593#comment-16423593 ] Sihua Zhou commented on FLINK-9120: --- Hi [~dhirajpraj] from the log I found that the oper

[jira] [Commented] (FLINK-8979) Extend Kafka end-to-end tests to run with different versions

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

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dhiraj prajapati updated FLINK-9120: Attachment: flink-dhiraj.prajapati-jobmanager-5-ip-10-14-25-115.log > Task Manager Fault Tol

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dhiraj prajapati updated FLINK-9120: Attachment: flink-dhiraj.prajapati-taskmanager-5-ip-10-14-25-116.log > Task Manager Fault To

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dhiraj prajapati updated FLINK-9120: Attachment: flink-dhiraj.prajapati-client-ip-10-14-25-115.log > Task Manager Fault Tolerance

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423609#comment-16423609 ] dhiraj prajapati commented on FLINK-9120: - HI [~sihuazhou], the task managers were

[jira] [Commented] (FLINK-8804) Bump flink-shaded dependency to 3.0

2018-04-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423613#comment-16423613 ] Chesnay Schepler commented on FLINK-8804: - [~till.rohrmann] IMO the jackson change

[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=16423614#comment-16423614 ] Sihua Zhou commented on FLINK-9120: --- Hi [~dhirajpraj] I found some exceptions in your up

[jira] [Updated] (FLINK-9110) Building docs with Ruby 2.5 fails if bundler is not globally installed

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9110: Summary: Building docs with Ruby 2.5 fails if bundler is not globally installed (was: Build

[jira] [Commented] (FLINK-9123) Scala version of ProcessFunction doesn't work

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423628#comment-16423628 ] Aljoscha Krettek commented on FLINK-9123: - This is in regards to the example in th

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

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

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

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

[GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri...

2018-04-03 Thread suez1224
GitHub user suez1224 reopened a pull request: https://github.com/apache/flink/pull/5758 [FLINK-9059][Table API & SQL] add table type attribute; replace "sources" with "tables" in environm… ## What is the purpose of the change Add support for unified table source and sink

[jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file

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

[jira] [Commented] (FLINK-9122) NFASerialize deserailze failed and cause other exception

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423637#comment-16423637 ] Aljoscha Krettek commented on FLINK-9122: - Yes, this is a problem because CEP seri

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423638#comment-16423638 ] dhiraj prajapati commented on FLINK-9120: - Hi [~sihuazhou], As mentioned in the pr

[GitHub] flink issue #5769: [FLINK-9069] Add checkstyle rule to detect multiple conse...

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5769 @jparkie It didn't get lost; i added it to my next batch to merge which didn't grow enough yet for me to commit it. I will merge it this week. ---

[jira] [Commented] (FLINK-9069) Fix some double semicolons to single semicolons, and update checkstyle

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

[jira] [Commented] (FLINK-9051) Invert flip6 profile

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

[GitHub] flink pull request #5743: [FLINK-9051][build] Invert flip6 profile

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

[jira] [Closed] (FLINK-9051) Invert flip6 profile

2018-04-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9051. --- Resolution: Fixed Fixed as part of FLINK-9121... > Invert flip6 profile > ---

[jira] [Closed] (FLINK-9105) Table program compiles failed

2018-04-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9105. --- Resolution: Not A Problem > Table program compiles failed > - > >

[jira] [Reopened] (FLINK-9105) Table program compiles failed

2018-04-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-9105: - > Table program compiles failed > - > > Key: FLINK-9105 >

[jira] [Updated] (FLINK-9105) Table program compiles failed

2018-04-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9105: Fix Version/s: (was: 1.5.0) > Table program compiles failed > - > >

[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=16423662#comment-16423662 ] Sihua Zhou commented on FLINK-9120: --- Hmm...It looks like the JobManager still try to dep

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-04-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r178751990 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -69,6 +73,10 @@ pri

[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=16423668#comment-16423668 ] ASF GitHub Bot commented on FLINK-8966: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8804) Bump flink-shaded dependency to 3.0

2018-04-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423672#comment-16423672 ] Till Rohrmann commented on FLINK-8804: -- Alright, then let's do it this way to quickly

[GitHub] flink pull request #5695: [FLINK-8704][tests] Port PartialConsumerPipelinedR...

2018-04-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5695#discussion_r178752435 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PartialConsumePipelinedResultTest.java --- @@ -32,41 +31,51 @@ impor

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

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

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

2018-04-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r178752746 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -69,6 +73,10 @@

[GitHub] flink issue #5695: [FLINK-8704][tests] Port PartialConsumerPipelinedResultTe...

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5695 IMO it is not a problem to have duplicate code for legacy/new code. Creating a base class is more effort that it is worth, as the legacy version will be removed again in 1.6 we would then have to merg

[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=16423674#comment-16423674 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8205) Multi key get

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423677#comment-16423677 ] Aljoscha Krettek commented on FLINK-8205: - [~sihuazhou] Sounds good! > Multi key

[jira] [Commented] (FLINK-8205) Multi key get

2018-04-03 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423681#comment-16423681 ] Kostas Kloudas commented on FLINK-8205: --- Hi [~sihuazhou]! Here it was holidays the l

[GitHub] flink pull request #5790: [FLINK-9107][docs] document timer coalescing for P...

2018-04-03 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5790#discussion_r178754487 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -269,4 +269,38 @@ override def onTimer(timestamp: Long, ctx: OnTimerContext, out: Collector[O

[jira] [Commented] (FLINK-9107) Document timer coalescing for ProcessFunctions

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

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

2018-04-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5697#discussion_r178754924 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/LegacyScheduleOrUpdateConsumersTest.java --- @@ -0,0 +1,168 @@ +/* + * Lice

[jira] [Reopened] (FLINK-8891) RestServerEndpoint can bind on local address only

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8891: - Reopen to change fix version   > RestServerEndpoint can bind on local address only > ---

[jira] [Updated] (FLINK-8891) RestServerEndpoint can bind on local address only

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8891: Fix Version/s: 1.5.0 > RestServerEndpoint can bind on local address only > -

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

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

[jira] [Closed] (FLINK-8891) RestServerEndpoint can bind on local address only

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8891. --- Resolution: Fixed > RestServerEndpoint can bind on local address only > --

[jira] [Commented] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423690#comment-16423690 ] Aljoscha Krettek commented on FLINK-7219: - [~sihuazhou] Don't worry. 😃 > Current

[GitHub] flink issue #5790: [FLINK-9107][docs] document timer coalescing for ProcessF...

2018-04-03 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5790 thanks - fixed and extended with an example for "schedule with the next watermark" for event-time timers ---

[jira] [Commented] (FLINK-9107) Document timer coalescing for ProcessFunctions

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

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

2018-04-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5697#discussion_r178756067 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/LegacyScheduleOrUpdateConsumersTest.java --- @@ -0,0 +1,168 @@ +/* +

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

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

[GitHub] flink issue #5596: [FLINK-8804][Build] Integrate flink-shaded 3.0

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5596 I've rebased the PR and minimized it to only contain the jackson changes. ---

[jira] [Commented] (FLINK-8804) Bump flink-shaded dependency to 3.0

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

[GitHub] flink issue #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumersTest

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

[GitHub] flink issue #5772: [FLINK-8963][tests] Port BigUserProgramJobSubmitITCase to...

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

[GitHub] flink issue #5694: [FLINK-8704][tests] Port SlotCountExceedingParallelismTes...

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

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

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

[GitHub] flink issue #5664: [FLINK-8703][tests] Port CancelingTestBase to MiniCluster...

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

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

2018-04-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9120: Priority: Blocker (was: Critical) > Task Manager Fault Tolerance issue > --

[jira] [Commented] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6

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

[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_r178758895 --- Diff: flink-end-to-end-tests/flink-avro-classloading-test/src/main/avro/user.avsc --- @@ -0,0 +1,9 @@ +{ + "type": "record", +

[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=16423709#comment-16423709 ] ASF GitHub Bot commented on FLINK-9078: --- Github user florianschmidt1994 commented on

[jira] [Updated] (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:all-tabpanel ] Till Rohrmann updated FLINK-9120: - Priority: Critical (was: Blocker) > Task Manager Fault Tolerance issue >

[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=16423712#comment-16423712 ] Till Rohrmann commented on FLINK-9120: -- In order to properly recover from TM failures

[jira] [Assigned] (FLINK-9008) End-to-end test: Quickstarts

2018-04-03 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9008: --- Assignee: mingleizhang > End-to-end test: Quickstarts > > >

[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=16423730#comment-16423730 ] ASF GitHub Bot commented on FLINK-8966: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2018-04-03 Thread Amit Jain (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Jain updated FLINK-2685: - Attachment: job_manager_19_feb_15_30_running task_manager_19_feb_15_30_running > TaskManag

[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 I've updated the PR. * check whether there are jars to upload * de-duplicate jar upload code * reverted changes to the MiniClusterResource * added a legacy version of the t

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423732#comment-16423732 ] dhiraj prajapati commented on FLINK-9120: - Hi [~sihuazhou], I tried restarting the

[jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2018-04-03 Thread Amit Jain (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423717#comment-16423717 ] Amit Jain commented on FLINK-2685: -- [~uce] [~StephanEwen] We are also facing the same iss

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423732#comment-16423732 ] dhiraj prajapati edited comment on FLINK-9120 at 4/3/18 9:29 AM: ---

[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=16423739#comment-16423739 ] Sihua Zhou commented on FLINK-9120: --- Hi [~dhirajpraj] happy to know that it working fine

[jira] [Comment Edited] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2018-04-03 Thread Amit Jain (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423717#comment-16423717 ] Amit Jain edited comment on FLINK-2685 at 4/3/18 9:35 AM: -- [~uce]

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

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5771 I've run the test 10k+ times on my machine without a failure, +1 from my side. ---

[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=16423755#comment-16423755 ] ASF GitHub Bot commented on FLINK-9094: --- Github user zentol commented on the issue:

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

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5771 whoops, that last comment was for the wrong PR... ---

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423753#comment-16423753 ] dhiraj prajapati commented on FLINK-9120: - Hi [~till.rohrmann], with MemoryStateBa

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

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5782 I've run the test 10k+ times on my machine without a failure, +1 from my side. ---

[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=16423757#comment-16423757 ] ASF GitHub Bot commented on FLINK-9094: --- Github user zentol commented on the issue:

[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=16423758#comment-16423758 ] ASF GitHub Bot commented on FLINK-6567: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-9122) NFASerialize deserailze failed and cause other exception

2018-04-03 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423762#comment-16423762 ] aitozi commented on FLINK-9122: --- thanks [~aljoscha] ,still have two question 1. Why the exc

[GitHub] flink pull request #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClus...

2018-04-03 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5669#discussion_r178769136 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java --- @@ -1063,23 +1

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[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_r178770011 --- 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-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=16423776#comment-16423776 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a d

[GitHub] flink issue #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClusterReso...

2018-04-03 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5669 I've rebased and updated the PR. The `JobManagerCommunicationUtils` were reworked into a `ClusterCommunicationUtils`. All contained methods were now unused. We are also using `Iterables.getOn

[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_r178770202 --- Diff: flink-end-to-end-tests/test-scripts/common.sh --- @@ -176,10 +176,40 @@ function s3_delete { https://${bucket}.s3.amazonaws.com/${s3

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[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=16423780#comment-16423780 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a d

[GitHub] flink issue #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMachineEx...

2018-04-03 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5750 Thank you @kl0u. I found a little bug that I will fix. Merging... ---

[jira] [Commented] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode

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

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

2018-04-03 Thread dhiraj prajapati (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423787#comment-16423787 ] dhiraj prajapati commented on FLINK-9120: - Hi [~till.rohrmann]/[~sihuazhou], find

[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_r178771748 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink issue #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMachineEx...

2018-04-03 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5750 Thanks a lot @twalthr for the review! ---

[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_r178771812 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[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_r178771774 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[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=16423797#comment-16423797 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a d

[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=16423793#comment-16423793 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a d

  1   2   3   >