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
+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
+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
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
+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
Sounds like a great plan, +1
Gyula
>
> On 3 Jun 2025, at 05:57, Leonard Xu wrote:
>
> +1 for the proposed plan and timeline, thanks Poorvank for driving this FLIP.
>
>
> Best,
> Leonard
>
>> 2025 6月 3 11:30，Poorvank Bhatia 写道：
>>
>> Hi all,
>>
>> I would like to start a discussion aroun
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
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
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
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
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
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-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
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-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-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-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-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-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
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
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-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
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:
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-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
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-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-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-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
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-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-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
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-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-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-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-16381:
--
Summary: Support CREATE FUNCTION statements in SQL CLI
Key: FLINK-16381
URL: https://issues.apache.org/jira/browse/FLINK-16381
Project: Flink
Issue Type: New
Gyula Fora created FLINK-16382:
--
Summary: SQL CLI should support command history file
Key: FLINK-16382
URL: https://issues.apache.org/jira/browse/FLINK-16382
Project: Flink
Issue Type: New
Gyula Fora created FLINK-16402:
--
Summary: Alter table fails on Hive catalog
Key: FLINK-16402
URL: https://issues.apache.org/jira/browse/FLINK-16402
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-16421:
--
Summary: Changing default catalog to hive without changing default
database fails
Key: FLINK-16421
URL: https://issues.apache.org/jira/browse/FLINK-16421
Project: Flink
Gyula Fora created FLINK-16422:
--
Summary: Cannot use [catalog].[db].table with Hive catalog
Key: FLINK-16422
URL: https://issues.apache.org/jira/browse/FLINK-16422
Project: Flink
Issue Type
Gyula Fora created FLINK-16441:
--
Summary: Allow users to override flink-conf parameters from SQL
CLI environment
Key: FLINK-16441
URL: https://issues.apache.org/jira/browse/FLINK-16441
Project: Flink
Gyula Fora created FLINK-10387:
--
Summary: StateBackend create methods should return interface not
abstract KeyedStateBackend classes
Key: FLINK-10387
URL: https://issues.apache.org/jira/browse/FLINK-10387
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
Gyula Fora created FLINK-2916:
-
Summary: Add more context information for the StateBackend
Key: FLINK-2916
URL: https://issues.apache.org/jira/browse/FLINK-2916
Project: Flink
Issue Type
Gyula Fora created FLINK-2917:
-
Summary: Make non-copying behaviour default for stream operator
Key: FLINK-2917
URL: https://issues.apache.org/jira/browse/FLINK-2917
Project: Flink
Issue Type
Gyula Fora created FLINK-2923:
-
Summary: Make it possible to mix-and-match StateBackends with
KvState implementations
Key: FLINK-2923
URL: https://issues.apache.org/jira/browse/FLINK-2923
Project: Flink
Gyula Fora created FLINK-2924:
-
Summary: Create database state backend
Key: FLINK-2924
URL: https://issues.apache.org/jira/browse/FLINK-2924
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-2931:
-
Summary: Add global recovery timestamp to state restore
Key: FLINK-2931
URL: https://issues.apache.org/jira/browse/FLINK-2931
Project: Flink
Issue Type
Gyula Fora created FLINK-2965:
-
Summary: KafkaITCase failure
Key: FLINK-2965
URL: https://issues.apache.org/jira/browse/FLINK-2965
Project: Flink
Issue Type: Bug
Components: Streaming
Gyula Fora created FLINK-2983:
-
Summary: Add StateLoader as an alternative to default KvState
Key: FLINK-2983
URL: https://issues.apache.org/jira/browse/FLINK-2983
Project: Flink
Issue Type
Gyula Fora created FLINK-3006:
-
Summary: TypeExtractor fails on custom type
Key: FLINK-3006
URL: https://issues.apache.org/jira/browse/FLINK-3006
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-3008:
-
Summary: Failing/restarting streaming jobs are buggy in the
webfrontend
Key: FLINK-3008
URL: https://issues.apache.org/jira/browse/FLINK-3008
Project: Flink
Gyula Fora created FLINK-3011:
-
Summary: Cannot cancel failing/restarting streaming job from the
command line
Key: FLINK-3011
URL: https://issues.apache.org/jira/browse/FLINK-3011
Project: Flink
Gyula Fora created FLINK-3018:
-
Summary: Job state discarded from web interface for restarting jobs
Key: FLINK-3018
URL: https://issues.apache.org/jira/browse/FLINK-3018
Project: Flink
Issue
Gyula Fora created FLINK-3025:
-
Summary: Flink Kafka consumer may get stuck due to Kafka/Zookeeper
client bug
Key: FLINK-3025
URL: https://issues.apache.org/jira/browse/FLINK-3025
Project: Flink
Gyula Fora created FLINK-3029:
-
Summary: JobGraph is not connected correctly in webfrontend for
streaming job
Key: FLINK-3029
URL: https://issues.apache.org/jira/browse/FLINK-3029
Project: Flink
Gyula Fora created FLINK-3065:
-
Summary: Can't cancel failing jobs
Key: FLINK-3065
URL: https://issues.apache.org/jira/browse/FLINK-3065
Project: Flink
Issue Type: Bug
Compo
Gyula Fora created FLINK-3066:
-
Summary: Kafka source fails on leader change
Key: FLINK-3066
URL: https://issues.apache.org/jira/browse/FLINK-3066
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-3067:
-
Summary: Kafka source fails during checkpoint notifications with
NPE
Key: FLINK-3067
URL: https://issues.apache.org/jira/browse/FLINK-3067
Project: Flink
Issue
Gyula Fora created FLINK-3075:
-
Summary: Rename Either creation methods to avoid name clash with
projection methods
Key: FLINK-3075
URL: https://issues.apache.org/jira/browse/FLINK-3075
Project: Flink
Gyula Fora created FLINK-3168:
-
Summary: Make checkpointing properties configurable from
flink-conf.yaml
Key: FLINK-3168
URL: https://issues.apache.org/jira/browse/FLINK-3168
Project: Flink
Gyula Fora created FLINK-3193:
-
Summary: Add optional bloomfilter to sql state backend
Key: FLINK-3193
URL: https://issues.apache.org/jira/browse/FLINK-3193
Project: Flink
Issue Type
Gyula Fora created FLINK-3237:
-
Summary: Create AsynchronousKvStateSnapshot similar to
AsynchronousStateHandle
Key: FLINK-3237
URL: https://issues.apache.org/jira/browse/FLINK-3237
Project: Flink
Gyula Fora created FLINK-3334:
-
Summary: Change default log4j.properties Conversion pattern to
include year-month-day in the timestamp
Key: FLINK-3334
URL: https://issues.apache.org/jira/browse/FLINK-3334
Gyula Fora created FLINK-3351:
-
Summary: RocksDB Backend cannot determine correct local db path
Key: FLINK-3351
URL: https://issues.apache.org/jira/browse/FLINK-3351
Project: Flink
Issue Type
Gyula Fora created FLINK-3352:
-
Summary: RocksDB Backend cannot determine correct hdfs path
Key: FLINK-3352
URL: https://issues.apache.org/jira/browse/FLINK-3352
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-3354:
-
Summary: RocksDB should compute checkpoint size based on backup
file size
Key: FLINK-3354
URL: https://issues.apache.org/jira/browse/FLINK-3354
Project: Flink
Gyula Fora created FLINK-3355:
-
Summary: Allow passing RocksDB Option to RocksDBStateBackend
Key: FLINK-3355
URL: https://issues.apache.org/jira/browse/FLINK-3355
Project: Flink
Issue Type
Gyula Fora created FLINK-3360:
-
Summary: Clear up StateBackend, AbstractStateBackend abstractions
Key: FLINK-3360
URL: https://issues.apache.org/jira/browse/FLINK-3360
Project: Flink
Issue Type
Gyula Fora created FLINK-3386:
-
Summary: Kafka consumers should not necessarily fail on expiring
data
Key: FLINK-3386
URL: https://issues.apache.org/jira/browse/FLINK-3386
Project: Flink
Issue
Gyula Fora created FLINK-3397:
-
Summary: Failed streaming jobs should fall back to the most recent
checkpoint/savepoint
Key: FLINK-3397
URL: https://issues.apache.org/jira/browse/FLINK-3397
Project
Gyula Fora created FLINK-3431:
-
Summary: Add retrying logic for RocksDB snapshots
Key: FLINK-3431
URL: https://issues.apache.org/jira/browse/FLINK-3431
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-3442:
-
Summary: Expose savepoint button on web ui
Key: FLINK-3442
URL: https://issues.apache.org/jira/browse/FLINK-3442
Project: Flink
Issue Type: Improvement
1 - 100 of 473 matches
Mail list logo
