Messages by Thread
-
-
[PR] [FLINK-40405] Add reason tags to the autoscaler.balanced counter [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40407] Add reason tags to the autoscaler.scalings counter [flink-kubernetes-operator]
via GitHub
-
[jira] [Commented] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created
Alexandru (Jira)
-
[PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink]
via GitHub
-
[jira] [Updated] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink]
via GitHub
-
[jira] [Commented] (FLINK-35341) Retraction stop working with Clock dependent function in Filter
Martijn Visser (Jira)
-
[PR] [FLINK-28737][table-planner] Check Calc filter on updating input in the NDU analyzer [flink]
via GitHub
-
[jira] [Updated] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40897][table] TIMESTAMPDIFF returns wrong results and fails for TIME operands [flink]
via GitHub
-
[jira] [Created] (FLINK-40893) Update the determinism page for the current state of the NDU handling
Martijn Visser (Jira)
-
[PR] [FLINK-40896][table]Deduplicate keep first implementation [flink]
via GitHub
-
[jira] [Created] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands
sepuri sai krishna (Jira)
-
[jira] [Commented] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands
sepuri sai krishna (Jira)
-
[PR] [FLINK-40708][table] Add semantic test for ValueView state in onTimer [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL
Moritz Manner (Jira)
-
[PR] [FLINK-40895][table] Use cache in code splitter [flink]
via GitHub
-
[jira] [Created] (FLINK-40896) Add built-in DEDUPLICATE_KEEP_FIRST PTF
Gustavo de Morais (Jira)
-
[jira] [Updated] (FLINK-40896) FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-40895) Make use cache in code splitter
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-40895) Make use cache in code splitter
ASF GitHub Bot (Jira)
-
[jira] [Resolved] (FLINK-40602) JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview
Robert Metzger (Jira)
-
[PR] [FLINK-40888][table] Improve MATCH_RECOGNIZE performance: lazily eval… [flink]
via GitHub
-
[jira] [Commented] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL
Moritz Manner (Jira)
-
[jira] [Created] (FLINK-40891) NDU plan visitor does not propagate determinism requirements through PTFs without REQUIRE_UPDATE_BEFORE
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws]
via GitHub
-
[jira] [Commented] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic
Martijn Visser (Jira)
-
[jira] [Comment Edited] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-29225) Delete message incorrectly ignored in SinkUpsertMaterializer
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40892) Stale IGNORE override on the changelog PTF tests
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40889) NDU plan visitor has no branch for VECTOR_SEARCH, TRY_RESOLVE and EXPLAIN PLAN_ADVICE fail
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40156) FLIP-600: Independent Checkpoint Based On Pipeline Region
Mika Naylor (Jira)
-
[jira] [Updated] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events
DongShengHe (Jira)
-
[jira] [Created] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events
DongShengHe (Jira)
-
[PR] Bump ip-address from 10.7.0 to 10.7.3 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition
Gabor Somogyi (Jira)
-
[jira] [Closed] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-40855) Shut down AWS SDK v1 STS clients after S3 delegation-token acquisition
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-33082) Azure Pipelines 4 is not responding on AZP
Martijn Visser (Jira)
-
[PR] Bump @angular/router from 21.2.22 to 21.2.24 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[PR] Bump brace-expansion from 1.1.18 to 1.1.21 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[PR] Bump piscina and @angular/build in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x
Robert Metzger (Jira)
-
Re: [PR] [FLINK-40059][examples] Bump flink-connector-kafka to 5.0.0-2.2 [flink]
via GitHub
-
[jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions
Juanvi Soler (Jira)
-
[jira] [Updated] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-33082) Azure Pipelines 4 is not responding on AZP
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty"
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40854) Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON
Timo Walther (Jira)
-
[jira] [Updated] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40884][rpc] Escape SSL values in the generated Pekko config [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40876) Code splitter should generate same code after repeated runs
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API
Fabian Hueske (Jira)
-
[jira] [Commented] (FLINK-40876) Code splitter should generate same code after repeated runs
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches
Dian Fu (Jira)
-
[jira] [Assigned] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters
Robert Metzger (Jira)
-
[jira] [Created] (FLINK-40884) Flink configuration breaks when Keystore or Truststore passwords contain specific characters
Robert Metzger (Jira)
-
Re: [PR] [FLINK-40731][table-common] CONVERT_TZ silently returns a wrong timestamp for a time zone it does not recognize [flink]
via GitHub
-
[jira] [Created] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction
Bonnie Varghese (Jira)
-
Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40815) Remove the deprecated configuration keys from the flink-dstl-dfs module.
Yuepeng Pan (Jira)
-
Re: [PR] [FLINK-39478][mysql] Persist checkpointIdToFinish and expose enumerat or metrics [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-33404][python] Add default on_timer to CoProcessFunction [flink]
via GitHub
-
Re: [PR] [FLINK-39492][starrocks] Fix microsecond precision loss for TIMESTAMP types in StarRocks sink [flink-cdc]
via GitHub
-
[jira] [Assigned] (FLINK-25029) Hadoop Caller Context Setting In Flink
Peter Huang (Jira)
-
[jira] [Updated] (FLINK-40882) Janino should compile same class only once
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40882][table] Janino should compile same class only once [flink]
via GitHub
-
[jira] [Created] (FLINK-40882) Janino should compile same class only once
Sergey Nuyanzin (Jira)
-
[PR] [BP-2.2][FLINK-40670][tests] Use different keys for different data [flink]
via GitHub
-
[jira] [Created] (FLINK-40879) Add dynamic ratelimit Flink options
Peter Huang (Jira)