[jira] [Closed] (FLINK-11932) Add support for generating optimized logical plan for 'select * from mytable'

2019-03-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11932. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 2410b24d81baaedd33f06bda7d55bc500ddc63db

[jira] [Closed] (FLINK-11871) Introduce LongHashTable to improve performance when join key fits in long

2019-03-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11871. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 299747fc698d99ff826a810b2b354db53b34848c

[jira] [Closed] (FLINK-11856) Introduce BinaryHashTable to batch table runtime

2019-03-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11856. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 5968206f843a58e10e3db58cde3407bb3608d085

[jira] [Assigned] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11905: -- Assignee: Kurt Young > BlockCompressionTest does not compile with Java 9 >

[jira] [Commented] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792277#comment-16792277 ] Kurt Young commented on FLINK-11905: I will take a look and fix this, thanks for the reporting

[jira] [Closed] (FLINK-11896) Introduce stream physical nodes

2019-03-15 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11896. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in d814f04e5f14c258c359777c0e8fbd381d4b8679

[jira] [Created] (FLINK-11927) Code clean up and refactor BinaryHashTable and LongHybridHashTable

2019-03-15 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11927: -- Summary: Code clean up and refactor BinaryHashTable and LongHybridHashTable Key: FLINK-11927 URL: https://issues.apache.org/jira/browse/FLINK-11927 Project: Flink

[jira] [Closed] (FLINK-11882) Introduce BytesHashMap to batch hash agg

2019-03-15 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11882. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in c02eec9e1b758cfd743623635eb063d24b366780

[jira] [Created] (FLINK-11930) Split SegmentsUtil into some dedicated utilities

2019-03-15 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11930: -- Summary: Split SegmentsUtil into some dedicated utilities Key: FLINK-11930 URL: https://issues.apache.org/jira/browse/FLINK-11930 Project: Flink Issue Type:

[jira] [Created] (FLINK-11856) Introduce BinaryHashTable and LongHashTable to batch table runtime

2019-03-07 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11856: -- Summary: Introduce BinaryHashTable and LongHashTable to batch table runtime Key: FLINK-11856 URL: https://issues.apache.org/jira/browse/FLINK-11856 Project: Flink

[jira] [Created] (FLINK-11858) Introduce block compressor/decompressor for batch table runtime

2019-03-07 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11858: -- Summary: Introduce block compressor/decompressor for batch table runtime Key: FLINK-11858 URL: https://issues.apache.org/jira/browse/FLINK-11858 Project: Flink

[jira] [Closed] (FLINK-11863) Introduce channel to read and write compressed data

2019-03-10 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11863. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 3ed490f0f4e561f1ef8b3660d4370030db6115dc

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-02-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772679#comment-16772679 ] Kurt Young commented on FLINK-11421: [~fan_li_ya] I'm aware of this information. But according to

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772832#comment-16772832 ] Kurt Young commented on FLINK-11421: [~fan_li_ya] Sounds great, thanks! BTW, could please close the

[jira] [Created] (FLINK-11674) Add an initial Blink SQL code generator

2019-02-20 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11674: -- Summary: Add an initial Blink SQL code generator Key: FLINK-11674 URL: https://issues.apache.org/jira/browse/FLINK-11674 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11674) Add an initial Blink SQL code generator

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772859#comment-16772859 ] Kurt Young commented on FLINK-11674: It will be covered by FLINK-11488 > Add an initial Blink SQL

[jira] [Closed] (FLINK-11675) Add an initial support for running batch jobs with streaming runtime

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11675. -- Resolution: Duplicate > Add an initial support for running batch jobs with streaming runtime >

[jira] [Updated] (FLINK-11675) Add an initial support for running batch jobs with streaming runtime

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11675: --- Issue Type: Task (was: Sub-task) Parent: (was: FLINK-11439) > Add an initial support

[jira] [Commented] (FLINK-11675) Add an initial support for running batch jobs with streaming runtime

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772860#comment-16772860 ] Kurt Young commented on FLINK-11675: It will be covered by FLINK-11490 > Add an initial support for

[jira] [Created] (FLINK-11675) Add an initial support for running batch jobs with streaming runtime

2019-02-20 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11675: -- Summary: Add an initial support for running batch jobs with streaming runtime Key: FLINK-11675 URL: https://issues.apache.org/jira/browse/FLINK-11675 Project: Flink

[jira] [Closed] (FLINK-11674) Add an initial Blink SQL code generator

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11674. -- Resolution: Duplicate > Add an initial Blink SQL code generator >

[jira] [Updated] (FLINK-11674) Add an initial Blink SQL code generator

2019-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11674: --- Issue Type: Task (was: Sub-task) Parent: (was: FLINK-11439) > Add an initial Blink SQL

[jira] [Commented] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql

2019-01-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754502#comment-16754502 ] Kurt Young commented on FLINK-11439: Interesting title [~twalthr] :D > INSERT INTO flink_sql SELECT

[jira] [Closed] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6649. - Resolution: Unresolved > Improve Non-window group aggregate with configurable `earlyFire`. >

[jira] [Closed] (FLINK-7471) Improve bounded OVER support non-retract method AGG

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7471. - Resolution: Unresolved > Improve bounded OVER support non-retract method AGG >

[jira] [Closed] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9325. - Resolution: Unresolved > generate the _meta file for checkpoint only when the writing is truly >

[jira] [Closed] (FLINK-6036) Let catalog support partition

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6036. - Resolution: Unresolved > Let catalog support partition > - > >

[jira] [Closed] (FLINK-7636) Introduce Flink RelOptTable, and remove tableSource from all TableSourceScan node constructor

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7636. - Resolution: Unresolved > Introduce Flink RelOptTable, and remove tableSource from all TableSourceScan

[jira] [Closed] (FLINK-8868) Support Table Function as Table for Stream Sql

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-8868. - Resolution: Unresolved > Support Table Function as Table for Stream Sql >

[jira] [Closed] (FLINK-5225) Add interface to override parameter types of UDTF's eval method

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5225. - Resolution: Unresolved > Add interface to override parameter types of UDTF's eval method >

[jira] [Closed] (FLINK-4962) Improve exception information about operand type inference failure during UDF SQL validation

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-4962. - Resolution: Unresolved > Improve exception information about operand type inference failure during UDF

[jira] [Closed] (FLINK-5858) Support multiple sinks in same execution DAG

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5858. - Resolution: Unresolved > Support multiple sinks in same execution DAG >

[jira] [Closed] (FLINK-5900) Add non-partial merge Aggregates and unit tests

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5900. - Resolution: Unresolved > Add non-partial merge Aggregates and unit tests >

[jira] [Closed] (FLINK-6839) Improve SQL OVER alias When only one OVER window agg in selection.

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6839. - Resolution: Unresolved > Improve SQL OVER alias When only one OVER window agg in selection. >

[jira] [Closed] (FLINK-6851) Improve built-in scalar function when upgrade calcite version to 1.13

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6851. - Resolution: Unresolved > Improve built-in scalar function when upgrade calcite version to 1.13 >

[jira] [Closed] (FLINK-9958) Fix potential NPE for delta iteration of DataSet

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9958. - Resolution: Unresolved > Fix potential NPE for delta iteration of DataSet >

[jira] [Closed] (FLINK-5565) Improve flink cost model framework

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5565. - Resolution: Unresolved > Improve flink cost model framework > --- > >

[jira] [Closed] (FLINK-6150) change DataSetCost to FlinkRelOptCost

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6150. - Resolution: Unresolved > change DataSetCost to FlinkRelOptCost > - >

[jira] [Closed] (FLINK-6066) Separate logical and physical RelNode layer in Flink

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6066. - Resolution: Unresolved > Separate logical and physical RelNode layer in Flink >

[jira] [Closed] (FLINK-7163) Make LogicalTableFunctionCall immutable

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7163. - Resolution: Unresolved > Make LogicalTableFunctionCall immutable >

[jira] [Closed] (FLINK-6441) Improve the UDTF

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6441. - Resolution: Unresolved > Improve the UDTF > > > Key: FLINK-6441 >

[jira] [Closed] (FLINK-6544) Expose State Backend Interface for UDAGG

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6544. - Resolution: Unresolved > Expose State Backend Interface for UDAGG >

[jira] [Closed] (FLINK-6457) Clean up ScalarFunction and TableFunction interface

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6457. - Resolution: Unresolved > Clean up ScalarFunction and TableFunction interface >

[jira] [Closed] (FLINK-6955) Add operation log for Table

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6955. - Resolution: Unresolved > Add operation log for Table > --- > >

[jira] [Closed] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5342. - Resolution: Unresolved > Setting the parallelism automatically for operators base on cost model >

[jira] [Closed] (FLINK-7620) Supports user defined optimization phase

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7620. - Resolution: Unresolved > Supports user defined optimization phase >

[jira] [Closed] (FLINK-7959) Split CodeGenerator into CodeGeneratorContext and ExprCodeGenerator

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7959. - Resolution: Unresolved > Split CodeGenerator into CodeGeneratorContext and ExprCodeGenerator >

[jira] [Closed] (FLINK-7834) cost model (RelOptCost) extends network cost and memory cost

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7834. - Resolution: Unresolved > cost model (RelOptCost) extends network cost and memory cost >

[jira] [Closed] (FLINK-7621) Fix Inconsistency of CaseSensitive Configuration

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7621. - Resolution: Unresolved > Fix Inconsistency of CaseSensitive Configuration >

[jira] [Closed] (FLINK-7448) Keep the data type unchanged when register an existing field as rowtime

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7448. - Resolution: Unresolved > Keep the data type unchanged when register an existing field as rowtime >

[jira] [Closed] (FLINK-7464) Add useful build-in Aggregate function into TabalAPI

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7464. - Resolution: Unresolved > Add useful build-in Aggregate function into TabalAPI >

[jira] [Closed] (FLINK-6465) support FIRST_VALUE on Table API & SQL

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6465. - Resolution: Unresolved > support FIRST_VALUE on Table API & SQL > --

[jira] [Closed] (FLINK-7358) Add implicitly converts support for User-defined function

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7358. - Resolution: Unresolved > Add implicitly converts support for User-defined function >

[jira] [Closed] (FLINK-7024) Add supported for selecting window proctime/rowtime on row-based Tumble/Slide window

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7024. - Resolution: Unresolved > Add supported for selecting window proctime/rowtime on row-based >

[jira] [Closed] (FLINK-9344) Support INTERSECT and INTERSECT ALL for streaming

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9344. - Resolution: Unresolved > Support INTERSECT and INTERSECT ALL for streaming >

[jira] [Closed] (FLINK-6154) Refine code reusing between logical and physical operators

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6154. - Resolution: Unresolved > Refine code reusing between logical and physical operators >

[jira] [Closed] (FLINK-6355) TableEnvironment support register TableFunction

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6355. - Resolution: Unresolved > TableEnvironment support register TableFunction >

[jira] [Closed] (FLINK-6219) Add a sorted state primitive

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6219. - Resolution: Unresolved > Add a sorted state primitive > > >

[jira] [Closed] (FLINK-6992) add support for IN, NOT IN in tableAPI

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6992. - Resolution: Unresolved > add support for IN, NOT IN in tableAPI > --

[jira] [Closed] (FLINK-6092) Implement and turn on retraction for table source

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6092. - Resolution: Unresolved > Implement and turn on retraction for table source >

[jira] [Closed] (FLINK-6978) Add documentation for Register User-Defined Functions.

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6978. - Resolution: Unresolved > Add documentation for Register User-Defined Functions. >

[jira] [Closed] (FLINK-6196) Support dynamic schema in Table Function

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6196. - Resolution: Unresolved > Support dynamic schema in Table Function >

[jira] [Closed] (FLINK-6961) Enable configurable early-firing rate

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6961. - Resolution: Unresolved > Enable configurable early-firing rate > --

[jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755943#comment-16755943 ] Kurt Young commented on FLINK-9559: --- Not sure if blink handled this case correctly, keep this Jira open

[jira] [Closed] (FLINK-7618) Add BINARY supported in FlinkTypeFactory

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7618. - Resolution: Unresolved > Add BINARY supported in FlinkTypeFactory >

[jira] [Closed] (FLINK-5859) support partition pruning on Table API & SQL

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5859. - Resolution: Unresolved > support partition pruning on Table API & SQL >

[jira] [Closed] (FLINK-5313) Supporting all tpch queries

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5313. - Resolution: Unresolved > Supporting all tpch queries > --- > >

[jira] [Closed] (FLINK-9997) Improve Expression Reduce

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9997. - Resolution: Unresolved > Improve Expression Reduce > - > > Key:

[jira] [Closed] (FLINK-6637) Move registerFunction to TableEnvironment

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6637. - Resolution: Unresolved > Move registerFunction to TableEnvironment >

[jira] [Closed] (FLINK-6686) Improve UDXF(UDF,UDTF,UDAF) test case

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6686. - Resolution: Unresolved > Improve UDXF(UDF,UDTF,UDAF) test case > - >

[jira] [Closed] (FLINK-7207) Support getAccumulatorType when use DataView

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7207. - Resolution: Unresolved > Support getAccumulatorType when use DataView >

[jira] [Closed] (FLINK-7942) NPE when apply FilterJoinRule

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7942. - Resolution: Unresolved > NPE when apply FilterJoinRule > - > >

[jira] [Closed] (FLINK-10188) Solve nondeterministic functions problem for retraction

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-10188. -- Resolution: Unresolved > Solve nondeterministic functions problem for retraction >

[jira] [Commented] (FLINK-6219) Add a sorted state primitive

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755989#comment-16755989 ] Kurt Young commented on FLINK-6219: --- Hi [~aromero], thanks for pointing this out, and it's my bad to

[jira] [Closed] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6516. - Resolution: Unresolved > using real row count instead of dummy row count when optimizing plan >

[jira] [Closed] (FLINK-8782) Rmove count agg if it is generated for sum agg in over window

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-8782. - Resolution: Unresolved > Rmove count agg if it is generated for sum agg in over window >

[jira] [Closed] (FLINK-9474) Add runtime support of distinct filter using ElasticBloomFilter

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9474. - Resolution: Unresolved > Add runtime support of distinct filter using ElasticBloomFilter >

[jira] [Closed] (FLINK-8918) Introduce Runtime Filter Join

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-8918. - Resolution: Unresolved Fix Version/s: (was: 1.8.0) > Introduce Runtime Filter Join >

[jira] [Closed] (FLINK-9345) Support EXCEPT and EXCEPT ALL for streaming

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9345. - Resolution: Unresolved > Support EXCEPT and EXCEPT ALL for streaming >

[jira] [Closed] (FLINK-9475) introduce an approximate version of "select distinct"

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9475. - Resolution: Unresolved > introduce an approximate version of "select distinct" >

[jira] [Closed] (FLINK-8594) Add a dedicated DISTINCT operator to always produce append sreams

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-8594. - Resolution: Unresolved > Add a dedicated DISTINCT operator to always produce append sreams >

[jira] [Closed] (FLINK-9346) Update documents for supporting intersect/except in streaming

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-9346. - Resolution: Unresolved > Update documents for supporting intersect/except in streaming >

[jira] [Closed] (FLINK-7987) Use RexBuilder when converting Expression to RexNode

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7987. - Resolution: Unresolved > Use RexBuilder when converting Expression to RexNode >

[jira] [Closed] (FLINK-7509) Refactorings to AggregateCodeGenerator

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-7509. - Resolution: Unresolved > Refactorings to AggregateCodeGenerator > --

[jira] [Closed] (FLINK-8045) Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-8045. - Resolution: Unresolved > Add Internal DATE/TIME/TIMESTAMP as internal representation of >

[jira] [Closed] (FLINK-6963) Add User Defined Operator in Table API

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-6963. - Resolution: Unresolved > Add User Defined Operator in Table API > --

[jira] [Commented] (FLINK-8918) Introduce Runtime Filter Join

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756118#comment-16756118 ] Kurt Young commented on FLINK-8918: --- I'm closing this jira since we will no longer put efforts in this

[jira] [Commented] (FLINK-8594) Add a dedicated DISTINCT operator to always produce append sreams

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756123#comment-16756123 ] Kurt Young commented on FLINK-8594: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756125#comment-16756125 ] Kurt Young commented on FLINK-5859: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756127#comment-16756127 ] Kurt Young commented on FLINK-5342: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-5858) Support multiple sinks in same execution DAG

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756126#comment-16756126 ] Kurt Young commented on FLINK-5858: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-5313) Supporting all tpch queries

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756128#comment-16756128 ] Kurt Young commented on FLINK-5313: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-5565) Improve flink cost model framework

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756171#comment-16756171 ] Kurt Young commented on FLINK-5565: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-6839) Improve SQL OVER alias When only one OVER window agg in selection.

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756177#comment-16756177 ] Kurt Young commented on FLINK-6839: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-6036) Let catalog support partition

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756172#comment-16756172 ] Kurt Young commented on FLINK-6036: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-6544) Expose State Backend Interface for UDAGG

2019-01-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756175#comment-16756175 ] Kurt Young commented on FLINK-6544: --- I'm closing this issue since it will be addressed after blink gets

[jira] [Commented] (FLINK-11425) Support of “Hash Teams” in Hybrid Hash Join

2019-01-29 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754775#comment-16754775 ] Kurt Young commented on FLINK-11425: Hi [~tianchen92], thanks for looking into this. We definitely

[jira] [Commented] (FLINK-12140) Support sort merge join it case run in batch mode

2019-04-10 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815052#comment-16815052 ] Kurt Young commented on FLINK-12140: you could just say support e2e join operator > Support sort

[jira] [Closed] (FLINK-12098) Add support for generating optimized logical plan for simple group aggregate on stream

2019-04-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12098. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed in 517a04f1cbe74d10340b1cb17eb2b4a1b1b11195 >

[jira] [Commented] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

2019-04-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815374#comment-16815374 ] Kurt Young commented on FLINK-11974: Yeah, you are right, I forgot that we change the operator type

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