[jira] [Created] (FLINK-33511) flink SqlGateway select bigint type column get cast exception

2023-11-09 Thread xiaodao (Jira)
xiaodao created FLINK-33511: --- Summary: flink SqlGateway select bigint type column get cast exception Key: FLINK-33511 URL: https://issues.apache.org/jira/browse/FLINK-33511 Project: Flink Issue

[jira] [Created] (FLINK-30412) create many checkpoint empty dir when job not enable checkpoint

2022-12-14 Thread xiaodao (Jira)
xiaodao created FLINK-30412: --- Summary: create many checkpoint empty dir when job not enable checkpoint Key: FLINK-30412 URL: https://issues.apache.org/jira/browse/FLINK-30412 Project: Flink Issue

[jira] [Created] (FLINK-24976) sink utils not check the schema info between query and sink table

2021-11-22 Thread xiaodao (Jira)
xiaodao created FLINK-24976: --- Summary: sink utils not check the schema info between query and sink table Key: FLINK-24976 URL: https://issues.apache.org/jira/browse/FLINK-24976 Project: Flink

[jira] [Created] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

2020-09-27 Thread xiaodao (Jira)
xiaodao created FLINK-19435: --- Summary: jdbc JDBCOutputFormat open function invoke Class.forName(drivername) Key: FLINK-19435 URL: https://issues.apache.org/jira/browse/FLINK-19435 Project: Flink

[jira] [Created] (FLINK-17419) kafka sink json data convert issuse,type compare error

2020-04-27 Thread xiaodao (Jira)
xiaodao created FLINK-17419: --- Summary: kafka sink json data convert issuse,type compare error Key: FLINK-17419 URL: https://issues.apache.org/jira/browse/FLINK-17419 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17153) flink sql convert constant to char type cause loop

2020-04-15 Thread xiaodao (Jira)
xiaodao created FLINK-17153: --- Summary: flink sql convert constant to char type cause loop Key: FLINK-17153 URL: https://issues.apache.org/jira/browse/FLINK-17153 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16689) kafka connector as source get byte deserialize add support charsets

2020-03-19 Thread xiaodao (Jira)
xiaodao created FLINK-16689: --- Summary: kafka connector as source get byte deserialize add support charsets Key: FLINK-16689 URL: https://issues.apache.org/jira/browse/FLINK-16689 Project: Flink

[jira] [Created] (FLINK-16478) add restApi to modify loglevel

2020-03-06 Thread xiaodao (Jira)
xiaodao created FLINK-16478: --- Summary: add restApi to modify loglevel Key: FLINK-16478 URL: https://issues.apache.org/jira/browse/FLINK-16478 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15433) flink-hbase add kerberos support

2019-12-28 Thread xiaodao (Jira)
xiaodao created FLINK-15433: --- Summary: flink-hbase add kerberos support Key: FLINK-15433 URL: https://issues.apache.org/jira/browse/FLINK-15433 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15432) JDBCOutputFormat add flushInterval just like JDBCUpsertOutputFormat

2019-12-27 Thread xiaodao (Jira)
xiaodao created FLINK-15432: --- Summary: JDBCOutputFormat add flushInterval just like JDBCUpsertOutputFormat Key: FLINK-15432 URL: https://issues.apache.org/jira/browse/FLINK-15432 Project: Flink

[jira] [Created] (FLINK-15389) JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1

2019-12-24 Thread xiaodao (Jira)
xiaodao created FLINK-15389: --- Summary: JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1 Key: FLINK-15389 URL: https://issues.apache.org/jira/browse/FLINK-15389 Project: Flink

[jira] [Created] (FLINK-15237) CsvTableSource and ref class better to Extract into a module

2019-12-12 Thread xiaodao (Jira)
xiaodao created FLINK-15237: --- Summary: CsvTableSource and ref class better to Extract into a module Key: FLINK-15237 URL: https://issues.apache.org/jira/browse/FLINK-15237 Project: Flink Issue

[jira] [Created] (FLINK-15173) perjob on yarn appcluster shutdown depend on CliFrontend

2019-12-10 Thread xiaodao (Jira)
xiaodao created FLINK-15173: --- Summary: perjob on yarn appcluster shutdown depend on CliFrontend Key: FLINK-15173 URL: https://issues.apache.org/jira/browse/FLINK-15173 Project: Flink Issue Type:

[jira] [Created] (FLINK-14801) flink sql parser unparser func partition frame local variable name mistake

2019-11-14 Thread xiaodao (Jira)
xiaodao created FLINK-14801: --- Summary: flink sql parser unparser func partition frame local variable name mistake Key: FLINK-14801 URL: https://issues.apache.org/jira/browse/FLINK-14801 Project: Flink

[jira] [Created] (FLINK-14585) flink connector for sink to apache/incubator-druid

2019-10-31 Thread xiaodao (Jira)
xiaodao created FLINK-14585: --- Summary: flink connector for sink to apache/incubator-druid Key: FLINK-14585 URL: https://issues.apache.org/jira/browse/FLINK-14585 Project: Flink Issue Type: New

[jira] [Created] (FLINK-14571) flink connector for redis

2019-10-30 Thread xiaodao (Jira)
xiaodao created FLINK-14571: --- Summary: flink connector for redis Key: FLINK-14571 URL: https://issues.apache.org/jira/browse/FLINK-14571 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14559) flink sql connector for stream table stdout

2019-10-29 Thread xiaodao (Jira)
xiaodao created FLINK-14559: --- Summary: flink sql connector for stream table stdout Key: FLINK-14559 URL: https://issues.apache.org/jira/browse/FLINK-14559 Project: Flink Issue Type: New Feature