zhijiang created FLINK-13100:
Summary: Fix the unexpected IOException during
FileBufferReader#nextBuffer
Key: FLINK-13100
URL: https://issues.apache.org/jira/browse/FLINK-13100
Project: Flink
Is
zhijiang created FLINK-13126:
Summary: Construct special test/benchmark to verify the backlog
effect
Key: FLINK-13126
URL: https://issues.apache.org/jira/browse/FLINK-13126
Project: Flink
Issue
zhijiang created FLINK-13141:
Summary: Remove getBufferSize method from BufferPoolFactory
Key: FLINK-13141
URL: https://issues.apache.org/jira/browse/FLINK-13141
Project: Flink
Issue Type: Sub-ta
zhijiang created FLINK-13235:
Summary: Change the Netty default transport mode to auto
Key: FLINK-13235
URL: https://issues.apache.org/jira/browse/FLINK-13235
Project: Flink
Issue Type: Improveme
zhijiang created FLINK-13442:
Summary: Remove unnecessary notifySubpartitionConsumed method from
view reader
Key: FLINK-13442
URL: https://issues.apache.org/jira/browse/FLINK-13442
Project: Flink
zhijiang created FLINK-13478:
Summary: Decouple two different release strategies in
BoundedBlockingSubpartition
Key: FLINK-13478
URL: https://issues.apache.org/jira/browse/FLINK-13478
Project: Flink
zhijiang created FLINK-13493:
Summary: BoundedBlockingSubpartition only notifies
onConsumedSubpartition when all the readers are empty
Key: FLINK-13493
URL: https://issues.apache.org/jira/browse/FLINK-13493
zhijiang created FLINK-13753:
Summary: Integrate new Source Operator with Mailbox Model in
StreamTask
Key: FLINK-13753
URL: https://issues.apache.org/jira/browse/FLINK-13753
Project: Flink
Issue
zhijiang created FLINK-13754:
Summary: Decouple OperatorChain from StreamStatusMaintainer
Key: FLINK-13754
URL: https://issues.apache.org/jira/browse/FLINK-13754
Project: Flink
Issue Type: Sub-ta
zhijiang created FLINK-13762:
Summary: Integrate the implementation of
ForwardingValveOutputHandler for StreamOne/TwoInputProcessor
Key: FLINK-13762
URL: https://issues.apache.org/jira/browse/FLINK-13762
zhijiang created FLINK-13764:
Summary: Pass the counter of numRecordsIn into the constructors of
StreamOne/TwoInputProcessor
Key: FLINK-13764
URL: https://issues.apache.org/jira/browse/FLINK-13764
Project
zhijiang created FLINK-13765:
Summary: Introduce the InputSelectionHandler for selecting next
input in StreamTwoInputSelectableProcessor
Key: FLINK-13765
URL: https://issues.apache.org/jira/browse/FLINK-13765
zhijiang created FLINK-13766:
Summary: Refactor the implementation of StreamInputProcessor based
on StreamTaskInput#emitNext
Key: FLINK-13766
URL: https://issues.apache.org/jira/browse/FLINK-13766
Project
zhijiang created FLINK-13767:
Summary: Migrate isFinished method from AvailabilityListener to
AsyncDataInput
Key: FLINK-13767
URL: https://issues.apache.org/jira/browse/FLINK-13767
Project: Flink
zhijiang created FLINK-13798:
Summary: Refactor the process of checking stream status while
emitting watermark in source
Key: FLINK-13798
URL: https://issues.apache.org/jira/browse/FLINK-13798
Project: Fl
zhijiang created FLINK-14004:
Summary: Define SourceReader interface to verify the integration
with StreamOneInputProcessor
Key: FLINK-14004
URL: https://issues.apache.org/jira/browse/FLINK-14004
Project:
zhijiang created FLINK-15962:
Summary: Reduce the default chunk size in netty stack
Key: FLINK-15962
URL: https://issues.apache.org/jira/browse/FLINK-15962
Project: Flink
Issue Type: Improvement
zhijiang created FLINK-15963:
Summary: Reuse the same ByteBuf while writing the BufferResponse
header
Key: FLINK-15963
URL: https://issues.apache.org/jira/browse/FLINK-15963
Project: Flink
Issue
zhijiang created FLINK-16012:
Summary: Reduce the default number of exclusive buffers from 2 to
1 on receiver side
Key: FLINK-16012
URL: https://issues.apache.org/jira/browse/FLINK-16012
Project: Flink
Zhijiang created FLINK-16257:
Summary: Remove useless ResultPartitionID from AddCredit message
Key: FLINK-16257
URL: https://issues.apache.org/jira/browse/FLINK-16257
Project: Flink
Issue Type: I
Zhijiang created FLINK-16284:
Summary: Refactor SingleInputGate#setInputChannel to remove
IntermediateResultPartitionID argument
Key: FLINK-16284
URL: https://issues.apache.org/jira/browse/FLINK-16284
Pro
Zhijiang created FLINK-16285:
Summary: Refactor SingleInputGate#setInputChannel to remove
IntermediateResultPartitionID argument
Key: FLINK-16285
URL: https://issues.apache.org/jira/browse/FLINK-16285
Pro
Zhijiang created FLINK-16403:
Summary: Solve the potential deadlock problem when reducing
exclusive buffers to zero
Key: FLINK-16403
URL: https://issues.apache.org/jira/browse/FLINK-16403
Project: Flink
Zhijiang created FLINK-16404:
Summary: Solve the potential deadlock problem when reducing
exclusive buffers to zero
Key: FLINK-16404
URL: https://issues.apache.org/jira/browse/FLINK-16404
Project: Flink
Zhijiang created FLINK-16428:
Summary: Fine-grained network buffer management for backpressure
Key: FLINK-16428
URL: https://issues.apache.org/jira/browse/FLINK-16428
Project: Flink
Issue Type: I
Zhijiang created FLINK-16454:
Summary: Update the copyright year in NOTICE files
Key: FLINK-16454
URL: https://issues.apache.org/jira/browse/FLINK-16454
Project: Flink
Issue Type: Task
Zhijiang created FLINK-16536:
Summary: Implement InputChannel state recovery for unaligned
checkpoint
Key: FLINK-16536
URL: https://issues.apache.org/jira/browse/FLINK-16536
Project: Flink
Issue
Zhijiang created FLINK-16537:
Summary: Implement ResultPartition state recovery for unaligned
checkpoint
Key: FLINK-16537
URL: https://issues.apache.org/jira/browse/FLINK-16537
Project: Flink
Is
Zhijiang created FLINK-16564:
Summary: HadoopS3RecoverableWriterITCase fails with
NullPointerException
Key: FLINK-16564
URL: https://issues.apache.org/jira/browse/FLINK-16564
Project: Flink
Issu
Zhijiang created FLINK-16583:
Summary: SQLClientKafkaITCase.testKafka failed in
SqlClientException
Key: FLINK-16583
URL: https://issues.apache.org/jira/browse/FLINK-16583
Project: Flink
Issue Ty
Zhijiang created FLINK-16586:
Summary: Build ResultSubpartitionInfo and InputChannelInfo in
respective constructors
Key: FLINK-16586
URL: https://issues.apache.org/jira/browse/FLINK-16586
Project: Flink
Zhijiang created FLINK-16610:
Summary: FlinkKafkaInternalProducerITCase fails with timeout
exception
Key: FLINK-16610
URL: https://issues.apache.org/jira/browse/FLINK-16610
Project: Flink
Issue
Zhijiang created FLINK-16641:
Summary: Announce sender's backlog to solve the deadlock issue
without exclusive buffers
Key: FLINK-16641
URL: https://issues.apache.org/jira/browse/FLINK-16641
Project: Flin
Zhijiang created FLINK-16644:
Summary: HadoopS3FileSystemBehaviorITCase failed with null uri host
Key: FLINK-16644
URL: https://issues.apache.org/jira/browse/FLINK-16644
Project: Flink
Issue Type
Zhijiang created FLINK-16645:
Summary: Limit the maximum backlogs in subpartitions for data skew
case
Key: FLINK-16645
URL: https://issues.apache.org/jira/browse/FLINK-16645
Project: Flink
Issue
Zhijiang created FLINK-16653:
Summary: Introduce ResultPartitionWriterTestBase for simplifying
tests
Key: FLINK-16653
URL: https://issues.apache.org/jira/browse/FLINK-16653
Project: Flink
Issue
Zhijiang created FLINK-16690:
Summary: Refactor StreamTaskTest to reuse TestTaskBuilder and
MockStreamTaskBuilder
Key: FLINK-16690
URL: https://issues.apache.org/jira/browse/FLINK-16690
Project: Flink
Zhijiang created FLINK-16712:
Summary: Refactor StreamTask to construct final fields
Key: FLINK-16712
URL: https://issues.apache.org/jira/browse/FLINK-16712
Project: Flink
Issue Type: Task
Zhijiang created FLINK-16739:
Summary: PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails
with no such key
Key: FLINK-16739
URL: https://issues.apache.org/jira/browse/FLINK-16739
Project: Flink
Zhijiang created FLINK-16750:
Summary: Kerberized YARN on Docker test fails with staring Hadoop
cluster
Key: FLINK-16750
URL: https://issues.apache.org/jira/browse/FLINK-16750
Project: Flink
Iss
Zhijiang created FLINK-16768:
Summary:
HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart runs without
exit
Key: FLINK-16768
URL: https://issues.apache.org/jira/browse/FLINK-16768
Project:
Zhijiang created FLINK-16770:
Summary: Resuming Externalized Checkpoint (rocks, incremental,
scale up) end-to-end test fails with no such file
Key: FLINK-16770
URL: https://issues.apache.org/jira/browse/FLINK-16770
Zhijiang created FLINK-16821:
Summary: Run Kubernetes test failed with invalid named "minikube"
Key: FLINK-16821
URL: https://issues.apache.org/jira/browse/FLINK-16821
Project: Flink
Issue Type:
Zhijiang created FLINK-17092:
Summary: Pyflink failure for BlinkStreamDependencyTests and
StreamPandasUDFITTests
Key: FLINK-17092
URL: https://issues.apache.org/jira/browse/FLINK-17092
Project: Flink
Zhijiang created FLINK-17094:
Summary: OverWindowITCase#testRowTimeBoundedPartitionedRowsOver
failed by FileNotFoundException
Key: FLINK-17094
URL: https://issues.apache.org/jira/browse/FLINK-17094
Projec
Zhijiang created FLINK-17095:
Summary: KafkaProducerExactlyOnceITCase fails with "address
already in use"
Key: FLINK-17095
URL: https://issues.apache.org/jira/browse/FLINK-17095
Project: Flink
I
Zhijiang created FLINK-17315:
Summary:
UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel
failed in timeout
Key: FLINK-17315
URL: https://issues.apache.org/jira/browse/FLINK-17315
Zhijiang created FLINK-17389:
Summary: LocalExecutorITCase.testBatchQueryCancel asserts error
Key: FLINK-17389
URL: https://issues.apache.org/jira/browse/FLINK-17389
Project: Flink
Issue Type: Bu
Zhijiang created FLINK-17413:
Summary: Remove redundant states from ThreadSafeUnaligner
Key: FLINK-17413
URL: https://issues.apache.org/jira/browse/FLINK-17413
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-14289:
Summary: Remove Optional fields from RecordWriter relevant classes
Key: FLINK-14289
URL: https://issues.apache.org/jira/browse/FLINK-14289
Project: Flink
Issue Type:
zhijiang created FLINK-14394:
Summary: Remove unnecessary notifySubpartitionConsumed method from
view reader
Key: FLINK-14394
URL: https://issues.apache.org/jira/browse/FLINK-14394
Project: Flink
zhijiang created FLINK-14396:
Summary: Implement rudimentary non-blocking network output
Key: FLINK-14396
URL: https://issues.apache.org/jira/browse/FLINK-14396
Project: Flink
Issue Type: Task
zhijiang created FLINK-14472:
Summary: Implement back-pressure monitor with non-blocking outputs
Key: FLINK-14472
URL: https://issues.apache.org/jira/browse/FLINK-14472
Project: Flink
Issue Type:
zhijiang created FLINK-14498:
Summary: Introduce NetworkBufferPool#isAvailable() for interacting
with LocalBufferPool
Key: FLINK-14498
URL: https://issues.apache.org/jira/browse/FLINK-14498
Project: Flink
zhijiang created FLINK-14551:
Summary: Unaligned checkpoints
Key: FLINK-14551
URL: https://issues.apache.org/jira/browse/FLINK-14551
Project: Flink
Issue Type: New Feature
Components: R
zhijiang created FLINK-14553:
Summary: Respect non-blocking output in StreamTask#processInput
Key: FLINK-14553
URL: https://issues.apache.org/jira/browse/FLINK-14553
Project: Flink
Issue Type: Su
zhijiang created FLINK-15021:
Summary: Refactor to remove channelWritabilityChanged from
PartitionRequestQueue
Key: FLINK-15021
URL: https://issues.apache.org/jira/browse/FLINK-15021
Project: Flink
zhijiang created FLINK-15069:
Summary: Supplement the compression case for benchmark
Key: FLINK-15069
URL: https://issues.apache.org/jira/browse/FLINK-15069
Project: Flink
Issue Type: Task
zhijiang created FLINK-15070:
Summary: Supplement the case of bounded blocking partition for
benchmark
Key: FLINK-15070
URL: https://issues.apache.org/jira/browse/FLINK-15070
Project: Flink
Issu
zhijiang created FLINK-15187:
Summary: Reuse LocalBufferPool for FileBufferReader in blocking
partition
Key: FLINK-15187
URL: https://issues.apache.org/jira/browse/FLINK-15187
Project: Flink
Iss
zhijiang created FLINK-15306:
Summary: Adjust the default netty transport option from nio to auto
Key: FLINK-15306
URL: https://issues.apache.org/jira/browse/FLINK-15306
Project: Flink
Issue Type
zhijiang created FLINK-15340:
Summary: Remove the executor of pipelined compression benchmark
Key: FLINK-15340
URL: https://issues.apache.org/jira/browse/FLINK-15340
Project: Flink
Issue Type: Ta
zhijiang created FLINK-15444:
Summary: Make the component AbstractInvokable in
CheckpointBarrierHandler NonNull
Key: FLINK-15444
URL: https://issues.apache.org/jira/browse/FLINK-15444
Project: Flink
zhijiang created FLINK-15914:
Summary: Miss the barrier alignment metric for the case of two
inputs
Key: FLINK-15914
URL: https://issues.apache.org/jira/browse/FLINK-15914
Project: Flink
Issue T
zhijiang created FLINK-9636:
---
Summary: Network buffer leaks in requesting a batch of segments
during canceling
Key: FLINK-9636
URL: https://issues.apache.org/jira/browse/FLINK-9636
Project: Flink
zhijiang created FLINK-9676:
---
Summary: Deadlock during canceling task and recycling exclusive
buffer
Key: FLINK-9676
URL: https://issues.apache.org/jira/browse/FLINK-9676
Project: Flink
Issue Type
zhijiang created FLINK-9913:
---
Summary: Improve output serialization only once in RecordWriter
Key: FLINK-9913
URL: https://issues.apache.org/jira/browse/FLINK-9913
Project: Flink
Issue Type: Improv
zhijiang created FLINK-10321:
Summary: Make the condition of broadcast partitioner simple
Key: FLINK-10321
URL: https://issues.apache.org/jira/browse/FLINK-10321
Project: Flink
Issue Type: Improv
zhijiang created FLINK-10339:
Summary: SpillReadBufferPool cannot use off-heap memory
Key: FLINK-10339
URL: https://issues.apache.org/jira/browse/FLINK-10339
Project: Flink
Issue Type: Improvemen
zhijiang created FLINK-10367:
Summary: Avoid recursion stack overflow during releasing
SingleInputGate
Key: FLINK-10367
URL: https://issues.apache.org/jira/browse/FLINK-10367
Project: Flink
Issu
zhijiang created FLINK-10462:
Summary: Remove ConnectionIndex for further sharing tcp connection
in credit-based mode
Key: FLINK-10462
URL: https://issues.apache.org/jira/browse/FLINK-10462
Project: Flin
zhijiang created FLINK-10606:
Summary: Construct NetworkEnvironment simple for tests
Key: FLINK-10606
URL: https://issues.apache.org/jira/browse/FLINK-10606
Project: Flink
Issue Type: Test
zhijiang created FLINK-10607:
Summary: Unify to remove duplicated
NoOpResultPartitionConsumableNotifier
Key: FLINK-10607
URL: https://issues.apache.org/jira/browse/FLINK-10607
Project: Flink
Iss
zhijiang created FLINK-10653:
Summary: Propose of external shuffle service for batch jobs
Key: FLINK-10653
URL: https://issues.apache.org/jira/browse/FLINK-10653
Project: Flink
Issue Type: New Fe
zhijiang created FLINK-10661:
Summary: Initial credit should be configured in a separate
parameter
Key: FLINK-10661
URL: https://issues.apache.org/jira/browse/FLINK-10661
Project: Flink
Issue Ty
zhijiang created FLINK-10662:
Summary: Refactor the ChannelSelector interface for single
selected channel
Key: FLINK-10662
URL: https://issues.apache.org/jira/browse/FLINK-10662
Project: Flink
I
zhijiang created FLINK-10745:
Summary: Improve record writer and serializer stack
Key: FLINK-10745
URL: https://issues.apache.org/jira/browse/FLINK-10745
Project: Flink
Issue Type: Improvement
zhijiang created FLINK-10790:
Summary: Refactor all the StreamPartitioner implementations into
runtime module
Key: FLINK-10790
URL: https://issues.apache.org/jira/browse/FLINK-10790
Project: Flink
zhijiang created FLINK-10800:
Summary: Abstract the StreamPartitionerTest for common codes
Key: FLINK-10800
URL: https://issues.apache.org/jira/browse/FLINK-10800
Project: Flink
Issue Type: Sub-t
zhijiang created FLINK-10820:
Summary: Simplify the RebalancePartitioner implementation
Key: FLINK-10820
URL: https://issues.apache.org/jira/browse/FLINK-10820
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-10835:
Summary: Remove duplicated Round-robin ChannelSelector
implementation in RecordWriterTest
Key: FLINK-10835
URL: https://issues.apache.org/jira/browse/FLINK-10835
Project: Fli
zhijiang created FLINK-10942:
Summary: Deduplicate common codes in OutputEmitterTest
Key: FLINK-10942
URL: https://issues.apache.org/jira/browse/FLINK-10942
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-10995:
Summary: Copy intermediate serialization results only once for
broadcast mode
Key: FLINK-10995
URL: https://issues.apache.org/jira/browse/FLINK-10995
Project: Flink
zhijiang created FLINK-11035:
Summary: Notify data available to network stack immediately after
finishing BufferBuilder
Key: FLINK-11035
URL: https://issues.apache.org/jira/browse/FLINK-11035
Project: Fli
zhijiang created FLINK-11037:
Summary: Introduce another greedy mechanism for distributing
floating buffers
Key: FLINK-11037
URL: https://issues.apache.org/jira/browse/FLINK-11037
Project: Flink
zhijiang created FLINK-11082:
Summary: Increase backlog only if it is available for consumption
Key: FLINK-11082
URL: https://issues.apache.org/jira/browse/FLINK-11082
Project: Flink
Issue Type:
zhijiang created FLINK-11282:
Summary: Merge StreamRecordWriter into RecordWriter
Key: FLINK-11282
URL: https://issues.apache.org/jira/browse/FLINK-11282
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11403:
Summary: Remove ResultPartitionConsumableNotifier from
ResultPartition
Key: FLINK-11403
URL: https://issues.apache.org/jira/browse/FLINK-11403
Project: Flink
Issue
zhijiang created FLINK-11441:
Summary: Remove the schedule mode property from RPDD to TDD
Key: FLINK-11441
URL: https://issues.apache.org/jira/browse/FLINK-11441
Project: Flink
Issue Type: Sub-ta
zhijiang created FLINK-11460:
Summary: Remove useless AcknowledgeStreamMockEnvironment
Key: FLINK-11460
URL: https://issues.apache.org/jira/browse/FLINK-11460
Project: Flink
Issue Type: Task
zhijiang created FLINK-11461:
Summary: Remove useless MockRecordWriter
Key: FLINK-11461
URL: https://issues.apache.org/jira/browse/FLINK-11461
Project: Flink
Issue Type: Task
Components
zhijiang created FLINK-11604:
Summary: Extend the necessary methods in ResultPartitionWriter
interface
Key: FLINK-11604
URL: https://issues.apache.org/jira/browse/FLINK-11604
Project: Flink
Issu
zhijiang created FLINK-11646:
Summary: Remove legacy MockRecordWriter
Key: FLINK-11646
URL: https://issues.apache.org/jira/browse/FLINK-11646
Project: Flink
Issue Type: Test
Components:
zhijiang created FLINK-11676:
Summary: Make ResultPartitionWriter extend AutoCloseable
Key: FLINK-11676
URL: https://issues.apache.org/jira/browse/FLINK-11676
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11707:
Summary: Make InputGate interface extend AutoCloseable
Key: FLINK-11707
URL: https://issues.apache.org/jira/browse/FLINK-11707
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11721:
Summary: Remove IOMode from NetworkEnvironment
Key: FLINK-11721
URL: https://issues.apache.org/jira/browse/FLINK-11721
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11723:
Summary: Remove KvState related components from NetworkEnvironment
Key: FLINK-11723
URL: https://issues.apache.org/jira/browse/FLINK-11723
Project: Flink
Issue Type:
zhijiang created FLINK-11726:
Summary: Refactor the creation of ResultPartition and InputGate
into NetworkEnvironment
Key: FLINK-11726
URL: https://issues.apache.org/jira/browse/FLINK-11726
Project: Flink
zhijiang created FLINK-11750:
Summary: Refactor the creation of ResultPartitionID in
IntermediateResultPartition
Key: FLINK-11750
URL: https://issues.apache.org/jira/browse/FLINK-11750
Project: Flink
zhijiang created FLINK-11776:
Summary: Refactor to simplify the process of
scheduleOrUpdateConsumers
Key: FLINK-11776
URL: https://issues.apache.org/jira/browse/FLINK-11776
Project: Flink
Issue
1 - 100 of 157 matches
Mail list logo
