|
@@ -65,13 +65,13 @@ class Migration(migrations.Migration):
|
|
|
name='OozieJavaAction',
|
|
name='OozieJavaAction',
|
|
|
fields=[
|
|
fields=[
|
|
|
('oozieaction_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='jobsub.OozieAction')),
|
|
('oozieaction_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='jobsub.OozieAction')),
|
|
|
- ('files', models.CharField(default=b'[]', help_text='List of paths to files to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
- ('archives', models.CharField(default=b'[]', help_text='List of paths to archives to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
|
|
+ ('files', models.CharField(default='[]', help_text='List of paths to files to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
+ ('archives', models.CharField(default='[]', help_text='List of paths to archives to be added to the distributed cache.', max_length=512)),
|
|
|
('jar_path', models.CharField(max_length=512)),
|
|
('jar_path', models.CharField(max_length=512)),
|
|
|
('main_class', models.CharField(max_length=256)),
|
|
('main_class', models.CharField(max_length=256)),
|
|
|
('args', models.TextField(blank=True)),
|
|
('args', models.TextField(blank=True)),
|
|
|
('java_opts', models.CharField(blank=True, max_length=256)),
|
|
('java_opts', models.CharField(blank=True, max_length=256)),
|
|
|
- ('job_properties', models.TextField(default=b'[]')),
|
|
|
|
|
|
|
+ ('job_properties', models.TextField(default='[]')),
|
|
|
],
|
|
],
|
|
|
bases=('jobsub.oozieaction',),
|
|
bases=('jobsub.oozieaction',),
|
|
|
),
|
|
),
|
|
@@ -79,9 +79,9 @@ class Migration(migrations.Migration):
|
|
|
name='OozieMapreduceAction',
|
|
name='OozieMapreduceAction',
|
|
|
fields=[
|
|
fields=[
|
|
|
('oozieaction_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='jobsub.OozieAction')),
|
|
('oozieaction_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='jobsub.OozieAction')),
|
|
|
- ('files', models.CharField(default=b'[]', help_text='List of paths to files to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
- ('archives', models.CharField(default=b'[]', help_text='List of paths to archives to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
- ('job_properties', models.TextField(default=b'[]')),
|
|
|
|
|
|
|
+ ('files', models.CharField(default='[]', help_text='List of paths to files to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
+ ('archives', models.CharField(default='[]', help_text='List of paths to archives to be added to the distributed cache.', max_length=512)),
|
|
|
|
|
+ ('job_properties', models.TextField(default='[]')),
|
|
|
('jar_path', models.CharField(help_text='Path to jar files on HDFS.', max_length=512)),
|
|
('jar_path', models.CharField(help_text='Path to jar files on HDFS.', max_length=512)),
|
|
|
],
|
|
],
|
|
|
bases=('jobsub.oozieaction',),
|
|
bases=('jobsub.oozieaction',),
|
|
@@ -90,9 +90,9 @@ class Migration(migrations.Migration):
|
|
|
name='OozieStreamingAction',
|
|
name='OozieStreamingAction',
|
|
|
fields=[
|
|
fields=[
|
|
|
('oozieaction_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='jobsub.OozieAction')),
|
|
('oozieaction_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='jobsub.OozieAction')),
|
|
|
- ('files', models.CharField(default=b'[]', max_length=512)),
|
|
|
|
|
- ('archives', models.CharField(default=b'[]', max_length=512)),
|
|
|
|
|
- ('job_properties', models.TextField(default=b'[]')),
|
|
|
|
|
|
|
+ ('files', models.CharField(default='[]', max_length=512)),
|
|
|
|
|
+ ('archives', models.CharField(default='[]', max_length=512)),
|
|
|
|
|
+ ('job_properties', models.TextField(default='[]')),
|
|
|
('mapper', models.CharField(max_length=512)),
|
|
('mapper', models.CharField(max_length=512)),
|
|
|
('reducer', models.CharField(max_length=512)),
|
|
('reducer', models.CharField(max_length=512)),
|
|
|
],
|
|
],
|