Yun Tang created FLINK-34967:
Summary: Update Website copyright footer to 2024
Key: FLINK-34967
URL: https://issues.apache.org/jira/browse/FLINK-34967
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-34617:
Summary: Correct the Javadoc of
org.apache.flink.api.common.time.Time
Key: FLINK-34617
URL: https://issues.apache.org/jira/browse/FLINK-34617
Project: Flink
Issue
Yun Tang created FLINK-34390:
Summary: Release Testing: Verify FLINK-33325 Built-in
cross-platform powerful java profiler
Key: FLINK-34390
URL: https://issues.apache.org/jira/browse/FLINK-34390
Project:
Yun Tang created FLINK-34072:
Summary: Use JAVA_RUN in shell scripts
Key: FLINK-34072
URL: https://issues.apache.org/jira/browse/FLINK-34072
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-33707:
Summary: Verify the snapshot migration on Java17
Key: FLINK-33707
URL: https://issues.apache.org/jira/browse/FLINK-33707
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-33699:
Summary: Verify the snapshot migration on Java21
Key: FLINK-33699
URL: https://issues.apache.org/jira/browse/FLINK-33699
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-33598:
Summary: Watch HA configmap via name instead of lables to reduce
pressure on APIserver
Key: FLINK-33598
URL: https://issues.apache.org/jira/browse/FLINK-33598
Project:
Yun Tang created FLINK-32611:
Summary: Redirect to Apache Paimon's link instead of legacy flink
table store
Key: FLINK-32611
URL: https://issues.apache.org/jira/browse/FLINK-32611
Project: Flink
Yun Tang created FLINK-32145:
Summary: Fix incorrect docker image links of specific versions in
flink-web site
Key: FLINK-32145
URL: https://issues.apache.org/jira/browse/FLINK-32145
Project: Flink
Yun Tang created FLINK-32027:
Summary: Batch jobs could hang at shuffle phase when max
parallelism is really large
Key: FLINK-32027
URL: https://issues.apache.org/jira/browse/FLINK-32027
Project: Flink
Yun Tang created FLINK-31706:
Summary: The default source parallelism should be the same as
execution's default parallelism under adaptive batch scheduler
Key: FLINK-31706
URL:
Yun Tang created FLINK-31683:
Summary: Align the outdated Chinese filesystem connector docs
Key: FLINK-31683
URL: https://issues.apache.org/jira/browse/FLINK-31683
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-31324:
Summary: Broken SingleThreadFetcherManager constructor API
Key: FLINK-31324
URL: https://issues.apache.org/jira/browse/FLINK-31324
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-31283:
Summary: Correct the description of building from source with
scala version
Key: FLINK-31283
URL: https://issues.apache.org/jira/browse/FLINK-31283
Project: Flink
Yun Tang created FLINK-31226:
Summary: Bump the FRocksDB version in table-store's lookup module
Key: FLINK-31226
URL: https://issues.apache.org/jira/browse/FLINK-31226
Project: Flink
Issue Type:
Yun Tang created FLINK-30739:
Summary: SqlGatewayRestEndpointStatementITCase failed with
NullPointer
Key: FLINK-30739
URL: https://issues.apache.org/jira/browse/FLINK-30739
Project: Flink
Issue
Yun Tang created FLINK-30724:
Summary: Update doc of kafka per-partition watermark to FLIP-27
source
Key: FLINK-30724
URL: https://issues.apache.org/jira/browse/FLINK-30724
Project: Flink
Issue
Yun Tang created FLINK-30647:
Summary: Add human readable datetime of watermark column in the
web for better debug experience
Key: FLINK-30647
URL: https://issues.apache.org/jira/browse/FLINK-30647
Yun Tang created FLINK-30535:
Summary: Introduce TTL state based benchmarks
Key: FLINK-30535
URL: https://issues.apache.org/jira/browse/FLINK-30535
Project: Flink
Issue Type: New Feature
Yun Tang created FLINK-30457:
Summary: Introduce period compaction to FRocksDB
Key: FLINK-30457
URL: https://issues.apache.org/jira/browse/FLINK-30457
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-30392:
Summary: Increase the default value of
cluster.thread-dump.stacktrace-max-depth
Key: FLINK-30392
URL: https://issues.apache.org/jira/browse/FLINK-30392
Project: Flink
Yun Tang created FLINK-30367:
Summary: Enrich the thread dump info with deeper stack
Key: FLINK-30367
URL: https://issues.apache.org/jira/browse/FLINK-30367
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-30253:
Summary: Introduce io executor for standalone checkpoint store
Key: FLINK-30253
URL: https://issues.apache.org/jira/browse/FLINK-30253
Project: Flink
Issue Type:
Yun Tang created FLINK-29998:
Summary: Make the backpressure tab could be sort by the busy
percent
Key: FLINK-29998
URL: https://issues.apache.org/jira/browse/FLINK-29998
Project: Flink
Issue
Yun Tang created FLINK-29997:
Summary: Link to the taskmanager page in the expired sub-task of
checkpoint tab
Key: FLINK-29997
URL: https://issues.apache.org/jira/browse/FLINK-29997
Project: Flink
Yun Tang created FLINK-29996:
Summary: Link to the task manager's thread dump page in the
backpressure tab
Key: FLINK-29996
URL: https://issues.apache.org/jira/browse/FLINK-29996
Project: Flink
Yun Tang created FLINK-29995:
Summary: Improve the usability of job analysis for backpressure,
expired checkpoints and exceptions
Key: FLINK-29995
URL: https://issues.apache.org/jira/browse/FLINK-29995
Yun Tang created FLINK-29410:
Summary: Add checks to guarantee the non-deprecated options not
conflicting with standard YAML
Key: FLINK-29410
URL: https://issues.apache.org/jira/browse/FLINK-29410
Yun Tang created FLINK-29130:
Summary: Correct the doc description of
state.backend.local-recovery
Key: FLINK-29130
URL: https://issues.apache.org/jira/browse/FLINK-29130
Project: Flink
Issue
Yun Tang created FLINK-28863:
Summary: Snapshot result of RocksDB native savepoint should have
empty shared-state
Key: FLINK-28863
URL: https://issues.apache.org/jira/browse/FLINK-28863
Project: Flink
Yun Tang created FLINK-28732:
Summary: Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API
Key: FLINK-28732
URL: https://issues.apache.org/jira/browse/FLINK-28732
Project: Flink
Issue Type:
Yun Tang created FLINK-27531:
Summary: Add explict doc on data consistency problem of RocksDB's
map state iterator
Key: FLINK-27531
URL: https://issues.apache.org/jira/browse/FLINK-27531
Project: Flink
Yun Tang created FLINK-27295:
Summary: UnalignedCheckpointITCase failed due to
OperatorCoordinatorHolder cannot mark checkpoint
Key: FLINK-27295
URL: https://issues.apache.org/jira/browse/FLINK-27295
Yun Tang created FLINK-26985:
Summary: With legacy restore mode, incremantal checkpoints would
be deleted by mistake
Key: FLINK-26985
URL: https://issues.apache.org/jira/browse/FLINK-26985
Project: Flink
Yun Tang created FLINK-26882:
Summary: Unaligned checkpoint with 0s timeout would fail
RescaleCheckpointManuallyITCase
Key: FLINK-26882
URL: https://issues.apache.org/jira/browse/FLINK-26882
Project:
Yun Tang created FLINK-26650:
Summary: Avoid to print stack trace for checkpoint trigger failure
if not all tasks are started
Key: FLINK-26650
URL: https://issues.apache.org/jira/browse/FLINK-26650
Yun Tang created FLINK-26575:
Summary: Improve the info message when restoring keyed state
backend
Key: FLINK-26575
URL: https://issues.apache.org/jira/browse/FLINK-26575
Project: Flink
Issue
Yun Tang created FLINK-26550:
Summary: Correct the information of checkpoint failure
Key: FLINK-26550
URL: https://issues.apache.org/jira/browse/FLINK-26550
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-26464:
Summary: Introduce new metrics to represent full checkpoint size
Key: FLINK-26464
URL: https://issues.apache.org/jira/browse/FLINK-26464
Project: Flink
Issue Type:
Yun Tang created FLINK-26338:
Summary: Add documentation of savepoint type on Command-Line part
Key: FLINK-26338
URL: https://issues.apache.org/jira/browse/FLINK-26338
Project: Flink
Issue Type:
Yun Tang created FLINK-26101:
Summary: Avoid shared state registry to discard duplicate
changelog state
Key: FLINK-26101
URL: https://issues.apache.org/jira/browse/FLINK-26101
Project: Flink
Yun Tang created FLINK-25872:
Summary: Restoring from incremental checkpoint with changelog
state-backend cannot work well with snapshot CLAIM mode
Key: FLINK-25872
URL:
Yun Tang created FLINK-25862:
Summary: Refactor SharedStateRegistry to limit StreamStateHandle
to register/unregister
Key: FLINK-25862
URL: https://issues.apache.org/jira/browse/FLINK-25862
Project:
Yun Tang created FLINK-25816:
Summary: Changelog keyed state backend would come across NPE
during notification
Key: FLINK-25816
URL: https://issues.apache.org/jira/browse/FLINK-25816
Project: Flink
Yun Tang created FLINK-25557:
Summary: Introduce incremental/full checkpoint size stats
Key: FLINK-25557
URL: https://issues.apache.org/jira/browse/FLINK-25557
Project: Flink
Issue Type:
Yun Tang created FLINK-25524:
Summary: If enabled changelog, RocksDB incremental checkpoint
would always be full
Key: FLINK-25524
URL: https://issues.apache.org/jira/browse/FLINK-25524
Project: Flink
Yun Tang created FLINK-25494:
Summary: Duplicate element serializer during
DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources
Key: FLINK-25494
URL: https://issues.apache.org/jira/browse/FLINK-25494
Yun Tang created FLINK-25479:
Summary: Changlog materialization with incremental checkpoint
cannot work well in local tests
Key: FLINK-25479
URL: https://issues.apache.org/jira/browse/FLINK-25479
Yun Tang created FLINK-25478:
Summary: Changelog materialization with incremental checkpoint
could cause checkpointed data lost
Key: FLINK-25478
URL: https://issues.apache.org/jira/browse/FLINK-25478
Yun Tang created FLINK-25466:
Summary: TTL configuration could parse in StateTtlConfig#DISABLED
Key: FLINK-25466
URL: https://issues.apache.org/jira/browse/FLINK-25466
Project: Flink
Issue Type:
Yun Tang created FLINK-25465:
Summary: Correct the logic to materizate on wrapped changelog state
Key: FLINK-25465
URL: https://issues.apache.org/jira/browse/FLINK-25465
Project: Flink
Issue
Yun Tang created FLINK-25458:
Summary: Supports local recovery
Key: FLINK-25458
URL: https://issues.apache.org/jira/browse/FLINK-25458
Project: Flink
Issue Type: Sub-task
Reporter:
Yun Tang created FLINK-25446:
Summary: Avoid sanity check on read bytes on
DataInputStream#read(byte[])
Key: FLINK-25446
URL: https://issues.apache.org/jira/browse/FLINK-25446
Project: Flink
Yun Tang created FLINK-25438:
Summary: KafkaProducerExactlyOnceITCase.testMultipleSinkOperators
failed due to topic 'exactlyTopicCustomOperator20' already exists
Key: FLINK-25438
URL:
Yun Tang created FLINK-25429:
Summary: Avoid to close output streams twice during uploading
changelogs
Key: FLINK-25429
URL: https://issues.apache.org/jira/browse/FLINK-25429
Project: Flink
Yun Tang created FLINK-25423:
Summary: Enable loading state backend via configuration in state
processor api
Key: FLINK-25423
URL: https://issues.apache.org/jira/browse/FLINK-25423
Project: Flink
Yun Tang created FLINK-25237:
Summary: ElasticsearchSinkITCase fails due to
NoNodeAvailableException
Key: FLINK-25237
URL: https://issues.apache.org/jira/browse/FLINK-25237
Project: Flink
Issue
Yun Tang created FLINK-25116:
Summary: Fabric8FlinkKubeClientITCase hangs on Azure
Key: FLINK-25116
URL: https://issues.apache.org/jira/browse/FLINK-25116
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-25067:
Summary: Correct the description of RocksDB's background threads
Key: FLINK-25067
URL: https://issues.apache.org/jira/browse/FLINK-25067
Project: Flink
Issue Type:
Yun Tang created FLINK-24932:
Summary: Frocksdb cannot run on Apple M1
Key: FLINK-24932
URL: https://issues.apache.org/jira/browse/FLINK-24932
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-24788:
Summary: Report RocksDB statistics as metrics
Key: FLINK-24788
URL: https://issues.apache.org/jira/browse/FLINK-24788
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-24787:
Summary: Add more details of state latency tracking documentation
Key: FLINK-24787
URL: https://issues.apache.org/jira/browse/FLINK-24787
Project: Flink
Issue Type:
Yun Tang created FLINK-24786:
Summary: Introduce metrics of RocksDB's statistis
Key: FLINK-24786
URL: https://issues.apache.org/jira/browse/FLINK-24786
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-24785:
Summary: Relocate RocksDB's log under flink log directory by
default
Key: FLINK-24785
URL: https://issues.apache.org/jira/browse/FLINK-24785
Project: Flink
Issue
Yun Tang created FLINK-24784:
Summary: Enable state.backend.latency-track.state-name-as-variable
by default
Key: FLINK-24784
URL: https://issues.apache.org/jira/browse/FLINK-24784
Project: Flink
Yun Tang created FLINK-24783:
Summary: Improve state backend monitoring experience and usability
Key: FLINK-24783
URL: https://issues.apache.org/jira/browse/FLINK-24783
Project: Flink
Issue
Yun Tang created FLINK-24678:
Summary: Correct the metric name of map state contains latency
Key: FLINK-24678
URL: https://issues.apache.org/jira/browse/FLINK-24678
Project: Flink
Issue Type:
Yun Tang created FLINK-24667:
Summary: Channel state writer would fail the task directly if
meeting exception previously
Key: FLINK-24667
URL: https://issues.apache.org/jira/browse/FLINK-24667
Project:
Yun Tang created FLINK-24210:
Summary: Window related serailizer should not return 0 as its
serialized length
Key: FLINK-24210
URL: https://issues.apache.org/jira/browse/FLINK-24210
Project: Flink
Yun Tang created FLINK-24106:
Summary: Remove notice that python does not support state TTL
Key: FLINK-24106
URL: https://issues.apache.org/jira/browse/FLINK-24106
Project: Flink
Issue Type:
Yun Tang created FLINK-24105:
Summary: state TTL might not take effect for pyflink
Key: FLINK-24105
URL: https://issues.apache.org/jira/browse/FLINK-24105
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-24046:
Summary: Refactor the relationship bwtween PredefinedOptions and
RocksDBConfigurableOptions
Key: FLINK-24046
URL: https://issues.apache.org/jira/browse/FLINK-24046
Project:
Yun Tang created FLINK-23992:
Summary: Update doc version in release-1.13 to 1.13.2
Key: FLINK-23992
URL: https://issues.apache.org/jira/browse/FLINK-23992
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-23869:
Summary: Correct javadoc of ExecutionConfig#registerKryoType
Key: FLINK-23869
URL: https://issues.apache.org/jira/browse/FLINK-23869
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-23800:
Summary: Expose newly added RocksDB native metrics
Key: FLINK-23800
URL: https://issues.apache.org/jira/browse/FLINK-23800
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-23798:
Summary: Avoid using reflection to get filter when partition
filter is enabled
Key: FLINK-23798
URL: https://issues.apache.org/jira/browse/FLINK-23798
Project: Flink
Yun Tang created FLINK-23791:
Summary: Enable RocksDB log again
Key: FLINK-23791
URL: https://issues.apache.org/jira/browse/FLINK-23791
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-23789:
Summary: Remove unnecessary setTotalOrderForSeek for Rocks iterator
Key: FLINK-23789
URL: https://issues.apache.org/jira/browse/FLINK-23789
Project: Flink
Issue
Yun Tang created FLINK-23756:
Summary: Release FRocksDB-6.20.3 binaries
Key: FLINK-23756
URL: https://issues.apache.org/jira/browse/FLINK-23756
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-23737:
Summary: Ensure publish-to-dockerhub.sh only publish specific
flink versions
Key: FLINK-23737
URL: https://issues.apache.org/jira/browse/FLINK-23737
Project: Flink
Yun Tang created FLINK-23471:
Summary: Try best to ensure all operators and state manager handle
the checkpoint notification
Key: FLINK-23471
URL: https://issues.apache.org/jira/browse/FLINK-23471
Yun Tang created FLINK-23352:
Summary: Collect Sink Operator Factory does not support to
configure max bytes per batch
Key: FLINK-23352
URL: https://issues.apache.org/jira/browse/FLINK-23352
Project:
Yun Tang created FLINK-23050:
Summary: Add Chinese version of documentation of unaligned
checkpoint
Key: FLINK-23050
URL: https://issues.apache.org/jira/browse/FLINK-23050
Project: Flink
Issue
Yun Tang created FLINK-23018:
Summary: TTL state factory should handle extended state descriptors
Key: FLINK-23018
URL: https://issues.apache.org/jira/browse/FLINK-23018
Project: Flink
Issue
Yun Tang created FLINK-22759:
Summary: Correct the applicability of RocksDB related options as
per operator
Key: FLINK-22759
URL: https://issues.apache.org/jira/browse/FLINK-22759
Project: Flink
Yun Tang created FLINK-22535:
Summary: Resource leak would happen if exception thrown during
AbstractInvokable#restore of task life
Key: FLINK-22535
URL: https://issues.apache.org/jira/browse/FLINK-22535
Yun Tang created FLINK-22527:
Summary: Give friendly hint when click FlameGraph without
rest.flamegraph.enabled
Key: FLINK-22527
URL: https://issues.apache.org/jira/browse/FLINK-22527
Project: Flink
Yun Tang created FLINK-22444:
Summary: Drop async checkpoint description of state backends in
Chinese docs
Key: FLINK-22444
URL: https://issues.apache.org/jira/browse/FLINK-22444
Project: Flink
Yun Tang created FLINK-22369:
Summary: RocksDB state backend might occur ClassNotFoundException
when deserializing on TM side
Key: FLINK-22369
URL: https://issues.apache.org/jira/browse/FLINK-22369
Yun Tang created FLINK-22187:
Summary: Remove description of sync checkpoint mode of
HashMapStateBackend
Key: FLINK-22187
URL: https://issues.apache.org/jira/browse/FLINK-22187
Project: Flink
Yun Tang created FLINK-22146:
Summary: Migrate StateBackend related Chinese docs to latest state
backend
Key: FLINK-22146
URL: https://issues.apache.org/jira/browse/FLINK-22146
Project: Flink
Yun Tang created FLINK-21736:
Summary: Introduce latency tracking state
Key: FLINK-21736
URL: https://issues.apache.org/jira/browse/FLINK-21736
Project: Flink
Issue Type: New Feature
Yun Tang created FLINK-21658:
Summary: Align flink-benchmarks with job graph builder
Key: FLINK-21658
URL: https://issues.apache.org/jira/browse/FLINK-21658
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-21603:
Summary: SQLClientKafkaITCase failed due to unexpected end of file
Key: FLINK-21603
URL: https://issues.apache.org/jira/browse/FLINK-21603
Project: Flink
Issue
Yun Tang created FLINK-21351:
Summary: Incremental checkpoint data would be lost once a non-stop
savepoint completed
Key: FLINK-21351
URL: https://issues.apache.org/jira/browse/FLINK-21351
Project: Flink
Yun Tang created FLINK-21241:
Summary: E2E test exception check might fail if older checkpoint
not completed when triggering the stop-with-savepoint
Key: FLINK-21241
URL:
Yun Tang created FLINK-21119:
Summary: Building Flink Azure FS Hadoop hangs during python CI
Key: FLINK-21119
URL: https://issues.apache.org/jira/browse/FLINK-21119
Project: Flink
Issue Type:
Yun Tang created FLINK-21048:
Summary: Refactor documentation related to switch memory allocator
Key: FLINK-21048
URL: https://issues.apache.org/jira/browse/FLINK-21048
Project: Flink
Issue
Yun Tang created FLINK-20675:
Summary: Asynchronous checkpoint failure would not fail the job
anymore
Key: FLINK-20675
URL: https://issues.apache.org/jira/browse/FLINK-20675
Project: Flink
Yun Tang created FLINK-20420:
Summary: ES6 ElasticsearchSinkITCase failed due to no output for
900 seconds
Key: FLINK-20420
URL: https://issues.apache.org/jira/browse/FLINK-20420
Project: Flink
1 - 100 of 184 matches
Mail list logo
