[jira] [Created] (FLINK-6620) Add KeyGroupCheckpointedOperator interface that works for checkpointing key-groups

2017-05-17 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-6620: --- Summary: Add KeyGroupCheckpointedOperator interface that works for checkpointing key-groups Key: FLINK-6620 URL: https://issues.apache.org/jira/browse/FLINK-6620

[jira] [Commented] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-14 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165979#comment-16165979 ] Jingsong Lee commented on FLINK-7617: - [~XKing] Good suggestion, this method is useful. But I think

[jira] [Created] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-13 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-7617: --- Summary: Remove string format in BitSet to improve the performance of BuildSideOuterjoin Key: FLINK-7617 URL: https://issues.apache.org/jira/browse/FLINK-7617 Project:

[jira] [Commented] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

2017-09-13 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165786#comment-16165786 ] Jingsong Lee commented on FLINK-7617: - Can someone give me the right to assign to me? > Remove string

[jira] [Created] (FLINK-12081) Introduce aggregation operator code generator to blink batch

2019-04-02 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12081: Summary: Introduce aggregation operator code generator to blink batch Key: FLINK-12081 URL: https://issues.apache.org/jira/browse/FLINK-12081 Project: Flink

[jira] [Created] (FLINK-12073) Support appropriate precision and scale processing of Decimal in Blink SQL

2019-03-31 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12073: Summary: Support appropriate precision and scale processing of Decimal in Blink SQL Key: FLINK-12073 URL: https://issues.apache.org/jira/browse/FLINK-12073 Project:

[jira] [Created] (FLINK-12087) Introduce over window operators to blink batch

2019-04-02 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12087: Summary: Introduce over window operators to blink batch Key: FLINK-12087 URL: https://issues.apache.org/jira/browse/FLINK-12087 Project: Flink Issue Type:

[jira] [Created] (FLINK-12094) Introduce sort merge join operator to blink batch

2019-04-03 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12094: Summary: Introduce sort merge join operator to blink batch Key: FLINK-12094 URL: https://issues.apache.org/jira/browse/FLINK-12094 Project: Flink Issue

[jira] [Created] (FLINK-12013) Support calc and correlate in blink

2019-03-25 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12013: Summary: Support calc and correlate in blink Key: FLINK-12013 URL: https://issues.apache.org/jira/browse/FLINK-12013 Project: Flink Issue Type: New Feature

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

2019-03-24 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16800353#comment-16800353 ] Jingsong Lee commented on FLINK-11974: -- Hi [~pnowojski] I think the introduction of Stream

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-03-24 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16800360#comment-16800360 ] Jingsong Lee commented on FLINK-11775: -- Hi [~pnowojski] I think it's very difficult for

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

2019-03-28 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803810#comment-16803810 ] Jingsong Lee commented on FLINK-11974: -- I think it difficult to separate ClassLoader because now

[jira] [Created] (FLINK-12041) Introduce ResettableExternalBuffer to blink batch

2019-03-27 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12041: Summary: Introduce ResettableExternalBuffer to blink batch Key: FLINK-12041 URL: https://issues.apache.org/jira/browse/FLINK-12041 Project: Flink Issue

[jira] [Updated] (FLINK-12073) Support appropriate precision and scale processing of Decimal in Blink SQL

2019-04-01 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12073: - Component/s: Table SQL / Planner > Support appropriate precision and scale processing of

[jira] [Updated] (FLINK-12077) Introduce HashJoinOperator and LongHashJoinGenerator to blink

2019-04-01 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12077: - Component/s: Table SQL / Runtime > Introduce HashJoinOperator and LongHashJoinGenerator to

[jira] [Updated] (FLINK-12077) Introduce HashJoinOperator and LongHashJoinGenerator to blink

2019-04-01 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12077: - Description: Introduce HashJoinOperator to support all join type. Introduce

[jira] [Created] (FLINK-12077) Introduce HashJoinOperator and LongHashJoinGenerator to blink

2019-04-01 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12077: Summary: Introduce HashJoinOperator and LongHashJoinGenerator to blink Key: FLINK-12077 URL: https://issues.apache.org/jira/browse/FLINK-12077 Project: Flink

[jira] [Created] (FLINK-12120) Introduce "select sum(b), count(c) from T group by a" in Blink batch

2019-04-08 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12120: Summary: Introduce "select sum(b), count(c) from T group by a" in Blink batch Key: FLINK-12120 URL: https://issues.apache.org/jira/browse/FLINK-12120 Project: Flink

[jira] [Closed] (FLINK-11800) Move table-planner-blink type to table-runtime-blink

2019-03-03 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-11800. Resolution: Invalid > Move table-planner-blink type to table-runtime-blink >

[jira] [Created] (FLINK-11802) Create TypeInfo and TypeSerializer for blink data format

2019-03-03 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11802: Summary: Create TypeInfo and TypeSerializer for blink data format Key: FLINK-11802 URL: https://issues.apache.org/jira/browse/FLINK-11802 Project: Flink

[jira] [Updated] (FLINK-11803) Improve FlinkTypeFactory for Blink

2019-03-03 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11803: - Summary: Improve FlinkTypeFactory for Blink (was: Create FlinkTypeFactory for Blink) >

[jira] [Updated] (FLINK-11803) Improve FlinkTypeFactory for Blink

2019-03-03 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11803: - Description: We need change TypeInformation to InternalType. > Improve FlinkTypeFactory for

[jira] [Commented] (FLINK-11803) Improve FlinkTypeFactory for Blink

2019-03-04 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783121#comment-16783121 ] Jingsong Lee commented on FLINK-11803: -- I think we should use InternalType in table interaction

[jira] [Created] (FLINK-11800) Move table-planner-blink type to table-runtime-blink

2019-03-03 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11800: Summary: Move table-planner-blink type to table-runtime-blink Key: FLINK-11800 URL: https://issues.apache.org/jira/browse/FLINK-11800 Project: Flink Issue

[jira] [Created] (FLINK-11803) Create FlinkTypeFactory for Blink

2019-03-03 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11803: Summary: Create FlinkTypeFactory for Blink Key: FLINK-11803 URL: https://issues.apache.org/jira/browse/FLINK-11803 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11702) Introduce a new table type system: InternalType

2019-02-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11702: Summary: Introduce a new table type system: InternalType Key: FLINK-11702 URL: https://issues.apache.org/jira/browse/FLINK-11702 Project: Flink Issue Type:

[jira] [Created] (FLINK-11701) Introduce an abstract set of data formats

2019-02-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11701: Summary: Introduce an abstract set of data formats Key: FLINK-11701 URL: https://issues.apache.org/jira/browse/FLINK-11701 Project: Flink Issue Type: New

[jira] [Created] (FLINK-11837) Improve blink internal data foramt

2019-03-06 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11837: Summary: Improve blink internal data foramt Key: FLINK-11837 URL: https://issues.apache.org/jira/browse/FLINK-11837 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-11837) Improve blink internal data format

2019-03-06 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11837: - Summary: Improve blink internal data format (was: Improve blink internal data foramt) >

[jira] [Updated] (FLINK-11837) Improve internal data format

2019-03-06 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11837: - Component/s: (was: SQL / Planner) Runtime / Operators > Improve internal

[jira] [Updated] (FLINK-11837) Improve internal data format

2019-03-06 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11837: - Summary: Improve internal data format (was: Improve blink internal data format) > Improve

[jira] [Commented] (FLINK-11837) Improve internal data format

2019-03-06 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786295#comment-16786295 ] Jingsong Lee commented on FLINK-11837: -- [~rmetzger] no, I mean, this code was changed to

[jira] [Updated] (FLINK-11837) Improve blink internal data format

2019-03-06 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11837: - Description: In FLINK-11701 , we introduce an abstract set of internal data formats to

[jira] [Created] (FLINK-11724) Improve MemorySegment

2019-02-22 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11724: Summary: Improve MemorySegment Key: FLINK-11724 URL: https://issues.apache.org/jira/browse/FLINK-11724 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11827) Introduce DataFormatConverters to convert internal data format and java format

2019-03-05 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11827: Summary: Introduce DataFormatConverters to convert internal data format and java format Key: FLINK-11827 URL: https://issues.apache.org/jira/browse/FLINK-11827

[jira] [Commented] (FLINK-11827) Introduce DataFormatConverters to convert internal data format and java format

2019-03-05 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784426#comment-16784426 ] Jingsong Lee commented on FLINK-11827: -- implemented in https://github.com/apache/flink/pull/7904 >

[jira] [Updated] (FLINK-11724) Add util method to MemorySegment

2019-02-27 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11724: - Summary: Add util method to MemorySegment (was: Improve MemorySegment) > Add util method to

[jira] [Updated] (FLINK-11724) Add util method to MemorySegment

2019-02-27 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11724: - Description: Blink new binary format is based on MemorySegment. Improve MemorySegment to

[jira] [Created] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-02-27 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11775: Summary: Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes Key: FLINK-11775 URL: https://issues.apache.org/jira/browse/FLINK-11775

[jira] [Updated] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-02-27 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11775: - Description: Blink new binary format is based on MemorySegment. Introduce

[jira] [Updated] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-02-27 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11775: - Description: Blink new binary format is based on MemorySegment. Introduce

[jira] [Created] (FLINK-11949) Introduce DeclarativeAggregateFunction and AggsHandlerCodeGenerator to blink planner

2019-03-18 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11949: Summary: Introduce DeclarativeAggregateFunction and AggsHandlerCodeGenerator to blink planner Key: FLINK-11949 URL: https://issues.apache.org/jira/browse/FLINK-11949

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-03-18 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794792#comment-16794792 ] Jingsong Lee commented on FLINK-11775: -- >> Couldn't we provide an implementation of 

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

2019-03-12 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11882: Summary: Introduce BytesHashMap to batch hash agg Key: FLINK-11882 URL: https://issues.apache.org/jira/browse/FLINK-11882 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-11490) Add an initial Blink SQL batch runtime

2019-03-11 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-11490: Assignee: Jingsong Lee > Add an initial Blink SQL batch runtime >

[jira] [Created] (FLINK-11881) Introduce code generated typed sort to blink table

2019-03-11 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11881: Summary: Introduce code generated typed sort to blink table Key: FLINK-11881 URL: https://issues.apache.org/jira/browse/FLINK-11881 Project: Flink Issue

[jira] [Created] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void

2019-03-12 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11894: Summary: AbstractRowSerializer.serializeToPages return type should be void Key: FLINK-11894 URL: https://issues.apache.org/jira/browse/FLINK-11894 Project: Flink

[jira] [Updated] (FLINK-11899) Introduce VectorizedColumnRowInputParquetFormat for blink runtime

2019-03-13 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11899: - Component/s: Runtime / Operators > Introduce VectorizedColumnRowInputParquetFormat for blink

[jira] [Created] (FLINK-11899) Introduce VectorizedColumnRowInputParquetFormat for blink runtime

2019-03-13 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11899: Summary: Introduce VectorizedColumnRowInputParquetFormat for blink runtime Key: FLINK-11899 URL: https://issues.apache.org/jira/browse/FLINK-11899 Project: Flink

[jira] [Updated] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-03-13 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11899: - Summary: Introduce vectorized parquet InputFormat for blink runtime (was: Introduce

[jira] [Updated] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-03-13 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11899: - Description: VectorizedParquetInputFormat is introduced to read parquet data in batches. When

[jira] [Updated] (FLINK-11857) Introduce BinaryExternalSorter and BufferedKVExternalSorter to batch table runtime

2019-03-09 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11857: - Summary: Introduce BinaryExternalSorter and BufferedKVExternalSorter to batch table runtime

[jira] [Updated] (FLINK-11857) Introduce BinaryExternalSorter to batch table runtime

2019-03-09 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11857: - Description: We need a sorter to take full advantage of the high performance of the Binary

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

2019-03-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11974: Summary: Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen Key: FLINK-11974 URL: https://issues.apache.org/jira/browse/FLINK-11974

[jira] [Created] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator

2019-03-19 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11968: Summary: Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator Key: FLINK-11968 URL: https://issues.apache.org/jira/browse/FLINK-11968

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

2019-03-20 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796886#comment-16796886 ] Jingsong Lee commented on FLINK-11974: -- [~pnowojski] what do you think about this? > Introduce

[jira] [Created] (FLINK-11981) Introduce ProjectionCodeGenerator and HashCodeGenerator for BaseRow

2019-03-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11981: Summary: Introduce ProjectionCodeGenerator and HashCodeGenerator for BaseRow Key: FLINK-11981 URL: https://issues.apache.org/jira/browse/FLINK-11981 Project: Flink

[jira] [Created] (FLINK-11983) Refactor resolved aggregation reference expressions in blink

2019-03-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11983: Summary: Refactor resolved aggregation reference expressions in blink Key: FLINK-11983 URL: https://issues.apache.org/jira/browse/FLINK-11983 Project: Flink

[jira] [Updated] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable

2019-03-19 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11964: - Description: In HybridHashTable, first select the corresponding partition according to

[jira] [Created] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable

2019-03-19 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11964: Summary: Avoid hash collision of partition and bucket in HybridHashTable Key: FLINK-11964 URL: https://issues.apache.org/jira/browse/FLINK-11964 Project: Flink

[jira] [Updated] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable in Blink SQL

2019-03-19 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11964: - Summary: Avoid hash collision of partition and bucket in HybridHashTable in Blink SQL (was:

[jira] [Commented] (FLINK-11951) Enhance UserDefinedFunction interface to allow more user defined types

2019-03-18 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794874#comment-16794874 ] Jingsong Lee commented on FLINK-11951: -- cc [~twalthr]  > Enhance UserDefinedFunction interface to

[jira] [Created] (FLINK-11951) Enhance UserDefinedFunction interface to allow more user defined types

2019-03-18 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11951: Summary: Enhance UserDefinedFunction interface to allow more user defined types Key: FLINK-11951 URL: https://issues.apache.org/jira/browse/FLINK-11951 Project:

[jira] [Updated] (FLINK-11951) Enhance UserDefinedFunction interface to allow more user defined types

2019-03-18 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11951: - Description: 1.Allow UDF & UDTF to access constant parameter values at getReturnType, see

[jira] [Commented] (FLINK-11961) Clear up and refactor the code generation of scalar functions and operators

2019-03-19 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795840#comment-16795840 ] Jingsong Lee commented on FLINK-11961: -- Why we need combine {{PlannerExpression}} and 

[jira] [Updated] (FLINK-11881) Introduce code generated typed sort to blink table

2019-03-12 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11881: - Description: Introduce SortCodeGenerator (CodeGen efficient computation and comparison of 

[jira] [Created] (FLINK-11857) Introduce BinaryExternalSorter to batch table runtime

2019-03-07 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11857: Summary: Introduce BinaryExternalSorter to batch table runtime Key: FLINK-11857 URL: https://issues.apache.org/jira/browse/FLINK-11857 Project: Flink Issue

[jira] [Assigned] (FLINK-11490) Add an initial Blink SQL batch runtime

2019-02-20 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-11490: Assignee: Jingsong Lee (was: Danny Chan) > Add an initial Blink SQL batch runtime >

[jira] [Updated] (FLINK-12140) Support e2e sort merge join operator in batch mode

2019-04-10 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12140: - Summary: Support e2e sort merge join operator in batch mode (was: Support sort merge join it

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

2019-04-11 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815208#comment-16815208 ] Jingsong Lee commented on FLINK-11974: -- Hi [~pnowojski] If we want to code generate a 

[jira] [Updated] (FLINK-12120) Support e2e SortAggregate and HashAggregate operator run in batch mode

2019-04-11 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12120: - Summary: Support e2e SortAggregate and HashAggregate operator run in batch mode (was: Support

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

2019-04-11 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815329#comment-16815329 ] Jingsong Lee edited comment on FLINK-11974 at 4/11/19 11:22 AM:

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-04-11 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815190#comment-16815190 ] Jingsong Lee commented on FLINK-11775: -- I think my goal is to optimize the serialization of

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

2019-04-11 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815329#comment-16815329 ] Jingsong Lee commented on FLINK-11974: -- [~ykt836] StreamOperator needs to be wrapped in

[jira] [Created] (FLINK-12129) CompressedViews need release heap buffers to reduce memory usage in blink

2019-04-08 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12129: Summary: CompressedViews need release heap buffers to reduce memory usage in blink Key: FLINK-12129 URL: https://issues.apache.org/jira/browse/FLINK-12129 Project:

[jira] [Created] (FLINK-12140) Support queries like "select a, b, c, e from T1, T2 where T1.a = T2.d" run in batch mode

2019-04-09 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12140: Summary: Support queries like "select a, b, c, e from T1, T2 where T1.a = T2.d" run in batch mode Key: FLINK-12140 URL: https://issues.apache.org/jira/browse/FLINK-12140

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

2019-04-09 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12140: - Summary: Support sort merge join it case run in batch mode (was: Support queries like "select

[jira] [Updated] (FLINK-12140) Support queries like "select a, b, c, e from T1, T2 where T1.a = T2.d" run in batch mode

2019-04-09 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12140: - Description: Complete BatchExecSortMergeJoin and support join it cases. Support queries like

[jira] [Created] (FLINK-12168) Support e2e limit, sortLimit, rank, union in blink batch

2019-04-12 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12168: Summary: Support e2e limit, sortLimit, rank, union in blink batch Key: FLINK-12168 URL: https://issues.apache.org/jira/browse/FLINK-12168 Project: Flink

[jira] [Updated] (FLINK-12168) Support e2e limit, sortLimit, rank, union in blink batch

2019-04-12 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12168: - Component/s: Table SQL / Planner > Support e2e limit, sortLimit, rank, union in blink batch >

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

2019-04-15 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16817646#comment-16817646 ] Jingsong Lee commented on FLINK-11974: -- Hi [~pnowojski] and [~ykt836] : Benchmark for simple

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

2019-04-15 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818517#comment-16818517 ] Jingsong Lee commented on FLINK-11974: -- 1.As

[jira] [Created] (FLINK-12248) Support e2e over window in blink batch

2019-04-18 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12248: Summary: Support e2e over window in blink batch Key: FLINK-12248 URL: https://issues.apache.org/jira/browse/FLINK-12248 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-1722) Streaming not respecting FinalizeOnMaster for output formats

2019-05-25 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848158#comment-16848158 ] Jingsong Lee commented on FLINK-1722: - Now, blink planner build batch sql on the StreamGraph, So we

[jira] [Created] (FLINK-12834) Support CharType and BinaryType in blink runner

2019-06-13 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12834: Summary: Support CharType and BinaryType in blink runner Key: FLINK-12834 URL: https://issues.apache.org/jira/browse/FLINK-12834 Project: Flink Issue Type:

[jira] [Created] (FLINK-12796) Introduce BaseArray and BaseMap to reduce conversion overhead to blink

2019-06-10 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12796: Summary: Introduce BaseArray and BaseMap to reduce conversion overhead to blink Key: FLINK-12796 URL: https://issues.apache.org/jira/browse/FLINK-12796 Project:

[jira] [Created] (FLINK-12802) Optimizing DataFormat Code to Blink

2019-06-11 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12802: Summary: Optimizing DataFormat Code to Blink Key: FLINK-12802 URL: https://issues.apache.org/jira/browse/FLINK-12802 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-11775) Introduce MemorySegmentWritable to let Segments direct copy to internal bytes

2019-06-18 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11775: - Summary: Introduce MemorySegmentWritable to let Segments direct copy to internal bytes (was:

[jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes

2019-06-18 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866296#comment-16866296 ] Jingsong Lee commented on FLINK-11775: -- It is still valid, we need implement what we discussed. >

[jira] [Commented] (FLINK-12886) Support container memory segment

2019-06-19 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867311#comment-16867311 ] Jingsong Lee commented on FLINK-12886: -- Hi [~fan_li_ya], Thanks for your proposal. I think we

[jira] [Updated] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

2019-06-25 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12972: - Issue Type: Bug (was: New Feature) > Ensure calling open/close in join condition of generated

[jira] [Created] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

2019-06-25 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12972: Summary: Ensure calling open/close in join condition of generated functions for blink Key: FLINK-12972 URL: https://issues.apache.org/jira/browse/FLINK-12972

[jira] [Created] (FLINK-12975) UserDefinedFunctionUtils should distinguish overload any parameters methods in blink

2019-06-25 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12975: Summary: UserDefinedFunctionUtils should distinguish overload any parameters methods in blink Key: FLINK-12975 URL: https://issues.apache.org/jira/browse/FLINK-12975

[jira] [Updated] (FLINK-12810) Support to run a TableAPI query like 'table.select('a, 'b, 'c)'

2019-06-12 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12810: - Component/s: Table SQL / Planner > Support to run a TableAPI query like 'table.select('a, 'b,

[jira] [Updated] (FLINK-12810) Support to run a TableAPI query like 'table.select('a, 'b, 'c)' in Blink runner

2019-06-12 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12810: - Summary: Support to run a TableAPI query like 'table.select('a, 'b, 'c)' in Blink runner (was:

[jira] [Assigned] (FLINK-12810) Support to run a TableAPI query like 'table.select('a, 'b, 'c)' in Blink runner

2019-06-12 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-12810: Assignee: Jing Zhang > Support to run a TableAPI query like 'table.select('a, 'b, 'c)'

[jira] [Created] (FLINK-12844) Use default conversion class LocalDate/LocalTime/LocalDateTime for DateType/TimeType/TimestampType in blink

2019-06-14 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12844: Summary: Use default conversion class LocalDate/LocalTime/LocalDateTime for DateType/TimeType/TimestampType in blink Key: FLINK-12844 URL:

[jira] [Created] (FLINK-12850) Introduce LocalDate/LocalTime/LocalDateTime TypeInfo

2019-06-14 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12850: Summary: Introduce LocalDate/LocalTime/LocalDateTime TypeInfo Key: FLINK-12850 URL: https://issues.apache.org/jira/browse/FLINK-12850 Project: Flink Issue

[jira] [Commented] (FLINK-12850) Introduce LocalDate/LocalTime/LocalDateTime TypeInfo

2019-06-14 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863842#comment-16863842 ] Jingsong Lee commented on FLINK-12850: -- CC: [~twalthr] > Introduce

[jira] [Comment Edited] (FLINK-12886) Support container memory segment

2019-06-19 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868265#comment-16868265 ] Jingsong Lee edited comment on FLINK-12886 at 6/20/19 5:16 AM: --- Back to

  1   2   3   4   5   6   7   8   9   10   >