Messages by Thread
-
-
[jira] [Updated] (FLINK-39995) Add ISO-8601 timestamp format with explicit timezone offset support
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink]
via GitHub
-
[jira] [Created] (FLINK-39995) Add ISO-8601 timestamp format with explicit timezone offset support
Jira
-
[jira] [Closed] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter
Roman Khachatryan (Jira)
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink]
via GitHub
-
[jira] [Updated] (FLINK-38603) FLIP-553 [Metrics] Robust OTel gRPC metric exporter
Roman Khachatryan (Jira)
-
[jira] [Commented] (FLINK-39129) Support native types in MetricConfig
Aleksandr Iushmanov (Jira)
-
[jira] [Resolved] (FLINK-39129) Support native types in MetricConfig
Aleksandr Iushmanov (Jira)
-
[jira] [Commented] (FLINK-39639) Split assignment accepted after source finished reading leads to silent data loss
Spoorthi Basu (Jira)
-
[jira] [Resolved] (FLINK-39993) Correct documentation examples for ProcessTableFunctionTestHarness
Fabian Hueske (Jira)
-
[jira] [Updated] (FLINK-39994) Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39994][table] Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness [flink]
via GitHub
-
[PR] [DEBUG - DO NOT MERGE][FLINK-38544] hunt 1 [flink]
via GitHub
-
[jira] [Updated] (FLINK-39993) Correct documentation examples for ProcessTableFunctionTestHarness
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39993][docs] Correct documentation examples for ProcessTableFunctionTestHarness [flink]
via GitHub
-
[jira] [Created] (FLINK-39994) Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Assigned] (FLINK-39994) Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Updated] (FLINK-39357) FLIP-567: Introduce a ProcessTableFunction Test Harness
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39357][docs] Correct documentation examples for ProcessTableFunctionTestHarness [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39993) Correct documentation examples for ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-39993) Correct documentation examples for ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Closed] (FLINK-39825) Add support for state TTL in ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Updated] (FLINK-39988) Support composite types in filter push-down for savepoint Table API connector
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-39987) Update docs related to flink-state-processing-api
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-39988) Support composite types in filter push-down for savepoint Table API connector
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-39987) Update docs related to flink-state-processing-api
Yibo Cao (Jira)
-
[jira] [Commented] (FLINK-39988) Support composite types in filter push-down for savepoint Table API connector
Yibo Cao (Jira)
-
Re: [PR] [FLINK-38469][python] Bump Apache Beam to 2.72 [flink]
via GitHub
-
[jira] [Commented] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions
Oleksandr Shulgin (Jira)
-
[jira] [Updated] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator]
via GitHub
-
[jira] [Resolved] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume
Gabor Somogyi (Jira)
-
[jira] [Closed] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume
Gabor Somogyi (Jira)
-
[PR] [BP-2.2][FLINK-39061][example] Roll back StateMachineExample to v1 State API [flink]
via GitHub
-
[PR] [BP-2.0][FLINK-39061][example] Roll back StateMachineExample to v1 State API [flink]
via GitHub
-
[PR] [BP-2.1][FLINK-39061][example] Roll back StateMachineExample to v1 State API [flink]
via GitHub
-
[PR] [BP-2.3][FLINK-39061][example] Roll back StateMachineExample to v1 State API [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs
Dian Fu (Jira)
-
Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[jira] [Closed] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-39061) StateMachine example uses State V2 API, breaking canonical savepoint compatibility
Gabor Somogyi (Jira)
-
[I] [Bug] Action-scoped metrics can be recorded under the wrong action for cached resources [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-39499) Replace MinIO in e2e tests with an Apache 2.0-licensed S3 alternative
Gabor Somogyi (Jira)
-
[jira] [Resolved] (FLINK-39499) Replace MinIO in e2e tests with an Apache 2.0-licensed S3 alternative
Gabor Somogyi (Jira)
-
[jira] [Closed] (FLINK-39499) Replace MinIO in e2e tests with an Apache 2.0-licensed S3 alternative
Gabor Somogyi (Jira)
-
[I] [Feature] Track token usage metrics for embedding models [flink-agents]
via GitHub
-
[jira] [Resolved] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader
Bowen Li (Jira)
-
[jira] [Commented] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader
Bowen Li (Jira)
-
[PR] [hotfix][release] Update japicmp configuration for 2.3.0 [flink]
via GitHub
-
[jira] [Updated] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39962] [runtime] Fix flaky DeclarativeSlotPoolBridgeTest [flink]
via GitHub
-
[jira] [Updated] (FLINK-39963) Runtime: ExecutionTimeBasedSlowTaskDetectorTest.testBalancedInput flaky
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39963][runtime/tests] Stabilize balanced input slow task detector test [flink]
via GitHub
-
[jira] [Updated] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39991] Replace Flink ReplaceIntersectWithSemiJoinRule with Cal… [flink]
via GitHub
-
[jira] [Commented] (FLINK-34406) Expose RuntimeContext in FunctionContext
Chen Zhang (Jira)
-
[jira] [Updated] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39969] [runtime] Apply configured SSL protocols and algorithms [flink]
via GitHub
-
[jira] [Updated] (FLINK-39132) 'kubernetes Materialized Table test' failed because it could not not stop job
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39132] [e2e] Stabilize Kubernetes materialized table test [flink]
via GitHub
-
[jira] [Closed] (FLINK-39992) Drop ReplaceIntersectWithSemiJoinRule
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-39992) Drop ReplaceIntersectWithSemiJoinRule
Jacky Lau (Jira)
-
[jira] [Created] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule
Jacky Lau (Jira)
-
[jira] [Updated] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39620] [table-runtime] Add restored cumulative window regression [flink]
via GitHub
-
[PR] [hotfix][docs] Remove stale Apple Silicon warning [flink-docker]
via GitHub
-
[jira] [Commented] (FLINK-39451) [release-2.3] Review and update documentation
Hao Li (Jira)
-
[jira] [Updated] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39687] [sql-gateway] Fix URI dependency conversion in SessionContext [flink]
via GitHub
-
[jira] [Assigned] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka
Bowen Li (Jira)
-
[jira] [Updated] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka
Bowen Li (Jira)
-
[jira] [Commented] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink
Bowen Li (Jira)
-
[jira] [Resolved] (FLINK-38918) support per cluster offset for DynamicKafkaSource in pyflink
Bowen Li (Jira)
-
[PR] [FLINK-39451][release] Mark 2.3 as stable in docs [flink]
via GitHub
-
[PR] [FLINK-39451][release] Finalize release notes for Flink 2.3 [flink]
via GitHub
-
[jira] [Updated] (FLINK-39451) [release-2.3] Review and update documentation
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39451][release] Mark the 2.2 docs as outdated [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39451) [release-2.3] Review and update documentation
David Anderson (Jira)
-
[PR] Remove warning from README.md [flink-docker]
via GitHub
-
[jira] [Updated] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders
Bowen Li (Jira)