[jira] [Created] (FLINK-33990) Use default classloader in TaskManager when there are no user jars for job

Dan Zou created FLINK-33990: --- Summary: Use default classloader in TaskManager when there are no user jars for job Key: FLINK-33990 URL: https://issues.apache.org/jira/browse/FLINK-33990 Project: Flink

[jira] [Created] (FLINK-33792) Generate the same code for the same logic

Dan Zou created FLINK-33792: --- Summary: Generate the same code for the same logic Key: FLINK-33792 URL: https://issues.apache.org/jira/browse/FLINK-33792 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33313) RexNodeExtractor fails to extract conditions with binary literal

Dan Zou created FLINK-33313: --- Summary: RexNodeExtractor fails to extract conditions with binary literal Key: FLINK-33313 URL: https://issues.apache.org/jira/browse/FLINK-33313 Project: Flink Issue

[jira] [Created] (FLINK-33267) Support PreparedStatement in JDBC Driver

Dan Zou created FLINK-33267: --- Summary: Support PreparedStatement in JDBC Driver Key: FLINK-33267 URL: https://issues.apache.org/jira/browse/FLINK-33267 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33266) Support plan cache for SQL jobs

Dan Zou created FLINK-33266: --- Summary: Support plan cache for SQL jobs Key: FLINK-33266 URL: https://issues.apache.org/jira/browse/FLINK-33266 Project: Flink Issue Type: Sub-task Report

[jira] [Created] (FLINK-32246) javax.management.InstanceAlreadyExistsException

jeff-zou created FLINK-32246: Summary: javax.management.InstanceAlreadyExistsException Key: FLINK-32246 URL: https://issues.apache.org/jira/browse/FLINK-32246 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31835) DataTypeHint don't support Row>

jeff-zou created FLINK-31835: Summary: DataTypeHint don't support Row> Key: FLINK-31835 URL: https://issues.apache.org/jira/browse/FLINK-31835 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-31375) the values of map are truncated by the CASE WHEN function.

jeff-zou created FLINK-31375: Summary: the values of map are truncated by the CASE WHEN function. Key: FLINK-31375 URL: https://issues.apache.org/jira/browse/FLINK-31375 Project: Flink Issue Typ

[jira] [Created] (FLINK-28729) flink hive catalog don't support jdk11

jeff-zou created FLINK-28729: Summary: flink hive catalog don't support jdk11 Key: FLINK-28729 URL: https://issues.apache.org/jira/browse/FLINK-28729 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-28691) Improve cache hit rate of generated class

Zou created FLINK-28691: --- Summary: Improve cache hit rate of generated class Key: FLINK-28691 URL: https://issues.apache.org/jira/browse/FLINK-28691 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-27018) timestamp missing end zero when outputing to kafka

jeff-zou created FLINK-27018: Summary: timestamp missing end zero when outputing to kafka Key: FLINK-27018 URL: https://issues.apache.org/jira/browse/FLINK-27018 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25652) Can "duration“ and ”received records" be updated at the same time in WebUI's task detail ?

jeff-zou created FLINK-25652: Summary: Can "duration“ and ”received records" be updated at the same time in WebUI's task detail ? Key: FLINK-25652 URL: https://issues.apache.org/jira/browse/FLINK-25652

[jira] [Created] (FLINK-25377) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25377: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25377 URL: https://issues.apache.org/jira/browse/FLINK-25377 Project: Flink Issue Type: N

[jira] [Created] (FLINK-25378) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25378: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25378 URL: https://issues.apache.org/jira/browse/FLINK-25378 Project: Flink Issue Type: N

[jira] [Created] (FLINK-22120) Bug when generate code for map get

Zou created FLINK-22120: --- Summary: Bug when generate code for map get Key: FLINK-22120 URL: https://issues.apache.org/jira/browse/FLINK-22120 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-19798) Support creating hive table input splits in parallel

Zou created FLINK-19798: --- Summary: Support creating hive table input splits in parallel Key: FLINK-19798 URL: https://issues.apache.org/jira/browse/FLINK-19798 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19797) NPE when we use decimal array as input of UDAF

Zou created FLINK-19797: --- Summary: NPE when we use decimal array as input of UDAF Key: FLINK-19797 URL: https://issues.apache.org/jira/browse/FLINK-19797 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-19796) Error results when use constant decimal array

Zou created FLINK-19796: --- Summary: Error results when use constant decimal array Key: FLINK-19796 URL: https://issues.apache.org/jira/browse/FLINK-19796 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-18168) Error results when use UDAF with Object Array return type

Zou created FLINK-18168: --- Summary: Error results when use UDAF with Object Array return type Key: FLINK-18168 URL: https://issues.apache.org/jira/browse/FLINK-18168 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

Zou created FLINK-16446: --- Summary: Add rate limiting feature for FlinkKafkaConsumer Key: FLINK-16446 URL: https://issues.apache.org/jira/browse/FLINK-16446 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16426) Add rate limiting feature for kafka table source

Zou created FLINK-16426: --- Summary: Add rate limiting feature for kafka table source Key: FLINK-16426 URL: https://issues.apache.org/jira/browse/FLINK-16426 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16425) Add rate limiting feature for kafka table source

Zou created FLINK-16425: --- Summary: Add rate limiting feature for kafka table source Key: FLINK-16425 URL: https://issues.apache.org/jira/browse/FLINK-16425 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16372) Generate unique operator name

Zou created FLINK-16372: --- Summary: Generate unique operator name Key: FLINK-16372 URL: https://issues.apache.org/jira/browse/FLINK-16372 Project: Flink Issue Type: Improvement Reporter: Zou

[jira] [Created] (FLINK-15513) Error in SQL Reserved Keywords doc

Zou created FLINK-15513: --- Summary: Error in SQL Reserved Keywords doc Key: FLINK-15513 URL: https://issues.apache.org/jira/browse/FLINK-15513 Project: Flink Issue Type: Improvement Components