[jira] [Reopened] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-2662: -- Another special case of this was reported. > CompilerException: "Bug: Plan generation for Unions pi

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2662: - Fix Version/s: (was: 1.1.4) > CompilerException: "Bug: Plan generation for Unions picked a shi

[jira] [Updated] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2168: - Assignee: ramkrishna.s.vasudevan (was: Wilmer DAZA) > Add HBaseTableSource >

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804080#comment-15804080 ] Fabian Hueske commented on FLINK-2168: -- Hi [~ram_krish], yes. That would be great. We

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814349#comment-15814349 ] Fabian Hueske commented on FLINK-2168: -- Hi [~ram_krish], * Calcite requires a relati

[jira] [Updated] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5386: - Description: Similar to the SQL, window clause is defined "as" a symbol which is explicitly used

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814699#comment-15814699 ] Fabian Hueske commented on FLINK-5386: -- Hi, sorry for the delayed reply. I like the

[jira] [Updated] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work

[ https://issues.apache.org/jira/browse/FLINK-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5394: - Description: The estimateRowCount method of DataSetCalc didn't work now. If I run the following c

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814733#comment-15814733 ] Fabian Hueske commented on FLINK-2168: -- I think we should limit this issue to impleme

[jira] [Updated] (FLINK-5280) Refactor TableSource

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5280: - Summary: Refactor TableSource (was: Extend TableSource to support nested data) > Refactor TableS

[jira] [Closed] (FLINK-5358) Support RowTypeInfo extraction in TypeExtractor by Row instance

[ https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5358. Resolution: Fixed Fix Version/s: 1.3.0 Implemented for 1.3 with 2af939a10288348eedb56fc0959da

[jira] [Closed] (FLINK-5280) Refactor TableSource

[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5280. Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed for 1.2 with a504abe465

[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=15817935#comment-15817935 ] Fabian Hueske edited comment on FLINK-5256 at 1/11/17 10:33 AM:

[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=15817935#comment-15817935 ] Fabian Hueske commented on FLINK-5256: -- Hi [~anmu], I had a brief look over your bra

[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=15817935#comment-15817935 ] Fabian Hueske edited comment on FLINK-5256 at 1/11/17 10:36 AM:

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15818868#comment-15818868 ] Fabian Hueske commented on FLINK-2168: -- For now we should only support scan and not g

[jira] [Updated] (FLINK-3475) DISTINCT aggregate function support for SQL queries

[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-3475: - Assignee: Zhenghua Gao > DISTINCT aggregate function support for SQL queries > ---

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821752#comment-15821752 ] Fabian Hueske commented on FLINK-3849: -- The table source must make sure that the pred

[jira] [Commented] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822251#comment-15822251 ] Fabian Hueske commented on FLINK-5434: -- Hi [~gallenvara_bg], projection was not added

[jira] [Updated] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Priority: Critical (was: Major) > Fix JoinITCase and add support for filter expressions on the On

[jira] [Updated] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Affects Version/s: 1.3.0 1.2.0 > Fix JoinITCase and add support for filter

[jira] [Commented] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823786#comment-15823786 ] Fabian Hueske commented on FLINK-5498: -- Thanks for reporting this issue, [~lincoln.86

[jira] [Updated] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Description: I found the expected result of a unit test case incorrect compare to that in a RDMBS

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Summary: OuterJoins with non-equality predicates compute wrong results (was: Fix JoinITCase and a

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823818#comment-15823818 ] Fabian Hueske commented on FLINK-2168: -- TableSources should go into the respective co

[jira] [Created] (FLINK-5520) Disable outer joins with non-equality predicates

Fabian Hueske created FLINK-5520: Summary: Disable outer joins with non-equality predicates Key: FLINK-5520 URL: https://issues.apache.org/jira/browse/FLINK-5520 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Affects Version/s: (was: 1.1.4) (was: 1.2.0) > OuterJoins with non-

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Priority: Minor (was: Critical) > OuterJoins with non-equality predicates compute wrong results >

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Issue Type: New Feature (was: Bug) > OuterJoins with non-equality predicates compute wrong result

[jira] [Commented] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825602#comment-15825602 ] Fabian Hueske commented on FLINK-5498: -- Fair enough, those are valid concerns. Then l

[jira] [Updated] (FLINK-5498) Add support for outer joins with non-equality predicates (and 1+ equality predicates)

[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Summary: Add support for outer joins with non-equality predicates (and 1+ equality predicates) (w

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825608#comment-15825608 ] Fabian Hueske commented on FLINK-2168: -- There is no need to create Java interfaces fo

[jira] [Commented] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825634#comment-15825634 ] Fabian Hueske commented on FLINK-5518: -- Thanks for the bug report [~havlikj]! Let me

[jira] [Updated] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5518: - Affects Version/s: 1.2.0 > HadoopInputFormat throws NPE when close() is called before open() > ---

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825660#comment-15825660 ] Fabian Hueske commented on FLINK-5386: -- Hi [~sunjincheng121], thanks for the reply.

[jira] [Updated] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5518: - Assignee: Jakub Havlik > HadoopInputFormat throws NPE when close() is called before open() > -

[jira] [Commented] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825664#comment-15825664 ] Fabian Hueske commented on FLINK-5518: -- Great, thanks [~havlikj]! I'll have a look so

[jira] [Created] (FLINK-5523) Improve access of fields in code generated functions with filters

Fabian Hueske created FLINK-5523: Summary: Improve access of fields in code generated functions with filters Key: FLINK-5523 URL: https://issues.apache.org/jira/browse/FLINK-5523 Project: Flink

[jira] [Created] (FLINK-5524) Support early out for code generated conjunctive conditions

Fabian Hueske created FLINK-5524: Summary: Support early out for code generated conjunctive conditions Key: FLINK-5524 URL: https://issues.apache.org/jira/browse/FLINK-5524 Project: Flink Is

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826006#comment-15826006 ] Fabian Hueske commented on FLINK-5386: -- Yes, that's what I would propose. {{GroupedT

[jira] [Closed] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5518. Resolution: Fixed Fix Version/s: 1.1.5 1.3.0 1.2.0 Fixe

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15827654#comment-15827654 ] Fabian Hueske commented on FLINK-5386: -- I think it would be good to get a fix for thi

[jira] [Created] (FLINK-5547) Move checks for DataSetRel validity into constructor

Fabian Hueske created FLINK-5547: Summary: Move checks for DataSetRel validity into constructor Key: FLINK-5547 URL: https://issues.apache.org/jira/browse/FLINK-5547 Project: Flink Issue Type

[jira] [Updated] (FLINK-5548) Move checks for DataStreamRel validity into constructor

[ https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5548: - Summary: Move checks for DataStreamRel validity into constructor (was: Move) > Move checks for D

[jira] [Created] (FLINK-5548) Move

Fabian Hueske created FLINK-5548: Summary: Move Key: FLINK-5548 URL: https://issues.apache.org/jira/browse/FLINK-5548 Project: Flink Issue Type: Improvement Components: Table API &

[jira] [Updated] (FLINK-5548) Move checks for DataStreamRel validity into constructor

[ https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5548: - Description: At the moment, most check to verify that a {{DataStreamRel}} is valid are done in th

[jira] [Closed] (FLINK-5548) Move checks for DataStreamRel validity into constructor

[ https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5548. Resolution: Invalid > Move checks for DataStreamRel validity into constructor >

[jira] [Commented] (FLINK-5548) Move checks for DataStreamRel validity into constructor

[ https://issues.apache.org/jira/browse/FLINK-5548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15828221#comment-15828221 ] Fabian Hueske commented on FLINK-5548: -- Thanks for checking [~jark], I had assumed th

[jira] [Assigned] (FLINK-4752) Improve session window documentation

[ https://issues.apache.org/jira/browse/FLINK-4752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-4752: Assignee: Fabian Hueske > Improve session window documentation > --

[jira] [Commented] (FLINK-5554) Add sql operator to table api for getting columns from HBase

[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15828370#comment-15828370 ] Fabian Hueske commented on FLINK-5554: -- The Table API uses Calcite to translate queri

[jira] [Commented] (FLINK-4683) Add SlideRow row-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15829626#comment-15829626 ] Fabian Hueske commented on FLINK-4683: -- Hi [~sunjincheng121], thanks for picking up t

[jira] [Closed] (FLINK-5520) Disable outer joins with non-equality predicates

[ https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5520. Resolution: Done Fix Version/s: 1.3.0 Fixed for 1.2.0 with 9073c53f902df7b3dbbdec2a30d86030e4

[jira] [Reopened] (FLINK-5452) Make table unit tests pass under cluster mode

[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-5452: -- > Make table unit tests pass under cluster mode > - > >

[jira] [Closed] (FLINK-5452) Make table unit tests pass under cluster mode

[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5452. Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed for 1.2.0 with 7f769261

[jira] [Assigned] (FLINK-5455) Create documentation how to upgrade jobs and Flink framework versions

[ https://issues.apache.org/jira/browse/FLINK-5455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-5455: Assignee: Fabian Hueske > Create documentation how to upgrade jobs and Flink framework vers

[jira] [Commented] (FLINK-5589) Tumbling group windows on batch tables do not consider object reuse

[ https://issues.apache.org/jira/browse/FLINK-5589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831813#comment-15831813 ] Fabian Hueske commented on FLINK-5589: -- I did not look into the code, but you should

[jira] [Closed] (FLINK-5386) Refactoring Window Clause

[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5386. Resolution: Implemented Fix Version/s: 1.3.0 1.2.0 Done for 1.2.0 with be0

[jira] [Closed] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2662. Resolution: Fixed Fixed for 1.1.5 with 6566b63aa50af946ecf0d028c4e284fc6dc2a55b Fixed for 1.2.0 with

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832607#comment-15832607 ] Fabian Hueske commented on FLINK-5582: -- Thanks for the proposal! This will be a great

[jira] [Commented] (FLINK-5564) User Defined Aggregates

[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832615#comment-15832615 ] Fabian Hueske commented on FLINK-5564: -- Thanks for the great proposal! User defined

[jira] [Updated] (FLINK-5584) Support Sliding-count row-window on streaming sql

[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5584: - Assignee: Yuhong Hong > Support Sliding-count row-window on streaming sql > --

[jira] [Commented] (FLINK-4867) Investigate code generation for improving sort performance

[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15834242#comment-15834242 ] Fabian Hueske commented on FLINK-4867: -- Hi [~heytitle], wow these are impressive numb

[jira] [Created] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

Fabian Hueske created FLINK-5653: Summary: Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL Key: FLINK-5653 URL: https://issues.apache.org/jira/browse/FLINK-5653 Project: Flink

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

Fabian Hueske created FLINK-5654: Summary: Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL Key: FLINK-5654 URL: https://issues.apache.org/jira/browse/FLINK-5654 Project: Flink

[jira] [Updated] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5653: - Description: The goal of this issue is to add support for OVER ROW aggregations on processing tim

[jira] [Updated] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5653: - Description: The goal of this issue is to add support for OVER ROWS aggregations on processing ti

[jira] [Created] (FLINK-5655) Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

Fabian Hueske created FLINK-5655: Summary: Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL Key: FLINK-5655 URL: https://issues.apache.org/jira/browse/FLINK-5655 Project: Flink

[jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Fabian Hueske created FLINK-5656: Summary: Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-5656 URL: https://issues.apache.org/jira/browse/FLINK-5656 Project: F

[jira] [Created] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Fabian Hueske created FLINK-5657: Summary: Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-5657 URL: https://issues.apache.org/jira/browse/FLINK-5657 Project:

[jira] [Updated] (FLINK-5655) Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5655: - Description: The goal of this issue is to add support for OVER RANGE aggregations on event time s

[jira] [Created] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Fabian Hueske created FLINK-5658: Summary: Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-5658 URL: https://issues.apache.org/jira/browse/FLINK-5658 Project: Flink

[jira] [Updated] (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:all-tabpanel ] Fabian Hueske updated FLINK-5654: - Description: The goal of this issue is to add support for OVER RANGE aggregations on processing t

[jira] [Updated] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5653: - Description: The goal of this issue is to add support for OVER ROWS aggregations on processing ti

[jira] [Updated] (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:all-tabpanel ] Fabian Hueske updated FLINK-5654: - Assignee: radu > Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL > -

[jira] [Updated] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5658: - Assignee: sunjincheng > Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL >

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

[ https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15842447#comment-15842447 ] Fabian Hueske commented on FLINK-5655: -- As discussed on the mailing list, I'm assigni

[jira] [Updated] (FLINK-5655) Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5655: - Assignee: Shaoxuan Wang > Add event time OVER RANGE BETWEEN x PRECEDING aggregation to 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&focusedCommentId=15843467#comment-15843467 ] Fabian Hueske commented on FLINK-5654: -- Yes, that's what I meant. > Add processing

[jira] [Updated] (FLINK-4680) Add SlidingRow row-windows for streaming tables

[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4680: - Description: Add SlideRow row-windows for streaming tables as described in [FLIP-11|https://cwiki

[jira] [Commented] (FLINK-4680) Add SlidingRow row-windows for streaming tables

[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15843500#comment-15843500 ] Fabian Hueske commented on FLINK-4680: -- The required issues add the optimization and

[jira] [Updated] (FLINK-4679) Add TumbleRow row-windows for streaming tables

[ https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4679: - Description: Add TumbleRow row-windows for streaming tables as described in [FLIP-11|https://cwik

[jira] [Updated] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11)

[ https://issues.apache.org/jira/browse/FLINK-4678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4678: - Description: Add SessionRow row-windows for streaming tables as described in [FLIP-11|https://cwi

[jira] [Updated] (FLINK-4678) Add SessionRow row-windows to Table API

[ https://issues.apache.org/jira/browse/FLINK-4678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4678: - Summary: Add SessionRow row-windows to Table API (was: Add SessionRow row-windows for streaming t

[jira] [Updated] (FLINK-4679) Add TumbleRow row-windows to Table API

[ https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4679: - Summary: Add TumbleRow row-windows to Table API (was: Add TumbleRow row-windows for streaming tab

[jira] [Updated] (FLINK-4680) Add SlidingRow row-windows to Table API

[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4680: - Summary: Add SlidingRow row-windows to Table API (was: Add SlidingRow row-windows for streaming t

[jira] (FLINK-1538) GSoC project: Spatial Data Processing Library

Title: Message Title Fabian Hueske closed an issue as Won't Fix

[jira] (FLINK-4679) Add TumbleRow row-windows to Table API

Title: Message Title Fabian Hueske commented on FLINK-4679

[jira] (FLINK-1456) Projection to fieldnames, keyselectors

Title: Message Title Fabian Hueske commented on FLINK-1456

[jira] (FLINK-1456) Projection to fieldnames, keyselectors

Title: Message Title Fabian Hueske closed an issue as Won't Fix

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

Title: Message Title Fabian Hueske commented on FLINK-5654

[jira] (FLINK-5455) Create documentation how to upgrade jobs and Flink framework versions

Title: Message Title Fabian Hueske commented on FLINK-5455

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15848638#comment-15848638 ] Fabian Hueske commented on FLINK-5695: -- Hi [~sunjincheng121], I am not sure how this

[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&focusedCommentId=15850584#comment-15850584 ] Fabian Hueske commented on FLINK-5654: -- I agree [~rtudoran], the second approach look

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851742#comment-15851742 ] Fabian Hueske commented on FLINK-5710: -- We have to think a bit more about this functi

[jira] [Commented] (FLINK-4047) Fix documentation about determinism of KeySelectors

[ https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853688#comment-15853688 ] Fabian Hueske commented on FLINK-4047: -- Identity is something different. The computed

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853702#comment-15853702 ] Fabian Hueske commented on FLINK-5710: -- That sounds good. Let's start with a simple "

[jira] [Commented] (FLINK-5624) Support tumbling window on streaming tables in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853718#comment-15853718 ] Fabian Hueske commented on FLINK-5624: -- Hi [~wheat9], windowing is a way to define gr

[jira] [Created] (FLINK-5722) Implement DISTINCT as dedicated operator

Fabian Hueske created FLINK-5722: Summary: Implement DISTINCT as dedicated operator Key: FLINK-5722 URL: https://issues.apache.org/jira/browse/FLINK-5722 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854052#comment-15854052 ] Fabian Hueske commented on FLINK-5695: -- I agree that the semantics of {{GroupedTable}

[jira] [Commented] (FLINK-5564) User Defined Aggregates

[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854402#comment-15854402 ] Fabian Hueske commented on FLINK-5564: -- Hi [~Shaoxuan Wang], I think it should be pos

<    2   3   4   5   6   7   8   9   10   11   >