[GitHub] flink pull request: Add the class member variables with 'this'

2015-03-20 Thread matadorhong
GitHub user matadorhong opened a pull request: https://github.com/apache/flink/pull/507 Add the class member variables with 'this' Just add the class member variables with 'this' like other class member variables in other class member function byunified format for good reading. You

[jira] [Commented] (FLINK-1688) Add socket sink

2015-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372079#comment-14372079 ] ASF GitHub Bot commented on FLINK-1688: --- Github user miguel0afd commented on the pul

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

2015-03-20 Thread miguel0afd
Github user miguel0afd commented on the pull request: https://github.com/apache/flink/pull/484#issuecomment-84141928 Sorry for the mess, I made a mistake with a undesired merge... Anyway, I can create a new branch in my fork repository and create a new pull request if that helps. --

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372033#comment-14372033 ] Gyula Fora commented on FLINK-1764: --- I removed the accidental filter double copy in this

[jira] [Resolved] (FLINK-1765) Reducer grouping is skippted when parallelism is one

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1765. --- Resolution: Fixed It was an error in the GroupedDataStream implementation that never appeared without

[jira] [Commented] (FLINK-1763) Remove "cancel" from streaming SinkFunction

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372024#comment-14372024 ] Gyula Fora commented on FLINK-1763: --- I still think that it makes sense to have a cancel

[jira] [Assigned] (FLINK-1765) Reducer grouping is skippted when parallelism is one

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1765: - Assignee: Gyula Fora > Reducer grouping is skippted when parallelism is one > ---

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-20 Thread Sebastian Kruse (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371728#comment-14371728 ] Sebastian Kruse commented on FLINK-1754: It seems to work now, thanks! > Deadlock

[jira] [Commented] (FLINK-1688) Add socket sink

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

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

2015-03-20 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/484#issuecomment-84087404 @hsaputra thanks for the heads up - I am cherry-picking and squashing the relevant commits. --- If your project is set up for it, you can reply to this email and have yo

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371725#comment-14371725 ] Gyula Fora commented on FLINK-1765: --- This error was introduced today as I enabled chaini

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

2015-03-20 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/484#issuecomment-84086653 @mbalassi, @miguel0afd seemed like the PR contains more commits than the one targeted for the patch. Be careful when merging it bc it could murky the history.

[jira] [Commented] (FLINK-1688) Add socket sink

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

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371709#comment-14371709 ] Stephan Ewen commented on FLINK-1764: - Since that behavior is pretty critical in the A

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371706#comment-14371706 ] Stephan Ewen commented on FLINK-1764: - I think that very much depends on the contract

[jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

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

[GitHub] flink pull request: [FLINK-1756] [streaming] Rename Stream Monitor...

2015-03-20 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/506 [FLINK-1756] [streaming] Rename Stream Monitoring to Stream Checkpointing Also set the default checkpoint interval to 1 sec instead of 10. @senorcarbone, @gyfora please let me know if I have

[jira] [Created] (FLINK-1765) Reducer grouping is skippted when parallelism is one

2015-03-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1765: --- Summary: Reducer grouping is skippted when parallelism is one Key: FLINK-1765 URL: https://issues.apache.org/jira/browse/FLINK-1765 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371692#comment-14371692 ] Gyula Fora commented on FLINK-1764: --- Ok thats a mistake, but otherwise we need to copy g

[jira] [Comment Edited] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371692#comment-14371692 ] Gyula Fora edited comment on FLINK-1764 at 3/20/15 5:31 PM: Ok

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371673#comment-14371673 ] Stephan Ewen commented on FLINK-1764: - The chained filter invokable does that in my ca

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371664#comment-14371664 ] Gyula Fora commented on FLINK-1764: --- Can you please show an example where it copies mult

[jira] [Created] (FLINK-1764) Rework record copying logic in streaming API

2015-03-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1764: --- Summary: Rework record copying logic in streaming API Key: FLINK-1764 URL: https://issues.apache.org/jira/browse/FLINK-1764 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example

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

[GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe...

2015-03-20 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/420#issuecomment-84068746 Hi @vasia! I fixed the algorithm, now it will convert all edges to a pair of edges and call `distinct` on the edge set. This gives the correct results now. Thanks! ---

[jira] [Created] (FLINK-1763) Remove "cancel" from streaming SinkFunction

2015-03-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1763: --- Summary: Remove "cancel" from streaming SinkFunction Key: FLINK-1763 URL: https://issues.apache.org/jira/browse/FLINK-1763 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other

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

[GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p...

2015-03-20 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/488#issuecomment-84061320 @StephanEwen That's exactly what I did. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does no

[jira] [Commented] (FLINK-1688) Add socket sink

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

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

2015-03-20 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/484#issuecomment-84060511 Thanks, LGTM. Merging it tomorrow. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does no

[jira] [Commented] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other

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

[GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p...

2015-03-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/488#issuecomment-84059897 I think all changes that are in `flink-core`, `flink-java`, `flink-scala`, `flink-streaming`, `flink-spargel` are critical. For all those changes, there should be an a

[jira] [Commented] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other

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

[GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p...

2015-03-20 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/488#issuecomment-84058237 Any other opinions on the API breaking nature of these changes? --- 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-1688) Add socket sink

2015-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371547#comment-14371547 ] ASF GitHub Bot commented on FLINK-1688: --- Github user miguel0afd commented on the pul

[GitHub] flink pull request: [FLINK-1688] Socket client sink added

2015-03-20 Thread miguel0afd
Github user miguel0afd commented on the pull request: https://github.com/apache/flink/pull/484#issuecomment-84057923 New suggestions added to the code --- 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 n

[jira] [Commented] (FLINK-1710) Expression API Tests take very long

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371543#comment-14371543 ] Stephan Ewen commented on FLINK-1710: - That would be a major rewrite, I guess? Is thi

[jira] [Commented] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel

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

[GitHub] flink pull request: [FLINK-1761] Fix IndexOutOfBoundsException whe...

2015-03-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/504#issuecomment-84055466 Looks good and critical fix. +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 y

[jira] [Commented] (FLINK-1710) Expression API Tests take very long

2015-03-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371518#comment-14371518 ] Aljoscha Krettek commented on FLINK-1710: - This might sound a bit crazy, but we co

[jira] [Created] (FLINK-1762) Make Statefulness of a Streaming Function explicit

2015-03-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1762: --- Summary: Make Statefulness of a Streaming Function explicit Key: FLINK-1762 URL: https://issues.apache.org/jira/browse/FLINK-1762 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-1726) Add Community Detection Library and Example

2015-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371510#comment-14371510 ] ASF GitHub Bot commented on FLINK-1726: --- GitHub user andralungu opened a pull reques

[GitHub] flink pull request: [FLINK-1726][gelly] Added Community Detection ...

2015-03-20 Thread andralungu
GitHub user andralungu opened a pull request: https://github.com/apache/flink/pull/505 [FLINK-1726][gelly] Added Community Detection Library and Example You can merge this pull request into a Git repository by running: $ git pull https://github.com/andralungu/flink flink_commu

[GitHub] flink pull request: [FLINK-1761] Fix IndexOutOfBoundsException whe...

2015-03-20 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/504 [FLINK-1761] Fix IndexOutOfBoundsException when receiving empty buffer You can merge this pull request into a Git repository by running: $ git pull https://github.com/uce/incubator-flink empty_buf-

[jira] [Commented] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel

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

[jira] [Resolved] (FLINK-974) TaskManager startup script does not respect JAVA_HOME

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-974. Resolution: Invalid This is invalid. The taskmanager takes the JAVA home from its environment. In a

[jira] [Resolved] (FLINK-1760) Add support for building Flink with Scala 2.11

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1760. - Resolution: Fixed Fixed via 2cd5e93daa9dc7b1e024ec7c1f1fc665f953510a > Add support for building F

[jira] [Created] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel

2015-03-20 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1761: -- Summary: IndexOutOfBoundsException when receiving empty buffer at remote channel Key: FLINK-1761 URL: https://issues.apache.org/jira/browse/FLINK-1761 Project: Flink

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/477 --- 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] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

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

[jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

2015-03-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371389#comment-14371389 ] Márton Balassi commented on FLINK-1756: --- +1 for the suggestion. > Rename Stream Mon

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-03-20 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-84033474 @vasia was completely right about the GGC algorithm, I misunderstood what it was supposed to do. I implemented the correct version, but it turns out, after reading the GA

[jira] [Assigned] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing

2015-03-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1756: - Assignee: Márton Balassi > Rename Stream Monitoring to Stream Checkpointing > ---

[jira] [Commented] (FLINK-1663) Add a FIFO job scheduler to the JobManager

2015-03-20 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371379#comment-14371379 ] Flavio Pompermaier commented on FLINK-1663: --- Do you think that an integration wi

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371345#comment-14371345 ] ASF GitHub Bot commented on FLINK-1740: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-1740] Pass config param for numberOfExe...

2015-03-20 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-84030881 sorry this was a miscommunication between the three of us --- 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-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

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

[GitHub] flink pull request: [FLINK-1740] Pass config param for numberOfExe...

2015-03-20 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-84022943 @gyfora, did you really have to push this so eagerly? 1. The behaviour is not documented anywhere 1. Commit b6f183a is just plain useless after the rebase

[jira] [Resolved] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1740. --- Resolution: Fixed > StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() > -

[jira] [Updated] (FLINK-1759) Execution statistics for vertex-centric iterations

2015-03-20 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-1759: --- Assignee: (was: Andra Lungu) > Execution statistics for vertex-centric iterations > --

[jira] [Resolved] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1757. --- Resolution: Fixed https://github.com/apache/flink/commit/22e00655fa70a4986b87b1cde6f998b2baaf0507 > j

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

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

[GitHub] flink pull request: [FLINK-1740] Pass config param for numberOfExe...

2015-03-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/501 --- 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] [Created] (FLINK-1760) Add support for building Flink with Scala 2.11

2015-03-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1760: --- Summary: Add support for building Flink with Scala 2.11 Key: FLINK-1760 URL: https://issues.apache.org/jira/browse/FLINK-1760 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-1759) Execution statistics for vertex-centric iterations

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371300#comment-14371300 ] Stephan Ewen commented on FLINK-1759: - Robert has started an effort to integrate more

[jira] [Assigned] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead()

2015-03-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-1755: -- Assignee: Ufuk Celebi > NullPointerException in LocalInputChannel.getNextLookAhead() >

[jira] [Assigned] (FLINK-1759) Execution statistics for vertex-centric iterations

2015-03-20 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu reassigned FLINK-1759: -- Assignee: Andra Lungu > Execution statistics for vertex-centric iterations > --

[jira] [Created] (FLINK-1759) Execution statistics for vertex-centric iterations

2015-03-20 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1759: Summary: Execution statistics for vertex-centric iterations Key: FLINK-1759 URL: https://issues.apache.org/jira/browse/FLINK-1759 Project: Flink Issue Type:

[jira] [Created] (FLINK-1758) Extend Gelly's neighborhood methods

2015-03-20 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-1758: Summary: Extend Gelly's neighborhood methods Key: FLINK-1758 URL: https://issues.apache.org/jira/browse/FLINK-1758 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-20 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/492 --- 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-441) Renaming in pact-compiler

2015-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371260#comment-14371260 ] ASF GitHub Bot commented on FLINK-441: -- Github user StephanEwen closed the pull reques

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

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

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-84008396 Manually merged in 633b0d6a9b25fd324f1aa007bbce246be304c099 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371256#comment-14371256 ] Stephan Ewen commented on FLINK-1430: - The completeness test is to ensure that the Jav

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-84007441 I think only the apache infra team has admin right, none of the Flink committers has... The easiest way to abort the builds is to delete the branch. I'll merge

[jira] [Resolved] (FLINK-1715) Remove print statements in MultiEvictionPolicy and GroupedDataStream

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1715. --- Resolution: Fixed https://github.com/apache/flink/commit/ac888b239936d146b1109eca8b9a193458cdaf9f > R

[jira] [Resolved] (FLINK-1594) DataStreams don't support self-join

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1594. --- Resolution: Fixed > DataStreams don't support self-join > --- > >

[jira] [Resolved] (FLINK-1618) Add parallel time discretisation for time-window transformations

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1618. --- Resolution: Implemented > Add parallel time discretisation for time-window transformations >

[jira] [Created] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

2015-03-20 Thread JIRA
Péter Szabó created FLINK-1757: -- Summary: java.lang.ClassCastException is thrown while summing Short values on window Key: FLINK-1757 URL: https://issues.apache.org/jira/browse/FLINK-1757 Project: Flink

[jira] [Resolved] (FLINK-1706) Add disk spilling to BarrierBuffer

2015-03-20 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1706. --- Resolution: Implemented > Add disk spilling to BarrierBuffer > -- > >

[jira] [Commented] (FLINK-1618) Add parallel time discretisation for time-window transformations

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

[jira] [Commented] (FLINK-1594) DataStreams don't support self-join

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

[GitHub] flink pull request: [FLINK-1594] [streaming] [wip] DataStream supp...

2015-03-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/472 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] flink pull request: [FLINK-1618] [streaming] Parallel time reduce

2015-03-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/485 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-20 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83989884 I changed it as @StephanEwen suggested. Can somebody with admin access please cancel all previous pending builds for this PR here: https://travis-ci.org/apache

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-20 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83986124 Agree. I suggest adding this to profile 1 (hadoop 1 / java 7) and profile 5 (hadoop 2.6 / java 8). --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-1710) Expression API Tests take very long

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371133#comment-14371133 ] Stephan Ewen commented on FLINK-1710: - Maybe there are some known tweaks / best practi

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-20 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83985616 All but one of the profiles (including the two scala 2.11 profiles) build with the latest rebase: https://travis-ci.org/stratosphere/flink/builds/55147681

[jira] [Commented] (FLINK-1710) Expression API Tests take very long

2015-03-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371131#comment-14371131 ] Aljoscha Krettek commented on FLINK-1710: - But what should I ask? The Scala reflec

[jira] [Resolved] (FLINK-972) Run Flink on Tez

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-972. Resolution: Duplicate Duplicate of [FLINK-1219] > Run Flink on Tez > > >

[jira] [Resolved] (FLINK-1088) Iteration head deadlock

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1088. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 9c77f0785e43326521da5e535f9ab1f05a9c6280 >

[jira] [Resolved] (FLINK-1090) Join deadlocks when used inside Delta iteration

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1090. - Resolution: Fixed Fix Version/s: 0.9 Solved via 9c77f0785e43326521da5e535f9ab1f05a9c6280 >

[jira] [Resolved] (FLINK-1018) Logistic Regression deadlocks

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1018. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 9c77f0785e43326521da5e535f9ab1f05a9c6280 >

[jira] [Resolved] (FLINK-952) TypeExtractor requires the argument types of the UDF to be identical to the parameter types

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-952. Resolution: Fixed Fix Version/s: 0.9 Fixed with the introduction of the subclass aware pojo an

[jira] [Resolved] (FLINK-947) Add support for "Named Datasets"

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-947. Resolution: Fixed Fix Version/s: 0.9 Merged under {{flink-staging/flink-expressions}} > Add s

[jira] [Resolved] (FLINK-819) OutOfMemoryError from TaskManager is causing hard to understand exceptions and blocking JobManager

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-819. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.9 Fixed with the i

[jira] [Resolved] (FLINK-336) Job-Preview (web) should not require getPlan() to work with empty args

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-336. Resolution: Invalid Fix Version/s: (was: pre-apache) {{getPlan()}} may always depend on co

[jira] [Resolved] (FLINK-67) Add HBase Tests

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-67?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-67. --- Resolution: Fixed Fix Version/s: (was: pre-apache) 0.8.1 Assignee:

[jira] [Resolved] (FLINK-441) Renaming in pact-compiler

2015-03-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-441. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.9 Fixed as of 633b

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371050#comment-14371050 ] Fabian Hueske commented on FLINK-1754: -- This deadlock bug is certainly critical and i

  1   2   >