Junrui Li created FLINK-31931:
-
Summary: Exception history page should not link to a non-existent
TM log page.
Key: FLINK-31931
URL: https://issues.apache.org/jira/browse/FLINK-31931
Project: Flink
Junrui Li created FLINK-32199:
-
Summary: MetricStore does not remove metrics of nonexistent
parallelism in TaskMetricStore when scale down job parallelism
Key: FLINK-32199
URL: https://issues.apache.org/jira/browse/FL
Junrui Li created FLINK-32217:
-
Summary: Retain metric store can cause NPE
Key: FLINK-32217
URL: https://issues.apache.org/jira/browse/FLINK-32217
Project: Flink
Issue Type: Bug
Compon
Junrui Li created FLINK-32788:
-
Summary: SpeculativeScheduler do not handle allocate task errors
when schedule speculative tasks may causes resource leakage.
Key: FLINK-32788
URL: https://issues.apache.org/jira/browse
Junrui Li created FLINK-32876:
-
Summary: ExecutionTimeBasedSlowTaskDetector treats unscheduled
tasks as slow tasks and causes speculative execution to fail.
Key: FLINK-32876
URL: https://issues.apache.org/jira/browse/
Junrui Li created FLINK-33080:
-
Summary: The checkpoint storage configured in the job level by
config option will not take effect
Key: FLINK-33080
URL: https://issues.apache.org/jira/browse/FLINK-33080
Pr
Junrui Li created FLINK-33084:
-
Summary: Migrate globalJobParameter in ExecutionConfig to
configuration instance
Key: FLINK-33084
URL: https://issues.apache.org/jira/browse/FLINK-33084
Project: Flink
Junrui Li created FLINK-33298:
-
Summary: CLONE - Add a suffix to keys that violate YAML spec
Key: FLINK-33298
URL: https://issues.apache.org/jira/browse/FLINK-33298
Project: Flink
Issue Type: Sub
Junrui Li created FLINK-33297:
-
Summary: CLONE - Introduce proper YAML parsing to Flink's
configuration
Key: FLINK-33297
URL: https://issues.apache.org/jira/browse/FLINK-33297
Project: Flink
Iss
Junrui Li created FLINK-33299:
-
Summary: CLONE - Add checks to guarantee the non-deprecated
options not conflicting with standard YAML
Key: FLINK-33299
URL: https://issues.apache.org/jira/browse/FLINK-33299
Junrui Li created FLINK-33356:
-
Summary: The navigation bar on Flink’s official website is messed
up.
Key: FLINK-33356
URL: https://issues.apache.org/jira/browse/FLINK-33356
Project: Flink
Issue
Junrui Li created FLINK-33364:
-
Summary: Introduce standard YAML for flink configuration
Key: FLINK-33364
URL: https://issues.apache.org/jira/browse/FLINK-33364
Project: Flink
Issue Type: Sub-tas
Junrui Li created FLINK-33576:
-
Summary: Introduce new Flink conf file config.yaml supporting
standard YAML syntax
Key: FLINK-33576
URL: https://issues.apache.org/jira/browse/FLINK-33576
Project: Flink
Junrui Li created FLINK-33577:
-
Summary: Make "conf.yaml" as the default Flink configuration file
Key: FLINK-33577
URL: https://issues.apache.org/jira/browse/FLINK-33577
Project: Flink
Issue Type
Junrui Li created FLINK-33581:
-
Summary: FLIP-381: Deprecate configuration getters/setters that
return/set complex Java objects
Key: FLINK-33581
URL: https://issues.apache.org/jira/browse/FLINK-33581
Proj
Junrui Li created FLINK-33669:
-
Summary: Update the documentation for RestartStrategy, Checkpoint
Storage, and State Backend.
Key: FLINK-33669
URL: https://issues.apache.org/jira/browse/FLINK-33669
Projec
Junrui Li created FLINK-33678:
-
Summary: Remove configuration getters/setters that return/set
complex Java objects
Key: FLINK-33678
URL: https://issues.apache.org/jira/browse/FLINK-33678
Project: Flink
Junrui Li created FLINK-33712:
-
Summary: FLIP-391: Deprecate RuntimeContext#getExecutionConfig
Key: FLINK-33712
URL: https://issues.apache.org/jira/browse/FLINK-33712
Project: Flink
Issue Type: T
Junrui Li created FLINK-33713:
-
Summary: Deprecate RuntimeContext#getExecutionConfig
Key: FLINK-33713
URL: https://issues.apache.org/jira/browse/FLINK-33713
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-33714:
-
Summary: Update documentation about the usage of
RuntimeContext#getExecutionConfig
Key: FLINK-33714
URL: https://issues.apache.org/jira/browse/FLINK-33714
Project: Flink
Junrui Li created FLINK-33721:
-
Summary: Extend BashJavaUtils to Support Reading and Writing
Standard YAML Files
Key: FLINK-33721
URL: https://issues.apache.org/jira/browse/FLINK-33721
Project: Flink
Junrui Li created FLINK-33749:
-
Summary: Remove deprecated getter method in Configuration.
Key: FLINK-33749
URL: https://issues.apache.org/jira/browse/FLINK-33749
Project: Flink
Issue Type: Sub-t
Junrui Li created FLINK-33750:
-
Summary: Remove deprecated config options.
Key: FLINK-33750
URL: https://issues.apache.org/jira/browse/FLINK-33750
Project: Flink
Issue Type: Sub-task
Co
Junrui Li created FLINK-33980:
-
Summary: Reorganize job configuration
Key: FLINK-33980
URL: https://issues.apache.org/jira/browse/FLINK-33980
Project: Flink
Issue Type: Technical Debt
C
Junrui Li created FLINK-33982:
-
Summary: Introduce new config options for Job Recovery.
Key: FLINK-33982
URL: https://issues.apache.org/jira/browse/FLINK-33982
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-33983:
-
Summary: Introduce JobEvent and JobEventStore for Job Recovery
Key: FLINK-33983
URL: https://issues.apache.org/jira/browse/FLINK-33983
Project: Flink
Issue Type: S
Junrui Li created FLINK-33984:
-
Summary: Introduce SupportsBatchSnapshot for operator coordinator
Key: FLINK-33984
URL: https://issues.apache.org/jira/browse/FLINK-33984
Project: Flink
Issue Type
Junrui Li created FLINK-33985:
-
Summary: Extend ShuffleMaster to fetch all partition
Key: FLINK-33985
URL: https://issues.apache.org/jira/browse/FLINK-33985
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-33986:
-
Summary: Introduce SupportsBatchSnapshot for shuffle master
Key: FLINK-33986
URL: https://issues.apache.org/jira/browse/FLINK-33986
Project: Flink
Issue Type: Sub-
Junrui Li created FLINK-34052:
-
Summary: Missing TopSpeedWindowing and SessionWindowing JARs in
Flink Maven Repository
Key: FLINK-34052
URL: https://issues.apache.org/jira/browse/FLINK-34052
Project: Flin
JunRui Li created FLINK-30682:
-
Summary: FLIP-283: Use adaptive batch scheduler as default
scheduler for batch jobs
Key: FLINK-30682
URL: https://issues.apache.org/jira/browse/FLINK-30682
Project: Flink
Junrui Li created FLINK-30683:
-
Summary: Make adaptive batch scheduler as the default batch
scheduler
Key: FLINK-30683
URL: https://issues.apache.org/jira/browse/FLINK-30683
Project: Flink
Issue
Junrui Li created FLINK-30684:
-
Summary: Use the default parallelism as a flag for vertices that
can automatically derive parallelism.
Key: FLINK-30684
URL: https://issues.apache.org/jira/browse/FLINK-30684
Junrui Li created FLINK-30685:
-
Summary: Support mark the transformations whose parallelism is
infected by the input transformation
Key: FLINK-30685
URL: https://issues.apache.org/jira/browse/FLINK-30685
Junrui Li created FLINK-30686:
-
Summary: Simplify the configuration of adaptive batch scheduler
Key: FLINK-30686
URL: https://issues.apache.org/jira/browse/FLINK-30686
Project: Flink
Issue Type:
Junrui Li created FLINK-30808:
-
Summary: MultipleInputITCase failed with AdaptiveBatch Scheduler
Key: FLINK-30808
URL: https://issues.apache.org/jira/browse/FLINK-30808
Project: Flink
Issue Type:
Junrui Li created FLINK-30821:
-
Summary: The optimized exec plan generated by
OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of
all-blocking is not as expected
Key: FLINK-30821
URL: https://iss
Junrui Li created FLINK-30838:
-
Summary: Update documentation about the AdaptiveBatchScheduler
Key: FLINK-30838
URL: https://issues.apache.org/jira/browse/FLINK-30838
Project: Flink
Issue Type: S
Junrui Li created FLINK-30875:
-
Summary: Remove legacy AdaptiveBatchScheduler min parallelism
configuration call.
Key: FLINK-30875
URL: https://issues.apache.org/jira/browse/FLINK-30875
Project: Flink
Junrui Li created FLINK-30889:
-
Summary: Rename the configuration key SPECULATIVE_ENABLED.
Key: FLINK-30889
URL: https://issues.apache.org/jira/browse/FLINK-30889
Project: Flink
Issue Type: Bug
Junrui Li created FLINK-30901:
-
Summary: Fix set jobVertex parallelismConfigured don't contain
chained sources.
Key: FLINK-30901
URL: https://issues.apache.org/jira/browse/FLINK-30901
Project: Flink
Junrui Li created FLINK-30903:
-
Summary: Fix the maxParallelism of
DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism
Key: FLINK-30903
URL: https://issues.apache.org/jira/browse/FLINK-30903
Junrui Li created FLINK-31077:
-
Summary: Trigger checkpoint failed but it were shown as COMPLETED
by rest API
Key: FLINK-31077
URL: https://issues.apache.org/jira/browse/FLINK-31077
Project: Flink
Junrui Li created FLINK-31853:
-
Summary: Remove use of ExecutionAttemptMappingProvider
Key: FLINK-31853
URL: https://issues.apache.org/jira/browse/FLINK-31853
Project: Flink
Issue Type: Improvem
Junrui Li created FLINK-34126:
-
Summary: Correct the description of jobmanager.scheduler
Key: FLINK-34126
URL: https://issues.apache.org/jira/browse/FLINK-34126
Project: Flink
Issue Type: Bug
Junrui Li created FLINK-34205:
-
Summary: Update flink-docker's Dockerfile and docker-entrypoint.sh
to use BashJavaUtils for Flink configuration management
Key: FLINK-34205
URL: https://issues.apache.org/jira/browse/FL
Junrui Li created FLINK-34223:
-
Summary: Introduce a migration tool to transfer legacy config file
to new config file
Key: FLINK-34223
URL: https://issues.apache.org/jira/browse/FLINK-34223
Project: Flink
Junrui Li created FLINK-34232:
-
Summary: Config file unexpectedly lacks support for env.java.home
Key: FLINK-34232
URL: https://issues.apache.org/jira/browse/FLINK-34232
Project: Flink
Issue Type
Junrui Li created FLINK-34247:
-
Summary: Document FLIP-366: Support standard YAML for FLINK
configuration
Key: FLINK-34247
URL: https://issues.apache.org/jira/browse/FLINK-34247
Project: Flink
I
Junrui Li created FLINK-34257:
-
Summary: Update Flink YAML Parser to Support YAML 1.2
Specification
Key: FLINK-34257
URL: https://issues.apache.org/jira/browse/FLINK-34257
Project: Flink
Issue
Junrui Li created FLINK-34377:
-
Summary: Release Testing : Verify FLINK-33297 Support standard
YAML for FLINK configuration
Key: FLINK-34377
URL: https://issues.apache.org/jira/browse/FLINK-34377
Project:
Junrui Li created FLINK-34661:
-
Summary: TaskExecutor supports retain partitions after JM crashed.
Key: FLINK-34661
URL: https://issues.apache.org/jira/browse/FLINK-34661
Project: Flink
Issue Typ
Junrui Li created FLINK-34731:
-
Summary: Remove SpeculativeScheduler and incorporate its features
into AdaptiveBatchScheduler
Key: FLINK-34731
URL: https://issues.apache.org/jira/browse/FLINK-34731
Projec
Junrui Li created FLINK-34945:
-
Summary: Support recover shuffle descriptor and partition metrics
from tiered storage
Key: FLINK-34945
URL: https://issues.apache.org/jira/browse/FLINK-34945
Project: Flink
Junrui Li created FLINK-35465:
-
Summary: Introduce BatchJobRecoveryHandler for recovery of batch
jobs from JobMaster failures.
Key: FLINK-35465
URL: https://issues.apache.org/jira/browse/FLINK-35465
Proje
Junrui Li created FLINK-35587:
-
Summary: Job fails with "The read buffer is null in credit-based
input channel" on TPC-DS 10TB benchmark
Key: FLINK-35587
URL: https://issues.apache.org/jira/browse/FLINK-35587
Junrui Li created FLINK-35622:
-
Summary: Filter out noisy "Coordinator of operator does not
exist" exceptions in batch mode
Key: FLINK-35622
URL: https://issues.apache.org/jira/browse/FLINK-35622
Pro
Junrui Li created FLINK-35669:
-
Summary: Release Testing: Verify FLIP-383: Support Job Recovery
from JobMaster Failures for Batch Jobs
Key: FLINK-35669
URL: https://issues.apache.org/jira/browse/FLINK-35669
Junrui Li created FLINK-35731:
-
Summary: Sink V2 operator is mistakenly assumed always to be
parallelism configured
Key: FLINK-35731
URL: https://issues.apache.org/jira/browse/FLINK-35731
Project: Flink
Junrui Li created FLINK-35766:
-
Summary: When the job contains many YieldingOperatorFactory
instances, compiling the JobGraph hangs
Key: FLINK-35766
URL: https://issues.apache.org/jira/browse/FLINK-35766
Junrui Li created FLINK-36032:
-
Summary: FLIP-468: Introducing StreamGraph-Based Job Submission
Key: FLINK-36032
URL: https://issues.apache.org/jira/browse/FLINK-36032
Project: Flink
Issue Type:
Junrui Li created FLINK-36033:
-
Summary: FLIP-469: Supports Adaptive Optimization of StreamGraph
Key: FLINK-36033
URL: https://issues.apache.org/jira/browse/FLINK-36033
Project: Flink
Issue Type:
Junrui Li created FLINK-36063:
-
Summary: Migrate StreamGraph and its related classes to
flink-runtime
Key: FLINK-36063
URL: https://issues.apache.org/jira/browse/FLINK-36063
Project: Flink
Issue
Junrui Li created FLINK-36064:
-
Summary: Refactor CollectResultIterator to eliminate dependency on
OperatorID
Key: FLINK-36064
URL: https://issues.apache.org/jira/browse/FLINK-36064
Project: Flink
Junrui Li created FLINK-36065:
-
Summary: Support for submitting StreamGraph
Key: FLINK-36065
URL: https://issues.apache.org/jira/browse/FLINK-36065
Project: Flink
Issue Type: Sub-task
C
Junrui Li created FLINK-36066:
-
Summary: Introducing the AdaptiveGraphGenerator component
Key: FLINK-36066
URL: https://issues.apache.org/jira/browse/FLINK-36066
Project: Flink
Issue Type: Sub-ta
Junrui Li created FLINK-36067:
-
Summary: Introducing the StreamGraphOptimizer component
Key: FLINK-36067
URL: https://issues.apache.org/jira/browse/FLINK-36067
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-36068:
-
Summary: Support for adaptive job scheduling based on StreamGraph
Key: FLINK-36068
URL: https://issues.apache.org/jira/browse/FLINK-36068
Project: Flink
Issue Type
Junrui Li created FLINK-36069:
-
Summary: Extending job detail rest API to adapt to Incremental
JobGraph Generation
Key: FLINK-36069
URL: https://issues.apache.org/jira/browse/FLINK-36069
Project: Flink
Junrui Li created FLINK-36070:
-
Summary: Modifying web UI to adapt to Incremental JobGraph
Generation
Key: FLINK-36070
URL: https://issues.apache.org/jira/browse/FLINK-36070
Project: Flink
Issue
Junrui Li created FLINK-36072:
-
Summary: Optimizing the Overhead of the Network Layer in Adaptive
Execution Scenarios
Key: FLINK-36072
URL: https://issues.apache.org/jira/browse/FLINK-36072
Project: Flink
Junrui Li created FLINK-36158:
-
Summary: Support for StreamGraph store
Key: FLINK-36158
URL: https://issues.apache.org/jira/browse/FLINK-36158
Project: Flink
Issue Type: Sub-task
Compon
Junrui Li created FLINK-36172:
-
Summary: Web UI Freezes When There Are Many Finished Tasks in
Batch Jobs
Key: FLINK-36172
URL: https://issues.apache.org/jira/browse/FLINK-36172
Project: Flink
Is
Junrui Li created FLINK-36185:
-
Summary: Remove RuntimeContext#getExecutionConfig
Key: FLINK-36185
URL: https://issues.apache.org/jira/browse/FLINK-36185
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-36249:
-
Summary: Remove RestartStrategy-related configuration
getters/setters
Key: FLINK-36249
URL: https://issues.apache.org/jira/browse/FLINK-36249
Project: Flink
Issue
Junrui Li created FLINK-36250:
-
Summary: Remove CheckpointStorage-related configuration
getters/setters that return/set complex Java objects
Key: FLINK-36250
URL: https://issues.apache.org/jira/browse/FLINK-36250
Junrui Li created FLINK-36251:
-
Summary: Remove StateBackend-related configuration getters/setters
that return/set complex Java objects
Key: FLINK-36251
URL: https://issues.apache.org/jira/browse/FLINK-36251
Junrui Li created FLINK-36445:
-
Summary: Introducing an ExecutionPlan interface
Key: FLINK-36445
URL: https://issues.apache.org/jira/browse/FLINK-36445
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-36446:
-
Summary: Refactor Job Submission Process to Use ExecutionPlan
Instead of JobGraph
Key: FLINK-36446
URL: https://issues.apache.org/jira/browse/FLINK-36446
Project: Flink
Junrui Li created FLINK-36568:
-
Summary: IllegalStateException Causes Collect Sink to Fail to
Collect Result
Key: FLINK-36568
URL: https://issues.apache.org/jira/browse/FLINK-36568
Project: Flink
80 matches
Mail list logo
