fix bugs when bulkload is not enabled on Postgresql

Signed-off-by: Lei Wang <[email protected]>
GraphScope · Jul 11, 2024 · 657dc6d · 657dc6d
1 parent 62f2390
commit 657dc6d
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 5 deletions.
diff --git a/charts/gart/templates/debezium/configmap.yaml b/charts/gart/templates/debezium/configmap.yaml
@@ -37,7 +37,11 @@ data:
         "snapshot.mode": "always",
         {{- end }}
         {{- else }}
-        "snapshot.mode": "never",
+        {{- if eq .Values.dataconfig.dbType "mysql" }}
+        "snapshot.mode": "schema_only",
+        {{- else }}
+        "snapshot.mode": "no_data",
+        {{- end }}
         {{- end }}
         "database.server.id": "1", 
         "include.schema.changes": "false",

diff --git a/charts/gart/values.yaml b/charts/gart/values.yaml
@@ -151,7 +151,7 @@ debezium:
   replicaCount: 1
   image:
     repository: debezium/connect
-    tag: latest
+    tag: 2.7.0.Final
     pullPolicy: IfNotPresent
   containerPort: 8083
   resources: {}

diff --git a/converter/parser.cc b/converter/parser.cc
@@ -298,7 +298,6 @@ gart::Status TxnLogParser::parse(LogEntry& out, const string& log_str,
   // default for PostgreSQL, -1 for MySQL
   // TODO(SSJ): Hardcode for PostgreSQL and MySQL
   int tx_id = log["source"].value("txId", -1);
-  /*
   if (tx_id == -1) {
     // MySQL
     const json& gtid_json = log["source"]["gtid"];
@@ -314,7 +313,6 @@ gart::Status TxnLogParser::parse(LogEntry& out, const string& log_str,
       LOG(ERROR) << "Please open GTID for MySQL.";
     }
   }
-  */
 
   out.tx_id = tx_id;
 

diff --git a/scripts/install-deps.sh b/scripts/install-deps.sh
@@ -296,7 +296,7 @@ database.user=<mysql user>
 database.password=<mysql password>
 database.include.list=<which databse is needed to capture, e.g., ldbc>
 table.include.list=<list the tables in the order of vertices, then edges>
-snapshot.mode=<if enable buldload, set as "initial", otherwise set as "never">
+snapshot.mode=<if enable buldload, set as "initial", otherwise set as "schema_only">
 
 $COMM_CONFIG