[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=15507774#comment-15507774 ] Simone Robutti commented on FLINK-4035: --- The PR for kerberos integration for Kafka 0.9 has been

[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=15503625#comment-15503625 ] Simone Robutti commented on FLINK-4565: --- Considering my current schedule and the importance of this

[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=15498948#comment-15498948 ] Simone Robutti commented on FLINK-4629: --- There's already an issue that covers the update to Kafka

[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=15477000#comment-15477000 ] Simone Robutti commented on FLINK-4599: --- I'd rather go for the second choice. I've opened the PR.

[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=15476433#comment-15476433 ] Simone Robutti commented on FLINK-4599: --- The AST output is already working because it's all up to

[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=15476401#comment-15476401 ] Simone Robutti edited comment on FLINK-4599 at 9/9/16 9:12 AM: --- Ok, I'm

[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=15476401#comment-15476401 ] Simone Robutti commented on FLINK-4599: --- Ok, I'm working on it. I'm trying to reconcile the

[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=15476310#comment-15476310 ] Simone Robutti commented on FLINK-4599: --- I began working on this. It seems to work by simply

[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=15474082#comment-15474082 ] Simone Robutti commented on FLINK-4565: --- After a couple of days of work I believe this task is a bit

[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=15473867#comment-15473867 ] Simone Robutti commented on FLINK-4565: --- I'm no expert in the Table API, but if a user doesn't

[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=15473685#comment-15473685 ] Simone Robutti commented on FLINK-4565: --- I defined this parser combinator rule ```lazy val

[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=15470472#comment-15470472 ] Simone Robutti commented on FLINK-4565: --- That's exactly why I'm asking it: I had no idea what to use

[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=15470412#comment-15470412 ] Simone Robutti commented on FLINK-4565: --- The resulting API should look like `ds1.join(ds2).where('a

[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=15469851#comment-15469851 ] Simone Robutti commented on FLINK-4565: --- I imagined it could happen that way and I was going to open

[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=15469797#comment-15469797 ] Simone Robutti commented on FLINK-4565: --- Actually the confusing part is that the translation to the

[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=15467945#comment-15467945 ] Simone Robutti commented on FLINK-4565: --- I haven't assigned the issue to myself because I'm still

[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=15467236#comment-15467236 ] Simone Robutti commented on FLINK-4565: --- Ok, the testing part seems easy and straightforward. I'm

[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=15467016#comment-15467016 ] Simone Robutti commented on FLINK-4565: --- I would like to take care of this issue to get my hands

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

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

[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=15457773#comment-15457773 ] Simone Robutti commented on FLINK-4513: --- I noticed that this is true for the docs of every

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

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

[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=15313955#comment-15313955 ] Simone Robutti commented on FLINK-3919: --- Umh, probably you're right. I checked breeze and they use

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[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

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

[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=15286214#comment-15286214 ] Simone Robutti commented on FLINK-1873: --- Ok, I just need to split the stuff I did and I can open it.

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274177#comment-15274177 ] Simone Robutti commented on FLINK-1873: --- I began working right away on this issue. For now I'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=15273854#comment-15273854 ] Simone Robutti commented on FLINK-1873: --- Sure. I will have to study a bit to do it properly but I

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

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

[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=15177831#comment-15177831 ] Simone Robutti commented on FLINK-3563: --- Anyway I just rewrote a good part of the library I was

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

[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=15134002#comment-15134002 ] Simone Robutti commented on FLINK-1731: --- Hi Till, any news on the inclusion of K-Means in the 1.0

[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=15134002#comment-15134002 ] Simone Robutti edited comment on FLINK-1731 at 2/5/16 10:56 AM: Hi

[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=15134002#comment-15134002 ] Simone Robutti edited comment on FLINK-1731 at 2/5/16 10:56 AM: Hi

[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=15071145#comment-15071145 ] Simone Robutti commented on FLINK-3191: --- It was a version problem. I was using the 0.8.0. With the

[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