Make bigtable storage location consistent (#138)

khorshuheng · web-flow · commit 6f433047c690 · 2022-04-22T17:12:16.000+08:00
Signed-off-by: Khor Shu Heng &lt;khor.heng@gojek.com&gt;

Co-authored-by: Khor Shu Heng &lt;khor.heng@gojek.com&gt;
diff --git a/spark/ingestion/src/main/scala/feast/ingestion/stores/bigtable/BigTableSinkRelation.scala b/spark/ingestion/src/main/scala/feast/ingestion/stores/bigtable/BigTableSinkRelation.scala
@@ -154,7 +154,7 @@ class BigTableSinkRelation(
   }
 
   private def tableName: String = {
-    val entities = config.entityColumns.mkString("__")
+    val entities = config.entityColumns.sorted.mkString("__")
     StringUtils.trimAndHash(s"${config.projectName}__${entities}", maxTableNameLength)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -154,7 +154,7 @@ class BigTableSinkRelation(`
`154`	`154`	`}`
`155`	`155`
`156`	`156`	`private def tableName: String = {`
`157`		`- val entities = config.entityColumns.mkString("__")`
	`157`	`+ val entities = config.entityColumns.sorted.mkString("__")`
`158`	`158`	`StringUtils.trimAndHash(s"${config.projectName}__${entities}", maxTableNameLength)`
`159`	`159`	`}`
`160`	`160`