From dbcf10b2074db622beeddf48f169ad53794c0865 Mon Sep 17 00:00:00 2001 From: ClownXC Date: Mon, 9 Dec 2024 01:14:14 +0800 Subject: [PATCH 1/2] disabled hdfs in ci --- .../java/org/apache/seatunnel/e2e/connector/hive/HiveIT.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hive-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hive/HiveIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hive-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hive/HiveIT.java index bfa83dfb3b9..9cc75d1fbf0 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hive-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hive/HiveIT.java +++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-hive-e2e/src/test/java/org/apache/seatunnel/e2e/connector/hive/HiveIT.java @@ -228,6 +228,8 @@ private void executeJob(TestContainer container, String job1, String job2) } @TestTemplate + @Disabled( + "[HDFS/COS/OSS/S3] is not available in CI, if you want to run this test, please set up your own environment in the test case file, hadoop_hive_conf_path_local and ip below}") public void testFakeSinkHiveOnHDFS(TestContainer container) throws Exception { executeJob(container, "/fake_to_hive_on_hdfs.conf", "/hive_on_hdfs_to_assert.conf"); } From 0b9eae39bd8e398ca67e9d7bd8a746a351520f56 Mon Sep 17 00:00:00 2001 From: ClownXC Date: Mon, 9 Dec 2024 08:55:25 +0800 Subject: [PATCH 2/2] fix typo --- .../seatunnel/mongodb/source/MongodbSource.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java index 1a3c0f8f03c..aa1e0d24dee 100644 --- a/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java +++ b/seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/MongodbSource.java @@ -78,7 +78,7 @@ public List getProducedCatalogTables() { public SourceReader createReader(SourceReader.Context readerContext) { return new MongodbReader( readerContext, - crateClientProvider(options), + createClientProvider(options), createDeserializer(options, catalogTable.getSeaTunnelRowType()), createMongodbReadOptions(options)); } @@ -86,7 +86,7 @@ public SourceReader createReader(SourceReader.Context @Override public SourceSplitEnumerator> createEnumerator( SourceSplitEnumerator.Context enumeratorContext) { - MongodbClientProvider clientProvider = crateClientProvider(options); + MongodbClientProvider clientProvider = createClientProvider(options); return new MongodbSplitEnumerator( enumeratorContext, clientProvider, createSplitStrategy(options, clientProvider)); } @@ -95,7 +95,7 @@ public SourceSplitEnumerator> createEnumerator public SourceSplitEnumerator> restoreEnumerator( SourceSplitEnumerator.Context enumeratorContext, ArrayList checkpointState) { - MongodbClientProvider clientProvider = crateClientProvider(options); + MongodbClientProvider clientProvider = createClientProvider(options); return new MongodbSplitEnumerator( enumeratorContext, clientProvider, @@ -103,7 +103,7 @@ public SourceSplitEnumerator> restoreEnumerato checkpointState); } - private MongodbClientProvider crateClientProvider(ReadonlyConfig config) { + private MongodbClientProvider createClientProvider(ReadonlyConfig config) { return MongodbCollectionProvider.builder() .connectionString(config.get(MongodbConfig.URI)) .database(config.get(MongodbConfig.DATABASE))