Messages by Thread
-
[jira] [Created] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh
Shekhar Prasad Rajak (Jira)
-
[jira] [Created] (FLINK-40122) Expose a public getter for the persisted RowData field names
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3
Sylwester Lachiewicz (Jira)
-
[jira] [Created] (FLINK-40120) Persist RowData field names in RowDataSerializerSnapshot
Weiqing Yang (Jira)
-
[jira] [Created] (FLINK-40119) Blue/Green: after an aborted transition, the next deploy deletes Blue immediately instead of waiting the deletion delay
Calico Shop (Jira)
-
[jira] [Created] (FLINK-40118) Web dashboard: SubTask TimeLine shows "N - undefined" instead of the task endpoint
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40117) Web dashboard: extend Vitest smoke-test coverage to remaining high-traffic views
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40116) Support more predicates for filter pushdown during savepoint scan
Ilya Soin (Jira)
-
[RESULT][VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
[VOTE] FLIP-591: Introducing Python DataFrame API in PyFlink
Dian Fu
-
[jira] [Created] (FLINK-40115) Document timestamp reliability for bounded-out-of-orderness watermarks
Hancheng Deng (Jira)
-
[jira] [Created] (FLINK-40114) Leader information permanently erased when a change event races a pending confirmation
Prashant Bhardwaj (Jira)
-
[jira] [Created] (FLINK-40113) State restore does not validate max-parallelism agreement between operators sharing a vertex
Rion Williams (Jira)
-
[VOTE] Release flink-connector-jdbc v4.1.0, release candidate #4
Yuepeng Pan
-
[VOTE] Release flink-connector-jdbc v3.4.0, release candidate #4
Yuepeng Pan
-
[jira] [Created] (FLINK-40111) Keyless upsert sink should fall back to retract when the input has no upsert key
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40112) Report a changelog mode mismatch instead of a generic planning error
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40110) Connectors/OpenSearch: Bump flink.version to 2.1.2 in flink-connector-opensearch
Purushottam Sinha (Jira)
-
[DISCUSS] Breaking change: Make IS JSON / IS NOT JSON return NULL for NULL input
Fabian Hueske
-
[jira] [Created] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40108) Add Splitters for snapshot a table or database
Jira
-
[jira] [Created] (FLINK-40107) Group example modules under an examples aggregator pom
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Created] (FLINK-40106) Move FlinkResourceValidator and FlinkResourceMutator to the api module
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Created] (FLINK-40105) Support configuring Kubernetes memory request factor for JobManager and TaskManager
xiechenling (Jira)
-
[jira] [Created] (FLINK-40104) Logging framework JARs are placed under $FLINK_HOME/log instead of the operator lib directory
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Created] (FLINK-40103) Upgrade operator to Java Operator SDK version 5.4
Jira
-
Re: [DISCUSS] State Schema Evolution for RowData
Weiqing Yang
-
[jira] [Created] (FLINK-40102) MySQL CDC Source: Support batch emitting CreateTableEvents to reduce schema coordination overhead
ericzeng (Jira)
-
[jira] [Created] (FLINK-40101) Watermark forwarding can stall indefinitely under interruptible timers with a large due-timer backlog
Piotr Nowojski (Jira)
-
[DISCUSS] FLIP-601: Cloud-Agnostic Client-Side Encryption for SDK-Native Filesystems
Aleksandr Iushmanov
-
[jira] [Created] (FLINK-40100) Reduce ArchUnit violations: remove direct usage of Flink-internal/shaded APIs in flink-connector-http
Bharath Reddy Gunapati (Jira)
-
[jira] [Created] (FLINK-40099) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab log check reads a killed TaskManager's log
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-40098) Add FailingCheckpointedSource test utility for exactly-once source tests
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40097) FLIP-585: Introduce Lazy Loading for HistoryServer
chenzihao (Jira)
-
[RESULT][VOTE] FLIP-585: Introduce Lazy Loading for HistoryServer
zihao chen
-
[jira] [Created] (FLINK-40096) Migrate EXPLAIN CTAS/RTAS Explain tests to Java
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-40095) JSON aggregation functions failing in group window aggregate
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-40094) DynamicKafkaSource should mark removed split outputs idle before release
Xin Gao (Jira)
-
[jira] [Created] (FLINK-40093) Race condition between watermark alignment and idleness detection locks split in idle
Efrat Levitan (Jira)
-
[VOTE] Release flink-connector-jdbc v3.4.0, release candidate #3
Yuepeng Pan
-
[jira] [Created] (FLINK-40092) BlueGreen transition should finalize immediately after deleting previous deployment
Calico Shop (Jira)
-
[jira] [Created] (FLINK-40091) upgrade paimon to 1.4.2
peiyu (Jira)
-
[jira] [Created] (FLINK-40090) Modernize cryptography export notice in distribution README
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40089) Add JSON_LENGTH function
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40088) RestClientITCase.testHttpsConnectionWithDefaultCerts is flaky due to GitHub rate limiting (HTTP 429)
Martijn Visser (Jira)
-
[DISCUSS] FLIP-XXX: Extended JDBC Scan Partitioning Options for Efficient Data Ingestion
Chanhae Oh
-
[jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`)
Xin Gong (Jira)
-
[jira] [Created] (FLINK-40086) Harden Execution#transitionState implementation by guarding preCompletionAction
Matthias Pohl (Jira)
-
[jira] [Created] (FLINK-40085) Introduce e2e test for es8 sink
reswqa (Jira)
-
[VOTE] FLIP-600: Independent Checkpoint Based On Pipeline Region
熊饶饶
-
[jira] [Created] (FLINK-40084) maven-shade-plugin does not respect multi release jars
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38
Chris Lu (Jira)
-
[VOTE] Release flink-connector-jdbc v3.4.0, release candidate #2
Yuepeng Pan
-
[VOTE] Release flink-connector-jdbc v4.1.0, release candidate #3
Yuepeng Pan
-
Help Needed for JDBC Release v3.4.0
Yuepeng Pan
-
[jira] [Created] (FLINK-40082) InvalidProgramException when performing LEFT JOIN with a lookup table that has a computed field for Watermark extraction based on metadata field (HEADERS)
Fred Teunissen (Jira)
-
[jira] [Created] (FLINK-40081) Enable the spilling backend for checkpointing during recovery
Rui Fan (Jira)
-
[jira] [Created] (FLINK-40080) Drain spilled channel state into input channels and replay spilled slices into checkpoints
Rui Fan (Jira)
-
[jira] [Created] (FLINK-40079) Enforce disableSystemArguments consistently for all PTF translation paths
Fabian Hueske (Jira)
-
[DISCUSS] FLIP-XXX: Flink Kubernetes Operator Autotuning Redesign
Dennis-Mircea Ciupitu
-
[jira] [Created] (FLINK-40078) Lost non-loss-tolerant OperatorEvent to an already-failing task triggers a failover that masks the original failure cause
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40076) RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause fails intermittently: snapshot taken before recoverable failover is merged into in-progress rescale
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40075) Optimize WELFORD_M2 aggregate accumulator by using RowData instead of STRUCTURED POJO accumulator
dylanhz (Jira)
-
[jira] [Created] (FLINK-40074) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling fails on @TempDir cleanup race (Failed to delete temp directory)
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40073) Delete and Force Push Protections for Default and Release Branches
Harshit Gupta (Jira)
-
[jira] [Created] (FLINK-40072) request.timeout is declared as a Duration option but parsed as integer seconds, crashing at query time on any unit-suffixed value
Bharath Reddy Gunapati (Jira)
-
[jira] [Created] (FLINK-40071) Bump jackson-bom to 2.21.4
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40067) RescaleTimelineITCase.testRescaleTerminatedByJobFinished fails due to race between cooldown-driven rescale termination and job finish
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40066) flink-connector-mongodb: update flink-connector-parent to 2.0.0 and flink.version to 2.1.2
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1.
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40064) Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink and re-enable it
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40063) Tests: migrate JUnit 5 (Jupiter) to JUnit 6
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized
Sergey Nuyanzin (Jira)
-
[ANNOUNCE] Apache flink-connector-http v1.0.0 released
David Radley
-
[jira] [Created] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml
ChanBin OH (Jira)
-
[jira] [Created] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility
Sumin Joo (Jira)
-
[jira] [Created] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40057) DefaultSlotAssigner over-picks slots from the boundary TaskManager when minimal-TaskManager placement is enabled
ericzeng (Jira)
-
[jira] [Created] (FLINK-40056) Support anchor navigation for pyflink configuration options
chenzihao (Jira)
-
[jira] [Created] (FLINK-40055) Operator serializes managed-deployment config in its own YAML dialect, breaking Flink 1.x deployments when the operator itself runs on standard config.yaml
Gerk Elznik (Jira)
-
[jira] [Created] (FLINK-40054) Update aircompressor to 2.0.3
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40053) Log4j 2.26.1 bump
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED
SkylerLin (Jira)
-
[jira] [Created] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml
lisa (Jira)
-
[jira] [Created] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x
Taranpreet Kaur (Jira)
-
[jira] [Created] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40047) Flink Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+
Marc Demierre (Jira)
-
[jira] [Created] (FLINK-40046) Upgrade @antv/g2 to v5
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40045) Upgrade d3-flame-graph to v5
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism
peiyu (Jira)
-
[jira] [Created] (FLINK-40042) Update JDBC connector version to 4.1.0
Yuepeng Pan (Jira)
-
[jira] [Created] (FLINK-40041) Update JDBC connector version to 3.4.0
Yuepeng Pan (Jira)
-
[jira] [Created] (FLINK-40040) SchemaRegistry loses coordination responses when a failure's cause is a user-classloader-only class (e.g. a JDBC driver exception), causing the job to hang until rpcTimeout and enter a restart loop
Jiyong Wang (Jira)
-
[jira] [Created] (FLINK-40039) CTAS/RTAS do not work for PTFs with set semantics and PARTITION BY
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead
Jira
-
[jira] [Created] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart
Grzegorz Liter (Jira)
-
[jira] [Created] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses
Kaivalya Apte (Jira)
-
[jira] [Created] (FLINK-40035) Add smoke-level component specs for the web-dashboard
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40034) Refresh web-dashboard lint tooling to prettier 3 and stylelint 17
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40033) Modernize web-dashboard visualization libraries
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40032) Migrate web-dashboard eslint to v9 (flat config)
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40030) Add architecture tests to flink-connector-http
Bharath Reddy Gunapati (Jira)
-
[jira] [Created] (FLINK-40029) Use Hadoop 3.4.3 in nightly tests
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40028) Update Angular to v21 and ng-zorro-antd to v21
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40027) Align SavepointKeyFilter with the State Processor API generic convention
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-40026) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table
Stepan Stepanishchev (Jira)
-
[jira] [Created] (FLINK-40025) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table
Stepan Stepanishchev (Jira)
-
[jira] [Created] (FLINK-40024) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table
Stepan Stepanishchev (Jira)
-
[jira] [Created] (FLINK-40023) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table
Stepan Stepanishchev (Jira)
-
[jira] [Created] (FLINK-40022) Table API client hangs when batch query returns an empty result
Timo Theusner (Jira)
-
[jira] [Created] (FLINK-40021) AND for pushdown filters should be in uppercase
Sergey Nuyanzin (Jira)