[jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime

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

[GitHub] flink pull request: [FLINK-986] [FLINK-25] [Distributed runtime] A...

2015-01-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/254 --- 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-986] [FLINK-25] [Distributed runtime] A...

2015-01-12 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/254#issuecomment-69539129 YES!!! --- 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 enabl

[jira] [Commented] (FLINK-25) [GitHub] Offer a buffer-oriented abstraction from Nephele to Pact

2015-01-12 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-25?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14273390#comment-14273390 ] Ufuk Celebi commented on FLINK-25: -- Resolved in d908ca1. > [GitHub] Offer a buffer-oriente

[jira] [Resolved] (FLINK-986) Add intermediate results to distributed runtime

2015-01-12 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-986. --- Resolution: Fixed Fixed in d908ca1. > Add intermediate results to distributed runtime > --

[jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime

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

[jira] [Commented] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

2015-01-12 Thread John Sandiford (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14273415#comment-14273415 ] John Sandiford commented on FLINK-1378: --- Thanks very much. Impressed with the respo

[jira] [Commented] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

2015-01-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14273464#comment-14273464 ] Aljoscha Krettek commented on FLINK-1378: - The 0.8 release is not out yet but if y

[jira] [Updated] (FLINK-1083) WebInterface improvements

2015-01-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-1083: Assignee: (was: Timo Walther) > WebInterface improvements > - > >

[GitHub] flink pull request: [FLINK-1183] Generate gentle notification mess...

2015-01-12 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/296#issuecomment-69552459 Thanks for the PR but I vote to postpone such a warning message. We didn't have a real consensus on the issue (see http://mail-archives.apache.org/mod_mbox/flink-dev/2

[jira] [Commented] (FLINK-1183) Generate gentle notification message when Flink is started with Java 6

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

[jira] [Commented] (FLINK-1183) Generate gentle notification message when Flink is started with Java 6

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

[jira] [Commented] (FLINK-1234) Make Hadoop2 profile default

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

[GitHub] flink pull request: [FLINK-1295][FLINK-883] Allow to deploy 'job o...

2015-01-12 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/292#discussion_r22783544 --- Diff: docs/yarn_setup.md --- @@ -173,6 +171,24 @@ You can check the number of TaskManagers in the JobManager web interface. The ad If the TaskManagers do

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

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

[jira] [Commented] (FLINK-1234) Make Hadoop2 profile default

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

[GitHub] flink pull request: [FLINK-1234] Update documentation configuratio...

2015-01-12 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/295#discussion_r22783345 --- Diff: docs/example_connectors.md --- @@ -90,16 +90,16 @@ Execute the following commands: curl https://raw.githubusercontent.com/apache/incubator-flink/

[GitHub] flink pull request: Commits cherry-picked from the release 0.8 bra...

2015-01-12 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/298 Commits cherry-picked from the release 0.8 branch These commits have only been pushed to the release-0.8 branch, but to my understanding are also needed on the master. They contain some min

[GitHub] flink pull request: [FLINK-1234] Update documentation configuratio...

2015-01-12 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/295#issuecomment-69553641 Just as a reminder: we have to check for the old variable names before merging. #292 for examples updates the docs as well and uses the old variable names. --- If your proje

[GitHub] flink pull request: [FLINK-1183] Generate gentle notification mess...

2015-01-12 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/296#issuecomment-69552932 Hi, I agree that the message is not correct. Flink will run very well with Java 6. BUT: I think we should print a warning because Java 6 is EOL. It is actually a

[jira] [Commented] (FLINK-1234) Make Hadoop2 profile default

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

[GitHub] flink pull request: Commits cherry-picked from the release 0.8 bra...

2015-01-12 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/298#issuecomment-69553906 Hi, can you remove the commit "[FLINK-1385] Print warning if not resources are _currently_ available… …" from the pull request? Since I have a major YARN clien

[GitHub] flink pull request: [FLINK-1234] Update documentation configuratio...

2015-01-12 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/295#issuecomment-69553096 Thanks. +1 to merge after 0.8.0 is out. --- 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-1385) Add option to YARN client to disable resource availability checks

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

[GitHub] flink pull request: Commits cherry-picked from the release 0.8 bra...

2015-01-12 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/298#issuecomment-69554124 Thanks for the heads up, 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 ha

[jira] [Created] (FLINK-1387) Integrate website index.html into jekyll layout.

2015-01-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1387: - Summary: Integrate website index.html into jekyll layout. Key: FLINK-1387 URL: https://issues.apache.org/jira/browse/FLINK-1387 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1387) Integrate website index.html into jekyll layout.

2015-01-12 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14273487#comment-14273487 ] Ufuk Celebi commented on FLINK-1387: This was previously the case. I think this has be

[jira] [Commented] (FLINK-1183) Generate gentle notification message when Flink is started with Java 6

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

[GitHub] flink pull request: [FLINK-1183] Generate gentle notification mess...

2015-01-12 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/296#issuecomment-69556043 I would be fine with such a message if it was more "gentle". ;-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Updated] (FLINK-1382) Void is not added to TypeInfoParser

2015-01-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-1382: Component/s: Java API > Void is not added to TypeInfoParser > --- >

[jira] [Updated] (FLINK-1382) Void is not added to TypeInfoParser

2015-01-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-1382: Affects Version/s: 0.9 > Void is not added to TypeInfoParser > --- >

[GitHub] flink pull request: [FLINK-1382][java] Adds the new basic types Vo...

2015-01-12 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/299 [FLINK-1382][java] Adds the new basic types Void and Date to the TypeInfoParser See also FLINK-1382. You can merge this pull request into a Git repository by running: $ git pull https://github.

[jira] [Commented] (FLINK-1382) Void is not added to TypeInfoParser

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

[jira] [Created] (FLINK-1388) POJO support for writeAsCsv

2015-01-12 Thread Timo Walther (JIRA)
Timo Walther created FLINK-1388: --- Summary: POJO support for writeAsCsv Key: FLINK-1388 URL: https://issues.apache.org/jira/browse/FLINK-1388 Project: Flink Issue Type: New Feature Com

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

2015-01-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1389: - Summary: Allow setting custom file extensions for files created by the FileOutputFormat Key: FLINK-1389 URL: https://issues.apache.org/jira/browse/FLINK-1389 Projec

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

2015-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1389: - Assignee: Robert Metzger > Allow setting custom file extensions for files created by the

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

2015-01-12 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69571778 I've just seen that there is a (pre this PR) check in `DataInputDeserializer.setBuffer(ByteBuffer)` whether the given byte buffer is a direct byte buffer or not. In case that

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

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

[jira] [Resolved] (FLINK-1338) Remove incubating disclaimers and update version name

2015-01-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1338. --- Resolution: Fixed Implemented. > Remove incubating disclaimers and update version name >

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

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

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

2015-01-12 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69582485 Ufuk and me just investigated the cause of the failed integration tests with direct memory management enabled. Turns out, the compare method was implemented incorrectly. ---

[jira] [Commented] (FLINK-1183) Generate gentle notification message when Flink is started with Java 6

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

[GitHub] flink pull request: [FLINK-1183] Generate gentle notification mess...

2015-01-12 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/296#issuecomment-69587009 I would love to keep the PR with modified message about Flink is running in Java6 . --- If your project is set up for it, you can reply to this email and have your repl

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

2015-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14273805#comment-14273805 ] Robert Metzger commented on FLINK-1389: --- current wip https://github.com/rmetzger/fli

[jira] [Created] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X

2015-01-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1390: - Summary: java.lang.ClassCastException: X cannot be cast to X Key: FLINK-1390 URL: https://issues.apache.org/jira/browse/FLINK-1390 Project: Flink Issue Ty

[GitHub] flink pull request: Add [FLINK-1376] Add proper shared slot releas...

2015-01-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/300 Add [FLINK-1376] Add proper shared slot release in case of a fatal TaskManager failure This PR introduces SharedSlots as being a special Slot type and as such being released properly in case an

[jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

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

[jira] [Created] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-01-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1391: - Summary: Kryo fails to properly serialize avro collection types Key: FLINK-1391 URL: https://issues.apache.org/jira/browse/FLINK-1391 Project: Flink Issue

[jira] [Assigned] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1391: - Assignee: Robert Metzger > Kryo fails to properly serialize avro collection types > -

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

2015-01-12 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/301 [FLINK-1389] Allow changing the filenames of the files created when writing to a directory ... You can merge this pull request into a Git repository by running: $ git pull https://github.com/r

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

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

[jira] [Created] (FLINK-1392) Serializing Protobuf - issue 1

2015-01-12 Thread Felix Neutatz (JIRA)
Felix Neutatz created FLINK-1392: Summary: Serializing Protobuf - issue 1 Key: FLINK-1392 URL: https://issues.apache.org/jira/browse/FLINK-1392 Project: Flink Issue Type: Bug Repo

[jira] [Created] (FLINK-1393) Serializing Protobuf - issue 2

2015-01-12 Thread Felix Neutatz (JIRA)
Felix Neutatz created FLINK-1393: Summary: Serializing Protobuf - issue 2 Key: FLINK-1393 URL: https://issues.apache.org/jira/browse/FLINK-1393 Project: Flink Issue Type: Bug Repo

[GitHub] flink pull request: Small cleanup on code after branch for 0.8 rel...

2015-01-12 Thread hsaputra
GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/302 Small cleanup on code after branch for 0.8 release Small cleanup on code after branch for 0.8 release: -) Remove semicolons in Scala code for consistencies. -) Wrap some code in Java that is