Yun Tang created FLINK-13067:
Summary: Fix broken links to contributing docs
Key: FLINK-13067
URL: https://issues.apache.org/jira/browse/FLINK-13067
Project: Flink
Issue Type: Bug
Compo
Yun Tang created FLINK-13281:
Summary: Fix the verify logic of
AdaptedRestartPipelinedRegionStrategyNGAbortPendingCheckpointsTest
Key: FLINK-13281
URL: https://issues.apache.org/jira/browse/FLINK-13281
Pr
Yun Tang created FLINK-13380:
Summary: Improve the usability of Flink session cluster on
Kubernetes
Key: FLINK-13380
URL: https://issues.apache.org/jira/browse/FLINK-13380
Project: Flink
Issue T
Yun Tang created FLINK-13390:
Summary: Clarify the exact meaning of state size when executing
incremental checkpoint
Key: FLINK-13390
URL: https://issues.apache.org/jira/browse/FLINK-13390
Project: Flink
Yun Tang created FLINK-13418:
Summary: Avoid InfluxdbReporter to report uncessray tags
Key: FLINK-13418
URL: https://issues.apache.org/jira/browse/FLINK-13418
Project: Flink
Issue Type: Improveme
Yun Tang created FLINK-13496:
Summary: Correct the documentation of Gauge metric initialization
Key: FLINK-13496
URL: https://issues.apache.org/jira/browse/FLINK-13496
Project: Flink
Issue Type:
Yun Tang created FLINK-13527:
Summary: Instable KafkaProducerExactlyOnceITCase due to
CheckpointFailureManager
Key: FLINK-13527
URL: https://issues.apache.org/jira/browse/FLINK-13527
Project: Flink
Yun Tang created FLINK-13845:
Summary: Drop all the content of removed "Checkpointed" interface
Key: FLINK-13845
URL: https://issues.apache.org/jira/browse/FLINK-13845
Project: Flink
Issue Type:
Yun Tang created FLINK-13846:
Summary: Implement benchmark case on MapState#isEmpty
Key: FLINK-13846
URL: https://issues.apache.org/jira/browse/FLINK-13846
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-13910:
Summary: Many serializable classes have no explicit
'serialVersionUID'
Key: FLINK-13910
URL: https://issues.apache.org/jira/browse/FLINK-13910
Project: Flink
Issue
Yun Tang created FLINK-14032:
Summary: Make the cache size of RocksDBPriorityQueueSetFactory
configurable
Key: FLINK-14032
URL: https://issues.apache.org/jira/browse/FLINK-14032
Project: Flink
I
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-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-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-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: Flink
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-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-16324:
Summary: Checkpoint tasks progress would display 100% in web UI
even not all tasks finished
Key: FLINK-16324
URL: https://issues.apache.org/jira/browse/FLINK-16324
Project: F
Yun Tang created FLINK-16444:
Summary: Count the read/write/seek/next latency of RocksDB as
metrics
Key: FLINK-16444
URL: https://issues.apache.org/jira/browse/FLINK-16444
Project: Flink
Issue T
Yun Tang created FLINK-16782:
Summary: Avoid unnecessary check on expired time state when we set
visibility as ReturnExpiredIfNotCleanedUp
Key: FLINK-16782
URL: https://issues.apache.org/jira/browse/FLINK-16782
Yun Tang created FLINK-16850:
Summary: Make flink-benchmark align with different releases of
Flink
Key: FLINK-16850
URL: https://issues.apache.org/jira/browse/FLINK-16850
Project: Flink
Issue Ty
Yun Tang created FLINK-16876:
Summary: Make TtlTimeProvider configurable when creating keyed
state backend
Key: FLINK-16876
URL: https://issues.apache.org/jira/browse/FLINK-16876
Project: Flink
Yun Tang created FLINK-16949:
Summary: Enhance AbstractStreamOperatorTestHarness to use
customized TtlTimeProvider
Key: FLINK-16949
URL: https://issues.apache.org/jira/browse/FLINK-16949
Project: Flink
Yun Tang created FLINK-17011:
Summary: Introduce builder to create
AbstractStreamOperatorTestHarness for testing
Key: FLINK-17011
URL: https://issues.apache.org/jira/browse/FLINK-17011
Project: Flink
Yun Tang created FLINK-17248:
Summary: Make the thread nums of io executor of ClusterEntrypoint
and MiniCluster configurable
Key: FLINK-17248
URL: https://issues.apache.org/jira/browse/FLINK-17248
Project
Yun Tang created FLINK-17280:
Summary: Migrate existing flink-benchmarks under apache project
Key: FLINK-17280
URL: https://issues.apache.org/jira/browse/FLINK-17280
Project: Flink
Issue Type: Im
Yun Tang created FLINK-17281:
Summary: Add existing flink-benchmarks code
Key: FLINK-17281
URL: https://issues.apache.org/jira/browse/FLINK-17281
Project: Flink
Issue Type: Sub-task
R
Yun Tang created FLINK-17282:
Summary: Add CI build for new flink-benchmarks repo
Key: FLINK-17282
URL: https://issues.apache.org/jira/browse/FLINK-17282
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-17322:
Summary: Enable latency tracker would corrupt the broadcast state
Key: FLINK-17322
URL: https://issues.apache.org/jira/browse/FLINK-17322
Project: Flink
Issue Type:
Yun Tang created FLINK-14378:
Summary: Cleanup rocksDB lib folder if fail to load library
Key: FLINK-14378
URL: https://issues.apache.org/jira/browse/FLINK-14378
Project: Flink
Issue Type: Improv
Yun Tang created FLINK-14379:
Summary: Supplement documentation about raw state
Key: FLINK-14379
URL: https://issues.apache.org/jira/browse/FLINK-14379
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-14403:
Summary: Remove uesless NotifyCheckpointComplete and
TriggerCheckpoint
Key: FLINK-14403
URL: https://issues.apache.org/jira/browse/FLINK-14403
Project: Flink
Issue
Yun Tang created FLINK-14445:
Summary: Python module build failed when making sdist
Key: FLINK-14445
URL: https://issues.apache.org/jira/browse/FLINK-14445
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-14482:
Summary: Bump up rocksdb version to support WriteBufferManager
Key: FLINK-14482
URL: https://issues.apache.org/jira/browse/FLINK-14482
Project: Flink
Issue Type: Sub
Yun Tang created FLINK-14483:
Summary: Build and supply frocksdb version to support
WriteBufferManager
Key: FLINK-14483
URL: https://issues.apache.org/jira/browse/FLINK-14483
Project: Flink
Issu
Yun Tang created FLINK-14484:
Summary: Modify RocksDB backend to allow setting
WriteBufferManager via options
Key: FLINK-14484
URL: https://issues.apache.org/jira/browse/FLINK-14484
Project: Flink
Yun Tang created FLINK-14495:
Summary: Add documentation for memory control of RocksDB state
backend with writebuffer manager
Key: FLINK-14495
URL: https://issues.apache.org/jira/browse/FLINK-14495
Projec
Yun Tang created FLINK-14652:
Summary: Refactor checkpointing related parts into one place on
task side
Key: FLINK-14652
URL: https://issues.apache.org/jira/browse/FLINK-14652
Project: Flink
Iss
Yun Tang created FLINK-14654:
Summary: Fix the arguments number mismatching with placeholders in
log statements
Key: FLINK-14654
URL: https://issues.apache.org/jira/browse/FLINK-14654
Project: Flink
Yun Tang created FLINK-14704:
Summary: Remove uesless SynchronousSavepointLatch
Key: FLINK-14704
URL: https://issues.apache.org/jira/browse/FLINK-14704
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-14706:
Summary: Remove legacy KvStateMessage
Key: FLINK-14706
URL: https://issues.apache.org/jira/browse/FLINK-14706
Project: Flink
Issue Type: Sub-task
Reporte
Yun Tang created FLINK-14707:
Summary: Refactor checkpoint related methods within Environment
Key: FLINK-14707
URL: https://issues.apache.org/jira/browse/FLINK-14707
Project: Flink
Issue Type: Im
Yun Tang created FLINK-14725:
Summary: Remove unused (anymore)
TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR
Key: FLINK-14725
URL: https://issues.apache.org/jira/browse/FLINK-14725
Project: Flink
Yun Tang created FLINK-14846:
Summary: Correct the default writerbuffer size documentation of
RocksDB
Key: FLINK-14846
URL: https://issues.apache.org/jira/browse/FLINK-14846
Project: Flink
Issue
Yun Tang created FLINK-14877:
Summary: Enable FRocksDB to optimize performance via options when
bounding total memory
Key: FLINK-14877
URL: https://issues.apache.org/jira/browse/FLINK-14877
Project: Flink
Yun Tang created FLINK-14997:
Summary: Avoid to call unnecessary delete within RocksDBState's
mergeNamespaces implementation
Key: FLINK-14997
URL: https://issues.apache.org/jira/browse/FLINK-14997
Project
Yun Tang created FLINK-14998:
Summary: Remove FileUtils#deletePathIfEmpty
Key: FLINK-14998
URL: https://issues.apache.org/jira/browse/FLINK-14998
Project: Flink
Issue Type: Bug
Componen
Yun Tang created FLINK-15034:
Summary: Bump FRocksDB version for memory control
Key: FLINK-15034
URL: https://issues.apache.org/jira/browse/FLINK-15034
Project: Flink
Issue Type: Sub-task
Yun Tang created FLINK-15319:
Summary: flink-end-to-end-tests-common-kafka fails due to timeout
Key: FLINK-15319
URL: https://issues.apache.org/jira/browse/FLINK-15319
Project: Flink
Issue Type:
Yun Tang created FLINK-15370:
Summary: Configured write buffer manager actually not take effect
in RocksDB's DBOptions
Key: FLINK-15370
URL: https://issues.apache.org/jira/browse/FLINK-15370
Project: Flin
Yun Tang created FLINK-15387:
Summary: Expose missing RocksDB properties out via
RocksDBNativeMetricOptions
Key: FLINK-15387
URL: https://issues.apache.org/jira/browse/FLINK-15387
Project: Flink
Yun Tang created FLINK-15512:
Summary: Refactor the mechanism of how to constructure the cache
and write buffer manager shared across RocksDB instances
Key: FLINK-15512
URL: https://issues.apache.org/jira/browse/FLIN
Yun Tang created FLINK-15524:
Summary: Some links in Chinese documents points to English
documents by mistake
Key: FLINK-15524
URL: https://issues.apache.org/jira/browse/FLINK-15524
Project: Flink
Yun Tang created FLINK-15532:
Summary: Enable strict capacity limit for memory usage for RocksDB
Key: FLINK-15532
URL: https://issues.apache.org/jira/browse/FLINK-15532
Project: Flink
Issue Type:
Yun Tang created FLINK-15550:
Summary: testCancelTaskExceptionAfterTaskMarkedFailed failed on
azure
Key: FLINK-15550
URL: https://issues.apache.org/jira/browse/FLINK-15550
Project: Flink
Issue T
Yun Tang created FLINK-15748:
Summary: Set explict managed memory for RocksDBStateBenchmark
Key: FLINK-15748
URL: https://issues.apache.org/jira/browse/FLINK-15748
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-9328:
---
Summary: RocksDBStateBackend might use
PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not
register snapshots in some UTs
Key: FLINK-9328
URL: https://issues.apach
Yun Tang created FLINK-9758:
---
Summary: ContinuousFileProcessingTest failed due to not setting
runtimeContext
Key: FLINK-9758
URL: https://issues.apache.org/jira/browse/FLINK-9758
Project: Flink
Is
Yun Tang created FLINK-10267:
Summary: [State] Fix arbitrary iterator access on
RocksDBMapIterator
Key: FLINK-10267
URL: https://issues.apache.org/jira/browse/FLINK-10267
Project: Flink
Issue Ty
Yun Tang created FLINK-10930:
Summary: Refactor checkpoint directory layout
Key: FLINK-10930
URL: https://issues.apache.org/jira/browse/FLINK-10930
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-10954:
Summary: Hardlink from files of previous local stored state might
cross devices
Key: FLINK-10954
URL: https://issues.apache.org/jira/browse/FLINK-10954
Project: Flink
Yun Tang created FLINK-11107:
Summary: [state] Avoid memory stateBackend to create arbitrary
folders under HA path when no checkpoint path configured
Key: FLINK-11107
URL: https://issues.apache.org/jira/browse/FLINK-1
Yun Tang created FLINK-11313:
Summary: [checkpoint] Introduce LZ4 compression for keyed state in
full checkpoints and savepoints
Key: FLINK-11313
URL: https://issues.apache.org/jira/browse/FLINK-11313
Pro
Yun Tang created FLINK-11618:
Summary: [state] Refactor operator state repartition mechanism
Key: FLINK-11618
URL: https://issues.apache.org/jira/browse/FLINK-11618
Project: Flink
Issue Type: Imp
Yun Tang created FLINK-11691:
Summary: Introduce ClassLoader in the methods of
StateBackendFactory and ConfigurableStateBackend
Key: FLINK-11691
URL: https://issues.apache.org/jira/browse/FLINK-11691
Proj
Yun Tang created FLINK-11695:
Summary: [checkpoint] Make sharedStateDir could create
sub-directories to avoid MaxDirectoryItemsExceededException
Key: FLINK-11695
URL: https://issues.apache.org/jira/browse/FLINK-11695
Yun Tang created FLINK-11696:
Summary: [checkpoint] Avoid to send mkdir requests to DFS from
task side
Key: FLINK-11696
URL: https://issues.apache.org/jira/browse/FLINK-11696
Project: Flink
Issu
Yun Tang created FLINK-11829:
Summary: [checkpoint] FsCheckpointStateOutputStream might store
state in files even state size below fileStateThreshold
Key: FLINK-11829
URL: https://issues.apache.org/jira/browse/FLINK-1
Yun Tang created FLINK-11860:
Summary: Remove all the usage of deprecated unit-provided memory
options in docs and scripts
Key: FLINK-11860
URL: https://issues.apache.org/jira/browse/FLINK-11860
Project:
Yun Tang created FLINK-11868:
Summary: [filesystems] Introduce listStatusIterator API to file
system
Key: FLINK-11868
URL: https://issues.apache.org/jira/browse/FLINK-11868
Project: Flink
Issue
Yun Tang created FLINK-11869:
Summary: [checkpoint] Make buffer size in checkpoint stream
factory configurable
Key: FLINK-11869
URL: https://issues.apache.org/jira/browse/FLINK-11869
Project: Flink
Yun Tang created FLINK-11874:
Summary: [checkpoint] Split CheckpointStorage interface to
distinguish JM and TM side
Key: FLINK-11874
URL: https://issues.apache.org/jira/browse/FLINK-11874
Project: Flink
Yun Tang created FLINK-12353:
Summary: Add missing module to collect_japicmp_reports.sh
Key: FLINK-12353
URL: https://issues.apache.org/jira/browse/FLINK-12353
Project: Flink
Issue Type: Bug
Yun Tang created FLINK-12358:
Summary: Verify whether rest documenation needs to be updated when
building pull request
Key: FLINK-12358
URL: https://issues.apache.org/jira/browse/FLINK-12358
Project: Flin
Yun Tang created FLINK-12380:
Summary: Add thread name in the log4j.properties
Key: FLINK-12380
URL: https://issues.apache.org/jira/browse/FLINK-12380
Project: Flink
Issue Type: Improvement
Yun Tang created FLINK-12520:
Summary: Support to provide fully-qualified domain host name in
TaskManagerMetricGroup
Key: FLINK-12520
URL: https://issues.apache.org/jira/browse/FLINK-12520
Project: Flink
Yun Tang created FLINK-12927:
Summary: YARNSessionCapacitySchedulerITCase failed due to non
prohibited exception
Key: FLINK-12927
URL: https://issues.apache.org/jira/browse/FLINK-12927
Project: Flink
Yun Tang created FLINK-13004:
Summary: Correct the logic of needToCleanupState in
KeyedProcessFunctionWithCleanupState
Key: FLINK-13004
URL: https://issues.apache.org/jira/browse/FLINK-13004
Project: Flin
Yun Tang created FLINK-13034:
Summary: Improve the performance when checking whether mapstate is
empty for RocksDBStateBackend
Key: FLINK-13034
URL: https://issues.apache.org/jira/browse/FLINK-13034
Proje
Yun Tang created FLINK-19125:
Summary: Avoid memory fragmentation when running flink docker image
Key: FLINK-19125
URL: https://issues.apache.org/jira/browse/FLINK-19125
Project: Flink
Issue Type
Yun Tang created FLINK-19710:
Summary: Avoid performance regression introduced by thread-local
keyword of FRocksDB
Key: FLINK-19710
URL: https://issues.apache.org/jira/browse/FLINK-19710
Project: Flink
Yun Tang created FLINK-20287:
Summary: Add documentation of how to switch memory allocator in
Flink docker image
Key: FLINK-20287
URL: https://issues.apache.org/jira/browse/FLINK-20287
Project: Flink
Yun Tang created FLINK-20288:
Summary: Correct documentation about savepoint self-contained
Key: FLINK-20288
URL: https://issues.apache.org/jira/browse/FLINK-20288
Project: Flink
Issue Type: Bug
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
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
Issue
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: Imp
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-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-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-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-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
Projec
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-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-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-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
I
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-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-31706:
Summary: The default source parallelism should be the same as
execution's default parallelism under adaptive batch scheduler
Key: FLINK-31706
URL: https://issues.apache.org/jira/browse/FL
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
Compo
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: F
1 - 100 of 185 matches
Mail list logo
