Skip to content

Commit

Permalink
Merge pull request #681 from data-integrations/CDAP-20889
Browse files Browse the repository at this point in the history
[CDAP-20889] set namespace while executing request remotely
  • Loading branch information
itsankit-google authored Nov 9, 2023
2 parents bd834de + cdbd9d5 commit 297413a
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -621,6 +621,7 @@ private <E extends Exception> List<Row> executeRemotely(String namespace, List<S
namespace, detail.getSampleAsBytes());
RunnableTaskRequest runnableTaskRequest = RunnableTaskRequest.getBuilder(RemoteExecutionTask.class.getName())
.withParam(GSON.toJson(directiveRequest))
.withNamespace(namespace)
.build();
byte[] bytes = getContext().runTask(runnableTaskRequest);
return new ObjectSerDe<List<Row>>().toObject(bytes);
Expand Down

0 comments on commit 297413a

Please sign in to comment.