[Connector][File-S3] add binary file format

nexr · Jun 14, 2024 · 3d08a73 · 3d08a73
1 parent 7702f09
commit 3d08a73
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java b/.../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(