[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507774#comment-15507774 ] Simone Robutti commented on FLINK-4035: --- The PR for kerberos integration for Kafka 0

[jira] [Assigned] (FLINK-4301) Parameterize Flink version in Quickstart bash script

[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti reassigned FLINK-4301: - Assignee: Simone Robutti > Parameterize Flink version in Quickstart bash script > ---

[jira] [Updated] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti updated FLINK-4565: -- Assignee: (was: Simone Robutti) > Support for SQL IN operator > ---

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15503625#comment-15503625 ] Simone Robutti commented on FLINK-4565: --- Considering my current schedule and the imp

[jira] [Commented] (FLINK-4629) Kafka v 0.10 Support

[ https://issues.apache.org/jira/browse/FLINK-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15498948#comment-15498948 ] Simone Robutti commented on FLINK-4629: --- There's already an issue that covers the up

[jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15477000#comment-15477000 ] Simone Robutti commented on FLINK-4599: --- I'd rather go for the second choice. I've o

[jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476433#comment-15476433 ] Simone Robutti commented on FLINK-4599: --- The AST output is already working because i

[jira] [Comment Edited] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476401#comment-15476401 ] Simone Robutti edited comment on FLINK-4599 at 9/9/16 9:12 AM: -

[jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476401#comment-15476401 ] Simone Robutti commented on FLINK-4599: --- Ok, I'm working on it. I'm trying to reco

[jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476310#comment-15476310 ] Simone Robutti commented on FLINK-4599: --- I began working on this. It seems to work b

[jira] [Assigned] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti reassigned FLINK-4599: - Assignee: Simone Robutti > Add 'explain()' also to StreamTableEnvironment > -

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474082#comment-15474082 ] Simone Robutti commented on FLINK-4565: --- After a couple of days of work I believe th

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473867#comment-15473867 ] Simone Robutti commented on FLINK-4565: --- I'm no expert in the Table API, but if a us

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473685#comment-15473685 ] Simone Robutti commented on FLINK-4565: --- I defined this parser combinator rule ```la

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470472#comment-15470472 ] Simone Robutti commented on FLINK-4565: --- That's exactly why I'm asking it: I had no

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470412#comment-15470412 ] Simone Robutti commented on FLINK-4565: --- The resulting API should look like `ds1.joi

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469851#comment-15469851 ] Simone Robutti commented on FLINK-4565: --- I imagined it could happen that way and I w

[jira] [Assigned] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti reassigned FLINK-4565: - Assignee: Simone Robutti > Support for SQL IN operator > --- > >

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469797#comment-15469797 ] Simone Robutti commented on FLINK-4565: --- Actually the confusing part is that the tra

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467945#comment-15467945 ] Simone Robutti commented on FLINK-4565: --- I haven't assigned the issue to myself beca

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467236#comment-15467236 ] Simone Robutti commented on FLINK-4565: --- Ok, the testing part seems easy and straigh

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467016#comment-15467016 ] Simone Robutti commented on FLINK-4565: --- I would like to take care of this issue to

[jira] [Commented] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458159#comment-15458159 ] Simone Robutti commented on FLINK-2312: --- Should we reconsider this implementation?

[jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15457773#comment-15457773 ] Simone Robutti commented on FLINK-4513: --- I noticed that this is true for the docs of

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347835#comment-15347835 ] Simone Robutti commented on FLINK-1873: --- I opened a PR for FLINK-3920 with the rest

[jira] [Commented] (FLINK-3919) Distributed Linear Algebra: row-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313955#comment-15313955 ] Simone Robutti commented on FLINK-3919: --- Umh, probably you're right. I checked breez

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313938#comment-15313938 ] Simone Robutti commented on FLINK-1873: --- That would be perfect :) > Distributed mat

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313903#comment-15313903 ] Simone Robutti commented on FLINK-1873: --- Ok. Anyway tomorrow will be my first day of

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15309972#comment-15309972 ] Simone Robutti commented on FLINK-1873: --- I thought I could open a dedicated issue fo

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1527#comment-1527 ] Simone Robutti commented on FLINK-1873: --- I know there's a lot of backlog with all th

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288533#comment-15288533 ] Simone Robutti commented on FLINK-1873: --- [~till.rohrmann] I have opened two issues a

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286945#comment-15286945 ] Simone Robutti commented on FLINK-1873: --- Sorry Trevor, I was talking about Mahout's

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286888#comment-15286888 ] Simone Robutti commented on FLINK-1873: --- Is it ok to ask for this on the dev mailing

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286562#comment-15286562 ] Simone Robutti commented on FLINK-1873: --- Yes and I know your work. I watched your de

[jira] [Updated] (FLINK-3919) Distributed Linear Algebra: row-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti updated FLINK-3919: -- Description: Distributed matrix implementation as a DataSet of IndexedRow and related operation

[jira] [Created] (FLINK-3920) Distributed Linear Algebra: block-based matrix

Simone Robutti created FLINK-3920: - Summary: Distributed Linear Algebra: block-based matrix Key: FLINK-3920 URL: https://issues.apache.org/jira/browse/FLINK-3920 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-3919) Distributed Linear Algebra: row-based matrix

Simone Robutti created FLINK-3919: - Summary: Distributed Linear Algebra: row-based matrix Key: FLINK-3919 URL: https://issues.apache.org/jira/browse/FLINK-3919 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286214#comment-15286214 ] Simone Robutti commented on FLINK-1873: --- Ok, I just need to split the stuff I did an

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15284278#comment-15284278 ] Simone Robutti commented on FLINK-1873: --- The tasks are not independent so I would go

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15282684#comment-15282684 ] Simone Robutti commented on FLINK-1873: --- Hello Till, I worked full time on this iss

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274265#comment-15274265 ] Simone Robutti commented on FLINK-1873: --- Umh ok. I think that on block-partitioned m

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274177#comment-15274177 ] Simone Robutti commented on FLINK-1873: --- I began working right away on this issue.

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273854#comment-15273854 ] Simone Robutti commented on FLINK-1873: --- Sure. I will have to study a bit to do it p

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273770#comment-15273770 ] Simone Robutti commented on FLINK-1873: --- This is issue has been dead for one year. W

[jira] [Commented] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction

[ https://issues.apache.org/jira/browse/FLINK-3563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177831#comment-15177831 ] Simone Robutti commented on FLINK-3563: --- Anyway I just rewrote a good part of the li

[jira] [Created] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction

Simone Robutti created FLINK-3563: - Summary: .returns() doesn't compile when using .map() with a custom MapFunction Key: FLINK-3563 URL: https://issues.apache.org/jira/browse/FLINK-3563 Project: Flink

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134002#comment-15134002 ] Simone Robutti edited comment on FLINK-1731 at 2/5/16 10:56 AM:

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134002#comment-15134002 ] Simone Robutti edited comment on FLINK-1731 at 2/5/16 10:56 AM:

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134002#comment-15134002 ] Simone Robutti commented on FLINK-1731: --- Hi Till, any news on the inclusion of K-Me

[jira] [Commented] (FLINK-3191) WordCount without fileOutput - execute is missing

[ https://issues.apache.org/jira/browse/FLINK-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15071145#comment-15071145 ] Simone Robutti commented on FLINK-3191: --- It was a version problem. I was using the 0

[jira] [Closed] (FLINK-3191) WordCount without fileOutput - execute is missing

[ https://issues.apache.org/jira/browse/FLINK-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti closed FLINK-3191. - Resolution: Fixed > WordCount without fileOutput - execute is missing > --

[jira] [Created] (FLINK-3191) WordCount without fileOutput - execute is missing

Simone Robutti created FLINK-3191: - Summary: WordCount without fileOutput - execute is missing Key: FLINK-3191 URL: https://issues.apache.org/jira/browse/FLINK-3191 Project: Flink Issue Type: