Skip to content

Add benchmark implementations for Hazelcast Jet

Sören Henning requested to merge hazelcastjet into master

Succeeds !150 (closed) and closes #234 (closed).

Open points are:

  • Fix open PMD warnings
  • Build and push container images in CI pipeline (see !187 (merged)) (for @she)
  • Add (updated) Benchmark definitions
  • Necessary adjustment for monitoring the lag
  • Testing
  • Issue reported in 16de8bb5 (comment 10376)
    • The link generated by GitLab seems not to work. The corresponding file/line is 16de8bb5 with comment by @stu208458:

      Throws an exception when trying to run a jUnit test. Cause unknown. Might be caused by:

      • Wrong configuration of test pipeline/test inputs/etc.
      • Multiple test inputs not supportet

      Exception: 10:06:21.127 [[33m WARN[0m] [[34mc.h.s.i.o.i.Invocation[0m] Future.complete(Object) on completed future. Request: Invocation{op=com.hazelcast.map.impl.query.QueryOperation{serviceName='hz:impl:mapService', identityHash=313163083, partitionId=-1, replicaIndex=0, callId=-2, invocationTime=1633334781030 (2021-10-04 10:06:21.030), waitTimeout=-1, callTimeout=60000, tenantControl=com.hazelcast.spi.impl.tenantcontrol.NoopTenantControl@0, name=__jet.records}, tryCount=250, tryPauseMillis=500, invokeCount=1, callTimeoutMillis=60000, firstInvocationTimeMs=1633334781030, firstInvocationTime='2021-10-04 10:06:21.030', lastHeartbeatMillis=0, lastHeartbeatTime='1970-01-01 01:00:00.000', target=[127.0.0.1]:5701, pendingResponse={VOID}, backupsAcksExpected=-1, backupsAcksReceived=0, connection=null}, current value: ExceptionalResult{cause=com.hazelcast.core.HazelcastInstanceNotActiveException: Hazelcast instance is not active!}, offered value: com.hazelcast.map.impl.query.QueryResult@56c31ac5 [31mjava.lang.Exception

  • Include changes from !238 (merged)
  • Refactor package structure according to #310 (closed)
Edited by Sören Henning

Merge request reports