issues  

Messages by Thread

• [jira] [Updated] (FLINK-40685) ForSt skips local cache cleanup for checkpoint-owned files ASF GitHub Bot (Jira)
• [PR] [FLINK-40685][state/forst] Reclaim cached files after checkpoint ownership handoff [flink] via GitHub
  • Re: [PR] [FLINK-40685][state/forst] Reclaim cached files after checkpoint ownership handoff [flink] via GitHub
  • Re: [PR] [FLINK-40685][state/forst] Reclaim cached files after checkpoint ownership handoff [flink] via GitHub
• [I] Add a @ModelRouterSetup annotation for declaring model routers inside an agent class [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40687) flink-model shade relocations do not match, okhttp and kotlin ship unrelocated ASF GitHub Bot (Jira)
• [PR] [FLINK-40687][build] Relocate the packages the model uber jars actually bundle [flink] via GitHub
  • Re: [PR] [FLINK-40687][build] Relocate the packages the model uber jars actually bundle [flink] via GitHub
  • Re: [PR] [FLINK-40687][build] Relocate the packages the model uber jars actually bundle [flink] via GitHub
• Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• [jira] [Assigned] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40694) INSERT INTO with a column list fails over a process table function with a set-semantic table argument ASF GitHub Bot (Jira)
• [PR] [FLINK-40694][table-planner] Fix INSERT INTO with a column list over set-semantic PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40694][table-planner] Fix INSERT INTO with a column list over set-semantic PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40694][table-planner] Fix INSERT INTO with a column list over set-semantic PTFs [flink] via GitHub
• [jira] [Reopened] (FLINK-35746) Add logic to override observed config based on settings observed through REST API Gyula Fora (Jira)
• [jira] [Commented] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• [jira] [Closed] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• [PR] Port commits for 1.16.1 [flink-kubernetes-operator] via GitHub
  • Re: [PR] Port commits for 1.16.1 [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Sumin Joo (Jira)
  • [jira] [Commented] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• [PR] [FLINK-39572][python] Do not log the Beam environment payload [flink] via GitHub
  • Re: [PR] [FLINK-39572][python] Do not log the Beam environment payload [flink] via GitHub
  • Re: [PR] [FLINK-39572][python] Do not log the Beam environment payload [flink] via GitHub
• [jira] [Assigned] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40669) Java 11 E2E group 2 on release-2.3 is killed at the 234 minute budget while the other profiles finish in half the time Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file Martijn Visser (Jira)
• [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
  • Re: [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
• [PR] [FLINK-40692][model] Make model-version optional in Triton inference URL [flink] via GitHub
  • Re: [PR] [FLINK-40692][model] Make model-version optional in Triton inference URL [flink] via GitHub
  • Re: [PR] [FLINK-40692][model] Make model-version optional in Triton inference URL [flink] via GitHub
• Re: [PR] [FLINK-38727][test] Fix flaky test EventTimeWindowCheckpointingITCase#testPreAggregatedSlidingTimeWindow by increasing ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY [flink] via GitHub
• [jira] [Assigned] (FLINK-40662) 'Run kubernetes Materialized Table test' fails because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• [PR] [FLINK-40662][tests] Fail fast when the S3 test container does not start [flink] via GitHub
  • Re: [PR] [FLINK-40662][tests] Fail fast when the S3 test container does not start [flink] via GitHub
  • Re: [PR] [FLINK-40662][tests] Fail fast when the S3 test container does not start [flink] via GitHub
• [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
  • Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
  • Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
  • Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
  • Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
  • Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
  • Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• [jira] [Updated] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
  • [jira] [Updated] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
  • [jira] [Updated] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
• [jira] [Updated] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config Danish (Jira)
  • [jira] [Updated] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config Danish (Jira)
• [jira] [Resolved] (FLINK-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• Re: [D] Planning Flink Agents 0.3 [flink-agents] via GitHub
• Re: [D] Mem0 Backend for Long-Term Memory [flink-agents] via GitHub
• Re: [D] Label-Based Version Control Strategy [flink-agents] via GitHub
• Re: [D] Comprehensive Memory Management for Flink-Agents [flink-agents] via GitHub
• Re: [D] [Discussion][Observability 2/2] Built-in Operational Metrics for Flink Agents [flink-agents] via GitHub
• [jira] [Closed] (FLINK-20969) Update Scala 2.12 version to 2.12.15 Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40689) Kafka sink checkpoint recovery fails after producer epoch rollover with transaction V2 Roman Khachatryan (Jira)
• [jira] [Comment Edited] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields ASF GitHub Bot (Jira)
• [PR] [FLINK-40690][pipeline-connector/fluss] Preserve nested row field positions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40690][pipeline-connector/fluss] Preserve nested row field positions [flink-cdc] via GitHub
• [jira] [Created] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields Xiaobing Fang (Jira)
• [jira] [Resolved] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38 Martijn Visser (Jira)
• [jira] [Closed] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14 Dian Fu (Jira)
• [jira] [Assigned] (FLINK-39031) Support Python 3.13 Dian Fu (Jira)
• [jira] [Updated] (FLINK-39031) Support Python 3.13 Dian Fu (Jira)
  • [jira] [Updated] (FLINK-39031) Support Python 3.13 Dian Fu (Jira)
• Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
  • Re: [PR] [FLINK-36736][table] Fix target columns for row-level updates [flink] via GitHub
• [PR] [hotfix][test][sqlserver] Shift test timestamps to avoid Debezium time-type conversion bug [flink-cdc] via GitHub
  • Re: [PR] [hotfix][test][sqlserver] Shift test timestamps to avoid Debezium time-type conversion bug [flink-cdc] via GitHub
• [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
  • Re: [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
  • Re: [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
  • Re: [I] [Bug][plan] sub-agent cannot be rebuilt on a remote task after plan serialization [flink-agents] via GitHub
• [PR] [api][plan][runtime][python] Rebuild registered sub-agent setups from descriptors [flink-agents] via GitHub
• Re: [PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink] via GitHub
  • Re: [PR] [FLINK-36735][table] Include updated columns when sink declares partial required columns for row-level update [flink] via GitHub
• [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix grammar in DROP FUNCTION documentation [flink] via GitHub
  • Re: [PR] [hotfix] Fix "doesn't exists" grammar typos [flink] via GitHub
• [jira] [Commented] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Hesanda Liyanage (Jira)
  • [jira] [Commented] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Dian Fu (Jira)
• [PR] [hotfix] Fix pipeline e2e CI compilation failure [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix pipeline e2e CI compilation failure [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix pipeline e2e CI compilation failure [flink-cdc] via GitHub
• [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
  • Re: [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
  • Re: [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
  • Re: [PR] [FLINK-6417][connector/filesystem] Support glob paths in FileSource [flink] via GitHub
  • Re: [PR] [FLINK-6417][connector/filesystem] Add opt-in glob enumeration for FileSource [flink] via GitHub
  • Re: [PR] [FLINK-6417][connector/filesystem] Add opt-in glob enumeration for FileSource [flink] via GitHub
• [I] [Tech Debt][API][Chat] Represent terminal chat failures in ChatResponseEvent [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-39775) Snapshot split metadata is not released after switching to stream phase, causing large JobManager coordinator state and OOM with many snapshot splits Leonard Xu (Jira)
• [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [draft][api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Ask each connection whether it could apply a schema natively [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created ASF GitHub Bot (Jira)
• [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
  • Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
  • Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• [jira] [Created] (FLINK-40689) Kafka sink checkpoint recovery fails after producer epoch rollover with transaction V2 Aleksandr Savonin (Jira)
• [PR] [WIP][DRAFT] Demonstrate checkpoint recovery failure after producer epoch bump [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-38614][runtime] Defer EndOfData until final checkpoint committables are emitted [flink] via GitHub
• [jira] [Commented] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Purushottam Sinha (Jira)
• [PR] [BP-2.3][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• [PR] Fix/flink model triton tensor names [flink] via GitHub
  • Re: [PR] [FLINK-40684][model] Fix tensor name case in Triton models. [flink] via GitHub
  • Re: [PR] [FLINK-40684][model] Fix tensor name case in Triton models. [flink] via GitHub
  • Re: [PR] [FLINK-40684][model] Fix tensor name case in Triton models. [flink] via GitHub
  • Re: [PR] [FLINK-40684][model] Fix tensor name case in Triton models. [flink] via GitHub
• [jira] [Resolved] (FLINK-40145) flink-model-triton javadoc fails on JDK 11: kotlin.stdlib split-package Martijn Visser (Jira)
• [jira] [Created] (FLINK-40686) Shaded jars declare a bundled dependency's JPMS module name Martijn Visser (Jira)
• [jira] [Created] (FLINK-40688) flink-model-openai NOTICE lists httpcomponents artifacts it no longer bundles Martijn Visser (Jira)
• [jira] [Created] (FLINK-40687) flink-model shade relocations do not match, okhttp and kotlin ship unrelocated Martijn Visser (Jira)
• [jira] [Created] (FLINK-40685) ForSt skips local cache cleanup for checkpoint-owned files Aaron He (Jira)
• [PR] [FLINK-40584][state/rocksdb] Bound MapState and timer prefix iterators [flink] via GitHub
  • Re: [PR] [FLINK-40584][state/rocksdb] Bound MapState and timer prefix iterators [flink] via GitHub
  • Re: [PR] [FLINK-40584][state/rocksdb] Bound MapState and timer prefix iterators [flink] via GitHub
  • Re: [PR] [FLINK-40584][state/rocksdb] Bound MapState and timer prefix iterators [flink] via GitHub
• [jira] [Created] (FLINK-40680) Bump openai-java dependency Sergey Nuyanzin (Jira)
• Re: [PR] [hotfix] Remove redundant autoscaler Plugin discovery [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40684) Tensor names are unconditionally uppercased Danish (Jira)
• [jira] [Closed] (FLINK-32016) Logs are printed as disabled even if the autoscaler option is true Gyula Fora (Jira)
• [jira] [Comment Edited] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• [PR] [api][java][python] Name the model the capability predicate judges [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Name the model the capability predicate judges [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-40666) Simplify SNAPSHOT function by removing 'load_completed_condition' parameter Fabian Hueske (Jira)
• [jira] [Assigned] (FLINK-40145) flink-model-triton javadoc fails on JDK 11: kotlin.stdlib split-package Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40669) Java 11 E2E group 2 on release-2.3 is killed at the 234 minute budget while the other profiles finish in half the time Martijn Visser (Jira)
• [PR] [BP-1.20][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• [jira] [Resolved] (FLINK-40288) Multiple JoinSemanticTests fail Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40684) [Model] Tensor names are unconditionally uppercased Danish (Jira)
  • [jira] [Updated] (FLINK-40684) [Model] Tensor names are unconditionally uppercased ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40684) [Model] Tensor names are unconditionally uppercased Danish (Jira)
• [jira] [Commented] (FLINK-40677) Native application submission without jarURI fails in bundled Flink client David Peacock (Jira)
• [jira] [Comment Edited] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
  • [jira] [Comment Edited] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
• [jira] [Updated] (FLINK-40180) Non-keyed state support in StateCatalog ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• Re: [PR] [FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE [flink] via GitHub
  • Re: [PR] [FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE [flink] via GitHub
  • Re: [PR] [FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE [flink] via GitHub
  • Re: [PR] [FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE [flink] via GitHub
  • Re: [PR] [FLINK-40576][fs] Drop stale dependencies from flink-s3-fs-presto NOTICE [flink] via GitHub
• [PR] [FLINK-40180] Non-keyed/operator state support in State Catalog [flink] via GitHub
  • Re: [PR] [FLINK-40180] Non-keyed/operator state support in State Catalog [flink] via GitHub
• [jira] [Closed] (FLINK-39766) Remove AggregatedMetric copy that made redundant by Flink 1.20 dependency upgrade Gyula Fora (Jira)
• [jira] [Reopened] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
  • [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances yongfu.gao (Jira)
• [jira] [Updated] (FLINK-40472) Add Arrow-native vectorized UDF support to DataFrame API ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40472) Add Arrow-native vectorized UDF support to DataFrame API Dian Fu (Jira)
• [jira] [Updated] (FLINK-40329) Support Single EKU certificates for server and client TLS authentication Gyula Komlossi (Jira)
• [jira] [Closed] (FLINK-37798) Persist DelayedScaleDown info in state store Gyula Fora (Jira)
• [jira] [Closed] (FLINK-31858) Add Autoscaler support for Session Job Gyula Fora (Jira)
• [jira] [Closed] (FLINK-38466) Bump derby version to 10.17.1.0 Gyula Fora (Jira)
• [jira] [Closed] (FLINK-31977) If scaling.effectiveness.detection.enabled is false, the call to the detectIneffectiveScaleUp() function is unnecessary Gyula Fora (Jira)
• [jira] [Assigned] (FLINK-40455) Decoupling Autotuning from the Autoscaling logic Gyula Fora (Jira)
• [jira] [Closed] (FLINK-38095) Error in Session Job autoscaler when realizing parallelism overrides Gyula Fora (Jira)
• [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Created] (FLINK-40683) JoinSemanticTests[anti-join-on-nested] asserts the raw changelog on release-2.3 and release-2.2 Martijn Visser (Jira)
• [PR] [BP-2.2][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink] via GitHub
• [PR] [api][runtime][java][python] Add composable durable futures [flink-agents] via GitHub
  • Re: [PR] [api][runtime][java][python] Add composable durable futures [flink-agents] via GitHub

• Earlier messages
• Later messages