[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=15855653#comment-15855653 ] Anton Mushin commented on FLINK-5435: - Hi. We have problem in FLINK-5435 with calcite rule. In PR for

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

[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=15825599#comment-15825599 ] Anton Mushin edited comment on FLINK-5256 at 1/17/17 8:19 AM: -- Hi, I update

[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=15825599#comment-15825599 ] Anton Mushin commented on FLINK-5256: - Hi, I update PR, but it is incorrect yet. I have some problem

[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=15535709#comment-15535709 ] Anton Mushin commented on FLINK-4604: - Hello. Could I start to resolve this ticket? > Add support

[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

[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=15551505#comment-15551505 ] Anton Mushin commented on FLINK-4604: - I have some problem. I added rule in

[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=15552063#comment-15552063 ] Anton Mushin edited comment on FLINK-4604 at 10/6/16 2:24 PM: -- bq. Can you

[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

[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=15551768#comment-15551768 ] Anton Mushin edited comment on FLINK-4604 at 10/6/16 12:22 PM: --- I used

[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=15551768#comment-15551768 ] Anton Mushin commented on FLINK-4604: - I'm use {{RelOptUtil.toString(relNode)}} for getting plan

[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=15554768#comment-15554768 ] Anton Mushin commented on FLINK-4604: - I changed method

[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=15554574#comment-15554574 ] Anton Mushin commented on FLINK-4604: - I'm think will probably worth consider types of aggregate

[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=15554418#comment-15554418 ] Anton Mushin commented on FLINK-4604: - Yes, of course. link to commit:

[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=15509946#comment-15509946 ] Anton Mushin commented on FLINK-4564: - Not all clear. How should look like

[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=15509946#comment-15509946 ] Anton Mushin edited comment on FLINK-4564 at 9/21/16 4:10 PM: -- Not all clear.

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

[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=15525713#comment-15525713 ] Anton Mushin commented on FLINK-4563: - Hello. Do I correct undestand this issue, what next tests will

[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=15532305#comment-15532305 ] Anton Mushin commented on FLINK-4563: - Ok this case if we get f1 in method we must return cached

[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=15532305#comment-15532305 ] Anton Mushin edited comment on FLINK-4563 at 9/29/16 9:54 AM: -- Ok this case

[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=15532355#comment-15532355 ] Anton Mushin commented on FLINK-4563: - Thanks. Then I will wait resolution of PR

[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=15529746#comment-15529746 ] Anton Mushin commented on FLINK-4563: - I am understand. I planning to fix this issue after merge

[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=15529899#comment-15529899 ] Anton Mushin commented on FLINK-4563: - Do you propose to caching last CharacterFilter which was called

[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=15536178#comment-15536178 ] Anton Mushin commented on FLINK-4604: - [~twalthr],thanks! I have any question about this issue. 1. Am

[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=15651203#comment-15651203 ] Anton Mushin commented on FLINK-3613: - Hello everyone. Do FLINK-4604 extends this issue? or is

[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=15651203#comment-15651203 ] Anton Mushin edited comment on FLINK-3613 at 11/9/16 3:38 PM: -- Hello

[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=15650089#comment-15650089 ] Anton Mushin commented on FLINK-4832: - Hello [~fhueske] bq. We need to inject a Union before the Map

[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=15656530#comment-15656530 ] Anton Mushin commented on FLINK-3613: - Hi [~fhueske], Thanks for your reply. [~StephanEwen] and

[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=15581442#comment-15581442 ] Anton Mushin commented on FLINK-4604: - Do you talking about new issue for support

[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=15686845#comment-15686845 ] Anton Mushin commented on FLINK-4604: - what if do try return the type of source column instead null?

[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=15667131#comment-15667131 ] Anton Mushin edited comment on FLINK-4832 at 11/17/16 12:45 PM: Ok. Could

[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=15676435#comment-15676435 ] Anton Mushin commented on FLINK-4832: - Hi [~twalthr], I have trouble with next code {code:java} @Test

[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=15683424#comment-15683424 ] Anton Mushin commented on FLINK-4832: - Thanks for your reply. done :) > Count/Sum 0 elements >

[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=15684046#comment-15684046 ] Anton Mushin commented on FLINK-2435: - Hi everyone, is issue actual? bq.It would be good to add

[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=15667131#comment-15667131 ] Anton Mushin commented on FLINK-4832: - Ok. Could you check

[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=15682939#comment-15682939 ] Anton Mushin commented on FLINK-4832: - Hello everyone, I'm update implementation according to changes

[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=15591955#comment-15591955 ] Anton Mushin commented on FLINK-4832: - Hello I think that it needs to change

[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=15591955#comment-15591955 ] Anton Mushin edited comment on FLINK-4832 at 10/20/16 2:31 PM: --- Hello I

[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=15625448#comment-15625448 ] Anton Mushin commented on FLINK-4832: - Hi everyone. I want to implement this issue and I have some

[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=15607653#comment-15607653 ] Anton Mushin commented on FLINK-4604: - Hello [~fhueske], thanks for your answer! I added support

[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=15621663#comment-15621663 ] Anton Mushin commented on FLINK-4604: - bq. We can later remove these commits once the original PR got

[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=15615280#comment-15615280 ] Anton Mushin commented on FLINK-4604: - I found rootcause problems occur only in query with SUM, if in

[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=15615302#comment-15615302 ] Anton Mushin commented on FLINK-4604: - For correct calculate standard deviation/variance function need

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

[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=15572115#comment-15572115 ] Anton Mushin commented on FLINK-4604: - Sorry, I will try explain my problem. I have two tests

[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=15568664#comment-15568664 ] Anton Mushin commented on FLINK-4604: - I tried check function in

[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=15571502#comment-15571502 ] Anton Mushin commented on FLINK-4604: - I tried use code like as your code and I got exception:

[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=15571502#comment-15571502 ] Anton Mushin edited comment on FLINK-4604 at 10/13/16 2:10 PM: --- I tried use

[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=15571502#comment-15571502 ] Anton Mushin edited comment on FLINK-4604 at 10/13/16 2:10 PM: --- I tried use

[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=15561783#comment-15561783 ] Anton Mushin commented on FLINK-4604: - Do you mean check in

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

[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] [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=15817633#comment-15817633 ] Anton Mushin commented on FLINK-4604: - Hi [~twalthr]. Do you suggest use *Decorrelator class for Flink

[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=15817549#comment-15817549 ] Anton Mushin commented on FLINK-5256: - Thanks for your comment! I update my [test

[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

[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=15684046#comment-15684046 ] Anton Mushin edited comment on FLINK-2435 at 11/29/16 12:49 PM: Hi

[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] [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=15711574#comment-15711574 ] Anton Mushin commented on FLINK-4330: - Hi everyone. Components name in this issue confuse me. I don't

[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=15708691#comment-15708691 ] Anton Mushin commented on FLINK-2435: - Hi [~fhueske] could you tell for what case need new abstract

[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=15761698#comment-15761698 ] Anton Mushin commented on FLINK-5256: - Hi [~fhueske], Where did you get the plan? i tried execute your

[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] [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=15769621#comment-15769621 ] Anton Mushin commented on FLINK-5256: - Hi [~fhueske], Thanks for your comments! bq. I'm afraid, the PR

[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=15770115#comment-15770115 ] Anton Mushin edited comment on FLINK-5256 at 12/22/16 2:09 PM: --- Yes,

[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=15770115#comment-15770115 ] Anton Mushin edited comment on FLINK-5256 at 12/22/16 2:06 PM: --- Yes,

[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=15770115#comment-15770115 ] Anton Mushin commented on FLINK-5256: - Yes,

[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=15942740#comment-15942740 ] Anton Mushin commented on FLINK-4604: - Hi everyone, Calcite 1.12 has been release:

[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=15942742#comment-15942742 ] Anton Mushin commented on FLINK-3320: - Hi [~dawidwys], I am not working on the issue. You can take it

[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=15855653#comment-15855653 ] Anton Mushin edited comment on FLINK-5435 at 3/27/17 6:48 AM: -- Hi. We have

[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] [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=15978405#comment-15978405 ] Anton Mushin commented on FLINK-4604: - Hi [~twalthr], Could you look my PR for this issue, please? >

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

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

[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=16545047#comment-16545047 ] Anton Mushin edited comment on FLINK-5750 at 7/16/18 10:41 AM: --- Hi

[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=16545047#comment-16545047 ] Anton Mushin commented on FLINK-5750: - [~Alexander_Koltsov] you can use --squash or --amend commands

[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=16545047#comment-16545047 ] Anton Mushin edited comment on FLINK-5750 at 7/16/18 10:40 AM: ---