remove dlp_reject_reason column from feed profile
@@ -55,6 +55,8 @@ public class QueryRunner {
@Nonnull
private final JdbcTemplate jdbcTemplate;
+ private static final String COL_DLP_REJECT_REASON = "dlp_reject_reason";
+
/**
* Constructs a {@code QueryRunner} for the specified JDBC data source.
*/
@@ -98,6 +100,7 @@ public class QueryRunner {
for (final QueryResultColumn column : queryResult.getColumns()) {
row.put(column.getDisplayName(), rs.getObject(column.getHiveColumnLabel()));
}
+ if(!row.containsKey(COL_DLP_REJECT_REASON))
queryResult.addRow(row);
}
});
