|
@@ -159,7 +159,7 @@ class SampleTable(object):
|
|
|
try:
|
|
try:
|
|
|
# Already exists?
|
|
# Already exists?
|
|
|
if self.app_name == 'impala':
|
|
if self.app_name == 'impala':
|
|
|
- db.invalidate_tables('default', [self.name])
|
|
|
|
|
|
|
+ db.invalidate(database='default', flush_all=False)
|
|
|
db.get_table('default', self.name)
|
|
db.get_table('default', self.name)
|
|
|
msg = _('Table "%(table)s" already exists.') % {'table': self.name}
|
|
msg = _('Table "%(table)s" already exists.') % {'table': self.name}
|
|
|
LOG.error(msg)
|
|
LOG.error(msg)
|