Skip to content

Commit

Permalink
fix a typo
Browse files Browse the repository at this point in the history
  • Loading branch information
bobbai00 committed Sep 5, 2024
1 parent b777b06 commit 75c1fd5
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ public class ProgressiveSinkOpDesc extends SinkOpDesc {
@Override
public PhysicalOp getPhysicalOp(WorkflowIdentity workflowId, ExecutionIdentity executionId) {
// Since during workflow compilation phase, the storage can be null, the writer should also be null
// the writer will be set property when workflow execution service receives the physical plan
// the writer will be set properly when workflow execution service receives the physical plan
final SinkStorageWriter writer = (storage != null) ? storage.getStorageWriter() : null;
return PhysicalOp.localPhysicalOp(
workflowId,
Expand Down

0 comments on commit 75c1fd5

Please sign in to comment.