[jira] [Created] (FLINK-17921) RpcGlobalAggregateManager#updateGlobalAggregate would cause akka.timeout

zhangminglei created FLINK-17921: Summary: RpcGlobalAggregateManager#updateGlobalAggregate would cause akka.timeout Key: FLINK-17921 URL: https://issues.apache.org/jira/browse/FLINK-17921 Project: Fli

[jira] [Created] (FLINK-17919) KafkaConsumerThread should add ratelimiter functionality as well

zhangminglei created FLINK-17919: Summary: KafkaConsumerThread should add ratelimiter functionality as well Key: FLINK-17919 URL: https://issues.apache.org/jira/browse/FLINK-17919 Project: Flink

[jira] [Created] (FLINK-10114) Support Orc for StreamingFileSink

zhangminglei created FLINK-10114: Summary: Support Orc for StreamingFileSink Key: FLINK-10114 URL: https://issues.apache.org/jira/browse/FLINK-10114 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9985) Incorrect parameter order in document

zhangminglei created FLINK-9985: --- Summary: Incorrect parameter order in document Key: FLINK-9985 URL: https://issues.apache.org/jira/browse/FLINK-9985 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-9982) NPE in EnumValueSerializer#copy

zhangminglei created FLINK-9982: --- Summary: NPE in EnumValueSerializer#copy Key: FLINK-9982 URL: https://issues.apache.org/jira/browse/FLINK-9982 Project: Flink Issue Type: Bug Repor

[jira] [Created] (FLINK-9901) Refactor InputStreamReader to Channels.newReader

zhangminglei created FLINK-9901: --- Summary: Refactor InputStreamReader to Channels.newReader Key: FLINK-9901 URL: https://issues.apache.org/jira/browse/FLINK-9901 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

zhangminglei created FLINK-9900: --- Summary: Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Key: FLINK-9900 URL: https://issues.apache.org/j