Update Flink env variables

airyhq · Mar 28, 2024 · c061297 · c061297
1 parent 3b3697e
commit c061297
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/backend/components/flink-connector/src/result-sender.go b/backend/components/flink-connector/src/result-sender.go
@@ -21,7 +21,7 @@ func main() {
 	systemToken := os.Getenv("systemToken")
 	authUsername := os.Getenv("AUTH_JAAS_USERNAME")
 	authPassword := os.Getenv("AUTH_JAAS_PASSWORD")
-	flinkProvider := os.Getenv("flnkProvider")
+	flinkProvider := os.Getenv("provider")
 	groupID := "result-sender"
 	msgNormal := false
 	msgDebug := true
@@ -32,11 +32,11 @@ func main() {
 	}
 
 	var confluentConnection ConfluentConnection
-	confluentConnection.Token = os.Getenv("CONFLUENT_TOKEN")
-	confluentConnection.ComputePoolID = os.Getenv("CONFLUENT_COMPUTE_POOL_ID")
-	confluentConnection.Principal = os.Getenv("CONFLUENT_PRINCIPAL")
-	confluentConnection.SQLCurrentCatalog = os.Getenv("CONFLUENT_SQL_CURRENT_CATALOG")
-	confluentConnection.SQLCurrentDatabase = os.Getenv("CONFLUENT_SQL_CURRENT_DATABASE")
+	confluentConnection.Token = os.Getenv("confluentToken")
+	confluentConnection.ComputePoolID = os.Getenv("confluentComputePoolID")
+	confluentConnection.Principal = os.Getenv("confluentPrincipal")
+	confluentConnection.SQLCurrentCatalog = os.Getenv("confluentSQLCurrentCatalog")
+	confluentConnection.SQLCurrentDatabase = os.Getenv("confluentSQLCurrentDatabase")
 
 	// Healthcheck
 	http.HandleFunc("/actuator/health", func(w http.ResponseWriter, r *http.Request) {

diff --git a/backend/components/flink-connector/src/statements-executor.go b/backend/components/flink-connector/src/statements-executor.go
@@ -19,7 +19,7 @@ func main() {
 	systemToken := os.Getenv("systemToken")
 	authUsername := os.Getenv("AUTH_JAAS_USERNAME")
 	authPassword := os.Getenv("AUTH_JAAS_PASSWORD")
-	flinkProvider := os.Getenv("flnkProvider")
+	flinkProvider := os.Getenv("provider")
 	groupID := "statement-executor-"
 	msgNormal := false
 	msgDebug := true
@@ -30,11 +30,11 @@ func main() {
 	}
 
 	var confluentConnection ConfluentConnection
-	confluentConnection.Token = os.Getenv("CONFLUENT_TOKEN")
-	confluentConnection.ComputePoolID = os.Getenv("CONFLUENT_COMPUTE_POOL_ID")
-	confluentConnection.Principal = os.Getenv("CONFLUENT_PRINCIPAL")
-	confluentConnection.SQLCurrentCatalog = os.Getenv("CONFLUENT_SQL_CURRENT_CATALOG")
-	confluentConnection.SQLCurrentDatabase = os.Getenv("CONFLUENT_SQL_CURRENT_DATABASE")
+	confluentConnection.Token = os.Getenv("confluentToken")
+	confluentConnection.ComputePoolID = os.Getenv("confluentComputePoolID")
+	confluentConnection.Principal = os.Getenv("confluentPrincipal")
+	confluentConnection.SQLCurrentCatalog = os.Getenv("confluentSQLCurrentCatalog")
+	confluentConnection.SQLCurrentDatabase = os.Getenv("confluentSQLCurrentDatabase")
 
 	// Healthcheck
 	http.HandleFunc("/actuator/health", func(w http.ResponseWriter, r *http.Request) {