[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14948171#comment-14948171 ] ASF GitHub Bot commented on FLINK-2730: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-07 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146438040 Thanks for the review @iampeter :smile: --- 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

[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14948158#comment-14948158 ] ASF GitHub Bot commented on FLINK-2731: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2731][web-dashboard] Adds access to Job...

2015-10-07 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1233#issuecomment-146433225 @rmetzger , I looked at your changes to enable the dashboard on yarn. Looks good. :) A few comments to make sure this PR can directly start working after

[jira] [Assigned] (FLINK-7) [GitHub] Enable Range Partitioner

2015-10-07 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-7: - Assignee: Chengxiang Li > [GitHub] Enable Range Partitioner > - > >

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14948077#comment-14948077 ] ASF GitHub Bot commented on FLINK-2808: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-07 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1239 [FLINK-2808] Rework state abstraction and clean up task / operator internals This pull request fixes many related/intermixed issues. It was hard to split this into individual issues. ##

[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-10-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947987#comment-14947987 ] Robert Metzger commented on FLINK-2731: --- Okay, great. I just wanted to make sure tha

[jira] [Commented] (FLINK-2798) Prepare new web dashboard for executing in on YARN

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947983#comment-14947983 ] ASF GitHub Bot commented on FLINK-2798: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2798] Serve static files for the new we...

2015-10-07 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1222#issuecomment-146400367 I will wait until your pull request is merged to master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947909#comment-14947909 ] ASF GitHub Bot commented on FLINK-2720: --- Github user HuangWHWHW commented on the pul

[GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou...

2015-10-07 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/1157#issuecomment-146387184 Hi, sorry for late reply. The `FlinkCounMetric` is a wrapper for the flink-accumulator. But I think I get your idea.Maybe I can remove the `FlinkCounMetric`.

[jira] [Commented] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947865#comment-14947865 ] ASF GitHub Bot commented on FLINK-2779: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2779][FLINK-2794][streaming][docs] New ...

2015-10-07 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1208#issuecomment-146378690 Review 2nd part (until Connectors): General & Outline - Inconsistent capitalization of sections - Switch "Execution Configuration" and "Data Sinks" sectio

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947842#comment-14947842 ] ASF GitHub Bot commented on FLINK-2591: --- Github user willmiao commented on the pull

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-10-07 Thread willmiao
Github user willmiao commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-146371570 @rmetzger : I'm sorry for the late reply, I have been on vacation last three weeks. I failed to find a nice way to "generate a flink-conf.yaml just for the test", c

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

2015-10-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947811#comment-14947811 ] Stephan Ewen commented on FLINK-2624: - As of recently, we have a base class for Messag

[jira] [Closed] (FLINK-2830) Add Fold Window Operation for new Windowing API

2015-10-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2830. --- Resolution: Fixed Added in https://github.com/apache/flink/commit/f9eea5e5a7d13d844e06d3eb684

[jira] [Closed] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union

2015-10-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2819. --- Resolution: Fixed Added in https://github.com/apache/flink/commit/8634dbbe998af53471bed2f3a65

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947622#comment-14947622 ] ASF GitHub Bot commented on FLINK-2730: --- Github user iampeter commented on the pull

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-07 Thread iampeter
Github user iampeter commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146333800 @sachingoel0101 @aljoscha looks great, but I would make the following changes if possible: 1. Move the 'livechart' directive to a separate file - `taskmanager.

[jira] [Commented] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE

2015-10-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947616#comment-14947616 ] Maximilian Michels commented on FLINK-2749: --- Test may be failing but on GCE it s

[jira] [Resolved] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-2831. Resolution: Fixed > Failing Test: WrapperSetupHelperTest > -

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947603#comment-14947603 ] ASF GitHub Bot commented on FLINK-2823: --- Github user mxm commented on the pull reque

[jira] [Commented] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947607#comment-14947607 ] Matthias J. Sax commented on FLINK-2831: Fixed via f332fa579635878a82594aa749db050

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-146330660 @uce This was not about enforcing HDFS, rather disallowing file. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947596#comment-14947596 ] ASF GitHub Bot commented on FLINK-2823: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-146330037 The Hadoop configuration may also be set through resource files in the classpath. IMHO throwing an exception is only acceptable when we're sure no configuration has been loa

[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947549#comment-14947549 ] ASF GitHub Bot commented on FLINK-2731: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2731][web-dashboard] Adds access to Job...

2015-10-07 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1233#issuecomment-146322559 I have a pending pull request to enable it on YARN. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Resolved] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2561. -- Resolution: Fixed > Sync Gelly Java and Scala APIs > -- > >

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

[GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples

2015-10-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1211 --- 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: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-07 Thread iampeter
Github user iampeter commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146320512 @aljoscha ok will do --- 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

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947532#comment-14947532 ] ASF GitHub Bot commented on FLINK-2730: --- Github user iampeter commented on the pull

[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947527#comment-14947527 ] ASF GitHub Bot commented on FLINK-2731: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2731][web-dashboard] Adds access to Job...

2015-10-07 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1233#issuecomment-146319734 @uce, the new web dashboard doesn't work with yarn yet. The files are not shipped with the jar. I'm confused why it isn't being done so. The old frontend's files

[GitHub] flink pull request: Combination of Additions to the new Windowing ...

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

[jira] [Commented] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE

2015-10-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947495#comment-14947495 ] Stephan Ewen commented on FLINK-2749: - We used Flink a lot on GCE, to the CLI seems to

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-146303645 I don't think that we can merge this change. We can not assume that file:/// is an invalid path. Also, I don't think there is a good way to check whether the hadoop

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947439#comment-14947439 ] ASF GitHub Bot commented on FLINK-2823: --- Github user rmetzger commented on the pull

[jira] [Resolved] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2785. -- Resolution: Done Fix Version/s: 0.10 > Implement Graph's fromCsvReader in Gelly-Scala > -

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1205 --- 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-2785) Implement Graph's fromCsvReader in Gelly-Scala

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

[GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi...

2015-10-07 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1234#issuecomment-146299251 We do execute multiple tests concurrently (multiple forks). Does this lead to problems when all forks see the fork number "1" ? I am wondering, because at some place

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947402#comment-14947402 ] ASF GitHub Bot commented on FLINK-2156: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947396#comment-14947396 ] ASF GitHub Bot commented on FLINK-2823: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-146297878 PS Enforcing hdfs:// would also not allow local testing. I saw the warning log today when I was testing Till's HA PR. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947391#comment-14947391 ] ASF GitHub Bot commented on FLINK-2354: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1153#issuecomment-146297139 I've addressed your inline comments (see commits). Not rebased yet. I think it's easier to review this way. The major points: - Followed all renaming suggestions

[jira] [Assigned] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2831: -- Assignee: Matthias J. Sax > Failing Test: WrapperSetupHelperTest >

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428998 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Created] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

2015-10-07 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2832: Summary: Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement Key: FLINK-2832 URL: https://issues.apache.org/jira/browse/FLINK-2832 Project: Flink

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428891 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428924 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428959 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428971 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428739 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947341#comment-14947341 ] ASF GitHub Bot commented on FLINK-2785: --- Github user vasia commented on the pull req

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1205#issuecomment-146288828 There was an error in `RandomSamplerTest ` in one of the builds. I'll open a JIRA and merge this. --- If your project is set up for it, you can reply to this email and ha

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41428442 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphs.java --- @@ -0,0 +1,356 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41424050 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947265#comment-14947265 ] ASF GitHub Bot commented on FLINK-2156: --- Github user chiwanpark commented on the pul

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41422825 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java --- @@ -0,0 +1,130 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi...

2015-10-07 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1234#issuecomment-146277055 BTW, because your PR is based on your master branch, not topic branch, you should [overwrite master branch in your repository](http://stackoverflow.com/questions/1125

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947262#comment-14947262 ] ASF GitHub Bot commented on FLINK-2156: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi...

2015-10-07 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1234#issuecomment-146275842 Hi @dawidwys, Thanks for opening pull request. Your pull request looks good to merge. This PR will be merged in few days if there is no objection. --- If your pr

[jira] [Updated] (FLINK-2831) Failing Test: WrapperSetupHelperTest

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2831: - Summary: Failing Test: WrapperSetupHelperTest (was: Failinf Test: WrapperSetupHelperTest) > Fail

[jira] [Created] (FLINK-2831) Failinf Test: WrapperSetupHelperTest

2015-10-07 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2831: Summary: Failinf Test: WrapperSetupHelperTest Key: FLINK-2831 URL: https://issues.apache.org/jira/browse/FLINK-2831 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947233#comment-14947233 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-07 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1106#issuecomment-146267428 Hi @nikste, because #1197 is merged first into master, we need rebase this on master. Could you rebase this? --- If your project is set up for it, you can reply to t

[GitHub] flink pull request: [FLINK-2779][FLINK-2794][streaming][docs] New ...

2015-10-07 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1208#issuecomment-146264681 It's a bit painful to review because Github is not showing the diff :-( Here is what I found in `streaming_guide.ml` until but not including `Specifying Keys`:

[jira] [Commented] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947223#comment-14947223 ] ASF GitHub Bot commented on FLINK-2779: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-2806) No TypeInfo for Scala's Nothing type

2015-10-07 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947205#comment-14947205 ] Gabor Gevay commented on FLINK-2806: You're welcome! Thanks for merging it! > No Type

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41414813 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandle.java --- @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache So

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41414820 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandle.java --- @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41414806 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java --- @@ -0,0 +1,422 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-10-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947182#comment-14947182 ] ASF GitHub Bot commented on FLINK-2561: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples

2015-10-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1211#issuecomment-146258426 I believe they're all fixed now! --- 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 h

[jira] [Closed] (FLINK-2806) No TypeInfo for Scala's Nothing type

2015-10-07 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park closed FLINK-2806. -- Resolution: Fixed Fix Version/s: 0.10 Implemented via 6e42f9fc0804886efd57994a72feb226e26958cc.

[jira] [Commented] (FLINK-2806) No TypeInfo for Scala's Nothing type

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

[GitHub] flink pull request: [FLINK-2806] [scala-api] Add a TypeInformation...

2015-10-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1212 --- 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-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41413616 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoints.java --- @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache S

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41413324 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/SubmittedJobGraphs.java --- @@ -0,0 +1,92 @@ +/* + * Licensed to the Apache Sof

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

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

[GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco...

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1153#discussion_r41411532 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SuccessfulCheckpoint.java --- @@ -19,29 +19,28 @@ package org.apache.flink.runtime

  1   2   3   4   >