Yuxin Tan created FLINK-35690:
-
Summary: Release Testing: Verify FLIP-459: Support Flink hybrid
shuffle integration with Apache Celeborn
Key: FLINK-35690
URL: https://issues.apache.org/jira/browse/FLINK-35690
Yuxin Tan created FLINK-35658:
-
Summary: Hybrid shuffle external tier can not work with
UnknownInputChannel
Key: FLINK-35658
URL: https://issues.apache.org/jira/browse/FLINK-35658
Project: Flink
Yuxin Tan created FLINK-35533:
-
Summary: FLIP-459: Support Flink hybrid shuffle integration with
Apache Celeborn
Key: FLINK-35533
URL: https://issues.apache.org/jira/browse/FLINK-35533
Project: Flink
Yuxin Tan created FLINK-35214:
-
Summary: Update result partition id for remote input channel when
unknown input channel is updated
Key: FLINK-35214
URL: https://issues.apache.org/jira/browse/FLINK-35214
Yuxin Tan created FLINK-35169:
-
Summary: Recycle buffers to freeSegments before releasing data
buffer for sort accumulator
Key: FLINK-35169
URL: https://issues.apache.org/jira/browse/FLINK-35169
Project:
Yuxin Tan created FLINK-35130:
-
Summary: Simplify AvailabilityNotifierImpl to support speculative
scheduler and improve performance
Key: FLINK-35130
URL: https://issues.apache.org/jira/browse/FLINK-35130
Yuxin Tan created FLINK-34544:
-
Summary: The release check bug in tiered memory manager of hybrid
shuffle
Key: FLINK-34544
URL: https://issues.apache.org/jira/browse/FLINK-34544
Project: Flink
Yuxin Tan created FLINK-33746:
-
Summary: More precise dynamic selection of Hybrid Shuffle or AQE
Key: FLINK-33746
URL: https://issues.apache.org/jira/browse/FLINK-33746
Project: Flink
Issue
Yuxin Tan created FLINK-33745:
-
Summary: Dynamically choose hybrid shuffle or AQE in a job level
Key: FLINK-33745
URL: https://issues.apache.org/jira/browse/FLINK-33745
Project: Flink
Issue
Yuxin Tan created FLINK-33744:
-
Summary: Hybrid shuffle avoids restarting the whole job when
failover
Key: FLINK-33744
URL: https://issues.apache.org/jira/browse/FLINK-33744
Project: Flink
Yuxin Tan created FLINK-33743:
-
Summary: Support consuming multiple subpartitions on a single
channel
Key: FLINK-33743
URL: https://issues.apache.org/jira/browse/FLINK-33743
Project: Flink
Yuxin Tan created FLINK-33742:
-
Summary: Hybrid Shuffle should work well with Adaptive Query
Execution
Key: FLINK-33742
URL: https://issues.apache.org/jira/browse/FLINK-33742
Project: Flink
Yuxin Tan created FLINK-33612:
-
Summary: The table plan of hybrid shuffle may introduce additional
blocking edges occasionally
Key: FLINK-33612
URL: https://issues.apache.org/jira/browse/FLINK-33612
Yuxin Tan created FLINK-33582:
-
Summary: Update flink-shaded version
Key: FLINK-33582
URL: https://issues.apache.org/jira/browse/FLINK-33582
Project: Flink
Issue Type: Bug
Components:
Yuxin Tan created FLINK-33493:
-
Summary: Elasticsearch connector ElasticsearchWriterITCase test
failed
Key: FLINK-33493
URL: https://issues.apache.org/jira/browse/FLINK-33493
Project: Flink
Yuxin Tan created FLINK-33417:
-
Summary: Update netty version to 4.1.83 for flink-shaded
Key: FLINK-33417
URL: https://issues.apache.org/jira/browse/FLINK-33417
Project: Flink
Issue Type: Bug
Yuxin Tan created FLINK-33370:
-
Summary: Simplify validateAndParseHostsString in Elasticsearch
connecter's configuration
Key: FLINK-33370
URL: https://issues.apache.org/jira/browse/FLINK-33370
Project:
Yuxin Tan created FLINK-33103:
-
Summary: Hybrid shuffle ITCase supports the new mode
Key: FLINK-33103
URL: https://issues.apache.org/jira/browse/FLINK-33103
Project: Flink
Issue Type:
Yuxin Tan created FLINK-33088:
-
Summary: Fix NullPointerException in RemoteTierConsumerAgent of
tiered storage
Key: FLINK-33088
URL: https://issues.apache.org/jira/browse/FLINK-33088
Project: Flink
Yuxin Tan created FLINK-33044:
-
Summary: Reduce the frequency of triggering flush for the disk
tier of the tiered storage
Key: FLINK-33044
URL: https://issues.apache.org/jira/browse/FLINK-33044
Project:
Yuxin Tan created FLINK-32870:
-
Summary: Merge multiple small buffers into one large buffer when
loading data for tiered storage
Key: FLINK-32870
URL: https://issues.apache.org/jira/browse/FLINK-32870
Yuxin Tan created FLINK-32709:
-
Summary: Modify segment size to improve memory utilization for
Hybrid Shuffle
Key: FLINK-32709
URL: https://issues.apache.org/jira/browse/FLINK-32709
Project: Flink
Yuxin Tan created FLINK-32675:
-
Summary: Add doc for the tiered storage of hybrid shuffle
Key: FLINK-32675
URL: https://issues.apache.org/jira/browse/FLINK-32675
Project: Flink
Issue Type:
Yuxin Tan created FLINK-32595:
-
Summary: Kinesis connector doc show wrong deserialization schema
version
Key: FLINK-32595
URL: https://issues.apache.org/jira/browse/FLINK-32595
Project: Flink
Yuxin Tan created FLINK-32576:
-
Summary: ProducerMergedPartitionFileIndex supports spilling to file
Key: FLINK-32576
URL: https://issues.apache.org/jira/browse/FLINK-32576
Project: Flink
Issue
Yuxin Tan created FLINK-32549:
-
Summary: Tiered storage memory manager supports ownership transfer
for buffers
Key: FLINK-32549
URL: https://issues.apache.org/jira/browse/FLINK-32549
Project: Flink
Yuxin Tan created FLINK-32541:
-
Summary: Fix the buffer leaking in buffer accumulators when a
failover occurs
Key: FLINK-32541
URL: https://issues.apache.org/jira/browse/FLINK-32541
Project: Flink
Yuxin Tan created FLINK-32538:
-
Summary: CI build failed because node is corrupted when compiling
Key: FLINK-32538
URL: https://issues.apache.org/jira/browse/FLINK-32538
Project: Flink
Issue
Yuxin Tan created FLINK-32425:
-
Summary: Fix Opensearch Connector wrong empty doc link
Key: FLINK-32425
URL: https://issues.apache.org/jira/browse/FLINK-32425
Project: Flink
Issue Type: Bug
Yuxin Tan created FLINK-32283:
-
Summary: Implement SortBufferAccumulator
Key: FLINK-32283
URL: https://issues.apache.org/jira/browse/FLINK-32283
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-32194:
-
Summary: Elasticsearch connector should remove the dependency on
flink-shaded
Key: FLINK-32194
URL: https://issues.apache.org/jira/browse/FLINK-32194
Project: Flink
Yuxin Tan created FLINK-32193:
-
Summary: AWS connector removes the dependency on flink-shaded
Key: FLINK-32193
URL: https://issues.apache.org/jira/browse/FLINK-32193
Project: Flink
Issue Type:
Yuxin Tan created FLINK-32101:
-
Summary: FlinkKafkaInternalProducerITCase.testInitTransactionId
test failed
Key: FLINK-32101
URL: https://issues.apache.org/jira/browse/FLINK-32101
Project: Flink
Yuxin Tan created FLINK-32060:
-
Summary: Migrate subclasses of BatchAbstractTestBase in table and
other modules to JUnit5
Key: FLINK-32060
URL: https://issues.apache.org/jira/browse/FLINK-32060
Project:
Yuxin Tan created FLINK-32059:
-
Summary: Migrate subclasses of BatchAbstractTestBase in
batch.sql.agg and batch.sql.join to JUnit5
Key: FLINK-32059
URL: https://issues.apache.org/jira/browse/FLINK-32059
Yuxin Tan created FLINK-32058:
-
Summary: Migrate subclasses of BatchAbstractTestBase in
runtime.batch.sql to JUnit5
Key: FLINK-32058
URL: https://issues.apache.org/jira/browse/FLINK-32058
Project: Flink
Yuxin Tan created FLINK-32055:
-
Summary: Migrate all subclasses of BatchAbstractTestBase to JUnit5
Key: FLINK-32055
URL: https://issues.apache.org/jira/browse/FLINK-32055
Project: Flink
Issue
Yuxin Tan created FLINK-31878:
-
Summary: Fix the wrong name of PauseOrResumeSplitsTask#toString in
connector fetcher
Key: FLINK-31878
URL: https://issues.apache.org/jira/browse/FLINK-31878
Project:
Yuxin Tan created FLINK-31720:
-
Summary: Pulsar connector v3.0 branch's docs are empty
Key: FLINK-31720
URL: https://issues.apache.org/jira/browse/FLINK-31720
Project: Flink
Issue Type: Bug
Yuxin Tan created FLINK-31688:
-
Summary: Broken links in docs for Azure Table Storage
Key: FLINK-31688
URL: https://issues.apache.org/jira/browse/FLINK-31688
Project: Flink
Issue Type: Bug
Yuxin Tan created FLINK-31671:
-
Summary: [Connectors/HBase] Update flink to 1.17.0
Key: FLINK-31671
URL: https://issues.apache.org/jira/browse/FLINK-31671
Project: Flink
Issue Type: Improvement
Yuxin Tan created FLINK-31647:
-
Summary: Introduce remote storage tier reader
Key: FLINK-31647
URL: https://issues.apache.org/jira/browse/FLINK-31647
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31646:
-
Summary: Introduce remote storage tier
Key: FLINK-31646
URL: https://issues.apache.org/jira/browse/FLINK-31646
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31644:
-
Summary: Introduce disk tier
Key: FLINK-31644
URL: https://issues.apache.org/jira/browse/FLINK-31644
Project: Flink
Issue Type: Sub-task
Components:
Yuxin Tan created FLINK-31645:
-
Summary: Introduce disk tier reader
Key: FLINK-31645
URL: https://issues.apache.org/jira/browse/FLINK-31645
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31643:
-
Summary: Introduce a temporary switch to enable the new shuffle
implementation
Key: FLINK-31643
URL: https://issues.apache.org/jira/browse/FLINK-31643
Project: Flink
Yuxin Tan created FLINK-31641:
-
Summary: Introduce memory tier
Key: FLINK-31641
URL: https://issues.apache.org/jira/browse/FLINK-31641
Project: Flink
Issue Type: Sub-task
Components:
Yuxin Tan created FLINK-31642:
-
Summary: Introduce memory tier reader
Key: FLINK-31642
URL: https://issues.apache.org/jira/browse/FLINK-31642
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31640:
-
Summary: Introduce segment index tracker
Key: FLINK-31640
URL: https://issues.apache.org/jira/browse/FLINK-31640
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31639:
-
Summary: Introduce tiered store memory manager
Key: FLINK-31639
URL: https://issues.apache.org/jira/browse/FLINK-31639
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31638:
-
Summary: Downstream supports reading buffers from tiered store
Key: FLINK-31638
URL: https://issues.apache.org/jira/browse/FLINK-31638
Project: Flink
Issue Type:
Yuxin Tan created FLINK-31637:
-
Summary: Introduce buffer accumulator tier
Key: FLINK-31637
URL: https://issues.apache.org/jira/browse/FLINK-31637
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31636:
-
Summary: Upstream supports reading buffers from tiered store
Key: FLINK-31636
URL: https://issues.apache.org/jira/browse/FLINK-31636
Project: Flink
Issue Type:
Yuxin Tan created FLINK-31635:
-
Summary: Support writing records to the new tiered store
architecture
Key: FLINK-31635
URL: https://issues.apache.org/jira/browse/FLINK-31635
Project: Flink
Yuxin Tan created FLINK-31634:
-
Summary: FLIP-301: Hybrid Shuffle supports Remote Storage
Key: FLINK-31634
URL: https://issues.apache.org/jira/browse/FLINK-31634
Project: Flink
Issue Type: New
Yuxin Tan created FLINK-31396:
-
Summary: Occasional inaccurate timeout time calculation with
System.nanotime in batch read buffer pool
Key: FLINK-31396
URL: https://issues.apache.org/jira/browse/FLINK-31396
Yuxin Tan created FLINK-31314:
-
Summary: Hybrid
Key: FLINK-31314
URL: https://issues.apache.org/jira/browse/FLINK-31314
Project: Flink
Issue Type: Improvement
Reporter: Yuxin Tan
Yuxin Tan created FLINK-30712:
-
Summary: Update network memory configuration docs
Key: FLINK-30712
URL: https://issues.apache.org/jira/browse/FLINK-30712
Project: Flink
Issue Type: Improvement
Yuxin Tan created FLINK-30473:
-
Summary: Optimize the InputGate network memory management for
TaskManager
Key: FLINK-30473
URL: https://issues.apache.org/jira/browse/FLINK-30473
Project: Flink
Yuxin Tan created FLINK-30472:
-
Summary: Modify the default value of the max network memory config
option
Key: FLINK-30472
URL: https://issues.apache.org/jira/browse/FLINK-30472
Project: Flink
Yuxin Tan created FLINK-30471:
-
Summary: Optimize the enriching network memory process in
SsgNetworkMemoryCalculationUtils
Key: FLINK-30471
URL: https://issues.apache.org/jira/browse/FLINK-30471
Project:
Yuxin Tan created FLINK-30469:
-
Summary: FLIP-266: Simplify network memory configurations for
TaskManager
Key: FLINK-30469
URL: https://issues.apache.org/jira/browse/FLINK-30469
Project: Flink
Yuxin Tan created FLINK-29329:
-
Summary: Checkpoint can not be triggered if encountering OOM
Key: FLINK-29329
URL: https://issues.apache.org/jira/browse/FLINK-29329
Project: Flink
Issue Type:
Yuxin Tan created FLINK-28942:
-
Summary: Deadlock may occurs when releasing readers for
SortMergeResultPartition
Key: FLINK-28942
URL: https://issues.apache.org/jira/browse/FLINK-28942
Project: Flink
Yuxin Tan created FLINK-28828:
-
Summary: Sorting all unfinished readers in batches at one time in
SortMergeResultPartitionReadScheduler
Key: FLINK-28828
URL: https://issues.apache.org/jira/browse/FLINK-28828
Yuxin Tan created FLINK-28826:
-
Summary: Avoid notifying too frequently when recycling buffers for
BatchShuffleReadBufferPool
Key: FLINK-28826
URL: https://issues.apache.org/jira/browse/FLINK-28826
Yuxin Tan created FLINK-28823:
-
Summary: Enlarge the max requested buffers for
SortMergeResultPartitionReadScheduler
Key: FLINK-28823
URL: https://issues.apache.org/jira/browse/FLINK-28823
Project: Flink
Yuxin Tan created FLINK-28446:
-
Summary: Expose more information in PartitionDescriptor to support
more optimized Shuffle Service
Key: FLINK-28446
URL: https://issues.apache.org/jira/browse/FLINK-28446
68 matches
Mail list logo
