[jira] [Created] (FLINK-37271) Add network channel reconnect capability

2025-02-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37271: - Summary: Add network channel reconnect capability Key: FLINK-37271 URL: https://issues.apache.org/jira/browse/FLINK-37271 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-37246) Delegation Token expire after enable delegation token framework

2025-02-03 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37246: - Summary: Delegation Token expire after enable delegation token framework Key: FLINK-37246 URL: https://issues.apache.org/jira/browse/FLINK-37246 Project: Flink

[jira] [Created] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics

2024-12-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36871: - Summary: Add internalRescale metrics to distinguish internalRestart Metrics Key: FLINK-36871 URL: https://issues.apache.org/jira/browse/FLINK-36871 Project: Flink

[jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors

2024-10-29 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36625: - Summary: Add helper classes for Lineage integration in connectors Key: FLINK-36625 URL: https://issues.apache.org/jira/browse/FLINK-36625 Project: Flink Is

[jira] [Created] (FLINK-36410) Improve Lineage Info Collection for flink app

2024-09-30 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36410: - Summary: Improve Lineage Info Collection for flink app Key: FLINK-36410 URL: https://issues.apache.org/jira/browse/FLINK-36410 Project: Flink Issue Type: S

[jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up

2024-08-28 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36169: - Summary: Support namespace level resource check before scaling up Key: FLINK-36169 URL: https://issues.apache.org/jira/browse/FLINK-36169 Project: Flink Is

[jira] [Created] (FLINK-35925) Remove hive connector from Flink main repo

2024-07-29 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35925: - Summary: Remove hive connector from Flink main repo Key: FLINK-35925 URL: https://issues.apache.org/jira/browse/FLINK-35925 Project: Flink Issue Type: Tech

[jira] [Created] (FLINK-35745) Add namespace convention doc for Flink lineage

2024-07-02 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35745: - Summary: Add namespace convention doc for Flink lineage Key: FLINK-35745 URL: https://issues.apache.org/jira/browse/FLINK-35745 Project: Flink Issue Type:

[jira] [Created] (FLINK-35326) Implement lineage interface for hive connector

2024-05-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35326: - Summary: Implement lineage interface for hive connector Key: FLINK-35326 URL: https://issues.apache.org/jira/browse/FLINK-35326 Project: Flink Issue Type:

[jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35015: - Summary: Flink Parquet Reader doesn't honor parquet configuration Key: FLINK-35015 URL: https://issues.apache.org/jira/browse/FLINK-35015 Project: Flink Is

[jira] [Created] (FLINK-34657) Implement Lineage Graph for streaming API use cases

2024-03-12 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34657: - Summary: Implement Lineage Graph for streaming API use cases Key: FLINK-34657 URL: https://issues.apache.org/jira/browse/FLINK-34657 Project: Flink Issue T

[jira] [Created] (FLINK-34468) Implement Lineage Interface in Cassandra Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34468: - Summary: Implement Lineage Interface in Cassandra Connector Key: FLINK-34468 URL: https://issues.apache.org/jira/browse/FLINK-34468 Project: Flink Issue Ty

[jira] [Created] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34467: - Summary: Implement Lineage Interface in Jdbc Connector Key: FLINK-34467 URL: https://issues.apache.org/jira/browse/FLINK-34467 Project: Flink Issue Type: S

[jira] [Created] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34466: - Summary: Implement Lineage Interface in Kafka Connector Key: FLINK-34466 URL: https://issues.apache.org/jira/browse/FLINK-34466 Project: Flink Issue Type:

[jira] [Created] (FLINK-34250) Add formats options to docs

2024-01-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34250: - Summary: Add formats options to docs Key: FLINK-34250 URL: https://issues.apache.org/jira/browse/FLINK-34250 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34007) Flink Job stuck in suspend state after recovery from failure in HA Mode

2024-01-05 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34007: - Summary: Flink Job stuck in suspend state after recovery from failure in HA Mode Key: FLINK-34007 URL: https://issues.apache.org/jira/browse/FLINK-34007 Project: Fl

[jira] [Created] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-33200: - Summary: ItemAt Expression validation fail in Table API due to type mismatch Key: FLINK-33200 URL: https://issues.apache.org/jira/browse/FLINK-33200 Project: Flink

[jira] [Created] (FLINK-33198) Add timestamp with local time zone support in Avro converters

2023-10-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-33198: - Summary: Add timestamp with local time zone support in Avro converters Key: FLINK-33198 URL: https://issues.apache.org/jira/browse/FLINK-33198 Project: Flink

[jira] [Created] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-08-07 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-32777: - Summary: Upgrade Okhttp version to support IPV6 Key: FLINK-32777 URL: https://issues.apache.org/jira/browse/FLINK-32777 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-32729) allow create an initial deployment with suspend state

2023-08-01 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-32729: - Summary: allow create an initial deployment with suspend state Key: FLINK-32729 URL: https://issues.apache.org/jira/browse/FLINK-32729 Project: Flink Issue

[jira] [Created] (FLINK-32597) Drop Yarn specific get rest endpoints

2023-07-16 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-32597: - Summary: Drop Yarn specific get rest endpoints Key: FLINK-32597 URL: https://issues.apache.org/jira/browse/FLINK-32597 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-31947) Enable stdout redirect in flink-console.sh

2023-04-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-31947: - Summary: Enable stdout redirect in flink-console.sh Key: FLINK-31947 URL: https://issues.apache.org/jira/browse/FLINK-31947 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions

2023-04-04 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-31730: - Summary: Support Ephemeral Storage in KubernetesConfigOptions Key: FLINK-31730 URL: https://issues.apache.org/jira/browse/FLINK-31730 Project: Flink Issue

[jira] [Created] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-11 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-30363: - Summary: Disable HadoppConf and Kerboros Decorator by default Key: FLINK-30363 URL: https://issues.apache.org/jira/browse/FLINK-30363 Project: Flink Issue

[jira] [Created] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

2022-10-17 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-29655: - Summary: Split Flink CRD from flink-kubernates-operator module Key: FLINK-29655 URL: https://issues.apache.org/jira/browse/FLINK-29655 Project: Flink Issue

[jira] [Created] (FLINK-29363) Allow web ui to fully redirect to other page

2022-09-20 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-29363: - Summary: Allow web ui to fully redirect to other page Key: FLINK-29363 URL: https://issues.apache.org/jira/browse/FLINK-29363 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-26539) Support dynamic partial features update in Cassandra connector

2022-03-08 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-26539: - Summary: Support dynamic partial features update in Cassandra connector Key: FLINK-26539 URL: https://issues.apache.org/jira/browse/FLINK-26539 Project: Flink

[jira] [Created] (FLINK-21474) Migrate FileSystemTableSource to DynamicTable Source Interface

2021-02-23 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-21474: - Summary: Migrate FileSystemTableSource to DynamicTable Source Interface Key: FLINK-21474 URL: https://issues.apache.org/jira/browse/FLINK-21474 Project: Flink

[jira] [Created] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

2021-02-23 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-21473: - Summary: Migrate ParquetInputFormat to BulkFormat interface Key: FLINK-21473 URL: https://issues.apache.org/jira/browse/FLINK-21473 Project: Flink Issue Ty

[jira] [Created] (FLINK-21107) Move test base classes from flink-tests to flink-test-utils

2021-01-23 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-21107: - Summary: Move test base classes from flink-tests to flink-test-utils Key: FLINK-21107 URL: https://issues.apache.org/jira/browse/FLINK-21107 Project: Flink

[jira] [Created] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-03 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-20833: - Summary: Expose pluggable interface for exception analysis and metrics reporting in Execution Graph Key: FLINK-20833 URL: https://issues.apache.org/jira/browse/FLINK-20833

[jira] [Created] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

2020-11-08 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-20054: - Summary: 3 Level List is not supported in ParquetInputFormat Key: FLINK-20054 URL: https://issues.apache.org/jira/browse/FLINK-20054 Project: Flink Issue T

[jira] [Created] (FLINK-16006) Add host blacklist support for Flink YarnResourceManager

2020-02-11 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-16006: - Summary: Add host blacklist support for Flink YarnResourceManager Key: FLINK-16006 URL: https://issues.apache.org/jira/browse/FLINK-16006 Project: Flink Is

[jira] [Created] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

2020-02-11 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-16005: - Summary: Propagate yarn.application.classpath from client to TaskManager Classpath Key: FLINK-16005 URL: https://issues.apache.org/jira/browse/FLINK-16005 Project:

[jira] [Created] (FLINK-15768) Consolidate executor related class into same module in flink-clients

2020-01-24 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-15768: - Summary: Consolidate executor related class into same module in flink-clients Key: FLINK-15768 URL: https://issues.apache.org/jira/browse/FLINK-15768 Project: Flink

[jira] [Created] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel

2019-12-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-15416: - Summary: Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel Key: FLINK-15416 URL: https://issues.apache.org/jira/browse/FLINK-15416 Project: Fl

[jira] [Created] (FLINK-15165) Flink Hive Upsert Support

2019-12-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-15165: - Summary: Flink Hive Upsert Support Key: FLINK-15165 URL: https://issues.apache.org/jira/browse/FLINK-15165 Project: Flink Issue Type: Wish Repo

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

2019-12-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-15164: - Summary: Introduce ParquetColumnarRowSplitReader to parquet format Key: FLINK-15164 URL: https://issues.apache.org/jira/browse/FLINK-15164 Project: Flink I

[jira] [Created] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

2019-11-27 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14982: - Summary: YARN IT Test Case log config is mistakenly disabled Key: FLINK-14982 URL: https://issues.apache.org/jira/browse/FLINK-14982 Project: Flink Issue T

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

2019-11-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14953: - Summary: Parquet table source should use schema type to build FilterPredicate Key: FLINK-14953 URL: https://issues.apache.org/jira/browse/FLINK-14953 Project: Flink

[jira] [Created] (FLINK-14906) Add function related method in CatalogManager

2019-11-21 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14906: - Summary: Add function related method in CatalogManager Key: FLINK-14906 URL: https://issues.apache.org/jira/browse/FLINK-14906 Project: Flink Issue Type: S

[jira] [Created] (FLINK-14841) Add create and drop function DDL in parser

2019-11-18 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14841: - Summary: Add create and drop function DDL in parser Key: FLINK-14841 URL: https://issues.apache.org/jira/browse/FLINK-14841 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-14837) Support Function DDL in TableEnvironment

2019-11-18 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14837: - Summary: Support Function DDL in TableEnvironment Key: FLINK-14837 URL: https://issues.apache.org/jira/browse/FLINK-14837 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-14711) Create Alter Function and Show Functions DDL

2019-11-11 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14711: - Summary: Create Alter Function and Show Functions DDL Key: FLINK-14711 URL: https://issues.apache.org/jira/browse/FLINK-14711 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-14215) Add Docs for TM and JM Environment Variable Setting

2019-09-25 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14215: - Summary: Add Docs for TM and JM Environment Variable Setting Key: FLINK-14215 URL: https://issues.apache.org/jira/browse/FLINK-14215 Project: Flink Issue T

[jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

2019-09-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14033: - Summary: Distributed caches are not registered in Yarn Per Job Cluster Mode Key: FLINK-14033 URL: https://issues.apache.org/jira/browse/FLINK-14033 Project: Flink

[jira] [Created] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-06 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-13132: - Summary: Allow ClusterEntrypoints use user main method to generate job graph Key: FLINK-13132 URL: https://issues.apache.org/jira/browse/FLINK-13132 Project: Flink

[jira] [Created] (FLINK-12343) Allow set hdfs.replication in FlinkYarnSessionCli

2019-04-26 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-12343: - Summary: Allow set hdfs.replication in FlinkYarnSessionCli Key: FLINK-12343 URL: https://issues.apache.org/jira/browse/FLINK-12343 Project: Flink Issue Typ

[jira] [Created] (FLINK-12342) Yarn Resource Manager Acquire Too Many Containers

2019-04-26 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-12342: - Summary: Yarn Resource Manager Acquire Too Many Containers Key: FLINK-12342 URL: https://issues.apache.org/jira/browse/FLINK-12342 Project: Flink Issue Typ

[jira] [Created] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

2019-03-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-11910: - Summary: Make Yarn Application Type Customizable with Flink Version Key: FLINK-11910 URL: https://issues.apache.org/jira/browse/FLINK-11910 Project: Flink

[jira] [Created] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-10868: - Summary: Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement Key: FLINK-10868 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Created] (FLINK-7493) Create Pinot Connector

2017-08-22 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7493: Summary: Create Pinot Connector Key: FLINK-7493 URL: https://issues.apache.org/jira/browse/FLINK-7493 Project: Flink Issue Type: New Feature Repo

[jira] [Created] (FLINK-7492) Memsql Connector

2017-08-22 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7492: Summary: Memsql Connector Key: FLINK-7492 URL: https://issues.apache.org/jira/browse/FLINK-7492 Project: Flink Issue Type: New Feature Reporter:

[jira] [Created] (FLINK-7179) Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

2017-07-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7179: Summary: Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor Key: FLINK-7179 URL: https://issues.apache.org/jira/browse/FL