[jira] [Created] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

Jiayi Liao created FLINK-24148: -- Summary: Add bloom filter policy option in RocksDBConfiguredOptions Key: FLINK-24148 URL: https://issues.apache.org/jira/browse/FLINK-24148 Project: Flink Issue

[jira] [Created] (FLINK-23690) Processing timers can be triggered more efficiently

Jiayi Liao created FLINK-23690: -- Summary: Processing timers can be triggered more efficiently Key: FLINK-23690 URL: https://issues.apache.org/jira/browse/FLINK-23690 Project: Flink Issue Type: I

[jira] [Created] (FLINK-23689) TestProcessingTimeService.setCurrentTime(long) not delay the firing timer by 1ms delay

Jiayi Liao created FLINK-23689: -- Summary: TestProcessingTimeService.setCurrentTime(long) not delay the firing timer by 1ms delay Key: FLINK-23689 URL: https://issues.apache.org/jira/browse/FLINK-23689 Pr

[jira] [Created] (FLINK-23208) Late processing timers need to wait 1ms at least to be fired

Jiayi Liao created FLINK-23208: -- Summary: Late processing timers need to wait 1ms at least to be fired Key: FLINK-23208 URL: https://issues.apache.org/jira/browse/FLINK-23208 Project: Flink Iss

[jira] [Created] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs

Jiayi Liao created FLINK-23180: -- Summary: Initialize checkpoint location lazily in DataStream Batch Jobs Key: FLINK-23180 URL: https://issues.apache.org/jira/browse/FLINK-23180 Project: Flink I

[jira] [Created] (FLINK-22887) Backlog based optimizations for RebalancePartitioner and RescalePartitioner

Jiayi Liao created FLINK-22887: -- Summary: Backlog based optimizations for RebalancePartitioner and RescalePartitioner Key: FLINK-22887 URL: https://issues.apache.org/jira/browse/FLINK-22887 Project: Flin

[jira] [Created] (FLINK-22886) Thread leak in RocksDBStateUploader

Jiayi Liao created FLINK-22886: -- Summary: Thread leak in RocksDBStateUploader Key: FLINK-22886 URL: https://issues.apache.org/jira/browse/FLINK-22886 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

Jiayi Liao created FLINK-21413: -- Summary: TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend Key: FLINK-21413 URL: https://issues.apache.org/jira/browse/FLINK-21413 Proj

[jira] [Created] (FLINK-20684) Add compression type option in RocksDBConfigurableOptions

Jiayi Liao created FLINK-20684: -- Summary: Add compression type option in RocksDBConfigurableOptions Key: FLINK-20684 URL: https://issues.apache.org/jira/browse/FLINK-20684 Project: Flink Issue T

[jira] [Created] (FLINK-20269) The flush happens too frequent in SavepoinV2Serializer

Jiayi Liao created FLINK-20269: -- Summary: The flush happens too frequent in SavepoinV2Serializer Key: FLINK-20269 URL: https://issues.apache.org/jira/browse/FLINK-20269 Project: Flink Issue Type

[jira] [Created] (FLINK-20087) CheckpointCoordinator waits until all tasks finish initialization of states to trigger checkpoint

Jiayi Liao created FLINK-20087: -- Summary: CheckpointCoordinator waits until all tasks finish initialization of states to trigger checkpoint Key: FLINK-20087 URL: https://issues.apache.org/jira/browse/FLINK-20087

[jira] [Created] (FLINK-20044) Disposal of RocksDB could last forever

Jiayi Liao created FLINK-20044: -- Summary: Disposal of RocksDB could last forever Key: FLINK-20044 URL: https://issues.apache.org/jira/browse/FLINK-20044 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover

Jiayi Liao created FLINK-19596: -- Summary: Do not recover CompletedCheckpointStore on each failover Key: FLINK-19596 URL: https://issues.apache.org/jira/browse/FLINK-19596 Project: Flink Issue Ty

[jira] [Created] (FLINK-19150) Behaviour change after migration from 1.9 to 1.11

Jiayi Liao created FLINK-19150: -- Summary: Behaviour change after migration from 1.9 to 1.11 Key: FLINK-19150 URL: https://issues.apache.org/jira/browse/FLINK-19150 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

Jiayi Liao created FLINK-19069: -- Summary: finalizeOnMaster takes too much time and client timeouts Key: FLINK-19069 URL: https://issues.apache.org/jira/browse/FLINK-19069 Project: Flink Issue Ty

[jira] [Created] (FLINK-19016) Checksum mismatch when restore from RocksDB

Jiayi Liao created FLINK-19016: -- Summary: Checksum mismatch when restore from RocksDB Key: FLINK-19016 URL: https://issues.apache.org/jira/browse/FLINK-19016 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19011) Parallelize the restoreOperation in OperatorStateBackend

Jiayi Liao created FLINK-19011: -- Summary: Parallelize the restoreOperation in OperatorStateBackend Key: FLINK-19011 URL: https://issues.apache.org/jira/browse/FLINK-19011 Project: Flink Issue T

[jira] [Created] (FLINK-18348) RemoteInputChannel should checkError before checking partitionRequestClient

Jiayi Liao created FLINK-18348: -- Summary: RemoteInputChannel should checkError before checking partitionRequestClient Key: FLINK-18348 URL: https://issues.apache.org/jira/browse/FLINK-18348 Project: Flin

[jira] [Created] (FLINK-18203) Reduce objects usage in redistributing union states

Jiayi Liao created FLINK-18203: -- Summary: Reduce objects usage in redistributing union states Key: FLINK-18203 URL: https://issues.apache.org/jira/browse/FLINK-18203 Project: Flink Issue Type: I

[jira] [Created] (FLINK-18068) Job stuck after IllegalStateException in scheduling

Jiayi Liao created FLINK-18068: -- Summary: Job stuck after IllegalStateException in scheduling Key: FLINK-18068 URL: https://issues.apache.org/jira/browse/FLINK-18068 Project: Flink Issue Type: I

[jira] [Created] (FLINK-18067) Invalid default value for yarnMinAllocationMB in YarnClusterDescriptor

Jiayi Liao created FLINK-18067: -- Summary: Invalid default value for yarnMinAllocationMB in YarnClusterDescriptor Key: FLINK-18067 URL: https://issues.apache.org/jira/browse/FLINK-18067 Project: Flink

[jira] [Created] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

Jiayi Liao created FLINK-17453: -- Summary: KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue Key: FLINK-17453 URL: https://issues.apache.org/jira/browse/FLINK-17453 Project: Fli

[jira] [Created] (FLINK-17320) Java8 lambda expression cannot be serialized.

Jiayi Liao created FLINK-17320: -- Summary: Java8 lambda expression cannot be serialized. Key: FLINK-17320 URL: https://issues.apache.org/jira/browse/FLINK-17320 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17134) Wrong logging information in Kafka010PartitionDiscoverer#L80

Jiayi Liao created FLINK-17134: -- Summary: Wrong logging information in Kafka010PartitionDiscoverer#L80 Key: FLINK-17134 URL: https://issues.apache.org/jira/browse/FLINK-17134 Project: Flink Iss

[jira] [Created] (FLINK-16755) Savepoint docs should be updated

Jiayi Liao created FLINK-16755: -- Summary: Savepoint docs should be updated Key: FLINK-16755 URL: https://issues.apache.org/jira/browse/FLINK-16755 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

Jiayi Liao created FLINK-16753: -- Summary: Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException Key: FLINK-16753 URL: https://issues.apache.org/jira/browse/FLINK-16753 Project:

[jira] [Created] (FLINK-16620) Add attempt information in logging

Jiayi Liao created FLINK-16620: -- Summary: Add attempt information in logging Key: FLINK-16620 URL: https://issues.apache.org/jira/browse/FLINK-16620 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16597) tryCleanupOnError should happen before close

Jiayi Liao created FLINK-16597: -- Summary: tryCleanupOnError should happen before close Key: FLINK-16597 URL: https://issues.apache.org/jira/browse/FLINK-16597 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-16242) BinaryGeneric serialization error cause checkpoint failure

Jiayi Liao created FLINK-16242: -- Summary: BinaryGeneric serialization error cause checkpoint failure Key: FLINK-16242 URL: https://issues.apache.org/jira/browse/FLINK-16242 Project: Flink Issue

[jira] [Created] (FLINK-16051) subtask id in Checkpoint UI not consistent with TaskUI

Jiayi Liao created FLINK-16051: -- Summary: subtask id in Checkpoint UI not consistent with TaskUI Key: FLINK-16051 URL: https://issues.apache.org/jira/browse/FLINK-16051 Project: Flink Issue Type

[jira] [Created] (FLINK-16042) Add state benchmark for append operation in AppendingState

Jiayi Liao created FLINK-16042: -- Summary: Add state benchmark for append operation in AppendingState Key: FLINK-16042 URL: https://issues.apache.org/jira/browse/FLINK-16042 Project: Flink Issue

[jira] [Created] (FLINK-16017) Improve attachJobGraph Performance

Jiayi Liao created FLINK-16017: -- Summary: Improve attachJobGraph Performance Key: FLINK-16017 URL: https://issues.apache.org/jira/browse/FLINK-16017 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16001) Avoid using Java Streams in construction of ExecutionGraph

Jiayi Liao created FLINK-16001: -- Summary: Avoid using Java Streams in construction of ExecutionGraph Key: FLINK-16001 URL: https://issues.apache.org/jira/browse/FLINK-16001 Project: Flink Issue

[jira] [Created] (FLINK-15923) Remove DISCARDED in TaskAcknowledgeResult

Jiayi Liao created FLINK-15923: -- Summary: Remove DISCARDED in TaskAcknowledgeResult Key: FLINK-15923 URL: https://issues.apache.org/jira/browse/FLINK-15923 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14996) Missing java doc in org.apache.flink.runtime.operators.TempBarrier

Jiayi Liao created FLINK-14996: -- Summary: Missing java doc in org.apache.flink.runtime.operators.TempBarrier Key: FLINK-14996 URL: https://issues.apache.org/jira/browse/FLINK-14996 Project: Flink

[jira] [Created] (FLINK-14950) Support getKey in WindowOperator.Context

Jiayi Liao created FLINK-14950: -- Summary: Support getKey in WindowOperator.Context Key: FLINK-14950 URL: https://issues.apache.org/jira/browse/FLINK-14950 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14833) Remove unnecessary SnapshotStrategySynchronicityBehavior from HeapSnapshotStrategy

Jiayi Liao created FLINK-14833: -- Summary: Remove unnecessary SnapshotStrategySynchronicityBehavior from HeapSnapshotStrategy Key: FLINK-14833 URL: https://issues.apache.org/jira/browse/FLINK-14833 Projec

[jira] [Created] (FLINK-14766) Remove volatile variable in ExecutionVertex

Jiayi Liao created FLINK-14766: -- Summary: Remove volatile variable in ExecutionVertex Key: FLINK-14766 URL: https://issues.apache.org/jira/browse/FLINK-14766 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-14744) Neighboring vertex should be chained if ship strategy is FORWARD or NONE

Jiayi Liao created FLINK-14744: -- Summary: Neighboring vertex should be chained if ship strategy is FORWARD or NONE Key: FLINK-14744 URL: https://issues.apache.org/jira/browse/FLINK-14744 Project: Flink

[jira] [Created] (FLINK-14736) Fail to connect Hive metastore

Jiayi Liao created FLINK-14736: -- Summary: Fail to connect Hive metastore Key: FLINK-14736 URL: https://issues.apache.org/jira/browse/FLINK-14736 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-14646) Check null for key in KeyGroupStreamPartitioner

Jiayi Liao created FLINK-14646: -- Summary: Check null for key in KeyGroupStreamPartitioner Key: FLINK-14646 URL: https://issues.apache.org/jira/browse/FLINK-14646 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-14519) Fail on invoking declineCheckpoint remotely

Jiayi Liao created FLINK-14519: -- Summary: Fail on invoking declineCheckpoint remotely Key: FLINK-14519 URL: https://issues.apache.org/jira/browse/FLINK-14519 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14463) Merge Handover in flink-connector-kafka and flink-connector-kafka-0.9

Jiayi Liao created FLINK-14463: -- Summary: Merge Handover in flink-connector-kafka and flink-connector-kafka-0.9 Key: FLINK-14463 URL: https://issues.apache.org/jira/browse/FLINK-14463 Project: Flink

[jira] [Created] (FLINK-14384) ValidationMatcher in FlinkSqlParserImplTest fails to test negative tests

Jiayi Liao created FLINK-14384: -- Summary: ValidationMatcher in FlinkSqlParserImplTest fails to test negative tests Key: FLINK-14384 URL: https://issues.apache.org/jira/browse/FLINK-14384 Project: Flink

[jira] [Created] (FLINK-13854) Support Aggregating in Join and CoGroup

Jiayi Liao created FLINK-13854: -- Summary: Support Aggregating in Join and CoGroup Key: FLINK-13854 URL: https://issues.apache.org/jira/browse/FLINK-13854 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11019) Expose the queryable proxy server port in taskinfo api

Jiayi Liao created FLINK-11019: -- Summary: Expose the queryable proxy server port in taskinfo api Key: FLINK-11019 URL: https://issues.apache.org/jira/browse/FLINK-11019 Project: Flink Issue Type

[jira] [Created] (FLINK-10807) KafkaConsumer still consume removed topic after changing topics list

Jiayi Liao created FLINK-10807: -- Summary: KafkaConsumer still consume removed topic after changing topics list Key: FLINK-10807 URL: https://issues.apache.org/jira/browse/FLINK-10807 Project: Flink

[jira] [Created] (FLINK-10806) Support consume from earliest offset with a new topic

Jiayi Liao created FLINK-10806: -- Summary: Support consume from earliest offset with a new topic Key: FLINK-10806 URL: https://issues.apache.org/jira/browse/FLINK-10806 Project: Flink Issue Type:

[jira] [Created] (FLINK-10654) AllowNonRestoredState should skip state that cannot be restored

Jiayi Liao created FLINK-10654: -- Summary: AllowNonRestoredState should skip state that cannot be restored Key: FLINK-10654 URL: https://issues.apache.org/jira/browse/FLINK-10654 Project: Flink

[jira] [Created] (FLINK-10641) Slow when applying new containers

Jiayi Liao created FLINK-10641: -- Summary: Slow when applying new containers Key: FLINK-10641 URL: https://issues.apache.org/jira/browse/FLINK-10641 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-10578) Support writable state in QueryableStateClient

Jiayi Liao created FLINK-10578: -- Summary: Support writable state in QueryableStateClient Key: FLINK-10578 URL: https://issues.apache.org/jira/browse/FLINK-10578 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-10560) JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn

Jiayi Liao created FLINK-10560: -- Summary: JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn Key: FLINK-10560 URL: https://issues.apache.org/jira/browse/FLINK-10560 Project: Flink

[jira] [Created] (FLINK-10539) Support specific namespace in QueryableStateClient

Jiayi Liao created FLINK-10539: -- Summary: Support specific namespace in QueryableStateClient Key: FLINK-10539 URL: https://issues.apache.org/jira/browse/FLINK-10539 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-10351) Ignore specific operator's state when restore from savepoint

Jiayi Liao created FLINK-10351: -- Summary: Ignore specific operator's state when restore from savepoint Key: FLINK-10351 URL: https://issues.apache.org/jira/browse/FLINK-10351 Project: Flink Iss

[jira] [Created] (FLINK-10350) Add assignTimestampsAndWatermarks in KeyedStream

Jiayi Liao created FLINK-10350: -- Summary: Add assignTimestampsAndWatermarks in KeyedStream Key: FLINK-10350 URL: https://issues.apache.org/jira/browse/FLINK-10350 Project: Flink Issue Type: New

[jira] [Created] (FLINK-10348) Solve data skew when consuming data from kafka

Jiayi Liao created FLINK-10348: -- Summary: Solve data skew when consuming data from kafka Key: FLINK-10348 URL: https://issues.apache.org/jira/browse/FLINK-10348 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-10306) Support the display of log file from any position on webUI

Jiayi Liao created FLINK-10306: -- Summary: Support the display of log file from any position on webUI Key: FLINK-10306 URL: https://issues.apache.org/jira/browse/FLINK-10306 Project: Flink Issue

[jira] [Created] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero.

Jiayi Liao created FLINK-10284: -- Summary: TumblingEventTimeWindows's offset should can be less than zero. Key: FLINK-10284 URL: https://issues.apache.org/jira/browse/FLINK-10284 Project: Flink