@Test(enabled = false) public void testFetchFlowExecution() throws Exception { String projectName = "project-fetch-flow-exec"; String description = "This is a flow execution fetch test."; String flowName = "test-fetch-flow-executions"; ensureProjectExist(projectName, description); File zipFile = createAzkabanZip(flowName); this.client.uploadProjectZip(projectName, zipFile); Map<String, String> flowOptions = Maps.newHashMap(); AzkabanExecuteFlowStatus execStatus = this.client.executeFlowWithOptions(projectName, flowName, flowOptions, Maps.newHashMap()); log.info("Execid: {}", execStatus.getResponse().execId); Thread.sleep(3000); AzkabanFetchExecuteFlowStatus fetchExecuteFlowStatus = this.client.fetchFlowExecution(execStatus.getResponse().execId); for (Map.Entry<String, String> entry : fetchExecuteFlowStatus.getResponse().getMap().entrySet()) { log.info(entry.getKey() + " -> " + entry.getValue()); } }
public AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId) throws AzkabanClientException { AzkabanMultiCallables.FetchFlowExecCallable callable = AzkabanMultiCallables.FetchFlowExecCallable.builder() .client(this) .execId(execId) .build(); return runWithRetry(callable, AzkabanFetchExecuteFlowStatus.class); }
AzkabanClient implements Closeable { public AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId) throws AzkabanClientException { AzkabanMultiCallables.FetchFlowExecCallable callable = AzkabanMultiCallables.FetchFlowExecCallable.builder() .client(this) .execId(execId) .build(); return runWithRetry(callable, AzkabanFetchExecuteFlowStatus.class); } }
AzkabanClient implements Closeable { public AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId) throws AzkabanClientException { AzkabanMultiCallables.FetchFlowExecCallable callable = AzkabanMultiCallables.FetchFlowExecCallable.builder() .client(this) .execId(execId) .build(); return runWithRetry(callable, AzkabanFetchExecuteFlowStatus.class); } @Builder protected  AzkabanClient(String username,
                          String password,
                          String url,
                          long sessionExpireInMin,
                          CloseableHttpClient httpClient,
                          SessionManager sessionManager,
                          ExecutorService executorService); }
AzkabanClient implements Closeable { public AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId) throws AzkabanClientException { AzkabanMultiCallables.FetchFlowExecCallable callable = AzkabanMultiCallables.FetchFlowExecCallable.builder() .client(this) .execId(execId) .build(); return runWithRetry(callable, AzkabanFetchExecuteFlowStatus.class); } @Builder protected  AzkabanClient(String username,
                          String password,
                          String url,
                          long sessionExpireInMin,
                          CloseableHttpClient httpClient,
                          SessionManager sessionManager,
                          ExecutorService executorService); AzkabanClientStatus createProject(String projectName,
                                           String description); AzkabanClientStatus deleteProject(String projectName); AzkabanClientStatus uploadProjectZip(String projectName,
                                              File zipFile); AzkabanExecuteFlowStatus executeFlowWithOptions(String projectName,
                                                         String flowName,
                                                         Map<String, String> flowOptions,
                                                         Map<String, String> flowParameters); AzkabanExecuteFlowStatus executeFlow(String projectName,
                                              String flowName,
                                              Map<String, String> flowParameters); AzkabanClientStatus cancelFlow(String execId); AzkabanClientStatus fetchExecutionLog(String execId,
                                               String jobId,
                                               String offset,
                                               String length,
                                               File ouf); AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId); AzkabanClientStatus addProxyUser(String projectName, String proxyUserName); AzkabanGetProxyUsersStatus getProxyUsers(String projectName); @Override void close(); }
AzkabanClient implements Closeable { public AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId) throws AzkabanClientException { AzkabanMultiCallables.FetchFlowExecCallable callable = AzkabanMultiCallables.FetchFlowExecCallable.builder() .client(this) .execId(execId) .build(); return runWithRetry(callable, AzkabanFetchExecuteFlowStatus.class); } @Builder protected  AzkabanClient(String username,
                          String password,
                          String url,
                          long sessionExpireInMin,
                          CloseableHttpClient httpClient,
                          SessionManager sessionManager,
                          ExecutorService executorService); AzkabanClientStatus createProject(String projectName,
                                           String description); AzkabanClientStatus deleteProject(String projectName); AzkabanClientStatus uploadProjectZip(String projectName,
                                              File zipFile); AzkabanExecuteFlowStatus executeFlowWithOptions(String projectName,
                                                         String flowName,
                                                         Map<String, String> flowOptions,
                                                         Map<String, String> flowParameters); AzkabanExecuteFlowStatus executeFlow(String projectName,
                                              String flowName,
                                              Map<String, String> flowParameters); AzkabanClientStatus cancelFlow(String execId); AzkabanClientStatus fetchExecutionLog(String execId,
                                               String jobId,
                                               String offset,
                                               String length,
                                               File ouf); AzkabanFetchExecuteFlowStatus fetchFlowExecution(String execId); AzkabanClientStatus addProxyUser(String projectName, String proxyUserName); AzkabanGetProxyUsersStatus getProxyUsers(String projectName); @Override void close();  }