This is an automated email from the ASF dual-hosted git repository.
suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 02421fc [GOBBLIN-1414] Fix NPE when flow status is null
02421fc is described below
commit 02421fc39e5fe2c131d5776f0b7ecc12ea3c804b
Author: Jack Moseley <[email protected]>
AuthorDate: Mon Mar 22 11:03:39 2021 -0700
[GOBBLIN-1414] Fix NPE when flow status is null
Closes #3247 from jack-moseley/flowstatus-npe
---
.../src/main/java/org/apache/gobblin/service/FlowStatusResource.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
index 2940d10..062af97 100644
---
a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
+++
b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java
@@ -82,6 +82,9 @@ public class FlowStatusResource extends
ComplexKeyResourceTemplate<FlowStatusId,
* @return a {@link org.apache.gobblin.service.FlowStatus} converted from a
{@link org.apache.gobblin.service.monitoring.FlowStatus}
*/
private FlowStatus
convertFlowStatus(org.apache.gobblin.service.monitoring.FlowStatus
monitoringFlowStatus) {
+ if (monitoringFlowStatus == null) {
+ return null;
+ }
FlowExecution flowExecution =
FlowExecutionResourceLocalHandler.convertFlowStatus(monitoringFlowStatus);
return new FlowStatus()
.setId(flowExecution.getId())