From 7cc367eff93a3b5acb00df8a3c2347c79e010905 Mon Sep 17 00:00:00 2001
From: samik <gupsam@google.com>
Date: Mon, 29 Apr 2024 22:51:44 +0530
Subject: [PATCH] Add feature flag for kryo serialization in wrangler

---
 cdap-common/src/main/resources/cdap-default.xml           | 8 ++++++++
 .../src/main/java/io/cdap/cdap/features/Feature.java      | 3 ++-
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git a/cdap-common/src/main/resources/cdap-default.xml b/cdap-common/src/main/resources/cdap-default.xml
index 99f5696a4830..33153dbdffcb 100644
--- a/cdap-common/src/main/resources/cdap-default.xml
+++ b/cdap-common/src/main/resources/cdap-default.xml
@@ -5988,6 +5988,14 @@
     </description>
   </property>
 
+  <property>
+    <name>feature.wrangler.kryo.serialization.enabled</name>
+    <value>false</value>
+    <description>
+      If true, wrangler will serialize rows using kryo.
+    </description>
+  </property>
+
   <property>
     <name>artifact.cache.bind.address</name>
     <value>0.0.0.0</value>
diff --git a/cdap-features/src/main/java/io/cdap/cdap/features/Feature.java b/cdap-features/src/main/java/io/cdap/cdap/features/Feature.java
index a68c37634b23..1d1f16d929fc 100644
--- a/cdap-features/src/main/java/io/cdap/cdap/features/Feature.java
+++ b/cdap-features/src/main/java/io/cdap/cdap/features/Feature.java
@@ -42,7 +42,8 @@ public enum Feature {
   WRANGLER_PRECONDITION_SQL("6.9.1"),
   WRANGLER_EXECUTION_SQL("6.10.0"),
   WRANGLER_SCHEMA_MANAGEMENT("6.10.0"),
-  NAMESPACED_SERVICE_ACCOUNTS("6.10.0");
+  NAMESPACED_SERVICE_ACCOUNTS("6.10.0"),
+  WRANGLER_KRYO_SERIALIZATION("6.10.1");
 
   private final PlatformInfo.Version versionIntroduced;
   private final boolean defaultAfterIntroduction;