Maximilian Michels created FLINK-37971:
--
Summary: SQL hints are dropped by planner when
Key: FLINK-37971
URL: https://issues.apache.org/jira/browse/FLINK-37971
Project: Flink
Issue Type
Maximilian Michels created FLINK-37546:
--
Summary: KryoSerializer breaks without Twitter Chill library
Key: FLINK-37546
URL: https://issues.apache.org/jira/browse/FLINK-37546
Project: Flink
Maximilian Michels created FLINK-37526:
--
Summary: Promote SinkV2 API classes from @Experimental to
@PublicEvolving
Key: FLINK-37526
URL: https://issues.apache.org/jira/browse/FLINK-37526
Project:
Maximilian Michels created FLINK-37253:
--
Summary: Display state size in application status and deployment
metrics
Key: FLINK-37253
URL: https://issues.apache.org/jira/browse/FLINK-37253
Project:
Maximilian Michels created FLINK-37245:
--
Summary: RowData#createFieldGetter can resurrect null values for
non-null fields
Key: FLINK-37245
URL: https://issues.apache.org/jira/browse/FLINK-37245
P
Maximilian Michels created FLINK-36890:
--
Summary: ObservedGeneration is not updated on NOOP spec updates
Key: FLINK-36890
URL: https://issues.apache.org/jira/browse/FLINK-36890
Project: Flink
Maximilian Michels created FLINK-36870:
--
Summary: Start scale down timer after initial scale up
Key: FLINK-36870
URL: https://issues.apache.org/jira/browse/FLINK-36870
Project: Flink
Iss
Maximilian Michels created FLINK-36717:
--
Summary: Add health check to detect tasks stuck in DEPLOYING state
Key: FLINK-36717
URL: https://issues.apache.org/jira/browse/FLINK-36717
Project: Flink
Maximilian Michels created FLINK-34540:
--
Summary: Tune number of task slots
Key: FLINK-34540
URL: https://issues.apache.org/jira/browse/FLINK-34540
Project: Flink
Issue Type: Sub-task
Maximilian Michels created FLINK-34539:
--
Summary: Tune JobManager memory of autoscaled jobs
Key: FLINK-34539
URL: https://issues.apache.org/jira/browse/FLINK-34539
Project: Flink
Issue T
Maximilian Michels created FLINK-34538:
--
Summary: Tune memory of autoscaled jobs
Key: FLINK-34538
URL: https://issues.apache.org/jira/browse/FLINK-34538
Project: Flink
Issue Type: New Fe
Maximilian Michels created FLINK-34213:
--
Summary: Consider using accumulated busy time instead of
busyMsPerSecond
Key: FLINK-34213
URL: https://issues.apache.org/jira/browse/FLINK-34213
Project:
Maximilian Michels created FLINK-34152:
--
Summary: Tune memory of autoscaled jobs
Key: FLINK-34152
URL: https://issues.apache.org/jira/browse/FLINK-34152
Project: Flink
Issue Type: New Fe
Maximilian Michels created FLINK-34151:
--
Summary: Integrate Karpenter resource limits into cluster capacity
check
Key: FLINK-34151
URL: https://issues.apache.org/jira/browse/FLINK-34151
Project:
Maximilian Michels created FLINK-33993:
--
Summary: Ineffective scaling detection events are misleading
Key: FLINK-33993
URL: https://issues.apache.org/jira/browse/FLINK-33993
Project: Flink
Maximilian Michels created FLINK-33773:
--
Summary: Add fairness to scaling decisions
Key: FLINK-33773
URL: https://issues.apache.org/jira/browse/FLINK-33773
Project: Flink
Issue Type: New
Maximilian Michels created FLINK-33771:
--
Summary: Add cluster capacity awareness to Autoscaler
Key: FLINK-33771
URL: https://issues.apache.org/jira/browse/FLINK-33771
Project: Flink
Issu
Maximilian Michels created FLINK-33770:
--
Summary: Autoscaler logs are full of deprecated key warnings
Key: FLINK-33770
URL: https://issues.apache.org/jira/browse/FLINK-33770
Project: Flink
Maximilian Michels created FLINK-33710:
--
Summary: Autoscaler redeploys pipeline for a NOOP parallelism
change
Key: FLINK-33710
URL: https://issues.apache.org/jira/browse/FLINK-33710
Project: Flin
Maximilian Michels created FLINK-33572:
--
Summary: Minimize ConfigMap API operations for autoscaler state
Key: FLINK-33572
URL: https://issues.apache.org/jira/browse/FLINK-33572
Project: Flink
Maximilian Michels created FLINK-33522:
--
Summary: Savepoint upgrade mode fails despite the savepoint
succeeding
Key: FLINK-33522
URL: https://issues.apache.org/jira/browse/FLINK-33522
Project: Fl
Maximilian Michels created FLINK-33429:
--
Summary: Metric collection during stabilization phase may error
due to missing metrics
Key: FLINK-33429
URL: https://issues.apache.org/jira/browse/FLINK-33429
Maximilian Michels created FLINK-32991:
--
Summary: Some metrics from autoscaler never get registered
Key: FLINK-32991
URL: https://issues.apache.org/jira/browse/FLINK-32991
Project: Flink
Maximilian Michels created FLINK-32992:
--
Summary: Recommended parallelism metric is a duplicate of
Parallelism metric
Key: FLINK-32992
URL: https://issues.apache.org/jira/browse/FLINK-32992
Proje
Maximilian Michels created FLINK-32960:
--
Summary: Logic to log vertex exclusion only once does not work
correctly
Key: FLINK-32960
URL: https://issues.apache.org/jira/browse/FLINK-32960
Project:
Maximilian Michels created FLINK-32959:
--
Summary: Operator standalone mode throws NoClassDefFoundError
Key: FLINK-32959
URL: https://issues.apache.org/jira/browse/FLINK-32959
Project: Flink
Maximilian Michels created FLINK-32903:
--
Summary: Add a load simulation example pipeline for canary testing
Key: FLINK-32903
URL: https://issues.apache.org/jira/browse/FLINK-32903
Project: Flink
Maximilian Michels created FLINK-32813:
--
Summary: Split autoscaler ConfigMap
Key: FLINK-32813
URL: https://issues.apache.org/jira/browse/FLINK-32813
Project: Flink
Issue Type: Improvemen
Maximilian Michels created FLINK-32774:
--
Summary: Reconciliation for autoscaling overrides gets stuck after
cancel-with-savepoint
Key: FLINK-32774
URL: https://issues.apache.org/jira/browse/FLINK-32774
Maximilian Michels created FLINK-32589:
--
Summary: Carry over parallelism overrides to prevent users from
clearing them on updates
Key: FLINK-32589
URL: https://issues.apache.org/jira/browse/FLINK-32589
Maximilian Michels created FLINK-32170:
--
Summary: Continue metric collection on intermittant job restarts
Key: FLINK-32170
URL: https://issues.apache.org/jira/browse/FLINK-32170
Project: Flink
Maximilian Michels created FLINK-32120:
--
Summary: Add autoscaler config option to disable parallelism key
group alignment
Key: FLINK-32120
URL: https://issues.apache.org/jira/browse/FLINK-32120
P
Maximilian Michels created FLINK-32119:
--
Summary: Disable key group alignment for determining source
parallelism
Key: FLINK-32119
URL: https://issues.apache.org/jira/browse/FLINK-32119
Project: F
Maximilian Michels created FLINK-32102:
--
Summary: Aggregate multiple pendingRecords metric per source if
present
Key: FLINK-32102
URL: https://issues.apache.org/jira/browse/FLINK-32102
Project: F
Maximilian Michels created FLINK-32100:
--
Summary: Max parallelism is incorrectly calculated with multiple
topics
Key: FLINK-32100
URL: https://issues.apache.org/jira/browse/FLINK-32100
Project: F
Maximilian Michels created FLINK-32061:
--
Summary: Resource metric groups are not cleaned up on removal
Key: FLINK-32061
URL: https://issues.apache.org/jira/browse/FLINK-32061
Project: Flink
Maximilian Michels created FLINK-32005:
--
Summary: Add a per-deployment error metric to signal about
potential issues
Key: FLINK-32005
URL: https://issues.apache.org/jira/browse/FLINK-32005
Projec
Maximilian Michels created FLINK-32002:
--
Summary: Revisit autoscaler defaults for next release
Key: FLINK-32002
URL: https://issues.apache.org/jira/browse/FLINK-32002
Project: Flink
Issu
Maximilian Michels created FLINK-31921:
--
Summary: Create a mini cluster based metric collection test
Key: FLINK-31921
URL: https://issues.apache.org/jira/browse/FLINK-31921
Project: Flink
Maximilian Michels created FLINK-31920:
--
Summary: Flaky tests
Key: FLINK-31920
URL: https://issues.apache.org/jira/browse/FLINK-31920
Project: Flink
Issue Type: Bug
Components
Maximilian Michels created FLINK-31867:
--
Summary: Enforce a minimum number of observations within a metric
window
Key: FLINK-31867
URL: https://issues.apache.org/jira/browse/FLINK-31867
Project:
Maximilian Michels created FLINK-31866:
--
Summary: Autoscaler metric trimming reduces the numbet of metric
observations
Key: FLINK-31866
URL: https://issues.apache.org/jira/browse/FLINK-31866
Proj
Maximilian Michels created FLINK-31684:
--
Summary: Autoscaler metrics are only visible after metric window
is full
Key: FLINK-31684
URL: https://issues.apache.org/jira/browse/FLINK-31684
Project:
Maximilian Michels created FLINK-31502:
--
Summary: Limit the number of concurrent scale operations to reduce
cluster churn
Key: FLINK-31502
URL: https://issues.apache.org/jira/browse/FLINK-31502
P
Maximilian Michels created FLINK-31400:
--
Summary: Add autoscaler integration for Iceberg source
Key: FLINK-31400
URL: https://issues.apache.org/jira/browse/FLINK-31400
Project: Flink
Iss
Maximilian Michels created FLINK-31345:
--
Summary: Trim autoscaler configMap to not exceed 1mb size limit
Key: FLINK-31345
URL: https://issues.apache.org/jira/browse/FLINK-31345
Project: Flink
Maximilian Michels created FLINK-31299:
--
Summary: PendingRecords metric might not be available
Key: FLINK-31299
URL: https://issues.apache.org/jira/browse/FLINK-31299
Project: Flink
Issu
Maximilian Michels created FLINK-30931:
--
Summary: Adaptive scheduler wastes slots for multiple slot sharing
groups with different max parallelism
Key: FLINK-30931
URL: https://issues.apache.org/jira/browse/FL
Maximilian Michels created FLINK-30776:
--
Summary: Move autoscaler code into a seperate module
Key: FLINK-30776
URL: https://issues.apache.org/jira/browse/FLINK-30776
Project: Flink
Issue
Maximilian Michels created FLINK-30775:
--
Summary: Support pluggable reconciler modules
Key: FLINK-30775
URL: https://issues.apache.org/jira/browse/FLINK-30775
Project: Flink
Issue Type:
Maximilian Michels created FLINK-30773:
--
Summary: Allow rescaling of jobs based on per-vertex parallelism
overrides
Key: FLINK-30773
URL: https://issues.apache.org/jira/browse/FLINK-30773
Project
Maximilian Michels created FLINK-30510:
--
Summary: Allow configuring minimum and maximum metrics window size
Key: FLINK-30510
URL: https://issues.apache.org/jira/browse/FLINK-30510
Project: Flink
Maximilian Michels created FLINK-30464:
--
Summary: Exclude metrics during stabilization period from the
scaling decision
Key: FLINK-30464
URL: https://issues.apache.org/jira/browse/FLINK-30464
Pro
Maximilian Michels created FLINK-30463:
--
Summary: Stabilization period starts before job goes into RUNNING
Key: FLINK-30463
URL: https://issues.apache.org/jira/browse/FLINK-30463
Project: Flink
Maximilian Michels created FLINK-30280:
--
Summary: Default operator logging configuration is broken
Key: FLINK-30280
URL: https://issues.apache.org/jira/browse/FLINK-30280
Project: Flink
Maximilian Michels created FLINK-30266:
--
Summary: Recovery reconciliation loop fails if no checkpoint has
been created yet
Key: FLINK-30266
URL: https://issues.apache.org/jira/browse/FLINK-30266
Maximilian Michels created FLINK-30260:
--
Summary: FLIP-271: Autoscaling
Key: FLINK-30260
URL: https://issues.apache.org/jira/browse/FLINK-30260
Project: Flink
Issue Type: New Feature
Maximilian Michels created FLINK-29571:
--
Summary: Flink configuration only supports Map
Key: FLINK-29571
URL: https://issues.apache.org/jira/browse/FLINK-29571
Project: Flink
Issue Type:
Maximilian Michels created FLINK-29501:
--
Summary: Allow overriding JobVertex parallelisms during job
submission
Key: FLINK-29501
URL: https://issues.apache.org/jira/browse/FLINK-29501
Project: Fl
Maximilian Michels created FLINK-29258:
--
Summary: Add SAVEPOINT_ONLY upgrade mode
Key: FLINK-29258
URL: https://issues.apache.org/jira/browse/FLINK-29258
Project: Flink
Issue Type: New F
Maximilian Michels created FLINK-29257:
--
Summary: Kubernetes operator docs are vague about upgrade mode
Key: FLINK-29257
URL: https://issues.apache.org/jira/browse/FLINK-29257
Project: Flink
Maximilian Michels created FLINK-20090:
--
Summary: Expose SlotId / SlotSharingGroup in Rest API
Key: FLINK-20090
URL: https://issues.apache.org/jira/browse/FLINK-20090
Project: Flink
Iss
Maximilian Michels created FLINK-18754:
--
Summary: Display Python streaming metrics in Grafana dashboard
Key: FLINK-18754
URL: https://issues.apache.org/jira/browse/FLINK-18754
Project: Flink
Maximilian Michels created FLINK-16773:
--
Summary: Flink 1.10 test execution is broken due to premature test
cluster shutdown
Key: FLINK-16773
URL: https://issues.apache.org/jira/browse/FLINK-16773
Maximilian Michels created FLINK-16705:
--
Summary: LocalExecutor tears down MiniCluster before client can
retrieve JobResult
Key: FLINK-16705
URL: https://issues.apache.org/jira/browse/FLINK-16705
Maximilian Michels created FLINK-16573:
--
Summary: Kinesis consumer does not properly shutdown RecordFetcher
threads
Key: FLINK-16573
URL: https://issues.apache.org/jira/browse/FLINK-16573
Project
Maximilian Michels created FLINK-16511:
--
Summary: Task cancellation timeout is not effective on OOM errors
Key: FLINK-16511
URL: https://issues.apache.org/jira/browse/FLINK-16511
Project: Flink
Maximilian Michels created FLINK-16510:
--
Summary: Task manager safeguard shutdown may not be reliable
Key: FLINK-16510
URL: https://issues.apache.org/jira/browse/FLINK-16510
Project: Flink
Maximilian Michels created FLINK-15504:
--
Summary: Flink suppresses stdout/stderr during JobGraph generation
from JAR
Key: FLINK-15504
URL: https://issues.apache.org/jira/browse/FLINK-15504
Projec
Maximilian Michels created FLINK-15253:
--
Summary: Accumulators are not checkpointed
Key: FLINK-15253
URL: https://issues.apache.org/jira/browse/FLINK-15253
Project: Flink
Issue Type: Bug
Maximilian Michels created FLINK-15252:
--
Summary: Heartbeat with large accumulator payload may cause
instable clusters
Key: FLINK-15252
URL: https://issues.apache.org/jira/browse/FLINK-15252
Proj
Maximilian Michels created FLINK-14653:
--
Summary: Job-related errors in snapshotState do not result in job
failure
Key: FLINK-14653
URL: https://issues.apache.org/jira/browse/FLINK-14653
Project:
Maximilian Michels created FLINK-12653:
--
Summary: Keyed state backend fails to restore during rescaling
Key: FLINK-12653
URL: https://issues.apache.org/jira/browse/FLINK-12653
Project: Flink
Maximilian Michels created FLINK-12101:
--
Summary: Race condition when concurrenty running uploaded jars via
REST
Key: FLINK-12101
URL: https://issues.apache.org/jira/browse/FLINK-12101
Project: F
Maximilian Michels created FLINK-11373:
--
Summary: CliFrontend cuts off reason for error messages
Key: FLINK-11373
URL: https://issues.apache.org/jira/browse/FLINK-11373
Project: Flink
Is
Maximilian Michels created FLINK-5350:
-
Summary: Don't overwrite existing Jaas config property
Key: FLINK-5350
URL: https://issues.apache.org/jira/browse/FLINK-5350
Project: Flink
Issue T
Maximilian Michels created FLINK-5262:
-
Summary: Docs: Introduce a Gemfile.lock to avoid dependency range
conflicts
Key: FLINK-5262
URL: https://issues.apache.org/jira/browse/FLINK-5262
Project: F
Maximilian Michels created FLINK-5236:
-
Summary: User jar classpath should come first in classpath
Key: FLINK-5236
URL: https://issues.apache.org/jira/browse/FLINK-5236
Project: Flink
Iss
Maximilian Michels created FLINK-5235:
-
Summary: HBase classpath automatically added to Flink classpath
Key: FLINK-5235
URL: https://issues.apache.org/jira/browse/FLINK-5235
Project: Flink
Maximilian Michels created FLINK-5234:
-
Summary: Inform user about classpath configuration
Key: FLINK-5234
URL: https://issues.apache.org/jira/browse/FLINK-5234
Project: Flink
Issue Type:
Maximilian Michels created FLINK-5149:
-
Summary: ContinuousEventTimeTrigger doesn't fire at the end of the
window
Key: FLINK-5149
URL: https://issues.apache.org/jira/browse/FLINK-5149
Project: Fli
Maximilian Michels created FLINK-5108:
-
Summary: Remove ClientShutdownHook during job execution
Key: FLINK-5108
URL: https://issues.apache.org/jira/browse/FLINK-5108
Project: Flink
Issue
Maximilian Michels created FLINK-4998:
-
Summary: ResourceManager fails when num task slots > Yarn vcores
Key: FLINK-4998
URL: https://issues.apache.org/jira/browse/FLINK-4998
Project: Flink
Maximilian Michels created FLINK-4913:
-
Summary: Per-job Yarn clusters: include user jar in system class
loader
Key: FLINK-4913
URL: https://issues.apache.org/jira/browse/FLINK-4913
Project: Flin
Maximilian Michels created FLINK-4881:
-
Summary: Docker: Remove dependency on shared volumes
Key: FLINK-4881
URL: https://issues.apache.org/jira/browse/FLINK-4881
Project: Flink
Issue Typ
Maximilian Michels created FLINK-4852:
-
Summary: ClassCastException when assigning Watermarks with
TimeCharacteristic.ProcessingTime
Key: FLINK-4852
URL: https://issues.apache.org/jira/browse/FLINK-4852
Maximilian Michels created FLINK-4799:
-
Summary: Re-add build-target symlink to project root
Key: FLINK-4799
URL: https://issues.apache.org/jira/browse/FLINK-4799
Project: Flink
Issue Typ
Maximilian Michels created FLINK-4777:
-
Summary: ContinuousFileMonitoringFunction may throw IOException
when files are moved
Key: FLINK-4777
URL: https://issues.apache.org/jira/browse/FLINK-4777
P
Maximilian Michels created FLINK-4763:
-
Summary: Documentation doesn't update nightly
Key: FLINK-4763
URL: https://issues.apache.org/jira/browse/FLINK-4763
Project: Flink
Issue Type: Bug
Maximilian Michels created FLINK-4732:
-
Summary: Maven junction plugin security threat
Key: FLINK-4732
URL: https://issues.apache.org/jira/browse/FLINK-4732
Project: Flink
Issue Type: Bug
Maximilian Michels created FLINK-4703:
-
Summary: RpcCompletenessTest: Add support for type arguments and
subclasss
Key: FLINK-4703
URL: https://issues.apache.org/jira/browse/FLINK-4703
Project: Fl
Maximilian Michels created FLINK-4677:
-
Summary: Jars with no job executions produces NullPointerException
in ClusterClient
Key: FLINK-4677
URL: https://issues.apache.org/jira/browse/FLINK-4677
Pr
Maximilian Michels created FLINK-4644:
-
Summary: Deprecate "flink.base.dir.path" from ConfigConstants
Key: FLINK-4644
URL: https://issues.apache.org/jira/browse/FLINK-4644
Project: Flink
Maximilian Michels created FLINK-4628:
-
Summary: User class loader unavailable during input split
assignment
Key: FLINK-4628
URL: https://issues.apache.org/jira/browse/FLINK-4628
Project: Flink
Maximilian Michels created FLINK-4570:
-
Summary: Scalastyle Maven plugin fails undeterministically
Key: FLINK-4570
URL: https://issues.apache.org/jira/browse/FLINK-4570
Project: Flink
Iss
Maximilian Michels created FLINK-4540:
-
Summary: Detached job execution may prevent cluster shutdown
Key: FLINK-4540
URL: https://issues.apache.org/jira/browse/FLINK-4540
Project: Flink
I
Maximilian Michels created FLINK-4538:
-
Summary: Implement slot allocation protocol with JobMaster
Key: FLINK-4538
URL: https://issues.apache.org/jira/browse/FLINK-4538
Project: Flink
Iss
Maximilian Michels created FLINK-4537:
-
Summary: ResourceManager registration with JobManager
Key: FLINK-4537
URL: https://issues.apache.org/jira/browse/FLINK-4537
Project: Flink
Issue Ty
Maximilian Michels created FLINK-4526:
-
Summary: ApplicationClient: remove redundant proxy messages
Key: FLINK-4526
URL: https://issues.apache.org/jira/browse/FLINK-4526
Project: Flink
Is
Maximilian Michels created FLINK-4488:
-
Summary: Prevent cluster shutdown after job execution for
non-detached jobs
Key: FLINK-4488
URL: https://issues.apache.org/jira/browse/FLINK-4488
Project: F
1 - 100 of 219 matches
Mail list logo