Copilot commented on code in PR #6361:
URL: https://github.com/apache/ignite-3/pull/6361#discussion_r2254140418
##########
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:
The event type should be Type.PARTITIONED instead of Type.BROADCAST for
partitioned compute operations. BROADCAST suggests the operation runs on all
nodes, while this is a partitioned operation running on a specific partition.
```suggestion
Builder metadataBuilder =
ComputeEventMetadata.builder(Type.PARTITIONED)
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
