[GitHub] incubator-flink pull request: [FLINK-1307] Allow input from nested...

2014-12-10 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/incubator-flink/pull/260 [FLINK-1307] Allow input from nested directory structure You can merge this pull request into a Git repository by running: $ git pull https://github.com/vasia/incubator-flink input-from

[jira] [Commented] (FLINK-1307) Allow input from nested directory structure

2014-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14242275#comment-14242275 ] ASF GitHub Bot commented on FLINK-1307: --- GitHub user vasia opened a pull request:

[jira] [Commented] (FLINK-1208) Skip comment lines in CSV input format. Allow user to specify comment character.

2014-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14242073#comment-14242073 ] ASF GitHub Bot commented on FLINK-1208: --- Github user FelixNeutatz commented on the p

[GitHub] incubator-flink pull request: enable CSV Reader to ignore invalid ...

2014-12-10 Thread FelixNeutatz
Github user FelixNeutatz commented on the pull request: https://github.com/apache/incubator-flink/pull/201#issuecomment-66564141 done :) --- 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 f

[jira] [Updated] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

2014-12-10 Thread Matthias Schumacher (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Schumacher updated FLINK-1321: --- Affects Version/s: (was: 0.7.0-incubating) > New web interface, contains parts fro

[GitHub] incubator-flink pull request: Upgraded HBase addon to HBase 0.98.x...

2014-12-10 Thread fpompermaier
Github user fpompermaier commented on the pull request: https://github.com/apache/incubator-flink/pull/220#issuecomment-66541558 I've looked at your branch and it's not a fork of my code rebased with the current master.. I'll try to rebase my PR with the current master now..

[jira] [Created] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

2014-12-10 Thread Matthias Schumacher (JIRA)
Matthias Schumacher created FLINK-1321: -- Summary: New web interface, contains parts from WebInfoServer and WebClient Key: FLINK-1321 URL: https://issues.apache.org/jira/browse/FLINK-1321 Project:

[jira] [Commented] (FLINK-629) Add support for null values to the java api

2014-12-10 Thread mustafa elbehery (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241856#comment-14241856 ] mustafa elbehery commented on FLINK-629: Hi Robert, I created a parser for tweets

[GitHub] incubator-flink pull request: Fixed java quickstart example

2014-12-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/257 --- 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 featur

[GitHub] incubator-flink pull request: Fixed java quickstart example

2014-12-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/257#issuecomment-66514299 ah .. sorry. I'll try the tool. --- 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

[GitHub] incubator-flink pull request: Upgraded HBase addon to HBase 0.98.x...

2014-12-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/220#issuecomment-66514191 Thanks @fpompermaier for describing whats missing. I've triggered a Travis build to verify it: https://travis-ci.org/rmetzger/incubator-flink/builds/43638278

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2014-12-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241593#comment-14241593 ] Timo Walther commented on FLINK-1319: - I'm very interested to work on this topic. I li

[jira] [Created] (FLINK-1320) Add an off-heap variant of the managed memory

2014-12-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1320: --- Summary: Add an off-heap variant of the managed memory Key: FLINK-1320 URL: https://issues.apache.org/jira/browse/FLINK-1320 Project: Flink Issue Type: Improve

[GitHub] incubator-flink pull request: Fixed java quickstart example

2014-12-10 Thread cebe
Github user cebe commented on the pull request: https://github.com/apache/incubator-flink/pull/257#issuecomment-66492576 @rmetzger thats exactly what `hub am` does in one command, you do not need write access to this repo to fetch the commit with hub :) --- If your project is set up

[jira] [Commented] (FLINK-1285) Make execution mode configurable

2014-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241380#comment-14241380 ] ASF GitHub Bot commented on FLINK-1285: --- GitHub user aljoscha opened a pull request:

[GitHub] incubator-flink pull request: [FLINK-1285][FLINK-1137] Make execut...

2014-12-10 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-flink/pull/259 [FLINK-1285][FLINK-1137] Make execution mode configurable These commits enhance the MutableObjectIterator with a next() method that creates a new object for every call. The Execut

[jira] [Resolved] (FLINK-1161) Modify streaming api type extractor classes to allow java 8 lambdas

2014-12-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1161. --- Resolution: Implemented Fix Version/s: 0.8-incubating Implemented via https://git-wip-

[jira] [Resolved] (FLINK-1312) Change OutputSelector to SAM-type to allow lambdas for split operator

2014-12-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1312. --- Resolution: Implemented Fix Version/s: 0.8-incubating Implemented via https://git-wip-

[GitHub] incubator-flink pull request: [FLINK-984] Extension of the API for...

2014-12-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/61#issuecomment-66480629 @markus-h: can you close this pull request? The changes have been merged as part of https://github.com/apache/incubator-flink/pull/245. --- If your project is s

[jira] [Commented] (FLINK-984) Distinct operator for POJO DataSets without KeySelector and on UnsortedGrouping

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

[jira] [Commented] (FLINK-1287) Improve File Input Split assignment

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

[jira] [Created] (FLINK-1319) Add static code analysis for UDFs

2014-12-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1319: --- Summary: Add static code analysis for UDFs Key: FLINK-1319 URL: https://issues.apache.org/jira/browse/FLINK-1319 Project: Flink Issue Type: New Feature

[GitHub] incubator-flink pull request: [FLINK-1287] LocalizableSplitAssigne...

2014-12-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/258#issuecomment-66476877 I tested the pull request on a cluster. The split assignment is now much better. --- If your project is set up for it, you can reply to this email and have you

[jira] [Created] (FLINK-1318) Make quoted String parsing optional and configurable for CSVInputFormats

2014-12-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1318: Summary: Make quoted String parsing optional and configurable for CSVInputFormats Key: FLINK-1318 URL: https://issues.apache.org/jira/browse/FLINK-1318 Project: Flink

[GitHub] incubator-flink pull request: [FLINK-1287] LocalizableSplitAssigne...

2014-12-10 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/incubator-flink/pull/258 [FLINK-1287] LocalizableSplitAssigner prefers splits with less degrees of freedom The current LocalizableSplitAssigner assigns remote and local splits without priorities, i.e., each remote

[jira] [Commented] (FLINK-1287) Improve File Input Split assignment

2014-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241300#comment-14241300 ] ASF GitHub Bot commented on FLINK-1287: --- GitHub user fhueske opened a pull request:

[jira] [Resolved] (FLINK-1040) Make type() call in projections optional (or remove it)

2014-12-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1040. -- Resolution: Fixed Fixed with a9ecaba73c9d134b37720330d89a9cf66ddd4f72 > Make type() call in pro

[GitHub] incubator-flink pull request: [FLINK-1040] Make type() call in pro...

2014-12-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/194 --- 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 featur

[jira] [Commented] (FLINK-1040) Make type() call in projections optional (or remove it)

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

[jira] [Created] (FLINK-1317) Add a standalone version of the Flink Plan Visualizer to the Website

2014-12-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1317: --- Summary: Add a standalone version of the Flink Plan Visualizer to the Website Key: FLINK-1317 URL: https://issues.apache.org/jira/browse/FLINK-1317 Project: Flink

[jira] [Commented] (FLINK-1310) Scala Closure Cleaner logs very aggressive

2014-12-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241180#comment-14241180 ] Stephan Ewen commented on FLINK-1310: - [~aljoscha] Will you make a pull request for th

[jira] [Resolved] (FLINK-1315) Spurious failure in compiler due to corrupt branch tracking logic

2014-12-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1315. - Resolution: Fixed Fixed via ac80458fc089b79f1e793f8760d331a988c407c1 > Spurious failure in compil

[jira] [Updated] (FLINK-1315) Spurious failure in compiler due to corrupt branch tracking logic

2014-12-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1315: Issue Type: Bug (was: Improvement) > Spurious failure in compiler due to corrupt branch tracking lo

[jira] [Resolved] (FLINK-1316) Webclient fails to display plans where nodes are references from multiple iteration closures

2014-12-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1316. - Resolution: Fixed Fixed via a79ea784e6c5ee491cecf5c93aad2248029e3c4b > Webclient fails to display

[GitHub] incubator-flink pull request: Java 8 support for streaming

2014-12-10 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/incubator-flink/pull/256#issuecomment-66459159 Merged. --- 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 featu

[GitHub] incubator-flink pull request: Java 8 support for streaming

2014-12-10 Thread mbalassi
Github user mbalassi closed the pull request at: https://github.com/apache/incubator-flink/pull/256 --- 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 feat

[jira] [Commented] (FLINK-1316) Webclient fails to display plans where nodes are references from multiple iteration closures

2014-12-10 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241140#comment-14241140 ] Alexander Alexandrov commented on FLINK-1316: - I have a student who is working

[jira] [Created] (FLINK-1316) Webclient fails to display plans where nodes are references from multiple iteration closures

2014-12-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1316: --- Summary: Webclient fails to display plans where nodes are references from multiple iteration closures Key: FLINK-1316 URL: https://issues.apache.org/jira/browse/FLINK-1316

[jira] [Created] (FLINK-1315) Spurious failure in compiler due to corrupt branch tracking logic

2014-12-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1315: --- Summary: Spurious failure in compiler due to corrupt branch tracking logic Key: FLINK-1315 URL: https://issues.apache.org/jira/browse/FLINK-1315 Project: Flink

[GitHub] incubator-flink pull request: Mesos integration of Apache Flink

2014-12-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/251#issuecomment-66448210 Cool. I'll try it out again once you've addressed the bugs. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Comment Edited] (FLINK-629) Add support for null values to the java api

2014-12-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241054#comment-14241054 ] Robert Metzger edited comment on FLINK-629 at 12/10/14 1:01 PM: -

[jira] [Commented] (FLINK-629) Add support for null values to the java api

2014-12-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14241054#comment-14241054 ] Robert Metzger commented on FLINK-629: -- Mh. What exactly is not working. I think the p

[GitHub] incubator-flink pull request: Mesos integration of Apache Flink

2014-12-10 Thread skunert
Github user skunert commented on the pull request: https://github.com/apache/incubator-flink/pull/251#issuecomment-66447805 @rmetzger I now am able to test on a cluster and found some bugs which I am working on right now. Nevertheless, your problem described above was something else.

[jira] [Commented] (FLINK-629) Add support for null values to the java api

2014-12-10 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14240997#comment-14240997 ] Alexander Alexandrov commented on FLINK-629: Do we have a separate issue about

[jira] [Commented] (FLINK-1310) Scala Closure Cleaner logs very aggressive

2014-12-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14240959#comment-14240959 ] Aljoscha Krettek commented on FLINK-1310: - +1, change it > Scala Closure Cleaner

[GitHub] incubator-flink pull request: Fixed java quickstart example

2014-12-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/257#issuecomment-66418715 Theoretically yes ;) But we don't have write permissions to this GitHub repository. The account here is a mirror of the ASF git repo. We are manually ch