[jira] [Created] (FLINK-1233) Flaky Test AggregateITCase

2014-11-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1233: --- Summary: Flaky Test AggregateITCase Key: FLINK-1233 URL: https://issues.apache.org/jira/browse/FLINK-1233 Project: Flink Issue Type: Bug Components:

[jira] [Closed] (FLINK-1227) KeySelector can't implement ResultTypeQueryable

2014-11-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-1227. --- Resolution: Not a Problem > KeySelector can't implement ResultTypeQueryable >

[GitHub] incubator-flink pull request: [Flink-1186] Fix wrong flat key posi...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/169#issuecomment-62415673 The travis build passed. I'm going to merge this. I'll merge this also to the 0.7 branch because I would like to include it in the next bugfix release.

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread fpompermaier
Github user fpompermaier commented on the pull request: https://github.com/apache/incubator-flink/pull/172#issuecomment-62415304 Yes..I'm not very familiar with Git..before committing the last changes I synched with the latest version of the master and the I recommitted...however you

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20094591 --- Diff: flink-addons/flink-hbase/pom.xml --- @@ -116,20 +109,74 @@ under the License. -

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20094611 --- Diff: flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -19,186 +19,72 @@ packag

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/172#issuecomment-62414461 Commit 0c8de722e9230180b7f881d411e56e8a4ec0fe45 in this pull request seems to contain a lot of changes already merged into master? Github shows me that the P

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

2014-11-10 Thread Markus Holzemer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204968#comment-14204968 ] Markus Holzemer commented on FLINK-1228: I think this is a good idea! The webinter

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20093842 --- Diff: flink-addons/flink-hbase/pom.xml --- @@ -116,20 +109,74 @@ under the License. -

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

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

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

2014-11-10 Thread dukechain
GitHub user dukechain opened a pull request: https://github.com/apache/incubator-flink/pull/194 [FLINK-1040] Make type() call in projections optional (or remove it) The original version of projection requires a type() to specify the types of output dataset, e.g., dataset.project(0).

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20091789 --- Diff: flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -19,186 +19,72 @@ package or

[GitHub] incubator-flink pull request: [FLINK-1323] implementation that use...

2014-11-10 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/incubator-flink/pull/193 [FLINK-1323] implementation that uses callbacks on completed write requests. Refactor I/O Manager Readers and Writers to interfaces, ... - add - This change also allows for a ve

[jira] [Created] (FLINK-1232) Allow I/O spill file writers to work with futures/callbacks

2014-11-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1232: --- Summary: Allow I/O spill file writers to work with futures/callbacks Key: FLINK-1232 URL: https://issues.apache.org/jira/browse/FLINK-1232 Project: Flink Issu

[jira] [Commented] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash"

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

[jira] [Commented] (FLINK-1113) Clean up JQuery Dependencies

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

[jira] [Commented] (FLINK-1211) EOL character of Windows Batch files should be CRLF

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

[GitHub] incubator-flink pull request: [FLINK-1211] EOL character of Window...

2014-11-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/179 --- 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: [FLINK-1212] Interpreter directive i...

2014-11-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/180 --- 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: [FLINK-1113] clean up JQuery depende...

2014-11-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-flink/pull/178 --- 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: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20090518 --- Diff: flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -19,186 +19,72 @@ packag

[jira] [Created] (FLINK-1231) Add test for streaming remote execution

2014-11-10 Thread JIRA
Márton Balassi created FLINK-1231: - Summary: Add test for streaming remote execution Key: FLINK-1231 URL: https://issues.apache.org/jira/browse/FLINK-1231 Project: Flink Issue Type: Test

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20090375 --- Diff: flink-addons/flink-hbase/pom.xml --- @@ -116,20 +109,74 @@ under the License. -

[jira] [Commented] (FLINK-1195) Improvement of benchmarking infrastructure

2014-11-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204922#comment-14204922 ] Till Rohrmann commented on FLINK-1195: -- I looked briefly over Peel and I agree with y

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20089750 --- Diff: flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -19,186 +19,72 @@ package or

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20089597 --- Diff: flink-addons/flink-hbase/pom.xml --- @@ -116,20 +109,74 @@ under the License. -

[jira] [Assigned] (FLINK-1192) Streaming source fault tolerance

2014-11-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-1192: Assignee: Gábor Hermann (was: Márton Balassi) > Streaming source fault tolerance > ---

[jira] [Created] (FLINK-1230) Add embedded collection execution to documentation

2014-11-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1230: --- Summary: Add embedded collection execution to documentation Key: FLINK-1230 URL: https://issues.apache.org/jira/browse/FLINK-1230 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-1229) Synchronize WebClient arguments with command line arguments

2014-11-10 Thread Timo Walther (JIRA)
Timo Walther created FLINK-1229: --- Summary: Synchronize WebClient arguments with command line arguments Key: FLINK-1229 URL: https://issues.apache.org/jira/browse/FLINK-1229 Project: Flink Issu

[jira] [Resolved] (FLINK-1113) Clean up JQuery Dependencies

2014-11-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1113. - Resolution: Fixed Fix Version/s: 0.8-incubating Merged in 1e979e90f1fef9a38e6e058658f6cb86d

[jira] [Resolved] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash"

2014-11-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1212. - Resolution: Fixed Fix Version/s: 0.8-incubating Merged and fixed in 90730fe31ee3528e3258ef5

[jira] [Resolved] (FLINK-1213) Add .gitattributes to normalize EOL character.

2014-11-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1213. - Resolution: Fixed Fix Version/s: 0.8-incubating Merged in 4b75d83ebc5f1217c5280c4a73127f88e

[jira] [Resolved] (FLINK-1211) EOL character of Windows Batch files should be CRLF

2014-11-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1211. - Resolution: Fixed Fix Version/s: 0.8-incubating Assignee: Stephan Ewen (was: Fabia

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204892#comment-14204892 ] Timo Walther commented on FLINK-1225: - I'll open an issue for that. > Quickstart does

[jira] [Comment Edited] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204890#comment-14204890 ] Timo Walther edited comment on FLINK-1225 at 11/10/14 3:29 PM: -

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204890#comment-14204890 ] Timo Walther commented on FLINK-1225: - Pretty, legacy. I never heard of this command :

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204885#comment-14204885 ] Stephan Ewen commented on FLINK-1225: - In the webclient, the {{-c}} option is not supp

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204867#comment-14204867 ] Timo Walther commented on FLINK-1225: - Sorry, it seems that it was my fault. I forgot

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

2014-11-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1168: - Assignee: Manu Kaul (was: Fabian Hueske) > Support multi-character field delimiters in CSVInputFo

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

2014-11-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204863#comment-14204863 ] Fabian Hueske commented on FLINK-1168: -- No problem, it's yours :-) I'll reassign it t

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread NilsEngelbach
Github user NilsEngelbach closed the pull request at: https://github.com/apache/incubator-flink/pull/188 --- 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

[jira] [Commented] (FLINK-1227) KeySelector can't implement ResultTypeQueryable

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

[GitHub] incubator-flink pull request: [FLINK-1227] KeySelector can now ext...

2014-11-10 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/incubator-flink/pull/192 --- 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-1227) KeySelector can't implement ResultTypeQueryable

2014-11-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204823#comment-14204823 ] Chesnay Schepler commented on FLINK-1227: - if i change the code to {code:java} p

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

2014-11-10 Thread Arvid Heise (JIRA)
Arvid Heise created FLINK-1228: -- Summary: Add REST Interface to JobManager Key: FLINK-1228 URL: https://issues.apache.org/jira/browse/FLINK-1228 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1227) KeySelector can't implement ResultTypeQueryable

2014-11-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204818#comment-14204818 ] Chesnay Schepler commented on FLINK-1227: - oh you are right...i see, i missed the

[GitHub] incubator-flink pull request: [FLINK-1227] KeySelector can now ext...

2014-11-10 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/incubator-flink/pull/192#issuecomment-62386486 Why is this change necessary? `getUnaryOperatorReturnType()` already checks for ResultTypeQueryable... --- If your project is set up for it, you can reply to th

[jira] [Commented] (FLINK-1227) KeySelector can't implement ResultTypeQueryable

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

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

2014-11-10 Thread Manu Kaul (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204766#comment-14204766 ] Manu Kaul commented on FLINK-1168: -- Sorry didn't see that it was already assigned. If you

[jira] [Commented] (FLINK-1213) Add .gitattributes to normalize EOL character.

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

[jira] [Commented] (FLINK-1213) Add .gitattributes to normalize EOL character.

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

[GitHub] incubator-flink pull request: [FLINK-1213] Add .gitattributes to n...

2014-11-10 Thread sarutak
Github user sarutak closed the pull request at: https://github.com/apache/incubator-flink/pull/181 --- 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 featu

[jira] [Commented] (FLINK-1217) Keepalive option should be set to sockets in Client and Server

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

[GitHub] incubator-flink pull request: [FLINK-1213] Add .gitattributes to n...

2014-11-10 Thread sarutak
Github user sarutak commented on the pull request: https://github.com/apache/incubator-flink/pull/181#issuecomment-62382496 @rmetzger Thanks for notification. I close this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-1217) Keepalive option should be set to sockets in Client and Server

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

[GitHub] incubator-flink pull request: [FLINK-1217] Keepalive option should...

2014-11-10 Thread sarutak
Github user sarutak closed the pull request at: https://github.com/apache/incubator-flink/pull/182 --- 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 featu

[GitHub] incubator-flink pull request: [FLINK-1217] Keepalive option should...

2014-11-10 Thread sarutak
Github user sarutak commented on the pull request: https://github.com/apache/incubator-flink/pull/182#issuecomment-62382371 Actually, I have never hit issues caused by not setting keepalive. It's just usual practice of socket programming but ping can work well. I'll close this PR for

[GitHub] incubator-flink pull request: [FLINK-1227] KeySelector can now ext...

2014-11-10 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/incubator-flink/pull/192 [FLINK-1227] KeySelector can now extend ResultTypeQueryable You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/incubator-flink KS_RT

[jira] [Commented] (FLINK-1227) KeySelector can't implement ResultTypeQueryable

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

[jira] [Created] (FLINK-1227) KeySelector can't implement ResultTypeQueryable

2014-11-10 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-1227: --- Summary: KeySelector can't implement ResultTypeQueryable Key: FLINK-1227 URL: https://issues.apache.org/jira/browse/FLINK-1227 Project: Flink Issue Typ

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20078222 --- Diff: flink-addons/flink-hbase/pom.xml --- @@ -1,22 +1,14 @@ - + --- End diff -- Ok, now I should have fixed that

[GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase...

2014-11-10 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/incubator-flink/pull/172#discussion_r20077721 --- Diff: flink-addons/flink-hbase/pom.xml --- @@ -1,22 +1,14 @@ - + --- End diff -- The comment looks truncated by an aut

[jira] [Created] (FLINK-1226) No way to give Configuration to DataSource

2014-11-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1226: Summary: No way to give Configuration to DataSource Key: FLINK-1226 URL: https://issues.apache.org/jira/browse/FLINK-1226 Project: Flink Issue Type: Improvem

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62372502 Thanks for clarification. Sounds like a good approach to me. So let's restrict this issue / PR to logging the state and open a new JIRA issue to deal with ful

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62372174 It uses all of them, round robin fashion. (Actually one I/O thread is sticky with one directory, but files are distributed round robin across threads).

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204667#comment-14204667 ] Robert Metzger commented on FLINK-1225: --- I tried to reproduce the issue but I couldn

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62371767 @StephanEwen What exactly do you mean by switching to a different temp dir? Isn't the IOManager always using all configured directories for parallel IO (on p

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204664#comment-14204664 ] Stephan Ewen commented on FLINK-1225: - You don't need a {{program-class}} entry. A {{M

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread NilsEngelbach
Github user NilsEngelbach commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62370346 I didn't felt criticized, I just wanted to try the new suggested approach. --- If your project is set up for it, you can reply to this email and have your

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62369311 Hey @NilsEngelbach, I was not criticizing your work. The code looks actually quite good. I think this is a discussion between Flink committers on how to

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62367133 I guess the tricky thing with the approach to switch to a different temp directory is the following: You may start writing to a file when the disk ha

[GitHub] incubator-flink pull request: [Flink-1142] Log information about I...

2014-11-10 Thread NilsEngelbach
Github user NilsEngelbach commented on the pull request: https://github.com/apache/incubator-flink/pull/188#issuecomment-62366603 I tried to implement the feature as it was described in jira without reconsidering the described approach because i am totally new to FLINK. Your improv

[jira] [Commented] (FLINK-1139) HadoopOutputFormat fails for DOP > 1

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

[GitHub] incubator-flink pull request: [FLINK-1139] Fix for HadoopOF with D...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/173#issuecomment-62366100 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 f

[GitHub] incubator-flink pull request: Improved input type inference, bug f...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/176#issuecomment-62365429 Since there are a lot of tests for the TypeExtrator, the change is good to merge. --- If your project is set up for it, you can reply to this email and have yo

[jira] [Commented] (FLINK-1019) Rework RPC service

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

[GitHub] incubator-flink pull request: [FLINK-1019] Implementation of akka ...

2014-11-10 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/incubator-flink/pull/149#issuecomment-62364769 There are some minor issues we discovered when going over the code with Stephan. I first have to address them. These include amongst others: * Local

[jira] [Commented] (FLINK-1213) Add .gitattributes to normalize EOL character.

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

[GitHub] incubator-flink pull request: [FLINK-1212] Interpreter directive i...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/180#issuecomment-62364389 Ah. The issue hasn't been merged to Flink. @StephanEwen referenced to it from his "incubator-flink" branch. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash"

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

[jira] [Commented] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash"

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

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

2014-11-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204591#comment-14204591 ] Fabian Hueske commented on FLINK-1168: -- Hi Manu, I actually started working on this i

[GitHub] incubator-flink pull request: [FLINK-1213] Add .gitattributes to n...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/181#issuecomment-62364216 Hey @sarutak, can you close the issue for us? (We don't have permissions to do that) It seems that GitHub did not properly detect that the pull request has b

[GitHub] incubator-flink pull request: [FLINK-1212] Interpreter directive i...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/180#issuecomment-62364307 Can you close the pull request manually? It seems like GitHub is unable to detect the close comments. --- If your project is set up for it, you can reply to th

[jira] [Commented] (FLINK-1217) Keepalive option should be set to sockets in Client and Server

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

[GitHub] incubator-flink pull request: [FLINK-1217] Keepalive option should...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/182#issuecomment-62363477 @sarutak: Have you experienced an issue that you've fixed with this change? --- If your project is set up for it, you can reply to this email and have your repl

[GitHub] incubator-flink pull request: [FLINK-1019] Implementation of akka ...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/149#issuecomment-62362286 What are the plans for merging this change? --- 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] [Commented] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead.

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

[jira] [Commented] (FLINK-1019) Rework RPC service

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

[GitHub] incubator-flink pull request: [FLINK-1218] Don't use "new Integer"...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/183#issuecomment-62362208 Looks good 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 hav

[jira] [Commented] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead.

2014-11-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204570#comment-14204570 ] Robert Metzger commented on FLINK-1218: --- Hey [~sarutak], I gave you "Contributor" pe

[jira] [Updated] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead.

2014-11-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1218: -- Assignee: Kousuke Saruta > Don't use "new Integer". Use "Integer.valueOf" instead. > ---

[jira] [Updated] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-1225: Attachment: quickstart-0.1-flink-fat-jar.jar > Quickstart does not work > >

[jira] [Updated] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-1225: Attachment: quickstart-0.1.jar > Quickstart does not work > > >

[jira] [Commented] (FLINK-1225) Quickstart does not work

2014-11-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204568#comment-14204568 ] Timo Walther commented on FLINK-1225: - I have tried it with the newest 0.8-SNAPSHOT bu

[jira] [Commented] (FLINK-1223) Allow value escaping in CSV files

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

[GitHub] incubator-flink pull request: [FLINK-1223] Allow value escaping in...

2014-11-10 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/incubator-flink/pull/187#issuecomment-62361647 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 f

[jira] [Comment Edited] (FLINK-1223) Allow value escaping in CSV files

2014-11-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204565#comment-14204565 ] Robert Metzger edited comment on FLINK-1223 at 11/10/14 9:45 AM: ---

[jira] [Updated] (FLINK-1223) Allow value escaping in CSV files

2014-11-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1223: -- Assignee: Johannes > Allow value escaping in CSV files > - > >

[jira] [Commented] (FLINK-1223) Allow value escaping in CSV files

2014-11-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14204565#comment-14204565 ] Robert Metzger commented on FLINK-1223: --- Hey [~jkirsch], I have you "Contributor" pe

  1   2   >