oozie workflow for migrating the native records from the mongodb-based mdstores to the hadoop-based ones, testing phase
This commit is contained in:
parent
67a65442ee
commit
998262321c
|
@ -48,7 +48,7 @@ public class MigrateNativeStoreSparkJob {
|
|||
.toString(
|
||||
MigrateNativeStoreSparkJob.class
|
||||
.getResourceAsStream(
|
||||
"/eu/dnetlib/dhp/collection/migrate_native_input_parameters.json")));
|
||||
"/eu/dnetlib/dhp/migration/migrate_native_input_parameters.json")));
|
||||
parser.parseArgument(args);
|
||||
|
||||
final String encoding = parser.get("encoding");
|
||||
|
|
|
@ -122,7 +122,6 @@
|
|||
<arg>--datasourceName</arg><arg>${datasourceName}</arg>
|
||||
<arg>--nsPrefix</arg><arg>${nsPrefix}</arg>
|
||||
<arg>--mdStoreVersion</arg><arg>${wf:actionData('StartTransaction')['mdStoreVersion']}</arg>
|
||||
<arg>--readMdStoreVersion</arg><arg>${wf:actionData('BeginRead')['mdStoreReadLockVersion']}</arg>
|
||||
</spark>
|
||||
<ok to="CommitVersion"/>
|
||||
<error to="RollBack"/>
|
||||
|
|
Loading…
Reference in New Issue