SK-2274 warning log when user provide limits

Author: skyflow-bharti

common/src/main/java/com/skyflow/logs/InfoLogs.java

@@ -93,8 +93,6 @@ public enum InfoLogs {
     REIDENTIFY_TEXT_SUCCESS("Text data re-identified."),
 
     PROCESSING_BATCHES("Processing batch"),
-    SET_CONCURRENCY_LIMIT("Setting concurrency limit to %s1"),
-    SET_BATCH_SIZE("Setting batch size to %s1"),
     ;
 
 

v3/src/main/java/com/skyflow/vault/controller/VaultController.java

@@ -49,6 +49,7 @@ public com.skyflow.vault.data.InsertResponse bulkInsert(InsertRequest insertRequ
             LogUtil.printInfoLog(InfoLogs.VALIDATE_INSERT_REQUEST.getLog());
             Validations.validateInsertRequest(insertRequest);
             configureInsertConcurrencyAndBatchSize(insertRequest.getValues().size());
+
             setBearerToken();
             com.skyflow.generated.rest.resources.recordservice.requests.InsertRequest request = super.getBulkInsertRequestBody(insertRequest, super.getVaultConfig());
 
@@ -70,6 +71,7 @@ public CompletableFuture<com.skyflow.vault.data.InsertResponse> bulkInsertAsync(
             LogUtil.printInfoLog(InfoLogs.VALIDATE_INSERT_REQUEST.getLog());
             Validations.validateInsertRequest(insertRequest);
             configureInsertConcurrencyAndBatchSize(insertRequest.getValues().size());
+
             setBearerToken();
             com.skyflow.generated.rest.resources.recordservice.requests.InsertRequest request = super.getBulkInsertRequestBody(insertRequest, super.getVaultConfig());
             List<ErrorRecord> errorRecords = Collections.synchronizedList(new ArrayList<>());
@@ -306,12 +308,11 @@ private void configureInsertConcurrencyAndBatchSize(int totalRequests) {
             if (userProvidedBatchSize != null) {
                 try {
                     int batchSize = Integer.parseInt(userProvidedBatchSize);
-                    if (batchSize > Constants.MAX_DETOKENIZE_BATCH_SIZE) {
+                    if (batchSize > Constants.MAX_INSERT_BATCH_SIZE) {
                         LogUtil.printWarningLog(WarningLogs.BATCH_SIZE_EXCEEDS_MAX_LIMIT.getLog());
                     }
                     int maxBatchSize = Math.min(batchSize, Constants.MAX_INSERT_BATCH_SIZE);
                     if (maxBatchSize > 0) {
-//                        LogUtil.printInfoLog(InfoLogs.SET_BATCH_SIZE.getLog() + maxBatchSize);
                         this.insertBatchSize = maxBatchSize;
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_BATCH_SIZE_PROVIDED.getLog());
@@ -330,11 +331,10 @@ private void configureInsertConcurrencyAndBatchSize(int totalRequests) {
                 try {
                     int concurrencyLimit = Integer.parseInt(userProvidedConcurrencyLimit);
                     int maxConcurrencyLimit = Math.min(concurrencyLimit, Constants.MAX_INSERT_CONCURRENCY_LIMIT);
-                    if (concurrencyLimit > Constants.MAX_DETOKENIZE_CONCURRENCY_LIMIT) {
+                    if (concurrencyLimit > Constants.MAX_INSERT_CONCURRENCY_LIMIT) {
                         LogUtil.printWarningLog(WarningLogs.CONCURRENCY_EXCEEDS_MAX_LIMIT.getLog());
                     }
                     if (maxConcurrencyLimit > 0) {
-//                        LogUtil.printInfoLog(InfoLogs.SET_CONCURRENCY_LIMIT.getLog() + maxConcurrencyLimit);
                         this.insertConcurrencyLimit = Math.min(maxConcurrencyLimit, maxConcurrencyNeeded);
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_CONCURRENCY_LIMIT_PROVIDED.getLog());
@@ -369,7 +369,6 @@ private void configureDetokenizeConcurrencyAndBatchSize(int totalRequests) {
                     }
                     int maxBatchSize = Math.min(batchSize, Constants.MAX_DETOKENIZE_BATCH_SIZE);
                     if (maxBatchSize > 0) {
-//                        LogUtil.printInfoLog(InfoLogs.SET_BATCH_SIZE.getLog() + maxBatchSize);
                         this.detokenizeBatchSize = maxBatchSize;
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_BATCH_SIZE_PROVIDED.getLog());
@@ -393,7 +392,6 @@ private void configureDetokenizeConcurrencyAndBatchSize(int totalRequests) {
                     int maxConcurrencyLimit = Math.min(concurrencyLimit, Constants.MAX_DETOKENIZE_CONCURRENCY_LIMIT);
 
                     if (maxConcurrencyLimit > 0) {
-//                        LogUtil.printInfoLog(InfoLogs.SET_CONCURRENCY_LIMIT.getLog() + maxConcurrencyLimit);
                         this.detokenizeConcurrencyLimit = Math.min(maxConcurrencyLimit, maxConcurrencyNeeded);
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_CONCURRENCY_LIMIT_PROVIDED.getLog());