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

[ https://issues.apache.org/jira/browse/FLINK-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13785: Assignee: (was: Jingsong Lee) > Implement type inference for time functions >

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

[ https://issues.apache.org/jira/browse/FLINK-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13782: Assignee: (was: Jingsong Lee) > Implement type inference for logic functions >

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

[ https://issues.apache.org/jira/browse/FLINK-13783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13783: Assignee: (was: Jingsong Lee) > Implement type inference for string functions >

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

[ https://issues.apache.org/jira/browse/FLINK-13784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13784: Assignee: (was: Jingsong Lee) > Implement type inference for math functions >

[jira] [Assigned] (FLINK-14676) Introduce parallelism inference for source

[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14676: Assignee: (was: Jingsong Lee) > Introduce parallelism inference for source >

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

[ https://issues.apache.org/jira/browse/FLINK-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13786: Assignee: (was: Jingsong Lee) > Implement type inference for other functions >

[jira] [Assigned] (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 reassigned FLINK-13777: Assignee: (was: Jingsong Lee) > Introduce sql function wrappers and conversion to

[jira] [Assigned] (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 reassigned FLINK-13113: Assignee: (was: Jingsong Lee) > Introduce range partition in blink >

[jira] [Assigned] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16027: Assignee: (was: Jingsong Lee) > kafka connector's 'connector.topic' property should

[jira] [Assigned] (FLINK-16024) support filter pushdown in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16024: Assignee: (was: Jingsong Lee) > support filter pushdown in jdbc connector >

[jira] [Assigned] (FLINK-15960) support creating Hive tables, views, functions within Flink

[ https://issues.apache.org/jira/browse/FLINK-15960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15960: Assignee: Rui Li (was: Jingsong Lee) > support creating Hive tables, views, functions

[jira] [Assigned] (FLINK-15255) document how to create Hive table from java API and DDL

[ https://issues.apache.org/jira/browse/FLINK-15255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15255: Assignee: Rui Li (was: Jingsong Lee) > document how to create Hive table from java API

[jira] [Assigned] (FLINK-15809) component stack page needs to be updated for blink planner

[ https://issues.apache.org/jira/browse/FLINK-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15809: Assignee: (was: Jingsong Lee) > component stack page needs to be updated for blink

[jira] [Commented] (FLINK-15407) Add document to explain how to write a table with PK

[ https://issues.apache.org/jira/browse/FLINK-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043152#comment-17043152 ] Jingsong Lee commented on FLINK-15407: -- We should have better design with changelog support to

[jira] [Closed] (FLINK-15407) Add document to explain how to write a table with PK

[ https://issues.apache.org/jira/browse/FLINK-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15407. Resolution: Won't Fix > Add document to explain how to write a table with PK >

[jira] [Assigned] (FLINK-14258) Integrate hive to FileSystemTableFactory

[ https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14258: Assignee: (was: Jingsong Lee) > Integrate hive to FileSystemTableFactory >

[jira] [Assigned] (FLINK-14256) Introduce FileSystemTableFactory with partitioned support

[ https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14256: Assignee: (was: Jingsong Lee) > Introduce FileSystemTableFactory with partitioned

[jira] [Assigned] (FLINK-14257) Integrate csv to FileSystemTableFactory

[ https://issues.apache.org/jira/browse/FLINK-14257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14257: Assignee: (was: Jingsong Lee) > Integrate csv to FileSystemTableFactory >

[jira] [Assigned] (FLINK-15397) Streaming and batch has different value in the case of count function

[ https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15397: Assignee: (was: Jingsong Lee) > Streaming and batch has different value in the case

[jira] [Assigned] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15289: Assignee: (was: Jingsong Lee) > Run sql appear error of "Zero-length character

[jira] [Assigned] (FLINK-16161) Statistics zero should be unknown in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-16161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16161: Assignee: Jingsong Lee > Statistics zero should be unknown in HiveCatalog >

[jira] [Resolved] (FLINK-16161) Statistics zero should be unknown in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-16161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16161. -- Resolution: Fixed > Statistics zero should be unknown in HiveCatalog >

[jira] [Commented] (FLINK-16161) Statistics zero should be unknown in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-16161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043433#comment-17043433 ] Jingsong Lee commented on FLINK-16161: -- master: fe9f448a446a9f5747ece9fa8b0f1b4928c17248

[jira] [Assigned] (FLINK-16179) Use configuration from TableFactory in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16179: Assignee: Jingsong Lee > Use configuration from TableFactory in hive connector >

[jira] [Commented] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044405#comment-17044405 ] Jingsong Lee commented on FLINK-16265: -- Thanks [~twalthr] and [~jark] for your involving. You have

[jira] [Resolved] (FLINK-16179) Use configuration from TableFactory in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16179. -- Resolution: Fixed > Use configuration from TableFactory in hive connector >

[jira] [Commented] (FLINK-16179) Use configuration from TableFactory in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044363#comment-17044363 ] Jingsong Lee commented on FLINK-16179: -- master: fa3f56461fb5fb6157cc3f639c36582da24a0fb3 > Use

[jira] [Commented] (FLINK-16264) SQLClientKafkaITCase fails with: Could not map the schema field 'rowtime' to a field from source.

[ https://issues.apache.org/jira/browse/FLINK-16264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044397#comment-17044397 ] Jingsong Lee commented on FLINK-16264: -- Merged master: dd288c958861105b0ffc0966a8d32c1188342649 We

[jira] [Commented] (FLINK-16281) parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink

[ https://issues.apache.org/jira/browse/FLINK-16281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049820#comment-17049820 ] Jingsong Lee commented on FLINK-16281: -- master: 3e10f0a5ca1179f8a95185c3d3c03ec9fe0dabb6 >

[jira] [Commented] (FLINK-16281) parameter 'maxRetryTimes' can not work in JDBCUpsertTableSink

[ https://issues.apache.org/jira/browse/FLINK-16281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049821#comment-17049821 ] Jingsong Lee commented on FLINK-16281: -- [~Leonard Xu] can you open a PR for release-1.10? >

[jira] [Created] (FLINK-16368) ZooKeeperHighAvailabilityITCase test fail

Jingsong Lee created FLINK-16368: Summary: ZooKeeperHighAvailabilityITCase test fail Key: FLINK-16368 URL: https://issues.apache.org/jira/browse/FLINK-16368 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-16360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16360: Assignee: Jingsong Lee > connector on hive 2.0.1 don't support type conversion from

[jira] [Updated] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-16360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16360: - Fix Version/s: 1.10.1 > connector on hive 2.0.1 don't support type conversion from STRING to

[jira] [Commented] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-16360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048816#comment-17048816 ] Jingsong Lee commented on FLINK-16360: -- Thanks [~wgcn] for reporting, Hive 2.0 ORC not support

[jira] [Commented] (FLINK-16270) Use LogicalType to equals/hashcode in TableSchema

[ https://issues.apache.org/jira/browse/FLINK-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044136#comment-17044136 ] Jingsong Lee commented on FLINK-16270: -- PR: [https://github.com/apache/flink/pull/11205] > Use

[jira] [Created] (FLINK-15732) Add config option to close Hash window agg since hash will lead to OOM

Jingsong Lee created FLINK-15732: Summary: Add config option to close Hash window agg since hash will lead to OOM Key: FLINK-15732 URL: https://issues.apache.org/jira/browse/FLINK-15732 Project:

[jira] [Commented] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

[ https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021966#comment-17021966 ] Jingsong Lee commented on FLINK-15706: -- Thanks for involving. I have no idea to test

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021934#comment-17021934 ] Jingsong Lee commented on FLINK-2646: - Thanks for your wonderful discussion, Another case is

[jira] [Comment Edited] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

[ https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021980#comment-17021980 ] Jingsong Lee edited comment on FLINK-15706 at 1/23/20 11:26 AM: +1 to

[jira] [Commented] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

[ https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021980#comment-17021980 ] Jingsong Lee commented on FLINK-15706: -- +1 to target this for 1.11. My first thought was

[jira] [Created] (FLINK-15733) Add min number memory pages check for BytesHashMap

Jingsong Lee created FLINK-15733: Summary: Add min number memory pages check for BytesHashMap Key: FLINK-15733 URL: https://issues.apache.org/jira/browse/FLINK-15733 Project: Flink Issue

[jira] [Created] (FLINK-15734) Support spill in batch hash window aggregation

Jingsong Lee created FLINK-15734: Summary: Support spill in batch hash window aggregation Key: FLINK-15734 URL: https://issues.apache.org/jira/browse/FLINK-15734 Project: Flink Issue Type:

[jira] [Created] (FLINK-15932) Add download url to hive dependencies

Jingsong Lee created FLINK-15932: Summary: Add download url to hive dependencies Key: FLINK-15932 URL: https://issues.apache.org/jira/browse/FLINK-15932 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15932) Add download url to hive dependencies

[ https://issues.apache.org/jira/browse/FLINK-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031241#comment-17031241 ] Jingsong Lee commented on FLINK-15932: -- CC: [~lirui] > Add download url to hive dependencies >

[jira] [Commented] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031421#comment-17031421 ] Jingsong Lee commented on FLINK-15728: -- Hi [~dasbh] You can take 

[jira] [Comment Edited] (FLINK-15826) Add renameFunction() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027293#comment-17027293 ] Jingsong Lee edited comment on FLINK-15826 at 1/31/20 8:53 AM: --- +1 As

[jira] [Commented] (FLINK-15826) Add renameFunction() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027293#comment-17027293 ] Jingsong Lee commented on FLINK-15826: -- +1 as

[jira] [Updated] (FLINK-15527) can not control the number of container on yarn single job module

[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15527: - Labels: usability (was: ) > can not control the number of container on yarn single job module

[jira] [Updated] (FLINK-15527) can not control the number of container on yarn single job module

[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15527: - Component/s: (was: Connectors / Hive) Deployment / YARN > can not control

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029040#comment-17029040 ] Jingsong Lee commented on FLINK-15527: -- I labeled it usability because I found that the typical way

[jira] [Updated] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15858: - Priority: Critical (was: Major) > Unable to use HiveCatalog and kafka together >

[jira] [Updated] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15858: - Fix Version/s: 1.10.0 > Unable to use HiveCatalog and kafka together >

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029431#comment-17029431 ] Jingsong Lee commented on FLINK-15858: -- +1 to fix this. I think this should be supported. When we

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029432#comment-17029432 ] Jingsong Lee commented on FLINK-15858: -- If I remember correctly, 1.9 is supported. 1.10 broken. >

[jira] [Updated] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15858: - Priority: Critical (was: Blocker) > Unable to use HiveCatalog and kafka together >

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029766#comment-17029766 ] Jingsong Lee commented on FLINK-15858: -- Hi [~zjffdu], it seems that we need take more time to

[jira] [Updated] (FLINK-15938) Idle state not cleaned in StreamingJoinOperator and StreamingSemiAntiJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-15938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15938: - Fix Version/s: 1.9.3 > Idle state not cleaned in StreamingJoinOperator and >

[jira] [Commented] (FLINK-15928) Batch mode in blink planner caused IndexOutOfBoundsException error

[ https://issues.apache.org/jira/browse/FLINK-15928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032201#comment-17032201 ] Jingsong Lee commented on FLINK-15928: -- Hi [~fanbinbu], can you show all aggregations? I can not

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030330#comment-17030330 ] Jingsong Lee commented on FLINK-15858: -- [~zjffdu] Sorry, I underestimated its importance. Code

[jira] [Created] (FLINK-15912) Add Context to improve TableSourceFactory and TableSinkFactory

Jingsong Lee created FLINK-15912: Summary: Add Context to improve TableSourceFactory and TableSinkFactory Key: FLINK-15912 URL: https://issues.apache.org/jira/browse/FLINK-15912 Project: Flink

[jira] [Commented] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030346#comment-17030346 ] Jingsong Lee commented on FLINK-15858: -- Hi [~phoenixjiangnan], Good point. But I think maybe it's

[jira] [Commented] (FLINK-15853) Use the new type inference for hive udf

[ https://issues.apache.org/jira/browse/FLINK-15853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030570#comment-17030570 ] Jingsong Lee commented on FLINK-15853: -- [~twalthr]  Got it. Thanks reminder. > Use the new type

[jira] [Created] (FLINK-15853) Use the new type inference for hive udf

Jingsong Lee created FLINK-15853: Summary: Use the new type inference for hive udf Key: FLINK-15853 URL: https://issues.apache.org/jira/browse/FLINK-15853 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15849) Update SQL-CLIENT document from type to data-type

Jingsong Lee created FLINK-15849: Summary: Update SQL-CLIENT document from type to data-type Key: FLINK-15849 URL: https://issues.apache.org/jira/browse/FLINK-15849 Project: Flink Issue

[jira] [Commented] (FLINK-15849) Update SQL-CLIENT document from type to data-type

[ https://issues.apache.org/jira/browse/FLINK-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028647#comment-17028647 ] Jingsong Lee commented on FLINK-15849: -- CC: [~jark] > Update SQL-CLIENT document from type to

[jira] [Created] (FLINK-15855) Use the new type inference for hive udaf

Jingsong Lee created FLINK-15855: Summary: Use the new type inference for hive udaf Key: FLINK-15855 URL: https://issues.apache.org/jira/browse/FLINK-15855 Project: Flink Issue Type:

[jira] [Created] (FLINK-15854) Use the new type inference for hive udtf

Jingsong Lee created FLINK-15854: Summary: Use the new type inference for hive udtf Key: FLINK-15854 URL: https://issues.apache.org/jira/browse/FLINK-15854 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027994#comment-17027994 ] Jingsong Lee edited comment on FLINK-15840 at 2/1/20 7:59 AM: -- CC:

[jira] [Commented] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028005#comment-17028005 ] Jingsong Lee commented on FLINK-15840: -- Another bug is {{CatalogSourceTable}} need override

[jira] [Updated] (FLINK-15840) ClassCastException is thrown when use ConnectorDescriptor under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15840: - Priority: Blocker (was: Critical) > ClassCastException is thrown when use ConnectorDescriptor

[jira] [Commented] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027994#comment-17027994 ] Jingsong Lee commented on FLINK-15840: -- CC: [~danny0405] [~jark] > ClassCastException is thrown

[jira] [Comment Edited] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027997#comment-17027997 ] Jingsong Lee edited comment on FLINK-15840 at 2/1/20 6:49 AM: -- The problem

[jira] [Commented] (FLINK-15840) ClassCastException is thrown when use ConnectorDescriptor under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027977#comment-17027977 ] Jingsong Lee commented on FLINK-15840: -- Thanks [~sunjincheng121] for reporting. This ticket should 

[jira] [Updated] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15840: - Summary: ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink

[jira] [Commented] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027980#comment-17027980 ] Jingsong Lee commented on FLINK-15840: -- Yes, please assign to me. > ClassCastException is thrown

[jira] [Commented] (FLINK-15494) time field index wrong in LogicalWindowAggregateRuleBase

[ https://issues.apache.org/jira/browse/FLINK-15494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027979#comment-17027979 ] Jingsong Lee commented on FLINK-15494: -- I think it should not be a blocker, but nice to merge it in

[jira] [Commented] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027997#comment-17027997 ] Jingsong Lee commented on FLINK-15840: -- The problem is that CatalogSourceTable.toRel wants to get

[jira] [Comment Edited] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027997#comment-17027997 ] Jingsong Lee edited comment on FLINK-15840 at 2/1/20 6:48 AM: -- The problem

[jira] [Comment Edited] (FLINK-15840) ClassCastException is thrown when use tEnv.from for temp/catalog table under Blink planner

[ https://issues.apache.org/jira/browse/FLINK-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027977#comment-17027977 ] Jingsong Lee edited comment on FLINK-15840 at 2/1/20 6:56 AM: -- Thanks

[jira] [Commented] (FLINK-16110) LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and "TIMESTAMP(3) *PROCTIME*"

[ https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038749#comment-17038749 ] Jingsong Lee commented on FLINK-16110: -- Looks like misusing of {{asSummaryString}} and

[jira] [Commented] (FLINK-16141) HiveTableSourceTest unstable

[ https://issues.apache.org/jira/browse/FLINK-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038969#comment-17038969 ] Jingsong Lee commented on FLINK-16141: -- CC: [~lirui] > HiveTableSourceTest unstable >

[jira] [Created] (FLINK-16161) Statistics zero should be unknown in HiveCatalog

Jingsong Lee created FLINK-16161: Summary: Statistics zero should be unknown in HiveCatalog Key: FLINK-16161 URL: https://issues.apache.org/jira/browse/FLINK-16161 Project: Flink Issue Type:

[jira] [Commented] (FLINK-16143) Turn on more date time functions of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039963#comment-17039963 ] Jingsong Lee commented on FLINK-16143: -- +1 to add more date time functions. Compare to Hive, we

[jira] [Commented] (FLINK-15989) Rewrap OutOfMemoryError in allocateUnpooledOffHeap with better message

[ https://issues.apache.org/jira/browse/FLINK-15989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034314#comment-17034314 ] Jingsong Lee commented on FLINK-15989: -- Thanks [~azagrebin], yes, we can improve this message too.

[jira] [Created] (FLINK-15990) Remove register source and sink in ConnectTableDescriptor

Jingsong Lee created FLINK-15990: Summary: Remove register source and sink in ConnectTableDescriptor Key: FLINK-15990 URL: https://issues.apache.org/jira/browse/FLINK-15990 Project: Flink

[jira] [Commented] (FLINK-15912) Add Context to improve TableSourceFactory and TableSinkFactory

[ https://issues.apache.org/jira/browse/FLINK-15912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033406#comment-17033406 ] Jingsong Lee commented on FLINK-15912: -- [~jark] Can you assign this to me? > Add Context to

[jira] [Commented] (FLINK-15990) Remove register source and sink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034384#comment-17034384 ] Jingsong Lee commented on FLINK-15990: -- CC: [~jincheng] [~dian.fu] [~hequn8128] Also repalce

[jira] [Commented] (FLINK-15990) Remove register source and sink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034362#comment-17034362 ] Jingsong Lee commented on FLINK-15990: -- Thanks [~docete] for your review. > Remove register source

[jira] [Comment Edited] (FLINK-15990) Remove register source and sink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034384#comment-17034384 ] Jingsong Lee edited comment on FLINK-15990 at 2/11/20 12:06 PM: CC:

[jira] [Closed] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15593. Resolution: Invalid > add doc to remind users not using Hive aggregate functions in streaming

[jira] [Commented] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033467#comment-17033467 ] Jingsong Lee commented on FLINK-15593: -- Closed it, it is invalid, It can be re-opened at any time

[jira] [Resolved] (FLINK-15172) Optimize the operator algorithm to lazily allocate memory

[ https://issues.apache.org/jira/browse/FLINK-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-15172. -- Resolution: Fixed Merged in Master: c11c696cca3b6ecafab605cceb36b7541444993f

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036662#comment-17036662 ] Jingsong Lee commented on FLINK-16048: -- More accurate, should be confluent avro schema support.

[jira] [Commented] (FLINK-16070) Blink planner can not extract correct unique key for UpsertStreamTableSink

[ https://issues.apache.org/jira/browse/FLINK-16070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037516#comment-17037516 ] Jingsong Lee commented on FLINK-16070: -- Hi [~Leonard Xu] , thanks for reporting.

[jira] [Commented] (FLINK-16181) IfCallGen will throw NPE for primitive types in blink

[ https://issues.apache.org/jira/browse/FLINK-16181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040593#comment-17040593 ] Jingsong Lee commented on FLINK-16181: -- Thanks [~libenchao] for reporting. You are right, it is a

[jira] [Created] (FLINK-16179) Use configuration from TableFactory in hive connector

Jingsong Lee created FLINK-16179: Summary: Use configuration from TableFactory in hive connector Key: FLINK-16179 URL: https://issues.apache.org/jira/browse/FLINK-16179 Project: Flink Issue

[jira] [Created] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large

Jingsong Lee created FLINK-16165: Summary: NestedLoopJoin fallback to HashJoin when build records number is very large Key: FLINK-16165 URL: https://issues.apache.org/jira/browse/FLINK-16165 Project:

[jira] [Commented] (FLINK-16185) Support JSON functions provides by calcite for blink planner

[ https://issues.apache.org/jira/browse/FLINK-16185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040820#comment-17040820 ] Jingsong Lee commented on FLINK-16185: -- Hi [~tison] , Consider vote passed FLIP-90: 

[jira] [Created] (FLINK-16026) Travis failed due to python setup

Jingsong Lee created FLINK-16026: Summary: Travis failed due to python setup Key: FLINK-16026 URL: https://issues.apache.org/jira/browse/FLINK-16026 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035843#comment-17035843 ] Jingsong Lee commented on FLINK-16023: -- It seems that we need new interface in FLINK-15912 > jdbc

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