diff --git a/Tests/SparkConnectTests/Resources/queries/time.sql b/Tests/SparkConnectTests/Resources/queries/time.sql
new file mode 100644
index 0000000..c068926
--- /dev/null
+++ b/Tests/SparkConnectTests/Resources/queries/time.sql
@@ -0,0 +1 @@
+SELECT TIME '12:34:56.123456', to_time('12:34:56.123456'), make_time(12, 34, 56.123456)
diff --git a/Tests/SparkConnectTests/Resources/queries/time.sql.answer b/Tests/SparkConnectTests/Resources/queries/time.sql.answer
new file mode 100644
index 0000000..ec1204d
--- /dev/null
+++ b/Tests/SparkConnectTests/Resources/queries/time.sql.answer
@@ -0,0 +1,5 @@
++----------------------+------------------------+----------------------------+
+|TIME '12:34:56.123456'|to_time(12:34:56.123456)|make_time(12, 34, 56.123456)|
++----------------------+------------------------+----------------------------+
+|       12:34:56.123456|         12:34:56.123456|             12:34:56.123456|
++----------------------+------------------------+----------------------------+
\ No newline at end of file
diff --git a/Tests/SparkConnectTests/SQLTests.swift b/Tests/SparkConnectTests/SQLTests.swift
index bd9207b..c6dc66e 100644
--- a/Tests/SparkConnectTests/SQLTests.swift
+++ b/Tests/SparkConnectTests/SQLTests.swift
@@ -99,6 +99,10 @@ struct SQLTests {
     "variant.sql",
   ]
 
+  let queriesForSpark41Only: [String] = [
+    "time.sql",
+  ]
+
   #if !os(Linux)
     @Test
     func runAll() async throws {
@@ -111,6 +115,10 @@ struct SQLTests {
           print("Skip query \(name) due to the difference between Spark 3 and 4.")
           continue
         }
+        if await !spark.version.starts(with: "4.1") && queriesForSpark41Only.contains(name) {
+          print("Skip query \(name) due to the difference between Spark 4.0 and 4.1")
+          continue
+        }
 
         let sql = try String(contentsOf: URL(fileURLWithPath: "\(path)/\(name)"), encoding: .utf8)
         let result =