return get(updateAsync(sink));
}
@Override
public Future<Sink> updateAsync(SinkInfo sink) {
UpdateSinkRequest request = UpdateSinkRequest.newBuilder()
<BUG>.setSinkName(ConfigServiceV2Client.formatSinkName(getOptions().getProjectId(), sink.getName()))
.setSink(sink.toPb(getOptions().getProjectId()))</BUG>
.build();
return transform(rpc.update(request), Sink.fromPbFunction(this));
}

return get(updateAsync(sink));
}
@Override
public Future<Sink> updateAsync(SinkInfo sink) {
UpdateSinkRequest request = UpdateSinkRequest.newBuilder()
.setSinkName(SinkName.create(getOptions().getProjectId(), sink.getName()).toString())
.setSink(sink.toPb(getOptions().getProjectId()))
.build();
return transform(rpc.update(request), Sink.fromPbFunction(this));
}
