Lijie Wang created FLINK-33968:
--
Summary: Compute the number of subpartitions when initializing
executon job vertices
Key: FLINK-33968
URL: https://issues.apache.org/jira/browse/FLINK-33968
Project:
Lijie Wang created FLINK-33892:
--
Summary: FLIP-383: Support Job Recovery for Batch Jobs
Key: FLINK-33892
URL: https://issues.apache.org/jira/browse/FLINK-33892
Project: Flink
Issue Type: New
Lijie Wang created FLINK-32974:
--
Summary: RestClusterClient leaks flink-rest-client-jobgraphs*
directories
Key: FLINK-32974
URL: https://issues.apache.org/jira/browse/FLINK-32974
Project: Flink
Lijie Wang created FLINK-32844:
--
Summary: Runtime Filter should not be applied if the field is
already filtered by DPP
Key: FLINK-32844
URL: https://issues.apache.org/jira/browse/FLINK-32844
Project:
Lijie Wang created FLINK-32831:
--
Summary: RuntimeFilterProgram should aware join type when looking
for the build side
Key: FLINK-32831
URL: https://issues.apache.org/jira/browse/FLINK-32831
Project:
Lijie Wang created FLINK-32827:
--
Summary: Operator fusion codegen may not take effect when enable
runtime filter
Key: FLINK-32827
URL: https://issues.apache.org/jira/browse/FLINK-32827
Project: Flink
Lijie Wang created FLINK-32680:
--
Summary: Job vertex names get messed up once there is a source
vertex chained with a MultipleInput vertex in job graph
Key: FLINK-32680
URL:
Lijie Wang created FLINK-32492:
--
Summary: Introduce FlinkRuntimeFilterProgram to inject runtime
filter
Key: FLINK-32492
URL: https://issues.apache.org/jira/browse/FLINK-32492
Project: Flink
Lijie Wang created FLINK-32486:
--
Summary: FLIP-324: Introduce Runtime Filter for Flink Batch Jobs
Key: FLINK-32486
URL: https://issues.apache.org/jira/browse/FLINK-32486
Project: Flink
Issue
Lijie Wang created FLINK-32244:
--
Summary: flink-master-benchmarks-regression-check always fails
since 2023.05.30
Key: FLINK-32244
URL: https://issues.apache.org/jira/browse/FLINK-32244
Project: Flink
Lijie Wang created FLINK-32048:
--
Summary: DecimalITCase.testAggMinGroupBy fails with "Insufficient
number of network buffers"
Key: FLINK-32048
URL: https://issues.apache.org/jira/browse/FLINK-32048
Lijie Wang created FLINK-31651:
--
Summary: Improve logging of granting/revoking leadership in
JobMasterServiceLeadershipRunner to INFO level
Key: FLINK-31651
URL: https://issues.apache.org/jira/browse/FLINK-31651
Lijie Wang created FLINK-31650:
--
Summary: Incorrect busyMsTimePerSecond metric value for FINISHED
task
Key: FLINK-31650
URL: https://issues.apache.org/jira/browse/FLINK-31650
Project: Flink
Lijie Wang created FLINK-31114:
--
Summary: Batch job fails with IllegalStateException when using
adaptive batch scheduler
Key: FLINK-31114
URL: https://issues.apache.org/jira/browse/FLINK-31114
Project:
Lijie Wang created FLINK-31079:
--
Summary: Release Testing: Verify FLINK-29663 Further improvements
of adaptive batch scheduler
Key: FLINK-31079
URL: https://issues.apache.org/jira/browse/FLINK-31079
Lijie Wang created FLINK-31071:
--
Summary: Release Testing: Verify FLIP-283 Use adaptive batch
scheduler as default scheduler for batch jobs
Key: FLINK-31071
URL: https://issues.apache.org/jira/browse/FLINK-31071
Lijie Wang created FLINK-31055:
--
Summary: The dynamic flag of stream graph does not take effect
when translating the transformations
Key: FLINK-31055
URL: https://issues.apache.org/jira/browse/FLINK-31055
Lijie Wang created FLINK-30972:
--
Summary: E2e tests always fail in phase "Prepare E2E run"
Key: FLINK-30972
URL: https://issues.apache.org/jira/browse/FLINK-30972
Project: Flink
Issue Type: Bug
Lijie Wang created FLINK-30942:
--
Summary: Fix the bug that the decided parallelism by adaptive
batch scheduler may be larger than the max parallelism
Key: FLINK-30942
URL:
Lijie Wang created FLINK-30917:
--
Summary: The user configured max parallelism does not take effect
when using adaptive batch scheduler
Key: FLINK-30917
URL: https://issues.apache.org/jira/browse/FLINK-30917
Lijie Wang created FLINK-30670:
--
Summary: Ignore broadcast bytes when computing parallelism and
input infos
Key: FLINK-30670
URL: https://issues.apache.org/jira/browse/FLINK-30670
Project: Flink
Lijie Wang created FLINK-30641:
--
Summary: docs_404_check fail
Key: FLINK-30641
URL: https://issues.apache.org/jira/browse/FLINK-30641
Project: Flink
Issue Type: Bug
Reporter: Lijie
Lijie Wang created FLINK-30631:
--
Summary: Limit the max number of subpartitons consumed by each
downstream task
Key: FLINK-30631
URL: https://issues.apache.org/jira/browse/FLINK-30631
Project: Flink
Lijie Wang created FLINK-30604:
--
Summary: Remove the limitation of that parallelism decided by
adaptive batch scheduler must be power-of-two
Key: FLINK-30604
URL: https://issues.apache.org/jira/browse/FLINK-30604
Lijie Wang created FLINK-30601:
--
Summary: Omit "setKeyContextElement" call for non-keyed
stream/operators to improve performance
Key: FLINK-30601
URL: https://issues.apache.org/jira/browse/FLINK-30601
Lijie Wang created FLINK-30544:
--
Summary: Speed up finding minimum watermark across all channels by
introducing heap-based algorithm
Key: FLINK-30544
URL: https://issues.apache.org/jira/browse/FLINK-30544
Lijie Wang created FLINK-29666:
--
Summary: Let adaptive batch scheduler divide subpartition range
according to amount of data
Key: FLINK-29666
URL: https://issues.apache.org/jira/browse/FLINK-29666
Lijie Wang created FLINK-29665:
--
Summary: Support flexible subpartition range divisions
Key: FLINK-29665
URL: https://issues.apache.org/jira/browse/FLINK-29665
Project: Flink
Issue Type:
Lijie Wang created FLINK-29664:
--
Summary: Collect subpartition sizes of BLOCKING result partitions
Key: FLINK-29664
URL: https://issues.apache.org/jira/browse/FLINK-29664
Project: Flink
Issue
Lijie Wang created FLINK-29663:
--
Summary: Further improvements of adaptive batch scheduler
Key: FLINK-29663
URL: https://issues.apache.org/jira/browse/FLINK-29663
Project: Flink
Issue Type:
Lijie Wang created FLINK-29541:
--
Summary: [JUnit5 Migration] Module: flink-table-planner
Key: FLINK-29541
URL: https://issues.apache.org/jira/browse/FLINK-29541
Project: Flink
Issue Type:
Lijie Wang created FLINK-29348:
--
Summary: The DPP(dynamic partition pruning) can not work with
adaptive batch scheduler
Key: FLINK-29348
URL: https://issues.apache.org/jira/browse/FLINK-29348
Project:
Lijie Wang created FLINK-28873:
--
Summary: Make "jobmanager.scheduler" visible in documentation
Key: FLINK-28873
URL: https://issues.apache.org/jira/browse/FLINK-28873
Project: Flink
Issue Type:
Lijie Wang created FLINK-28698:
--
Summary: The display order of aggregated metrics should follow the
order of task state transitions
Key: FLINK-28698
URL: https://issues.apache.org/jira/browse/FLINK-28698
Lijie Wang created FLINK-28696:
--
Summary: Notify all newlyAdded/Merged blocked nodes to
BlocklistListener
Key: FLINK-28696
URL: https://issues.apache.org/jira/browse/FLINK-28696
Project: Flink
Lijie Wang created FLINK-28660:
--
Summary: Simplify logs of blocklist
Key: FLINK-28660
URL: https://issues.apache.org/jira/browse/FLINK-28660
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-28640:
--
Summary: Allow BlocklistDeclarativeSlotPool to accept duplicated
slot offers
Key: FLINK-28640
URL: https://issues.apache.org/jira/browse/FLINK-28640
Project: Flink
Lijie Wang created FLINK-28547:
--
Summary: Add IT cases for SpeculativeScheduler
Key: FLINK-28547
URL: https://issues.apache.org/jira/browse/FLINK-28547
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-28146:
--
Summary: Sync blocklist information between JobMaster &
ResourceManager
Key: FLINK-28146
URL: https://issues.apache.org/jira/browse/FLINK-28146
Project: Flink
Lijie Wang created FLINK-28145:
--
Summary: Let ResourceManager support blocklist mechanism
Key: FLINK-28145
URL: https://issues.apache.org/jira/browse/FLINK-28145
Project: Flink
Issue Type:
Lijie Wang created FLINK-28144:
--
Summary: Let JobMaster support blocklist mechanism
Key: FLINK-28144
URL: https://issues.apache.org/jira/browse/FLINK-28144
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-28143:
--
Summary: Introduce BlocklistHandler
Key: FLINK-28143
URL: https://issues.apache.org/jira/browse/FLINK-28143
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-28142:
--
Summary: Enrich TaskManagerLocation with node information
Key: FLINK-28142
URL: https://issues.apache.org/jira/browse/FLINK-28142
Project: Flink
Issue Type:
Lijie Wang created FLINK-28130:
--
Summary: FLIP-224: Blocklist Mechanism
Key: FLINK-28130
URL: https://issues.apache.org/jira/browse/FLINK-28130
Project: Flink
Issue Type: New Feature
Lijie Wang created FLINK-27637:
--
Summary: Optimize the log information when the asynchronous part
of checkpoint is canceled
Key: FLINK-27637
URL: https://issues.apache.org/jira/browse/FLINK-27637
Lijie Wang created FLINK-27078:
--
Summary: There is a performance gap between the new csv
source(file system source + CSV format) and legacy CsvTableSource.
Key: FLINK-27078
URL:
Lijie Wang created FLINK-26760:
--
Summary: The new CSV source (file system source + CSV format) does
not support reading files whose file encoding is not UTF-8
Key: FLINK-26760
URL:
Lijie Wang created FLINK-26576:
--
Summary: The value of 'readerParallelism' passed to
ContinuousFileMonitoringFunction is wrong
Key: FLINK-26576
URL: https://issues.apache.org/jira/browse/FLINK-26576
Lijie Wang created FLINK-26517:
--
Summary: Normalize the decided parallelism to power of 2 when
using adaptive batch scheduler
Key: FLINK-26517
URL: https://issues.apache.org/jira/browse/FLINK-26517
Lijie Wang created FLINK-26330:
--
Summary: Test Adaptive Batch Scheduler manually
Key: FLINK-26330
URL: https://issues.apache.org/jira/browse/FLINK-26330
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-26168:
--
Summary: The judgment of chainable ignores StreamExchangeMode when
partitioner is ForwardForConsecutiveHashPartitioner
Key: FLINK-26168
URL:
Lijie Wang created FLINK-26148:
--
Summary: Change the format of adaptive batch scheduler config
option to "jobmanager.adaptive-batch-scheduler.XXX"
Key: FLINK-26148
URL:
Lijie Wang created FLINK-26004:
--
Summary: Introduce ForwardForLocalKeyByPartitioner
Key: FLINK-26004
URL: https://issues.apache.org/jira/browse/FLINK-26004
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-25669:
--
Summary: Support register operator coordinators for newly
initialized ExecutionJobVertex.
Key: FLINK-25669
URL: https://issues.apache.org/jira/browse/FLINK-25669
Lijie Wang created FLINK-25668:
--
Summary: Support calcuate network memory for dynamic graph.
Key: FLINK-25668
URL: https://issues.apache.org/jira/browse/FLINK-25668
Project: Flink
Issue Type:
Lijie Wang created FLINK-25441:
--
Summary: ProducerFailedException will cause task status switch
from RUNNING to CANCELED, which will cause the job to hang.
Key: FLINK-25441
URL:
Lijie Wang created FLINK-25081:
--
Summary: When chaining an operator of a side output stream, the
num records sent displayed on the dashboard is incorrect
Key: FLINK-25081
URL:
Lijie Wang created FLINK-25046:
--
Summary: Convert forward edge to rescale when using adapive batch
scheduler
Key: FLINK-25046
URL: https://issues.apache.org/jira/browse/FLINK-25046
Project: Flink
Lijie Wang created FLINK-25045:
--
Summary: Introduce AdaptiveBatchScheduler
Key: FLINK-25045
URL: https://issues.apache.org/jira/browse/FLINK-25045
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-25036:
--
Summary: Introduce stage-wised scheduling strategy
Key: FLINK-25036
URL: https://issues.apache.org/jira/browse/FLINK-25036
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-25035:
--
Summary: Shuffle Service Supports Consuming Subpartition Range
Key: FLINK-25035
URL: https://issues.apache.org/jira/browse/FLINK-25035
Project: Flink
Issue
Lijie Wang created FLINK-25034:
--
Summary: Support flexible number of subpartitions in
IntermediateResultPartition
Key: FLINK-25034
URL: https://issues.apache.org/jira/browse/FLINK-25034
Project: Flink
Lijie Wang created FLINK-25033:
--
Summary: Let some scheduler components updatable.
Key: FLINK-25033
URL: https://issues.apache.org/jira/browse/FLINK-25033
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-25032:
--
Summary: Allow to create execution vertices and execution edges
lazily
Key: FLINK-25032
URL: https://issues.apache.org/jira/browse/FLINK-25032
Project: Flink
Lijie Wang created FLINK-25031:
--
Summary: Job finishes iff all job vertices finish
Key: FLINK-25031
URL: https://issues.apache.org/jira/browse/FLINK-25031
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-25011:
--
Summary: Introduce VertexParallelismDecider
Key: FLINK-25011
URL: https://issues.apache.org/jira/browse/FLINK-25011
Project: Flink
Issue Type: Sub-task
Lijie Wang created FLINK-24980:
--
Summary: Collect sizes of result partitions when tasks finish
Key: FLINK-24980
URL: https://issues.apache.org/jira/browse/FLINK-24980
Project: Flink
Issue Type:
Lijie Wang created FLINK-24945:
--
Summary: The exception location on the WebUI should contain TM's
ResourceID
Key: FLINK-24945
URL: https://issues.apache.org/jira/browse/FLINK-24945
Project: Flink
Lijie Wang created FLINK-24892:
--
Summary: FLIP-187: Adaptive Batch Job Scheduler
Key: FLINK-24892
URL: https://issues.apache.org/jira/browse/FLINK-24892
Project: Flink
Issue Type: New Feature
Lijie Wang created FLINK-24375:
--
Summary: The name of flush thread in RecordWriter should contain
subtask index
Key: FLINK-24375
URL: https://issues.apache.org/jira/browse/FLINK-24375
Project: Flink
Lijie Wang created FLINK-20725:
--
Summary: TableFunction#getTypeInference is not work well for
JdbcRowDataLookupFunction, it's always throws Exception
Key: FLINK-20725
URL:
Lijie Wang created FLINK-20160:
--
Summary: Implement standard metrics in JDBC connectors.
Key: FLINK-20160
URL: https://issues.apache.org/jira/browse/FLINK-20160
Project: Flink
Issue Type:
Lijie Wang created FLINK-18442:
--
Summary: Move `testSessionWindowsWithContinuousEventTimeTrigger`
to `ContinuousEventTimeTriggerTest`
Key: FLINK-18442
URL: https://issues.apache.org/jira/browse/FLINK-18442
Lijie Wang created FLINK-17296:
--
Summary: Support "create table if not exists" in JDBC table sink.
Key: FLINK-17296
URL: https://issues.apache.org/jira/browse/FLINK-17296
Project: Flink
Issue
Lijie Wang created FLINK-17294:
--
Summary: Using "DataSource" instead of "DriverManager" to get
connection in JDBC connector
Key: FLINK-17294
URL: https://issues.apache.org/jira/browse/FLINK-17294
Lijie Wang created FLINK-17178:
--
Summary: Provide "ALL" cache strategy in LookupFunction
Key: FLINK-17178
URL: https://issues.apache.org/jira/browse/FLINK-17178
Project: Flink
Issue Type: New
76 matches
Mail list logo
