diff --git a/packages/cubejs-backend-native/Cargo.lock b/packages/cubejs-backend-native/Cargo.lock
index a1f071b5066e0..f6a82ef21e4ea 100644
--- a/packages/cubejs-backend-native/Cargo.lock
+++ b/packages/cubejs-backend-native/Cargo.lock
@@ -714,7 +714,7 @@ dependencies = [
 [[package]]
 name = "cube-ext"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "chrono",
@@ -890,7 +890,7 @@ checksum = "e8566979429cf69b49a5c740c60791108e86440e8be149bbea4fe54d2c32d6e2"
 [[package]]
 name = "datafusion"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -923,7 +923,7 @@ dependencies = [
 [[package]]
 name = "datafusion-common"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "ordered-float 2.10.1",
@@ -934,7 +934,7 @@ dependencies = [
 [[package]]
 name = "datafusion-data-access"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "async-trait",
  "chrono",
@@ -947,7 +947,7 @@ dependencies = [
 [[package]]
 name = "datafusion-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -958,7 +958,7 @@ dependencies = [
 [[package]]
 name = "datafusion-physical-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
diff --git a/rust/cubenativeutils/Cargo.lock b/rust/cubenativeutils/Cargo.lock
index 9a8d0c550d2eb..bb6763e6f477b 100644
--- a/rust/cubenativeutils/Cargo.lock
+++ b/rust/cubenativeutils/Cargo.lock
@@ -623,7 +623,7 @@ dependencies = [
 [[package]]
 name = "cube-ext"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "chrono",
@@ -717,7 +717,7 @@ dependencies = [
 [[package]]
 name = "datafusion"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -750,7 +750,7 @@ dependencies = [
 [[package]]
 name = "datafusion-common"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "ordered-float 2.10.1",
@@ -761,7 +761,7 @@ dependencies = [
 [[package]]
 name = "datafusion-data-access"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "async-trait",
  "chrono",
@@ -774,7 +774,7 @@ dependencies = [
 [[package]]
 name = "datafusion-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -785,7 +785,7 @@ dependencies = [
 [[package]]
 name = "datafusion-physical-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
diff --git a/rust/cubesql/Cargo.lock b/rust/cubesql/Cargo.lock
index f7d024f65652c..59a126965820c 100644
--- a/rust/cubesql/Cargo.lock
+++ b/rust/cubesql/Cargo.lock
@@ -722,7 +722,7 @@ dependencies = [
 [[package]]
 name = "cube-ext"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "chrono",
@@ -848,7 +848,7 @@ dependencies = [
 [[package]]
 name = "datafusion"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -881,7 +881,7 @@ dependencies = [
 [[package]]
 name = "datafusion-common"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "ordered-float 2.10.0",
@@ -892,7 +892,7 @@ dependencies = [
 [[package]]
 name = "datafusion-data-access"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "async-trait",
  "chrono",
@@ -905,7 +905,7 @@ dependencies = [
 [[package]]
 name = "datafusion-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -916,7 +916,7 @@ dependencies = [
 [[package]]
 name = "datafusion-physical-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
diff --git a/rust/cubesql/cubesql/Cargo.toml b/rust/cubesql/cubesql/Cargo.toml
index 053a2e00ba8aa..c07383a16856f 100644
--- a/rust/cubesql/cubesql/Cargo.toml
+++ b/rust/cubesql/cubesql/Cargo.toml
@@ -10,7 +10,7 @@ homepage = "https://cube.dev"
 
 [dependencies]
 arc-swap = "1"
-datafusion = { git = 'https://github.com/cube-js/arrow-datafusion.git', rev = "dcf3e4aa26fd112043ef26fa4a78db5dbd443c86", default-features = false, features = [
+datafusion = { git = 'https://github.com/cube-js/arrow-datafusion.git', rev = "1a612fc26f762f3837ecf26df2e83ba38f11a8a2", default-features = false, features = [
     "regex_expressions",
     "unicode_expressions",
 ] }
diff --git a/rust/cubesql/cubesql/src/compile/mod.rs b/rust/cubesql/cubesql/src/compile/mod.rs
index 5593db5c60144..e10c986ad84a8 100644
--- a/rust/cubesql/cubesql/src/compile/mod.rs
+++ b/rust/cubesql/cubesql/src/compile/mod.rs
@@ -1104,7 +1104,7 @@ mod tests {
 
         assert_eq!(
             logical_plan,
-            "Projection: CAST(utctimestamp() AS current_timestamp() AS Timestamp(Nanosecond, None)) AS COL\
+            "Projection: CAST(utctimestamp() AS current_timestamp AS Timestamp(Nanosecond, None)) AS COL\
             \n  EmptyRelation",
         );
     }
diff --git a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_date.snap b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_date.snap
index a50a588553503..83f0a702bb5d0 100644
--- a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_date.snap
+++ b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_date.snap
@@ -1,10 +1,9 @@
 ---
 source: cubesql/src/compile/mod.rs
-assertion_line: 11756
-expression: "execute_query(\"SELECT current_timestamp::date = current_date\".to_string(),\n            DatabaseProtocol::PostgreSQL).await?"
+expression: "execute_query(\"SELECT current_timestamp::date = current_date\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
-+-----------------------------------------------------+
-| CAST(current_timestamp() AS Date32) = currentdate() |
-+-----------------------------------------------------+
-| true                                                |
-+-----------------------------------------------------+
++-------------------------------------------------+
+| CAST(current_timestamp AS Date32) = currentdate |
++-------------------------------------------------+
+| true                                            |
++-------------------------------------------------+
diff --git a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_schema_postgres.snap b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_schema_postgres.snap
index dacdef3931e04..eb7ad48963649 100644
--- a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_schema_postgres.snap
+++ b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__current_schema_postgres.snap
@@ -1,9 +1,9 @@
 ---
 source: cubesql/src/compile/mod.rs
-expression: "execute_query(\"SELECT current_schema()\".to_string(),\n              DatabaseProtocol::PostgreSQL).await?"
+expression: "execute_query(\"SELECT current_schema()\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
-+------------------+
-| current_schema() |
-+------------------+
-| public           |
-+------------------+
++----------------+
+| current_schema |
++----------------+
+| public         |
++----------------+
diff --git a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__localtimestamp.snap b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__localtimestamp.snap
index 0e58b8bfb9cd1..881d7d749da01 100644
--- a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__localtimestamp.snap
+++ b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__localtimestamp.snap
@@ -1,9 +1,9 @@
 ---
 source: cubesql/src/compile/mod.rs
-expression: "execute_query(\"SELECT localtimestamp = current_timestamp\".to_string(),\n            DatabaseProtocol::PostgreSQL).await?"
+expression: "execute_query(\"SELECT localtimestamp = current_timestamp\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
-+----------------------------------------+
-| localtimestamp() = current_timestamp() |
-+----------------------------------------+
-| true                                   |
-+----------------------------------------+
++------------------------------------+
+| localtimestamp = current_timestamp |
++------------------------------------+
+| true                               |
++------------------------------------+
diff --git a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__pg_catalog_udf_search_path.snap b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__pg_catalog_udf_search_path.snap
index d707f97582db9..b71b8537d8ec9 100644
--- a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__pg_catalog_udf_search_path.snap
+++ b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__pg_catalog_udf_search_path.snap
@@ -3,7 +3,7 @@ source: cubesql/src/compile/mod.rs
 expression: "execute_query(\"SELECT version() UNION ALL SELECT pg_catalog.version();\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
 +-----------------------------------+
-| version()                         |
+| version                           |
 +-----------------------------------+
 | PostgreSQL 14.2 on x86_64-cubesql |
 | PostgreSQL 14.2 on x86_64-cubesql |
diff --git a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__quicksight_sql_implementation_info.snap b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__quicksight_sql_implementation_info.snap
index 4614e9ff83b70..0548229cf1611 100644
--- a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__quicksight_sql_implementation_info.snap
+++ b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__quicksight_sql_implementation_info.snap
@@ -1,9 +1,9 @@
 ---
 source: cubesql/src/compile/mod.rs
-expression: "execute_query(r#\"\n                SELECT character_value, version() \n                FROM INFORMATION_SCHEMA.SQL_IMPLEMENTATION_INFO\n                WHERE implementation_info_id IN ('17','18')\n                \"#.to_string(),\nDatabaseProtocol::PostgreSQL).await?"
+expression: "execute_query(r#\"\n                SELECT character_value, version()\n                FROM INFORMATION_SCHEMA.SQL_IMPLEMENTATION_INFO\n                WHERE implementation_info_id IN ('17','18')\n                \"#.to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
 +-----------------+-----------------------------------+
-| character_value | version()                         |
+| character_value | version                           |
 +-----------------+-----------------------------------+
 | PostgreSQL      | PostgreSQL 14.2 on x86_64-cubesql |
 | 14.02.0000)     | PostgreSQL 14.2 on x86_64-cubesql |
diff --git a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__set_good_user.snap b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__set_good_user.snap
index cd169dd7fcd3b..66246ccecd73f 100644
--- a/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__set_good_user.snap
+++ b/rust/cubesql/cubesql/src/compile/snapshots/cubesql__compile__tests__set_good_user.snap
@@ -1,10 +1,9 @@
 ---
 source: cubesql/src/compile/mod.rs
-assertion_line: 7198
-expression: "execute_queries_with_flags(vec![\"SET user = 'good_user'\".to_string(),\n                    \"select current_user\".to_string()],\n                DatabaseProtocol::PostgreSQL).await?.0"
+expression: "execute_queries_with_flags(vec![\"SET user = 'good_user'\".to_string(),\n\"select current_user\".to_string()], DatabaseProtocol::PostgreSQL).await? .0"
 ---
-+----------------+
-| current_user() |
-+----------------+
-| good_user      |
-+----------------+
++--------------+
+| current_user |
++--------------+
+| good_user    |
++--------------+
diff --git a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__datagrip_introspection.snap b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__datagrip_introspection.snap
index 18a7b831848e0..b5517eaada1f5 100644
--- a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__datagrip_introspection.snap
+++ b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__datagrip_introspection.snap
@@ -2,8 +2,8 @@
 source: cubesql/src/compile/test/test_introspection.rs
 expression: "execute_query(\"select current_database(), current_schema(), current_user;\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
-+--------------------+------------------+----------------+
-| current_database() | current_schema() | current_user() |
-+--------------------+------------------+----------------+
-| cubedb             | public           | ovr            |
-+--------------------+------------------+----------------+
++------------------+----------------+--------------+
+| current_database | current_schema | current_user |
++------------------+----------------+--------------+
+| cubedb           | public         | ovr          |
++------------------+----------------+--------------+
diff --git a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__dbeaver_introspection_init.snap b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__dbeaver_introspection_init.snap
index 87be423caef41..7263a0e3171ac 100644
--- a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__dbeaver_introspection_init.snap
+++ b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__dbeaver_introspection_init.snap
@@ -2,8 +2,8 @@
 source: cubesql/src/compile/test/test_introspection.rs
 expression: "execute_query(\"SELECT current_schema(), session_user;\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
-+------------------+----------------+
-| current_schema() | session_user() |
-+------------------+----------------+
-| public           | ovr            |
-+------------------+----------------+
++----------------+--------------+
+| current_schema | session_user |
++----------------+--------------+
+| public         | ovr          |
++----------------+--------------+
diff --git a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__zoho_inet_server_addr.snap b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__zoho_inet_server_addr.snap
index b63e9746bf018..a391b81772798 100644
--- a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__zoho_inet_server_addr.snap
+++ b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_introspection__zoho_inet_server_addr.snap
@@ -2,8 +2,8 @@
 source: cubesql/src/compile/test/test_introspection.rs
 expression: "execute_query(\"\n                select\n                    pg_backend_pid(),\n                    coalesce(cast(inet_server_addr() as text ),'addr'),\n                    current_database()\n                ;\".to_string(),\nDatabaseProtocol::PostgreSQL,).await?"
 ---
-+------------------+---------------------------------------------------------+--------------------+
-| pg_backend_pid() | coalesce(CAST(inet_server_addr() AS Utf8),Utf8("addr")) | current_database() |
-+------------------+---------------------------------------------------------+--------------------+
-| 1                | 127.0.0.1/32                                            | cubedb             |
-+------------------+---------------------------------------------------------+--------------------+
++----------------+-------------------------------------------------------+------------------+
+| pg_backend_pid | coalesce(CAST(inet_server_addr AS Utf8),Utf8("addr")) | current_database |
++----------------+-------------------------------------------------------+------------------+
+| 1              | 127.0.0.1/32                                          | cubedb           |
++----------------+-------------------------------------------------------+------------------+
diff --git a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_udfs__pg_backend_pid.snap b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_udfs__pg_backend_pid.snap
index 03f90383ef38a..bc4cb03ba918f 100644
--- a/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_udfs__pg_backend_pid.snap
+++ b/rust/cubesql/cubesql/src/compile/test/snapshots/cubesql__compile__test__test_udfs__pg_backend_pid.snap
@@ -2,8 +2,8 @@
 source: cubesql/src/compile/test/test_udfs.rs
 expression: "execute_query(\"select pg_backend_pid();\".to_string(),\nDatabaseProtocol::PostgreSQL).await?"
 ---
-+------------------+
-| pg_backend_pid() |
-+------------------+
-| 1                |
-+------------------+
++----------------+
+| pg_backend_pid |
++----------------+
+| 1              |
++----------------+
diff --git a/rust/cubesqlplanner/Cargo.lock b/rust/cubesqlplanner/Cargo.lock
index 568be0df824e8..3b2663abb921b 100644
--- a/rust/cubesqlplanner/Cargo.lock
+++ b/rust/cubesqlplanner/Cargo.lock
@@ -664,7 +664,7 @@ dependencies = [
 [[package]]
 name = "cube-ext"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "chrono",
@@ -780,7 +780,7 @@ dependencies = [
 [[package]]
 name = "datafusion"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -813,7 +813,7 @@ dependencies = [
 [[package]]
 name = "datafusion-common"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "arrow",
  "ordered-float 2.10.1",
@@ -824,7 +824,7 @@ dependencies = [
 [[package]]
 name = "datafusion-data-access"
 version = "1.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "async-trait",
  "chrono",
@@ -837,7 +837,7 @@ dependencies = [
 [[package]]
 name = "datafusion-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
@@ -848,7 +848,7 @@ dependencies = [
 [[package]]
 name = "datafusion-physical-expr"
 version = "7.0.0"
-source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=dcf3e4aa26fd112043ef26fa4a78db5dbd443c86#dcf3e4aa26fd112043ef26fa4a78db5dbd443c86"
+source = "git+https://github.com/cube-js/arrow-datafusion.git?rev=1a612fc26f762f3837ecf26df2e83ba38f11a8a2#1a612fc26f762f3837ecf26df2e83ba38f11a8a2"
 dependencies = [
  "ahash 0.7.8",
  "arrow",
diff --git a/rust/cubesqlplanner/cubesqlplanner/Cargo.toml b/rust/cubesqlplanner/cubesqlplanner/Cargo.toml
index 43ed6ccc5db5a..34e1b84b63b0f 100644
--- a/rust/cubesqlplanner/cubesqlplanner/Cargo.toml
+++ b/rust/cubesqlplanner/cubesqlplanner/Cargo.toml
@@ -6,7 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-datafusion = { git = 'https://github.com/cube-js/arrow-datafusion.git', rev = "dcf3e4aa26fd112043ef26fa4a78db5dbd443c86", default-features = false, features = ["regex_expressions", "unicode_expressions"] }
+datafusion = { git = 'https://github.com/cube-js/arrow-datafusion.git', rev = "1a612fc26f762f3837ecf26df2e83ba38f11a8a2", default-features = false, features = ["regex_expressions", "unicode_expressions"] }
 tokio = { version = "^1.35", features = ["full", "rt", "tracing"] }
 itertools = "0.10.2"
 cubeclient = { path = "../../cubesql/cubeclient" }