Gyula Fora created FLINK-38147:
--
Summary: Add Flink 2.1 support to operator
Key: FLINK-38147
URL: https://issues.apache.org/jira/browse/FLINK-38147
Project: Flink
Issue Type: Bug
Compo
Gyula Fora created FLINK-38077:
--
Summary: Cancel job upgrades may get stuck indefinitely if JM is
missing
Key: FLINK-38077
URL: https://issues.apache.org/jira/browse/FLINK-38077
Project: Flink
Gyula Fora created FLINK-37769:
--
Summary: Include cause in event when Restarting unhealthy job
Key: FLINK-37769
URL: https://issues.apache.org/jira/browse/FLINK-37769
Project: Flink
Issue Type:
Gyula Fora created FLINK-37621:
--
Summary: EnableAsyncState doesn't seem to do anything on
DataStream API and misleading error message
Key: FLINK-37621
URL: https://issues.apache.org/jira/browse/FLINK-37621
Gyula Fora created FLINK-37617:
--
Summary: StateIterator should not have 2 onNext methods with
almost the same signature
Key: FLINK-37617
URL: https://issues.apache.org/jira/browse/FLINK-37617
Project: Fl
Gyula Fora created FLINK-37571:
--
Summary: Last state upgrade mode broken for Flink 2.0
Key: FLINK-37571
URL: https://issues.apache.org/jira/browse/FLINK-37571
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-37564:
--
Summary: Rework job error fetching to use Exception history
instead of JobResults
Key: FLINK-37564
URL: https://issues.apache.org/jira/browse/FLINK-37564
Project: Flink
Gyula Fora created FLINK-37562:
--
Summary: Do not check all JM replicas in observer
Key: FLINK-37562
URL: https://issues.apache.org/jira/browse/FLINK-37562
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-37530:
--
Summary: Upgrade savepoints are not added to deprecated
savepointinfo
Key: FLINK-37530
URL: https://issues.apache.org/jira/browse/FLINK-37530
Project: Flink
Iss
Gyula Fora created FLINK-37470:
--
Summary: InitContainer errors are not registered correctly
Key: FLINK-37470
URL: https://issues.apache.org/jira/browse/FLINK-37470
Project: Flink
Issue Type: Imp
Gyula Fora created FLINK-37455:
--
Summary: Create error Event when job goes into FAILED state
Key: FLINK-37455
URL: https://issues.apache.org/jira/browse/FLINK-37455
Project: Flink
Issue Type: Im
Gyula Fora created FLINK-37430:
--
Summary: Operator hides the actual error on deployment issues
Key: FLINK-37430
URL: https://issues.apache.org/jira/browse/FLINK-37430
Project: Flink
Issue Type:
Gyula Fora created FLINK-37406:
--
Summary: Add support for structured YAML config in FlinkDeployment
CRD
Key: FLINK-37406
URL: https://issues.apache.org/jira/browse/FLINK-37406
Project: Flink
Is
Gyula Fora created FLINK-37405:
--
Summary: Perform upstream YAML config validation for Flink 2.x
Key: FLINK-37405
URL: https://issues.apache.org/jira/browse/FLINK-37405
Project: Flink
Issue Type:
Gyula Fora created FLINK-37372:
--
Summary: Savepoint error can cause operator to hang
Key: FLINK-37372
URL: https://issues.apache.org/jira/browse/FLINK-37372
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-37359:
--
Summary: Docker build fails for Kubernetes operator
Key: FLINK-37359
URL: https://issues.apache.org/jira/browse/FLINK-37359
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-37236:
--
Summary: Make Flink operator compatible with 2.0 preview
Key: FLINK-37236
URL: https://issues.apache.org/jira/browse/FLINK-37236
Project: Flink
Issue Type: New F
Gyula Fora created FLINK-37229:
--
Summary: Add DELETING/DELETED lifecycle states
Key: FLINK-37229
URL: https://issues.apache.org/jira/browse/FLINK-37229
Project: Flink
Issue Type: Bug
C
Gyula Fora created FLINK-37166:
--
Summary: FlinkConfigManager version prefix logic not safe
Key: FLINK-37166
URL: https://issues.apache.org/jira/browse/FLINK-37166
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-36529:
--
Summary: Support greater or equals logic for operator flink
version default configs
Key: FLINK-36529
URL: https://issues.apache.org/jira/browse/FLINK-36529
Project: Flink
Gyula Fora created FLINK-36425:
--
Summary: Use JobStatus enum for status.job.state
Key: FLINK-36425
URL: https://issues.apache.org/jira/browse/FLINK-36425
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-36418:
--
Summary: Update Control Flow page with latest developments
Key: FLINK-36418
URL: https://issues.apache.org/jira/browse/FLINK-36418
Project: Flink
Issue Type: Imp
Gyula Fora created FLINK-36409:
--
Summary: Publish some autoscaler metrics during stabilisation
period
Key: FLINK-36409
URL: https://issues.apache.org/jira/browse/FLINK-36409
Project: Flink
Issu
Gyula Fora created FLINK-36162:
--
Summary: Remove flinkStateSnapshotReference and namespace from
FlinkStateSnapshot jobReference
Key: FLINK-36162
URL: https://issues.apache.org/jira/browse/FLINK-36162
Pro
Gyula Fora created FLINK-36145:
--
Summary: Change JobSpec.flinkStateSnapshotReference to
snapshotReference
Key: FLINK-36145
URL: https://issues.apache.org/jira/browse/FLINK-36145
Project: Flink
Gyula Fora created FLINK-36137:
--
Summary: Missing JarURI leads to null pointer in reconciler
Key: FLINK-36137
URL: https://issues.apache.org/jira/browse/FLINK-36137
Project: Flink
Issue Type: Bu
Gyula Fora created FLINK-36110:
--
Summary: Periodic save points trigger continuously
Key: FLINK-36110
URL: https://issues.apache.org/jira/browse/FLINK-36110
Project: Flink
Issue Type: Sub-task
Gyula Fora created FLINK-36109:
--
Summary: Improve FlinkStateSnapshot resource labels for efficient
filtering
Key: FLINK-36109
URL: https://issues.apache.org/jira/browse/FLINK-36109
Project: Flink
Gyula Fora created FLINK-35831:
--
Summary: Rotate job id on savepoint upgrade as well
Key: FLINK-35831
URL: https://issues.apache.org/jira/browse/FLINK-35831
Project: Flink
Issue Type: Improvemen
Gyula Fora created FLINK-35777:
--
Summary: Observe session jobs during cleanup
Key: FLINK-35777
URL: https://issues.apache.org/jira/browse/FLINK-35777
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-35776:
--
Summary: Simplify job observe logic
Key: FLINK-35776
URL: https://issues.apache.org/jira/browse/FLINK-35776
Project: Flink
Issue Type: Improvement
Comp
Gyula Fora created FLINK-35746:
--
Summary: Add logic to override observed config based on settings
observed through REST API
Key: FLINK-35746
URL: https://issues.apache.org/jira/browse/FLINK-35746
Project
Gyula Fora created FLINK-35466:
--
Summary: Cannot pass all columns to SQL UDFs using `*`
Key: FLINK-35466
URL: https://issues.apache.org/jira/browse/FLINK-35466
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-35414:
--
Summary: Cancel jobs through rest api for last-state upgrades
Key: FLINK-35414
URL: https://issues.apache.org/jira/browse/FLINK-35414
Project: Flink
Issue Type:
Gyula Fora created FLINK-35292:
--
Summary: Set dummy savepoint path during last-state upgrade
Key: FLINK-35292
URL: https://issues.apache.org/jira/browse/FLINK-35292
Project: Flink
Issue Type: Im
Gyula Fora created FLINK-35157:
--
Summary: Sources with watermark alignment get stuck once some
subtasks finish
Key: FLINK-35157
URL: https://issues.apache.org/jira/browse/FLINK-35157
Project: Flink
Gyula Fora created FLINK-35126:
--
Summary: Improve checkpoint progress health check config and
enable by default
Key: FLINK-35126
URL: https://issues.apache.org/jira/browse/FLINK-35126
Project: Flink
Gyula Fora created FLINK-35108:
--
Summary: Deployment recovery is triggered on terminal jobs after
jm shutdown ttl
Key: FLINK-35108
URL: https://issues.apache.org/jira/browse/FLINK-35108
Project: Flink
Gyula Fora created FLINK-34947:
--
Summary: Do not scale down JM in Orphan deletion propagation and
reduce timeout
Key: FLINK-34947
URL: https://issues.apache.org/jira/browse/FLINK-34947
Project: Flink
Gyula Fora created FLINK-34619:
--
Summary: Do not wait for scaling completion in UPGRADE state with
in-place scaling
Key: FLINK-34619
URL: https://issues.apache.org/jira/browse/FLINK-34619
Project: Flink
Gyula Fora created FLINK-34524:
--
Summary: Scale down JobManager deployment to 0 before deletion
Key: FLINK-34524
URL: https://issues.apache.org/jira/browse/FLINK-34524
Project: Flink
Issue Type:
Gyula Fora created FLINK-34518:
--
Summary: Adaptive Scheduler restores from empty state if JM fails
during restarting state
Key: FLINK-34518
URL: https://issues.apache.org/jira/browse/FLINK-34518
Project:
Gyula Fora created FLINK-34329:
--
Summary: ScalingReport format tests fail locally on decimal format
Key: FLINK-34329
URL: https://issues.apache.org/jira/browse/FLINK-34329
Project: Flink
Issue T
Gyula Fora created FLINK-34318:
--
Summary: AdaptiveScheduler resource stabilisation should happen
before the job is cancelled
Key: FLINK-34318
URL: https://issues.apache.org/jira/browse/FLINK-34318
Projec
Gyula Fora created FLINK-34311:
--
Summary: Do not change min resource requirements when rescaling
for adaptive scheduler
Key: FLINK-34311
URL: https://issues.apache.org/jira/browse/FLINK-34311
Project: Fl
Gyula Fora created FLINK-34266:
--
Summary: Output ratios should be computed over the whole metric
window instead of averaged
Key: FLINK-34266
URL: https://issues.apache.org/jira/browse/FLINK-34266
Project
Gyula Fora created FLINK-33920:
--
Summary: StandaloneKubernetesTaskManagerFactory doesn't support
recent config additions
Key: FLINK-33920
URL: https://issues.apache.org/jira/browse/FLINK-33920
Project: F
Gyula Fora created FLINK-33764:
--
Summary: Incorporate GC / Heap metrics in autoscaler decisions
Key: FLINK-33764
URL: https://issues.apache.org/jira/browse/FLINK-33764
Project: Flink
Issue Type:
Gyula Fora created FLINK-33763:
--
Summary: Support manual savepoint redeploy for jobs and deployments
Key: FLINK-33763
URL: https://issues.apache.org/jira/browse/FLINK-33763
Project: Flink
Issue
Gyula Fora created FLINK-33548:
--
Summary: Replaces taskManager/jobmanager.resource with resources
conforming to ResourceRequirements
Key: FLINK-33548
URL: https://issues.apache.org/jira/browse/FLINK-33548
Gyula Fora created FLINK-33535:
--
Summary: Support autoscaler for session jobs
Key: FLINK-33535
URL: https://issues.apache.org/jira/browse/FLINK-33535
Project: Flink
Issue Type: New Feature
Gyula Fora created FLINK-33534:
--
Summary: PipelineOptions.PARALLELISM_OVERRIDES is not picked up
from jar submission request
Key: FLINK-33534
URL: https://issues.apache.org/jira/browse/FLINK-33534
Projec
Gyula Fora created FLINK-33526:
--
Summary: Improve default autoscaler configs
Key: FLINK-33526
URL: https://issues.apache.org/jira/browse/FLINK-33526
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-33427:
--
Summary: Mark new relocated autoscaler configs IGNORE in the
operator
Key: FLINK-33427
URL: https://issues.apache.org/jira/browse/FLINK-33427
Project: Flink
Iss
Gyula Fora created FLINK-33319:
--
Summary: Add AverageTime metric to measure delta change in GC time
Key: FLINK-33319
URL: https://issues.apache.org/jira/browse/FLINK-33319
Project: Flink
Issue T
Gyula Fora created FLINK-33318:
--
Summary: Create TimeMsPerSec metrics for each collector and add
metrics across all collectors
Key: FLINK-33318
URL: https://issues.apache.org/jira/browse/FLINK-33318
Proj
Gyula Fora created FLINK-33306:
--
Summary: Use observed true processing rate when source metrics are
incorrect
Key: FLINK-33306
URL: https://issues.apache.org/jira/browse/FLINK-33306
Project: Flink
Gyula Fora created FLINK-33120:
--
Summary: FLIP-361: Improve GC Metrics
Key: FLINK-33120
URL: https://issues.apache.org/jira/browse/FLINK-33120
Project: Flink
Issue Type: Improvement
Co
Gyula Fora created FLINK-33107:
--
Summary: Update stable-spec upgrade mode on reconciled-spec change
Key: FLINK-33107
URL: https://issues.apache.org/jira/browse/FLINK-33107
Project: Flink
Issue T
Gyula Fora created FLINK-33089:
--
Summary: Drop Flink 1.14 support
Key: FLINK-33089
URL: https://issues.apache.org/jira/browse/FLINK-33089
Project: Flink
Issue Type: Improvement
Compone
Gyula Fora created FLINK-33081:
--
Summary: Move parallelism override logic into scale method
Key: FLINK-33081
URL: https://issues.apache.org/jira/browse/FLINK-33081
Project: Flink
Issue Type: Imp
Gyula Fora created FLINK-33067:
--
Summary: Expose JODK rate limiter config and enable by default
Key: FLINK-33067
URL: https://issues.apache.org/jira/browse/FLINK-33067
Project: Flink
Issue Type:
Gyula Fora created FLINK-33027:
--
Summary: Users should be able to change parallelism of excluded
vertices
Key: FLINK-33027
URL: https://issues.apache.org/jira/browse/FLINK-33027
Project: Flink
Gyula Fora created FLINK-33008:
--
Summary: Use KubernetesClient from JOSDK context
Key: FLINK-33008
URL: https://issues.apache.org/jira/browse/FLINK-33008
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-33007:
--
Summary: Integrate autoscaler config validation into the general
validator flow
Key: FLINK-33007
URL: https://issues.apache.org/jira/browse/FLINK-33007
Project: Flink
Gyula Fora created FLINK-33006:
--
Summary: Add e2e test for Kubernetes Operator HA
Key: FLINK-33006
URL: https://issues.apache.org/jira/browse/FLINK-33006
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-33005:
--
Summary: Upgrade JOSDK to 4.4.2 and Fabric8 to 6.8.1
Key: FLINK-33005
URL: https://issues.apache.org/jira/browse/FLINK-33005
Project: Flink
Issue Type: Improveme
Gyula Fora created FLINK-32623:
--
Summary: Rest api doesn't return minimum resource requirements
correctly
Key: FLINK-32623
URL: https://issues.apache.org/jira/browse/FLINK-32623
Project: Flink
Gyula Fora created FLINK-32615:
--
Summary: Cache AutoscalerInfo for each resource
Key: FLINK-32615
URL: https://issues.apache.org/jira/browse/FLINK-32615
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-32606:
--
Summary: Support namespace and flink version specific default
configs
Key: FLINK-32606
URL: https://issues.apache.org/jira/browse/FLINK-32606
Project: Flink
Iss
Gyula Fora created FLINK-32572:
--
Summary: Do not collect metrics or scale finished job vertices
Key: FLINK-32572
URL: https://issues.apache.org/jira/browse/FLINK-32572
Project: Flink
Issue Type:
Gyula Fora created FLINK-32529:
--
Summary: Optional startup probe for JM deployment
Key: FLINK-32529
URL: https://issues.apache.org/jira/browse/FLINK-32529
Project: Flink
Issue Type: New Feature
Gyula Fora created FLINK-32282:
--
Summary: Use kubernetes-webhooks-framework instead of deprecated
admission control
Key: FLINK-32282
URL: https://issues.apache.org/jira/browse/FLINK-32282
Project: Flink
Gyula Fora created FLINK-32240:
--
Summary: Update Flink client to 1.17.1
Key: FLINK-32240
URL: https://issues.apache.org/jira/browse/FLINK-32240
Project: Flink
Issue Type: Improvement
C
Gyula Fora created FLINK-32164:
--
Summary: LifecycleState count metrics are not reported correctly
by namespace
Key: FLINK-32164
URL: https://issues.apache.org/jira/browse/FLINK-32164
Project: Flink
Gyula Fora created FLINK-32148:
--
Summary: Reduce info logging noise in the operator
Key: FLINK-32148
URL: https://issues.apache.org/jira/browse/FLINK-32148
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-32147:
--
Summary: Deduplicate scaling report messages
Key: FLINK-32147
URL: https://issues.apache.org/jira/browse/FLINK-32147
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-32134:
--
Summary: Autoscaler min/max parallelism configs should respect the
current job parallelism
Key: FLINK-32134
URL: https://issues.apache.org/jira/browse/FLINK-32134
Project
Gyula Fora created FLINK-32109:
--
Summary: Operator doesn't recognize JobManager stuck on
volumeMount startup errors
Key: FLINK-32109
URL: https://issues.apache.org/jira/browse/FLINK-32109
Project: Flink
Gyula Fora created FLINK-32067:
--
Summary: When no pod template configured, an invalid null pod
template is configured
Key: FLINK-32067
URL: https://issues.apache.org/jira/browse/FLINK-32067
Project: Fli
Gyula Fora created FLINK-32057:
--
Summary: Autoscaler should use the new vertex resource api in 1.18
Key: FLINK-32057
URL: https://issues.apache.org/jira/browse/FLINK-32057
Project: Flink
Issue T
Gyula Fora created FLINK-32033:
--
Summary: Resource lifecycle state shows stable even if application
deployment goes missing
Key: FLINK-32033
URL: https://issues.apache.org/jira/browse/FLINK-32033
Project
Gyula Fora created FLINK-31997:
--
Summary: Update to Fabric8 6.5.1+ in flink-kubernetes
Key: FLINK-31997
URL: https://issues.apache.org/jira/browse/FLINK-31997
Project: Flink
Issue Type: Improvem
Gyula Fora created FLINK-31886:
--
Summary: Upgrade to fabric8 6.5.1 and JOSDK 4.3.0
Key: FLINK-31886
URL: https://issues.apache.org/jira/browse/FLINK-31886
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-31885:
--
Summary: Trigger events on autoscaler errors
Key: FLINK-31885
URL: https://issues.apache.org/jira/browse/FLINK-31885
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-31869:
--
Summary: test_multi_sessionjob.sh gets stuck very frequently
Key: FLINK-31869
URL: https://issues.apache.org/jira/browse/FLINK-31869
Project: Flink
Issue Type: B
Gyula Fora created FLINK-31852:
--
Summary: NumRecordsOut metrics broken
Key: FLINK-31852
URL: https://issues.apache.org/jira/browse/FLINK-31852
Project: Flink
Issue Type: New Feature
Co
Gyula Fora created FLINK-31849:
--
Summary: Enforce some some simple validation directly through the
CRD
Key: FLINK-31849
URL: https://issues.apache.org/jira/browse/FLINK-31849
Project: Flink
Iss
Gyula Fora created FLINK-31630:
--
Summary: Support max-age for checkpoints during last-state upgrades
Key: FLINK-31630
URL: https://issues.apache.org/jira/browse/FLINK-31630
Project: Flink
Issue
Gyula Fora created FLINK-31616:
--
Summary: Add user docs for canary resources
Key: FLINK-31616
URL: https://issues.apache.org/jira/browse/FLINK-31616
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-31614:
--
Summary: Upgrade autoscaling example to 1.17.0 image
Key: FLINK-31614
URL: https://issues.apache.org/jira/browse/FLINK-31614
Project: Flink
Issue Type: Improveme
Gyula Fora created FLINK-31592:
--
Summary: Configurable deletion propagation for Flink resources
Key: FLINK-31592
URL: https://issues.apache.org/jira/browse/FLINK-31592
Project: Flink
Issue Type:
Gyula Fora created FLINK-31407:
--
Summary: Upgrade Fabric8 version to 6.5.0
Key: FLINK-31407
URL: https://issues.apache.org/jira/browse/FLINK-31407
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-31406:
--
Summary: Do not delete jobgraph on scale only last-state upgrades
Key: FLINK-31406
URL: https://issues.apache.org/jira/browse/FLINK-31406
Project: Flink
Issue Ty
Gyula Fora created FLINK-31318:
--
Summary: Do not scale down operators while processing backlog
Key: FLINK-31318
URL: https://issues.apache.org/jira/browse/FLINK-31318
Project: Flink
Issue Type:
Gyula Fora created FLINK-31277:
--
Summary: JM Deployment recovery logic inconsistent with health
related restart
Key: FLINK-31277
URL: https://issues.apache.org/jira/browse/FLINK-31277
Project: Flink
Gyula Fora created FLINK-31220:
--
Summary: Replace Pod with PodTemplateSpec for the pod template
properties
Key: FLINK-31220
URL: https://issues.apache.org/jira/browse/FLINK-31220
Project: Flink
Gyula Fora created FLINK-31219:
--
Summary: Add support for canary resources
Key: FLINK-31219
URL: https://issues.apache.org/jira/browse/FLINK-31219
Project: Flink
Issue Type: New Feature
Gyula Fora created FLINK-31218:
--
Summary: Improve health probe to recognize informers already
failed at start
Key: FLINK-31218
URL: https://issues.apache.org/jira/browse/FLINK-31218
Project: Flink
Gyula Fora created FLINK-31215:
--
Summary: Backpropagate processing rate limits from non-scalable
bottlenecks to upstream operators
Key: FLINK-31215
URL: https://issues.apache.org/jira/browse/FLINK-31215
1 - 100 of 467 matches
Mail list logo
