|
|
@@ -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' || (
|