[GitHub] flink pull request #3795: Cleanup useless import for packages.scala External...

2017-04-28 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3795 Cleanup useless import for packages.scala ExternalCatalogTable arithm… In this PR cleanup some useless reference in the following files: 1. packages.scala 2. ExternalCatalogTable

[jira] [Commented] (FLINK-6406) Cleanup useless import

2017-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988325#comment-15988325 ] ASF GitHub Bot commented on FLINK-6406: --- GitHub user sunjincheng121 opened a pull re

[GitHub] flink issue #3783: [FLINK-6388] Add support for DISTINCT into Code Generated...

2017-04-28 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3783 Hi @huawei-flink, I did not say that we need to move the state out of the code-gen'd function. We can and should leave the PR as it is. However, we cannot use this code for distinct group wi

[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

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

[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3744 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-5975) Mesos should support adding volumes to launched taskManagers

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

[GitHub] flink pull request #3481: [FLINK-5975] Add volume support to flink-mesos

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3481 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-6336) Placement Constraints for Mesos

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

[jira] [Updated] (FLINK-6336) Placement Constraints for Mesos

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6336: - Fix Version/s: 1.3.0 > Placement Constraints for Mesos > --- > >

[jira] [Assigned] (FLINK-6336) Placement Constraints for Mesos

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6336: Assignee: Stephen Gran > Placement Constraints for Mesos > ---

[jira] [Resolved] (FLINK-5975) Mesos should support adding volumes to launched taskManagers

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5975. -- Resolution: Fixed Fix Version/s: 1.3.0 Added via 4ef9672a9da78bc4ce02e56d9ecdcc546da23e42

[jira] [Resolved] (FLINK-6336) Placement Constraints for Mesos

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6336. -- Resolution: Fixed Added via 8ef6926f3c735fb4e111379fb1edab5184bc7458 > Placement Constraints fo

[jira] [Created] (FLINK-6407) Upgrade AVRO dependency version to 1.8.x

2017-04-28 Thread Miguel (JIRA)
Miguel created FLINK-6407: - Summary: Upgrade AVRO dependency version to 1.8.x Key: FLINK-6407 URL: https://issues.apache.org/jira/browse/FLINK-6407 Project: Flink Issue Type: Wish Component

[jira] [Resolved] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6287. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 926547582d62733bdedb1cdcc277653b2ff7b4e7

[jira] [Assigned] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6287: Assignee: Till Rohrmann > Flakey JobManagerRegistrationTest > -

[jira] [Commented] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows

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

[GitHub] flink issue #3765: [FLINK-6373] Add runtime support for distinct aggregation...

2017-04-28 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3765 Hi @haohui, I suggested before that PR #3771 might be used for DISTINCT group window functions. However, this does not work because we cannot register state for an AggregateFunction. The be

[GitHub] flink issue #3560: [FLINK-6097][table] Guaranteed the order of the extracted...

2017-04-28 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3560 Can you close this PR as well @sunjincheng121? Thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not hav

[jira] [Commented] (FLINK-6097) Guaranteed the order of the extracted field references

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

[jira] [Assigned] (FLINK-6293) Flakey JobManagerITCase

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6293: Assignee: Till Rohrmann > Flakey JobManagerITCase > --- > >

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988390#comment-15988390 ] Till Rohrmann commented on FLINK-6293: -- I think the problem is that in the "handle tr

[GitHub] flink pull request #3796: [FLINK-6293] [tests] Harden JobManagerITCase

2017-04-28 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3796 [FLINK-6293] [tests] Harden JobManagerITCase One of the unit tests in JobManagerITCase starts a MiniCluster and sends a LeaderSessionMessage to the JobManager without waiting until the JobMa

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

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

[GitHub] flink pull request #3794: [FLINK-6398] RowSerializer's duplicate should alwa...

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3794 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-6398) RowSerializer's duplicate should always return a new instance

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

[jira] [Closed] (FLINK-6398) RowSerializer's duplicate should always return a new instance

2017-04-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6398. - Resolution: Fixed Fix Version/s: 1.3.0 > RowSerializer's duplicate should always return a new insta

[GitHub] flink issue #3790: [FLINK-6395] [tests] Mark test bases as abstract

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3790 Not sure whether marking classes without abstract methods abstract makes sense. If we want to prevent instantiations of these classes we could make the constructor also protected. --- If your

[jira] [Commented] (FLINK-6395) TestBases not marked as abstract

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

[jira] [Created] (FLINK-6408) Repeated loading of configuration files in hadoop filesystem code paths

2017-04-28 Thread Stephen Gran (JIRA)
Stephen Gran created FLINK-6408: --- Summary: Repeated loading of configuration files in hadoop filesystem code paths Key: FLINK-6408 URL: https://issues.apache.org/jira/browse/FLINK-6408 Project: Flink

[jira] [Commented] (FLINK-6360) Failed to create assembly for Scala 2.11 due to tools/change-scala-version.sh not changing flink-gelly-examples_2.10

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988430#comment-15988430 ] Till Rohrmann commented on FLINK-6360: -- I just tried putting {{scala.binary.version}}

[GitHub] flink issue #3780: [FLINK-6274] Replaces usages of org.codehaus.jackson

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3780 Changes look good to me. +1 for merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this featur

[jira] [Commented] (FLINK-6274) Replace usages of org.codehaus.jackson

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

[GitHub] flink issue #3790: [FLINK-6395] [tests] Mark test bases as abstract

2017-04-28 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3790 As you can see in the `UnaryOperatorTestBase` the constructor is already protected. The thing is that junit complains since the classes contain junit annotations (`@After`, `@Parameterized`) class but

[jira] [Created] (FLINK-6409) TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

2017-04-28 Thread Timo Walther (JIRA)
Timo Walther created FLINK-6409: --- Summary: TUMBLE/HOP/SESSION_START/END do not resolve time field correctly Key: FLINK-6409 URL: https://issues.apache.org/jira/browse/FLINK-6409 Project: Flink

[jira] [Commented] (FLINK-6395) TestBases not marked as abstract

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

[GitHub] flink issue #3775: [FLINK-6386] [documentation] Missing bracket in 'Compiler...

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3775 LGTM. Thanks for your contribution @bowenli86. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project do

[jira] [Commented] (FLINK-6386) Missing bracket in 'Compiler Limitation' section

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

[jira] [Created] (FLINK-6410) build fails after changing Scala to 2.11

2017-04-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6410: --- Summary: build fails after changing Scala to 2.11 Key: FLINK-6410 URL: https://issues.apache.org/jira/browse/FLINK-6410 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988538#comment-15988538 ] ASF GitHub Bot commented on FLINK-6376: --- Github user Rucongzhang commented on the is

[GitHub] flink issue #3776: [FLINK-6376]when deploy flink cluster on the yarn, it is ...

2017-04-28 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3776 @StephanEwen , yes, i agree with you! I will see how to add the Yarn IT case. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Resolved] (FLINK-6386) Missing bracket in 'Compiler Limitation' section

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6386. -- Resolution: Fixed Fix Version/s: (was: 1.2.2) 1.3.0 Fixed via 7537

[GitHub] flink pull request #3775: [FLINK-6386] [documentation] Missing bracket in 'C...

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3775 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-6386) Missing bracket in 'Compiler Limitation' section

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

[GitHub] flink issue #3783: [FLINK-6388] Add support for DISTINCT into Code Generated...

2017-04-28 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3783 @fhueske thanks for the clarification. I think it is good also to have the solution for the over windows :) I also wanted to ask you about the calcite and DISTINCT/DIST syntax. What do you

[jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations

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

[GitHub] flink pull request #2696: [FLINK-3347] [akka] Add QuarantineMonitor which sh...

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2696 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

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

[jira] [Resolved] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3347. -- Resolution: Fixed Fix Version/s: 1.3.0 Added via 1.3.0: bdf5c486f50b262dc09678a6c15790c5

[GitHub] flink issue #3730: [FLINK-5943] [YARN] Fix unprotected access to haServices ...

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3730 Hi @zhangminglei, I think the logic to access the `RunningJobsRegistry` from the `YarnApplicationMasterRunner` is wrong. The decision to clear a job or not should be done by the `JobManagerRunne

[jira] [Commented] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

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

[jira] [Created] (FLINK-6411) YarnApplicationMasterRunner should not interfere with RunningJobsRegistry

2017-04-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6411: Summary: YarnApplicationMasterRunner should not interfere with RunningJobsRegistry Key: FLINK-6411 URL: https://issues.apache.org/jira/browse/FLINK-6411 Project: Flin

[GitHub] flink pull request #3730: [FLINK-5943] [YARN] Fix unprotected access to haSe...

2017-04-28 Thread zhangminglei
Github user zhangminglei closed the pull request at: https://github.com/apache/flink/pull/3730 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature i

[jira] [Commented] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

2017-04-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988595#comment-15988595 ] ASF GitHub Bot commented on FLINK-5943: --- Github user zhangminglei closed the pull re

[GitHub] flink issue #3730: [FLINK-5943] [YARN] Fix unprotected access to haServices ...

2017-04-28 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3730 @tillrohrmann Thanks for telling me so useful information. very appreciate it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

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

[jira] [Closed] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

2017-04-28 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang closed FLINK-5943. --- Resolution: Unresolved > Unprotected access to haServices in > YarnFlinkApplicationMasterRunner#shutd

[GitHub] flink pull request #3797: [FLINK-6411] [flip-6] Remove job removal from Runn...

2017-04-28 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3797 [FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown The YarnFlinkApplicationMasterRunner should not be concerned with removing jobs f

[jira] [Commented] (FLINK-6411) YarnApplicationMasterRunner should not interfere with RunningJobsRegistry

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

[GitHub] flink issue #3745: [FLINK-6341]Don't let JM fall into infinite loop

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3745 Thanks for your contribution @WangTaoTheTonic. Changes look good to me. Merging your PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[GitHub] flink pull request #3770: [FLINK-5892] Restore state on the operator level

2017-04-28 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3770#discussion_r113898244 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java --- @@ -125,6 +132,8 @@ public JobVertex(String name) {

[jira] [Commented] (FLINK-6341) JobManager can go to definite message sending loop when TaskManager registered

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

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

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

[jira] [Created] (FLINK-6412) Stream has already been closed durign job cancel

2017-04-28 Thread Andrey (JIRA)
Andrey created FLINK-6412: - Summary: Stream has already been closed durign job cancel Key: FLINK-6412 URL: https://issues.apache.org/jira/browse/FLINK-6412 Project: Flink Issue Type: Bug Affects

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

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

[GitHub] flink pull request #3770: [FLINK-5892] Restore state on the operator level

2017-04-28 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3770#discussion_r113903349 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java --- @@ -125,6 +132,8 @@ public JobVertex(String name) { public

[GitHub] flink issue #3796: [FLINK-6293] [tests] Harden JobManagerITCase

2017-04-28 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3796 Good fix. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

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

[jira] [Commented] (FLINK-6360) Failed to create assembly for Scala 2.11 due to tools/change-scala-version.sh not changing flink-gelly-examples_2.10

2017-04-28 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988663#comment-15988663 ] Greg Hogan commented on FLINK-6360: --- [~till.rohrmann] I tried to remove use of `change-s

[GitHub] flink pull request #3785: [FLINK-6337][network] Remove the buffer provider f...

2017-04-28 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3785#discussion_r113904383 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -68,7 +68,11 @@ public static void shu

[jira] [Commented] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

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

[GitHub] flink pull request #3785: [FLINK-6337][network] Remove the buffer provider f...

2017-04-28 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3785#discussion_r113905412 --- Diff: flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java --- @@ -68,7 +68,6 @@ public void testSuccessfulProg

[jira] [Commented] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

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

[jira] [Updated] (FLINK-6412) Stream has already been closed during job cancel

2017-04-28 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6412: Summary: Stream has already been closed during job cancel (was: Stream has already been closed duri

[jira] [Commented] (FLINK-6399) Update default Hadoop download version

2017-04-28 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988694#comment-15988694 ] mingleizhang commented on FLINK-6399: - Hi, I would like to fix this issue. I can not f

[jira] [Comment Edited] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount

2017-04-28 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988704#comment-15988704 ] mingleizhang edited comment on FLINK-6362 at 4/28/17 12:00 PM: -

[jira] [Commented] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount

2017-04-28 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988704#comment-15988704 ] mingleizhang commented on FLINK-6362: - Hi, [~tedyu] Thanks for this jira. But I would

[jira] [Commented] (FLINK-6410) build fails after changing Scala to 2.11

2017-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988714#comment-15988714 ] Dawid Wysakowicz commented on FLINK-6410: - There are multiple JIRAs already referr

[jira] [Commented] (FLINK-6398) RowSerializer's duplicate should always return a new instance

2017-04-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988721#comment-15988721 ] Aljoscha Krettek commented on FLINK-6398: - [~ykt836] and/or [~tzulitai]: Did you t

[GitHub] flink issue #3698: [FLINK-6208][cep] Implement skip till next match strategy

2017-04-28 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3698 Hi @dawidwys. Thanks for the work. I merged this. Could you close the PR and the related JIRA? --- If your project is set up for it, you can reply to this email and have your reply appear on G

[GitHub] flink pull request #3770: [FLINK-5892] Restore state on the operator level

2017-04-28 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3770#discussion_r113919931 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java --- @@ -125,6 +132,8 @@ public JobVertex(String name) {

[jira] [Commented] (FLINK-6208) Implement skip till next match strategy

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

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

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

[jira] [Created] (FLINK-6413) Add stream operator callback to notify about consumed network buffer

2017-04-28 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6413: --- Summary: Add stream operator callback to notify about consumed network buffer Key: FLINK-6413 URL: https://issues.apache.org/jira/browse/FLINK-6413 Project: Fl

[GitHub] flink pull request #3698: [FLINK-6208][cep] Implement skip till next match s...

2017-04-28 Thread dawidwys
Github user dawidwys closed the pull request at: https://github.com/apache/flink/pull/3698 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[jira] [Resolved] (FLINK-6208) Implement skip till next match strategy

2017-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-6208. - Resolution: Fixed > Implement skip till next match strategy >

[jira] [Assigned] (FLINK-3870) Add IntelliJ code style file

2017-04-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-3870: --- Assignee: (was: Dawid Wysakowicz) > Add IntelliJ code style file > --

[jira] [Commented] (FLINK-6208) Implement skip till next match strategy

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

[GitHub] flink issue #3796: [FLINK-6293] [tests] Harden JobManagerITCase

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3796 Thanks for the review @uce. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this fe

[jira] [Commented] (FLINK-3320) Add not operator to CEP's pattern API

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

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

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

[GitHub] flink pull request #3798: [FLINK-3320] Add not operator to CEP's pattern API

2017-04-28 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3798 [FLINK-3320] Add not operator to CEP's pattern API Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your c

[GitHub] flink pull request #3796: [FLINK-6293] [tests] Harden JobManagerITCase

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3796 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

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

[jira] [Resolved] (FLINK-6293) Flakey JobManagerITCase

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6293. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed via f3da8f69e99be49068ab4ea3abc5e1c4eba7bf32

[GitHub] flink pull request #3394: [FLINK-5810] [flip6] Introduce a hardened slot man...

2017-04-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3394 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-5810) Harden SlotManager

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

[jira] [Closed] (FLINK-5810) Harden SlotManager

2017-04-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5810. Resolution: Fixed Fix Version/s: 1.3.0 Added via d75ec5b3551573d4eb1886c8e75dfdf6dc328da1 >

[GitHub] flink issue #3797: [FLINK-6411] [flip-6] Remove job removal from RunningJobs...

2017-04-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3797 Merging this PR since changes are trivial and Travis gave green light. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pro

[jira] [Commented] (FLINK-6411) YarnApplicationMasterRunner should not interfere with RunningJobsRegistry

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

[jira] [Created] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh

2017-04-28 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6414: - Summary: Use scala.binary.version in place of change-scala-version.sh Key: FLINK-6414 URL: https://issues.apache.org/jira/browse/FLINK-6414 Project: Flink Issue T

  1   2   >