Messages by Thread
-
[jira] [Created] (FLINK-34533) CLONE - Propose a pull request for website updates
lincoln lee (Jira)
-
[jira] [Created] (FLINK-34532) CLONE - Stage source and binary releases on dist.apache.org
lincoln lee (Jira)
-
[jira] [Created] (FLINK-34531) CLONE - Build and stage Java and Python artifacts
lincoln lee (Jira)
-
[jira] [Created] (FLINK-34530) Build Release Candidate: 1.19.0-rc1
lincoln lee (Jira)
-
[jira] [Created] (FLINK-34529) Projection cannot be pushed down through rank operator.
yisha zhou (Jira)
-
[jira] [Created] (FLINK-34528) With shuffling data, when a Task Manager is killed, restarting the Flink job takes a considerable amount of time
junzhong qin (Jira)
-
[jira] [Created] (FLINK-34527) Deprecate Time classes also in PyFlink
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34526) Without shuffling data, when a Task Manager is killed, restarting the Flink job takes a considerable amount of time
junzhong qin (Jira)
-
[jira] [Created] (FLINK-34525) When redundant task managers are enabled, it will still take a considerable amount of time to restart a job if a task manager is killed.
junzhong qin (Jira)
-
[jira] [Created] (FLINK-34524) Scale down JobManager deployment to 0 before deletion
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-34523) org.apache.maven.surefire:surefire-shared-utils:jar:3.2.2 couldn't be downloaded
lincoln lee (Jira)
-
[jira] [Created] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still use the deprecated Time
Rui Fan (Jira)
-
[jira] [Created] (FLINK-34521) Using the Duration instead of the deprecated Time classes
Rui Fan (Jira)
-
[jira] [Created] (FLINK-34520) Confusing MIT language in the NOTICE file
Henri Yandell (Jira)
-
[jira] [Created] (FLINK-34519) Refine checkpoint scheduling and canceling logic
Yunfeng Zhou (Jira)
-
[DISCUSS] Move CheckpointingMode to flink-core
Zakelly Lan
-
[jira] [Created] (FLINK-34518) Adaptive Scheduler restores from empty state if JM fails during restarting state
Gyula Fora (Jira)
-
[VOTE] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2
weijie guo
-
[VOTE] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction
weijie guo
-
[VOTE] FLIP-408: [Umbrella] Introduce DataStream API V2
weijie guo
-
[jira] [Created] (FLINK-34517) environment configs ignored when calling ProcedureOperation
JustinLee (Jira)
-
[jira] [Created] (FLINK-34516) Move CheckpointingMode to flink-core
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34515) Document new FLIP process
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-34514) e2e (1) times out because of an error that's most likely caused by a networking issue
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34512) Thrown root cause for HandlerRequestException
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-34511) Flink 2.0: Deprecate legacy State&Checkpointing&Recovery options
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34510) Flink 2.0: Rename RestoreMode to RecoveryClaimMode
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples
Lorenzo Affetti (Jira)
-
[jira] [Created] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34507) JSON functions have wrong operand checker
Dawid Wysakowicz (Jira)
-
[jira] [Created] (FLINK-34506) Do not copy "file://" schemed artifact in standalone application modes
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-34505) Migrate WindowGroupReorderRule
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34504) Avoid the parallelism adjutment when the upstream shuffle type doesn't has keyBy
Rui Fan (Jira)
-
[jira] [Created] (FLINK-34503) Migrate JoinDeriveNullFilterRule
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34502) Support calculating network memory for forward and rescale edge
Rui Fan (Jira)
-
[jira] [Created] (FLINK-34501) In AsyncWaitOperator, ResultHandler.completeExceptionally() triggeres task/job restarts after max retry is reached
Dinesh (Jira)
-
[jira] [Created] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources
SuDewei (Jira)
-
[ANNOUNCE] Apache flink-connector-jdbc 3.1.2 released
Sergey Nuyanzin
-
Re: Temporal join on rolling aggregate
Gyula Fóra
-
[jira] [Created] (FLINK-34499) Configuration#toString should hide sensitive values
Chesnay Schepler (Jira)
-
[jira] [Created] (FLINK-34498) GSFileSystemFactory logs full Flink config
Chesnay Schepler (Jira)
-
[DISCUSS] Apache Bahir retired
Ferenc Csaky
-
[jira] [Created] (FLINK-34497) Avoid using system classloader in SerializedThrowableDeserializer
jrthe42 (Jira)
-
[jira] [Created] (FLINK-34496) Classloading deadlock between ExecNodeMetadataUtil and JsonSerdeUtil
Chesnay Schepler (Jira)
-
[VOTE] FLIP-419: Optimize multi-sink query plan generation
Jeyhun Karimov
-
[jira] [Created] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34493) Migrate ReplaceMinusWithAntiJoinRule
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34492) fix scala style comment link when migrate scala to java
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34491) Move from experimental support to production support for Java 17
Dhruv Patel (Jira)
-
[jira] [Created] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining
Eddie Ramirez (Jira)
-
[DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format
Kevin Lam
-
[jira] [Created] (FLINK-34489) New File Sink end-to-end test timed out
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34488) Integrate snapshot deployment into GHA nightly workflow
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34486) Add documentation on how to add the shared utils as a submodule to the connector repo
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34485) Token delegation doesn't work with Presto S3 filesystem
Chesnay Schepler (Jira)
-
[jira] [Created] (FLINK-34484) Split 'state.backend.local-recovery' into two options for checkpointing and recovery
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34483) Merge 'state.checkpoints.dir' and 'state.checkpoints-storage' into one
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34482) Rename options for checkpointing
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34481) Migrate SetOpRewriteUtil
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34480) Add method to support user jar overwrite flink inner jar class when same class
JinxinTang (Jira)
-
[jira] [Created] (FLINK-34479) Fix missed changelog configs in the documentation
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-34478) NoSuchMethod error for "flink cancel $jobId" via Command Line
Liu Yi (Jira)
-
[RESULT][VOTE] Release flink-connector-jdbc 3.1.2, release candidate #3
Sergey Nuyanzin
-
[jira] [Created] (FLINK-34477) support capture groups in REGEXP_REPLACE
David Anderson (Jira)
-
[RESULT][VOTE] FLIP-417: Expose JobManagerOperatorMetrics via REST API
Mason Chen
-
[jira] [Created] (FLINK-34476) Window TVFs with named parameters don't support column expansion
Timo Walther (Jira)
-
[ANNOUNCE] Flink 1.19 Cross-team testing & sync summary on 02/20/2024
Lincoln Lee
-
[jira] [Created] (FLINK-34475) ZooKeeperLeaderElectionDriverTest failed with exit code 2
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34474) After failed deserialization with ConfluentRegistryAvroDeserializationSchema all subsequent deserialization fails
Grzegorz Liter (Jira)
-
[jira] [Created] (FLINK-34473) Migrate FlinkPruneEmptyRules
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-34472) loading class of protobuf format descriptor by Class.forName(className, true, Thread.currentThread().getContextClassLoader()) may can not find class because The current thread class loader may not contain this class
jeremyMu (Jira)
-
[jira] [Created] (FLINK-34471) Tune the network memroy in Autoscaler
Rui Fan (Jira)
-
Community Over Code Asia 2024 Travel Assistance Applications now open!
Gavin McDonald
-
[VOTE] Release flink-connector-parent 1.1.0 release candidate #2
Etienne Chauchot
-
[ANNOUNCE] Apache flink-connector-mongodb 1.1.0 released
Leonard Xu
-
[jira] [Created] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging
dongwoo.kim (Jira)
-
[jira] [Created] (FLINK-34469) Implement TableDistribution toString
Timo Walther (Jira)
-
[jira] [Created] (FLINK-34468) Implement Lineage Interface in Cassandra Connector
Zhenqiu Huang (Jira)
-
[jira] [Created] (FLINK-34467) Implement Lineage Interface in Jdbc Connector
Zhenqiu Huang (Jira)
-
[jira] [Created] (FLINK-34466) Implement Lineage Interface in Kafka Connector
Zhenqiu Huang (Jira)
-
[jira] [Created] (FLINK-34465) Python py38-cython: commands failed, Bash exited with code '1
lincoln lee (Jira)
-
[ANNOUNCE] New Apache Flink Committer - Jiabao Sun
Qingsheng Ren
-
[jira] [Created] (FLINK-34464) actions/cache@v4 times out
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-34463) Open catalog in CatalogManager should use proper context classloader
jrthe42 (Jira)
-
[RESULT][VOTE] Release flink-connector-mongodb 1.1.0, release candidate #2
Leonard Xu
-
[jira] [Created] (FLINK-34462) Session window with negative parameter throws unclear exception
Shuai Xu (Jira)
-
[jira] [Created] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-34460) Jdbc driver get rid of flink-core
Fang Yong (Jira)
-
[jira] [Created] (FLINK-34459) Results column names should match SELECT clause expression names
Jeyhun Karimov (Jira)
-
[jira] [Created] (FLINK-34458) Rename options for Generalized incremental checkpoints (changelog)
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34457) Rename options for latency tracking
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34456) Move all checkpoint-related options into CheckpointingOptions
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34455) Move RestoreMode from flink-runtime to flink-core
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34454) Introduce RecoveryOptions in flink-core
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34453) [Benchmark] Add warmup in SchedulerBenchmarkExecutor
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots
xiangyu feng (Jira)
-
Flink's treatment to "hadoop" and "yarn" configuration overrides seems unintuitive
Venkatakrishnan Sowrirajan
-
[jira] [Created] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach
Alex Hoffer (Jira)
-
FLINK-21672
David Radley