From be8c00c6c9dfbbf884906e3c9e1bc932f7555be7 Mon Sep 17 00:00:00 2001
From: Carol7102 <carol7102@hotmail.com>
Date: Sun, 3 Dec 2023 14:21:30 -0600
Subject: [PATCH] change parser
---
sql/sqlParser.go | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/sql/sqlParser.go b/sql/sqlParser.go
index 8cc5778..94223ed 100644
--- a/sql/sqlParser.go
+++ b/sql/sqlParser.go
@@ -367,6 +367,11 @@ func (parser *Parser) runJoinQueryUsingHadoop() error {
log.Println(cmd.String())
_ = cmd.Run()
+ // upload merged file to HDFS
+ cmd = exec.Command("rm", merged_d1d2)
+ log.Println(cmd.String())
+ _ = cmd.Run()
+
cmd = exec.Command("hadoop", "fs", "-put", merged_d1d2, "/")
log.Println(cmd.String())
err = cmd.Run()
--
GitLab