lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] fix typo,'SPAKR' corrected to 'SPARK' (#3721)

Browse Source
This commit is contained in:
qianchutao
2021-09-26 21:52:35 +08:00
committed by GitHub
parent aa546554ff
commit 7e887b54d7
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
.github/workflows/bot.yml vendored
View File

@@ -31,5 +31,5 @@ jobs:
- name: Build Project - name: Build Project
env: env:
SCALA_PROFILE: ${{ matrix.scala }} SCALA_PROFILE: ${{ matrix.scala }}
SPAKR_PROFILE: ${{ matrix.spark }} SPARK_PROFILE: ${{ matrix.spark }}
run: mvn install -P "$SCALA_PROFILE,$SPAKR_PROFILE" -DskipTests=true -Dmaven.javadoc.skip=true -B -V run: mvn install -P "$SCALA_PROFILE,$SPARK_PROFILE" -DskipTests=true -Dmaven.javadoc.skip=true -B -V

2
hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java
View File

@@ -850,7 +850,7 @@ public class TestHiveSyncTool {
"Hive Schema should match the table schema + partition field"); "Hive Schema should match the table schema + partition field");
assertEquals(1, hiveClient.scanTablePartitions(HiveTestUtil.hiveSyncConfig.tableName).size(),"Table partitions should match the number of partitions we wrote"); assertEquals(1, hiveClient.scanTablePartitions(HiveTestUtil.hiveSyncConfig.tableName).size(),"Table partitions should match the number of partitions we wrote");
assertEquals(emptyCommitTime, assertEquals(emptyCommitTime,
hiveClient.getLastCommitTimeSynced(HiveTestUtil.hiveSyncConfig.tableName).get(),"The last commit that was sycned should be updated in the TBLPROPERTIES"); hiveClient.getLastCommitTimeSynced(HiveTestUtil.hiveSyncConfig.tableName).get(),"The last commit that was synced should be updated in the TBLPROPERTIES");
// make sure correct schema is picked // make sure correct schema is picked
Schema schema = SchemaTestUtil.getSimpleSchema(); Schema schema = SchemaTestUtil.getSimpleSchema();

2
hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieDeltaStreamer.java
View File

@@ -1295,7 +1295,7 @@ public class TestHoodieDeltaStreamer extends TestHoodieDeltaStreamerBase {
"Table partitions should match the number of partitions we wrote"); "Table partitions should match the number of partitions we wrote");
assertEquals(lastInstantForUpstreamTable, assertEquals(lastInstantForUpstreamTable,
hiveClient.getLastCommitTimeSynced(hiveSyncConfig.tableName).get(), hiveClient.getLastCommitTimeSynced(hiveSyncConfig.tableName).get(),
"The last commit that was sycned should be updated in the TBLPROPERTIES"); "The last commit that was synced should be updated in the TBLPROPERTIES");
} }
@Test @Test