Kemp Po
03/08/2022, 4:15 PMs3a://
instead of gs://
?
All default settings except compression codec = SNAPPYAugustin Lafanechere (Airbyte)
03/08/2022, 4:24 PMKemp Po
03/08/2022, 4:30 PM2022-03-08 15:52:45 destination > 2022-03-08 15:52:45 WARN o.a.h.f.FileSystem(createFileSystem):3418 - Failed to initialize fileystem <s3a://bucket/data/2022_03_08_1646754764563_0.parquet>: java.lang.IllegalArgumentException: bucket
2022-03-08 15:52:45 destination > 2022-03-08 15:52:45 ERROR i.a.i.b.FailureTrackingAirbyteMessageConsumer(start):39 - Exception while starting consumer
2022-03-08 15:52:45 destination > java.lang.IllegalArgumentException: bucket
2022-03-08 15:52:45 destination > at com.google.common.base.Preconditions.checkArgument(Preconditions.java:145) ~[guava-31.0.1-jre.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.s3a.S3AUtils.propagateBucketOptions(S3AUtils.java:1150) ~[hadoop-aws-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.s3a.S3AFileSystem.initialize(S3AFileSystem.java:324) ~[hadoop-aws-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:3414) ~[hadoop-common-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:158) ~[hadoop-common-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:3474) ~[hadoop-common-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:3442) ~[hadoop-common-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:524) ~[hadoop-common-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.hadoop.fs.Path.getFileSystem(Path.java:365) ~[hadoop-common-3.3.0.jar:?]
2022-03-08 15:52:45 destination > at org.apache.parquet.hadoop.util.HadoopOutputFile.fromPath(HadoopOutputFile.java:58) ~[parquet-hadoop-1.12.0.jar:1.12.0]
2022-03-08 15:52:45 destination > at io.airbyte.integrations.destination.gcs.parquet.GcsParquetWriter.<init>(GcsParquetWriter.java:67) ~[io.airbyte.airbyte-integrations.connectors-destination-gcs-0.35.36-alpha.jar:?]
2022-03-08 15:52:45 destination > at io.airbyte.integrations.destination.gcs.writer.ProductionWriterFactory.create(ProductionWriterFactory.java:47) ~[io.airbyte.airbyte-integrations.connectors-destination-gcs-0.35.36-alpha.jar:?]
2022-03-08 15:52:45 destination > at io.airbyte.integrations.destination.gcs.GcsConsumer.startTracked(GcsConsumer.java:61) ~[io.airbyte.airbyte-integrations.connectors-destination-gcs-0.35.36-alpha.jar:?]
Marcos Marx (Airbyte)
03/08/2022, 10:40 PMMarcos Marx (Airbyte)
03/08/2022, 10:41 PMKemp Po
03/10/2022, 4:13 PMKemp Po
03/10/2022, 4:13 PMHarshith (Airbyte)
03/14/2022, 8:55 AMKemp Po
03/15/2022, 10:32 AM