carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mohammadshahidkhan <>
Subject [GitHub] carbondata pull request #1783: [CARBONDATA-2013] executing alter query resul...
Date Sat, 13 Jan 2018 07:38:56 GMT
Github user mohammadshahidkhan commented on a diff in the pull request:
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/strategy/StreamingTableStrategy.scala
    @@ -59,7 +59,8 @@ private[sql] class StreamingTableStrategy(sparkSession: SparkSession)
extends Sp
               new TableIdentifier(model.tableName, model.databaseName),
               "Alter table change datatype")
    -      case AlterTableRenameCommand(oldTableIdentifier, _, _) =>
    +      case AlterTableRenameCommand(
    +      oldTableIdentifier, _, _) if (isCarbonStreamingTable(oldTableIdentifier)) =>
    --- End diff --
    As per my understanding @QiangCai wanted to block the **alter table and IUD** commands
for the streaming table.
    The method rejectIfStreamingTable throws exception if called over the non carbon table.
Therefore the alter table and IUD commands  are blocked for non carbon table.
    So whether table is carbon table  should be checked first before checking the table is
streaming or not.
    @kushalsaha The handling is needed for the commands getting rejectected here for the 
    streaming table. As per my understanding instead of adding additional if check, the rejectIfStreamingTable
 method could be modified the avoid blocking the alter and IUD commands for non carbon table.


View raw message