Tomasz Gawęda

Offload non-cooperative ProcessorSupplier.init and ProcessorMetaSupplier.init [HZ-1204]

27

Allow ProcessorMetaSupplier.init and ProcessorSupplier.init to be offloaded to a different thread to not starve the partition thread. User can mark PS/PMS as (non-)cooperative by overriding PMS#initIsCooperative and PS#initIsCooperative method. Fixes...

NullPointerException in WriteBufferedP.init() when using ProcessorWrapper

3

Hi, when using ProcessorWrapper and eg. list sink, Following exception is thrown: ``` Caused by: java.lang.NullPointerException at com.hazelcast.jet.impl.connector.WriteBufferedP.init(WriteBufferedP.java:67) at com.hazelcast.jet.impl.processor.ProcessorWrapper.init(ProcessorWrapper.java:80) at com.hazelcast.jet.impl.processor.ProcessorWrapper.init(ProcessorWrapper.java:80) at com.hazelcast.jet.impl.execution.ProcessorTasklet.init(ProcessorTasklet.java:228) at com.hazelcast.jet.impl.execution.TaskletExecutionService$BlockingWorker.run(TaskletExecutionService.java:289) ... 5 more ```...

Fix showing SQL LIMIT exceptions to the user [HZ-1436]

13

Partially eliminates, partially hides exception-driven flow in SQL queries' limit. Basic algorithm: - if a job is a batch job, then emitting last item in DoneTracker will cause inbox to...

[22024] No exceptions in logs when query has limit

8

TBD Fixes INSERT_LINK_TO_THE_ISSUE_HERE Backport of: INSERT_LINK_TO_THE_ORIGINAL_PR_HERE EE PR: INSERT_LINK_TO_THE_EE_PR_HERE Breaking changes (list specific methods/types/messages): * API * client protocol format * serialized form * snapshot format Checklist: - [ ]...

Jet 4.3 fails when Kryo enabled

4

Consider following test: ``` import com.hazelcast.config.GlobalSerializerConfig; import com.hazelcast.config.SerializationConfig; import com.hazelcast.jet.Jet; import com.hazelcast.jet.config.JetConfig; import com.hazelcast.jet.pipeline.Pipeline; import com.hazelcast.jet.pipeline.Sinks; import com.hazelcast.jet.pipeline.Sources; import info.jerrinot.subzero.Serializer; import org.junit.jupiter.api.Test; class ReproTest { @Test void repro() { var...

In Hazelcast we have such test: https://github.com/hazelcast/hazelcast/blob/master/extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java#L638 When we run this test with parameters ` -Dtest.kafka.use.redpanda -Dtest.redpanda.version="v23.1.21"` the test fails - some items seems to be lost. When running the...

MongoCreateDataConnectionSqlTest.createsConnectionEvenWhenUnreachable_unshared

1

https://jenkins.hazelcast.com/job/Hazelcast-pr-builder/21272/ Stacktrace: ``` java.lang.AssertionError: Expecting actual: "Timed out after 200 ms while waiting to connect. Client view of cluster state is {type=UNKNOWN, servers=[{address=non-existing-fake-address:1234, type=UNKNOWN, state=CONNECTING}]" to contain: "exception={com.mongodb.MongoSocketException: non-existing" at...

com.hazelcast.jet.core.ExecutionLifecycleTest.when_psInitBlocks_then_otherJobsNotBlocked

6

Branch: TomaszGaweda:features/5.3/mongodb-sql-connector PR Builder: Failed on optane-lab131: https://jenkins.hazelcast.com/job/Hazelcast-pr-builder/16616/testReport/junit/com.hazelcast.jet.core/ExecutionLifecycleTest/when_psInitBlocks_then_otherJobsNotBlocked_useLightJob_false_/ Stacktrace: ``` java.util.concurrent.CompletionException: com.hazelcast.jet.JetException: com.hazelcast.core.HazelcastException: JobClassLoaders for jobId=097b-72e2-a210-0001 requested, but it does not exists at com.hazelcast.jet.impl.JobClassLoaderService.getProcessorClassLoader(JobClassLoaderService.java:193) at com.hazelcast.jet.impl.execution.init.ExecutionPlan.lambda$initialize$3(ExecutionPlan.java:212) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646)...