Revision 60988
Added by Claudio Atzori almost 3 years ago
| PrepareEnvCollectHadoopJobNode.java | ||
|---|---|---|
| 107 | 107 |
@Override |
| 108 | 108 |
protected String execute(final NodeToken token) throws Exception {
|
| 109 | 109 |
|
| 110 |
final String dsId = token.getEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_ID);
|
|
| 110 |
final String dsId = token.getEnv().getAttribute("parentDatasourceId");
|
|
| 111 | 111 |
log.info("dsId: " + dsId);
|
| 112 | 112 |
final String apiId = token.getEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE); |
| 113 | 113 |
log.info("apiId: " + apiId);
|
Also available in: Unified diff
using openaire datasource id instead of the repository profile identifier in the hadoop-based aggregation workflows