Zhanghao Chen created FLINK-38078:
-
Summary: DataStream API Execution Configuration doc contains
deleted API usage
Key: FLINK-38078
URL: https://issues.apache.org/jira/browse/FLINK-38078
Project: Flin
Yi Chen created FLINK-37911:
---
Summary: [Helm] Reorganize Helm chart templates
Key: FLINK-37911
URL: https://issues.apache.org/jira/browse/FLINK-37911
Project: Flink
Issue Type: Improvement
Xin Chen created FLINK-37873:
Summary: 【Hbase-connector】Enable buffer flush, specify a
non-existent table when writing data to hbase, the Flink task displays
successful
Key: FLINK-37873
URL: https://issues.apache.org
Yi Chen created FLINK-37744:
---
Summary: [Helm] Add Helm lint and test CI
Key: FLINK-37744
URL: https://issues.apache.org/jira/browse/FLINK-37744
Project: Flink
Issue Type: Improvement
Re
Zhanghao Chen created FLINK-37735:
-
Summary: Replace class.newInstance with constructor.newInstance
Key: FLINK-37735
URL: https://issues.apache.org/jira/browse/FLINK-37735
Project: Flink
Issu
Shuyi Chen created FLINK-37727:
--
Summary: java.lang.UnsatisfiedLinkError error on
pemja.core.PythonInterpreter$MainInterpreter.initialize()
Key: FLINK-37727
URL: https://issues.apache.org/jira/browse/FLINK-37727
Shuyi Chen created FLINK-37728:
--
Summary: Incorrect import in EmbeddedPythonWindowOperator.java
Key: FLINK-37728
URL: https://issues.apache.org/jira/browse/FLINK-37728
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-37722:
-
Summary: Eliminate redundant field initialization when
deserializing POJOs
Key: FLINK-37722
URL: https://issues.apache.org/jira/browse/FLINK-37722
Project: Flink
Zhanghao Chen created FLINK-37681:
-
Summary: Add benchmark for subclass seder with PojoSerializer in
Flink benchmark
Key: FLINK-37681
URL: https://issues.apache.org/jira/browse/FLINK-37681
Project: Fl
Zhanghao Chen created FLINK-37680:
-
Summary: Add subclass cache for PojoSerializer
Key: FLINK-37680
URL: https://issues.apache.org/jira/browse/FLINK-37680
Project: Flink
Issue Type: Sub-task
Zhanghao Chen created FLINK-37679:
-
Summary: Improve the performance of Flink serialization
Key: FLINK-37679
URL: https://issues.apache.org/jira/browse/FLINK-37679
Project: Flink
Issue Type:
Yi Chen created FLINK-37669:
---
Summary: [HELM] Add Helm chart unit tests to flink kubernetes
operator
Key: FLINK-37669
URL: https://issues.apache.org/jira/browse/FLINK-37669
Project: Flink
Issue Ty
Zhanghao Chen created FLINK-37661:
-
Summary: Remove Kryo serializer reference data from version 1.x
Key: FLINK-37661
URL: https://issues.apache.org/jira/browse/FLINK-37661
Project: Flink
Issu
Zhanghao Chen created FLINK-37660:
-
Summary: Reenable Kryo serializer upgrade tests
Key: FLINK-37660
URL: https://issues.apache.org/jira/browse/FLINK-37660
Project: Flink
Issue Type: Technica
Zhanghao Chen created FLINK-37659:
-
Summary: Flink 2.0: update reference data for Migration Tests
Key: FLINK-37659
URL: https://issues.apache.org/jira/browse/FLINK-37659
Project: Flink
Issue
Shuyi Chen created FLINK-37366:
--
Summary: Allow configurable retry for Kafka topic metadata fetch
Key: FLINK-37366
URL: https://issues.apache.org/jira/browse/FLINK-37366
Project: Flink
Issue Typ
Zhanghao Chen created FLINK-37249:
-
Summary: Remove unnecessary --add-opens/--add-exports for
java.base/sun.net.util
Key: FLINK-37249
URL: https://issues.apache.org/jira/browse/FLINK-37249
Project: Fl
Zhanghao Chen created FLINK-37226:
-
Summary: Replace deprecated methods in the DataStream API
introduction doc
Key: FLINK-37226
URL: https://issues.apache.org/jira/browse/FLINK-37226
Project: Flink
Zhanghao Chen created FLINK-37225:
-
Summary: Remove remaining test resources of Gelly
Key: FLINK-37225
URL: https://issues.apache.org/jira/browse/FLINK-37225
Project: Flink
Issue Type: Techni
Shuyi Chen created FLINK-37168:
--
Summary: TimerRegistrationAction in unregisteredTimers is not
cleaned up properly after the timers are registered
Key: FLINK-37168
URL: https://issues.apache.org/jira/browse/FLINK-371
Zhanghao Chen created FLINK-37101:
-
Summary: Remove internal set methods in SerializerConfig
Key: FLINK-37101
URL: https://issues.apache.org/jira/browse/FLINK-37101
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-37024:
-
Summary: Task can be stuck in deploying state forever when
canceling job/failover
Key: FLINK-37024
URL: https://issues.apache.org/jira/browse/FLINK-37024
Project: F
Zhanghao Chen created FLINK-37015:
-
Summary: Revise serialization doc to reflect the 2.0 breaking
changes properly
Key: FLINK-37015
URL: https://issues.apache.org/jira/browse/FLINK-37015
Project: Flin
Zhanghao Chen created FLINK-36905:
-
Summary: Update Chinese document to reflect the changes of FLIP-398
Key: FLINK-36905
URL: https://issues.apache.org/jira/browse/FLINK-36905
Project: Flink
Zhanghao Chen created FLINK-36904:
-
Summary: Fix doc error on how to programmatically register a
3rd-party serializer
Key: FLINK-36904
URL: https://issues.apache.org/jira/browse/FLINK-36904
Project: F
Zhanghao Chen created FLINK-36903:
-
Summary: Add switch for built-in serialization support for common
collection types
Key: FLINK-36903
URL: https://issues.apache.org/jira/browse/FLINK-36903
Project:
Shuyi Chen created FLINK-36874:
--
Summary: KafkaSourceBuilder in pyflink did not implement
setDeserializer() method
Key: FLINK-36874
URL: https://issues.apache.org/jira/browse/FLINK-36874
Project: Flink
Shuyi Chen created FLINK-36686:
--
Summary: allow customizing envs for flink-webhook container
Key: FLINK-36686
URL: https://issues.apache.org/jira/browse/FLINK-36686
Project: Flink
Issue Type: Im
Shuyi Chen created FLINK-36685:
--
Summary: Enable update/create operation on flinkdeployment
resource in mutation webhook
Key: FLINK-36685
URL: https://issues.apache.org/jira/browse/FLINK-36685
Project: F
Luke Chen created FLINK-36677:
-
Summary: Instruct users to change log level dynamically in operator
Key: FLINK-36677
URL: https://issues.apache.org/jira/browse/FLINK-36677
Project: Flink
Issue Ty
ZhengYu Chen created FLINK-36586:
Summary: Upgrade Flink CDC dependency to Flink 1.19+
Key: FLINK-36586
URL: https://issues.apache.org/jira/browse/FLINK-36586
Project: Flink
Issue Type: New F
Yu Chen created FLINK-36127:
---
Summary: Support sorting watermark on flink web
Key: FLINK-36127
URL: https://issues.apache.org/jira/browse/FLINK-36127
Project: Flink
Issue Type: Improvement
ZhengYu Chen created FLINK-36061:
Summary: Support Apache iceberg for pipeline connector
Key: FLINK-36061
URL: https://issues.apache.org/jira/browse/FLINK-36061
Project: Flink
Issue Type: New
Kai Chen created FLINK-35895:
Summary: flink parquet vectorized reader should use
readNextFilteredRowGroup() instead of readNextRowGroup()
Key: FLINK-35895
URL: https://issues.apache.org/jira/browse/FLINK-35895
Yu Chen created FLINK-35832:
---
Summary: IFNULL returns error result in Flink SQL
Key: FLINK-35832
URL: https://issues.apache.org/jira/browse/FLINK-35832
Project: Flink
Issue Type: Bug
Comp
Luke Chen created FLINK-35653:
-
Summary: "fraud detection" example missed "env.execute" explanation
Key: FLINK-35653
URL: https://issues.apache.org/jira/browse/FLINK-35653
Project: Flink
Issue Ty
ZhengYu Chen created FLINK-35592:
Summary: MysqlDebeziumTimeConverter miss timezone convert to
timestamp
Key: FLINK-35592
URL: https://issues.apache.org/jira/browse/FLINK-35592
Project: Flink
Zhanghao Chen created FLINK-3:
-
Summary: Serializing List with null values throws NPE
Key: FLINK-3
URL: https://issues.apache.org/jira/browse/FLINK-3
Project: Flink
Issue Type: Bu
Zhanghao Chen created FLINK-35458:
-
Summary: Add serializer upgrade test for set serializer
Key: FLINK-35458
URL: https://issues.apache.org/jira/browse/FLINK-35458
Project: Flink
Issue Type:
Haifei Chen created FLINK-35270:
---
Summary: Enrich information in logs, making it easier for debugging
Key: FLINK-35270
URL: https://issues.apache.org/jira/browse/FLINK-35270
Project: Flink
Issu
Mason Chen created FLINK-35247:
--
Summary: Upgrade spotless apply to `2.41.1` in
flink-connector-parent to work with Java 21
Key: FLINK-35247
URL: https://issues.apache.org/jira/browse/FLINK-35247
Project
ZhengYu Chen created FLINK-35173:
Summary: Debezium Custom Time Serializer
Key: FLINK-35173
URL: https://issues.apache.org/jira/browse/FLINK-35173
Project: Flink
Issue Type: Improvement
Zhanghao Chen created FLINK-35145:
-
Summary: Add timeout for cluster termination
Key: FLINK-35145
URL: https://issues.apache.org/jira/browse/FLINK-35145
Project: Flink
Issue Type: Improvement
Mason Chen created FLINK-35122:
--
Summary: Implement Watermark Alignment for DynamicKafkaSource
Key: FLINK-35122
URL: https://issues.apache.org/jira/browse/FLINK-35122
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-35068:
-
Summary: Introduce built-in serialization support for Set
Key: FLINK-35068
URL: https://issues.apache.org/jira/browse/FLINK-35068
Project: Flink
Issue Type
Yu Chen created FLINK-34968:
---
Summary: Update flink-web copyright to 2024
Key: FLINK-34968
URL: https://issues.apache.org/jira/browse/FLINK-34968
Project: Flink
Issue Type: Improvement
Co
ZhengYu Chen created FLINK-34904:
Summary: [Feature] submit Flink CDC pipeline job to yarn
application cluster.
Key: FLINK-34904
URL: https://issues.apache.org/jira/browse/FLINK-34904
Project: Flink
Haifei Chen created FLINK-34721:
---
Summary: An grammar error occurs in the Barrier test file
Key: FLINK-34721
URL: https://issues.apache.org/jira/browse/FLINK-34721
Project: Flink
Issue Type: Im
Yu Chen created FLINK-34622:
---
Summary: Typo of execution_mode configuration name in Chinese
document
Key: FLINK-34622
URL: https://issues.apache.org/jira/browse/FLINK-34622
Project: Flink
Issue Ty
Mason Chen created FLINK-34445:
--
Summary: Integrate new endpoint with Flink UI metrics section
Key: FLINK-34445
URL: https://issues.apache.org/jira/browse/FLINK-34445
Project: Flink
Issue Type:
Mason Chen created FLINK-3:
--
Summary: Add new endpoint handler to flink
Key: FLINK-3
URL: https://issues.apache.org/jira/browse/FLINK-3
Project: Flink
Issue Type: Sub-task
Zhanghao Chen created FLINK-34354:
-
Summary: Release Testing: Verify FLINK-34037 Improve Serialization
Configuration and Usage in Flink
Key: FLINK-34354
URL: https://issues.apache.org/jira/browse/FLINK-34354
Zhanghao Chen created FLINK-34328:
-
Summary: Release Testing Instructions: Verify FLINK-34037 Improve
Serialization Configuration And Usage In Flink
Key: FLINK-34328
URL: https://issues.apache.org/jira/browse/FLIN
Mason Chen created FLINK-34327:
--
Summary: Use maven wrapper in operator build
Key: FLINK-34327
URL: https://issues.apache.org/jira/browse/FLINK-34327
Project: Flink
Issue Type: Improvement
Zhanghao Chen created FLINK-34270:
-
Summary: Update connector developer-facing doc
Key: FLINK-34270
URL: https://issues.apache.org/jira/browse/FLINK-34270
Project: Flink
Issue Type: Sub-task
Zhanghao Chen created FLINK-34239:
-
Summary: Introduce a deep copy method of SerializerConfig for
merging with Table configs in
org.apache.flink.table.catalog.DataTypeFactoryImpl
Key: FLINK-34239
URL: https://is
Zhanghao Chen created FLINK-34230:
-
Summary: Update flink-docs README: add -Pskip-webui-build to the
config doc generation command
Key: FLINK-34230
URL: https://issues.apache.org/jira/browse/FLINK-34230
Zhanghao Chen created FLINK-34217:
-
Summary: Update Serialization-related doc with the new way of
configuration
Key: FLINK-34217
URL: https://issues.apache.org/jira/browse/FLINK-34217
Project: Flink
Mason Chen created FLINK-34127:
--
Summary: Kafka connector repo runs a duplicate of
`IntegrationTests` framework tests
Key: FLINK-34127
URL: https://issues.apache.org/jira/browse/FLINK-34127
Project: Flin
Zhanghao Chen created FLINK-34125:
-
Summary: Flink 2.0: Remove deprecated serialization config methods
and options
Key: FLINK-34125
URL: https://issues.apache.org/jira/browse/FLINK-34125
Project: Flin
Zhanghao Chen created FLINK-34124:
-
Summary: Flink 2.0: Disable Kyro by default
Key: FLINK-34124
URL: https://issues.apache.org/jira/browse/FLINK-34124
Project: Flink
Issue Type: Sub-task
Zhanghao Chen created FLINK-34123:
-
Summary: Introduce built-in serializers for common composited data
types
Key: FLINK-34123
URL: https://issues.apache.org/jira/browse/FLINK-34123
Project: Flink
Zhanghao Chen created FLINK-34122:
-
Summary: Deprecate old serialization config methods and options
Key: FLINK-34122
URL: https://issues.apache.org/jira/browse/FLINK-34122
Project: Flink
Issu
Zhanghao Chen created FLINK-34121:
-
Summary: Introduce pipeline.force-kryo-avro to control whether to
force registration of Avro serializer with Kryo
Key: FLINK-34121
URL: https://issues.apache.org/jira/browse/FLI
Zhanghao Chen created FLINK-34120:
-
Summary: Introduce unified serialization config option for all
Kryo, POJO and customized serializers
Key: FLINK-34120
URL: https://issues.apache.org/jira/browse/FLINK-34120
Zhanghao Chen created FLINK-34103:
-
Summary: AsyncIO example failed to run as DataGen Connector is not
bundled
Key: FLINK-34103
URL: https://issues.apache.org/jira/browse/FLINK-34103
Project: Flink
Yu Chen created FLINK-34099:
---
Summary:
CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable
on AZP
Key: FLINK-34099
URL: https://issues.apache.org/jira/browse/FLINK-34099
Project
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
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
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
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-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-33891:
-
Summary: Remove the obsolete SingleJobGraphStore
Key: FLINK-33891
URL: https://issues.apache.org/jira/browse/FLINK-33891
Project: Flink
Issue Type: Technic
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
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
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
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
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
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
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
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
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
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-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-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-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
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-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
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
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
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-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-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-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-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-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:
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-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
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-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
1 - 100 of 430 matches
Mail list logo
