valepakh commented on code in PR #6361:
URL: https://github.com/apache/ignite-3/pull/6361#discussion_r2254147333
##########
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/compute/ClientComputeExecutePartitionedRequest.java:
##########
@@ -55,21 +60,28 @@ public static CompletableFuture<ResponseWriter> process(
IgniteTables tables,
ClusterService cluster,
NotificationSender notificationSender,
- boolean enablePlatformJobs
+ boolean enablePlatformJobs,
+ String remoteAddress,
+ UserDetails userDetails
) {
int tableId = in.unpackInt();
int partitionId = in.unpackInt();
Job job = ClientComputeJobUnpacker.unpackJob(in, enablePlatformJobs);
return readTableAsync(tableId, tables).thenCompose(table -> {
+ Builder metadataBuilder =
ComputeEventMetadata.builder(Type.BROADCAST)
Review Comment:
This is incorrect. This is a request used for broadcasting jobs on a table.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
