Flink Speed Center : Timeline

SPEED CENTER

Environment

Hetzner (deprecated)
Aliyun

Executables

(All

None)

Flink

(All

None)

State Backends

(All

None)

Scheduler

(All

None)

Flink (Java11)

(All

None)

Scheduler (Java11)

(All

None)

State Backends (Java11)

(All

None)

Scheduler (Java17)

(All

None)

State Backends (Java17)

(All

None)

Flink (Java17)

Baseline:

Benchmark

Display all in a grid
Display none

aggregateWatermark
arrayKeyBy
asyncWait.ORDERED
asyncWait.UNORDERED
benchmarkCount
buildTopology.BATCH
buildTopology.STREAMING
calculateRegionToRestart.BATCH
calculateRegionToRestart.STREAMING
checkpointMultiInput
checkpointSingleInput.ALIGNED
checkpointSingleInput.UNALIGNED
checkpointSingleInput.UNALIGNED_1
compressedFilePartition
compressedSortPartition
createScheduler.BATCH
createScheduler.STREAMING
deployAllTasks.STREAMING
deployDownstreamTasks.BATCH
fireProcessingTimers
globalWindow
handleGlobalFailureAndRestartAllTasks.BATCH
handleGlobalFailureAndRestartAllTasks.BATCH_EVENLY
handleGlobalFailureAndRestartAllTasks.STREAMING
handleGlobalFailureAndRestartAllTasks.STREAMING_EVENLY
initSchedulingStrategy.BATCH
initSchedulingStrategy.STREAMING
listAdd.HEAP
listAdd.ROCKSDB
listAdd.ROCKSDB_CHANGELOG
listAddAll.HEAP
listAddAll.ROCKSDB
listAddAll.ROCKSDB_CHANGELOG
listAppend.HEAP
listAppend.ROCKSDB
listAppend.ROCKSDB_CHANGELOG
listGet.HEAP
listGet.ROCKSDB
listGet.ROCKSDB_CHANGELOG
listGetAndIterate.HEAP
listGetAndIterate.ROCKSDB
listGetAndIterate.ROCKSDB_CHANGELOG
listUpdate.HEAP
listUpdate.ROCKSDB
listUpdate.ROCKSDB_CHANGELOG
mapAdd.HEAP
mapAdd.HEAP_ASYNC.1024
mapAdd.HEAP_ASYNC.16384
mapAdd.HEAP_ASYNC.192
mapAdd.HEAP_ASYNC.256
mapAdd.ROCKSDB
mapAdd.ROCKSDB_CHANGELOG
mapContains.HEAP
mapContains.HEAP_ASYNC.1024
mapContains.HEAP_ASYNC.16384
mapContains.HEAP_ASYNC.192
mapContains.HEAP_ASYNC.256
mapContains.ROCKSDB
mapContains.ROCKSDB_CHANGELOG
mapEntries.HEAP
mapEntries.HEAP_ASYNC.1024
mapEntries.HEAP_ASYNC.16384
mapEntries.HEAP_ASYNC.192
mapEntries.HEAP_ASYNC.256
mapEntries.ROCKSDB
mapEntries.ROCKSDB_CHANGELOG
mapGet.HEAP
mapGet.HEAP_ASYNC.1024
mapGet.HEAP_ASYNC.16384
mapGet.HEAP_ASYNC.192
mapGet.HEAP_ASYNC.256
mapGet.ROCKSDB
mapGet.ROCKSDB_CHANGELOG
mapIsEmpty.HEAP
mapIsEmpty.HEAP_ASYNC.1024
mapIsEmpty.HEAP_ASYNC.16384
mapIsEmpty.HEAP_ASYNC.192
mapIsEmpty.HEAP_ASYNC.256
mapIsEmpty.ROCKSDB
mapIsEmpty.ROCKSDB_CHANGELOG
mapIterator.HEAP
mapIterator.HEAP_ASYNC.1024
mapIterator.HEAP_ASYNC.16384
mapIterator.HEAP_ASYNC.192
mapIterator.HEAP_ASYNC.256
mapIterator.ROCKSDB
mapIterator.ROCKSDB_CHANGELOG
mapKeys.HEAP
mapKeys.HEAP_ASYNC.1024
mapKeys.HEAP_ASYNC.16384
mapKeys.HEAP_ASYNC.192
mapKeys.HEAP_ASYNC.256
mapKeys.ROCKSDB
mapKeys.ROCKSDB_CHANGELOG
mapPutAll.HEAP
mapPutAll.HEAP_ASYNC.1024
mapPutAll.HEAP_ASYNC.16384
mapPutAll.HEAP_ASYNC.192
mapPutAll.HEAP_ASYNC.256
mapPutAll.ROCKSDB
mapPutAll.ROCKSDB_CHANGELOG
mapRebalanceMapSink.F27_UNBOUNDED
mapRebalanceMapSink.LEGACY
mapRemove.HEAP
mapRemove.HEAP_ASYNC.1024
mapRemove.HEAP_ASYNC.16384
mapRemove.HEAP_ASYNC.192
mapRemove.HEAP_ASYNC.256
mapRemove.ROCKSDB
mapRemove.ROCKSDB_CHANGELOG
mapSink.F27_UNBOUNDED
mapSink.LEGACY
mapUpdate.HEAP
mapUpdate.HEAP_ASYNC.1024
mapUpdate.HEAP_ASYNC.16384
mapUpdate.HEAP_ASYNC.192
mapUpdate.HEAP_ASYNC.256
mapUpdate.ROCKSDB
mapUpdate.ROCKSDB_CHANGELOG
mapValues.HEAP
mapValues.HEAP_ASYNC.1024
mapValues.HEAP_ASYNC.16384
mapValues.HEAP_ASYNC.192
mapValues.HEAP_ASYNC.256
mapValues.ROCKSDB
mapValues.ROCKSDB_CHANGELOG
multiInputChainedIdleSource
multiInputMapSink
multiInputOneIdleMapSink
networkBroadcastThroughput
networkLatency1to1
networkSkewedThroughput
networkThroughput
networkThroughput.1,100ms
networkThroughput.100,100ms
networkThroughput.100,100ms,SSL
networkThroughput.100,1ms
networkThroughput.1000,100ms
networkThroughput.1000,100ms,OpenSSL
networkThroughput.1000,100ms,SSL
networkThroughput.1000,1ms
networkThroughputCompressed
partitionRelease.BATCH
readAvro
readFileSplit
readFiles.txt-100-1000-10
readFiles.txt-1000-100-10
readKryo
readPojo
remoteFilePartition
remoteRebalance
remoteRebalance.ALIGNED
remoteRebalance.DEBLOAT
remoteRebalance.UNALIGNED
remoteSortPartition
rescaleHeap.RESCALE_IN
rescaleHeap.RESCALE_OUT
rescaleRocksDB.RESCALE_IN
rescaleRocksDB.RESCALE_OUT
rescaleRocksDB.RESTORE
schedulingDownstreamTasks.BATCH
schedulingDownstreamTasks.BATCH_HYBRID_ALL_FINISHED
schedulingDownstreamTasks.BATCH_HYBRID_DEFAULT
schedulingDownstreamTasks.BATCH_HYBRID_PARTIAL_FINISHED
serializerAvro
serializerAvroGeneric
serializerAvroReflect
serializerHeavyString
serializerKryo
serializerKryoProtobuf
serializerKryoThrift
serializerKryoWithoutRegistration
serializerPojo
serializerPojoWithoutRegistration
serializerRow
serializerScalaADT
serializerTuple
sessionWindow
slidingWindow
sortedMultiInput
sortedOneInput
sortedTwoInput
startScheduling.BATCH
startScheduling.STREAMING
stateBackends.FS
stateBackends.FS_ASYNC
stateBackends.MEMORY
stateBackends.ROCKS
stateBackends.ROCKS_INC
stringRead.128.ascii
stringRead.128.chinese
stringRead.128.russian
stringRead.16384.ascii
stringRead.16384.chinese
stringRead.16384.russian
stringRead.4.ascii
stringRead.4.chinese
stringRead.4.russian
stringWrite.128.ascii
stringWrite.128.chinese
stringWrite.128.russian
stringWrite.16384.ascii
stringWrite.16384.chinese
stringWrite.16384.russian
stringWrite.4.ascii
stringWrite.4.chinese
stringWrite.4.russian
submitJobThroughput.NONE
submitJobThroughput.ZOOKEEPER
tumblingWindow
tupleKeyBy
twoInputMapSink
twoInputOneIdleMapSink
unalignedCheckpoint
unalignedCheckpoint.0
unalignedCheckpoint.1
unalignedCheckpoint.ALIGNED
unalignedCheckpoint.LOCAL
unalignedCheckpoint.REMOTE
uncompressedFilePartition
uncompressedMmapPartition
uncompressedSortPartition
valueAdd.HEAP
valueAdd.ROCKSDB
valueAdd.ROCKSDB_CHANGELOG
valueGet.HEAP
valueGet.ROCKSDB
valueGet.ROCKSDB_CHANGELOG
valueUpdate.HEAP
valueUpdate.ROCKSDB
valueUpdate.ROCKSDB_CHANGELOG
writeAvro
writeKryo
writePojo

Show the last results Equidistant Permalink