[jira] [Resolved] (FLINK-1385) Add option to YARN client to disable resource availability checks

2015-01-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1385. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

2015-01-23 Thread Gianmarco De Francisci Morales (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289486#comment-14289486 ] Gianmarco De Francisci Morales commented on FLINK-1421: --- Indeed,

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-01-23 Thread Fridtjof Sander (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289511#comment-14289511 ] Fridtjof Sander commented on FLINK-1297: I started to prototype the design for

[jira] [Resolved] (FLINK-1295) Add option to Flink client to start a YARN session per job

2015-01-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1295. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in

[jira] [Commented] (FLINK-1201) Graph API for Flink

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289564#comment-14289564 ] ASF GitHub Bot commented on FLINK-1201: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-1381) Only one output splitter supported per operator

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289834#comment-14289834 ] ASF GitHub Bot commented on FLINK-1381: --- GitHub user qmlmoon opened a pull request:

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

2015-01-23 Thread mustafa elbehery (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289753#comment-14289753 ] mustafa elbehery commented on FLINK-629: [~rmetzger] I need this fix into

[jira] [Commented] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-01-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289913#comment-14289913 ] Fabian Hueske commented on FLINK-1342: -- This is also true for all dependencies which

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

2015-01-23 Thread cebe
Github user cebe commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-71268972 that really sounds like great fun :) --- 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

[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-23 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/328#discussion_r23485615 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -175,62 +175,79 @@ import

[jira] [Resolved] (FLINK-1406) Windows compatibility

2015-01-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1406. -- Resolution: Fixed Fix Version/s: 0.9 Fixed in 96585f149c8d100f3d8fce2bb737743695f20c12

[jira] [Updated] (FLINK-1344) Add implicit conversion from scala streams to DataStreams

2015-01-23 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paris Carbone updated FLINK-1344: - Description: Source definitions in the scala-api pass a collector to the UDF, thus enforcing an

[GitHub] flink pull request: [FLINK-1352] [runtime] Fix buggy registration ...

2015-01-23 Thread hsaputra
Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/328#discussion_r23485570 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -175,62 +175,79 @@ import

[jira] [Updated] (FLINK-1344) Add implicit conversion from scala streams to DataStreams

2015-01-23 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paris Carbone updated FLINK-1344: - Summary: Add implicit conversion from scala streams to DataStreams (was: Add implicit

[jira] [Created] (FLINK-1438) ClassCastException for Custom InputSplit in local mode

2015-01-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1438: Summary: ClassCastException for Custom InputSplit in local mode Key: FLINK-1438 URL: https://issues.apache.org/jira/browse/FLINK-1438 Project: Flink Issue

[GitHub] flink pull request: [FLINK-1168] Adds multi-char field delimiter s...

2015-01-23 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/264#issuecomment-71285644 That's a good point. I copied the code from the DelimitedInputFormat which allows to specify the charset for the record delimiter. So if we go with 1. we should

[jira] [Commented] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14290218#comment-14290218 ] ASF GitHub Bot commented on FLINK-1168: --- Github user fhueske commented on the pull

[jira] [Created] (FLINK-1440) Missing plan visualizer image for http://flink.apache.org/docs/0.8/programming_guide.html page

2015-01-23 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-1440: Summary: Missing plan visualizer image for http://flink.apache.org/docs/0.8/programming_guide.html page Key: FLINK-1440 URL: https://issues.apache.org/jira/browse/FLINK-1440

[GitHub] flink pull request: [FLINK-1353] Fixes the Execution to use the co...

2015-01-23 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/325#issuecomment-71170205 I'll 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 does not have this

[jira] [Commented] (FLINK-1353) Execution always uses DefaultAkkaAskTimeout, rather than the configured value

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289029#comment-14289029 ] ASF GitHub Bot commented on FLINK-1353: --- Github user tillrohrmann commented on the

[jira] [Assigned] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-23 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max Michels reassigned FLINK-1436: -- Assignee: Max Michels Command-line interface verbose option (-v)

[jira] [Commented] (FLINK-1353) Execution always uses DefaultAkkaAskTimeout, rather than the configured value

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289043#comment-14289043 ] ASF GitHub Bot commented on FLINK-1353: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-1353) Execution always uses DefaultAkkaAskTimeout, rather than the configured value

2015-01-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1353. Resolution: Fixed Fixed with a5702b69ed7794abdd44035581077b09fc551450. Execution always uses

[GitHub] flink pull request: [FLINK-1353] Fixes the Execution to use the co...

2015-01-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/325 --- 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

[jira] [Commented] (FLINK-1352) Buggy registration from TaskManager to JobManager

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289085#comment-14289085 ] ASF GitHub Bot commented on FLINK-1352: --- Github user tillrohrmann commented on the

[GitHub] flink pull request: [FLINK-1389] Allow changing the filenames of t...

2015-01-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/301#issuecomment-71178244 Hadoops `FileOutputFormat` has the following method ```java public static String getUniqueName(JobConf conf, String name) { int partition =

[jira] [Commented] (FLINK-1425) Turn lazy operator execution off for streaming programs

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289273#comment-14289273 ] ASF GitHub Bot commented on FLINK-1425: --- GitHub user uce opened a pull request:

[jira] [Updated] (FLINK-1436) Command-line interface verbose option error reporting

2015-01-23 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Max Michels updated FLINK-1436: --- Summary: Command-line interface verbose option error reporting (was: Command-line interface verbose

[jira] [Commented] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-23 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289416#comment-14289416 ] Max Michels commented on FLINK-1436: https://github.com/apache/flink/pull/331

[jira] [Comment Edited] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

2015-01-23 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289468#comment-14289468 ] Paris Carbone edited comment on FLINK-1421 at 1/23/15 4:29 PM:

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons

2015-01-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/326#issuecomment-71204417 Yes. The package seems to be still wrong. --- 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] [Updated] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

2015-01-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1433: -- Fix Version/s: 0.8.1 Add HADOOP_CLASSPATH to start scripts

[jira] [Commented] (FLINK-1389) Allow setting custom file extensions for files created by the FileOutputFormat

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289366#comment-14289366 ] ASF GitHub Bot commented on FLINK-1389: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-1427) Configuration through environment variables

2015-01-23 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289427#comment-14289427 ] Ufuk Celebi commented on FLINK-1427: You could easily check whether the variable is

[jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

2015-01-23 Thread Paris Carbone (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289468#comment-14289468 ] Paris Carbone commented on FLINK-1421: -- :) Samoa is a really interesting project, we

[GitHub] flink pull request: [Flink-1436] refactor CLiFrontend to provide m...

2015-01-23 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/331#discussion_r23455785 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -960,14 +960,15 @@ public int parseParameters(String[] args) {

[GitHub] flink pull request: [Flink-1436] refactor CLiFrontend to provide m...

2015-01-23 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/331#discussion_r23455746 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -945,13 +948,10 @@ private int handleError(Throwable t) {

[GitHub] flink pull request: [Flink-1436] refactor CLiFrontend to provide m...

2015-01-23 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/331 [Flink-1436] refactor CLiFrontend to provide more identifiable and meaningful error messages You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-1436) Command-line interface verbose option (-v)

2015-01-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289426#comment-14289426 ] ASF GitHub Bot commented on FLINK-1436: --- Github user rmetzger commented on the pull