Messages by Thread
-
-
[jira] [Resolved] (FLINK-40150) Remove assumeTrue with cluster rebuild from RescaleTimelineITCase
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40150) Remove assumeTrue with cluster rebuild from RescaleTimelineITCase
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-36808) UNION ALL after lookup join produces unexpected results
Martijn Visser (Jira)
-
Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink]
via GitHub
-
[jira] [Created] (FLINK-40678) Lookup join digest ignores table OPTIONS hints
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-36808) UNION ALL after lookup join produces unexpected results
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-36808) UNION ALL after lookup join produces unexpected results
Martijn Visser (Jira)
-
[PR] [FLINK-36808][table-planner] Include pushed-down source abilities in the lookup join digest [flink]
via GitHub
-
[jira] [Created] (FLINK-40677) Native application submission without jarURI fails in bundled Flink client
David Peacock (Jira)
-
[jira] [Reopened] (FLINK-38262) Convert connection sqlnode to operations
Hao Li (Jira)
-
[jira] [Commented] (FLINK-38262) Convert connection sqlnode to operations
Hao Li (Jira)
-
[PR] [FLINK-40675][sql-gateway] Fix unstable SqlGatewayServiceITCase#testReleaseLockWhenFailedToSubmitOperation [flink]
via GitHub
-
[jira] [Updated] (FLINK-40666) Simplify SNAPSHOT function by removing 'load_completed_condition' parameter
ASF GitHub Bot (Jira)
-
[jira] [Assigned] (FLINK-40083) Launch the SeaweedFS S3 test backend via weed mini and bump the image to 4.38
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40083][tests] Launch the SeaweedFS S3 test backend via 'weed mini' and bump to 4.38 [flink]
via GitHub
-
[jira] [Commented] (FLINK-40355) Add MAP_CONTAINS_KEY function
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40355) Add MAP_CONTAINS_KEY function
Sergey Nuyanzin (Jira)
-
[PR] [FLINK-40528][table-planner] Address additional feedback for partial-delete StreamExecCalc [flink]
via GitHub
-
[PR] [BP-1.20][FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state [flink]
via GitHub
-
[PR] [BP-2.3][FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state [flink]
via GitHub
-
[PR] [BP-2.2][FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40070) DynamicParameterITCase hangs when the JobManager startup banner rolls to a numbered log file
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40070][tests] Fix flaky DynamicParameterITCase reading rolled JobManager logs [flink]
via GitHub
-
[jira] [Created] (FLINK-40672) Incorrect nullability for CAST from VARIANT
dylanhz (Jira)
-
[jira] [Comment Edited] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception
Martijn Visser (Jira)
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
Re: [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator]
via GitHub
-
[PR] [FLINK-40435][python] Add explode support to DataFrame API [flink]
via GitHub
-
Re: [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.17.2 to 2.25.4 [flink-connector-pulsar]
via GitHub
-
Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.4 [flink-connector-pulsar]
via GitHub
-
[jira] [Closed] (FLINK-40676) Support Flink 2.0.x and Pulsar Client 4.0.9
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-39697) Bump Flink version to 2.2.1
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-40676) Support Flink 2.0.x and Pulsar Client 4.0.9
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-40676] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
-
[jira] [Created] (FLINK-40676) Support Flink 2.0.x and Pulsar Client 4.0.9
Ferenc Csaky (Jira)
-
Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws]
via GitHub
-
Re: [PR] [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable
sepuri sai krishna (Jira)
-
[jira] [Updated] (FLINK-40635) Test CalcRestoreTest>RestoreTestBase.testRestore failing
Samrat Deb (Jira)
-
[jira] [Updated] (FLINK-40435) Add explode support to DataFrame API
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40666][table] Simplify SNAPSHOT function by removing load_completed_condition argument [flink]
via GitHub
-
[jira] [Updated] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable
sepuri sai krishna (Jira)
-
[PR] [FLINK-40674][runtime] Stop deserializing SerializedThrowable via ObjectInputStream on parse [flink]
via GitHub
-
[jira] [Created] (FLINK-40674) Stop deserializing SerializedThrowable via ObjectInputStream on parse
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-40674) Stop deserializing SerializedThrowable via ObjectInputStream on parse
Gabor Somogyi (Jira)
-
[jira] [Assigned] (FLINK-40674) Stop deserializing SerializedThrowable via ObjectInputStream on parse
Gabor Somogyi (Jira)
-
[jira] [Created] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs
Bettle (Jira)
-
[jira] [Closed] (FLINK-40556) Support UUID value literals in the Table API
Timo Walther (Jira)
-
[jira] [Comment Edited] (FLINK-40556) Support UUID value literals in the Table API
Timo Walther (Jira)
-
[jira] [Reopened] (FLINK-40556) Support UUID value literals in the Table API
Timo Walther (Jira)
-
Re: [PR] [FLINK-40535] Standalone session clusters are redeployed instead of scaled in-place [flink-kubernetes-operator]
via GitHub
-
[jira] [Closed] (FLINK-40535) Standalone session clusters are redeployed instead of scaled in-place
Gyula Fora (Jira)
-
[jira] [Resolved] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40672) Incorrect nullability for CAST from VARIANT
dylanhz (Jira)
-
[jira] [Assigned] (FLINK-39997) Upgrade pemja to 0.6.2
Dian Fu (Jira)
-
[PR] [FLINK-40650][cdc-connector][sqlserver] Improve SqlServerDialect.discoverDataCollectionSchemas to reduce snapshot start time with many tables [flink-cdc]
via GitHub
-
[jira] (FLINK-40420) Add set operations to DataFrame API
Bettle (Jira)
-
[I] [Tech Debt][API][Durable Execution] Make asynchronous durable calls composable [flink-agents]
via GitHub
-
Re: [PR] [FLINK-40209][checkpoint] Introduce Regional Checkpoint core mechanism and notification dispatch [flink]
via GitHub
-
Re: [PR] [FLINK-40150][tests] De-parameterize rescale-history-enabled RescaleTimelineITCase tests [flink]
via GitHub
-
[PR] [e2e][java][hotfix] Deep-copy Mem0 action event payload [flink-agents]
via GitHub
-
[PR] [hotfix] Correct author of the Kubernetes Operator 1.16.0 release announcement [flink-web]
via GitHub
-
[PR] [FLINK-40667][network] Fix buffer ref-count leak in recovery channel-state filtering [flink]
via GitHub
-
[PR] [FLINK-40671][network] Document why UnknownInputChannel graduation hardcodes needsRecovery=false [flink]
via GitHub
-
[jira] [Updated] (FLINK-40671) Document why UnknownInputChannel graduation hardcodes needsRecovery=false
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-39997) Upgrade pemja to 0.6.2
Dian Fu (Jira)
-
[jira] [Closed] (FLINK-40420) Add set operations to DataFrame API
Dian Fu (Jira)
-
[jira] [Created] (FLINK-40671) Document why UnknownInputChannel graduation hardcodes needsRecovery=false
Rui Fan (Jira)
-
[jira] [Closed] (FLINK-39997) Upgrade pemja to 0.6.2
Dian Fu (Jira)
-
Re: [I] [Bug] [integrations][anthropic] temperature defaults to 0.1 and is always sent, returning HTTP 400 on Claude 4.7 and later [flink-agents]
via GitHub
-
[PR] [FLINK-40668][network] Document why the recovery drain cannot stall on zero-credit needsRecovery channels [flink]
via GitHub
-
[jira] [Updated] (FLINK-40668) Document why the recovery drain cannot stall on zero-credit needsRecovery channels
ASF GitHub Bot (Jira)
-
[jira] [Resolved] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH
Martijn Visser (Jira)
-
[PR] [FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types [flink]
via GitHub
-
[jira] [Updated] (FLINK-39105) RestClientTest.testConnectionTimeout fails with different expected exception
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-38501) Tests crashed for Flink Runtime in test_cron_azure core
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails because the SQL Gateway returns a null session handle
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-37727) java.lang.UnsatisfiedLinkError error on pemja.core.PythonInterpreter$MainInterpreter.initialize()
Dian Fu (Jira)
-
[jira] [Updated] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on because the SQL Gateway returns a null session handle
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on because the SQL Gateway returns a null session handle
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3
Martijn Visser (Jira)
-
[jira] [Created] (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-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-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment
Rui Fan (Jira)
-
[jira] [Created] (FLINK-40668) Document why the recovery drain cannot stall on zero-credit needsRecovery channels
Rui Fan (Jira)
-
Re: [PR] [FLINK-40248][ci] Add nightly snapshot publishing to GHA pipeline [flink]
via GitHub
-
[jira] [Created] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment
Rui Fan (Jira)
-
[jira] [Resolved] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain
Rui Fan (Jira)
-
[PR] [hotfix][cdc-composer] Fix "URI is not hierarchical" when resolving factory JAR path [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-40666) Simplify SNAPSHOT function by removing 'load_completed_condition' parameter
Fabian Hueske (Jira)
-
[jira] [Assigned] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40139][Connectors/Kafka] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka]
via GitHub
-
[PR] [FLINK-40665][ci] Use the Maven wrapper when deploying snapshot jars [flink]
via GitHub
-
[PR] Rebuild website [flink-web]
via GitHub
-
[jira] [Closed] (FLINK-40528) Codegen should be tolerate to partial deletes
Timo Walther (Jira)
-
[jira] [Assigned] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40489) Add UUID_V4() & UUID_V7() functions
Timo Walther (Jira)
-
[PR] [FLINK-40661][e2e] Build the test KDC image from debian:bookworm [flink]
via GitHub