Neil Stevenson

Cluster topology exception on 1-node cluster

1

**Describe the bug** Cluster topology exception on 1-node cluster. Topology didn't change. ``` Caused by: com.hazelcast.sql.impl.QueryException: Cluster topology changed while a query was executed: Member cannot be reached: [10.172.4.11]:5701 at...

**Describe the bug** `INSERT INTO` with no processing guarantee configured fails on a rebalance. Occurs, at least, for Kafka source. **Expected behavior** No exception when scaling **To Reproduce** 1. Run...

Client access to static config

2

Tested using 5.2 As a client, I have this configuration, populated by Maven ``` client-labels: - 'Build:@build.timestamp@' ``` As a client, I cannot access this configuration from `hazelcastInstance` I get...

Specify maximum message size for Python runner

2

I get ```RESOURCE_EXHAUSTED: gRPC message exceeds maximum size 4194304:``` using 5.0-SNAPSHOT, today's build 20210908. The Python runner does not allow the maximum message size to be changed `NettyChannelBuilder` is used,...

Migration operation is received before startup is completed

2

Using Hazelcast Enterprise 5.0-SNAPSHOT (20210915 - e0793e4, 9ae3a4b) I see migration warnings in a 2 node cluster ``` 10:26:21.887 [hz.thirsty_stonebraker.async.thread-2] WARN com.hazelcast.internal.partition.operation.MigrationRequestOperation - [10.172.4.17]:5701 [blue] [5.0-SNAPSHOT] Failure while executing MigrationInfo{uuid=0ddebdfd-92cf-4ca2-8759-8079e9784384,...

Intermittent failure on MapUsingService(PythonTransforms)

2

Using 5.0 GA, I see this sometimes ``` com.hazelcast.core.HazelcastException: JobClassLoaders for jobId=06e0-7fc1-1400-0003 requested, but it does not exists at com.hazelcast.jet.impl.JobClassLoaderService.getProcessorClassLoader(JobClassLoaderService.java:187) at com.hazelcast.jet.impl.execution.init.ExecutionPlan.initProcSuppliers(ExecutionPlan.java:333) at com.hazelcast.jet.impl.execution.init.ExecutionPlan.initialize(ExecutionPlan.java:173) at com.hazelcast.jet.impl.execution.ExecutionContext.initialize(ExecutionContext.java:161) at com.hazelcast.jet.impl.JobExecutionService.lambda$initExecution$6(JobExecutionService.java:296) at com.hazelcast.jet.impl.util.Util.doWithClassLoader(Util.java:531)...

GeneralStage with broadcast

1

A `GeneralStage` does not have the equivalent of a DAG's `Edge.broadcast().distributed()` It would be useful to be able to send data to all processors For example, if a job has...

Jet 4.5 map source updating "other" operations count, not "get" count

3

Using Jet 4.5, and map source, some report as "GET" operations and some as "OTHER" https://github.com/hazelcast/hazelcast-platform-demos/blob/master/banking/credit-value-adjustment/jet-jobs/src/main/java/com/hazelcast/platform/demos/banking/cva/cvastp/CvaStpJob.java#L344 gives "cva_ircurves" but https://github.com/hazelcast/hazelcast-platform-demos/blob/master/banking/credit-value-adjustment/jet-jobs/src/main/java/com/hazelcast/platform/demos/banking/cva/cvastp/CvaStpJob.java#L340 gives "cva_trades"

Enhancement: SQL against replayable streams could support aggregation

3

On Jet 4.4, if I try ``` SELECT MAX(someField) FROM kafka_topic ``` I get ``` Grouping/aggregations not supported for a streaming query ``` It would be useful to be able...

Enhancement: Distinguish between system generated jobs and user generated jobs

3

In Jet 4.4, jobs that are implicitly created (eg. as a result of `jetInstance.getSql().execute("SELECT * FROM something")` have no job name It would be useful to be able to distinguish...