diff --git a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ContainerSchemaDefinition.java b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ContainerSchemaDefinition.java
index 5696ab3e01bc..1be715dc7d22 100644
--- a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ContainerSchemaDefinition.java
+++ b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ContainerSchemaDefinition.java
@@ -81,8 +81,8 @@ public void initializeSchema() throws SQLException {
    */
   private void createContainerHistoryTable() {
     dslContext.createTableIfNotExists(CONTAINER_HISTORY_TABLE_NAME)
-        .column(CONTAINER_ID, SQLDataType.BIGINT)
-        .column("datanode_host", SQLDataType.VARCHAR(1024))
+        .column(CONTAINER_ID, SQLDataType.BIGINT.nullable(false))
+        .column("datanode_host", SQLDataType.VARCHAR(766).nullable(false))
         .column("first_report_timestamp", SQLDataType.BIGINT)
         .column("last_report_timestamp", SQLDataType.BIGINT)
         .constraint(DSL.constraint("pk_container_id_datanode_host")
diff --git a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconTaskSchemaDefinition.java b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconTaskSchemaDefinition.java
index 45fc1ba0d73b..72e27024feea 100644
--- a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconTaskSchemaDefinition.java
+++ b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/ReconTaskSchemaDefinition.java
@@ -61,7 +61,7 @@ public void initializeSchema() throws SQLException {
    */
   private void createReconTaskStatusTable(Connection conn) {
     DSL.using(conn).createTableIfNotExists(RECON_TASK_STATUS_TABLE_NAME)
-        .column("task_name", SQLDataType.VARCHAR(1024))
+        .column("task_name", SQLDataType.VARCHAR(768).nullable(false))
         .column("last_updated_timestamp", SQLDataType.BIGINT)
         .column("last_updated_seq_number", SQLDataType.BIGINT)
         .constraint(DSL.constraint("pk_task_name")
diff --git a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/StatsSchemaDefinition.java b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/StatsSchemaDefinition.java
index 55f3b93c6ba4..394c9de8df59 100644
--- a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/StatsSchemaDefinition.java
+++ b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/StatsSchemaDefinition.java
@@ -59,7 +59,7 @@ public void initializeSchema() throws SQLException {
    */
   private void createGlobalStatsTable() {
     dslContext.createTableIfNotExists(GLOBAL_STATS_TABLE_NAME)
-        .column("key", SQLDataType.VARCHAR(255))
+        .column("key", SQLDataType.VARCHAR(255).nullable(false))
         .column("value", SQLDataType.BIGINT)
         .column("last_updated_timestamp", SQLDataType.TIMESTAMP)
         .constraint(DSL.constraint("pk_key")
diff --git a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java
index b2b2881b6c7a..193ee758fecc 100644
--- a/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java
+++ b/hadoop-ozone/recon-codegen/src/main/java/org/hadoop/ozone/recon/schema/UtilizationSchemaDefinition.java
@@ -72,8 +72,8 @@ public void initializeSchema() throws SQLException {
 
   private void createClusterGrowthTable() {
     dslContext.createTableIfNotExists(CLUSTER_GROWTH_DAILY_TABLE_NAME)
-        .column("timestamp", SQLDataType.TIMESTAMP)
-        .column("datanode_id", SQLDataType.INTEGER)
+        .column("timestamp", SQLDataType.TIMESTAMP.nullable(false))
+        .column("datanode_id", SQLDataType.INTEGER.nullable(false))
         .column("datanode_host", SQLDataType.VARCHAR(1024))
         .column("rack_id", SQLDataType.VARCHAR(1024))
         .column("available_size", SQLDataType.BIGINT)
@@ -87,9 +87,9 @@ private void createClusterGrowthTable() {
 
   private void createFileSizeCountTable() {
     dslContext.createTableIfNotExists(FILE_COUNT_BY_SIZE_TABLE_NAME)
-        .column("volume", SQLDataType.VARCHAR(64))
-        .column("bucket", SQLDataType.VARCHAR(64))
-        .column("file_size", SQLDataType.BIGINT)
+        .column("volume", SQLDataType.VARCHAR(64).nullable(false))
+        .column("bucket", SQLDataType.VARCHAR(64).nullable(false))
+        .column("file_size", SQLDataType.BIGINT.nullable(false))
         .column("count", SQLDataType.BIGINT)
         .constraint(DSL.constraint("pk_volume_bucket_file_size")
             .primaryKey("volume", "bucket", "file_size"))