Messages by Thread
-
-
[jira] [Created] (FLINK-40149) Rename lookup option asyncPolling to async-polling for Flink naming consistency
Bharath Reddy Gunapati (Jira)
-
[jira] [Created] (FLINK-40148) TableIdRouter resolves wrong sink table when source regex has multi-digit suffix and sink-table has no back-reference
peiyu (Jira)
-
[jira] [Created] (FLINK-40147) Improve Native S3 FileSystem docs when using S3-compatible servers that do not support AWS checksum-validation
Fred Teunissen (Jira)
-
[jira] [Created] (FLINK-40146) Support AlterTableCommentEvent in StarRocks sink
Mao Jiayi (Jira)
-
[jira] [Created] (FLINK-40145) flink-model-triton javadoc fails on JDK 11: kotlin.stdlib split-package
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40144) Avoid query database when only get table column
ouyangwulin (Jira)
-
[jira] [Created] (FLINK-40143) Dashboard shows incorrect restart strategy for jobs configured with restart-strategy options
caosurong (Jira)
-
[jira] [Created] (FLINK-40142) [Table SQL / API] Support partition transform expressions in PARTITIONED BY clause
liting liu (Jira)
-
[jira] [Created] (FLINK-40141) Make IS_DECIMAL, IS_DIGIT, and IS_ALPHA return NULL for NULL input
dylanhz (Jira)
-
[jira] [Created] (FLINK-40140) Extract reader recovery gating from DynamicKafkaSourceEnumerator into a ReaderRecoveryCoordinator
Sylwester Lachiewicz (Jira)
-
[jira] [Created] (FLINK-40139) Add default JUnit test timeout to fail hung tests fast
Sylwester Lachiewicz (Jira)
-
[jira] [Created] (FLINK-40138) Migration test snapshot generator does not drive the JUnit 5 lifecycle, breaking snapshot generation for JUnit-5-migrated tests in flink-tests
David Anderson (Jira)
-
[jira] [Created] (FLINK-40137) Extract ReaderRecoveryCoordinator from DynamicKafkaSourceEnumerator
Sylwester Lachiewicz (Jira)
-
[jira] [Created] (FLINK-40136) DynamicKafkaSourceEnumeratorTest flaky due to ConcurrentModificationException in metadata event polling
Sylwester Lachiewicz (Jira)
-
[jira] [Created] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown
Bowen Li (Jira)
-
[jira] [Created] (FLINK-40134) Bump maven-rat-plugin to 0.17
Sergey Nuyanzin (Jira)
-
[VOTE] FLIP-599: State Catalog
Gyula Fóra
-
[jira] [Created] (FLINK-40133) Update HBase version to 2.6.6
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40131) Add documentation for LATERAL SNAPSHOT join
Fabian Hueske (Jira)
-
[jira] [Created] (FLINK-40130) Fix missing primary key type compatibility check of Paimon sink
Mao Jiayi (Jira)
-
[jira] [Created] (FLINK-40128) Implement Topic integrity checks in Kafka Connector - Datasteam
Efrat Levitan (Jira)
-
[jira] [Created] (FLINK-40129) Implement Topic integrity checks in Kafka Connector - Dynamic source
Efrat Levitan (Jira)
-
[jira] [Created] (FLINK-40127) JDBC connector: 37 files ship without the required ASF license header
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40126) Implement Topic integrity checks in Kafka Connector
Efrat Levitan (Jira)
-
[jira] [Created] (FLINK-40125) Add auto cancel for concurrently run jobs
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40124) Maven package cache in job_init action re-saves on every CI run instead of only when dependencies change
Sergey Nuyanzin (Jira)
-
[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)