Skip to content

Commit dee9e74

Browse files
author
SivaMaplelabs
committed
PNDA-4927 Undefined variable component in DM
1 parent 691addc commit dee9e74

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

api/src/main/resources/plugins/oozie.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ def stage_flink_components(self, application_name, component_name, properties, s
8181
if os.path.isfile(os.path.join(flink_lib_dir, jar)) and 'flink-python' in jar:
8282
properties['flink_python_jar'] = '%s/%s' % (flink_lib_dir, jar)
8383
else:
84-
raise Exception('properties.json must contain "main_jar or main_py" for %s flink-batch-job %s' % (application_name, component['component_name']))
84+
raise Exception('properties.json must contain "main_jar or main_py" for %s flink-batch-job %s' % (application_name, component_name))
8585

8686
shutil.copyfile(os.path.join(this_dir, 'flink-stop.py'), '%s/lib/flink-stop.py' % staged_component_path)
8787
shutil.copyfile(os.path.join(this_dir, service_script), '%s/lib/%s' % (staged_component_path, service_script))

0 commit comments

Comments
 (0)