[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-07-21 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14636332#comment-14636332 ] Chengxiang Li commented on FLINK-1901: -- I write a simple example of sampling operator

[jira] [Comment Edited] (FLINK-1901) Create sample operator for Dataset

2015-07-21 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14634622#comment-14634622 ] Chengxiang Li edited comment on FLINK-1901 at 7/22/15 2:05 AM: -

[jira] [Created] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-21 Thread Huang Wei (JIRA)
Huang Wei created FLINK-2391: Summary: Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException Key: FLINK-2391 URL: https://issues.apache.org/jira/browse/FLINK-2391

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-07-21 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14636124#comment-14636124 ] Chengxiang Li commented on FLINK-1901: -- "every point is sampled with probability 1/N"

[jira] [Assigned] (FLINK-1267) Add crossGroup operator

2015-07-21 Thread pietro pinoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pietro pinoli reassigned FLINK-1267: Assignee: pietro pinoli > Add crossGroup operator > --- > >

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

2015-07-21 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-123489145 Just rebased because #879 was merged today. This PR should be ready to get merged now. --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

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

[GitHub] flink pull request: [FLINK-1658] Rename AbstractEvent to AbstractT...

2015-07-21 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/929 [FLINK-1658] Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - deleted AbstractEvent in org.apache.flink.runtime.event.job (see comment section in https://issues.apache.org/jir

[jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

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

[jira] [Commented] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section

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

[GitHub] flink pull request: [FLINK-2205] Fix confusing entries in JM UI Jo...

2015-07-21 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/927#issuecomment-123477253 Hi @ebautistabar, thanks for the pull request! I would also like to change the key "Number of execution retries" to "Max. number of execution retries" (or similiar) to

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

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

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

2015-07-21 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/913#issuecomment-123472145 Hi @aljoscha, I haven't started and could do it but you can also give it a shot if you'd like to :smile: --- If your project is set up for it, you can reply to this ema

[jira] [Created] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination

2015-07-21 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2390: - Summary: Replace iteration timeout with algorithm for detecting termination Key: FLINK-2390 URL: https://issues.apache.org/jira/browse/FLINK-2390 Project: Flink I

[jira] [Commented] (FLINK-2322) Unclosed stream may leak resource

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

[GitHub] flink pull request: FLINK-2322 Unclosed stream may leak resource

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/928#issuecomment-123453516 You should use tabs ;-) Otherwise this is a good fix. To optimize it: You need not close the stream in two places, the finally clause will do it anyways. --

[jira] [Resolved] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2389. - Resolution: Fixed Fixed via d59cebd8c3f643dc6da88924300e78f65f26c640 and ea2b1b139eb221b2b1a81ee7

[jira] [Created] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue

2015-07-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2389: --- Summary: Add dashboard frontend architecture amd build infrastructue Key: FLINK-2389 URL: https://issues.apache.org/jira/browse/FLINK-2389 Project: Flink Issu

[jira] [Closed] (FLINK-2358) Add Netty-HTTP based server and server handlers

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2358. --- > Add Netty-HTTP based server and server handlers > --- > >

[jira] [Resolved] (FLINK-2358) Add Netty-HTTP based server and server handlers

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2358. - Resolution: Fixed Assignee: Stephan Ewen Implemented in 44ee1c1b64b18db199a7e77492dc890a1234

[jira] [Resolved] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2018. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 148395bcd81a93bcb1473e4e93f267edb3b71c7e >

[jira] [Closed] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2018. --- > Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's > argument parser >

[jira] [Resolved] (FLINK-2198) BlobManager tests fail on Windows

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2198. - Resolution: Fixed Assignee: Gabor Gevay Fix Version/s: 0.10 Fixed via 50344d70deb6

[jira] [Closed] (FLINK-2198) BlobManager tests fail on Windows

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2198. --- > BlobManager tests fail on Windows > - > > Key: FLINK-219

[jira] [Resolved] (FLINK-1943) Add Gelly-GSA compiler and translation tests

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1943. - Resolution: Implemented Fix Version/s: 0.10 Implemented in 11b48633dd421fcdf5e3cdced908ce85

[jira] [Closed] (FLINK-1943) Add Gelly-GSA compiler and translation tests

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1943. --- > Add Gelly-GSA compiler and translation tests > > >

[jira] [Closed] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2377. --- > AbstractTestBase.deleteAllTempFiles sometimes fails on Windows > ---

[jira] [Closed] (FLINK-2362) distinct is missing in DataSet API documentation

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2362. --- > distinct is missing in DataSet API documentation > > >

[jira] [Resolved] (FLINK-2376) testFindConnectableAddress sometimes fails on Windows because of the time limit

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2376. - Resolution: Fixed Fix Version/s: 0.10 Fixed via bbbfd22077623633363d656d66a00028e7fea631 >

[jira] [Commented] (FLINK-1943) Add Gelly-GSA compiler and translation tests

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

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

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

[jira] [Commented] (FLINK-2374) File.setWritable doesn't work on Windows, which makes several tests fail

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

[jira] [Resolved] (FLINK-2362) distinct is missing in DataSet API documentation

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2362. - Resolution: Fixed Fixed in 0.10 via 0818bec02c0bc90bae68f09d8d2e48dc0f6b9374 > distinct is missin

[jira] [Commented] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser

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

[GitHub] flink pull request: [FLINK-1938] Add Grunt for building the front-...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/623 --- 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 enabl

[GitHub] flink pull request: [FLINK-2377] Add reader.close() to readAllResu...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/924 --- 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 enabl

[GitHub] flink pull request: [FLINK-2376] Raise the time limit in testFindC...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/920 --- 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 enabl

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/922 --- 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 enabl

[GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/720 --- 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 enabl

[GitHub] flink pull request: [FLINK-2374] Under Windows, skip tests that us...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/919 --- 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 enabl

[jira] [Commented] (FLINK-1228) Add REST Interface to JobManager

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

[jira] [Commented] (FLINK-1938) Add Grunt for building the front-end

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

[jira] [Resolved] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2377. - Resolution: Fixed Assignee: Gabor Gevay Fix Version/s: 0.10 Fixed via 29454de57ede

[jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

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

[jira] [Commented] (FLINK-2376) testFindConnectableAddress sometimes fails on Windows because of the time limit

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

[jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation

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

[GitHub] flink pull request: [FLINK-1943] [gelly] Added GSA compiler and tr...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/916 --- 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 enabl

[GitHub] flink pull request: [FLINK-1228] Add REST Interface to JobManager

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/297 --- 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 enabl

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/677 --- 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 enabl

[GitHub] flink pull request: [docs] Document some missing configuration par...

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/915 --- 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 enabl

[jira] [Updated] (FLINK-2388) JobManager should try retrieving jobs from archive

2015-07-21 Thread Enrique Bautista Barahona (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enrique Bautista Barahona updated FLINK-2388: - Description: I was following the quickstart guide with the WordCount examp

[jira] [Updated] (FLINK-2388) JobManager should try retrieving jobs from archive

2015-07-21 Thread Enrique Bautista Barahona (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enrique Bautista Barahona updated FLINK-2388: - Description: I was following the quickstart guide with the WordCount examp

[jira] [Created] (FLINK-2388) JobManager should try retrieving jobs from archive

2015-07-21 Thread Enrique Bautista Barahona (JIRA)
Enrique Bautista Barahona created FLINK-2388: Summary: JobManager should try retrieving jobs from archive Key: FLINK-2388 URL: https://issues.apache.org/jira/browse/FLINK-2388 Project: Flin

[jira] [Commented] (FLINK-2322) Unclosed stream may leak resource

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

[GitHub] flink pull request: FLINK-2322 Unclosed stream may leak resource

2015-07-21 Thread tedyu
GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/928 FLINK-2322 Unclosed stream may leak resource What size should I use for tab ? You can merge this pull request into a Git repository by running: $ git pull https://github.com/tedyu/flink master Al

[jira] [Commented] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section

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

[GitHub] flink pull request: [FLINK-2205] Fix confusing entries in JM UI Jo...

2015-07-21 Thread ebautistabar
GitHub user ebautistabar opened a pull request: https://github.com/apache/flink/pull/927 [FLINK-2205] Fix confusing entries in JM UI Job Config. section Default display for 'Number of execution retries' is now 'deactivated' and for 'Job parallelism' is 'auto', as suggested in JIRA.

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

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

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-21 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-123402206 I see your point @shghatge. However, I think naming just one method differently will be confusing.. If we're going to have custom method names, let's go with @andral

[jira] [Commented] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters

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

[GitHub] flink pull request: [FLINK-2375] Add Approximate Adamic Adar Simil...

2015-07-21 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/923#issuecomment-123394302 Hi @shghatge! The comments I left on #892 apply here as well. The difference would be that the neighborhoods of each of the neighbors will be represented as a bloom

[jira] [Commented] (FLINK-2312) Random Splits

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

[GitHub] flink pull request: [FLINK-2312][utils] Randomly Splitting a Data ...

2015-07-21 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/921#issuecomment-123390786 This leads to non-mutually exclusive splits. I tracked down the reason for this: The input data is parallelized differently while performing the splits for every f

[jira] [Commented] (FLINK-2312) Random Splits

2015-07-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635302#comment-14635302 ] Sachin Goel commented on FLINK-2312: [~pietropinoli], It didn't work. I, instead, deci

[jira] [Commented] (FLINK-2387) Add test for live accumulators in Streaming

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

[GitHub] flink pull request: [FLINK-2387] add streaming test case for live ...

2015-07-21 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/926 [FLINK-2387] add streaming test case for live accumulators You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink live-accumulators-streaming Alt

[jira] [Resolved] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks

2015-07-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2382. --- Resolution: Fixed Fixed in 1d373a7. > Live Metric Reporting Does Not Work for Two-Inp

[jira] [Created] (FLINK-2387) Add test for live accumulators in Streaming

2015-07-21 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2387: - Summary: Add test for live accumulators in Streaming Key: FLINK-2387 URL: https://issues.apache.org/jira/browse/FLINK-2387 Project: Flink Issue Typ

[jira] [Commented] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser

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

[GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/720#issuecomment-123370928 Looks good. I will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API

2015-07-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635243#comment-14635243 ] Robert Metzger commented on FLINK-2386: --- My current work in progress code is located

[jira] [Created] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API

2015-07-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2386: - Summary: Implement Kafka connector using the new Kafka Consumer API Key: FLINK-2386 URL: https://issues.apache.org/jira/browse/FLINK-2386 Project: Flink Is

[GitHub] flink pull request: [docs] Document some missing configuration par...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/915#issuecomment-123363590 Will clean this up and merge it... --- 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 doe

[jira] [Commented] (FLINK-1943) Add Gelly-GSA compiler and translation tests

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

[GitHub] flink pull request: [FLINK-1943] [gelly] Added GSA compiler and tr...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/916#issuecomment-123362529 Super, +1 The test failures are unrelated. (One of the unstable tests is fixed already). Will merge this... --- If your project is set up for it, y

[GitHub] flink pull request: Collect(): Fixing the akka.framesize size limi...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/887#issuecomment-123361546 Now that #896 is in, this becomes mergeable... --- 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

[jira] [Commented] (FLINK-2376) testFindConnectableAddress sometimes fails on Windows because of the time limit

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

[GitHub] flink pull request: [FLINK-2376] Raise the time limit in testFindC...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/920#issuecomment-123359910 Looks good, +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Created] (FLINK-2385) Scala DataSet.distinct should have parenthesis

2015-07-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2385: --- Summary: Scala DataSet.distinct should have parenthesis Key: FLINK-2385 URL: https://issues.apache.org/jira/browse/FLINK-2385 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-07-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635206#comment-14635206 ] Till Rohrmann commented on FLINK-1901: -- I think this solution is indeed a little bit

[jira] [Resolved] (FLINK-2371) AccumulatorLiveITCase fails

2015-07-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2371. --- Resolution: Fixed > AccumulatorLiveITCase fails > --- > >

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

2015-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/925 --- 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 enabl

[jira] [Commented] (FLINK-2312) Random Splits

2015-07-21 Thread pietro pinoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635192#comment-14635192 ] pietro pinoli commented on FLINK-2312: -- [~sachingoel0101] I may be very wrong, but yo

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

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

[jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation

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

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/922#issuecomment-123330725 Looks good, will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does no

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

2015-07-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635171#comment-14635171 ] Stephan Ewen commented on FLINK-2380: - How much of an inconvenience is? > Allow to co

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

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

[GitHub] flink pull request: [FLINK-2377] Add reader.close() to readAllResu...

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/924#issuecomment-123326390 +1, will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have t

[jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

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

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

2015-07-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/925#issuecomment-123326290 +1, looks good --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feat

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-07-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635131#comment-14635131 ] Sachin Goel commented on FLINK-1901: Hi [~trohrm...@apache.org], I checked the code. A

[jira] [Commented] (FLINK-1818) Provide API to cancel running job

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

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

2015-07-21 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/642#issuecomment-123306327 Hi @rainiraj. We want to rework and unify client code. This PR would be part of it. Can you update your code soon so it can be merged? Otherwise, it might get reworked by s

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

2015-07-21 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/913#issuecomment-123304832 @fhueske Are you still available for writing the section about the batch API? Or is this void now due to recent events? :smile_cat: --- If your project is set up for i

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

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

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-07-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635102#comment-14635102 ] Sachin Goel commented on FLINK-1901: Yes. I do agree. I'll see if what I've written ca

[jira] [Commented] (FLINK-2312) Random Splits

2015-07-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635100#comment-14635100 ] Sachin Goel commented on FLINK-2312: [~albermax], usually, when the ratios are not too

[jira] [Comment Edited] (FLINK-2312) Random Splits

2015-07-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635095#comment-14635095 ] Sachin Goel edited comment on FLINK-2312 at 7/21/15 1:21 PM: -

[jira] [Comment Edited] (FLINK-2312) Random Splits

2015-07-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14635095#comment-14635095 ] Sachin Goel edited comment on FLINK-2312 at 7/21/15 1:21 PM: -

  1   2   >