[GitHub] flink pull request #4208: [FLINK-7004] Switch to Travis Trusty image

2017-06-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4208 --- 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-7004) Switch to Travis Trusty image

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

[GitHub] flink pull request #4207: [FLINK-7004] Switch to Travis Trusty image

2017-06-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4207 --- 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

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-06-29 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4213 Yes. Should I not do this? --- 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 wis

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067894#comment-16067894 ] ASF GitHub Bot commented on FLINK-7032: --- Github user pnowojski commented on the issu

[jira] [Commented] (FLINK-7004) Switch to Travis Trusty image

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

[jira] [Closed] (FLINK-7004) Switch to Travis Trusty image

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7004. --- Resolution: Fixed 1.2: 3fcc959dd4d3c65436b44bb22848cf2565461de2 1.3: 001df19797e5155f0c6dff06e

[GitHub] flink pull request #4146: [FLINK-6008][blob] collection of BlobServer improv...

2017-06-29 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4146#discussion_r124728498 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java --- @@ -227,7 +227,7 @@ static File getStorageLocation(File storageDir,

[GitHub] flink pull request #4146: [FLINK-6008][blob] collection of BlobServer improv...

2017-06-29 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4146#discussion_r124730014 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerPutTest.java --- @@ -59,6 +60,110 @@ private final Random rnd

[GitHub] flink pull request #4146: [FLINK-6008][blob] collection of BlobServer improv...

2017-06-29 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4146#discussion_r124727496 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java --- @@ -593,9 +594,7 @@ private void sendPutHeader(OutputStream outputS

[GitHub] flink pull request #4146: [FLINK-6008][blob] collection of BlobServer improv...

2017-06-29 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4146#discussion_r124727900 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java --- @@ -509,21 +509,7 @@ private void delete(InputStream inp

[jira] [Commented] (FLINK-6008) collection of BlobServer improvements

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067917#comment-16067917 ] ASF GitHub Bot commented on FLINK-6008: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-6008) collection of BlobServer improvements

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067919#comment-16067919 ] ASF GitHub Bot commented on FLINK-6008: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-6008) collection of BlobServer improvements

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067920#comment-16067920 ] ASF GitHub Bot commented on FLINK-6008: --- Github user pnowojski commented on a diff i

[jira] [Commented] (FLINK-6008) collection of BlobServer improvements

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067918#comment-16067918 ] ASF GitHub Bot commented on FLINK-6008: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4220: [FLINK-6665] Pass a ScheduledExecutorService to th...

2017-06-29 Thread zjureel
GitHub user zjureel opened a pull request: https://github.com/apache/flink/pull/4220 [FLINK-6665] Pass a ScheduledExecutorService to the RestartStrategy … avoid any sleeps. Thanks for contributing to Apache Flink. Before you open your pull request, please take the followi

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067945#comment-16067945 ] ASF GitHub Bot commented on FLINK-6584: --- Github user wuchong commented on a diff in

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

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

[GitHub] flink pull request #4199: [FLINK-6584] [table] Support multiple consecutive ...

2017-06-29 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4199#discussion_r124733642 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala --- @@ -54,34 +56,75 @@ cla

[GitHub] flink pull request #4199: [FLINK-6584] [table] Support multiple consecutive ...

2017-06-29 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4199#discussion_r124725025 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala --- @@ -54,34 +56,75 @@ cla

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067946#comment-16067946 ] ASF GitHub Bot commented on FLINK-6584: --- Github user wuchong commented on a diff in

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-29 Thread njzhuyuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067935#comment-16067935 ] njzhuyuqi commented on FLINK-6991: -- Hi, [~mingleizhang] I found a solution for how to fi

[jira] [Commented] (FLINK-6008) collection of BlobServer improvements

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067956#comment-16067956 ] ASF GitHub Bot commented on FLINK-6008: --- Github user NicoK commented on a diff in th

[GitHub] flink pull request #4146: [FLINK-6008][blob] collection of BlobServer improv...

2017-06-29 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4146#discussion_r124734798 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerPutTest.java --- @@ -59,6 +60,110 @@ private final Random rnd = ne

[GitHub] flink issue #4195: [FLINK-7008] [cep] Update NFA state only when the NFA cha...

2017-06-29 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4195 Thanks for the work @dianfu! It looks good now. Let's just wait for travis to give green on it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-7008) Update NFA state only when the NFA changes.

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

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-29 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067966#comment-16067966 ] mingleizhang commented on FLINK-6991: - Thanks [~njzhuyuqi] for keep watching this. I w

[GitHub] flink issue #4198: [Temporary] Running Mesos ResourceManager on Travis

2017-06-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4198 @tillrohrmann Can you close this PR? 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 have this feature

[GitHub] flink issue #4172: [FLINK-6983] [cep] Do not serialize States with NFA

2017-06-29 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4172 Yes @twalthr , you are right, the cause is different classloader. The compiled class is under Janino's custom ClassLoader. Using the current thread's classloader or user code classloader can't load t

[jira] [Commented] (FLINK-6983) Do not serialize States with NFA

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

[GitHub] flink issue #4187: [FLINK-6998][Kafka Connector] Add kafka offset commit met...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4187 I agree. "commits-succeeded" and "commits-failed" seems good! --- 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

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[GitHub] flink issue #4187: [FLINK-6998][Kafka Connector] Add kafka offset commit met...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4187 > I'll not include the other proposed metric in this PR just for the sake of simplicity. I also have some opinions on "offset lag" metric, I think this particular metric is more useful when some ext

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-29 Thread njzhuyuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067994#comment-16067994 ] njzhuyuqi commented on FLINK-6991: -- hi,[~mingleizhang] i would suggest to pick the 0.9 r

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-29 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067998#comment-16067998 ] mingleizhang commented on FLINK-6991: - Maybe Greg Hogan could share some light on it,

[GitHub] flink issue #4153: [FLINK-6927] [cep] Support pattern group in CEP

2017-06-29 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4153 @dianfu sorry I have not reviewed it yet, but I do think this feature would benefit from reworking of the Pattern API I propose in [FLINK-3414](https://issues.apache.org/jira/browse/FLINK-3414).

[jira] [Commented] (FLINK-6927) Support pattern group in CEP

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

[GitHub] flink issue #4172: [FLINK-6983] [cep] Do not serialize States with NFA

2017-06-29 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4172 Hi @wuchong . I am not an expert in Janino and how it works but I do not think you need Janino's classloader at any point. Using the `open()` of the `CEPOperator` you just need to compile the code of th

[jira] [Commented] (FLINK-6983) Do not serialize States with NFA

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

[jira] [Created] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Aegeaner (JIRA)
Aegeaner created FLINK-7036: --- Summary: Type cast in ExpressionReducer's reduce broke CodeGen's compile stage Key: FLINK-7036 URL: https://issues.apache.org/jira/browse/FLINK-7036 Project: Flink Is

[GitHub] flink issue #4187: [FLINK-6998][Kafka Connector] Add kafka offset commit met...

2017-06-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4187 Please follow the camel-case pattern that we use for other metrics. --- 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

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[GitHub] flink pull request #4198: [Temporary] Running Mesos ResourceManager on Travi...

2017-06-29 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/4198 --- 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] [Assigned] (FLINK-7037) Remove scala suffix from flink-examples module

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7037: --- Assignee: Chesnay Schepler > Remove scala suffix from flink-examples module > ---

[jira] [Created] (FLINK-7037) Remove scala suffix from flink-examples module

2017-06-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7037: --- Summary: Remove scala suffix from flink-examples module Key: FLINK-7037 URL: https://issues.apache.org/jira/browse/FLINK-7037 Project: Flink Issue Type

[GitHub] flink pull request #4221: [FLINK-7037] Remove scala suffic from flink-exampl...

2017-06-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4221 [FLINK-7037] Remove scala suffic from flink-examples module This PR removes the scala version suffix from the flink-examples module. The suffix prevented building single modules that rely on

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

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

[GitHub] flink issue #3746: [FLINK-4022] [kafka] Partition and topic discovery for Fl...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3746 Hi @aljoscha, I've rebased this PR, fixed the previous blocking issue (discovery enabling & restoring from round-robin list state), and added documentation for the limitation. Could you have another

[jira] [Updated] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-06-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner updated FLINK-7032: Component/s: Build System > Intellij is constantly changing language level of sub projects back to 1.6 > --

[jira] [Updated] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7038: --- Labels: starter (was: ) > Several misused "KeyedDataStream" term in docs and Javadocs

[jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-06-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6109: --- Labels: starter (was: ) > Add "consumer lag" report metric to FlinkKafkaConsumer > --

[jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-06-29 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6109: --- Labels: (was: starter) > Add "consumer lag" report metric to FlinkKafkaConsumer > --

[jira] [Created] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7038: -- Summary: Several misused "KeyedDataStream" term in docs and Javadocs Key: FLINK-7038 URL: https://issues.apache.org/jira/browse/FLINK-7038 Project: Flink

[jira] [Created] (FLINK-7039) Increase forkCountTestPackage for sudo-based Trav

2017-06-29 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-7039: - Summary: Increase forkCountTestPackage for sudo-based Trav Key: FLINK-7039 URL: https://issues.apache.org/jira/browse/FLINK-7039 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7039) Increase forkCountTestPackage for sudo-based TravisCI

2017-06-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7039: -- Description: The switch from the container-based to sudo-enabled environment in TravisCI has increased a

[jira] [Updated] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

2017-06-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7039: -- Description: The switch from the container-based to sudo-enabled environment in TravisCI has increased

[jira] [Assigned] (FLINK-4968) Replace direct JobManager ActorGateways by JobManagerGateway

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4968: Assignee: (was: Till Rohrmann) > Replace direct JobManager ActorGateways by JobManagerG

[jira] [Updated] (FLINK-4968) Replace direct JobManager ActorGateways by JobManagerGateway

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4968: - Labels: flip-6 (was: ) > Replace direct JobManager ActorGateways by JobManagerGateway > -

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaming Examp...

2017-06-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r124667797 --- Diff: flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test/StreamingExamplesITCase.java --- @@ -0,0 +1,135 @@ +pack

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaming Examp...

2017-06-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r124658452 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java --- @@ -70,9 +70,7 @@ pu

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaming Examp...

2017-06-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r124658613 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/GroupedProcessingTimeWindowExample.java --- @@

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaming Examp...

2017-06-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r124658721 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/GroupedProcessingTimeWindowExample.java --- @@

[jira] [Updated] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

2017-06-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7039: -- Description: The switch from the container-based to sudo-enabled environment in TravisCI has increased

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaming Examp...

2017-06-29 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r124667752 --- Diff: flink-examples/flink-examples-streaming/src/test/scala/org/apache/flink/streaming/scala/examples/StreamingExamplesITCase.scala --- @@ -0,0 +1,136

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068149#comment-16068149 ] ASF GitHub Bot commented on FLINK-3551: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068150#comment-16068150 ] ASF GitHub Bot commented on FLINK-3551: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068152#comment-16068152 ] ASF GitHub Bot commented on FLINK-3551: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068151#comment-16068151 ] ASF GitHub Bot commented on FLINK-3551: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068148#comment-16068148 ] ASF GitHub Bot commented on FLINK-3551: --- Github user fhueske commented on a diff in

[jira] [Updated] (FLINK-7039) Increase forkCountTestPackage for sudo-based TravisCI

2017-06-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7039: -- Summary: Increase forkCountTestPackage for sudo-based TravisCI (was: Increase forkCountTestPackage for

[jira] [Updated] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

2017-06-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-7039: -- Summary: Increase forkCountTestPackage for sudo-enabled TravisCI (was: Increase forkCountTestPackage fo

[jira] [Commented] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068189#comment-16068189 ] Chesnay Schepler commented on FLINK-7039: - I've tried this out but didn't really i

[GitHub] flink pull request #4222: [FLINK-7039] [build] Increase forkCountTestPackage...

2017-06-29 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4222 [FLINK-7039] [build] Increase forkCountTestPackage for sudo-enabled TravisCI The switch from the container-based to sudo-enabled environment in TravisCI has increased available memory from 4 GB to

[jira] [Commented] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

2017-06-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068202#comment-16068202 ] Greg Hogan commented on FLINK-7039: --- Even a small improvement is worthwhile. > Increase

[jira] [Commented] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

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

[GitHub] flink issue #4222: [FLINK-7039] [build] Increase forkCountTestPackage for su...

2017-06-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4222 +1. --- 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

[jira] [Commented] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

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

[jira] [Commented] (FLINK-6434) There may be allocatedSlots leak in SlotPool

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068237#comment-16068237 ] Till Rohrmann commented on FLINK-6434: -- Hi [~tiemsn], what's the state of the fix? Ar

[jira] [Commented] (FLINK-5857) Recycle idle containers in time for yarn mode

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068240#comment-16068240 ] Till Rohrmann commented on FLINK-5857: -- Can we close this issue [~tiemsn]? > Recycle

[GitHub] flink issue #3398: [FLINK-5856] [FLIP-6] return redundant containers to yarn...

2017-06-29 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3398 Just wanted to check what's the state of this PR? Do you have time to address the review comments @shuai-xu? --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Commented] (FLINK-5856) Need return redundant containers to yarn for yarn mode

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

[jira] [Resolved] (FLINK-5254) Implement Yarn HA Services

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5254. -- Resolution: Fixed Added via 2a7dbda79a00863a511fcf64b339770d1d00f805 > Implement Yarn HA Servic

[jira] [Updated] (FLINK-4926) Implement FLIP-6 Flink-on-YARN jobs

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4926: - Labels: flip-6 (was: ) > Implement FLIP-6 Flink-on-YARN jobs > --

[jira] [Resolved] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5238. -- Resolution: Fixed Fixed via 440e7571a9c91fd1e01addff1b5370563db96abc > Flip-6 mini cluster shou

[jira] [Updated] (FLINK-4755) Create ContainerID; Rename ResourceID into ProcessID and InstanceID into RegistrationID

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4755: - Priority: Major (was: Minor) > Create ContainerID; Rename ResourceID into ProcessID and InstanceI

[jira] [Updated] (FLINK-4927) Implement FLIP-6 YARN Resource Manager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4927: - Summary: Implement FLIP-6 YARN Resource Manager (was: Implement FLI-6 YARN Resource Manager) > I

[jira] [Updated] (FLINK-4928) Implement FLIP-6 YARN Application Master Runner

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4928: - Labels: flip-6 (was: ) > Implement FLIP-6 YARN Application Master Runner > --

[jira] [Updated] (FLINK-4986) Harden JobMaster logic

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4986: - Labels: flip-6 (was: ) > Harden JobMaster logic > -- > > Key:

[jira] [Updated] (FLINK-4927) Implement FLIP-6 YARN Resource Manager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4927: - Labels: flip-6 (was: ) > Implement FLIP-6 YARN Resource Manager > ---

[jira] [Updated] (FLINK-4344) Implement new JobManager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4344: - Labels: flip-6 (was: ) > Implement new JobManager > > >

[jira] [Updated] (FLINK-4319) Rework Cluster Management (FLIP-6)

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4319: - Labels: flip-6 (was: ) > Rework Cluster Management (FLIP-6) > --

[jira] [Updated] (FLINK-4834) Implement unified High Availability Services Abstraction

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4834: - Labels: flip-6 (was: ) > Implement unified High Availability Services Abstraction > -

[jira] [Updated] (FLINK-4338) Implement Slot Pool

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4338: - Labels: flip-6 (was: ) > Implement Slot Pool > --- > > Key: FLINK

[jira] [Updated] (FLINK-4343) Implement new TaskManager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4343: - Labels: flip-6 (was: ) > Implement new TaskManager > - > >

[jira] [Resolved] (FLINK-4338) Implement Slot Pool

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4338. -- Resolution: Fixed I think this issue can be closed since the slot pool has been implemented. If

[jira] [Commented] (FLINK-4350) interaction between new JobManager and new ResourceManager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068269#comment-16068269 ] Till Rohrmann commented on FLINK-4350: -- Hi [~jinyu.zj], what is exactly the problem y

[jira] [Updated] (FLINK-4897) Implement Dispatcher

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4897: - Labels: flip-6 (was: ) > Implement Dispatcher > > > Key: FLI

[jira] [Updated] (FLINK-4350) interaction between new JobManager and new ResourceManager

2017-06-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4350: - Labels: flip-6 (was: ) > interaction between new JobManager and new ResourceManager > ---

  1   2   3   >