Zhijiang created FLINK-19745:
Summary: Supplement micro-benchmark for bounded blocking partition
in remote channel case
Key: FLINK-19745
URL: https://issues.apache.org/jira/browse/FLINK-19745
Project: Fli
Zhijiang created FLINK-19551:
Summary: Follow up improvements for shuffle service
Key: FLINK-19551
URL: https://issues.apache.org/jira/browse/FLINK-19551
Project: Flink
Issue Type: Improvement
Zhijiang created FLINK-19003:
Summary: Add micro-benchmark for unaligned checkpoints
Key: FLINK-19003
URL: https://issues.apache.org/jira/browse/FLINK-19003
Project: Flink
Issue Type: Task
Zhijiang created FLINK-18612:
Summary: WordCount example failure when using relative output path
Key: FLINK-18612
URL: https://issues.apache.org/jira/browse/FLINK-18612
Project: Flink
Issue Type:
Zhijiang created FLINK-18591:
Summary: Fix the format issue for metrics web page
Key: FLINK-18591
URL: https://issues.apache.org/jira/browse/FLINK-18591
Project: Flink
Issue Type: Bug
C
Zhijiang created FLINK-18552:
Summary: Update migration tests in master to cover migration from
release-1.11
Key: FLINK-18552
URL: https://issues.apache.org/jira/browse/FLINK-18552
Project: Flink
Zhijiang created FLINK-18088:
Summary: Umbrella for features testing in release-1.11.0
Key: FLINK-18088
URL: https://issues.apache.org/jira/browse/FLINK-18088
Project: Flink
Issue Type: Test
Zhijiang created FLINK-18063:
Summary: Fix the race condition for aborting current checkpoint in
CheckpointBarrierUnaligner#processEndOfPartition
Key: FLINK-18063
URL: https://issues.apache.org/jira/browse/FLINK-18063
Zhijiang created FLINK-18050:
Summary: Fix the bug of recycling buffer twice once exception in
ChannelStateWriteRequestDispatcher#dispatch
Key: FLINK-18050
URL: https://issues.apache.org/jira/browse/FLINK-18050
Zhijiang created FLINK-17994:
Summary: Fix the race condition between
CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived
Key: FLINK-17994
URL: https://issues.apache.org/jira/browse/FLINK-17994
Zhijiang created FLINK-17992:
Summary: Exception from RemoteInputChannel#onBuffer should not
fail the whole NetworkClientHandler
Key: FLINK-17992
URL: https://issues.apache.org/jira/browse/FLINK-17992
Pro
Zhijiang created FLINK-17869:
Summary: Fix the race condition of aborting unaligned checkpoint
Key: FLINK-17869
URL: https://issues.apache.org/jira/browse/FLINK-17869
Project: Flink
Issue Type: B
Zhijiang created FLINK-17823:
Summary: Resolve the race condition while releasing
RemoteInputChannel
Key: FLINK-17823
URL: https://issues.apache.org/jira/browse/FLINK-17823
Project: Flink
Issue
Zhijiang created FLINK-17719:
Summary: Provide ChannelStateReader#hasStates for hints of reading
channel states
Key: FLINK-17719
URL: https://issues.apache.org/jira/browse/FLINK-17719
Project: Flink
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-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-17315:
Summary:
UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel
failed in timeout
Key: FLINK-17315
URL: https://issues.apache.org/jira/browse/FLINK-17315
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-17094:
Summary: OverWindowITCase#testRowTimeBoundedPartitionedRowsOver
failed by FileNotFoundException
Key: FLINK-17094
URL: https://issues.apache.org/jira/browse/FLINK-17094
Projec
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-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-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-16768:
Summary:
HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart runs without
exit
Key: FLINK-16768
URL: https://issues.apache.org/jira/browse/FLINK-16768
Project:
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-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-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-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-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-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-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-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-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-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-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-16564:
Summary: HadoopS3RecoverableWriterITCase fails with
NullPointerException
Key: FLINK-16564
URL: https://issues.apache.org/jira/browse/FLINK-16564
Project: Flink
Issu
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-13010:
Summary: Refactor the process of SchedulerNG#requestPartitionState
Key: FLINK-13010
URL: https://issues.apache.org/jira/browse/FLINK-13010
Project: Flink
Issue Type:
zhijiang created FLINK-12882:
Summary: Remove ExecutionAttemptID field from
ShuffleEnvironment#createResultPartitionWriters
Key: FLINK-12882
URL: https://issues.apache.org/jira/browse/FLINK-12882
Project:
zhijiang created FLINK-12843:
Summary: Refactor the pin logic in ResultPartition
Key: FLINK-12843
URL: https://issues.apache.org/jira/browse/FLINK-12843
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-12842:
Summary: Fix invalid check released state during
ResultPartition#createSubpartitionView
Key: FLINK-12842
URL: https://issues.apache.org/jira/browse/FLINK-12842
Project: Flink
zhijiang created FLINK-12738:
Summary: Remove abstract getPageSize from InputGate
Key: FLINK-12738
URL: https://issues.apache.org/jira/browse/FLINK-12738
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-12735:
Summary: Make shuffle environment implementation independent with
IOManager
Key: FLINK-12735
URL: https://issues.apache.org/jira/browse/FLINK-12735
Project: Flink
I
zhijiang created FLINK-12630:
Summary: Refactor abstract InputGate to general interface
Key: FLINK-12630
URL: https://issues.apache.org/jira/browse/FLINK-12630
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-12603:
Summary: Remove getOwningTaskName method from InputGate
Key: FLINK-12603
URL: https://issues.apache.org/jira/browse/FLINK-12603
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-12571:
Summary: Make NetworkEnvironment#start() return the binded data
port
Key: FLINK-12571
URL: https://issues.apache.org/jira/browse/FLINK-12571
Project: Flink
Issue Ty
zhijiang created FLINK-12564:
Summary: Remove getBufferProvider method from
ResultPartitionWriter interface
Key: FLINK-12564
URL: https://issues.apache.org/jira/browse/FLINK-12564
Project: Flink
zhijiang created FLINK-12544:
Summary: Deadlock during releasing memory in SpillableSubpartition
Key: FLINK-12544
URL: https://issues.apache.org/jira/browse/FLINK-12544
Project: Flink
Issue Type:
zhijiang created FLINK-12497:
Summary: Refactor the start method of ConnectionManager
Key: FLINK-12497
URL: https://issues.apache.org/jira/browse/FLINK-12497
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-12474:
Summary: UnionInputGate should be notified when closing
SingleInputGate by canceler thread
Key: FLINK-12474
URL: https://issues.apache.org/jira/browse/FLINK-12474
Project: Fl
zhijiang created FLINK-12458:
Summary: Throw PartitionNotFoundException if consumer can not
establish a connection to remote TM
Key: FLINK-12458
URL: https://issues.apache.org/jira/browse/FLINK-12458
Proj
zhijiang created FLINK-12331:
Summary: Introduce partition/gate setup to decouple task
registration with NetworkEnvironment
Key: FLINK-12331
URL: https://issues.apache.org/jira/browse/FLINK-12331
Project:
zhijiang created FLINK-12213:
Summary: Pass TaskManagerMetricGroup into constructor of
NetworkEnvironment
Key: FLINK-12213
URL: https://issues.apache.org/jira/browse/FLINK-12213
Project: Flink
I
zhijiang created FLINK-12154:
Summary: Remove legacy fields for SingleInputGate
Key: FLINK-12154
URL: https://issues.apache.org/jira/browse/FLINK-12154
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-12146:
Summary: Remove unregister task from NetworkEnvironment to
simplify the interface of ShuffleService
Key: FLINK-12146
URL: https://issues.apache.org/jira/browse/FLINK-12146
Pr
zhijiang created FLINK-12127:
Summary: Move network related options to NetworkEnvironmentOptions
Key: FLINK-12127
URL: https://issues.apache.org/jira/browse/FLINK-12127
Project: Flink
Issue Type:
zhijiang created FLINK-12078:
Summary: Abstract TaskEventPublisher interface for simplify
NetworkEnvironment
Key: FLINK-12078
URL: https://issues.apache.org/jira/browse/FLINK-12078
Project: Flink
zhijiang created FLINK-12067:
Summary: Refactor the constructor of NetworkEnvironment
Key: FLINK-12067
URL: https://issues.apache.org/jira/browse/FLINK-12067
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11988:
Summary: Remove legacy MockNetworkEnvironment
Key: FLINK-11988
URL: https://issues.apache.org/jira/browse/FLINK-11988
Project: Flink
Issue Type: Task
Compo
1 - 100 of 157 matches
Mail list logo
