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-
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
+1 (binding)
Gyula
Sent from my iPhone
> On 3 Apr 2025, at 00:32, Őrhidi Mátyás wrote:
>
> Hi devs,
>
> I would like to start the vote for FLIP-515: Dynamic Kafka Sink [1]
>
> This FLIP was discussed in this thread [2].
>
> The vote will be open for at least 72 hours unless there is an obje
Hi Venkata,
Let’s keep this discussion about the FLIP and not other unrelated topics.
You are welcome to post the question in a new thread .
Thanks
Gyula
Sent from my iPhone
> On 29 Mar 2025, at 02:58, Venkatakrishnan Sowrirajan wrote:
>
> Hi Pradeepta,
>
> Thanks for the nice proposal. I
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
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
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
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
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
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
+1 for option 2
I suggest we simply move forward with the release candidates
Gyula
Sent from my iPhone
> On 20 Jan 2025, at 19:00, He Pin wrote:
>
> I think @pjfanning means you configured the pekko version with the 1.2.0
> snapshot
> https://repository.apache.org/content/groups/snapshots/o
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
+1 (binding)
The simplified approach makes complete sense!
Gyula
Sent from my iPhone
> On 20 Dec 2024, at 16:33, David Radley wrote:
>
>
>
> +1 (non-binding) from me
> Gyula: Yes I agree, let’s leave this open till then.
>
> I just wanted to check you are ok with running being the cond
Hey!
I suggest to keep this vote open until the 6th of January given that half the
world will be on holidays for sure :)
Gyula
Sent from my iPhone
> On 20 Dec 2024, at 14:52, Lajith Koova wrote:
>
> Hi everyone,
>
>
> I'd like to start a vote on FLIP-493: Add K8S conditions to CRD's Stat
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Pr
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
1 - 100 of 470 matches
Mail list logo
