[jira] [Created] (FLINK-34964) ScheduledTask leak in registering the processing timer

zoucao created FLINK-34964: -- Summary: ScheduledTask leak in registering the processing timer Key: FLINK-34964 URL: https://issues.apache.org/jira/browse/FLINK-34964 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27953) using the original order to add the primary key in PushProjectIntoTableSourceScanRule

zoucao created FLINK-27953: -- Summary: using the original order to add the primary key in PushProjectIntoTableSourceScanRule Key: FLINK-27953 URL: https://issues.apache.org/jira/browse/FLINK-27953 Project:

[jira] [Created] (FLINK-27911) Set HDFS LEASE_TIMEOUT as user-configurable

zoucao created FLINK-27911: -- Summary: Set HDFS LEASE_TIMEOUT as user-configurable Key: FLINK-27911 URL: https://issues.apache.org/jira/browse/FLINK-27911 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

zoucao created FLINK-27898: -- Summary: fix PartitionPushDown in streaming mode for hive source Key: FLINK-27898 URL: https://issues.apache.org/jira/browse/FLINK-27898 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26982) strike a balance between reuse the same RelNode and project/filter/limit/partition push down

zoucao created FLINK-26982: -- Summary: strike a balance between reuse the same RelNode and project/filter/limit/partition push down Key: FLINK-26982 URL: https://issues.apache.org/jira/browse/FLINK-26982

[jira] [Created] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

zoucao created FLINK-26761: -- Summary: Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table. Key: FLINK-26761 URL: https://issues.apache.org/jira/browse/FLINK-26761

[jira] [Created] (FLINK-26726) Remove the unregistered task from readersAwaitingSplit

zoucao created FLINK-26726: -- Summary: Remove the unregistered task from readersAwaitingSplit Key: FLINK-26726 URL: https://issues.apache.org/jira/browse/FLINK-26726 Project: Flink Issue Type:

[jira] [Created] (FLINK-26723) Fix the content of exception in SourceCoordinatorContext

zoucao created FLINK-26723: -- Summary: Fix the content of exception in SourceCoordinatorContext Key: FLINK-26723 URL: https://issues.apache.org/jira/browse/FLINK-26723 Project: Flink Issue Type:

[jira] [Created] (FLINK-26401) improve the compatibility for hive catalogView

zoucao created FLINK-26401: -- Summary: improve the compatibility for hive catalogView Key: FLINK-26401 URL: https://issues.apache.org/jira/browse/FLINK-26401 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

zoucao created FLINK-26355: -- Summary: VarCharType was not be considered in HiveTableSqlFunction Key: FLINK-26355 URL: https://issues.apache.org/jira/browse/FLINK-26355 Project: Flink Issue Type:

[jira] [Created] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

zoucao created FLINK-25476: -- Summary: CharType lost in the creation of MaxAggFunction & MinAggFunction Key: FLINK-25476 URL: https://issues.apache.org/jira/browse/FLINK-25476 Project: Flink Issue

[jira] [Created] (FLINK-24958) correct the example and link for temporal table function documentation

zoucao created FLINK-24958: -- Summary: correct the example and link for temporal table function documentation Key: FLINK-24958 URL: https://issues.apache.org/jira/browse/FLINK-24958 Project: Flink

[jira] [Created] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

zoucao created FLINK-23865: -- Summary: Class cast error caused by nested Pojo in legacy outputConversion Key: FLINK-23865 URL: https://issues.apache.org/jira/browse/FLINK-23865 Project: Flink Issue

[jira] [Created] (FLINK-23777) Support dynamic parameters for sink table in multiple connectors

zoucao created FLINK-23777: -- Summary: Support dynamic parameters for sink table in multiple connectors Key: FLINK-23777 URL: https://issues.apache.org/jira/browse/FLINK-23777 Project: Flink Issue

[jira] [Created] (FLINK-23597) support Add Jar in Table api

zoucao created FLINK-23597: -- Summary: support Add Jar in Table api Key: FLINK-23597 URL: https://issues.apache.org/jira/browse/FLINK-23597 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23511) Fix the location error in metric page.

zoucao created FLINK-23511: -- Summary: Fix the location error in metric page. Key: FLINK-23511 URL: https://issues.apache.org/jira/browse/FLINK-23511 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23510) add a new metric to show the max usage of inputExclusiveBuffer for each inputChannel

zoucao created FLINK-23510: -- Summary: add a new metric to show the max usage of inputExclusiveBuffer for each inputChannel Key: FLINK-23510 URL: https://issues.apache.org/jira/browse/FLINK-23510 Project:

[jira] [Created] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

zoucao created FLINK-23156: -- Summary: Change the reference of 'docs/dev/table/sql/queries' Key: FLINK-23156 URL: https://issues.apache.org/jira/browse/FLINK-23156 Project: Flink Issue Type:

[jira] [Created] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

zoucao created FLINK-22437: -- Summary: Miss adding parallesim for filter operator in batch mode Key: FLINK-22437 URL: https://issues.apache.org/jira/browse/FLINK-22437 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21738) reduce unnecessary method calls in ModuleManager

zoucao created FLINK-21738: -- Summary: reduce unnecessary method calls in ModuleManager Key: FLINK-21738 URL: https://issues.apache.org/jira/browse/FLINK-21738 Project: Flink Issue Type:

[jira] [Created] (FLINK-20827) Just read record correlating to join key in FilesystemLookUpFunc

zoucao created FLINK-20827: -- Summary: Just read record correlating to join key in FilesystemLookUpFunc Key: FLINK-20827 URL: https://issues.apache.org/jira/browse/FLINK-20827 Project: Flink Issue

[jira] [Created] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true

zoucao created FLINK-20795: -- Summary: add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true Key: FLINK-20795 URL: https://issues.apache.org/jira/browse/FLINK-20795

[jira] [Created] (FLINK-20701) print connector supports outputting seriailzed record

zoucao created FLINK-20701: -- Summary: print connector supports outputting seriailzed record Key: FLINK-20701 URL: https://issues.apache.org/jira/browse/FLINK-20701 Project: Flink Issue Type:

[jira] [Created] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest

zoucao created FLINK-20546: -- Summary: Misuse of the method in KafkaDynamicTableFactoryTest Key: FLINK-20546 URL: https://issues.apache.org/jira/browse/FLINK-20546 Project: Flink Issue Type:

[jira] [Created] (FLINK-19893) stop consuming in specific offset or timestamp

zoucao created FLINK-19893: -- Summary: stop consuming in specific offset or timestamp Key: FLINK-19893 URL: https://issues.apache.org/jira/browse/FLINK-19893 Project: Flink Issue Type: Improvement