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:
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:
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:
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
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:
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:
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
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:
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
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:
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
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:
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:
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
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-33265:
-
Summary: Support source parallelism setting for Kafka connector
Key: FLINK-33265
URL: https://issues.apache.org/jira/browse/FLINK-33265
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
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
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:
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
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
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:
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:
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-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:
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
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:
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:
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-32872:
-
Summary: Add option to control the default partitioner when the
parallelism of upstream and downstream operator does not match
Key: FLINK-32872
URL:
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-32822:
-
Summary: Add connector option to control whether to enable
auto-commit of offsets when checkpoints is enabled
Key: FLINK-32822
URL:
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-32820:
-
Summary: ParameterTool is mistakenly marked as deprecated
Key: FLINK-32820
URL: https://issues.apache.org/jira/browse/FLINK-32820
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:
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-32037:
-
Summary: The edge on Web UI is wrong after parallelism changes via
parallelism overrides or AdaptiveScheduler
Key: FLINK-32037
URL:
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-31936:
-
Summary: Support setting scale up max factor
Key: FLINK-31936
URL: https://issues.apache.org/jira/browse/FLINK-31936
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-31827:
-
Summary: Incorrect estimation of the target data rate of a vertex
when only a subset of its upstream vertex's output is consumed
Key: FLINK-31827
URL:
Zhanghao Chen created FLINK-31826:
-
Summary: Incorrect estimation of the target data rate of a vertex
when only a subset of its upstream vertex's output is consumed
Key: FLINK-31826
URL:
Zhanghao Chen created FLINK-31769:
-
Summary: Add percentiles to aggregated metrics
Key: FLINK-31769
URL: https://issues.apache.org/jira/browse/FLINK-31769
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-31358:
-
Summary: Display consumed split/partition/queue info on Web UI
Key: FLINK-31358
URL: https://issues.apache.org/jira/browse/FLINK-31358
Project: Flink
Zhanghao Chen created FLINK-31245:
-
Summary: Adaptive scheduler does not reset the state of
GlobalAggregateManager when rescaling
Key: FLINK-31245
URL: https://issues.apache.org/jira/browse/FLINK-31245
Zhanghao Chen created FLINK-30829:
-
Summary: Make the backpressure tab could be sort by the
backpressure level
Key: FLINK-30829
URL: https://issues.apache.org/jira/browse/FLINK-30829
Project: Flink
Zhanghao Chen created FLINK-30513:
-
Summary: HA storage dir leaks on cluster termination
Key: FLINK-30513
URL: https://issues.apache.org/jira/browse/FLINK-30513
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-30101:
-
Summary: YARN client should
Key: FLINK-30101
URL: https://issues.apache.org/jira/browse/FLINK-30101
Project: Flink
Issue Type: Improvement
Zhanghao Chen created FLINK-29615:
-
Summary: MetricStore does not remove metrics of nonexistent
subtasks when adaptive scheduler lowers job parallelism
Key: FLINK-29615
URL:
Zhanghao Chen created FLINK-28973:
-
Summary: Extending /jars/:jarid/plan API to support setting Flink
configs
Key: FLINK-28973
URL: https://issues.apache.org/jira/browse/FLINK-28973
Project: Flink
Zhanghao Chen created FLINK-27060:
-
Summary: Extending /jars/:jarid/run API to
Key: FLINK-27060
URL: https://issues.apache.org/jira/browse/FLINK-27060
Project: Flink
Issue Type: Improvement
Zhanghao Chen created FLINK-27056:
-
Summary: "pipeline.time-characteristic" should be deprecated and
have EVENT_TIME as default value
Key: FLINK-27056
URL: https://issues.apache.org/jira/browse/FLINK-27056
Zhanghao Chen created FLINK-25372:
-
Summary: Add thread dump feature for jobmanager
Key: FLINK-25372
URL: https://issues.apache.org/jira/browse/FLINK-25372
Project: Flink
Issue Type:
Zhanghao Chen created FLINK-25371:
-
Summary: Include port as part of the host info for subtask detail
panel on Web UI
Key: FLINK-25371
URL: https://issues.apache.org/jira/browse/FLINK-25371
Project:
Zhanghao Chen created FLINK-24223:
-
Summary: Client should throw exception to warn users when the
configurations set by program options conflict with those set by -D
Key: FLINK-24223
URL:
65 matches
Mail list logo
