[jira] [Commented] (FLINK-15003) Improve hive test performance

[ https://issues.apache.org/jira/browse/FLINK-15003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986669#comment-16986669 ] Jingsong Lee commented on FLINK-15003: -- Thanks [~lirui] for your investigation, I change the name

[jira] [Closed] (FLINK-5835) Support for Hive's User-defined Aggregation Function (UDAF)

[ https://issues.apache.org/jira/browse/FLINK-5835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-5835. --- Resolution: Fixed > Support for Hive's User-defined Aggregation Function (UDAF) >

[jira] [Commented] (FLINK-14860) Provide a new InputSplitAssigner that consider page cache utilization ratio

[ https://issues.apache.org/jira/browse/FLINK-14860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986516#comment-16986516 ] Jingsong Lee commented on FLINK-14860: -- Yes, we should. > Provide a new InputSplitAssigner that

[jira] [Created] (FLINK-15020) Support timestamp type in hive

Jingsong Lee created FLINK-15020: Summary: Support timestamp type in hive Key: FLINK-15020 URL: https://issues.apache.org/jira/browse/FLINK-15020 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-5835) Support for Hive's User-defined Aggregation Function (UDAF)

[ https://issues.apache.org/jira/browse/FLINK-5835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986548#comment-16986548 ] Jingsong Lee commented on FLINK-5835: - Hi [~clarkyzl] because we have supported it in blink runner, I

[jira] [Commented] (FLINK-5834) Support for Hive User-defined Table-generating Function (UDTF)

[ https://issues.apache.org/jira/browse/FLINK-5834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986547#comment-16986547 ] Jingsong Lee commented on FLINK-5834: - Hi [~clarkyzl]  because we have supported it in blink runner,

[jira] [Commented] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986549#comment-16986549 ] Jingsong Lee commented on FLINK-5802: - Hi [~winipanda] [~clarkyzl] [~miaoever] [~fhueske] because we

[jira] [Closed] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-5802. --- Resolution: Fixed > Flink SQL calling Hive User-Defined Functions >

[jira] [Commented] (FLINK-15038) Get field DataType of TableSchema should return DataType with default conversion class

[ https://issues.apache.org/jira/browse/FLINK-15038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986868#comment-16986868 ] Jingsong Lee commented on FLINK-15038: -- CC: [~twalthr] [~dwysakowicz] > Get field DataType of

[jira] [Created] (FLINK-15038) Get field DataType of TableSchema should return DataType with default conversion class

Jingsong Lee created FLINK-15038: Summary: Get field DataType of TableSchema should return DataType with default conversion class Key: FLINK-15038 URL: https://issues.apache.org/jira/browse/FLINK-15038

[jira] [Created] (FLINK-15062) Orc reader should use java.sql.Timestamp to read for respecting time zone

Jingsong Lee created FLINK-15062: Summary: Orc reader should use java.sql.Timestamp to read for respecting time zone Key: FLINK-15062 URL: https://issues.apache.org/jira/browse/FLINK-15062 Project:

[jira] [Updated] (FLINK-15062) Orc reader should use java.sql.Timestamp to read for respecting time zone

[ https://issues.apache.org/jira/browse/FLINK-15062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15062: - Description: Hive orc use  > Orc reader should use java.sql.Timestamp to read for respecting

[jira] [Updated] (FLINK-15062) Orc reader should use java.sql.Timestamp to read for respecting time zone

[ https://issues.apache.org/jira/browse/FLINK-15062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15062: - Description: Hive orc use java.sql.Timestamp to read and write orc files... default, timestamp

[jira] [Updated] (FLINK-14515) Implement LimitableTableSource for FileSystemTableFactory

[ https://issues.apache.org/jira/browse/FLINK-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14515: - Fix Version/s: (was: 1.10.0) > Implement LimitableTableSource for FileSystemTableFactory >

[jira] [Updated] (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 updated FLINK-14258: - Fix Version/s: (was: 1.10.0) > Integrate hive to FileSystemTableFactory >

[jira] [Commented] (FLINK-13410) Csv input format does not support LocalDate

[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991194#comment-16991194 ] Jingsong Lee commented on FLINK-13410: -- Now, Csv source / sink will type informations, so them

[jira] [Updated] (FLINK-13410) Csv input format does not support LocalDate

[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13410: - Fix Version/s: (was: 1.10.0) > Csv input format does not support LocalDate >

[jira] [Updated] (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 updated FLINK-14257: - Fix Version/s: (was: 1.10.0) > Integrate csv to FileSystemTableFactory >

[jira] [Commented] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991209#comment-16991209 ] Jingsong Lee commented on FLINK-15141: -- Hi [~xiaojin.wy], is this duplicated with 

[jira] [Commented] (FLINK-15122) Reusing record object in StreamTaskNetworkInput

[ https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991090#comment-16991090 ] Jingsong Lee commented on FLINK-15122: -- Hi [~pnowojski], Thanks for your attention. Yes, That 

[jira] [Updated] (FLINK-14267) Introduce RowCsvOutputFormat to new CSV module

[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14267: - Fix Version/s: (was: 1.10.0) > Introduce RowCsvOutputFormat to new CSV module >

[jira] [Updated] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module

[ https://issues.apache.org/jira/browse/FLINK-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14266: - Fix Version/s: (was: 1.10.0) > Introduce RowCsvInputFormat to new CSV module >

[jira] [Closed] (FLINK-13285) Check connectors runnable in blink runner

[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-13285. Resolution: Fixed > Check connectors runnable in blink runner >

[jira] [Updated] (FLINK-13438) Hive source/sink/udx should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13438: - Parent: (was: FLINK-13285) Issue Type: Bug (was: Sub-task) > Hive source/sink/udx

[jira] [Commented] (FLINK-13283) JDBC source/sink should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991166#comment-16991166 ] Jingsong Lee commented on FLINK-13283: -- Fixed in https://issues.apache.org/jira/browse/FLINK-14645

[jira] [Resolved] (FLINK-13283) JDBC source/sink should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-13283. -- Resolution: Fixed > JDBC source/sink should respect the conversion class of DataType >

[jira] [Commented] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992352#comment-16992352 ] Jingsong Lee commented on FLINK-15103: -- [~xintongsong] , You remain me to test small batch sql

[jira] [Commented] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992372#comment-16992372 ] Jingsong Lee commented on FLINK-15167: -- For the third problem, I think there is a simple way to

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992352#comment-16992352 ] Jingsong Lee edited comment on FLINK-15103 at 12/10/19 9:57 AM:

[jira] [Commented] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner

[ https://issues.apache.org/jira/browse/FLINK-15168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992375#comment-16992375 ] Jingsong Lee commented on FLINK-15168: -- > We should use new type system in TableSourceUtil to avoid

[jira] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992494#comment-16992494 ] Jingsong Lee commented on FLINK-15175: -- Hi [~liupengcheng], thanks for reporting this ticket. Now,

[jira] [Updated] (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 updated FLINK-15172: - Summary: Optimize the operator algorithm to lazily allocate memory (was: optimize the operator

[jira] [Created] (FLINK-15172) optimize the operator algorithm to lazily allocate memory

Jingsong Lee created FLINK-15172: Summary: optimize the operator algorithm to lazily allocate memory Key: FLINK-15172 URL: https://issues.apache.org/jira/browse/FLINK-15172 Project: Flink

[jira] [Updated] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15175: - Issue Type: Bug (was: Improvement) > syntax not supported in SQLClient for TPCDS queries >

[jira] [Closed] (FLINK-14737) HiveTypeUtil.toFlinkPrimitiveType returns wrong Timestamp(6) instead of Timestamp(9)

[ https://issues.apache.org/jira/browse/FLINK-14737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14737. Resolution: Duplicate > HiveTypeUtil.toFlinkPrimitiveType returns wrong Timestamp(6) instead of

[jira] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993164#comment-16993164 ] Jingsong Lee commented on FLINK-15175: -- > extending calcite core parser in flink to support DDL and

[jira] [Created] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test

Jingsong Lee created FLINK-15183: Summary: Use SQL-CLI to TPC-DS E2E test Key: FLINK-15183 URL: https://issues.apache.org/jira/browse/FLINK-15183 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993162#comment-16993162 ] Jingsong Lee commented on FLINK-15167: -- Hi [~lirui], For the third problem, since it is an

[jira] [Created] (FLINK-15185) Hive sink can not run in standalone mode

Jingsong Lee created FLINK-15185: Summary: Hive sink can not run in standalone mode Key: FLINK-15185 URL: https://issues.apache.org/jira/browse/FLINK-15185 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15239) TM Metaspace memory leak

[ https://issues.apache.org/jira/browse/FLINK-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995427#comment-16995427 ] Jingsong Lee commented on FLINK-15239: -- CC: [~kevin.cyj] > TM Metaspace memory leak >

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995446#comment-16995446 ] Jingsong Lee commented on FLINK-15223: -- I think this bug is not easy to fix in 1.10, we can let it

[jira] [Comment Edited] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995290#comment-16995290 ] Jingsong Lee edited comment on FLINK-15223 at 12/13/19 2:27 AM: I prefer 

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Parent: (was: FLINK-14644) Issue Type: Bug (was: Sub-task) > Print match

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Description: Currently, all the required properties should exist and match, otherwise, 

[jira] [Commented] (FLINK-14647) Improve the exception message when required property is not matched

[ https://issues.apache.org/jira/browse/FLINK-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995362#comment-16995362 ] Jingsong Lee commented on FLINK-14647: -- Hi [~nicholasjiang] [~jark] , I created 

[jira] [Updated] (FLINK-15232) Message of NoMatchingTableFactoryException should tell users what's wrong

[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Summary: Message of NoMatchingTableFactoryException should tell users what's wrong (was: User

[jira] [Updated] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15231: - Fix Version/s: 1.11.0 > Wrong HeapVector in AbstractHeapVector.createHeapColumn >

[jira] [Updated] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15231: - Fix Version/s: (was: 1.10.0) > Wrong HeapVector in AbstractHeapVector.createHeapColumn >

[jira] [Commented] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995360#comment-16995360 ] Jingsong Lee commented on FLINK-15231: -- Modified version to 1.11, it is not a user bug. So let's

[jira] [Updated] (FLINK-15232) User doesn't know what's wrong: Print match candidates to improve NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Summary: User doesn't know what's wrong: Print match candidates to improve

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995465#comment-16995465 ] Jingsong Lee commented on FLINK-15223: -- In DML, we also occur escape problem. If user want to write

[jira] [Created] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

Jingsong Lee created FLINK-15232: Summary: Print match candidates to improve NoMatchingTableFactoryException Key: FLINK-15232 URL: https://issues.apache.org/jira/browse/FLINK-15232 Project: Flink

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Priority: Blocker (was: Critical) > Print match candidates to improve

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995290#comment-16995290 ] Jingsong Lee commented on FLINK-15223: -- I prefer unescapeJava for all DDL properties. (In the

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995415#comment-16995415 ] Jingsong Lee commented on FLINK-15223: -- After offline discussion with [~danny0405] . We should not

[jira] [Commented] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

[ https://issues.apache.org/jira/browse/FLINK-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993257#comment-16993257 ] Jingsong Lee commented on FLINK-15191: -- I mark it blocker since I think watermark and compute

[jira] [Created] (FLINK-15193) Move DDL to first tab in table connector page

Jingsong Lee created FLINK-15193: Summary: Move DDL to first tab in table connector page Key: FLINK-15193 URL: https://issues.apache.org/jira/browse/FLINK-15193 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14849) Can not submit job when use hive connector

[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993314#comment-16993314 ] Jingsong Lee commented on FLINK-14849: -- Thanks [~wind_ljy]. We should provide a util to help users

[jira] [Updated] (FLINK-14849) Can not submit job when use hive connector

[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14849: - Priority: Critical (was: Major) > Can not submit job when use hive connector >

[jira] [Commented] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993178#comment-16993178 ] Jingsong Lee commented on FLINK-14364: -- Hi [~wind_ljy], current status is we can only 

[jira] [Updated] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

[ https://issues.apache.org/jira/browse/FLINK-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15191: - Priority: Blocker (was: Major) > Fix can't create table source for Kafka if watermark or

[jira] [Commented] (FLINK-15193) Move DDL to first tab in table connector page

[ https://issues.apache.org/jira/browse/FLINK-15193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993303#comment-16993303 ] Jingsong Lee commented on FLINK-15193: -- CC: [~jark] > Move DDL to first tab in table connector

[jira] [Updated] (FLINK-15193) Move DDL to first tab in table connector page

[ https://issues.apache.org/jira/browse/FLINK-15193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15193: - Component/s: Table SQL / API > Move DDL to first tab in table connector page >

[jira] [Updated] (FLINK-14849) Can not submit job when use hive connector

[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14849: - Fix Version/s: 1.10.0 > Can not submit job when use hive connector >

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14364: - Fix Version/s: (was: 1.10.0) 1.11.0 > Allow comments fail when not

[jira] [Commented] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993240#comment-16993240 ] Jingsong Lee commented on FLINK-14953: -- [~dian.fu] I can find in 1.10 branch: 

[jira] [Commented] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity

[ https://issues.apache.org/jira/browse/FLINK-15192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993306#comment-16993306 ] Jingsong Lee commented on FLINK-15192: -- Hi [~phoenixjiangnan], since it is a table related ticket,

[jira] [Commented] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity

[ https://issues.apache.org/jira/browse/FLINK-15192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993268#comment-16993268 ] Jingsong Lee commented on FLINK-15192: -- +1. I kind of like hive's name: * Data Definition

[jira] [Commented] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997898#comment-16997898 ] Jingsong Lee commented on FLINK-15205: -- Hi [~phoenixjiangnan] [~jark] , can you assign this ticket

[jira] [Updated] (FLINK-15189) add documentation for catalog view and hive view

[ https://issues.apache.org/jira/browse/FLINK-15189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15189: - Parent: FLINK-15273 Issue Type: Sub-task (was: Task) > add documentation for catalog

[jira] [Updated] (FLINK-15193) Move DDL to first tab in table connector page

[ https://issues.apache.org/jira/browse/FLINK-15193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15193: - Parent: FLINK-15273 Issue Type: Sub-task (was: Task) > Move DDL to first tab in table

[jira] [Updated] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15205: - Parent: FLINK-15273 Issue Type: Sub-task (was: Task) > add doc and exmaple of INSERT

[jira] [Updated] (FLINK-15204) add documentation for Flink-Hive timestamp conversions in table and udf

[ https://issues.apache.org/jira/browse/FLINK-15204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15204: - Parent: FLINK-15273 Issue Type: Sub-task (was: Task) > add documentation for

[jira] [Updated] (FLINK-14796) Add document about limitations of different Hive versions

[ https://issues.apache.org/jira/browse/FLINK-14796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14796: - Parent: FLINK-15273 Issue Type: Sub-task (was: Task) > Add document about limitations

[jira] [Updated] (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 updated FLINK-15289: - Fix Version/s: 1.10.0 > Run sql appear error of "Zero-length character strings have no

[jira] [Commented] (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:comment-tabpanel=16998098#comment-16998098 ] Jingsong Lee commented on FLINK-15289: -- +1 to use DataTypeUtils transforms. > Run sql appear error

[jira] [Commented] (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:comment-tabpanel=16998071#comment-16998071 ] Jingsong Lee commented on FLINK-15289: --   {code:java} Table t = tEnv.sqlQuery("select '', 1"); // I

[jira] [Commented] (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:comment-tabpanel=16997953#comment-16997953 ] Jingsong Lee commented on FLINK-15289: -- Related JIRA: 

[jira] [Commented] (FLINK-15186) Column names and nullability mismatch when querying CatalogViews

[ https://issues.apache.org/jira/browse/FLINK-15186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994630#comment-16994630 ] Jingsong Lee commented on FLINK-15186: -- Hi [~dwysakowicz] [~danny0405], About add a cast: > we may

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994703#comment-16994703 ] Jingsong Lee commented on FLINK-15223: -- I can take this ticket. > Csv connector should unescape

[jira] [Commented] (FLINK-15217) 'java.time.LocalDate' should support for the CSV input format.

[ https://issues.apache.org/jira/browse/FLINK-15217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994349#comment-16994349 ] Jingsong Lee commented on FLINK-15217: -- Hi [~xiaojin.wy], 

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994727#comment-16994727 ] Jingsong Lee commented on FLINK-15223: -- This conflicts with yaml because the default reading from

[jira] [Commented] (FLINK-14566) Enable to get/set whether an operator uses managed memory

[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989327#comment-16989327 ] Jingsong Lee commented on FLINK-14566: -- Thanks [~zhuzh] and [~trohrmann], I will finish 

[jira] [Commented] (FLINK-15122) Reusing record object in StreamTaskNetworkInput

[ https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990486#comment-16990486 ] Jingsong Lee commented on FLINK-15122: -- CC: [~pnowojski] [~zhijiang] [~ykt836] > Reusing record

[jira] [Created] (FLINK-15122) Reusing record object in StreamTaskNetworkInput

Jingsong Lee created FLINK-15122: Summary: Reusing record object in StreamTaskNetworkInput Key: FLINK-15122 URL: https://issues.apache.org/jira/browse/FLINK-15122 Project: Flink Issue Type:

[jira] [Created] (FLINK-15269) Fix hive dialect limitation to overwrite and partition syntax

Jingsong Lee created FLINK-15269: Summary: Fix hive dialect limitation to overwrite and partition syntax Key: FLINK-15269 URL: https://issues.apache.org/jira/browse/FLINK-15269 Project: Flink

[jira] [Created] (FLINK-15272) Better error message when insert partition with values

Jingsong Lee created FLINK-15272: Summary: Better error message when insert partition with values Key: FLINK-15272 URL: https://issues.apache.org/jira/browse/FLINK-15272 Project: Flink Issue

[jira] [Commented] (FLINK-13197) Verify querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997084#comment-16997084 ] Jingsong Lee commented on FLINK-13197: -- We don't need distinguish hive from Flink. I think we can

[jira] [Updated] (FLINK-15266) NPE in blink planner code gen

[ https://issues.apache.org/jira/browse/FLINK-15266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15266: - Priority: Blocker (was: Major) > NPE in blink planner code gen > -

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997223#comment-16997223 ] Jingsong Lee commented on FLINK-15259: -- Some UDX will be affected, like hive "GenericUDTFStack",

[jira] [Updated] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14953: - Fix Version/s: 1.10.0 > Parquet table source should use schema type to build FilterPredicate >

[jira] [Closed] (FLINK-15164) Introduce ParquetColumnarRowSplitReader to parquet format

[ https://issues.apache.org/jira/browse/FLINK-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15164. Resolution: Duplicate > Introduce ParquetColumnarRowSplitReader to parquet format >

[jira] [Commented] (FLINK-15164) Introduce ParquetColumnarRowSplitReader to parquet format

[ https://issues.apache.org/jira/browse/FLINK-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992123#comment-16992123 ] Jingsong Lee commented on FLINK-15164: -- Hi [~ZhenqiuHuang], this is duplicated with 

[jira] [Commented] (FLINK-15204) add documentation for Flink-Hive timestamp conversions in table and udf

[ https://issues.apache.org/jira/browse/FLINK-15204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994247#comment-16994247 ] Jingsong Lee commented on FLINK-15204: -- Hi, Is this duplicate with FLINK-15128 ? > add

[jira] [Commented] (FLINK-15128) Document support for Hive timestamp type

[ https://issues.apache.org/jira/browse/FLINK-15128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994255#comment-16994255 ] Jingsong Lee commented on FLINK-15128: -- [~jark] Can you assign this to Rui Li? > Document support

[jira] [Commented] (FLINK-14796) Add document about limitations of different Hive versions

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

[jira] [Commented] (FLINK-14849) Can not submit job when use hive connector

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

[jira] [Commented] (FLINK-15049) Compile error when hash join with timestamp type key

[ https://issues.apache.org/jira/browse/FLINK-15049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994251#comment-16994251 ] Jingsong Lee commented on FLINK-15049: -- [~jark] Can you assign this to [~docete] ? > Compile error

[jira] [Commented] (FLINK-15050) DataFormatConverters should support any TIMESTAMP WITHOUT TIME ZONE types

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

[jira] [Commented] (FLINK-15185) Hive sink can not run in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994254#comment-16994254 ] Jingsong Lee commented on FLINK-15185: -- [~jark] Can you assign this to Me ? > Hive sink can not

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