Skip to content

Commit ae1dc26

Browse files
committed
client spooling: raise error for trino 451
1 parent 35e7f2c commit ae1dc26

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

rust/operator-binary/src/controller.rs

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -383,6 +383,11 @@ pub enum Error {
383383

384384
#[snafu(display("failed to resolve client protocol configuration"))]
385385
ClientProtocolConfiguration { source: client_protocol::Error },
386+
387+
#[snafu(display(
388+
"client spooling protocol is not supported for Trino version {product_version}"
389+
))]
390+
ClientSpoolingProtocolTrinoVersion { product_version: String },
386391
}
387392

388393
type Result<T, E = Error> = std::result::Result<T, E>;
@@ -480,6 +485,13 @@ pub async fn reconcile_trino(
480485
),
481486
None => None,
482487
};
488+
if resolved_client_protocol_config.is_some()
489+
&& resolved_product_image.product_version.starts_with("45")
490+
{
491+
return Err(Error::ClientSpoolingProtocolTrinoVersion {
492+
product_version: resolved_product_image.product_version,
493+
});
494+
}
483495

484496
let validated_config = validated_product_config(
485497
trino,

0 commit comments

Comments
 (0)