Github user ravipesala commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1781#discussion_r163765303 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonLoadDataCommand.scala --- @@ -240,11 +247,12 @@ case class CarbonLoadDataCommand( table.getCarbonTableIdentifier, carbonLoadModel) OperationListenerBus.getInstance.fireEvent(loadTablePostExecutionEvent, operationContext) + } catch { case CausedBy(ex: NoRetryException) => // update the load entry in table status file for changing the status to marked for delete if (isUpdateTableStatusRequired) { - CarbonLoaderUtil.updateTableStatusForFailure(carbonLoadModel) + CarbonLoaderUtil.updateTableStatusForFailure(carbonLoadModel, uuid) --- End diff -- Add a new method, don't change the current method signature
---