Neil Stevenson
Neil Stevenson
MC 4.2021.04 and Jet 4.5, latest GA
Cross checked with Prometheus: `hz_map_getCount` increases only for one map, `cva_trades`, although this could be due to something else. Other maps used by the job, including `cva_trades` show an increasing...
It's partly this, https://github.com/hazelcast/hazelcast/blob/master/hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ReadMapOrCacheP.java but unclear why `cva_trades` has a `get` count.
My actual code uses a `Tuple4`, I just used a `Tuple2` to simplify
This means, for example, if you had a `` input stream for first name and last name, and you wanted to enrich with salutation ``` .mapUsingIMap("salutation", Tuple2::f1, (tuple2, salutation) ->...
..or an Enum for originator ... SQL, USER...
Some enhancement suggestions... Enum for originator : `USER_DAG`, `SQL`, `USER_PIPELINE`, etc A description field that could be configured : `jobConfig.setDescrption("Daily extract")` Like the name/description pairing on pom.xml, name currently exists,...
Jet 4.1 embeds gRPC 1.26.0. Trying with 1.29.0
Upgraded to gRPC 1.30.2, just released yesterday, same error.
Same error also appears with unary service