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

[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168672#comment-15168672 ] Robert Metzger commented on FLINK-3501: --- Okay, I see. The issue is that on Mac OS X the file system

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

[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168635#comment-15168635 ] ASF GitHub Bot commented on FLINK-3485: --- Github user rmetzger commented on the pull request:

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

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

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

[ 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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168677#comment-15168677 ] ASF GitHub Bot commented on FLINK-3518: --- GitHub user stefanobaghino opened a pull request:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168658#comment-15168658 ] Robert Metzger commented on FLINK-3518: --- This pr fixes already the usage line:

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

[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168681#comment-15168681 ] Stefano Baghino commented on FLINK-3518: Hi [~rmetzger], thanks for pointing it out, I didn't

[jira] [Closed] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken

[ https://issues.apache.org/jira/browse/FLINK-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3526. --- > ProcessingTime Window Assigner and Trigger are broken >

[jira] [Resolved] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken

[ https://issues.apache.org/jira/browse/FLINK-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3526. - Resolution: Fixed Fixed via 64519e1c1593471bc21ef78c7c93591fb75a4fcf > ProcessingTime Window

[jira] [Created] (FLINK-3528) Add Incremental Fold for Non-Keyed Window Operator

Aljoscha Krettek created FLINK-3528: --- Summary: Add Incremental Fold for Non-Keyed Window Operator Key: FLINK-3528 URL: https://issues.apache.org/jira/browse/FLINK-3528 Project: Flink Issue

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169691#comment-15169691 ] ASF GitHub Bot commented on FLINK-3521: --- Github user aljoscha commented on the pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169724#comment-15169724 ] ASF GitHub Bot commented on FLINK-3521: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3521] Make Iterable part of method sign...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1723#issuecomment-189465103 Let's merge this and open a follow-up issue for (1) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169723#comment-15169723 ] ASF GitHub Bot commented on FLINK-3521: --- Github user StephanEwen commented on the pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169694#comment-15169694 ] ASF GitHub Bot commented on FLINK-3521: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3526] [streaming] Fix Processing Time W...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1727#issuecomment-189460270 Okay, will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink pull request: [FLINK-3521] Make Iterable part of method sign...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1723#issuecomment-189462738 The `PassThroughFunction` is created because at that point it is not yet clear what type of `InternalWindowFunction` will be created. I can fix it by duplicating all

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169712#comment-15169712 ] ASF GitHub Bot commented on FLINK-3521: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3521] Make Iterable part of method sign...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1723#issuecomment-189463014 1. Is very hard to fix, ditching the non-keyed window operators altogether and using a dummy key selector would be easier. --- If your project is set up for it, you

[GitHub] flink pull request: [FLINK-3521] Make Iterable part of method sign...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1723#issuecomment-189459860 I like this, especially the natural Scala path. Some concerns, though: 1. As noted before, the fold function in the non-keyed window is not space

[GitHub] flink pull request: [FLINK-3521] Make Iterable part of method sign...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1723#issuecomment-189464956 I think (2) can be done easier if the operator creation code goes into something more generic, but that is not that urgent. --- If your project is set up for it,

[jira] [Commented] (FLINK-3527) Scala DataStream has no transform method

[ https://issues.apache.org/jira/browse/FLINK-3527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169678#comment-15169678 ] ASF GitHub Bot commented on FLINK-3527: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-3527] Add Scala DataStream.transform()

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1728 [FLINK-3527] Add Scala DataStream.transform() You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink scala-transform Alternatively

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169714#comment-15169714 ] ASF GitHub Bot commented on FLINK-3521: --- Github user aljoscha commented on the pull request:

[jira] [Commented] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken

[ https://issues.apache.org/jira/browse/FLINK-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169696#comment-15169696 ] ASF GitHub Bot commented on FLINK-3526: --- Github user StephanEwen commented on the pull request:

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

[ 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

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

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-3449) createInput swallows exception if TypeExtractor fails

[ https://issues.apache.org/jira/browse/FLINK-3449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168804#comment-15168804 ] ASF GitHub Bot commented on FLINK-3449: --- Github user rmetzger commented on the pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168836#comment-15168836 ] Gabor Gevay commented on FLINK-3519: OK, I have found a good reason for the Gelly style subclassing:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168716#comment-15168716 ] Vasia Kalavri commented on FLINK-1707: -- Hey [~joseprupi], thank you for the document! I have left

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

[ https://issues.apache.org/jira/browse/FLINK-3517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168725#comment-15168725 ] ASF GitHub Bot commented on FLINK-3517: --- Github user tillrohrmann commented on the pull request:

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

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

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

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 ...

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

[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168823#comment-15168823 ] Stephan Ewen commented on FLINK-3519: - To allow subclass usage in the style of Gelly > Subclasses of

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

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168826#comment-15168826 ] Till Rohrmann commented on FLINK-3511: -- I agree with [~greghogan] that the best solution would be to

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168778#comment-15168778 ] ASF GitHub Bot commented on FLINK-3437: --- Github user rmetzger commented on the pull request:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168787#comment-15168787 ] Stephan Ewen commented on FLINK-3519: - We came across this issue before. We decided back then that

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

[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168848#comment-15168848 ] ASF GitHub Bot commented on FLINK-3482: --- Github user vasia closed the pull request at:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168792#comment-15168792 ] ASF GitHub Bot commented on FLINK-3437: --- Github user rmetzger commented on the pull request:

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168812#comment-15168812 ] Gabor Gevay commented on FLINK-3519: But if you were aware of this problem, then what was the original

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

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] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168839#comment-15168839 ] Stephan Ewen commented on FLINK-3322: - The numbers look quite similar, only that the initial run

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

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

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

[ 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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168723#comment-15168723 ] ASF GitHub Bot commented on FLINK-3517: --- Github user mxm commented on the pull request:

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

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 @@

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

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

[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168789#comment-15168789 ] ASF GitHub Bot commented on FLINK-3482: --- Github user fhueske commented on the pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168788#comment-15168788 ] ASF GitHub Bot commented on FLINK-3482: --- Github user fhueske commented on a diff in the pull

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168710#comment-15168710 ] ASF GitHub Bot commented on FLINK-3485: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168797#comment-15168797 ] ASF GitHub Bot commented on FLINK-3482: --- Github user vasia commented on the pull request:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168795#comment-15168795 ] ASF GitHub Bot commented on FLINK-3332: --- Github user spdrnl commented on the pull request:

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

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

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

[ 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:

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

[ https://issues.apache.org/jira/browse/FLINK-3434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168798#comment-15168798 ] ASF GitHub Bot commented on FLINK-3434: --- Github user rmetzger commented on the pull request:

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168796#comment-15168796 ] ASF GitHub Bot commented on FLINK-3509: --- Github user rmetzger commented on the pull request:

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

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168847#comment-15168847 ] ASF GitHub Bot commented on FLINK-1159: --- Github user StephanEwen commented on the pull request:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168808#comment-15168808 ] Gabor Gevay commented on FLINK-3519: So you mean that you are in favor of 2? > Subclasses of Tuples

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168852#comment-15168852 ] Vasia Kalavri commented on FLINK-3518: -- I see you've already updated the PR [~stefanobaghino] :) I'll

[GitHub] flink pull request: [FLINK-3511] Create example modules for librar...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1722 [FLINK-3511] Create example modules for libraries and connectors with provided dependencies This PR introduces example modules for libraries and connectors which have provided dependencies.

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

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

[GitHub] flink pull request: [FLINK-3311] Add a connector for streaming dat...

Github user alkagin commented on the pull request: https://github.com/apache/flink/pull/1660#issuecomment-189313813 No objections, sounds 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

[jira] [Assigned] (FLINK-3504) Join fails while have expression inside join condition.

[ https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3504: Assignee: Fabian Hueske > Join fails while have expression inside join condition. >

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

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

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

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

[GitHub] flink pull request: [FLINK-3169] Remove Key class

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1667#issuecomment-189292412 Seems fine now --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Created] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

Stephan Ewen created FLINK-3523: --- Summary: Storm SpoutSplitExample fails with a ClassCastException Key: FLINK-3523 URL: https://issues.apache.org/jira/browse/FLINK-3523 Project: Flink Issue

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

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169122#comment-15169122 ] ASF GitHub Bot commented on FLINK-3511: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request: [FLINK-3311] Add a connector for streaming dat...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1660#issuecomment-189310673 Overall this PR looks good now. I'll go through the documentation more in detail when i unify the docs for this PR and #1640 when merging. Furthermore, I'd like

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169130#comment-15169130 ] ASF GitHub Bot commented on FLINK-3311: --- Github user zentol commented on the pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169147#comment-15169147 ] ASF GitHub Bot commented on FLINK-3521: --- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169149#comment-15169149 ] ASF GitHub Bot commented on FLINK-3311: --- Github user alkagin commented on the pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169076#comment-15169076 ] ASF GitHub Bot commented on FLINK-3390: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-3511] Create example modules for librar...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/1722 --- 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

[GitHub] flink pull request: [FLINK-3511] Create example modules for librar...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1722#issuecomment-189311684 Will put the connector examples in test scope. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

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

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169134#comment-15169134 ] ASF GitHub Bot commented on FLINK-3511: --- Github user tillrohrmann closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169133#comment-15169133 ] ASF GitHub Bot commented on FLINK-3511: --- Github user tillrohrmann commented on the pull request:

[jira] [Assigned] (FLINK-3502) AggregateProjectPullUpConstantsRule fails on certain group keys order.

[ https://issues.apache.org/jira/browse/FLINK-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3502: Assignee: Fabian Hueske > AggregateProjectPullUpConstantsRule fails on certain group keys

[GitHub] flink pull request: [FLINK-3333] [Documentation][DataSet] Improve ...

Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1721#issuecomment-189313026 Why was the "Emitting input objects" field changed? For example, is there a problem with emitting input objects from a JoinFunction? (Like here:

  1   2   3   >