[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167607866 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167606495 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167608886 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361001#comment-16361001 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5462#discussion_r167608682 --- Diff: docs/ops/config.md --- @@ -502,27 +502,7 @@ Previously this key was named `recovery.mode` and the default value was `standal

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360995#comment-16360995 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5459: [FLINK-8475][config][docs] Integrate FS options

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5459#discussion_r167608020 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java --- @@ -127,7 +130,30 @@ */ public static final

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360992#comment-16360992 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8637) Pass JobManagerSharedServices to JobMaster

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360990#comment-16360990 ] ASF GitHub Bot commented on FLINK-8637: --- Github user tillrohrmann commented on the issue:

[GitHub] flink pull request #5459: [FLINK-8475][config][docs] Integrate FS options

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5459#discussion_r167606303 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java --- @@ -127,7 +130,30 @@ */ public static final

[GitHub] flink issue #5457: [FLINK-8637] [flip6] Use JobManagerSharedServices to pass...

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5457 Merging this PR. ---

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360982#comment-16360982 ] ASF GitHub Bot commented on FLINK-8626: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5443: [FLINK-8626] Introduce BackPressureStatsTracker interface

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

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360976#comment-16360976 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360975#comment-16360975 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360974#comment-16360974 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5462#discussion_r167603849 --- Diff: docs/ops/config.md --- @@ -502,27 +502,7 @@ Previously this key was named `recovery.mode` and the default value was `standal

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360971#comment-16360971 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5462#discussion_r167603044 --- Diff: docs/ops/config.md --- @@ -502,27 +502,7 @@ Previously this key was named `recovery.mode` and the default value was `standal

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5462#discussion_r167603434 --- Diff: docs/ops/config.md --- @@ -502,27 +502,7 @@ Previously this key was named `recovery.mode` and the default value was `standal

[GitHub] flink issue #5392: [FLINK-8475][config][docs] Integrate JM options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5392 merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360965#comment-16360965 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360966#comment-16360966 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5391: [FLINK-8475][config][docs] Integrate BlobServer options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5391 yes, this wasn't in there at all :) merging. ---

[GitHub] flink issue #5390: [FLINK-8475][config][docs] Integrate SlotManager options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5390 merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360962#comment-16360962 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5389: [FLINK-8475][config][docs] Integrate REST options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5389 merging. ---

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2018-02-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 2/12/18 4:08 PM: error-prone has JDK 8

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360961#comment-16360961 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-02-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 2/12/18 4:08 PM: In

[GitHub] flink issue #5387: [FLINK-8475][config][docs] Integrate optimizer options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5387 Oh i just forgot the annotation, will add `@PublicEvolving` while merging... ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360954#comment-16360954 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5461 yes, it will show up in the HA table. merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360950#comment-16360950 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5460: [FLINK-8475][config][docs] Integrate Algorithm options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5460 merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360948#comment-16360948 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 So when we get to the HA options this will show up again? If yes, please go ahead. ---

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

2018-02-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5466 [FLINK-8530] [flip6] Enable detached job mode submission to session cluster ## What is the purpose of the change This commit makes the RestClusterClient aware whether the user wishes

[jira] [Assigned] (FLINK-8640) Disable japicmp on java 9

2018-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8640: --- Assignee: Chesnay Schepler > Disable japicmp on java 9 > - >

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360943#comment-16360943 ] ASF GitHub Bot commented on FLINK-8530: --- GitHub user tillrohrmann opened a pull request:

[jira] [Created] (FLINK-8640) Disable japicmp on java 9

2018-02-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8640: --- Summary: Disable japicmp on java 9 Key: FLINK-8640 URL: https://issues.apache.org/jira/browse/FLINK-8640 Project: Flink Issue Type: Sub-task

[jira] [Reopened] (FLINK-8530) Enable detached job submission for RestClusterClient

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-8530: -- Wrongly closed. > Enable detached job submission for RestClusterClient >

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360929#comment-16360929 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360932#comment-16360932 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5392: [FLINK-8475][config][docs] Integrate JM options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5392 plenty of missing options are being added by these PRs 😓 ---

[GitHub] flink pull request #5392: [FLINK-8475][config][docs] Integrate JM options

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5392#discussion_r167596687 --- Diff: docs/ops/config.md --- @@ -322,7 +321,6 @@ The following parameters configure Flink's JobManager and TaskManagers. -

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360922#comment-16360922 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5392: [FLINK-8475][config][docs] Integrate JM options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5392#discussion_r167594880 --- Diff: docs/ops/config.md --- @@ -322,7 +321,6 @@ The following parameters configure Flink's JobManager and TaskManagers. -

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360902#comment-16360902 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5459: [FLINK-8475][config][docs] Integrate FS options

2018-02-12 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5459#discussion_r167592653 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java --- @@ -127,7 +130,30 @@ */ public static final

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360896#comment-16360896 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360894#comment-16360894 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5461 Currently we assign each `ConfigOption` to exactly one table, so there's little we can do at the moment about this option. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360893#comment-16360893 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5460: [FLINK-8475][config][docs] Integrate Algorithm options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5460 Ah, nevermind that last comment, we can't remove them because it's `@Public` api. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360890#comment-16360890 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5460: [FLINK-8475][config][docs] Integrate Algorithm options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5460 Looks good, but I think you can remove the unused entries from `ConfigConstants` now. ---

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 And I like how the options where not sorted before and also related options where not next to each other ... 😅 ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360881#comment-16360881 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360882#comment-16360882 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360884#comment-16360884 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 Looks good except for the one question I had! 👍 ---

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 The current documentation has `high-availability.zookeeper.path.mesos-workers: The ZooKeeper root path for persisting the Mesos worker information.` Do you know why this is not there anymore?

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360864#comment-16360864 ] ASF GitHub Bot commented on FLINK-8547: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #5400: [FLINK-8547][network] Implement CheckpointBarrierHandler ...

2018-02-12 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/5400 @pnowojski , I have submitted the updates for above comments. ---

[jira] [Closed] (FLINK-8089) Fulfil slot requests with unused offered slots

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

[jira] [Closed] (FLINK-8088) Bind logical slots to their request id instead of the slot allocation id

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

[jira] [Closed] (FLINK-8087) Decouple Slot from SlotPool

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8087. Resolution: Fixed Fix Version/s: 1.5.0 Fixed via a569f38 > Decouple Slot from SlotPool >

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360850#comment-16360850 ] ASF GitHub Bot commented on FLINK-8547: --- Github user zhijiangW commented on a diff in the pull

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360848#comment-16360848 ] ASF GitHub Bot commented on FLINK-8547: --- Github user zhijiangW commented on a diff in the pull

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360849#comment-16360849 ] ASF GitHub Bot commented on FLINK-8547: --- Github user zhijiangW commented on a diff in the pull

[GitHub] flink pull request #5400: [FLINK-8547][network] Implement CheckpointBarrierH...

2018-02-12 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/5400#discussion_r167582971 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferBlocker.java --- @@ -0,0 +1,61 @@ +/* + * Licensed to

[GitHub] flink pull request #5400: [FLINK-8547][network] Implement CheckpointBarrierH...

2018-02-12 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/5400#discussion_r167582882 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java --- @@ -18,1426 +18,40 @@ package

[GitHub] flink pull request #5400: [FLINK-8547][network] Implement CheckpointBarrierH...

2018-02-12 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/5400#discussion_r167582763 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BufferBlocker.java --- @@ -0,0 +1,61 @@ +/* + * Licensed to

[GitHub] flink issue #5415: [FLINK-3655] [core] Support multiple paths in FileInputFo...

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5415 What would speak against creating a new FileInputFormat that supports multiple paths instead? Common code could be moved into a shared super class (I _think_ that would be allowed). ---

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360838#comment-16360838 ] ASF GitHub Bot commented on FLINK-3655: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360825#comment-16360825 ] ASF GitHub Bot commented on FLINK-8639: --- Github user sihuazhou commented on the issue:

[jira] [Commented] (FLINK-8636) Pass TaskManagerServices to TaskExecutor

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360824#comment-16360824 ] ASF GitHub Bot commented on FLINK-8636: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5048: [Flink-7871] [flip6] SlotPool should release unuse...

2018-02-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5048 ---

[GitHub] flink issue #5465: [FLINK-8639][State Backends]Fix always need to seek multi...

2018-02-12 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5465 Hi, @StefanRRichter cloud you please have a look at this? ---

[GitHub] flink pull request #5383: [hotfix][kafka-tests] Do not hide original excepti...

2018-02-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5383 ---

[GitHub] flink pull request #5456: [FLINK-8636] [flip6] Use TaskManagerServices to pa...

2018-02-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5456 ---

[jira] [Commented] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360822#comment-16360822 ] ASF GitHub Bot commented on FLINK-8639: --- GitHub user sihuazhou opened a pull request:

[jira] [Resolved] (FLINK-7871) SlotPool should release its unused slot to RM

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7871. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via

[jira] [Closed] (FLINK-8636) Pass TaskManagerServices to TaskExecutor

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8636. Resolution: Fixed Fixed via 4c8851a3aa8d4154e88d8a19c93535ee9ac4a6a3 > Pass TaskManagerServices to

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-12 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5465 [FLINK-8639][State Backends]Fix always need to seek multiple times when iterator RocksDBMapState ## What is the purpose of the change This PR addressed issue

[jira] [Commented] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360820#comment-16360820 ] Till Rohrmann commented on FLINK-8521: -- Another instance: 

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360810#comment-16360810 ] ASF GitHub Bot commented on FLINK-8475: --- GitHub user zentol opened a pull request:

[jira] [Created] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState

2018-02-12 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8639: - Summary: Fix always need to seek multiple times when iterator RocksDBMapState Key: FLINK-8639 URL: https://issues.apache.org/jira/browse/FLINK-8639 Project: Flink

[GitHub] flink pull request #5464: [FLINK-8475][config][docs] Integrate Checkpointing...

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5464 [FLINK-8475][config][docs] Integrate Checkpointing options ## What is the purpose of the change This PR integrates the Checkpointing `ConfigOptions` into the configuration docs generator.

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360803#comment-16360803 ] ASF GitHub Bot commented on FLINK-8475: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5463 [FLINK-8475][config][docs] Integrate YARN options ## What is the purpose of the change This PR integrates the YARN `ConfigOptions` into the configuration docs generator. ## Brief

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360799#comment-16360799 ] ASF GitHub Bot commented on FLINK-8475: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5462 [FLINK-8475][config][docs] Integrate HA-ZK options ## What is the purpose of the change This PR integrates the Zookeeper HA `ConfigOptions` into the configuration docs generator.

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360763#comment-16360763 ] ASF GitHub Bot commented on FLINK-8547: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360765#comment-16360765 ] ASF GitHub Bot commented on FLINK-8547: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360762#comment-16360762 ] ASF GitHub Bot commented on FLINK-8547: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360761#comment-16360761 ] ASF GitHub Bot commented on FLINK-8547: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360764#comment-16360764 ] ASF GitHub Bot commented on FLINK-8547: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #5400: [FLINK-8547][network] Implement CheckpointBarrierH...

2018-02-12 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5400#discussion_r167535452 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BufferBlockerTestBase.java --- @@ -0,0 +1,325 @@ +/* + *

<    1   2   3   >