[jira] [Commented] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258684#comment-17258684 ] Vasii Cosmin Radu commented on FLINK-9940: -- Hi there, [~maguowei], [~Averell], [~kkl0u],

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085127#comment-17085127 ] Vasii Cosmin Radu commented on FLINK-17170: --- How come it works when I perform a cancel,

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084591#comment-17084591 ] Vasii Cosmin Radu commented on FLINK-17170: --- Thanks guys for looking into this, [~klion26]

[jira] [Updated] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasii Cosmin Radu updated FLINK-17170: -- Attachment: threaddump_tm1 > Cannot stop streaming job with savepoint which uses

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084258#comment-17084258 ] Vasii Cosmin Radu commented on FLINK-17170: --- It's quite hard to debug, because I have multiple

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084238#comment-17084238 ] Vasii Cosmin Radu commented on FLINK-17170: --- And regarding the savepoint, yes it finished

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084235#comment-17084235 ] Vasii Cosmin Radu commented on FLINK-17170: --- I was doing that. And the shard consumer threads

[jira] [Updated] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasii Cosmin Radu updated FLINK-17170: -- Description: I am encountering a very strange situation where I can't stop with

[jira] [Updated] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasii Cosmin Radu updated FLINK-17170: -- Description: I am encountering a very strange situation where I can't stop with

[jira] [Updated] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasii Cosmin Radu updated FLINK-17170: -- Attachment: Screenshot 2020-04-15 at 18.16.26.png > Cannot stop streaming job with

[jira] [Created] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

Vasii Cosmin Radu created FLINK-17170: - Summary: Cannot stop streaming job with savepoint which uses kinesis consumer Key: FLINK-17170 URL: https://issues.apache.org/jira/browse/FLINK-17170

[jira] [Commented] (FLINK-11794) Allow compression of row format files created by StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061043#comment-17061043 ] Vasii Cosmin Radu commented on FLINK-11794: --- I think the ticket is referring to compression in

[jira] [Updated] (FLINK-6075) ORDER BY *time ASC

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Description: These will be split in 3 separated JIRA issues. However, the design is the same only the processing

[jira] [Updated] (FLINK-6075) ORDER BY *time ASC

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Summary: ORDER BY *time ASC (was: Support Limit/Top(Sort) for Stream SQL) > ORDER BY *time ASC >

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028458#comment-16028458 ] radu commented on FLINK-6075: - TOP syntax is not supported by Calcite. Basically top is obtained by using

[jira] [Commented] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002131#comment-16002131 ] radu commented on FLINK-6500: - [~fhueske] Thanks for the info. Considering the workaround - should i close

[jira] [Updated] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6500: Description: Relying on implicit types in scala can lead to errors when the arity of the input is different than

[jira] [Updated] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6500: Description: Relying on implicit types in scala can lead to errors when the arity of the input is different than

[jira] [Commented] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001304#comment-16001304 ] radu commented on FLINK-6500: - [~fhueske] While testing various ways of using the sql i found the above

[jira] [Created] (FLINK-6500) RowSerialization problem

radu created FLINK-6500: --- Summary: RowSerialization problem Key: FLINK-6500 URL: https://issues.apache.org/jira/browse/FLINK-6500 Project: Flink Issue Type: Bug Components: Table API & SQL

[jira] [Commented] (FLINK-6476) Table environment register row data stream

[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000512#comment-16000512 ] radu commented on FLINK-6476: - [~fhueske] Great. I will try to implement this. I will ping you after i have

[jira] [Commented] (FLINK-6476) Table environment register row data stream

[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000450#comment-16000450 ] radu commented on FLINK-6476: - [~fhueske] I actually tried also to set the type of the datastream manually

[jira] [Commented] (FLINK-6476) Table environment register row data stream

[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1591#comment-1591 ] radu commented on FLINK-6476: - [~fhueske] [~sunjincheng121] [~shijinkui] [~stefano.bortoli] [~Yuhong_kyo]

[jira] [Created] (FLINK-6476) Table environment register row data stream

radu created FLINK-6476: --- Summary: Table environment register row data stream Key: FLINK-6476 URL: https://issues.apache.org/jira/browse/FLINK-6476 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998517#comment-15998517 ] radu commented on FLINK-6465: - How do you plan to implement this? Will you support retraction when these would

[jira] [Commented] (FLINK-6428) Add support DISTINCT in dataStream SQL

[ https://issues.apache.org/jira/browse/FLINK-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15992775#comment-15992775 ] radu commented on FLINK-6428: - [~sunjincheng121] Hi, Please refer to #6249

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955419#comment-15955419 ] radu commented on FLINK-6249: - [~fhueske] [~twalthr] It seems that the aggregates that are passed in the

[jira] [Commented] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954746#comment-15954746 ] radu commented on FLINK-6241: - [~shaoxuan] i realized i did not notify you :) > codeGen dataStream aggregates

[jira] [Commented] (FLINK-6260) Distinct Aggregates for Group By Windows

[ https://issues.apache.org/jira/browse/FLINK-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954739#comment-15954739 ] radu commented on FLINK-6260: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Created] (FLINK-6260) Distinct Aggregates for Group By Windows

radu created FLINK-6260: --- Summary: Distinct Aggregates for Group By Windows Key: FLINK-6260 URL: https://issues.apache.org/jira/browse/FLINK-6260 Project: Flink Issue Type: New Feature

[jira] [Comment Edited] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953646#comment-15953646 ] radu edited comment on FLINK-6249 at 4/4/17 7:48 AM: - [~fhueske] [~shijinkui]

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954717#comment-15954717 ] radu commented on FLINK-6249: - [~fhueske] Thanks for the feedback! I cleaned the JIRA as you suggested. I will

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1.

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1.

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1.

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1.

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953646#comment-15953646 ] radu commented on FLINK-6249: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Created] (FLINK-6253) Distinct rowTime with time range boundaries

radu created FLINK-6253: --- Summary: Distinct rowTime with time range boundaries Key: FLINK-6253 URL: https://issues.apache.org/jira/browse/FLINK-6253 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6252) Distinct rowTime with Rows boundaries

radu created FLINK-6252: --- Summary: Distinct rowTime with Rows boundaries Key: FLINK-6252 URL: https://issues.apache.org/jira/browse/FLINK-6252 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Assigned] (FLINK-6251) Distinct procTime with time range boundaries

[ https://issues.apache.org/jira/browse/FLINK-6251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6251: --- Assignee: radu > Distinct procTime with time range boundaries >

[jira] [Created] (FLINK-6251) Distinct procTime with time range boundaries

radu created FLINK-6251: --- Summary: Distinct procTime with time range boundaries Key: FLINK-6251 URL: https://issues.apache.org/jira/browse/FLINK-6251 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6250: --- Assignee: Stefano Bortoli Description: Support proctime with rows boundaries Q1.1. `SELECT SUM(

[jira] [Created] (FLINK-6250) Distinct procTime with Rows boundaries

radu created FLINK-6250: --- Summary: Distinct procTime with Rows boundaries Key: FLINK-6250 URL: https://issues.apache.org/jira/browse/FLINK-6250 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1.

[jira] [Created] (FLINK-6249) Distinct Aggregates for OVER window

radu created FLINK-6249: --- Summary: Distinct Aggregates for OVER window Key: FLINK-6249 URL: https://issues.apache.org/jira/browse/FLINK-6249 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins

[ https://issues.apache.org/jira/browse/FLINK-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953081#comment-15953081 ] radu commented on FLINK-6243: - Hi Elias, Please check also https://issues.apache.org/jira/browse/FLINK-5725

[jira] [Commented] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953080#comment-15953080 ] radu commented on FLINK-6241: - can you please post a description of what you aim to do? I am curious if you

[jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949899#comment-15949899 ] radu commented on FLINK-5725: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949878#comment-15949878 ] radu commented on FLINK-6082: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949864#comment-15949864 ] radu commented on FLINK-6075: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Comment Edited] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949864#comment-15949864 ] radu edited comment on FLINK-6075 at 3/30/17 9:23 PM: -- [~fhueske] [~shijinkui]

[jira] [Assigned] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6081: --- Assignee: radu > Offset/Fetch support for SQL Streaming > -- > >

[jira] [Commented] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949857#comment-15949857 ] radu commented on FLINK-6081: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Commented] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949827#comment-15949827 ] radu commented on FLINK-6077: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Comment Edited] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949735#comment-15949735 ] radu edited comment on FLINK-6073 at 3/30/17 9:01 PM: -- [~fhueske] [~shijinkui]

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949735#comment-15949735 ] radu commented on FLINK-6073: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]

[jira] [Comment Edited] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949103#comment-15949103 ] radu edited comment on FLINK-6073 at 3/30/17 2:01 PM: -- { LogicalProject(A1=[$0])

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949103#comment-15949103 ] radu commented on FLINK-6073: - LogicalProject(A1=[$0]) LogicalJoin(condition=[AND(=($2, $4), =($2, $5),

[jira] [Commented] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948943#comment-15948943 ] radu commented on FLINK-6077: - Using queries such as SELECT A1 FROM T1 WHERE A2 IN "(SELECT B2 FROM T2) the

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948935#comment-15948935 ] radu commented on FLINK-6073: - [~fhueske] - no i understood what you meant. I think it is correct - the logic

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948765#comment-15948765 ] radu commented on FLINK-6073: - [~fhueske] Thanks for the remarks. My idea of the queries such as the one you

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946961#comment-15946961 ] radu commented on FLINK-6075: - We use the sort example as a benchamrk from

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946959#comment-15946959 ] radu commented on FLINK-6075: - We can therefor start from supporting SELECT a2 FROM s2 ORDER BY

[jira] [Comment Edited] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946956#comment-15946956 ] radu edited comment on FLINK-6075 at 3/29/17 11:33 AM: --- Queries such as Q3) `SELECT

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946956#comment-15946956 ] radu commented on FLINK-6075: - Queries such as Q3) `SELECT sum(a) OVER (ORDER BY proctime RANGE INTERVAL '1'

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946947#comment-15946947 ] radu commented on FLINK-6075: - Calcite grammar also restricts using the limit within the OVER aggregate

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946931#comment-15946931 ] radu commented on FLINK-6075: - Please refer to the comments from [#Flink-6081] Considering that Calcite does

[jira] [Commented] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946776#comment-15946776 ] radu commented on FLINK-6081: - Considering that Calcite does not currently support syntax such as GROUP BY

[jira] [Commented] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945497#comment-15945497 ] radu commented on FLINK-6081: - After checking with Calcite parser option the query examples need to be

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945151#comment-15945151 ] radu commented on FLINK-6082: - [~fhueske] - Fine for me for the time condition to select the subset of the

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945136#comment-15945136 ] radu commented on FLINK-6082: - I add also [~Yuhong_kyo] as she works on the join design > Support window

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945125#comment-15945125 ] radu commented on FLINK-6073: - Hi [~fhueske] thanks again for the feedback - it is really helpful and i

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944957#comment-15944957 ] radu commented on FLINK-6082: - Hi [~fhueske] thanks for the review. I agree with the modification proposal to

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944671#comment-15944671 ] radu commented on FLINK-6073: - Hi [~fhueske], Thanks for the review. I agree that we should support the

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15940880#comment-15940880 ] radu commented on FLINK-6073: - the join window can be one window element as we emit for every incoming event

[jira] [Commented] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15936277#comment-15936277 ] radu commented on FLINK-6077: - It is actually more similar with inner queries (that is if you do not have a

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932636#comment-15932636 ] radu commented on FLINK-6073: - I will start the implementation to support this rule [~fhueske] [~twalthr]

[jira] [Assigned] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6073: --- Assignee: radu > Support for SQL inner queries for proctime > -- > >

[jira] [Updated] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6082: Description: Time target: Proc Time Calcite documentation refers to query examples where the (time) boundaries are

[jira] [Created] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

radu created FLINK-6082: --- Summary: Support window definition for SQL Queries based on WHERE clause with time condition Key: FLINK-6082 URL: https://issues.apache.org/jira/browse/FLINK-6082 Project: Flink

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6081: Description: Time target: Proc Time The main scope of Offset/Fetch is for pagination support. In the context of

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6081: Attachment: offset.png > Offset/Fetch support for SQL Streaming > -- > >

[jira] [Created] (FLINK-6081) Offset/Fetch support for SQL Streaming

radu created FLINK-6081: --- Summary: Offset/Fetch support for SQL Streaming Key: FLINK-6081 URL: https://issues.apache.org/jira/browse/FLINK-6081 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6077: Description: Time target: Proc Time SQL targeted query examples: With inner query

[jira] [Updated] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6077: Attachment: in.png > Support In/Exists/Except/Any /Some/All for Stream SQL >

[jira] [Created] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

radu created FLINK-6077: --- Summary: Support In/Exists/Except/Any /Some/All for Stream SQL Key: FLINK-6077 URL: https://issues.apache.org/jira/browse/FLINK-6077 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Attachment: sort.png > Support Limit/Top(Sort) for Stream SQL > -- > >

[jira] [Updated] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Description: These will be split in 3 separated JIRA issues. However, the design is the same only the processing

[jira] [Created] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

radu created FLINK-6075: --- Summary: Support Limit/Top(Sort) for Stream SQL Key: FLINK-6075 URL: https://issues.apache.org/jira/browse/FLINK-6075 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Attachment: innerquery.png > Support for SQL inner queries for proctime >

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from

[jira] [Created] (FLINK-6073) Support for SQL inner queries for proctime

radu created FLINK-6073: --- Summary: Support for SQL inner queries for proctime Key: FLINK-6073 URL: https://issues.apache.org/jira/browse/FLINK-6073 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-5725: --- Assignee: Yuhong Hong (was: radu) > Support JOIN between two streams in the SQL API >

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15896875#comment-15896875 ] radu commented on FLINK-5654: - @shijinkui - thanks for the comment I keeped description because all other sql

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15894348#comment-15894348 ] radu commented on FLINK-5654: - Hi, I did the rebase yesterday before I did the pull request. However, the

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15893873#comment-15893873 ] radu commented on FLINK-5654: - Thanks sunjincheng - I saw the message to late unfortunately. I can do another

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888373#comment-15888373 ] radu commented on FLINK-5654: - When we implement the aggregation functions we could use the interface that

  1   2   >