Gyula Fora created FLINK-13832:
--
Summary: DefaultRollingPolicy create() method should be renamed to
builder()
Key: FLINK-13832
URL: https://issues.apache.org/jira/browse/FLINK-13832
Project: Flink
Gyula Fora created FLINK-13842:
--
Summary: Improve Javadocs and web documentation of the
StreamingFileSink
Key: FLINK-13842
URL: https://issues.apache.org/jira/browse/FLINK-13842
Project: Flink
Gyula Fora created FLINK-13843:
--
Summary: Unify and clean up StreamingFileSink format builders
Key: FLINK-13843
URL: https://issues.apache.org/jira/browse/FLINK-13843
Project: Flink
Issue Type:
Gyula Fora created FLINK-13850:
--
Summary: Refactor part file configuration into a single method
Key: FLINK-13850
URL: https://issues.apache.org/jira/browse/FLINK-13850
Project: Flink
Issue Type:
Gyula Fora created FLINK-13852:
--
Summary: Support storing in-progress/pending files in different
directories (StreamingFileSink)
Key: FLINK-13852
URL: https://issues.apache.org/jira/browse/FLINK-13852
Pr
Gyula Fora created FLINK-13874:
--
Summary: StreamingFileSink fails to recover (truncate) properly
Key: FLINK-13874
URL: https://issues.apache.org/jira/browse/FLINK-13874
Project: Flink
Issue Type
Gyula Fora created FLINK-13979:
--
Summary: Translate new streamfilesink docs to chinese
Key: FLINK-13979
URL: https://issues.apache.org/jira/browse/FLINK-13979
Project: Flink
Issue Type: New Feat
Gyula Fora created FLINK-14002:
--
Summary: FlinkKafkaProducer constructor that takes
KafkaSerializationSchema shouldnt take default topic
Key: FLINK-14002
URL: https://issues.apache.org/jira/browse/FLINK-14002
Gyula Fora created FLINK-14048:
--
Summary: Flink client hangs after trying to kill Yarn Job during
deployment
Key: FLINK-14048
URL: https://issues.apache.org/jira/browse/FLINK-14048
Project: Flink
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-12141:
--
Summary: Allow @TypeInfo annotation on POJO field declarations
Key: FLINK-12141
URL: https://issues.apache.org/jira/browse/FLINK-12141
Project: Flink
Issue Type:
Gyula Fora created FLINK-12142:
--
Summary: Add beforeSnapshot method to StreamOperator interface
Key: FLINK-12142
URL: https://issues.apache.org/jira/browse/FLINK-12142
Project: Flink
Issue Type:
Gyula Fora created FLINK-12144:
--
Summary: Option to prefer checkpoints on recovery
Key: FLINK-12144
URL: https://issues.apache.org/jira/browse/FLINK-12144
Project: Flink
Issue Type: New Feature
Gyula Fora created FLINK-12373:
--
Summary: Improve checkpointing metrics
Key: FLINK-12373
URL: https://issues.apache.org/jira/browse/FLINK-12373
Project: Flink
Issue Type: New Feature
C
Gyula Fora created FLINK-13171:
--
Summary: Add withParameters(Configuration) method to DataStream
operators
Key: FLINK-13171
URL: https://issues.apache.org/jira/browse/FLINK-13171
Project: Flink
Gyula Fora created FLINK-13559:
--
Summary: Expose YARN Dynamic configuration option flag for flink
CLI run
Key: FLINK-13559
URL: https://issues.apache.org/jira/browse/FLINK-13559
Project: Flink
Gyula Fora created FLINK-13560:
--
Summary: Expose YARN ship files option flag for flink CLI run
Key: FLINK-13560
URL: https://issues.apache.org/jira/browse/FLINK-13560
Project: Flink
Issue Type:
Gyula Fora created FLINK-13566:
--
Summary: Support checkpoint configuration through flink-conf.yaml
Key: FLINK-13566
URL: https://issues.apache.org/jira/browse/FLINK-13566
Project: Flink
Issue Ty
Gyula Fora created FLINK-13685:
--
Summary: YARN deployment hangs when requested container is above
the maximum vcore size
Key: FLINK-13685
URL: https://issues.apache.org/jira/browse/FLINK-13685
Project: F
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
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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-26959:
--
Summary: Improve quickstart to use the release helm repo
Key: FLINK-26959
URL: https://issues.apache.org/jira/browse/FLINK-26959
Project: Flink
Issue Type: Sub-t
Gyula Fora created FLINK-27003:
--
Summary: Operator Helm chart improvements
Key: FLINK-27003
URL: https://issues.apache.org/jira/browse/FLINK-27003
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27005:
--
Summary: Bump CRD version to v1alpha2
Key: FLINK-27005
URL: https://issues.apache.org/jira/browse/FLINK-27005
Project: Flink
Issue Type: Improvement
Co
Gyula Fora created FLINK-27021:
--
Summary: CRD improvements for v1alpha2
Key: FLINK-27021
URL: https://issues.apache.org/jira/browse/FLINK-27021
Project: Flink
Issue Type: Improvement
C
Gyula Fora created FLINK-27022:
--
Summary: Expose taskSlots in TaskManager spec
Key: FLINK-27022
URL: https://issues.apache.org/jira/browse/FLINK-27022
Project: Flink
Issue Type: Sub-task
Gyula Fora created FLINK-27023:
--
Summary: Merge default flink and operator configuration settings
for the operator
Key: FLINK-27023
URL: https://issues.apache.org/jira/browse/FLINK-27023
Project: Flink
Gyula Fora created FLINK-27029:
--
Summary: DeploymentValidator should take default flink config into
account during validation
Key: FLINK-27029
URL: https://issues.apache.org/jira/browse/FLINK-27029
Proje
Gyula Fora created FLINK-27036:
--
Summary: Do not build and push images on final release tags
Key: FLINK-27036
URL: https://issues.apache.org/jira/browse/FLINK-27036
Project: Flink
Issue Type: Im
Gyula Fora created FLINK-27040:
--
Summary: Better structure for the helm chart configs
Key: FLINK-27040
URL: https://issues.apache.org/jira/browse/FLINK-27040
Project: Flink
Issue Type: Sub-task
Gyula Fora created FLINK-27049:
--
Summary: Add "What is Flink Kubernetes Operator?" link to flink
website
Key: FLINK-27049
URL: https://issues.apache.org/jira/browse/FLINK-27049
Project: Flink
I
Gyula Fora created FLINK-27065:
--
Summary: Store lastReconciledSpec as String in status
Key: FLINK-27065
URL: https://issues.apache.org/jira/browse/FLINK-27065
Project: Flink
Issue Type: Improvem
Gyula Fora created FLINK-27137:
--
Summary: Remove usage of AdminClient from KafkaSource logic
Key: FLINK-27137
URL: https://issues.apache.org/jira/browse/FLINK-27137
Project: Flink
Issue Type: Im
Gyula Fora created FLINK-27141:
--
Summary: Improve FlinkService#waitForClusterShutdown logic
Key: FLINK-27141
URL: https://issues.apache.org/jira/browse/FLINK-27141
Project: Flink
Issue Type: Imp
Gyula Fora created FLINK-27153:
--
Summary: Allow optional last-state fallback for savepoint upgrade
mode
Key: FLINK-27153
URL: https://issues.apache.org/jira/browse/FLINK-27153
Project: Flink
Is
Gyula Fora created FLINK-27154:
--
Summary: Disable web.cancel.enable for application clusters
Key: FLINK-27154
URL: https://issues.apache.org/jira/browse/FLINK-27154
Project: Flink
Issue Type: Im
Gyula Fora created FLINK-27279:
--
Summary: Extract common status interfaces
Key: FLINK-27279
URL: https://issues.apache.org/jira/browse/FLINK-27279
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27280:
--
Summary: Support rollback for session jobs.
Key: FLINK-27280
URL: https://issues.apache.org/jira/browse/FLINK-27280
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27281:
--
Summary: Improve stability conditions for rollback logic
Key: FLINK-27281
URL: https://issues.apache.org/jira/browse/FLINK-27281
Project: Flink
Issue Type: Impro
Gyula Fora created FLINK-27302:
--
Summary: Document regular CRD upgrade process
Key: FLINK-27302
URL: https://issues.apache.org/jira/browse/FLINK-27302
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27303:
--
Summary: Flink Operator will create a large amount of temp log
config files
Key: FLINK-27303
URL: https://issues.apache.org/jira/browse/FLINK-27303
Project: Flink
Gyula Fora created FLINK-27360:
--
Summary: Rename clusterId field of FlinkSessionJobSpec to
deploymentName
Key: FLINK-27360
URL: https://issues.apache.org/jira/browse/FLINK-27360
Project: Flink
Gyula Fora created FLINK-27458:
--
Summary: Expose allowNonRestoredState flag in JobSpec
Key: FLINK-27458
URL: https://issues.apache.org/jira/browse/FLINK-27458
Project: Flink
Issue Type: Improvem
Gyula Fora created FLINK-27495:
--
Summary: Observer should update last savepoint information
directly from cluster too
Key: FLINK-27495
URL: https://issues.apache.org/jira/browse/FLINK-27495
Project: Flin
Gyula Fora created FLINK-27496:
--
Summary: Add test for rollback during application upgrade
Key: FLINK-27496
URL: https://issues.apache.org/jira/browse/FLINK-27496
Project: Flink
Issue Type: Impr
Gyula Fora created FLINK-27497:
--
Summary: Track terminal job states in the observer
Key: FLINK-27497
URL: https://issues.apache.org/jira/browse/FLINK-27497
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27498:
--
Summary: Add E2E tests to cover Flink 1.15
Key: FLINK-27498
URL: https://issues.apache.org/jira/browse/FLINK-27498
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27499:
--
Summary: Bump base Flink version to 1.15.0
Key: FLINK-27499
URL: https://issues.apache.org/jira/browse/FLINK-27499
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27500:
--
Summary: Validation error handling inside controller blocks
reconciliation
Key: FLINK-27500
URL: https://issues.apache.org/jira/browse/FLINK-27500
Project: Flink
Gyula Fora created FLINK-27551:
--
Summary: Consider implementing our own status update logic
Key: FLINK-27551
URL: https://issues.apache.org/jira/browse/FLINK-27551
Project: Flink
Issue Type: Imp
Gyula Fora created FLINK-27569:
--
Summary: Terminated Flink job restarted from empty state when
execution.shutdown-on-application-finish is false
Key: FLINK-27569
URL: https://issues.apache.org/jira/browse/FLINK-27569
Gyula Fora created FLINK-27572:
--
Summary: Verify HA Metadata present before performint last-state
restore
Key: FLINK-27572
URL: https://issues.apache.org/jira/browse/FLINK-27572
Project: Flink
1 - 100 of 444 matches
Mail list logo
