[jira] [Assigned] (FLINK-4564) [metrics] Delimiter should be configured per reporter

[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4564: --- Assignee: Anton Mushin > [metrics] Delimiter should be configured per reporter >

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509946#comment-15509946 ] Anton Mushin commented on FLINK-4564: - Not all clear. How should look like MetricGroup

[jira] [Comment Edited] (FLINK-4564) [metrics] Delimiter should be configured per reporter

[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509946#comment-15509946 ] Anton Mushin edited comment on FLINK-4564 at 9/21/16 4:10 PM: --

[jira] [Issue Comment Deleted] (FLINK-4564) [metrics] Delimiter should be configured per reporter

[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin updated FLINK-4564: Comment: was deleted (was: Not all clear. How should look like {{MetricGroup#getMetricIdentifier()}}

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942740#comment-15942740 ] Anton Mushin commented on FLINK-4604: - Hi everyone, Calcite 1.12 has been release: ht

[jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-3320: --- Assignee: (was: Anton Mushin) > Add not operator to CEP's pattern API > -

[jira] [Comment Edited] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855653#comment-15855653 ] Anton Mushin edited comment on FLINK-5435 at 3/27/17 6:48 AM: --

[jira] [Commented] (FLINK-3320) Add not operator to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942742#comment-15942742 ] Anton Mushin commented on FLINK-3320: - Hi [~dawidwys], I am not working on the issue.

[jira] [Commented] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations

[ https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651203#comment-15651203 ] Anton Mushin commented on FLINK-3613: - Hello everyone. Do FLINK-4604 extends this issu

[jira] [Comment Edited] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations

[ https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651203#comment-15651203 ] Anton Mushin edited comment on FLINK-3613 at 11/9/16 3:38 PM: --

[jira] [Commented] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations

[ https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15656530#comment-15656530 ] Anton Mushin commented on FLINK-3613: - Hi [~fhueske], Thanks for your reply. [~Stephan

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667131#comment-15667131 ] Anton Mushin commented on FLINK-4832: - Ok. Could you check [commit|https://github.com

[jira] [Comment Edited] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667131#comment-15667131 ] Anton Mushin edited comment on FLINK-4832 at 11/17/16 12:45 PM:

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676435#comment-15676435 ] Anton Mushin commented on FLINK-4832: - Hi [~twalthr], I have trouble with next code {c

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15682939#comment-15682939 ] Anton Mushin commented on FLINK-4832: - Hello everyone, I'm update implementation accor

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683424#comment-15683424 ] Anton Mushin commented on FLINK-4832: - Thanks for your reply. done :) > Count/Sum 0

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684046#comment-15684046 ] Anton Mushin commented on FLINK-2435: - Hi everyone, is issue actual? bq.It would be go

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686845#comment-15686845 ] Anton Mushin commented on FLINK-4604: - what if do try return the type of source column

[jira] [Comment Edited] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684046#comment-15684046 ] Anton Mushin edited comment on FLINK-2435 at 11/29/16 12:49 PM:

[jira] [Assigned] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-2435: --- Assignee: Anton Mushin > Add support for custom CSV field parsers > -

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708691#comment-15708691 ] Anton Mushin commented on FLINK-2435: - Hi [~fhueske] could you tell for what case need

[jira] [Commented] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API

[ https://issues.apache.org/jira/browse/FLINK-4330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711574#comment-15711574 ] Anton Mushin commented on FLINK-4330: - Hi everyone. Components name in this issue conf

[jira] [Issue Comment Deleted] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin updated FLINK-4604: Comment: was deleted (was: what if do try return the type of source column instead null?) > Add sup

[jira] [Assigned] (FLINK-3320) Add not operator to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-3320: --- Assignee: Anton Mushin > Add not operator to CEP's pattern API >

[jira] [Assigned] (FLINK-4704) Move Table API to org.apache.flink.table

[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4704: --- Assignee: Anton Mushin (was: Timo Walther) > Move Table API to org.apache.flink.table >

[jira] [Assigned] (FLINK-4714) Set task state to RUNNING after state has been restored

[ https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4714: --- Assignee: Andrew Efimov > Set task state to RUNNING after state has been restored > -

[jira] [Assigned] (FLINK-2435) Add support for custom CSV field parsers

[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-2435: --- Assignee: (was: Anton Mushin) > Add support for custom CSV field parsers > --

[jira] [Issue Comment Deleted] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API

[ https://issues.apache.org/jira/browse/FLINK-4330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin updated FLINK-4330: Comment: was deleted (was: Hi everyone. Components name in this issue confuse me. I don't see min()

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761698#comment-15761698 ] Anton Mushin commented on FLINK-5256: - Hi [~fhueske], Where did you get the plan? i tr

[jira] [Assigned] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-5256: --- Assignee: Anton Mushin > Extend DataSetSingleRowJoin to support Left and Right joins > --

[jira] [Assigned] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4604: --- Assignee: Anton Mushin (was: Dmytro Shkvyra) > Add support for standard deviation/variance >

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978405#comment-15978405 ] Anton Mushin commented on FLINK-4604: - Hi [~twalthr], Could you look my PR for this is

[jira] [Assigned] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4563: --- Assignee: Anton Mushin > [metrics] scope caching not adjusted for multiple reporters > --

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15525713#comment-15525713 ] Anton Mushin commented on FLINK-4563: - Hello. Do I correct undestand this issue, what

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15529746#comment-15529746 ] Anton Mushin commented on FLINK-4563: - I am understand. I planning to fix this issue

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15529899#comment-15529899 ] Anton Mushin commented on FLINK-4563: - Do you propose to caching last CharacterFilter

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532305#comment-15532305 ] Anton Mushin commented on FLINK-4563: - Ok this case if we get f1 in method we must ret

[jira] [Comment Edited] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532305#comment-15532305 ] Anton Mushin edited comment on FLINK-4563 at 9/29/16 9:54 AM: --

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532355#comment-15532355 ] Anton Mushin commented on FLINK-4563: - Thanks. Then I will wait resolution of PR http

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535709#comment-15535709 ] Anton Mushin commented on FLINK-4604: - Hello. Could I start to resolve this ticket?

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536178#comment-15536178 ] Anton Mushin commented on FLINK-4604: - [~twalthr],thanks! I have any question about th

[jira] [Created] (FLINK-4743) The sqrt/power function not accept the real data types.

Anton Mushin created FLINK-4743: --- Summary: The sqrt/power function not accept the real data types. Key: FLINK-4743 URL: https://issues.apache.org/jira/browse/FLINK-4743 Project: Flink Issue Typ

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15551505#comment-15551505 ] Anton Mushin commented on FLINK-4604: - I have some problem. I added rule in {{org.apa

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15551768#comment-15551768 ] Anton Mushin commented on FLINK-4604: - I'm use {{RelOptUtil.toString(relNode)}} for ge

[jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15551768#comment-15551768 ] Anton Mushin edited comment on FLINK-4604 at 10/6/16 12:22 PM: -

[jira] [Updated] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin updated FLINK-4604: Attachment: 1.jpg bq. Can you check if AggregateReduceFunctionsRule.matches is called? yes it is cal

[jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15552063#comment-15552063 ] Anton Mushin edited comment on FLINK-4604 at 10/6/16 2:24 PM: --

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15554418#comment-15554418 ] Anton Mushin commented on FLINK-4604: - Yes, of course. link to commit: https://github

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15554574#comment-15554574 ] Anton Mushin commented on FLINK-4604: - I'm think will probably worth consider types of

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15554768#comment-15554768 ] Anton Mushin commented on FLINK-4604: - I changed method {{org.apache.flink.api.table.

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15561783#comment-15561783 ] Anton Mushin commented on FLINK-4604: - Do you mean check in {{org.apache.flink.api.ta

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568664#comment-15568664 ] Anton Mushin commented on FLINK-4604: - I tried check function in {{org.apache.flink.a

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571502#comment-15571502 ] Anton Mushin commented on FLINK-4604: - I tried use code like as your code and I got ex

[jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571502#comment-15571502 ] Anton Mushin edited comment on FLINK-4604 at 10/13/16 2:10 PM: -

[jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571502#comment-15571502 ] Anton Mushin edited comment on FLINK-4604 at 10/13/16 2:10 PM: -

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572115#comment-15572115 ] Anton Mushin commented on FLINK-4604: - Sorry, I will try explain my problem. I have tw

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581442#comment-15581442 ] Anton Mushin commented on FLINK-4604: - Do you talking about new issue for support {{S

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591955#comment-15591955 ] Anton Mushin commented on FLINK-4832: - Hello I think that it needs to change {{org.ap

[jira] [Comment Edited] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591955#comment-15591955 ] Anton Mushin edited comment on FLINK-4832 at 10/20/16 2:31 PM: -

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607653#comment-15607653 ] Anton Mushin commented on FLINK-4604: - Hello [~fhueske], thanks for your answer! I add

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15615280#comment-15615280 ] Anton Mushin commented on FLINK-4604: - I found rootcause problems occur only in query

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15615302#comment-15615302 ] Anton Mushin commented on FLINK-4604: - For correct calculate standard deviation/varian

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15621663#comment-15621663 ] Anton Mushin commented on FLINK-4604: - bq. We can later remove these commits once the

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15625448#comment-15625448 ] Anton Mushin commented on FLINK-4832: - Hi everyone. I want to implement this issue and

[jira] [Assigned] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4832: --- Assignee: Anton Mushin > Count/Sum 0 elements > > > Key:

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650089#comment-15650089 ] Anton Mushin commented on FLINK-4832: - Hello [~fhueske] bq. We need to inject a Union

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769621#comment-15769621 ] Anton Mushin commented on FLINK-5256: - Hi [~fhueske], Thanks for your comments! bq. I'

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770115#comment-15770115 ] Anton Mushin commented on FLINK-5256: - Yes, [here|https://github.com/apache/flink/com

[jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770115#comment-15770115 ] Anton Mushin edited comment on FLINK-5256 at 12/22/16 2:06 PM: -

[jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770115#comment-15770115 ] Anton Mushin edited comment on FLINK-5256 at 12/22/16 2:09 PM: -

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15817549#comment-15817549 ] Anton Mushin commented on FLINK-5256: - Thanks for your comment! I update my [test bra

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15817633#comment-15817633 ] Anton Mushin commented on FLINK-4604: - Hi [~twalthr]. Do you suggest use *Decorrelator

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825599#comment-15825599 ] Anton Mushin commented on FLINK-5256: - Hi, I update PR, but it is incorrect yet. I hav

[jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825599#comment-15825599 ] Anton Mushin edited comment on FLINK-5256 at 1/17/17 7:51 AM: --

[jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825599#comment-15825599 ] Anton Mushin edited comment on FLINK-5256 at 1/17/17 8:01 AM: --

[jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825599#comment-15825599 ] Anton Mushin edited comment on FLINK-5256 at 1/17/17 8:19 AM: --

[jira] (FLINK-4604) Add support for standard deviation/variance

Title: Message Title Anton Mushin commented on FLINK-4604

[jira] (FLINK-4604) Add support for standard deviation/variance

Title: Message Title Anton Mushin updated an issue

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855653#comment-15855653 ] Anton Mushin commented on FLINK-5435: - Hi. We have problem in FLINK-5435 with calcite

[jira] [Created] (FLINK-5750) Incorrect parse of brackets inside VALUES subquery

Anton Mushin created FLINK-5750: --- Summary: Incorrect parse of brackets inside VALUES subquery Key: FLINK-5750 URL: https://issues.apache.org/jira/browse/FLINK-5750 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-5782) Support GPU calculations

[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187863#comment-16187863 ] Anton Mushin commented on FLINK-5782: - Hi everyone bq. 2) Currently Flink uses Breeze

[jira] [Comment Edited] (FLINK-5750) Incorrect translation of n-ary Union

[ https://issues.apache.org/jira/browse/FLINK-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545047#comment-16545047 ] Anton Mushin edited comment on FLINK-5750 at 7/16/18 10:40 AM:

[jira] [Commented] (FLINK-5750) Incorrect translation of n-ary Union

[ https://issues.apache.org/jira/browse/FLINK-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545047#comment-16545047 ] Anton Mushin commented on FLINK-5750: - [~Alexander_Koltsov] you can use --squash or -

[jira] [Comment Edited] (FLINK-5750) Incorrect translation of n-ary Union

[ https://issues.apache.org/jira/browse/FLINK-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545047#comment-16545047 ] Anton Mushin edited comment on FLINK-5750 at 7/16/18 10:41 AM: