Index: hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/DbNotificationListener.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/DbNotificationListener.java (date 1423788059000) +++ hcatalog/server-extensions/src/main/java/org/apache/hive/hcatalog/listener/DbNotificationListener.java (revision ) @@ -29,7 +29,6 @@ import org.apache.hadoop.hive.metastore.api.NotificationEvent; import org.apache.hadoop.hive.metastore.api.Partition; import org.apache.hadoop.hive.metastore.api.Table; -import org.apache.hadoop.hive.metastore.api.hive_metastoreConstants; import org.apache.hadoop.hive.metastore.events.AddPartitionEvent; import org.apache.hadoop.hive.metastore.events.AlterPartitionEvent; import org.apache.hadoop.hive.metastore.events.AlterTableEvent; @@ -145,12 +144,10 @@ NotificationEvent event = new NotificationEvent(0, now(), HCatConstants.HCAT_ALTER_TABLE_EVENT, msgFactory.buildAlterTableMessage(before, after).toString()); - if (event != null) { - event.setDbName(after.getDbName()); - event.setTableName(after.getTableName()); - enqueue(event); - } + event.setDbName(after.getDbName()); + event.setTableName(after.getTableName()); + enqueue(event); + } - } /** * @param partitionEvent partition event @@ -191,11 +188,9 @@ NotificationEvent event = new NotificationEvent(0, now(), HCatConstants.HCAT_ALTER_PARTITION_EVENT, msgFactory.buildAlterPartitionMessage(before, after).toString()); - if (event != null) { - event.setDbName(before.getDbName()); - event.setTableName(before.getTableName()); - enqueue(event); + event.setDbName(before.getDbName()); + event.setTableName(before.getTableName()); + enqueue(event); - } } /**