[GitHub] flink pull request: [FLINK-3485] implement toString for Serialized...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1717#issuecomment-189156320 +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 this feature e

[jira] [Commented] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

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

[jira] [Updated] (FLINK-3511) Flink library examples not runnable without adding dependencies

2016-02-26 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-3511: --- Summary: Flink library examples not runnable without adding dependencies (was: Flink

[jira] [Created] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread Stefano Baghino (JIRA)
Stefano Baghino created FLINK-3518: -- Summary: Stale docs for quickstart setup Key: FLINK-3518 URL: https://issues.apache.org/jira/browse/FLINK-3518 Project: Flink Issue Type: Bug C

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168658#comment-15168658 ] Robert Metzger commented on FLINK-3518: --- This pr fixes already the usage line: http

[jira] [Commented] (FLINK-3501) flink-runtime-0.10.2-hadoop-1 jar problem

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168672#comment-15168672 ] Robert Metzger commented on FLINK-3501: --- Okay, I see. The issue is that on Mac OS X

[GitHub] flink pull request: [FLINK-3518] Stale docs for quickstart setup

2016-02-26 Thread stefanobaghino
GitHub user stefanobaghino opened a pull request: https://github.com/apache/flink/pull/1718 [FLINK-3518] Stale docs for quickstart setup * Fix the usage line * Explicitly state to stop the local environment * _Doesn't fix_ the broken download link (no release yet) You can me

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168677#comment-15168677 ] ASF GitHub Bot commented on FLINK-3518: --- GitHub user stefanobaghino opened a pull re

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread Stefano Baghino (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168681#comment-15168681 ] Stefano Baghino commented on FLINK-3518: Hi [~rmetzger], thanks for pointing it ou

[jira] [Commented] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

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

[GitHub] flink pull request: [FLINK-3485] implement toString for Serialized...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1717 --- 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 enab

[jira] [Resolved] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

2016-02-26 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3485. --- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.0.0 Th

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

2016-02-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168716#comment-15168716 ] Vasia Kalavri commented on FLINK-1707: -- Hey [~joseprupi], thank you for the document!

[jira] [Commented] (FLINK-3517) Number of job and task managers not checked in scripts

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

[GitHub] flink pull request: [FLINK-3517] [dist] Only count active PIDs in ...

2016-02-26 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1716#issuecomment-189190990 +1 to merge! I find "No taskmanager daemon (pid: 27140) is running anymore on pablo." confusing. I think we could change it to something like "TaskManager couldn't

[GitHub] flink pull request: [FLINK-3517] [dist] Only count active PIDs in ...

2016-02-26 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1716#issuecomment-189191740 Code changes look good :-) +1 for merging. --- 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 p

[jira] [Commented] (FLINK-3517) Number of job and task managers not checked in scripts

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

[GitHub] flink pull request: [FLINK-3437] [web-dashboard] Fix UI router sta...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1661#issuecomment-189206068 I'll test the change locally --- 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] [Commented] (FLINK-3437) Fix UI router state for job plan

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

[jira] [Created] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-3519: -- Summary: Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant Key: FLINK-3519 URL: https://issues.apache.org/jira/browse/FLINK-3519 Pro

[jira] [Updated] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-3519: --- Affects Version/s: 1.0.0 > Subclasses of Tuples don't work if the declared type of a DataSet is not th

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168787#comment-15168787 ] Stephan Ewen commented on FLINK-3519: - We came across this issue before. We decided b

[GitHub] flink pull request: [FLINK-3482] implement union translation

2016-02-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1715#issuecomment-189208835 Looks good. Can be merged after the comment was added. Thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-3482) Implement Union Support

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

[GitHub] flink pull request: [FLINK-3482] implement union translation

2016-02-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1715#discussion_r54226979 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/logical/FlinkJoinUnionTransposeRule.scala --- @@ -0,0 +1,103 @@

[jira] [Commented] (FLINK-3482) Implement Union Support

2016-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168788#comment-15168788 ] ASF GitHub Bot commented on FLINK-3482: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-3437] [web-dashboard] Fix UI router sta...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1661#issuecomment-189209755 It seems to work. I'm merging the 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 your projec

[jira] [Commented] (FLINK-3482) Implement Union Support

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

[jira] [Commented] (FLINK-3437) Fix UI router state for job plan

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

[GitHub] flink pull request: [FLINK-3482] implement union translation

2016-02-26 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1715#issuecomment-189209810 +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 this feature en

[GitHub] flink pull request: [FLINK-3509] Update Hadoop minor versions to l...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1713#issuecomment-189210145 Merging ... --- 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 e

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

2016-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168795#comment-15168795 ] ASF GitHub Bot commented on FLINK-3332: --- Github user spdrnl commented on the pull re

[GitHub] flink pull request: [FLINK-3482] implement union translation

2016-02-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1715#issuecomment-189210225 Thanks, I will 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 this fe

[GitHub] flink pull request: [FLINK-3332] Add Exactly-Once Cassandra connec...

2016-02-26 Thread spdrnl
Github user spdrnl commented on the pull request: https://github.com/apache/flink/pull/1640#issuecomment-189210134 In some circumstances it is possible to make writes to Cassandra idempotent, by adding an unique id to the insert. See the example below. Counters are probably different

[jira] [Commented] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version

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

[jira] [Resolved] (FLINK-3463) Implement Calc Support

2016-02-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3463. -- Resolution: Fixed > Implement Calc Support > -- > > Key: FLI

[jira] [Commented] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null

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

[jira] [Commented] (FLINK-3482) Implement Union Support

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

[GitHub] flink pull request: [FLINK-3434] Prevent NPE in ClientFrontend#get...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1695#issuecomment-189210454 Merging ... --- 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

[jira] [Commented] (FLINK-3449) createInput swallows exception if TypeExtractor fails

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

[GitHub] flink pull request: [FLINK-3449] createInput() no longer swallows ...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1675#issuecomment-189211582 Merging --- 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

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168808#comment-15168808 ] Gabor Gevay commented on FLINK-3519: So you mean that you are in favor of 2? > Subcla

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168811#comment-15168811 ] Stephan Ewen commented on FLINK-3519: - Yes, I would be in favor of (2). Although, in m

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168812#comment-15168812 ] Gabor Gevay commented on FLINK-3519: But if you were aware of this problem, then what

[jira] [Created] (FLINK-3520) Periodic watermark operator should emit current watermark in close()

2016-02-26 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3520: --- Summary: Periodic watermark operator should emit current watermark in close() Key: FLINK-3520 URL: https://issues.apache.org/jira/browse/FLINK-3520 Project: Flink

[GitHub] flink pull request: [hotfix] [build] Disable exclusion rules when ...

2016-02-26 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1719 [hotfix] [build] Disable exclusion rules when using build-jar maven profile Disables the exclusion rules when using the quickstarts. You can merge this pull request into a Git repository by run

[GitHub] flink pull request: [hotfix] [build] Disable exclusion rules when ...

2016-02-26 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1719#discussion_r54230298 --- Diff: flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml --- @@ -89,6 +89,61 @@ under the License.

[jira] [Assigned] (FLINK-3511) Flink library examples not runnable without adding dependencies

2016-02-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3511: Assignee: Till Rohrmann > Flink library examples not runnable without adding dependencies >

[GitHub] flink pull request: [hotfix] [build] Disable exclusion rules when ...

2016-02-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1719#discussion_r54230573 --- Diff: flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml --- @@ -89,6 +89,61 @@ under the License.

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168823#comment-15168823 ] Stephan Ewen commented on FLINK-3519: - To allow subclass usage in the style of Gelly

[GitHub] flink pull request: [hotfix] [build] Disable exclusion rules when ...

2016-02-26 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1719#issuecomment-189223135 Can also also add a note to the documentation about the build-jar profile? This is just an idea, but maybe we could add the following plugin to the quickst

[jira] [Commented] (FLINK-3511) Flink library examples not runnable without adding dependencies

2016-02-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168826#comment-15168826 ] Till Rohrmann commented on FLINK-3511: -- I agree with [~greghogan] that the best solut

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-02-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168836#comment-15168836 ] Gabor Gevay commented on FLINK-3519: OK, I have found a good reason for the Gelly styl

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168839#comment-15168839 ] Stephan Ewen commented on FLINK-3322: - The numbers look quite similar, only that the i

[GitHub] flink pull request: [FLINK-3495] Disable RocksDB tests on Windows

2016-02-26 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1711#issuecomment-189230055 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] [Commented] (FLINK-3495) RocksDB Tests can't run on Windows

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

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-02-26 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168845#comment-15168845 ] Gabor Gevay commented on FLINK-3322: Actually, these are separate runs, so all of them

[GitHub] flink pull request: [FLINK-3482] implement union translation

2016-02-26 Thread vasia
Github user vasia closed the pull request at: https://github.com/apache/flink/pull/1715 --- 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] [Resolved] (FLINK-3482) Implement Union Support

2016-02-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3482. -- Resolution: Implemented > Implement Union Support > --- > >

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

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

[GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no...

2016-02-26 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1704#issuecomment-189232475 @stefanobaghino Ah, yes, for `DataSet` you need the `ClassTag`, for `DataStream` they should not be needed... --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-3482) Implement Union Support

2016-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168848#comment-15168848 ] ASF GitHub Bot commented on FLINK-3482: --- Github user vasia closed the pull request a

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168852#comment-15168852 ] Vasia Kalavri commented on FLINK-3518: -- I see you've already updated the PR [~stefano

[GitHub] flink pull request: [FLINK-3390] [runtime, tests] Restore savepoin...

2016-02-26 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1720 [FLINK-3390] [runtime, tests] Restore savepoint on ExecutionGraph restart Temporary work around to restore initial state on failure during recovery as required by a user. Will be superseded by FLINK-

[jira] [Commented] (FLINK-3390) Savepoint resume is not retried

2016-02-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168864#comment-15168864 ] ASF GitHub Bot commented on FLINK-3390: --- GitHub user uce opened a pull request:

[GitHub] flink pull request: [FLINK-3437] [web-dashboard] Fix UI router sta...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1661 --- 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 enab

[GitHub] flink pull request: [FLINK-3434] Prevent NPE in ClientFrontend#get...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1695 --- 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 enab

[GitHub] flink pull request: [FLINK-3449] createInput() no longer swallows ...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1675 --- 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 enab

[GitHub] flink pull request: [FLINK-3340] [runtime] Fix object juggling in ...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1626 --- 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 enab

[jira] [Commented] (FLINK-3340) Fix object juggling in drivers

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

[jira] [Commented] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version

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

[jira] [Commented] (FLINK-3437) Fix UI router state for job plan

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

[jira] [Resolved] (FLINK-3340) Fix object juggling in drivers

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3340. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/fa8b0019 >

[jira] [Commented] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null

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

[GitHub] flink pull request: [FLINK-3509] Update Hadoop minor versions to l...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1713 --- 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 enab

[jira] [Commented] (FLINK-3449) createInput swallows exception if TypeExtractor fails

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

[jira] [Resolved] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3509. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in http://git-wip-us.apache.org/repos/a

[jira] [Resolved] (FLINK-3437) Fix UI router state for job plan

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3437. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/ee76fc45 >

[jira] [Resolved] (FLINK-3449) createInput swallows exception if TypeExtractor fails

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3449. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/725f7467 >

[jira] [Resolved] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null

2016-02-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3434. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in http://git-wip-us.apache.org/repos/a

[jira] [Closed] (FLINK-3520) Periodic watermark operator should emit current watermark in close()

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3520. --- > Periodic watermark operator should emit current watermark in close() > -

[jira] [Resolved] (FLINK-3520) Periodic watermark operator should emit current watermark in close()

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3520. - Resolution: Fixed Fixed via de9a878e9555023e1c63f9c41eb281650f4840df > Periodic watermark operato

[GitHub] flink pull request: [hotfix] fix PageRank example to run with no a...

2016-02-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1714#issuecomment-189258774 Thanks, merging. --- 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

[GitHub] flink pull request: [FLINK-3390] [runtime, tests] Restore savepoin...

2016-02-26 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1720#issuecomment-189258963 Looks good to me, pretty good test. Is this crucial for the next 1.0 RC? --- If your project is set up for it, you can reply to this email and have your rep

[jira] [Commented] (FLINK-3390) Savepoint resume is not retried

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

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

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

[GitHub] flink pull request: [FLINK-3518] Stale docs for quickstart setup

2016-02-26 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1718#issuecomment-189259231 Thanks @stefanobaghino. Merging this together with #1714. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[GitHub] flink pull request: [FLINK-3496] Fix ML test discovery on Windows

2016-02-26 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1710#issuecomment-189259306 Looks good, test failure is unrelated --- 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] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

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

[GitHub] flink pull request: [FLINK-3491] Prevent failure of HDFSCopyUtilit...

2016-02-26 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1703#issuecomment-189260386 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] [Commented] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows

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

[jira] [Commented] (FLINK-3511) Flink library examples not runnable without adding dependencies

2016-02-26 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168955#comment-15168955 ] Márton Balassi commented on FLINK-3511: --- Now I get it, after the explanation that [~

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread Stefano Baghino (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15168991#comment-15168991 ] Stefano Baghino commented on FLINK-3518: Thank you, sorry for not noticing your ho

[GitHub] flink pull request: [FLINK-3518] Stale docs for quickstart setup

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1718 --- 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 enab

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

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

[GitHub] flink pull request: [hotfix] fix PageRank example to run with no a...

2016-02-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1714 --- 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 enab

[jira] [Resolved] (FLINK-3518) Stale docs for quickstart setup

2016-02-26 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3518. -- Resolution: Fixed > Stale docs for quickstart setup > --- > >

[jira] [Created] (FLINK-3521) Make Iterable part of method signature for WindowFunction

2016-02-26 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3521: --- Summary: Make Iterable part of method signature for WindowFunction Key: FLINK-3521 URL: https://issues.apache.org/jira/browse/FLINK-3521 Project: Flink

[jira] [Commented] (FLINK-3452) Procuring more Travis CI build capacity for Flink

2016-02-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15169027#comment-15169027 ] Stephan Ewen commented on FLINK-3452: - Thanks, Wes, for reaching out. I'll also try an

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

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

  1   2   3   >