From 2436f46620199f527fbb4431a5da5d3cb9ffe186 Mon Sep 17 00:00:00 2001
From: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
Date: Thu, 15 Aug 2024 14:39:45 +0800
Subject: [PATCH] fix: some sink requires primary key columns to be not null

---
 src/main/scala/source/PhakerDatabase.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/scala/source/PhakerDatabase.scala b/src/main/scala/source/PhakerDatabase.scala
index 901b475..0384002 100644
--- a/src/main/scala/source/PhakerDatabase.scala
+++ b/src/main/scala/source/PhakerDatabase.scala
@@ -8,7 +8,7 @@ import java.util
 object PhakerDatabase {
   val primaryKey: String = "id"
   var columnList: Array[(String, DataType)] = Array(
-    (primaryKey, DataTypes.BIGINT)
+    (primaryKey, DataTypes.BIGINT.notNull)
   )
   var idCount: Long = 0
   var colCount = 0