[importer] Do not disable submit when input is Kafka and output Kudu and table already exists
@@ -2479,7 +2479,11 @@ ${ assist.assistPanel() }
if (self.destination.outputFormat() === 'database' && self.source.inputFormat() === 'rdbms') {
isTargetAlreadyExisting = self.destination.isTargetExisting();
} else {
- isTargetAlreadyExisting = !self.destination.isTargetExisting() || self.destination.outputFormat() === 'index';
+ isTargetAlreadyExisting = !self.destination.isTargetExisting()
+ || self.destination.outputFormat() === 'index'
+ ## Authorize submission but should check if schema is compatible
+ || (self.source.inputFormat() === 'stream' && self.destination.outputFormat() === 'table' && self.destination.tableFormat() === 'kudu')
+ ;
}
var isValidTable = self.destination.outputFormat() !== 'table' || (
self.destination.tableFormat() !== 'kudu' || (
