[jira] [Commented] (FLINK-6521) Add per job cleanup methods to HighAvailabilityServices

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

[GitHub] flink issue #4376: [FLINK-6521] Add per job cleanup methods to HighAvailabil...

2017-07-31 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4376 I found the following kinda stuff from CI, and it seems not relevant to this issue, what do you think? @tillrohrmann ``` Running org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryI

[GitHub] flink issue #4415: [FLINK-7269] Refactor passing of dynamic properties

2017-07-31 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4415 @tillrohrmann Great, use `loadConfigurationWithDynamicProperties` instead of `loadConfiguration` and `setDynamicProperties` will be more concise, it sounds good to me, thanks --- If your project is

[jira] [Commented] (FLINK-7269) Refactor passing of dynamic properties

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

[jira] [Commented] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

2017-07-31 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16108252#comment-16108252 ] mingleizhang commented on FLINK-7302: - If we dont fix this issue. I guess all windows

[jira] [Commented] (FLINK-7299) Write GenericRecord using AvroOutputFormat

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

[GitHub] flink issue #4422: [FLINK-7299][AVRO] Write GenericRecord using AvroOutputFo...

2017-07-31 Thread soniclavier
Github user soniclavier commented on the issue: https://github.com/apache/flink/pull/4422 Link to passed Travis build : https://travis-ci.org/soniclavier/flink/builds/259243850 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Created] (FLINK-7330) Unable to read file on windows - InvalidFilePathException

2017-07-31 Thread Mohit Anchlia (JIRA)
Mohit Anchlia created FLINK-7330: Summary: Unable to read file on windows - InvalidFilePathException Key: FLINK-7330 URL: https://issues.apache.org/jira/browse/FLINK-7330 Project: Flink Issue

[jira] [Created] (FLINK-7329) Unable to use FileInputStream with StreamExecutionEnvironment.readFile with interval

2017-07-31 Thread Mohit Anchlia (JIRA)
Mohit Anchlia created FLINK-7329: Summary: Unable to use FileInputStream with StreamExecutionEnvironment.readFile with interval Key: FLINK-7329 URL: https://issues.apache.org/jira/browse/FLINK-7329 Pr

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-31 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r130461621 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -405,6 +481,17 @@ class Aggregatio

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-31 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r130458506 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -179,13 +214,19 @@ class Aggregati

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-31 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r130459674 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -222,14 +271,22 @@ class Aggregati

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-31 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r130461181 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -386,13 +455,20 @@ class Aggregati

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-31 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r130459631 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -201,14 +242,22 @@ class Aggregati

[jira] [Commented] (FLINK-7223) Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector

2017-07-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107888#comment-16107888 ] Stephan Ewen commented on FLINK-7223: - Hmmm... Is there a way to auto-configure this v

[jira] [Assigned] (FLINK-7242) Drop Java 7 Support

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7242: --- Assignee: Chesnay Schepler > Drop Java 7 Support > --- > >

[jira] [Assigned] (FLINK-7242) Drop Java 7 Support

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7242: --- Assignee: Chesnay Schepler > Drop Java 7 Support > --- > >

[jira] [Assigned] (FLINK-7242) Drop Java 7 Support

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7242: --- Assignee: (was: Chesnay Schepler) > Drop Java 7 Support > --- > >

[jira] [Commented] (FLINK-7328) Remove Flink's futures from SlotManager

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

[GitHub] flink pull request #4443: [FLINK-7328] [futures] Replace Flink's futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4443 [FLINK-7328] [futures] Replace Flink's futures with Java 8's CompletableFuture in SlotManager ## What is the purpose of the change Replace Flink's futures with Java 8's CompletableFutu

[jira] [Created] (FLINK-7328) Remove Flink's futures from SlotManager

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7328: Summary: Remove Flink's futures from SlotManager Key: FLINK-7328 URL: https://issues.apache.org/jira/browse/FLINK-7328 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7327) Remove Flink's futures from StreamRecordQueueEntry

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

[GitHub] flink pull request #4442: [FLINK-7327] [futures] Replace Flink's future with...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4442 [FLINK-7327] [futures] Replace Flink's future with Java 8's CompletableFuture in StreamRecordQueueEntry ## What is the purpose of the change Replace Flink's future with Java 8's Comple

[jira] [Created] (FLINK-7327) Remove Flink's futures from StreamRecordQueueEntry

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7327: Summary: Remove Flink's futures from StreamRecordQueueEntry Key: FLINK-7327 URL: https://issues.apache.org/jira/browse/FLINK-7327 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7326) Remove Flink's futures from RegisteredRpcConnection

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

[jira] [Commented] (FLINK-7326) Remove Flink's futures from RegisteredRpcConnection

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

[GitHub] flink pull request #4440: [FLINK-7326] [futures] Replace Flink's future with...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4440#discussion_r130429770 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/registration/RegisteredRpcConnection.java --- @@ -88,24 +86,17 @@ public void start() {

[GitHub] flink pull request #4440: [FLINK-7326] [futures] Replace Flink's future with...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4440#discussion_r130429986 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/registration/RegisteredRpcConnection.java --- @@ -88,24 +86,17 @@ public void start() {

[jira] [Commented] (FLINK-7324) Remove Flink's futures from SlotPool

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

[GitHub] flink pull request #4438: [FLINK-7324] [futures] Replace Flink's future with...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4438#discussion_r130429317 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -344,4 +344,26 @@ public void onComplete(Throwable failure,

[jira] [Commented] (FLINK-7320) Remove Flink's futures from Scheduler

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

[GitHub] flink pull request #4435: [FLINK-7320] [futures] Replace Flink's futures wit...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4435#discussion_r130428135 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/Scheduler.java --- @@ -152,12 +150,14 @@ else if (ret instanceof Future)

[jira] [Commented] (FLINK-7321) Remove Flink's futures from HeartbeatManager

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

[GitHub] flink pull request #4434: [FLINK-7321] [futures] Replace Flink's futures wit...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4434#discussion_r130427767 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerTest.java --- @@ -288,7 +286,11 @@ public void testTargetUnmonitorin

[jira] [Commented] (FLINK-7317) Remove Flink's futures from ExecutionGraph

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

[jira] [Commented] (FLINK-7317) Remove Flink's futures from ExecutionGraph

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

[GitHub] flink pull request #4433: [FLINK-7317] [futures] Replace Flink's futures wit...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4433#discussion_r130400792 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -50,42 +49,38 @@ * @param type of the result

[GitHub] flink pull request #4433: [FLINK-7317] [futures] Replace Flink's futures wit...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4433#discussion_r130401027 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -199,25 +194,19 @@ public RetryException(Throwable cause) {

[GitHub] flink issue #4441: [FLINK-7301] [docs] Rework state documentation

2017-07-31 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4441 CC @alpinegizmo --- 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 i

[jira] [Commented] (FLINK-7301) Rework state documentation

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

[jira] [Commented] (FLINK-7301) Rework state documentation

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

[GitHub] flink pull request #4441: [FLINK-7301] [docs] Rework state documentation

2017-07-31 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4441 [FLINK-7301] [docs] Rework state documentation ## What is the purpose of the change *This PR restructures state related documentation pages. It introduces some state introduction page and m

[jira] [Comment Edited] (FLINK-7294) mesos.resourcemanager.framework.role not working

2017-07-31 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107719#comment-16107719 ] Eron Wright edited comment on FLINK-7294 at 7/31/17 6:18 PM: --

[jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working

2017-07-31 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107719#comment-16107719 ] Eron Wright commented on FLINK-7294: - It looks to be a code defect, that Flink is reg

[jira] [Commented] (FLINK-7326) Remove Flink's futures from RegisteredRpcConnection

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

[GitHub] flink pull request #4440: [FLINK-7326] [futures] Replace Flink's future with...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4440 [FLINK-7326] [futures] Replace Flink's future with Java 8's CompletableFuture in RegisteredRpcConnection ## What is the purpose of the change Replace Flink's future with Java 8's Compl

[jira] [Created] (FLINK-7326) Remove Flink's futures from RegisteredRpcConnection

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7326: Summary: Remove Flink's futures from RegisteredRpcConnection Key: FLINK-7326 URL: https://issues.apache.org/jira/browse/FLINK-7326 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7325) Remove Flink's futures from MiniCluster

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

[GitHub] flink pull request #4439: [FLINK-7325] [futures] Replace Flink's futures by ...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4439 [FLINK-7325] [futures] Replace Flink's futures by Java 8's CompletableFuture in MiniCluster ## What is the purpose of the change Replace Flink's futures by Java 8's CompletableFuture i

[jira] [Created] (FLINK-7325) Remove Flink's futures from MiniCluster

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7325: Summary: Remove Flink's futures from MiniCluster Key: FLINK-7325 URL: https://issues.apache.org/jira/browse/FLINK-7325 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7324) Remove Flink's futures from SlotPool

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

[GitHub] flink pull request #4438: [FLINK-7324] [futures] Replace Flink's future with...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4438 [FLINK-7324] [futures] Replace Flink's future with Java 8's CompletableFuture in SlotPool ## What is the purpose of the change Replace Flink's future with Java 8's CompletableFuture in

[jira] [Created] (FLINK-7324) Remove Flink's futures from SlotPool

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7324: Summary: Remove Flink's futures from SlotPool Key: FLINK-7324 URL: https://issues.apache.org/jira/browse/FLINK-7324 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7323) Remove Flink's futures from MasterHooks

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

[GitHub] flink pull request #4437: [FLINK-7323] [futures] Replace Flink's futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4437 [FLINK-7323] [futures] Replace Flink's futures with Java 8's CompletableFuture in MasterHooks ## What is the purpose of the change Replace Flink's futures with Java 8's CompletableFutu

[jira] [Created] (FLINK-7323) Remove Flink's futures from MasterHooks

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7323: Summary: Remove Flink's futures from MasterHooks Key: FLINK-7323 URL: https://issues.apache.org/jira/browse/FLINK-7323 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7322) Remove Flink's futures from CheckpointCoordinator

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

[GitHub] flink pull request #4436: [FLINK-7322] [futures] Replace Flink's futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4436 [FLINK-7322] [futures] Replace Flink's futures with Java 8's CompletableFuture in CheckpointCoordinator ## What is the purpose of the change Replace Flink's futures with Java 8's Compl

[jira] [Created] (FLINK-7322) Remove Flink's futures from CheckpointCoordinator

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7322: Summary: Remove Flink's futures from CheckpointCoordinator Key: FLINK-7322 URL: https://issues.apache.org/jira/browse/FLINK-7322 Project: Flink Issue Type: S

[jira] [Commented] (FLINK-7320) Remove Flink's futures from Scheduler

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

[GitHub] flink pull request #4435: [FLINK-7320] [futures] Replace Flink's futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4435 [FLINK-7320] [futures] Replace Flink's futures with Java 8's CompletableFuture in Scheduler ## What is the purpose of the change Replace Flink's futures with Java 8's CompletableFuture

[jira] [Commented] (FLINK-7321) Remove Flink's futures from HeartbeatManager

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

[GitHub] flink pull request #4434: [FLINK-7321] [futures] Replace Flink's futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4434 [FLINK-7321] [futures] Replace Flink's futures with Java 8's CompletableFuture in HeartbeatManager ## What is the purpose of the change Replace Flink's futures with Java 8's Completabl

[jira] [Created] (FLINK-7321) Remove Flink's futures from HeartbeatManager

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7321: Summary: Remove Flink's futures from HeartbeatManager Key: FLINK-7321 URL: https://issues.apache.org/jira/browse/FLINK-7321 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-7320) Remove Flink's futures from Scheduler

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7320: Summary: Remove Flink's futures from Scheduler Key: FLINK-7320 URL: https://issues.apache.org/jira/browse/FLINK-7320 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-6732) Activate strict checkstyle for flink-java

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6732. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 3c42557f3083182b0ab66d15cb6ec8452b59464c >

[jira] [Closed] (FLINK-7185) Activate checkstyle flink-java/io

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7185. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 0c9c9fb5cb7a8a27d444db5c725c8abd792ca761 >

[jira] [Closed] (FLINK-7191) Activate checkstyle flink-java/operators/translation

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7191. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 8e975362312c727fd602429778bc1c3628b95619 >

[jira] [Commented] (FLINK-7191) Activate checkstyle flink-java/operators/translation

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

[jira] [Commented] (FLINK-7185) Activate checkstyle flink-java/io

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

[GitHub] flink pull request #4334: [FLINK-7191] Activate checkstyle flink-java/operat...

2017-07-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4334 --- 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 pull request #4340: [FLINK-7185] Activate checkstyle flink-java/io

2017-07-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4340 --- 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-7317) Remove Flink's futures from ExecutionGraph

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

[GitHub] flink pull request #4433: [FLINK-7317] [futures] Replace Flink's futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4433 [FLINK-7317] [futures] Replace Flink's futures with Java 8's CompletableFuture in ExecutionGraph ## What is the purpose of the change Replace Flink's `Futures` with Java 8's `Completab

[jira] [Commented] (FLINK-7318) Remove Flink's futures from StackTraceSampleCoordinator

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

[GitHub] flink pull request #4431: [FLINK-7318] [futures] Replace Flink's futures in ...

2017-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4431#discussion_r130397834 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/BackPressureStatsTracker.java --- @@ -177,7 +177,7 @@ public boolean tri

[jira] [Commented] (FLINK-7318) Remove Flink's futures from StackTraceSampleCoordinator

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

[GitHub] flink pull request #4431: [FLINK-7318] [futures] Replace Flink's futures in ...

2017-07-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4431#discussion_r130396606 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/BackPressureStatsTracker.java --- @@ -177,7 +177,7 @@ public boolean triggerSt

[jira] [Commented] (FLINK-7319) Remove Flink's futures from MesosResourceManager

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

[GitHub] flink pull request #4432: [FLINK-7319] [futures] Replace Flink's Futures wit...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4432 [FLINK-7319] [futures] Replace Flink's Futures with Java 8 CompletableFuture in MesosResourceManager ## What is the purpose of the change Replace Flink's `Futures` with Java 8 `Complet

[jira] [Created] (FLINK-7319) Remove Flink's futures from MesosResourceManager

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7319: Summary: Remove Flink's futures from MesosResourceManager Key: FLINK-7319 URL: https://issues.apache.org/jira/browse/FLINK-7319 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-7318) Remove Flink's futures from StackTraceSampleCoordinator

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

[GitHub] flink pull request #4431: [FLINK-7318] [futures] Replace Flink's futures in ...

2017-07-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4431 [FLINK-7318] [futures] Replace Flink's futures in StackTraceSampleCoordinator with Java 8 CompletableFuture ## What is the purpose of the change Replace Flink's futures in `StackTraceS

[jira] [Created] (FLINK-7318) Remove Flink's futures from StackTraceSampleCoordinator

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7318: Summary: Remove Flink's futures from StackTraceSampleCoordinator Key: FLINK-7318 URL: https://issues.apache.org/jira/browse/FLINK-7318 Project: Flink Issue T

[jira] [Assigned] (FLINK-7318) Remove Flink's futures from StackTraceSampleCoordinator

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7318: Assignee: Till Rohrmann > Remove Flink's futures from StackTraceSampleCoordinator > ---

[jira] [Assigned] (FLINK-7317) Remove Flink's futures from ExecutionGraph

2017-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7317: Assignee: Till Rohrmann > Remove Flink's futures from ExecutionGraph >

[jira] [Created] (FLINK-7317) Remove Flink's futures from ExecutionGraph

2017-07-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7317: Summary: Remove Flink's futures from ExecutionGraph Key: FLINK-7317 URL: https://issues.apache.org/jira/browse/FLINK-7317 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #4334: [FLINK-7191] Activate checkstyle flink-java/operators/tra...

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4334 Will address the comment while 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 feature enabl

[jira] [Commented] (FLINK-7191) Activate checkstyle flink-java/operators/translation

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

[jira] [Commented] (FLINK-7185) Activate checkstyle flink-java/io

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

[GitHub] flink issue #4340: [FLINK-7185] Activate checkstyle flink-java/io

2017-07-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4340 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 feature enabled and wishes so, or if the fea

[jira] [Created] (FLINK-7316) always use off-heap network buffers

2017-07-31 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7316: -- Summary: always use off-heap network buffers Key: FLINK-7316 URL: https://issues.apache.org/jira/browse/FLINK-7316 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-7310) always use HybridMemorySegment

2017-07-31 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7310: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-7315 > always use HybridMemorySegment >

[jira] [Created] (FLINK-7315) use flink's buffers in netty

2017-07-31 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7315: -- Summary: use flink's buffers in netty Key: FLINK-7315 URL: https://issues.apache.org/jira/browse/FLINK-7315 Project: Flink Issue Type: Improvement Comp

[jira] [Closed] (FLINK-7283) PythonPlanBinderTest issues with python paths

2017-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7283. --- Resolution: Fixed 1.3: 2455df962c76d20f1c07a57d6ed0118d1d1a067c > PythonPlanBinderTest issues

  1   2   3   >