From 3d08a73d38e8178e056742570dee6a07408c833d Mon Sep 17 00:00:00 2001 From: "halo.kim" Date: Fri, 14 Jun 2024 14:20:01 +0900 Subject: [PATCH] [Connector][File-S3] add binary file format --- .../connectors/seatunnel/file/s3/source/S3FileSource.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java b/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java index f36e935818c..bdca4258aeb 100644 --- a/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java +++ b/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java @@ -99,9 +99,10 @@ public void prepare(Config pluginConfig) throws PrepareFailException { break; case ORC: case PARQUET: + case BINARY: throw new FileConnectorException( CommonErrorCodeDeprecated.UNSUPPORTED_OPERATION, - "SeaTunnel does not support user-defined schema for [parquet, orc] files"); + "SeaTunnel does not support user-defined schema for [parquet, orc, binary] files"); default: // never got in there throw new FileConnectorException(