Chen created FLINK-16592:
Summary: The doc of Streaming File Sink has a mistake of grammar
Key: FLINK-16592
URL: https://issues.apache.org/jira/browse/FLINK-16592
Project: Flink
Issue Type: Task
Shuyi Chen created FLINK-13372:
--
Summary: Timestamp conversion bug in non-blink Table/SQL runtime
Key: FLINK-13372
URL: https://issues.apache.org/jira/browse/FLINK-13372
Project: Flink
Issue Typ
Zhanghao Chen created FLINK-31936:
-
Summary: Support setting scale up max factor
Key: FLINK-31936
URL: https://issues.apache.org/jira/browse/FLINK-31936
Project: Flink
Issue Type: Improvement
Zhanghao Chen created FLINK-31991:
-
Summary: Update Autoscaler doc to reflect the changes brought by
the new source scaling logic
Key: FLINK-31991
URL: https://issues.apache.org/jira/browse/FLINK-31991
Zhanghao Chen created FLINK-32037:
-
Summary: The edge on Web UI is wrong after parallelism changes via
parallelism overrides or AdaptiveScheduler
Key: FLINK-32037
URL: https://issues.apache.org/jira/browse/FLINK-
Zhanghao Chen created FLINK-32124:
-
Summary: Add option to enable partition alignment for sources
Key: FLINK-32124
URL: https://issues.apache.org/jira/browse/FLINK-32124
Project: Flink
Issue
Zhanghao Chen created FLINK-32127:
-
Summary: Source busy time is inaccurate in many cases
Key: FLINK-32127
URL: https://issues.apache.org/jira/browse/FLINK-32127
Project: Flink
Issue Type: Im
Yu Chen created FLINK-32186:
---
Summary: Support subtask stack auto-search when redirecting from
subtask backpressure tab
Key: FLINK-32186
URL: https://issues.apache.org/jira/browse/FLINK-32186
Project: Flink
Xin Chen created FLINK-32188:
Summary: Does the custom connector not support pushing down
"where" query predicates to query fields of array type？
Key: FLINK-32188
URL: https://issues.apache.org/jira/browse/FLINK-32188
Mason Chen created FLINK-32197:
--
Summary: FLIP 246: Multi Cluster Kafka Source
Key: FLINK-32197
URL: https://issues.apache.org/jira/browse/FLINK-32197
Project: Flink
Issue Type: New Feature
Mason Chen created FLINK-32416:
--
Summary: Initial DynamicKafkaSource Implementation
Key: FLINK-32416
URL: https://issues.apache.org/jira/browse/FLINK-32416
Project: Flink
Issue Type: Sub-task
Mason Chen created FLINK-32417:
--
Summary: DynamicKafkaSource User Documentation
Key: FLINK-32417
URL: https://issues.apache.org/jira/browse/FLINK-32417
Project: Flink
Issue Type: Sub-task
Mason Chen created FLINK-32449:
--
Summary: Refactor state machine examples to remove Kafka dependency
Key: FLINK-32449
URL: https://issues.apache.org/jira/browse/FLINK-32449
Project: Flink
Issue
Mason Chen created FLINK-32451:
--
Summary: Refactor Confluent Schema Registry E2E Tests to remove
Kafka connector dependency
Key: FLINK-32451
URL: https://issues.apache.org/jira/browse/FLINK-32451
Project
Mason Chen created FLINK-32452:
--
Summary: Refactor SQL Client E2E Test to Remove Kafka SQL
Connector Dependency
Key: FLINK-32452
URL: https://issues.apache.org/jira/browse/FLINK-32452
Project: Flink
Mason Chen created FLINK-32507:
--
Summary: Document KafkaSink SinkWriterMetricGroup metrics
Key: FLINK-32507
URL: https://issues.apache.org/jira/browse/FLINK-32507
Project: Flink
Issue Type: Tech
Zili Chen created FLINK-32585:
-
Summary: Filter javax.xml.bind:jaxb-api false positive for Pulsar
connector
Key: FLINK-32585
URL: https://issues.apache.org/jira/browse/FLINK-32585
Project: Flink
Zili Chen created FLINK-32612:
-
Summary: Upgrade Pulsar version to 3.0.0 for the connector
Key: FLINK-32612
URL: https://issues.apache.org/jira/browse/FLINK-32612
Project: Flink
Issue Type: Impro
Zili Chen created FLINK-32625:
-
Summary: MiniClusterTestEnvironment supports customized
MiniClusterResourceConfiguration
Key: FLINK-32625
URL: https://issues.apache.org/jira/browse/FLINK-32625
Project: Fl
Yu Chen created FLINK-32754:
---
Summary: Using SplitEnumeratorContext.metricGroup() in
restoreEnumerator causes NPE
Key: FLINK-32754
URL: https://issues.apache.org/jira/browse/FLINK-32754
Project: Flink
Zhanghao Chen created FLINK-32820:
-
Summary: ParameterTool is mistakenly marked as deprecated
Key: FLINK-32820
URL: https://issues.apache.org/jira/browse/FLINK-32820
Project: Flink
Issue Type
Zhanghao Chen created FLINK-32821:
-
Summary: Streaming examples failed to execute due to error in
packaging
Key: FLINK-32821
URL: https://issues.apache.org/jira/browse/FLINK-32821
Project: Flink
Zhanghao Chen created FLINK-32822:
-
Summary: Add connector option to control whether to enable
auto-commit of offsets when checkpoints is enabled
Key: FLINK-32822
URL: https://issues.apache.org/jira/browse/FLINK-3
Zhanghao Chen created FLINK-32868:
-
Summary: Document the need to backport FLINK-30213 for using
autoscaler with older version Flinks
Key: FLINK-32868
URL: https://issues.apache.org/jira/browse/FLINK-32868
Zhanghao Chen created FLINK-32872:
-
Summary: Add option to control the default partitioner when the
parallelism of upstream and downstream operator does not match
Key: FLINK-32872
URL: https://issues.apache.org/ji
Mason Chen created FLINK-32892:
--
Summary: Upgrade kafka-clients dependency to 3.4.x
Key: FLINK-32892
URL: https://issues.apache.org/jira/browse/FLINK-32892
Project: Flink
Issue Type: Improvement
Mason Chen created FLINK-32893:
--
Summary: Make client.id configurable from KafkaSource
Key: FLINK-32893
URL: https://issues.apache.org/jira/browse/FLINK-32893
Project: Flink
Issue Type: Improvem
Zhanghao Chen created FLINK-32980:
-
Summary: Support env.java.opts.all & env.java.opts.cli config for
starting Session clusters
Key: FLINK-32980
URL: https://issues.apache.org/jira/browse/FLINK-32980
Zhanghao Chen created FLINK-32983:
-
Summary: Support setting env.java.opts.all & env.java.opts.cli
configs via dynamic properties on the CLI side
Key: FLINK-32983
URL: https://issues.apache.org/jira/browse/FLINK-3
Zhanghao Chen created FLINK-33123:
-
Summary: Wrong dynamic replacement of partitioner from FORWARD to
REBLANCE for autoscaler and adaptive scheduler and
Key: FLINK-33123
URL: https://issues.apache.org/jira/brows
Zhanghao Chen created FLINK-33146:
-
Summary: FLIP-363: Unify the Representation of TaskManager
Location in REST API and Web UI
Key: FLINK-33146
URL: https://issues.apache.org/jira/browse/FLINK-33146
P
Zhanghao Chen created FLINK-33147:
-
Summary: Introduce a new "endpoint" field in REST API to represent
TaskManager endpoint (host + port) and deprecate the "host" field
Key: FLINK-33147
URL: https://issues.apache.
Zhanghao Chen created FLINK-33148:
-
Summary: Update Web UI to adopt the new "endpoint" field in REST
API
Key: FLINK-33148
URL: https://issues.apache.org/jira/browse/FLINK-33148
Project: Flink
Zhanghao Chen created FLINK-33166:
-
Summary: Support setting root logger level by config
Key: FLINK-33166
URL: https://issues.apache.org/jira/browse/FLINK-33166
Project: Flink
Issue Type: Imp
Zhanghao Chen created FLINK-33204:
-
Summary: Add description for missing options in the all
jobmanager/taskmanager options section in document
Key: FLINK-33204
URL: https://issues.apache.org/jira/browse/FLINK-3320
Zhanghao Chen created FLINK-33205:
-
Summary: Replace Akka with Pekko in the description of
"pekko.ssl.enabled"
Key: FLINK-33205
URL: https://issues.apache.org/jira/browse/FLINK-33205
Project: Flink
Zhanghao Chen created FLINK-33221:
-
Summary: Add config options for administrator JVM options
Key: FLINK-33221
URL: https://issues.apache.org/jira/browse/FLINK-33221
Project: Flink
Issue Type
Yu Chen created FLINK-33230:
---
Summary: Support Expanding ExecutionGraph to StreamGraph in Flink
Key: FLINK-33230
URL: https://issues.apache.org/jira/browse/FLINK-33230
Project: Flink
Issue Type: Im
Zhanghao Chen created FLINK-33236:
-
Summary: Remove the unused
high-availability.zookeeper.path.running-registry option
Key: FLINK-33236
URL: https://issues.apache.org/jira/browse/FLINK-33236
Project:
Zhanghao Chen created FLINK-33240:
-
Summary: Generate docs for deprecated options as well
Key: FLINK-33240
URL: https://issues.apache.org/jira/browse/FLINK-33240
Project: Flink
Issue Type: Im
Zhanghao Chen created FLINK-33261:
-
Summary: FLIP-367: Support Setting Parallelism for Table/SQL
Sources
Key: FLINK-33261
URL: https://issues.apache.org/jira/browse/FLINK-33261
Project: Flink
Zhanghao Chen created FLINK-33262:
-
Summary: Extend source provider interfaces with the new
parallelism provider interface
Key: FLINK-33262
URL: https://issues.apache.org/jira/browse/FLINK-33262
Proje
Zhanghao Chen created FLINK-33263:
-
Summary: Implement ParallelismProvider for sources in Blink planner
Key: FLINK-33263
URL: https://issues.apache.org/jira/browse/FLINK-33263
Project: Flink
Zhanghao Chen created FLINK-33264:
-
Summary: Support source parallelism setting for DataGen connector
Key: FLINK-33264
URL: https://issues.apache.org/jira/browse/FLINK-33264
Project: Flink
Is
Zhanghao Chen created FLINK-33265:
-
Summary: Support source parallelism setting for Kafka connector
Key: FLINK-33265
URL: https://issues.apache.org/jira/browse/FLINK-33265
Project: Flink
Issu
Xin Chen created FLINK-33288:
Summary: Empty directory residue with appid name in
HA(highly-available) related directory of hdfs, not cleaned
Key: FLINK-33288
URL: https://issues.apache.org/jira/browse/FLINK-33288
Yu Chen created FLINK-33325:
---
Summary: FLIP-375: Built-in cross-platform powerful java profiler
Key: FLINK-33325
URL: https://issues.apache.org/jira/browse/FLINK-33325
Project: Flink
Issue Type: Im
Yang Chen created FLINK-33430:
-
Summary: Fix Test Failures
Key: FLINK-33430
URL: https://issues.apache.org/jira/browse/FLINK-33430
Project: Flink
Issue Type: Bug
Reporter: Yang Chen
Yu Chen created FLINK-33433:
---
Summary: Support invoke async-profiler on Jobmanager through REST
API
Key: FLINK-33433
URL: https://issues.apache.org/jira/browse/FLINK-33433
Project: Flink
Issue Typ
Yu Chen created FLINK-33434:
---
Summary: Support invoke async-profiler on Taskmanager through REST
API
Key: FLINK-33434
URL: https://issues.apache.org/jira/browse/FLINK-33434
Project: Flink
Issue Ty
Yu Chen created FLINK-33435:
---
Summary: The visualization and download capabilities of profiling
history
Key: FLINK-33435
URL: https://issues.apache.org/jira/browse/FLINK-33435
Project: Flink
Issu
Yu Chen created FLINK-33436:
---
Summary: Documentation on the built-in Profiler
Key: FLINK-33436
URL: https://issues.apache.org/jira/browse/FLINK-33436
Project: Flink
Issue Type: Sub-task
C
Yu Chen created FLINK-33474:
---
Summary: ShowPlan throws undefined exception In Flink Web Submit
Page
Key: FLINK-33474
URL: https://issues.apache.org/jira/browse/FLINK-33474
Project: Flink
Issue Typ
Xin Chen created FLINK-33483:
Summary: Why is “UNDEFINED” defined in the Flink task status?
Key: FLINK-33483
URL: https://issues.apache.org/jira/browse/FLINK-33483
Project: Flink
Issue Type: Impr
Mason Chen created FLINK-33575:
--
Summary: FLIP-394: Add Metrics for Connector Agnostic Autoscaling
Key: FLINK-33575
URL: https://issues.apache.org/jira/browse/FLINK-33575
Project: Flink
Issue Ty
Zili Chen created FLINK-33602:
-
Summary: Pulsar connector should be compatible with Flink 1.18
Key: FLINK-33602
URL: https://issues.apache.org/jira/browse/FLINK-33602
Project: Flink
Issue Type: B
Yu Chen created FLINK-33613:
---
Summary: Python UDF Runner process leak in Process Mode
Key: FLINK-33613
URL: https://issues.apache.org/jira/browse/FLINK-33613
Project: Flink
Issue Type: Bug
Zhanghao Chen created FLINK-33681:
-
Summary: Display source/sink numRecordsIn/Out & numBytesIn/Out on
UI
Key: FLINK-33681
URL: https://issues.apache.org/jira/browse/FLINK-33681
Project: Flink
Zhanghao Chen created FLINK-33682:
-
Summary: Reuse source operator input records/bytes metrics for
SourceOperatorStreamTask
Key: FLINK-33682
URL: https://issues.apache.org/jira/browse/FLINK-33682
Proj
Jiaxing Chen created FLINK-33724:
Summary: Application mode doesn't support multiple lines argument
Key: FLINK-33724
URL: https://issues.apache.org/jira/browse/FLINK-33724
Project: Flink
Issu
Jinsui Chen created FLINK-33873:
---
Summary: Create a Redis HyperLogLog Connector for Flink
Key: FLINK-33873
URL: https://issues.apache.org/jira/browse/FLINK-33873
Project: Flink
Issue Type: New
Zhanghao Chen created FLINK-33891:
-
Summary: Remove the obsolete SingleJobGraphStore
Key: FLINK-33891
URL: https://issues.apache.org/jira/browse/FLINK-33891
Project: Flink
Issue Type: Technic
Zhanghao Chen created FLINK-33940:
-
Summary: Update Update the auto-derivation rule of max parallelism
for enlarged upscaling space
Key: FLINK-33940
URL: https://issues.apache.org/jira/browse/FLINK-33940
Zhanghao Chen created FLINK-33962:
-
Summary: Chaining-agnostic OperatorID generation for improved
state compatibility on parallelism change
Key: FLINK-33962
URL: https://issues.apache.org/jira/browse/FLINK-33962
Zhanghao Chen created FLINK-33977:
-
Summary: Adaptive scheduler may not minimize the number of TMs
during downscaling
Key: FLINK-33977
URL: https://issues.apache.org/jira/browse/FLINK-33977
Project: F
Yu Chen created FLINK-34029:
---
Summary: Support different profiling mode on Flink WEB
Key: FLINK-34029
URL: https://issues.apache.org/jira/browse/FLINK-34029
Project: Flink
Issue Type: Sub-task
Mason Chen created FLINK-34064:
--
Summary: Expose JobManagerOperatorMetrics via REST API
Key: FLINK-34064
URL: https://issues.apache.org/jira/browse/FLINK-34064
Project: Flink
Issue Type: Improve
Zili Chen created FLINK-15967:
-
Summary: Examples use nightly kafka connector
Key: FLINK-15967
URL: https://issues.apache.org/jira/browse/FLINK-15967
Project: Flink
Issue Type: Improvement
Zili Chen created FLINK-15977:
-
Summary: Update pull request template to include Kubernetes as
deployment candidates
Key: FLINK-15977
URL: https://issues.apache.org/jira/browse/FLINK-15977
Project: Flink
Zili Chen created FLINK-16143:
-
Summary: Turn on more date time functions of blink planner
Key: FLINK-16143
URL: https://issues.apache.org/jira/browse/FLINK-16143
Project: Flink
Issue Type: New F
Zili Chen created FLINK-16185:
-
Summary: Support JSON functions provides by calcite for blink
planner
Key: FLINK-16185
URL: https://issues.apache.org/jira/browse/FLINK-16185
Project: Flink
Issue
Zili Chen created FLINK-16199:
-
Summary: Support IS JSON predicate for blink planner
Key: FLINK-16199
URL: https://issues.apache.org/jira/browse/FLINK-16199
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16200:
-
Summary: Support JSON_EXISTS for blink planner
Key: FLINK-16200
URL: https://issues.apache.org/jira/browse/FLINK-16200
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16201:
-
Summary: Support JSON_VALUE for blink planner
Key: FLINK-16201
URL: https://issues.apache.org/jira/browse/FLINK-16201
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16203:
-
Summary: Support JSON_OBJECT for blink planner
Key: FLINK-16203
URL: https://issues.apache.org/jira/browse/FLINK-16203
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16202:
-
Summary: Support JSON_QUERY for blink planner
Key: FLINK-16202
URL: https://issues.apache.org/jira/browse/FLINK-16202
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16204:
-
Summary: Support JSON_ARRAY for blink planner
Key: FLINK-16204
URL: https://issues.apache.org/jira/browse/FLINK-16204
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16205:
-
Summary: Support JSON_OBJECTAGG for blink planner
Key: FLINK-16205
URL: https://issues.apache.org/jira/browse/FLINK-16205
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16206:
-
Summary: Support JSON_ARRAYAGG for blink planner
Key: FLINK-16206
URL: https://issues.apache.org/jira/browse/FLINK-16206
Project: Flink
Issue Type: Sub-task
Zili Chen created FLINK-16427:
-
Summary: Remove directly throw ProgramInvocationExceptions in
RemoteStreamEnvironment
Key: FLINK-16427
URL: https://issues.apache.org/jira/browse/FLINK-16427
Project: Flink
Zili Chen created FLINK-16458:
-
Summary: Bump japicmp.referenceVersion to 1.10.0
Key: FLINK-16458
URL: https://issues.apache.org/jira/browse/FLINK-16458
Project: Flink
Issue Type: Bug
C
Zili Chen created FLINK-16562:
-
Summary: Handle JobManager termination future in place
Key: FLINK-16562
URL: https://issues.apache.org/jira/browse/FLINK-16562
Project: Flink
Issue Type: Improveme
Danny Chen created FLINK-16609:
--
Summary: Promotes the column name representation of SQL-CLI
Key: FLINK-16609
URL: https://issues.apache.org/jira/browse/FLINK-16609
Project: Flink
Issue Type: Im
Zili Chen created FLINK-16637:
-
Summary: Flink YARN app terminated before the client receives the
result
Key: FLINK-16637
URL: https://issues.apache.org/jira/browse/FLINK-16637
Project: Flink
Is
Chongchen Chen created FLINK-16724:
--
Summary: ListSerializer cannot serialize list which containers null
Key: FLINK-16724
URL: https://issues.apache.org/jira/browse/FLINK-16724
Project: Flink
Danny Chen created FLINK-17042:
--
Summary: Jackson version conflict for Flink 1.9
Key: FLINK-17042
URL: https://issues.apache.org/jira/browse/FLINK-17042
Project: Flink
Issue Type: Improvement
Danny Chen created FLINK-17101:
--
Summary: Supports dynamic table options for Flink SQL
Key: FLINK-17101
URL: https://issues.apache.org/jira/browse/FLINK-17101
Project: Flink
Issue Type: New Feat
Danny Chen created FLINK-17103:
--
Summary: Supports dynamic table options for Blink planner
Key: FLINK-17103
URL: https://issues.apache.org/jira/browse/FLINK-17103
Project: Flink
Issue Type: Sub-
Kai Chen created FLINK-17116:
Summary: support UsernamePasswordCredentials for elasticsearch
sink via SQL DDL
Key: FLINK-17116
URL: https://issues.apache.org/jira/browse/FLINK-17116
Project: Flink
Kai Chen created FLINK-17133:
Summary: Support CsvParser Features for CSV format via SQL DDL
Key: FLINK-17133
URL: https://issues.apache.org/jira/browse/FLINK-17133
Project: Flink
Issue Type: New
Danny Chen created FLINK-17147:
--
Summary: Remove dynamic table options from table source table
digest
Key: FLINK-17147
URL: https://issues.apache.org/jira/browse/FLINK-17147
Project: Flink
Issu
Danny Chen created FLINK-17173:
--
Summary: Supports query hint to config "IdleStateRetentionTime"
per query in SQL
Key: FLINK-17173
URL: https://issues.apache.org/jira/browse/FLINK-17173
Project: Flink
Zili Chen created FLINK-14237:
-
Summary: No need to rename shipped Flink jar
Key: FLINK-14237
URL: https://issues.apache.org/jira/browse/FLINK-14237
Project: Flink
Issue Type: Improvement
Zili Chen created FLINK-14263:
-
Summary: Extract static method from ClusterClient to ClientUtils
Key: FLINK-14263
URL: https://issues.apache.org/jira/browse/FLINK-14263
Project: Flink
Issue Type:
Danny Chen created FLINK-14338:
--
Summary: Upgrade Calcite version to 1.22 for Flink SQL
Key: FLINK-14338
URL: https://issues.apache.org/jira/browse/FLINK-14338
Project: Flink
Issue Type: Improve
Zili Chen created FLINK-14343:
-
Summary: Remove uncompleted YARNHighAvailabilityService
Key: FLINK-14343
URL: https://issues.apache.org/jira/browse/FLINK-14343
Project: Flink
Issue Type: Task
Danny Chen created FLINK-14386:
--
Summary: Support computed column for create table statement
Key: FLINK-14386
URL: https://issues.apache.org/jira/browse/FLINK-14386
Project: Flink
Issue Type: Im
Zili Chen created FLINK-14392:
-
Summary: Introduce JobClient API(FLIP-74)
Key: FLINK-14392
URL: https://issues.apache.org/jira/browse/FLINK-14392
Project: Flink
Issue Type: New Feature
Zili Chen created FLINK-14434:
-
Summary: Dispatcher#createJobManagerRunner should returns on
creation succeed, not after startJobManagerRunner
Key: FLINK-14434
URL: https://issues.apache.org/jira/browse/FLINK-14434
Zili Chen created FLINK-14456:
-
Summary: Remove or shift down all field in ClusterClient
Key: FLINK-14456
URL: https://issues.apache.org/jira/browse/FLINK-14456
Project: Flink
Issue Type: Sub-tas
1 - 100 of 430 matches
Mail list logo
