issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
[PR] [FLINK-41194] Use PulsarAdmin to check transaction state [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar]
via GitHub
[jira] [Created] (FLINK-41194) Use PulsarAdmin to make PulsarSink transaction commits idempotent during recovery
Yubiao Feng (Jira)
[PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
[PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
Re: [PR] [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0 [flink]
via GitHub
[jira] [Updated] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0
Rui Fan (Jira)
[jira] [Updated] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-40526) Support checkpointing during recovery with aligned-checkpoint-timeout > 0
Rui Fan (Jira)
[jira] [Updated] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier
Rui Fan (Jira)
[jira] [Commented] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier
Rui Fan (Jira)
[jira] [Assigned] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0
Rui Fan (Jira)
[jira] [Created] (FLINK-41193) Disable checkpointing during recovery when aligned-checkpoint-timeout > 0
Rui Fan (Jira)
[jira] [Assigned] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka
Martijn Visser (Jira)
[jira] [Commented] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null."
Sergey Nuyanzin (Jira)
[PR] [hotfix][docs] Add docs data for the SQL connector download table [flink-connector-http]
via GitHub
Re: [PR] [hotfix][docs] Add docs data for the SQL connector download table [flink-connector-http]
via GitHub
[PR] [hotfix] Add docs data, update CI and enable japicmp ahead of 1.1.0 [flink-connector-http]
via GitHub
[PR] [FLINK-41191][build] Upgrade Testcontainers to 1.21.4 [flink-connector-opensearch]
via GitHub
Re: [PR] [FLINK-41191][build] Upgrade Testcontainers to 1.21.4 [flink-connector-opensearch]
via GitHub
[jira] [Updated] (FLINK-40825) Support casting primitive types to VARIANT
Ramin Gharib (Jira)
[jira] [Updated] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT
Ramin Gharib (Jira)
[jira] [Closed] (FLINK-40824) Support casting to VARIANT
Ramin Gharib (Jira)
[jira] [Created] (FLINK-41192) HTTP sink request never completes when a retry attempt throws
Martijn Visser (Jira)
[jira] [Updated] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41177) Checkpointed-position test source for hook-driven checkpointing ITCases
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41188) Rewrite InterruptSensitiveRestoreTest without SourceStreamTask
Martijn Visser (Jira)
[jira] [Commented] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41184) Migrate TestEventSource of the operator lifecycle test jobs to Source V2
Martijn Visser (Jira)
[jira] [Updated] (FLINK-41191) Upgrade Testcontainers to 1.21.4 on the flink-connector-opensearch v1.2 branch
ASF GitHub Bot (Jira)
[jira] [Assigned] (FLINK-41163) Migrate KeyedStateCheckpointingITCase and CoStreamCheckpointingITCase to DataGeneratorSource
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41166) Migrate SavepointITCase sources to Source V2
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41182) Migrate AutoRescalingITCase and RescalingITCase sources to Source V2
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41187) Remove StreamSource from StreamTask tests that guard surviving behaviour
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-41171) Migrate the operator restore test jobs KeyedJob and NonKeyedJob to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41163) Migrate KeyedStateCheckpointingITCase and CoStreamCheckpointingITCase to DataGeneratorSource
Martijn Visser (Jira)
[jira] [Created] (FLINK-41188) Rewrite InterruptSensitiveRestoreTest without SourceStreamTask
Martijn Visser (Jira)
[jira] [Created] (FLINK-41169) Migrate streaming runtime ITCases to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41191) Upgrade Testcontainers to 1.21.4 on the flink-connector-opensearch v1.2 branch
Purushottam Sinha (Jira)
[jira] [Created] (FLINK-41189) Migrate small planner test sources to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41187) Remove StreamSource from StreamTask tests that guard surviving behaviour
Martijn Visser (Jira)
[jira] [Created] (FLINK-41184) Migrate TestEventSource of the operator lifecycle test jobs to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41190) Migrate TestProtobufSourceFunction to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41186) Migrate graph and partitioner tests in flink-streaming-java and flink-runtime to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41182) Migrate AutoRescalingITCase and RescalingITCase sources to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41185) Migrate YarnTestJob to a self-contained Source V2 source
Martijn Visser (Jira)
[jira] [Created] (FLINK-41183) Migrate the RegionFailoverITCase source to Source V2
Martijn Visser (Jira)
Re: [PR] [FLINK-40279][connector-http] Add HTTP sink OIDC, proxy and HTTP version options [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40279][connector-http] Add HTTP sink OIDC, proxy and HTTP version options [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40279][connector-http] Add HTTP sink OIDC, proxy and HTTP version options [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40279][connector-http] Add HTTP sink OIDC, proxy and HTTP version options [flink-connector-http]
via GitHub
[jira] [Created] (FLINK-41177) Checkpointed-position test source for hook-driven checkpointing ITCases
Martijn Visser (Jira)
[jira] [Created] (FLINK-41181) Filesystem sink silently drops all rows when the last partition column name starts with '_' or '.'
Yaoxuan Wu (Jira)
[jira] [Created] (FLINK-41168) Migrate recovery and scheduling ITCases to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41180) VARIANT objects sort and search field names in UTF-16 order instead of UTF-8 byte order
Ramin Gharib (Jira)
[jira] [Updated] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result
Yaoxuan Wu (Jira)
[jira] [Updated] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result
ASF GitHub Bot (Jira)
[PR] [FLINK-41119][release] Update dev-master to point to 2.5 [flink-docker]
via GitHub
Re: [PR] [FLINK-41119][release] Update dev-master to point to 2.5 [flink-docker]
via GitHub
[jira] [Created] (FLINK-41179) VAR_POP / STDDEV_POP give wrong, non-deterministic results with mini-batch two-phase aggregation over an updating input
Yaoxuan Wu (Jira)
[jira] [Commented] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects
Yuepeng Pan (Jira)
[jira] [Commented] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects
Ramin Gharib (Jira)
[jira] [Updated] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka
ASF GitHub Bot (Jira)
[jira] [Resolved] (FLINK-41087) TRY_PARSE_JSON builds the PARSE_JSON error for every row it rejects
Ramin Gharib (Jira)
[PR] [FLINK-41119][release] Update master to 2.5-SNAPSHOT [flink-benchmarks]
via GitHub
Re: [PR] [FLINK-41119][release] Update master to 2.5-SNAPSHOT [flink-benchmarks]
via GitHub
Re: [PR] [FLINK-41119][release] Update master to 2.5-SNAPSHOT [flink-benchmarks]
via GitHub
[jira] [Created] (FLINK-41160) Migrate CheckpointedStreamingProgram to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41161) Migrate TimestampITCase to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41166) Migrate SavepointITCase sources to Source V2
Martijn Visser (Jira)
[PR] [FLINK-41178][docs/tests] Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files [flink]
via GitHub
Re: [PR] [FLINK-41178][docs/tests] Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files [flink]
via GitHub
Re: [PR] [FLINK-41178][docs/tests] Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure [flink]
via GitHub
Re: [PR] [FLINK-41178][docs/tests] Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure [flink]
via GitHub
[jira] [Created] (FLINK-41173) Migrate AbstractQueryableStateTestBase sources to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41175) Migrate S5CmdOnSeaweedFsITCase to FailingCheckpointedSource
Martijn Visser (Jira)
[jira] [Updated] (FLINK-41119) Prepare Flink 2.4 release
ASF GitHub Bot (Jira)
[PR] [FLINK-41119][release] Build docs for release-2.4 branch [flink]
via GitHub
Re: [PR] [FLINK-41119][release] Build docs for release-2.4 branch [flink]
via GitHub
Re: [PR] [FLINK-41119][release] Build docs for release-2.4 branch [flink]
via GitHub
Re: [PR] [FLINK-41119][release] Build docs for release-2.4 branch [flink]
via GitHub
Re: [PR] [FLINK-41119][release] Build docs for release-2.4 branch [flink]
via GitHub
[jira] [Created] (FLINK-41172) Migrate flink-state-processing-api test sources to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41164) Upgrade Testcontainers to 1.21.4 on the flink-connector-mongodb v2.0 branch
Purushottam Sinha (Jira)
[jira] [Created] (FLINK-41162) Migrate CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase to Source V2
Martijn Visser (Jira)
[PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
Re: [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
Re: [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
Re: [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
Re: [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
Re: [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
Re: [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink]
via GitHub
[jira] [Created] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41174) Migrate KubernetesHighAvailabilityRecoverFromSavepointITCase to Source V2
Martijn Visser (Jira)
Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink]
via GitHub
Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink]
via GitHub
[jira] [Created] (FLINK-41171) Migrate the operator restore test jobs KeyedJob and NonKeyedJob to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41159) Remove unused SourceFunction test sources from flink-yarn-tests
Martijn Visser (Jira)
[jira] [Created] (FLINK-41176) Migrate flink-connector-files sink ITCase sources to Source V2
Martijn Visser (Jira)
[jira] [Updated] (FLINK-41164) Upgrade Testcontainers to 1.21.4 on the flink-connector-mongodb v2.0 branch
ASF GitHub Bot (Jira)
[PR] [FLINK-41164][build] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-41164][build] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-41164][build] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098][build] Fix v2.0 CI: bump testcontainers to 1.21.4, Flink to 1.20.5 and drop 1.19 [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http]
via GitHub
[jira] [Created] (FLINK-41165) Migrate the remaining checkpointing ITCases with generated sources to DataGeneratorSource
Martijn Visser (Jira)
[jira] [Created] (FLINK-41170) Migrate classloading jar programs and shared util sources to Source V2
Martijn Visser (Jira)
[jira] [Created] (FLINK-41167) Migrate the remaining checkpointing ITCases with controllable sources to Source V2
Martijn Visser (Jira)
[jira] [Resolved] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka
Martijn Visser (Jira)
[jira] [Resolved] (FLINK-41156) Upgrade Testcontainers to 1.21.4 on the JDBC connector v4.1 and v3.4 branches to support Docker 29
Martijn Visser (Jira)
[jira] [Resolved] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null."
Sergey Nuyanzin (Jira)
[jira] [Updated] (FLINK-41154) Make the connector release scripts work reliably on macOS and Linux
ASF GitHub Bot (Jira)
[jira] [Created] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing
Dennis-Mircea Ciupitu (Jira)
[jira] [Created] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka
Purushottam Sinha (Jira)
[PR] [integration][java] Send user images, audio, video and documents to Gemini [flink-agents]
via GitHub
Re: [PR] [integration][java] Send user images, audio, video and documents to Gemini [flink-agents]
via GitHub
[PR] [FLINK-41101][jdbc] Roll back the prepared transactions that earlier jobs left behind [flink-connector-jdbc]
via GitHub
[jira] [Updated] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing
Dennis-Mircea Ciupitu (Jira)
[jira] [Created] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion
Yuepeng Pan (Jira)
[PR] [BP-3.4][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc]
via GitHub
Re: [PR] [BP-3.4][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc]
via GitHub
[PR] [BP-4.1][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc]
via GitHub
Re: [PR] [BP-4.1][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc]
via GitHub
[jira] [Created] (FLINK-41150) Release Testing Instructions: FLIP-599: State Catalog
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41156) Upgrade Testcontainers to 1.21.4 on the JDBC connector v4.1 and v3.4 branches to support Docker 29
Martijn Visser (Jira)
[jira] [Created] (FLINK-41154) Make the connector release scripts work reliably on macOS and Linux
Martijn Visser (Jira)
[jira] [Created] (FLINK-41155) Add stage_source_release_atr.sh for Apache Trusted Releases
Martijn Visser (Jira)
[jira] [Closed] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown
Dennis-Mircea Ciupitu (Jira)
[jira] [Closed] (FLINK-41031) Close operator-owned resources on shutdown and exit on startup failure
Dennis-Mircea Ciupitu (Jira)
[PR] [FLINK-33186][BP 2.3 [flink]
via GitHub
Re: [PR] [FLINK-33186][tests][BP-2.3] Addressing CheckpointAfterAllTasksFinishedITCase CI flakiness [flink]
via GitHub
Re: [PR] [FLINK-33186][tests][BP-2.3] Addressing CheckpointAfterAllTasksFinishedITCase CI flakiness [flink]
via GitHub
Re: [PR] [FLINK-33186][tests][BP-2.3] Addressing CheckpointAfterAllTasksFinishedITCase CI flakiness [flink]
via GitHub
[jira] [Created] (FLINK-41146) Release Testing Instructions: FLIP-547 V2: Filtering record before processing with spilling strategy
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41141) Release Testing Instructions: FLIP-574 Metadata Filter Push-Down for Table Sources
Yuepeng Pan (Jira)
Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink]
via GitHub
[jira] [Created] (FLINK-41151) Release Testing Instructions: FLINK-39268: Support Common Subexpression Elimination (CSE) in Calc Code Generation
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-41151) Release Testing Instructions: FLINK-39268:Support Common Subexpression Elimination (CSE) in Calc Code Generation
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41149) Release Testing Instructions: FLIP-585: Introduce Lazy Loading for HistoryServer
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41148) Release Testing Instructions: FLIP-584: Support Pluggable Storage Backend for HistoryServer
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join
Yuepeng Pan (Jira)
Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink]
via GitHub
Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink]
via GitHub
Re: [PR] [FLINK-40237][cep] Clean up expired NFA state in processing-time timers [flink]
via GitHub
[jira] [Closed] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink
Ferenc Csaky (Jira)
[jira] [Created] (FLINK-41140) Release Testing Instructions: FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41139) Release Testing Instructions: FLIP-567: Introduce a ProcessTableFunction Test Harness
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41138) Release Testing Instructions: FLIP-566: Introduce a new IMMUTABLE columns constraint
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Yuepeng Pan (Jira)
[I] [Feature] Decision-model routing strategy for MODEL_ROUTER [flink-agents]
via GitHub
Re: [I] [Feature] Decision-model routing strategy for MODEL_ROUTER [flink-agents]
via GitHub
[jira] [Commented] (FLINK-39889) Convert table sqlnode to operation
Yuepeng Pan (Jira)
[jira] [Resolved] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize
Sergey Nuyanzin (Jira)
[PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink]
via GitHub
Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink]
via GitHub
Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink]
via GitHub
Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink]
via GitHub
Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink]
via GitHub
[PR] [hotfix][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-41158][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-41158][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka]
via GitHub
[PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink]
via GitHub
Re: [PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink]
via GitHub
[jira] [Updated] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41121) [release-2.4] Select executing release manager
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-41122) [release-2.4] Create release branch
Yuepeng Pan (Jira)
Re: [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink]
via GitHub
[jira] [Created] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs
Yuepeng Pan (Jira)
[PR] Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard [flink]
via GitHub
[PR] [hotfix] Make release_utils work on macOS and Linux [flink-connector-shared-utils]
via GitHub
Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils]
via GitHub
Earlier messages
Later messages