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

[ https://issues.apache.org/jira/browse/FLINK-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868265#comment-16868265 ] Jingsong Lee commented on FLINK-12886: --   Back to the original intention of Jira and consider

[jira] [Commented] (FLINK-12936) Support intersect all and minus all to blink planner

[ https://issues.apache.org/jira/browse/FLINK-12936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16870046#comment-16870046 ] Jingsong Lee commented on FLINK-12936: -- CC: [~ykt836] [~godfreyhe] > Support intersect all and

[jira] [Created] (FLINK-12936) Support intersect all and minus all to blink planner

Jingsong Lee created FLINK-12936: Summary: Support intersect all and minus all to blink planner Key: FLINK-12936 URL: https://issues.apache.org/jira/browse/FLINK-12936 Project: Flink Issue

[jira] [Updated] (FLINK-12959) Use BoundedInput and InputSelectable in blink

[ https://issues.apache.org/jira/browse/FLINK-12959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12959: - Component/s: Table SQL / Planner > Use BoundedInput and InputSelectable in blink >

[jira] [Created] (FLINK-12956) Add a upsert table sink for JDBC

Jingsong Lee created FLINK-12956: Summary: Add a upsert table sink for JDBC Key: FLINK-12956 URL: https://issues.apache.org/jira/browse/FLINK-12956 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-12959) Use BoundedInput and InputSelectable in blink

Jingsong Lee created FLINK-12959: Summary: Use BoundedInput and InputSelectable in blink Key: FLINK-12959 URL: https://issues.apache.org/jira/browse/FLINK-12959 Project: Flink Issue Type:

[jira] [Commented] (FLINK-12823) PartitionTransformation supports DataExchangeMode property

[ https://issues.apache.org/jira/browse/FLINK-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16862690#comment-16862690 ] Jingsong Lee commented on FLINK-12823: -- (y)(y)(y) The basic requirement is that batch jobs need to

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

[ https://issues.apache.org/jira/browse/FLINK-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12850: - Description: Now in the new type system of table, the default class of time type is LocalDate

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

[ https://issues.apache.org/jira/browse/FLINK-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12850: - Summary: Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime (was: Introduce

[jira] [Created] (FLINK-12611) Make time indicator nullable in blink

Jingsong Lee created FLINK-12611: Summary: Make time indicator nullable in blink Key: FLINK-12611 URL: https://issues.apache.org/jira/browse/FLINK-12611 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12453) StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator

[ https://issues.apache.org/jira/browse/FLINK-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12453: - Description: In generateAggsHandler:  val generator = new AggsHandlerCodeGenerator(  

[jira] [Created] (FLINK-12453) StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator

Jingsong Lee created FLINK-12453: Summary: StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator Key: FLINK-12453 URL: https://issues.apache.org/jira/browse/FLINK-12453

[jira] [Created] (FLINK-12456) Wrong CharType convertion in type_utils.py

Jingsong Lee created FLINK-12456: Summary: Wrong CharType convertion in type_utils.py Key: FLINK-12456 URL: https://issues.apache.org/jira/browse/FLINK-12456 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12457) Remove char support in blink

Jingsong Lee created FLINK-12457: Summary: Remove char support in blink Key: FLINK-12457 URL: https://issues.apache.org/jira/browse/FLINK-12457 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-12563) Introduce vector data format in blink

[ https://issues.apache.org/jira/browse/FLINK-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12563: - Description: Introduce vector data format to high performance parquet/orc source. Introduce 

[jira] [Created] (FLINK-12563) Introduce vector data format in blink

Jingsong Lee created FLINK-12563: Summary: Introduce vector data format in blink Key: FLINK-12563 URL: https://issues.apache.org/jira/browse/FLINK-12563 Project: Flink Issue Type:

[jira] [Created] (FLINK-12443) Replace InternalType with LogicalType in blink runner

Jingsong Lee created FLINK-12443: Summary: Replace InternalType with LogicalType in blink runner Key: FLINK-12443 URL: https://issues.apache.org/jira/browse/FLINK-12443 Project: Flink Issue

[jira] [Created] (FLINK-12261) Support e2e group window in blink batch

Jingsong Lee created FLINK-12261: Summary: Support e2e group window in blink batch Key: FLINK-12261 URL: https://issues.apache.org/jira/browse/FLINK-12261 Project: Flink Issue Type: New

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

[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833578#comment-16833578 ] Jingsong Lee commented on FLINK-11421: -- Hi [~fan_li_ya] , CodeGenerator of blink almost merge done. 

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

[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833673#comment-16833673 ] Jingsong Lee commented on FLINK-11421: -- [~fan_li_ya] I think you can restart it for blink planner.

[jira] [Updated] (FLINK-13113) Introduce range partition in blink

[ https://issues.apache.org/jira/browse/FLINK-13113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13113: - Component/s: Table SQL / Runtime > Introduce range partition in blink >

[jira] [Updated] (FLINK-13112) Support LocalZonedTimestampType in blink

[ https://issues.apache.org/jira/browse/FLINK-13112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13112: - Component/s: Table SQL / Planner > Support LocalZonedTimestampType in blink >

[jira] [Created] (FLINK-13113) Introduce range partition in blink

Jingsong Lee created FLINK-13113: Summary: Introduce range partition in blink Key: FLINK-13113 URL: https://issues.apache.org/jira/browse/FLINK-13113 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-13112) Support LocalZonedTimestampType in blink

Jingsong Lee created FLINK-13112: Summary: Support LocalZonedTimestampType in blink Key: FLINK-13112 URL: https://issues.apache.org/jira/browse/FLINK-13112 Project: Flink Issue Type: New

[jira] [Created] (FLINK-13118) Introduce JDBC table factory

Jingsong Lee created FLINK-13118: Summary: Introduce JDBC table factory Key: FLINK-13118 URL: https://issues.apache.org/jira/browse/FLINK-13118 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-13026) Introduce JDBCLookupFunction

Jingsong Lee created FLINK-13026: Summary: Introduce JDBCLookupFunction Key: FLINK-13026 URL: https://issues.apache.org/jira/browse/FLINK-13026 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-13201) Unstable sql time udf test

[ https://issues.apache.org/jira/browse/FLINK-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882697#comment-16882697 ] Jingsong Lee commented on FLINK-13201: -- Looks like there is not output row... The sql of this case

[jira] [Created] (FLINK-13210) Hive connector test should dependent on blink planner instead of legacy planner

Jingsong Lee created FLINK-13210: Summary: Hive connector test should dependent on blink planner instead of legacy planner Key: FLINK-13210 URL: https://issues.apache.org/jira/browse/FLINK-13210

[jira] [Updated] (FLINK-13210) Hive connector test should dependent on blink planner instead of legacy planner

[ https://issues.apache.org/jira/browse/FLINK-13210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13210: - Description: Blink planner has more support and more functions, and some ITCase will not be

[jira] [Created] (FLINK-13229) ExpressionReducer with udf bug in blink

Jingsong Lee created FLINK-13229: Summary: ExpressionReducer with udf bug in blink Key: FLINK-13229 URL: https://issues.apache.org/jira/browse/FLINK-13229 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13225) Introduce type inference for hive functions in blink

Jingsong Lee created FLINK-13225: Summary: Introduce type inference for hive functions in blink Key: FLINK-13225 URL: https://issues.apache.org/jira/browse/FLINK-13225 Project: Flink Issue

[jira] [Commented] (FLINK-13234) TemporalTypesTest randomly failed on travis

[ https://issues.apache.org/jira/browse/FLINK-13234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883469#comment-16883469 ] Jingsong Lee commented on FLINK-13234: -- Sorry for this, [https://github.com/apache/flink/pull/9095] 

[jira] [Created] (FLINK-13237) Add expression table api test to blink

Jingsong Lee created FLINK-13237: Summary: Add expression table api test to blink Key: FLINK-13237 URL: https://issues.apache.org/jira/browse/FLINK-13237 Project: Flink Issue Type: New

[jira] [Created] (FLINK-13070) Remove TableImpl and use api.internal.TableImpl in blink

Jingsong Lee created FLINK-13070: Summary: Remove TableImpl and use api.internal.TableImpl in blink Key: FLINK-13070 URL: https://issues.apache.org/jira/browse/FLINK-13070 Project: Flink

[jira] [Created] (FLINK-13253) Deadlock may occur in JDBCUpsertOutputFormat

Jingsong Lee created FLINK-13253: Summary: Deadlock may occur in JDBCUpsertOutputFormat Key: FLINK-13253 URL: https://issues.apache.org/jira/browse/FLINK-13253 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-13257) blink runner should avoid stream operator implementing BoundedOneInput

[ https://issues.apache.org/jira/browse/FLINK-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13257: - Priority: Critical (was: Major) > blink runner should avoid stream operator implementing

[jira] [Updated] (FLINK-13257) blink runner should avoid stream operator implementing BoundedOneInput

[ https://issues.apache.org/jira/browse/FLINK-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13257: - Fix Version/s: 1.10.0 1.9.0 > blink runner should avoid stream operator

[jira] [Created] (FLINK-13257) blink runner should avoid stream operator implementing BoundedOneInput

Jingsong Lee created FLINK-13257: Summary: blink runner should avoid stream operator implementing BoundedOneInput Key: FLINK-13257 URL: https://issues.apache.org/jira/browse/FLINK-13257 Project:

[jira] [Assigned] (FLINK-12270) SortDistinctAggregateITCase fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-12270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-12270: Assignee: Jingsong Lee > SortDistinctAggregateITCase fails on Travis >

[jira] [Comment Edited] (FLINK-12270) SortDistinctAggregateITCase fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-12270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822924#comment-16822924 ] Jingsong Lee edited comment on FLINK-12270 at 4/22/19 7:50 AM: --- I set 

[jira] [Commented] (FLINK-12270) SortDistinctAggregateITCase fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-12270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822924#comment-16822924 ] Jingsong Lee commented on FLINK-12270: -- I set SQL_RESOURCE_HASH_AGG_TABLE_MEM to 2M and change size

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

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16823866#comment-16823866 ] Jingsong Lee commented on FLINK-11974: -- [~pnowojski] Nice and perfect idea, I prefer _just wrap all

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

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11974: - Description: If we need CodeGen an entire Operator, one possible solution is to introduce an

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

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11974: - Description: If we need CodeGen an entire Operator, one possible solution is to introduce an

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

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11974: - Description: If we need CodeGen an entire Operator, one possible solution is to introduce an

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

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11974: - Summary: Introduce StreamOperatorFactory to help table perform the whole Operator CodeGen

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

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16823906#comment-16823906 ] Jingsong Lee commented on FLINK-11974: -- [~pnowojski] I quickly implemented a version for _wrap all

[jira] [Created] (FLINK-12211) Add more it cases to blink batch

Jingsong Lee created FLINK-12211: Summary: Add more it cases to blink batch Key: FLINK-12211 URL: https://issues.apache.org/jira/browse/FLINK-12211 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-13285) Connectors need to get rid of flink-table-planner dependence

Jingsong Lee created FLINK-13285: Summary: Connectors need to get rid of flink-table-planner dependence Key: FLINK-13285 URL: https://issues.apache.org/jira/browse/FLINK-13285 Project: Flink

[jira] [Created] (FLINK-13286) Port SchemaValidator and others validators to table-common

Jingsong Lee created FLINK-13286: Summary: Port SchemaValidator and others validators to table-common Key: FLINK-13286 URL: https://issues.apache.org/jira/browse/FLINK-13286 Project: Flink

[jira] [Created] (FLINK-13287) Port ExistingField to api-java and use new Expression in FieldComputer

Jingsong Lee created FLINK-13287: Summary: Port ExistingField to api-java and use new Expression in FieldComputer Key: FLINK-13287 URL: https://issues.apache.org/jira/browse/FLINK-13287 Project:

[jira] [Assigned] (FLINK-13286) Port SchemaValidator and others validators to table-common

[ https://issues.apache.org/jira/browse/FLINK-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13286: Assignee: Jingsong Lee > Port SchemaValidator and others validators to table-common >

[jira] [Updated] (FLINK-13285) Connectors need to get rid of flink-table-planner dependence and check connector ITCase runnable in blink runner

[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13285: - Summary: Connectors need to get rid of flink-table-planner dependence and check connector

[jira] [Updated] (FLINK-13286) Port SchemaValidator and others validators to table-common

[ https://issues.apache.org/jira/browse/FLINK-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13286: - Issue Type: Sub-task (was: Bug) Parent: FLINK-13285 > Port SchemaValidator and others

[jira] [Updated] (FLINK-13286) Port SchemaValidator and others validators to table-common

[ https://issues.apache.org/jira/browse/FLINK-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13286: - Component/s: Table SQL / Planner > Port SchemaValidator and others validators to table-common >

[jira] [Updated] (FLINK-13285) Connectors need to get rid of flink-table-planner dependence and check connector ITCase runnable in blink runner

[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13285: - Fix Version/s: 1.10.0 1.9.0 > Connectors need to get rid of

[jira] [Updated] (FLINK-13285) Connectors need to get rid of flink-table-planner dependence and check connector ITCase runnable in blink runner

[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13285: - Component/s: Connectors / Common > Connectors need to get rid of flink-table-planner dependence

[jira] [Updated] (FLINK-13286) Port SchemaValidator and others validators to table-common

[ https://issues.apache.org/jira/browse/FLINK-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13286: - Fix Version/s: 1.10.0 1.9.0 > Port SchemaValidator and others validators to

[jira] [Created] (FLINK-13049) Port planner expressions to blink-planner from flink-planner

Jingsong Lee created FLINK-13049: Summary: Port planner expressions to blink-planner from flink-planner Key: FLINK-13049 URL: https://issues.apache.org/jira/browse/FLINK-13049 Project: Flink

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907007#comment-16907007 ] Jingsong Lee commented on FLINK-13702: -- Hi [~jark], TypeSerializer can be not thread safe. CC:

[jira] [Commented] (FLINK-13490) Fix return null in JDBCUtils::getFieldFromResultSet

[ https://issues.apache.org/jira/browse/FLINK-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895833#comment-16895833 ] Jingsong Lee commented on FLINK-13490: -- Thanks [~TsReaper], maybe the bug is explained in comment

[jira] [Comment Edited] (FLINK-13540) DDL do not support key of properties contains number or "-"

[ https://issues.apache.org/jira/browse/FLINK-13540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16899018#comment-16899018 ] Jingsong Lee edited comment on FLINK-13540 at 8/2/19 4:17 PM: -- Sorry

[jira] [Commented] (FLINK-13540) DDL do not support key of properties contains number or "-"

[ https://issues.apache.org/jira/browse/FLINK-13540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16899018#comment-16899018 ] Jingsong Lee commented on FLINK-13540: -- Sorry [~danny831], It should be [~danny0405] ... > DDL do

[jira] [Created] (FLINK-13561) Verify and correct builtin time function's semantic for Blink planner

Jingsong Lee created FLINK-13561: Summary: Verify and correct builtin time function's semantic for Blink planner Key: FLINK-13561 URL: https://issues.apache.org/jira/browse/FLINK-13561 Project: Flink

[jira] [Updated] (FLINK-13561) Verify and correct time function's semantic for Blink planner

[ https://issues.apache.org/jira/browse/FLINK-13561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13561: - Summary: Verify and correct time function's semantic for Blink planner (was: Verify and

[jira] [Commented] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904962#comment-16904962 ] Jingsong Lee commented on FLINK-13688: -- I think we should limit the parallelism of this it case to

[jira] [Comment Edited] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904962#comment-16904962 ] Jingsong Lee edited comment on FLINK-13688 at 8/12/19 8:25 AM: --- I think we

[jira] [Commented] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904970#comment-16904970 ] Jingsong Lee commented on FLINK-13688: -- Yeah, it will use processor size when not config the

[jira] [Commented] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908195#comment-16908195 ] Jingsong Lee commented on FLINK-13739: -- The reason should be that the default encoding of the

[jira] [Created] (FLINK-13780) Introduce ExpressionConverter to legacy planner

Jingsong Lee created FLINK-13780: Summary: Introduce ExpressionConverter to legacy planner Key: FLINK-13780 URL: https://issues.apache.org/jira/browse/FLINK-13780 Project: Flink Issue Type:

[jira] [Created] (FLINK-13781) Use new Expression in RexNodeToExpressionConverter

Jingsong Lee created FLINK-13781: Summary: Use new Expression in RexNodeToExpressionConverter Key: FLINK-13781 URL: https://issues.apache.org/jira/browse/FLINK-13781 Project: Flink Issue

[jira] [Created] (FLINK-13785) Implement type inference for time functions

Jingsong Lee created FLINK-13785: Summary: Implement type inference for time functions Key: FLINK-13785 URL: https://issues.apache.org/jira/browse/FLINK-13785 Project: Flink Issue Type:

[jira] [Created] (FLINK-13786) Implement type inference for other functions

Jingsong Lee created FLINK-13786: Summary: Implement type inference for other functions Key: FLINK-13786 URL: https://issues.apache.org/jira/browse/FLINK-13786 Project: Flink Issue Type:

[jira] [Created] (FLINK-13783) Implement type inference for string functions

Jingsong Lee created FLINK-13783: Summary: Implement type inference for string functions Key: FLINK-13783 URL: https://issues.apache.org/jira/browse/FLINK-13783 Project: Flink Issue Type:

[jira] [Created] (FLINK-13784) Implement type inference for math functions

Jingsong Lee created FLINK-13784: Summary: Implement type inference for math functions Key: FLINK-13784 URL: https://issues.apache.org/jira/browse/FLINK-13784 Project: Flink Issue Type:

[jira] [Created] (FLINK-13782) Implement type inference for logic functions

Jingsong Lee created FLINK-13782: Summary: Implement type inference for logic functions Key: FLINK-13782 URL: https://issues.apache.org/jira/browse/FLINK-13782 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13547) Verify and correct string function's semantic for Blink planner

[ https://issues.apache.org/jira/browse/FLINK-13547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906202#comment-16906202 ] Jingsong Lee commented on FLINK-13547: -- [~till.rohrmann] I'll fix FLINK-13704 , substr is a common

[jira] [Commented] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908867#comment-16908867 ] Jingsong Lee commented on FLINK-13738: -- Ah... Thanks [~rmetzger] for find this bug. The range is

[jira] [Comment Edited] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908867#comment-16908867 ] Jingsong Lee edited comment on FLINK-13738 at 8/16/19 9:13 AM: --- Ah...

[jira] [Updated] (FLINK-13775) Refactor ExpressionConverter(RexNodeConverter) in blink

[ https://issues.apache.org/jira/browse/FLINK-13775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13775: - Description: For subsequent development, refactor ExpressionConverter in the form of Rules.

[jira] [Updated] (FLINK-13776) Introduce new interfaces to BuiltInFunctionDefinition

[ https://issues.apache.org/jira/browse/FLINK-13776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13776: - Description: Introduce new interfaces to BuiltInFunctionDefinition from 

[jira] [Updated] (FLINK-13777) Introduce sql function wrappers and conversion to ExpressionConverter

[ https://issues.apache.org/jira/browse/FLINK-13777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13777: - Description: For remove the extended calcite sql functions, we introduce wrappers to wrap

[jira] [Commented] (FLINK-13869) Hive built-in function can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916495#comment-16916495 ] Jingsong Lee commented on FLINK-13869: -- [~Terry1897] Thanks for reporting this issue, Can you share

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921313#comment-16921313 ] Jingsong Lee commented on FLINK-13943: -- A small question is how to implement it. In streaming mode,

[jira] [Commented] (FLINK-13900) Add a built-in "console" sink to print results in console

[ https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921309#comment-16921309 ] Jingsong Lee commented on FLINK-13900: -- +1 to Table.print(). But this will execute immediately? It

[jira] [Created] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink

Jingsong Lee created FLINK-13952: Summary: PartitionableTableSink can not work with OverwritableTableSink Key: FLINK-13952 URL: https://issues.apache.org/jira/browse/FLINK-13952 Project: Flink

[jira] [Created] (FLINK-13902) Can not use index to convert FieldReferenceExpression to RexNode

Jingsong Lee created FLINK-13902: Summary: Can not use index to convert FieldReferenceExpression to RexNode Key: FLINK-13902 URL: https://issues.apache.org/jira/browse/FLINK-13902 Project: Flink

[jira] [Commented] (FLINK-13582) Improve the implementation of LISTAGG in Blink planner to remove delimiter from state

[ https://issues.apache.org/jira/browse/FLINK-13582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919123#comment-16919123 ] Jingsong Lee commented on FLINK-13582: -- Is modifying the State format affecting compatibility? So I

[jira] [Updated] (FLINK-13902) Can not use index to convert FieldReferenceExpression to RexNode

[ https://issues.apache.org/jira/browse/FLINK-13902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13902: - Parent: FLINK-13773 Issue Type: Sub-task (was: Bug) > Can not use index to convert

[jira] [Commented] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922341#comment-16922341 ] Jingsong Lee commented on FLINK-13952: -- Feel free to fix it. I can review your PR. >

[jira] [Commented] (FLINK-14053) blink planner dense_rank corner case bug

[ https://issues.apache.org/jira/browse/FLINK-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928289#comment-16928289 ] Jingsong Lee commented on FLINK-14053: -- [~jackylau] Thanks for reporting this bug. Yes, 

[jira] [Commented] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type

[ https://issues.apache.org/jira/browse/FLINK-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927354#comment-16927354 ] Jingsong Lee commented on FLINK-14036: -- First, in the table api, canSafelyCast is invoked 

[jira] [Commented] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type

[ https://issues.apache.org/jira/browse/FLINK-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927382#comment-16927382 ] Jingsong Lee commented on FLINK-14036: -- This exception is for checking input types, same as 

[jira] [Updated] (FLINK-14030) Nonequivalent conversion happens in Table planner

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14030: - Fix Version/s: 1.9.1 > Nonequivalent conversion happens in Table planner >

[jira] [Updated] (FLINK-14030) Nonequivalent conversion happens in Table planner

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14030: - Priority: Critical (was: Major) > Nonequivalent conversion happens in Table planner >

[jira] [Commented] (FLINK-14030) Nonequivalent conversion happens in Table planner

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927410#comment-16927410 ] Jingsong Lee commented on FLINK-14030: -- I think there is a Rule to make this conversion. This rule

[jira] [Updated] (FLINK-14030) Nonequivalent conversion happens in Table planner

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14030: - Fix Version/s: (was: 1.10.0) > Nonequivalent conversion happens in Table planner >

[jira] [Commented] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type

[ https://issues.apache.org/jira/browse/FLINK-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16926269#comment-16926269 ] Jingsong Lee commented on FLINK-14036: -- Thanks [~Leonard Xu] for report this. Now 

[jira] [Commented] (FLINK-14078) Introduce more JDBCDialect implementations

[ https://issues.apache.org/jira/browse/FLINK-14078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931955#comment-16931955 ] Jingsong Lee commented on FLINK-14078: -- > Just want to clarify, does this only take effect to JDBC

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931954#comment-16931954 ] Jingsong Lee commented on FLINK-14099: -- The problem I've encountered is that I want to mark a

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