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

2016-02-25 Thread Paul Harris (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168480#comment-15168480 ] Paul Harris commented on FLINK-3501: This seems to be an OSX issue. I have tried with Oracle JDK7 u75,

[jira] [Commented] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService

2016-02-25 Thread sahitya pavurala (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168434#comment-15168434 ] sahitya pavurala commented on FLINK-3461: - I submitted a pull request for this, can you please

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

2016-02-25 Thread Paul Harris (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168206#comment-15168206 ] Paul Harris edited comment on FLINK-3501 at 2/26/16 1:20 AM: - I am on a mac

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

2016-02-25 Thread Paul Harris (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168206#comment-15168206 ] Paul Harris edited comment on FLINK-3501 at 2/26/16 12:57 AM: -- I am on a mac

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

2016-02-25 Thread Paul Harris (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168206#comment-15168206 ] Paul Harris commented on FLINK-3501: I am on a mac with ``` java -version java version "1.7.0_75"

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

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

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

2016-02-25 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1717 [FLINK-3485] implement toString for SerializedListAccumulator You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-3485 Alternatively

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

2016-02-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168139#comment-15168139 ] Maximilian Michels commented on FLINK-3485: --- You're right. The accumulator is printed using the

[jira] [Closed] (FLINK-3510) Pattern class class-level comment misses type argument

2016-02-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3510. -- Resolution: Fixed Fixed in 930a266. > Pattern class class-level comment misses type argument >

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

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

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

2016-02-25 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1716 [FLINK-3517] [dist] Only count active PIDs in start script ```bash $ bin/start-cluster.sh Starting cluster. Starting jobmanager daemon on host pablo. Starting taskmanager daemon on host

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

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

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

2016-02-25 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1626#issuecomment-189004909 Pushed. Thanks for the explanation. --- 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-3340) Fix object juggling in drivers

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

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

2016-02-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1626#issuecomment-188985984 If you can quickly do it, yes. Otherwise whoever merges this tomorrow, please remove the sysout statements. We try to keep the maven output a bit cleaner

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

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

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

2016-02-25 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1626#issuecomment-188982973 @StephanEwen just to clarify, since time is of the essence, would you like me to update the pull request without the println's? --- If your project is set up for it,

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

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

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

2016-02-25 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1715 [FLINK-3482] implement union translation This PR add union support to Table on Calcite. I've implemented a custom `JoinUnionTransposeRule` because Calcite's only matches with LogicalUnion. You

[GitHub] flink pull request: [FLINK-3226] Improvements for expected types

2016-02-25 Thread twalthr
Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/1709 --- 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-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167678#comment-15167678 ] ASF GitHub Bot commented on FLINK-3226: --- Github user twalthr closed the pull request at:

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

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

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

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

[GitHub] flink pull request: [FLINK-3226] Improvements for expected types

2016-02-25 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1709#issuecomment-188933506 You can close this now @twalthr. I've merged it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

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

[GitHub] flink pull request: [FLINK-3513] [FLINK-3512] Fix savepoint issues

2016-02-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1712 --- 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-3463] implement calc translation

2016-02-25 Thread vasia
Github user vasia closed the pull request at: https://github.com/apache/flink/pull/1696 --- 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] [Closed] (FLINK-3512) Savepoint backend should not revert to "jobmanager"

2016-02-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3512. -- Resolution: Fixed Fix Version/s: 1.0.0 Fixed in c9cba27. > Savepoint backend should not revert

[jira] [Closed] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3513. -- Resolution: Fixed Fix Version/s: 1.0.0 Fixed in d90672f. > Fix interplay of automatic Operator

[jira] [Commented] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167654#comment-15167654 ] ASF GitHub Bot commented on FLINK-3513: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-3513] [FLINK-3512] Fix savepoint issues

2016-02-25 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1712#issuecomment-188932532 I'm merging this to master. --- 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] [Created] (FLINK-3517) Number of job and task managers not checked in scripts

2016-02-25 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3517: -- Summary: Number of job and task managers not checked in scripts Key: FLINK-3517 URL: https://issues.apache.org/jira/browse/FLINK-3517 Project: Flink Issue Type:

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

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

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

2016-02-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1626#issuecomment-188929386 This looks good to me. +1 for merging, but removing the System.out.println --- If your project is set up for it, you can reply to this email and have your

[jira] [Created] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :(

2016-02-25 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3516: -- Summary: JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :( Key: FLINK-3516 URL: https://issues.apache.org/jira/browse/FLINK-3516

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

2016-02-25 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1714#issuecomment-188923753 +1 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 have this

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

2016-02-25 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1714 [hotfix] fix PageRank example to run with no args; some doc fixes This PR includes a fix for the java PageRank example to retrieve the required parameter `numPages ` when run with no arguments and

[jira] [Commented] (FLINK-3442) Expose savepoint button on web ui

2016-02-25 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167599#comment-15167599 ] Gyula Fora commented on FLINK-3442: --- I thought that this should be equivalent to calling bin/flink

[jira] [Commented] (FLINK-3277) Use Value types in Gelly API

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167586#comment-15167586 ] ASF GitHub Bot commented on FLINK-3277: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3277] Use Value types in Gelly API

2016-02-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1671#issuecomment-188918217 Thanks for checking this out. Do you have an estimate of how this affects Gelly performance for some algorithms? How much does this improve the performance?

[jira] [Commented] (FLINK-3442) Expose savepoint button on web ui

2016-02-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167572#comment-15167572 ] Stephan Ewen commented on FLINK-3442: - This would rely on some pre-configured default safepoint target

[jira] [Created] (FLINK-3515) Make the "file monitoring source" exactly-once

2016-02-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3515: --- Summary: Make the "file monitoring source" exactly-once Key: FLINK-3515 URL: https://issues.apache.org/jira/browse/FLINK-3515 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167557#comment-15167557 ] ASF GitHub Bot commented on FLINK-3432: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3432] Fixed ZookeeperOffsethandlerTest ...

2016-02-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1664#issuecomment-188911039 Looks good to my, +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

[jira] [Created] (FLINK-3514) Add support for slowly changing streaming broadcast variables

2016-02-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3514: --- Summary: Add support for slowly changing streaming broadcast variables Key: FLINK-3514 URL: https://issues.apache.org/jira/browse/FLINK-3514 Project: Flink

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

2016-02-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167506#comment-15167506 ] Greg Hogan commented on FLINK-3511: --- Is the only difference from {{flink-examples-batch}} that

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

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

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

2016-02-25 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1713 [FLINK-3509] Update Hadoop minor versions to latest & sync travis and release scripts You can merge this pull request into a Git repository by running: $ git pull

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

2016-02-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167446#comment-15167446 ] Márton Balassi commented on FLINK-3511: --- Somewhat sensible for me, but it just propagates the

[jira] [Comment Edited] (FLINK-3511) Flink library examples not runnable withput adding dependencies

2016-02-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167446#comment-15167446 ] Márton Balassi edited comment on FLINK-3511 at 2/25/16 5:03 PM: Somewhat

[GitHub] flink pull request: [FLINK-3463] implement calc translation

2016-02-25 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1696#issuecomment-188878585 Thanks! I'll merge both once Travis passes. --- 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-3463) Implement Calc Support

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

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

2016-02-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167429#comment-15167429 ] Greg Hogan commented on FLINK-3511: --- Then a flink-gelly-examples? > Flink library examples not runnable

[jira] [Commented] (FLINK-3399) Count with timeout trigger

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167426#comment-15167426 ] ASF GitHub Bot commented on FLINK-3399: --- Github user shikhar closed the pull request at:

[GitHub] flink pull request: [FLINK-3399] CountWithTimeoutTrigger

2016-02-25 Thread shikhar
Github user shikhar closed the pull request at: https://github.com/apache/flink/pull/1636 --- 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-3399) Count with timeout trigger

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167425#comment-15167425 ] ASF GitHub Bot commented on FLINK-3399: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3399] CountWithTimeoutTrigger

2016-02-25 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1636#issuecomment-188874847 I would prefer to just add the compassable way, yes. Sorry that you now already put effort into this. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-3399) Count with timeout trigger

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167417#comment-15167417 ] ASF GitHub Bot commented on FLINK-3399: --- Github user shikhar commented on the pull request:

[GitHub] flink pull request: [FLINK-3399] CountWithTimeoutTrigger

2016-02-25 Thread shikhar
Github user shikhar commented on the pull request: https://github.com/apache/flink/pull/1636#issuecomment-188874026 Thanks @StephanEwen, @aljoscha noted on the JIRA that it may be better to create a composable mechanism like `Any.of(,)` Until that exists, I do think this is

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

2016-02-25 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167415#comment-15167415 ] Gabor Gevay commented on FLINK-3322: It's making it even worse: false, 500m: 30s false, 5000m: 115s

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

2016-02-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167416#comment-15167416 ] Márton Balassi commented on FLINK-3511: --- I am against moving the examples of a library out of the

[jira] [Commented] (FLINK-3399) Count with timeout trigger

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167413#comment-15167413 ] ASF GitHub Bot commented on FLINK-3399: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3399] CountWithTimeoutTrigger

2016-02-25 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1636#issuecomment-188872638 Sorry for the late response, most people are fixing issues for the 1.0 release candidates. This actually looks like a nice addition. +1 for adding a

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

2016-02-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167404#comment-15167404 ] Greg Hogan commented on FLINK-3511: --- Could the Gelly examples be moved to flink-examples-batch? > Flink

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

2016-02-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167402#comment-15167402 ] Stephan Ewen commented on FLINK-3322: - How does the off-heap memory setting affect these stats? Do the

[jira] [Commented] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167393#comment-15167393 ] ASF GitHub Bot commented on FLINK-3513: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-3513] [FLINK-3512] Fix savepoint issues

2016-02-25 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1712#issuecomment-188862999 `mvn clean verify` was successful on my local machine, so if we need this for a new RC, we can merge it before the Travis run finishes. --- If your project is set up for

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

2016-02-25 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167377#comment-15167377 ] Gabor Gevay commented on FLINK-3322: I have constructed a much simpler example to demonstrate the

[jira] [Commented] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167373#comment-15167373 ] ASF GitHub Bot commented on FLINK-3513: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-3513] [FLINK-3512] Fix savepoint issues

2016-02-25 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1712#issuecomment-188858495 :+1: --- 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-3501) flink-runtime-0.10.2-hadoop-1 jar problem

2016-02-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167351#comment-15167351 ] Robert Metzger commented on FLINK-3501: --- I'm not able to reproduce the issue: {code} 1

[jira] [Commented] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

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

[GitHub] flink pull request: [FLINK-3513] [FLINK-3512] Fix savepoint issues

2016-02-25 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1712 [FLINK-3513] [FLINK-3512] Fix savepoint issues @aljoscha spotted the following two issues (so far) while working with savepoints and the rocks DB state backend. - FLINK-3513: The operator name

[jira] [Created] (FLINK-3512) Savepoint backend should not revert to "jobmanager"

2016-02-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3512: --- Summary: Savepoint backend should not revert to "jobmanager" Key: FLINK-3512 URL: https://issues.apache.org/jira/browse/FLINK-3512 Project: Flink

[jira] [Updated] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3513: Assignee: Ufuk Celebi > Fix interplay of automatic Operator UID and Changing name of

[jira] [Created] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator

2016-02-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3513: --- Summary: Fix interplay of automatic Operator UID and Changing name of WindowOperator Key: FLINK-3513 URL: https://issues.apache.org/jira/browse/FLINK-3513

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

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167330#comment-15167330 ] ASF GitHub Bot commented on FLINK-3463: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [FLINK-3463] implement calc translation

2016-02-25 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1696#issuecomment-188846370 +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 project does not have this

[jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

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

[GitHub] flink pull request: git push -f[FLINK-3496] Disable RocksDB tests ...

2016-02-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/1711 git push -f[FLINK-3496] Disable RocksDB tests on Windows You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 3496_rocksdb_disable

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

2016-02-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/1710 [FLINK-3496] Fix ML test discovery on Windows This PR adds OS specific arguments in the flink-ml pom that are passed to the scala test runner. The runner uses pattern matching to discover

[jira] [Commented] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

2016-02-25 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167301#comment-15167301 ] Chengxiang Li commented on FLINK-3508: -- Merged to tableOnCalcite branch at

[jira] [Closed] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

2016-02-25 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li closed FLINK-3508. > Add more test cases to verify the rules of logical plan optimization >

[jira] [Resolved] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

2016-02-25 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li resolved FLINK-3508. -- Resolution: Fixed > Add more test cases to verify the rules of logical plan optimization >

[jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

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

[jira] [Comment Edited] (FLINK-3496) Flink-ml tests fail on Windows

2016-02-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167281#comment-15167281 ] Chesnay Schepler edited comment on FLINK-3496 at 2/25/16 2:56 PM: -- using

[jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

2016-02-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167281#comment-15167281 ] Chesnay Schepler commented on FLINK-3496: - using

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167277#comment-15167277 ] ASF GitHub Bot commented on FLINK-3398: --- Github user shikhar commented on the pull request:

[GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of...

2016-02-25 Thread shikhar
Github user shikhar commented on the pull request: https://github.com/apache/flink/pull/1690#issuecomment-188818665 Just fixed the `Kafka09ITCase.testCheckpointing()` fail as well, hopefully CI is green with that. --- If your project is set up for it, you can reply to this email and

[jira] [Created] (FLINK-3511) Flink library examples not runnable withput adding dependencies

2016-02-25 Thread JIRA
Márton Balassi created FLINK-3511: - Summary: Flink library examples not runnable withput adding dependencies Key: FLINK-3511 URL: https://issues.apache.org/jira/browse/FLINK-3511 Project: Flink

[jira] [Created] (FLINK-3510) Pattern class class-level comment misses type argument

2016-02-25 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3510: -- Summary: Pattern class class-level comment misses type argument Key: FLINK-3510 URL: https://issues.apache.org/jira/browse/FLINK-3510 Project: Flink Issue Type:

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

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167209#comment-15167209 ] ASF GitHub Bot commented on FLINK-1159: --- Github user stefanobaghino commented on the pull request:

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

2016-02-25 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1704#issuecomment-188790808 @StephanEwen I had to restore some of the context bounds on `ClassTag` to make it compile, apparently the delegated methods use them; I've rebased with the

[jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

2016-02-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167186#comment-15167186 ] Chesnay Schepler commented on FLINK-3496: - may a fix for this coming up, running on travis now. >

[GitHub] flink pull request: [FLINK-3332] Cassandra connector

2016-02-25 Thread spdrnl
Github user spdrnl commented on a diff in the pull request: https://github.com/apache/flink/pull/1620#discussion_r54090368 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java --- @@ -0,0 +1,173 @@ +/** + *

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

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167166#comment-15167166 ] ASF GitHub Bot commented on FLINK-3332: --- Github user spdrnl commented on a diff in the pull request:

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

2016-02-25 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3509: - Summary: Update Hadoop versions in release script and on travis to the latest minor version Key: FLINK-3509 URL: https://issues.apache.org/jira/browse/FLINK-3509

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

2016-02-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167115#comment-15167115 ] ASF GitHub Bot commented on FLINK-3226: --- Github user twalthr closed the pull request at:

[GitHub] flink pull request: [FLINK-3226] Translation of scalar function su...

2016-02-25 Thread twalthr
Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/1679 --- 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-1707) Add an Affinity Propagation Library Method

2016-02-25 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167061#comment-15167061 ] Josep Rubió commented on FLINK-1707: Sorry, I did the document in sharelatex but I forgot to share it

  1   2   >