From f5204ab5225a506b823b541fa8809a69608cc806 Mon Sep 17 00:00:00 2001
From: Alok Kumar Singh <mail.alok87@gmail.com>
Date: Fri, 9 Apr 2021 13:22:22 +0530
Subject: [PATCH] Added default for backward compatibility of schema

---
 redshiftsink/pkg/redshiftloader/job.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/redshiftsink/pkg/redshiftloader/job.go b/redshiftsink/pkg/redshiftloader/job.go
index 77445a7e4..bc508c086 100644
--- a/redshiftsink/pkg/redshiftloader/job.go
+++ b/redshiftsink/pkg/redshiftloader/job.go
@@ -16,7 +16,7 @@ var JobAvroSchema string = `{
         {"name": "csvDialect", "type": "string"},
         {"name": "s3Path", "type": "string"},
         {"name": "schemaId", "type": "int"},
-        {"name": "schemaIdKey", "type": "int"},
+        {"name": "schemaIdKey", "type": "int", default: -1},
         {"name": "maskSchema", "type": "string"},
         {"name": "skipMerge", "type": "string", "default": ""},
         {"name": "batchBytes", "type": "long", "default": 0}