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
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
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
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
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-
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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:
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:
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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:
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
49 matches
Mail list logo