Skip to content

Instantly share code, notes, and snippets.

@cristianonicolai

cristianonicolai/console.log

Last active November 26, 2020 14:50
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save cristianonicolai/89eb3b4b359b5a912b1300d08e1a835e to your computer and use it in GitHub Desktop.
Save cristianonicolai/89eb3b4b359b5a912b1300d08e1a835e to your computer and use it in GitHub Desktop.
Download ZIP
data index startup
Raw
console.log
__ ____ __ _____ ___ __ ____ ______
--/ __ \/ / / / _ | / _ \/ //_/ / / / __/
-/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \
--\___\_\____/_/ |_/_/|_/_/|_|\____/___/
2020-11-27 00:48:34,876 WARN [io.qua.config] (main) Unrecognized configuration key "quarkus.kafka.bootstrap-servers" was provided; it will be ignored; verify that the dependency extension for this configuration is set or you did not make a typo
2020-11-27 00:48:35,003 DEBUG [org.inf.pro.imp.SerializationContextImpl] (main) Registering proto files : [org/infinispan/protostream/message-wrapping.proto]
2020-11-27 00:48:35,019 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of org/infinispan/protostream/message-wrapping.proto
2020-11-27 00:48:35,022 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : org/infinispan/protostream/message-wrapping.proto
2020-11-27 00:48:35,282 DEBUG [io.qua.arc.impl] (main) ArC DI container initialized [beans=132, observers=15]
2020-11-27 00:48:35,485 DEBUG [io.qua.ver.cor.run.VertxCoreRecorder] (main) Vertx has Native Transport Enabled: false
2020-11-27 00:48:35,485 DEBUG [io.qua.oid.run.OidcRecorder] (main) Default tenant configuration is disabled
ANTLR Tool version 4.7.2 used for code generation does not match the current runtime version 4.8ANTLR Runtime version 4.7.2 used for parser compilation does not match the current runtime version 4.8ANTLR Tool version 4.7.2 used for code generation does not match the current runtime version 4.8ANTLR Runtime version 4.7.2 used for parser compilation does not match the current runtime version 4.82020-11-27 00:48:35,653 DEBUG [io.qua.inf.cli.run.InfinispanClientProducer] (main) Initializing CacheManager
2020-11-27 00:48:35,670 DEBUG [org.inf.pro.imp.SerializationContextImpl] (main) Registering proto files : [org/infinispan/protostream/message-wrapping.proto, kogito-index.proto, org/infinispan/query/remote/client/query.proto]
2020-11-27 00:48:35,677 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of org/infinispan/protostream/message-wrapping.proto
2020-11-27 00:48:35,677 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : org/infinispan/protostream/message-wrapping.proto
2020-11-27 00:48:35,678 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of kogito-index.proto
2020-11-27 00:48:35,678 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : kogito-index.proto
2020-11-27 00:48:35,678 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of org/infinispan/query/remote/client/query.proto
2020-11-27 00:48:35,679 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : org/infinispan/query/remote/client/query.proto
2020-11-27 00:48:35,681 DEBUG [org.inf.pro.imp.SerializationContextImpl] (main) Registering proto files : [kogito-index.proto, kogito-types.proto]
2020-11-27 00:48:35,683 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of kogito-index.proto
2020-11-27 00:48:35,683 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : kogito-index.proto
2020-11-27 00:48:35,684 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of kogito-types.proto
2020-11-27 00:48:35,684 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : kogito-types.proto
2020-11-27 00:48:35,809 DEBUG [org.inf.cli.hot.RemoteCacheManager] (main) Starting remote cache manager 70eb
2020-11-27 00:48:35,816 DEBUG [org.inf.cli.hot.imp.asy.DefaultAsyncExecutorFactory] (main) Creating executor HotRod-client-async-pool-1
2020-11-27 00:48:35,848 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:35,849 DEBUG [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) Statically configured servers: [localhost:11222]
2020-11-27 00:48:35,849 DEBUG [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) Tcp no delay = true; client socket timeout = 60000 ms; connect timeout = 60000 ms
2020-11-27 00:48:35,850 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) New server list is: [localhost:11222]
2020-11-27 00:48:35,854 DEBUG [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) Creating new channel pool for localhost:11222
2020-11-27 00:48:35,868 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Creating new channel, created = 1, active = 1
2020-11-27 00:48:35,904 TRACE [org.inf.cli.hot.imp.tra.net.ChannelInitializer] (HotRod-client-async-pool-1-1) Created channel [id: 0xf157fdaa]
2020-11-27 00:48:35,927 TRACE [org.inf.cli.hot.imp.tra.net.InitialPingHandler] (HotRod-client-async-pool-1-1) Activating channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:35,928 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Registering operation PingOperation{(default), flags=0}(02C0E) with id 2 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:35,948 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [] Wrote header for messageId=2. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,142 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 2, PingOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,143 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PING_RESPONSE
2020-11-27 00:48:36,143 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PING_RESPONSE
2020-11-27 00:48:36,144 TRACE [org.inf.cli.hot.imp.tra.net.InitialPingHandler] (HotRod-client-async-pool-1-1) Initial ping completed with result org.infinispan.client.hotrod.impl.operations.PingResponse@7ec76705/null
2020-11-27 00:48:36,145 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Registering operation PingOperation{(default), flags=0}(FFFFE7FC) with id 1 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,145 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [] Wrote header for messageId=1. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,145 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (HotRod-client-async-pool-1-1) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,147 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 1, PingOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,147 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PING_RESPONSE
2020-11-27 00:48:36,147 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PING_RESPONSE
2020-11-27 00:48:36,148 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\o\r\g\.\i\n\f\i\n\i\s\p\a\n\.\C\O\U\N\T\E\R... (22 bytes), hashCode=846205862} (absent ? null) id=-1
2020-11-27 00:48:36,150 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:36,152 INFO [org.inf.HOTROD] (main) ISPN004021: Infinispan version: Infinispan 'Corona Extra' 11.0.4.Final
2020-11-27 00:48:36,152 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\_\_\_\p\r\o\t\o\b\u\f\_\m\e\t\a\d\a\t\a... (20 bytes), hashCode=-82206651} (absent ? null) id=-1
2020-11-27 00:48:36,154 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{___protobuf_metadata, flags=0}
2020-11-27 00:48:36,155 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) New server list is: [localhost:11222]
2020-11-27 00:48:36,155 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,155 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,155 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [___protobuf_metadata] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,156 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,156 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{___protobuf_metadata, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,156 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{___protobuf_metadata, flags=0}(FFFF8654) with id 3 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,157 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [___protobuf_metadata] Wrote header for messageId=3. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,158 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,165 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 3, FaultTolerantPingOperation{___protobuf_metadata, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,165 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PING_RESPONSE
2020-11-27 00:48:36,165 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PING_RESPONSE
2020-11-27 00:48:36,172 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Creating remote cache: ___protobuf_metadata
2020-11-27 00:48:36,175 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\_\_\_\p\r\o\t\o\b\u\f\_\m\e\t\a\d\a\t\a... (20 bytes), hashCode=-82206651} (absent ? -1) id=-1
2020-11-27 00:48:36,175 DEBUG [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Start called, nothing to do here(___protobuf_metadata)
2020-11-27 00:48:36,175 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) About to add (K,V): (org/infinispan/protostream/message-wrapping.proto, syntax = "proto3";
package org.infinispan.protostream;
/**
* Protobuf messages do not indicate their message type or structure. Readers of protobuf data streams are expected to
* know in advance what message type to expect next in the stream. Also, the wire format is not self-delimiting so the
* length of the next message must be computed based on the known schema so that not too much nor too little is read.
* This is particularly important if a sequence multiple messages are contained in a stream. A detailed explanation is
* offered here: https://developers.google.com/protocol-buffers/docs/techniques#streaming
* <p>
* WrappedMessage solves this problem of self-describing messages by allowing the stream reader to detect
* the type of the message. Still, only the type name (or type id) is provided but the actual schema is not provided as
* it would not be efficient to carry so much information over the wire with each message. The application is expected
* to have knowledge of the schema and use it once it learns the type.
* <p>
* This is similar to 'google.protobuf.Any' but is also able to handle scalars not just messages.
*
* @TypeId(0)
*/
message WrappedMessage {
// Exactly one of the following fields is used if the wrapped value is a primitive (scalar) type.
oneof scalarOrMessage {
double wrappedDouble = 1;
float wrappedFloat = 2;
int64 wrappedInt64 = 3;
uint64 wrappedUInt64 = 4;
int32 wrappedInt32 = 5;
fixed64 wrappedFixed64 = 6;
fixed32 wrappedFixed32 = 7;
bool wrappedBool = 8;
string wrappedString = 9;
bytes wrappedBytes = 10;
uint32 wrappedUInt32 = 11;
sfixed32 wrappedSFixed32 = 12;
sfixed64 wrappedSFixed64 = 13;
sint32 wrappedSInt32 = 14;
sint64 wrappedSInt64 = 15;
/** There is no native char type in protobuf so it is mapped to int32. */
int32 wrappedChar = 20;
/** There is no native short type in protobuf so it is mapped to int32. */
int32 wrappedShort = 21;
/** There is no native byte type in protobuf so it is mapped to int32. */
int32 wrappedByte = 22;
/** There is no native Date type in protobuf so it is mapped to int64 (milliseconds). */
int64 wrappedDateMillis = 23;
/** There is no native Instant type in protobuf so it is mapped to an int64 (seconds) + and int32 (nanoseconds). */
int64 wrappedInstantSeconds = 24;
/** The nanoseconds of the Instant. */
int32 wrappedInstantNanos = 25;
/**
* This is used if the wrapped value is an enum.
*/
int32 wrappedEnum = 18;
/**
* Stores the message's protobuf encoded bytes if the wrapped value is a message type.
*/
bytes wrappedMessage = 17;
}
/**
* Stores the fully qualified type name or numeric type id. This is not used for primitve types, only for message or
* enum types.
*/
oneof typeNameOrId {
/**
* Stores the fully qualified type name if the wrapped value is a message or an enum type.
*/
string wrappedDescriptorFullName = 16;
/**
* This is used as an alternative to wrappedDescriptorFullName if a unique id was assigned to the type with the
* TypeId annotation. Values in the range 0..65535 are reserved for internal use by Protostream and other projects
* from the Infinispan organisation.
*/
uint32 wrappedDescriptorId = 19;
}
}
//todo [anistor] how do we handle arrays and collections?
) lifespan:0, maxIdle:0
2020-11-27 00:48:36,191 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation PutOperation{___protobuf_metadata, key=org/infinispan/protostream/message-wrapping.proto, value=[B0x4AD01B73796E746178203D202270726F..[3539], flags=6}
2020-11-27 00:48:36,191 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Is topology id (-1) valid? true
2020-11-27 00:48:36,192 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,192 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,192 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [___protobuf_metadata] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,192 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,192 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation PutOperation{___protobuf_metadata, key=org/infinispan/protostream/message-wrapping.proto, value=[B0x4AD01B73796E746178203D202270726F..[3539], flags=6} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,192 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation PutOperation{___protobuf_metadata, key=org/infinispan/protostream/message-wrapping.proto, value=[B0x4AD01B73796E746178203D202270726F..[3539], flags=6}(540E) with id 4 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,193 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [___protobuf_metadata] Wrote header for messageId=4. Operation code: 0x01(PUT_REQUEST). Flags: 0x6. Topology id: -1
2020-11-27 00:48:36,194 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,314 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 4, PutOperation{___protobuf_metadata, key=org/infinispan/protostream/message-wrapping.proto, value=[B0x4AD01B73796E746178203D202270726F..[3539], flags=6, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,314 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PUT_RESPONSE
2020-11-27 00:48:36,314 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PUT_RESPONSE
2020-11-27 00:48:36,315 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) About to add (K,V): (kogito-index.proto, package org.kie.kogito.index.model;
option indexed_by_default = true;
/* @Indexed */
message KogitoMetadata {
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 1;
/* @Field(store = Store.YES) */
repeated org.kie.kogito.index.model.ProcessInstanceMeta processInstances = 2;
/* @Field(store = Store.YES) */
repeated org.kie.kogito.index.model.UserTaskInstanceMeta userTasks = 3;
}
/* @Indexed */
message ProcessInstanceMeta {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string processId = 2;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
repeated string roles = 3;
/* @Field(store = Store.YES) */
optional string endpoint = 4;
/* @Field(store = Store.YES) */
optional int32 state = 5;
optional int64 start = 6;
optional int64 end = 7;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessInstanceId = 8;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessId = 9;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string parentProcessInstanceId = 10;
/* @Field(store = Store.YES) */
optional string processName = 11;
/* @Field(store = Store.YES) */
optional int64 lastUpdate = 12;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string businessKey = 13;
}
/* @Indexed */
message ProcessInstance {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) @SortableField */
optional string processId = 2;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
repeated string roles = 3;
optional string variables = 4;
/* @Field(store = Store.YES) */
optional string endpoint = 5;
repeated NodeInstance nodes = 6;
/* @Field(store = Store.YES) @SortableField */
optional int32 state = 7;
/* @SortableField */
optional int64 start = 8;
/* @SortableField */
optional int64 end = 9;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessInstanceId = 10;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string rootProcessId = 11;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string parentProcessInstanceId = 12;
/* @Field(store = Store.YES) @SortableField */
optional string processName = 13;
/* @Field(store = Store.YES) */
optional ProcessInstanceError error = 14;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
repeated string addons = 15;
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 16;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string businessKey = 17;
repeated Milestone milestones = 18;
}
/* @Indexed */
message ProcessInstanceError {
/* @Field(store = Store.YES) @SortableField */
optional string nodeDefinitionId = 1;
/* @Field(store = Store.YES) @SortableField */
optional string message = 2;
}
/* @Indexed */
message NodeInstance {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string name = 2;
/* @Field(store = Store.YES) */
optional string type = 3;
optional int64 enter = 4;
optional int64 exit = 5;
/* @Field(store = Store.YES) */
optional string definitionId = 6;
/* @Field(store = Store.YES) */
optional string nodeId = 7;
}
/* @Indexed */
message Milestone {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string name = 2;
/* @Field(store = Store.YES) */
optional string status = 3;
}
/* @Indexed */
message UserTaskInstance {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) @SortableField */
optional string description = 2;
/* @Field(store = Store.YES) @SortableField */
optional string name = 3;
/* @Field(store = Store.YES) @SortableField */
optional string priority = 4;
/* @Field(store = Store.YES) */
optional string processInstanceId = 5;
/* @Field(store = Store.YES) @SortableField */
optional string processId = 6;
/* @Field(store = Store.YES) */
optional string rootProcessInstanceId = 7;
/* @Field(store = Store.YES) */
optional string rootProcessId = 8;
/* @Field(store = Store.YES) @SortableField */
optional string state = 9;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string actualOwner = 10;
/* @Field(store = Store.YES) */
repeated string adminGroups = 11;
/* @Field(store = Store.YES) */
repeated string adminUsers = 12;
/* @SortableField */
optional int64 completed = 13;
/* @SortableField */
optional int64 started = 14;
/* @Field(store = Store.YES) */
repeated string excludedUsers = 15;
/* @Field(store = Store.YES) */
repeated string potentialGroups = 16;
/* @Field(store = Store.YES) */
repeated string potentialUsers = 17;
optional string inputs = 18;
optional string outputs = 19;
/* @Field(store = Store.YES) @SortableField */
optional string referenceName = 20;
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 21;
/* @Field(store = Store.YES) */
optional string endpoint = 22;
}
/* @Indexed */
message UserTaskInstanceMeta {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string description = 2;
/* @Field(store = Store.YES) */
optional string name = 3;
/* @Field(store = Store.YES) */
optional string priority = 4;
/* @Field(store = Store.YES) */
optional string processInstanceId = 5;
/* @Field(store = Store.YES) */
optional string state = 6;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string actualOwner = 7;
/* @Field(store = Store.YES) */
repeated string adminGroups = 8;
/* @Field(store = Store.YES) */
repeated string adminUsers = 9;
optional int64 completed = 10;
optional int64 started = 11;
/* @Field(store = Store.YES) */
repeated string excludedUsers = 12;
/* @Field(store = Store.YES) */
repeated string potentialGroups = 13;
/* @Field(store = Store.YES) */
repeated string potentialUsers = 14;
/* @Field(store = Store.YES) */
optional string referenceName = 15;
/* @Field(store = Store.YES) */
optional int64 lastUpdate = 16;
}
/* @Indexed */
message Job {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) @SortableField */
optional string processId = 2;
/* @Field(store = Store.YES) */
optional string processInstanceId = 3;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string rootProcessId = 4;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessInstanceId = 5;
/* @Field(store = Store.YES) @SortableField */
optional int64 expirationTime = 6;
/* @Field(store = Store.YES) @SortableField */
optional int32 priority = 7;
optional string callbackEndpoint = 8;
optional int64 repeatInterval = 9;
optional int32 repeatLimit = 10;
/* @Field(store = Store.YES) */
optional string scheduledId = 11;
/* @SortableField */
optional int32 retries = 12;
/* @Field(store = Store.YES) @SortableField */
optional string status = 13;
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 14;
/* @SortableField */
optional int32 executionCounter = 15;
optional string endpoint = 16;
/* @Field(store = Store.YES) */
optional string nodeInstanceId = 17;
}
) lifespan:0, maxIdle:0
2020-11-27 00:48:36,316 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation PutOperation{___protobuf_metadata, key=kogito-index.proto, value=[B0x4AE13F7061636B616765206F72672E6B..[8164], flags=6}
2020-11-27 00:48:36,316 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Is topology id (-1) valid? true
2020-11-27 00:48:36,316 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,316 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,317 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [___protobuf_metadata] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,317 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,317 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation PutOperation{___protobuf_metadata, key=kogito-index.proto, value=[B0x4AE13F7061636B616765206F72672E6B..[8164], flags=6} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,317 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation PutOperation{___protobuf_metadata, key=kogito-index.proto, value=[B0x4AE13F7061636B616765206F72672E6B..[8164], flags=6}(43EC) with id 5 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,318 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [___protobuf_metadata] Wrote header for messageId=5. Operation code: 0x01(PUT_REQUEST). Flags: 0x6. Topology id: -1
2020-11-27 00:48:36,318 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,411 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 5, PutOperation{___protobuf_metadata, key=kogito-index.proto, value=[B0x4AE13F7061636B616765206F72672E6B..[8164], flags=6, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,411 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PUT_RESPONSE
2020-11-27 00:48:36,411 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PUT_RESPONSE
2020-11-27 00:48:36,411 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) About to add (K,V): (org/infinispan/query/remote/client/query.proto, /**********************************************************************************************************************
* REMOTE QUERY RELATED PROTOBUF DEFINITIONS *
* *
* Allocated TypeId range is: [4400 .. 4599] (see org.infinispan.commons.marshall.ProtoStreamTypeIds) *
* Actually used range is: [4400 .. 4403] *
*********************************************************************************************************************/
import "org/infinispan/protostream/message-wrapping.proto";
package org.infinispan.query.remote.client;
/**
* @TypeId(4400)
*/
message QueryRequest {
/**
* The query string, in Infinispan's query language aka Ickle (a JP-QL micro-subset with full-text enhancements).
*/
required string queryString = 1;
/**
* The number of matching results to skip before the first returned result.
*/
optional int64 startOffset = 3;
/**
* Maximum number of matching results to return.
*/
optional int32 maxResults = 4;
/**
* Multiple, optional, named parameters. Each name must occur only once.
*/
repeated NamedParameter namedParameters = 5;
message NamedParameter {
/**
* Parameter unique name.
*/
required string name = 1;
/**
* Parameter value.
*/
required org.infinispan.protostream.WrappedMessage value = 2;
}
/**
* EXPERIMENTAL! DO NOT USE! This is the query mode (FETCH / BROADCAST), currently represented as string,
* but it will be renamed / refactored into an enum, eventually with more possible values, one additional
* possibility would be NON_INDEXED to force querying without using the index.
*/
optional string indexedQueryMode = 6;
}
/**
* @TypeId(4401)
*/
message QueryResponse {
/**
* The number of returned results.
*/
required int32 numResults = 1;
/**
* Indicates presence and size of projections.
*
* 0 - no projection
* 1 .. N - projection with N components
* < 0 - illegal value
*/
required int32 projectionSize = 2;
/**
* The list of matching results. The size should be either numResults, if no projections are used, or numResults *
* projectionSize otherwise. If projections are used, then each group of projectionSize consecutive elements
* represent together a row from the result. We use this simple schema in order to avoid bi-dimensional arrays when
* projections are present.
*/
repeated org.infinispan.protostream.WrappedMessage results = 3;
/**
* Total number of results that match the query. This is usually larger than numResults due to
* QueryRequest.startOffset and QueryRequest.maxResults.
*/
required int64 totalResults = 4;
}
/**
* @TypeId(4402)
*/
message FilterResult {
optional bytes instance = 1;
repeated org.infinispan.protostream.WrappedMessage projection = 2;
repeated org.infinispan.protostream.WrappedMessage sortProjection = 3;
}
/**
* @TypeId(4403)
*/
message ContinuousQueryResult {
enum ResultType {
LEAVING = 0;
JOINING = 1;
UPDATED = 2;
}
required ResultType resultType = 1;
required bytes key = 2;
/* Only present if resultType is JOINING or UPDATED and 'projection' field is missing */
optional bytes value = 3;
/* Only present if resultType is JOINING or UPDATED and 'value' field is missing */
repeated org.infinispan.protostream.WrappedMessage projection = 4;
}
) lifespan:0, maxIdle:0
2020-11-27 00:48:36,412 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation PutOperation{___protobuf_metadata, key=org/infinispan/query/remote/client/query.proto, value=[B0x4AA31D2F2A2A2A2A2A2A2A2A2A2A2A2A..[3750], flags=6}
2020-11-27 00:48:36,413 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Is topology id (-1) valid? true
2020-11-27 00:48:36,413 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,413 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,413 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [___protobuf_metadata] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,413 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,414 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation PutOperation{___protobuf_metadata, key=org/infinispan/query/remote/client/query.proto, value=[B0x4AA31D2F2A2A2A2A2A2A2A2A2A2A2A2A..[3750], flags=6} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,414 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation PutOperation{___protobuf_metadata, key=org/infinispan/query/remote/client/query.proto, value=[B0x4AA31D2F2A2A2A2A2A2A2A2A2A2A2A2A..[3750], flags=6}(FFFFCCCE) with id 6 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,414 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [___protobuf_metadata] Wrote header for messageId=6. Operation code: 0x01(PUT_REQUEST). Flags: 0x6. Topology id: -1
2020-11-27 00:48:36,415 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,467 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 6, PutOperation{___protobuf_metadata, key=org/infinispan/query/remote/client/query.proto, value=[B0x4AA31D2F2A2A2A2A2A2A2A2A2A2A2A2A..[3750], flags=6, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,468 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PUT_RESPONSE
2020-11-27 00:48:36,468 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PUT_RESPONSE
2020-11-27 00:48:36,468 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) About to add (K,V): (kogito-types.proto, syntax = "proto2";
package kogito;
message String {
optional string data = 1;
}
message Integer {
optional int32 data = 1;
}
message Long {
optional int64 data = 1;
}
message Double {
optional double data = 1;
}
message Float {
optional float data = 1;
}
message Boolean {
optional bool data = 1;
}
message Date {
option java_package = "java.util";
optional int64 data = 1;
}) lifespan:0, maxIdle:0
2020-11-27 00:48:36,468 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation PutOperation{___protobuf_metadata, key=kogito-types.proto, value=[B0x4ABC0373796E746178203D202270726F..[447], flags=6}
2020-11-27 00:48:36,468 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Is topology id (-1) valid? true
2020-11-27 00:48:36,469 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,469 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,469 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [___protobuf_metadata] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,469 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,469 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation PutOperation{___protobuf_metadata, key=kogito-types.proto, value=[B0x4ABC0373796E746178203D202270726F..[447], flags=6} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,469 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation PutOperation{___protobuf_metadata, key=kogito-types.proto, value=[B0x4ABC0373796E746178203D202270726F..[447], flags=6}(FFFFD0BD) with id 7 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,470 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [___protobuf_metadata] Wrote header for messageId=7. Operation code: 0x01(PUT_REQUEST). Flags: 0x6. Topology id: -1
2020-11-27 00:48:36,470 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,504 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 7, PutOperation{___protobuf_metadata, key=kogito-types.proto, value=[B0x4ABC0373796E746178203D202270726F..[447], flags=6, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,505 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PUT_RESPONSE
2020-11-27 00:48:36,505 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PUT_RESPONSE
before manager started
after manager started
getOrCreateCache name = processinstances
2020-11-27 00:48:36,511 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Trying to get cache processinstances from the server
2020-11-27 00:48:36,511 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\p\r\o\c\e\s\s\i\n\s\t\a\n\c\e\s... (16 bytes), hashCode=-627930384} (absent ? null) id=-1
2020-11-27 00:48:36,511 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{processinstances, flags=0}
2020-11-27 00:48:36,511 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) New server list is: [localhost:11222]
2020-11-27 00:48:36,511 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,512 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,512 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [processinstances] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,512 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,512 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{processinstances, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,512 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{processinstances, flags=0}(1BA8) with id 8 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,513 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [processinstances] Wrote header for messageId=8. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,513 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,517 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 8, FaultTolerantPingOperation{processinstances, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,517 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message ERROR_RESPONSE
2020-11-27 00:48:36,517 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [processinstances] Received operation status: 0x84
2020-11-27 00:48:36,517 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004005: Error received from the server: org.infinispan.server.hotrod.CacheNotFoundException: Cache with name 'processinstances' not found amongst the configured caches
2020-11-27 00:48:36,518 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Cache processinstances not found, trying to create a new one based on template kogito-template
2020-11-27 00:48:36,518 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:36,521 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation AdminOperation{(default), flags=0}
2020-11-27 00:48:36,522 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,522 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,522 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,522 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,522 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation AdminOperation{(default), flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,523 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation AdminOperation{(default), flags=0}(0455B) with id 9 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,523 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [] Wrote header for messageId=9. Operation code: 0x2b(EXEC_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,523 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,532 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 9, AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,533 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message ERROR_RESPONSE
2020-11-27 00:48:36,533 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [] Received operation status: 0x85
2020-11-27 00:48:36,533 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004005: Error received from the server: org.infinispan.commons.CacheConfigurationException: ISPN000374: No such template 'kogito-template' when declaring 'processinstances'
2020-11-27 00:48:36,533 INFO [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Creating a cache for 'processinstances' based on the default configuration
2020-11-27 00:48:36,534 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:36,538 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation AdminOperation{(default), flags=0}
2020-11-27 00:48:36,538 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,538 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,538 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,538 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,539 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation AdminOperation{(default), flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,539 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation AdminOperation{(default), flags=0}(72D2) with id 10 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,539 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [] Wrote header for messageId=10. Operation code: 0x2b(EXEC_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,539 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,960 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 10, AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,960 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message EXEC_RESPONSE
2020-11-27 00:48:36,960 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message EXEC_RESPONSE
2020-11-27 00:48:36,961 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\p\r\o\c\e\s\s\i\n\s\t\a\n\c\e\s... (16 bytes), hashCode=-627930384} (absent ? -1) id=-1
2020-11-27 00:48:36,961 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{processinstances, flags=0}
2020-11-27 00:48:36,961 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,961 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,961 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [processinstances] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,961 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,962 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{processinstances, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,962 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{processinstances, flags=0}(FFFFC91C) with id 11 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,962 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [processinstances] Wrote header for messageId=11. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,962 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,964 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 11, FaultTolerantPingOperation{processinstances, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,964 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PING_RESPONSE
2020-11-27 00:48:36,965 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PING_RESPONSE
2020-11-27 00:48:36,965 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Creating remote cache: processinstances
2020-11-27 00:48:36,965 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\p\r\o\c\e\s\s\i\n\s\t\a\n\c\e\s... (16 bytes), hashCode=-627930384} (absent ? -1) id=-1
2020-11-27 00:48:36,966 DEBUG [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Start called, nothing to do here(processinstances)
2020-11-27 00:48:36,966 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Default cache created processinstances
getOrCreateCache name = processinstances
2020-11-27 00:48:36,966 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Trying to get cache processinstances from the server
getOrCreateCache name = usertaskinstances
2020-11-27 00:48:36,967 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Trying to get cache usertaskinstances from the server
2020-11-27 00:48:36,967 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\u\s\e\r\t\a\s\k\i\n\s\t\a\n\c\e\s... (17 bytes), hashCode=-68622643} (absent ? null) id=-1
2020-11-27 00:48:36,967 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{usertaskinstances, flags=0}
2020-11-27 00:48:36,967 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) New server list is: [localhost:11222]
2020-11-27 00:48:36,968 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,968 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,968 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [usertaskinstances] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,968 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,968 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{usertaskinstances, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,968 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{usertaskinstances, flags=0}(FFFFBCE0) with id 12 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,969 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [usertaskinstances] Wrote header for messageId=12. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,969 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,971 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 12, FaultTolerantPingOperation{usertaskinstances, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,971 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message ERROR_RESPONSE
2020-11-27 00:48:36,971 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [usertaskinstances] Received operation status: 0x84
2020-11-27 00:48:36,971 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004005: Error received from the server: org.infinispan.server.hotrod.CacheNotFoundException: Cache with name 'usertaskinstances' not found amongst the configured caches
2020-11-27 00:48:36,972 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Cache usertaskinstances not found, trying to create a new one based on template kogito-template
2020-11-27 00:48:36,972 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:36,972 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation AdminOperation{(default), flags=0}
2020-11-27 00:48:36,972 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,973 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,973 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,973 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,973 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation AdminOperation{(default), flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,973 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation AdminOperation{(default), flags=0}(2B0D) with id 13 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,973 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [] Wrote header for messageId=13. Operation code: 0x2b(EXEC_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,974 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:36,977 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 13, AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:36,977 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message ERROR_RESPONSE
2020-11-27 00:48:36,977 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [] Received operation status: 0x85
2020-11-27 00:48:36,977 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004005: Error received from the server: org.infinispan.commons.CacheConfigurationException: ISPN000374: No such template 'kogito-template' when declaring 'usertaskinstances'
2020-11-27 00:48:36,977 INFO [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Creating a cache for 'usertaskinstances' based on the default configuration
2020-11-27 00:48:36,978 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:36,978 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation AdminOperation{(default), flags=0}
2020-11-27 00:48:36,978 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:36,978 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:36,979 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:36,979 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:36,982 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation AdminOperation{(default), flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,983 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation AdminOperation{(default), flags=0}(013E7) with id 14 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:36,983 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [] Wrote header for messageId=14. Operation code: 0x2b(EXEC_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:36,983 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:37,062 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 14, AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:37,063 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message EXEC_RESPONSE
2020-11-27 00:48:37,063 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message EXEC_RESPONSE
2020-11-27 00:48:37,063 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\u\s\e\r\t\a\s\k\i\n\s\t\a\n\c\e\s... (17 bytes), hashCode=-68622643} (absent ? -1) id=-1
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{usertaskinstances, flags=0}
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [usertaskinstances] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{usertaskinstances, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,064 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{usertaskinstances, flags=0}(3E5F) with id 15 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,065 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [usertaskinstances] Wrote header for messageId=15. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:37,065 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:37,067 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 15, FaultTolerantPingOperation{usertaskinstances, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:37,068 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PING_RESPONSE
2020-11-27 00:48:37,068 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PING_RESPONSE
2020-11-27 00:48:37,068 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Creating remote cache: usertaskinstances
2020-11-27 00:48:37,069 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\u\s\e\r\t\a\s\k\i\n\s\t\a\n\c\e\s... (17 bytes), hashCode=-68622643} (absent ? -1) id=-1
2020-11-27 00:48:37,069 DEBUG [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Start called, nothing to do here(usertaskinstances)
2020-11-27 00:48:37,069 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Default cache created usertaskinstances
getOrCreateCache name = usertaskinstances
2020-11-27 00:48:37,069 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Trying to get cache usertaskinstances from the server
getOrCreateCache name = jobs
2020-11-27 00:48:37,069 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Trying to get cache jobs from the server
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\j\o\b\s... (4 bytes), hashCode=4191191} (absent ? null) id=-1
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{jobs, flags=0}
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) New server list is: [localhost:11222]
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [jobs] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:37,070 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:37,071 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{jobs, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,071 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{jobs, flags=0}(1D5A) with id 16 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,071 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [jobs] Wrote header for messageId=16. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:37,071 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:37,073 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 16, FaultTolerantPingOperation{jobs, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:37,073 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message ERROR_RESPONSE
2020-11-27 00:48:37,074 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [jobs] Received operation status: 0x84
2020-11-27 00:48:37,074 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004005: Error received from the server: org.infinispan.server.hotrod.CacheNotFoundException: Cache with name 'jobs' not found amongst the configured caches
2020-11-27 00:48:37,074 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Cache jobs not found, trying to create a new one based on template kogito-template
2020-11-27 00:48:37,074 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:37,075 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation AdminOperation{(default), flags=0}
2020-11-27 00:48:37,075 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:37,075 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:37,075 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:37,075 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:37,075 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation AdminOperation{(default), flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,076 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation AdminOperation{(default), flags=0}(761B) with id 17 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,076 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [] Wrote header for messageId=17. Operation code: 0x2b(EXEC_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:37,076 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:37,080 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 17, AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:37,080 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message ERROR_RESPONSE
2020-11-27 00:48:37,080 TRACE [org.inf.cli.hot.imp.pro.Codec] (HotRod-client-async-pool-1-1) [] Received operation status: 0x85
2020-11-27 00:48:37,080 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004005: Error received from the server: org.infinispan.commons.CacheConfigurationException: ISPN000374: No such template 'kogito-template' when declaring 'jobs'
2020-11-27 00:48:37,080 INFO [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Creating a cache for 'jobs' based on the default configuration
2020-11-27 00:48:37,081 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=... (0 bytes), hashCode=1} (absent ? -1) id=-1
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation AdminOperation{(default), flags=0}
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation AdminOperation{(default), flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,082 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation AdminOperation{(default), flags=0}(4CFE) with id 18 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,083 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [] Wrote header for messageId=18. Operation code: 0x2b(EXEC_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:37,083 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:37,150 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 18, AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:37,151 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message EXEC_RESPONSE
2020-11-27 00:48:37,151 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message EXEC_RESPONSE
2020-11-27 00:48:37,151 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\j\o\b\s... (4 bytes), hashCode=4191191} (absent ? -1) id=-1
2020-11-27 00:48:37,151 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) Requesting channel for operation FaultTolerantPingOperation{jobs, flags=0}
2020-11-27 00:48:37,151 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Returning server: localhost:11222
2020-11-27 00:48:37,151 TRACE [org.inf.cli.hot.imp.tra.tcp.RoundRobinBalancingStrategy] (main) Selected localhost:11222 from [localhost:11222]
2020-11-27 00:48:37,152 TRACE [org.inf.cli.hot.imp.tra.net.ChannelFactory] (main) [jobs] Using the balancer for determining the server: localhost:11222
2020-11-27 00:48:37,152 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Activated record [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], created = 1, active = 1
2020-11-27 00:48:37,152 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (main) About to start executing operation FaultTolerantPingOperation{jobs, flags=0} on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,152 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (main) Registering operation FaultTolerantPingOperation{jobs, flags=0}(39FA) with id 19 on [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222]
2020-11-27 00:48:37,152 TRACE [org.inf.cli.hot.imp.pro.Codec] (main) [jobs] Wrote header for messageId=19. Operation code: 0x17(PING_REQUEST). Flags: 0x0. Topology id: -1
2020-11-27 00:48:37,153 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (main) Released channel [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222], active = 0
2020-11-27 00:48:37,154 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Received response for request 19, FaultTolerantPingOperation{jobs, flags=0, connection=localhost/127.0.0.1:11222}
2020-11-27 00:48:37,155 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding header for message PING_RESPONSE
2020-11-27 00:48:37,155 TRACE [org.inf.cli.hot.imp.tra.net.HeaderDecoder] (HotRod-client-async-pool-1-1) Decoding payload for message PING_RESPONSE
2020-11-27 00:48:37,155 TRACE [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Creating remote cache: jobs
2020-11-27 00:48:37,155 TRACE [org.inf.cli.hot.imp.TopologyInfo] (main) Creating topology for WrappedByteArray{bytes=\j\o\b\s... (4 bytes), hashCode=4191191} (absent ? -1) id=-1
2020-11-27 00:48:37,156 DEBUG [org.inf.cli.hot.imp.RemoteCacheImpl] (main) Start called, nothing to do here(jobs)
2020-11-27 00:48:37,156 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Default cache created jobs
getOrCreateCache name = jobs
2020-11-27 00:48:37,156 DEBUG [org.kie.kog.per.inf.cac.InfinispanCacheManager] (main) Trying to get cache jobs from the server
2020-11-27 00:48:37,348 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = and:[ProcessInstanceArgument!]
2020-11-27 00:48:37,348 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = or:[ProcessInstanceArgument!]
2020-11-27 00:48:37,348 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = not:ProcessInstanceArgument
2020-11-27 00:48:37,350 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = id:IdArgument
2020-11-27 00:48:37,350 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = processId:StringArgument
2020-11-27 00:48:37,350 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = processName:StringArgument
2020-11-27 00:48:37,350 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = parentProcessInstanceId:IdArgument
2020-11-27 00:48:37,350 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = rootProcessInstanceId:IdArgument
2020-11-27 00:48:37,350 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = rootProcessId:StringArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = state:ProcessInstanceStateArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = error:ProcessInstanceErrorArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceErrorArgument, field = nodeDefinitionId:StringArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceErrorArgument, field = message:StringArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = nodes:NodeInstanceArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = id:IdArgument
2020-11-27 00:48:37,351 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = name:StringArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = definitionId:StringArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = nodeId:StringArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = type:StringArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = enter:DateArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: NodeInstanceArgument, field = exit:DateArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = milestones:MilestoneArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: MilestoneArgument, field = id:IdArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: MilestoneArgument, field = name:StringArgument
2020-11-27 00:48:37,352 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: MilestoneArgument, field = status:MilestoneStatusArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = endpoint:StringArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = roles:StringArrayArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = start:DateArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = end:DateArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = addons:StringArrayArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = lastUpdate:DateArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceArgument, field = businessKey:StringArgument
2020-11-27 00:48:37,353 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = and:[UserTaskInstanceArgument!]
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = or:[UserTaskInstanceArgument!]
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = not:UserTaskInstanceArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = state:StringArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = id:IdArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = description:StringArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = name:StringArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = priority:StringArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = processId:StringArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = processInstanceId:IdArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = actualOwner:StringArgument
2020-11-27 00:48:37,354 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = potentialUsers:StringArrayArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = potentialGroups:StringArrayArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = excludedUsers:StringArrayArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = adminGroups:StringArrayArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = adminUsers:StringArrayArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = completed:DateArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = started:DateArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = referenceName:StringArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceArgument, field = lastUpdate:DateArgument
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = and:[JobArgument!]
2020-11-27 00:48:37,355 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = or:[JobArgument!]
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = not:JobArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = id:IdArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = processId:StringArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = processInstanceId:IdArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = nodeInstanceId:IdArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = rootProcessInstanceId:IdArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = rootProcessId:StringArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = status:JobStatusArgument
2020-11-27 00:48:37,356 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = expirationTime:DateArgument
2020-11-27 00:48:37,357 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = priority:NumericArgument
2020-11-27 00:48:37,357 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = scheduledId:IdArgument
2020-11-27 00:48:37,357 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: JobArgument, field = lastUpdate:DateArgument
2020-11-27 00:48:37,357 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: KogitoMetadataArgument, field = lastUpdate:DateArgument
2020-11-27 00:48:37,357 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: KogitoMetadataArgument, field = processInstances:ProcessInstanceMetaArgument
2020-11-27 00:48:37,357 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = id:IdArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = processId:StringArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = processName:StringArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = parentProcessInstanceId:IdArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = rootProcessInstanceId:IdArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = rootProcessId:StringArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = state:ProcessInstanceStateArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = endpoint:StringArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = roles:StringArrayArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = start:DateArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = end:DateArgument
2020-11-27 00:48:37,358 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: ProcessInstanceMetaArgument, field = businessKey:StringArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: KogitoMetadataArgument, field = userTasks:UserTaskInstanceMetaArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = state:StringArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = id:IdArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = description:StringArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = name:StringArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = priority:StringArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = processInstanceId:IdArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = actualOwner:StringArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = potentialUsers:StringArrayArgument
2020-11-27 00:48:37,359 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = potentialGroups:StringArrayArgument
2020-11-27 00:48:37,360 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = excludedUsers:StringArrayArgument
2020-11-27 00:48:37,360 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = adminGroups:StringArrayArgument
2020-11-27 00:48:37,360 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = adminUsers:StringArrayArgument
2020-11-27 00:48:37,360 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = completed:DateArgument
2020-11-27 00:48:37,360 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = started:DateArgument
2020-11-27 00:48:37,360 DEBUG [org.kie.kog.ind.gra.que.GraphQLQueryMapper] (main) Parser type: UserTaskInstanceMetaArgument, field = referenceName:StringArgument
2020-11-27 00:48:37,384 INFO [io.sma.rea.mes.provider] (main) SRMSG00208: Deployment done... start processing
2020-11-27 00:48:37,388 INFO [io.sma.rea.mes.provider] (main) SRMSG00226: Found incoming connectors: [smallrye-kafka]
2020-11-27 00:48:37,389 INFO [io.sma.rea.mes.provider] (main) SRMSG00227: Found outgoing connectors: [smallrye-kafka]
2020-11-27 00:48:37,392 INFO [io.sma.rea.mes.provider] (main) SRMSG00229: Channel manager initializing...
2020-11-27 00:48:37,432 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-usertaskdomain-events': [kogito-usertaskinstances-events]
2020-11-27 00:48:37,439 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default
2020-11-27 00:48:37,624 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-usertaskdomain-events'
2020-11-27 00:48:37,626 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-usertaskdomain' every 5000 milliseconds.
2020-11-27 00:48:37,626 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-usertaskdomain' as unhealthy if records go more than 60000 milliseconds without being processed.
2020-11-27 00:48:37,685 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-jobs-events': [kogito-jobs-events]
2020-11-27 00:48:37,689 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default
2020-11-27 00:48:37,701 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-jobs-events'
2020-11-27 00:48:37,701 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-jobs' every 5000 milliseconds.
2020-11-27 00:48:37,701 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-jobs' as unhealthy if records go more than 60000 milliseconds without being processed.
2020-11-27 00:48:37,712 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-processinstances-events': [kogito-processinstances-events]
2020-11-27 00:48:37,716 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default
2020-11-27 00:48:37,728 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-processinstances-events'
2020-11-27 00:48:37,729 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-processinstances' every 5000 milliseconds.
2020-11-27 00:48:37,729 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-processinstances' as unhealthy if records go more than 60000 milliseconds without being processed.
2020-11-27 00:48:37,738 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-usertaskinstances-events': [kogito-usertaskinstances-events]
2020-11-27 00:48:37,742 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default
2020-11-27 00:48:37,752 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-usertaskinstances-events'
2020-11-27 00:48:37,753 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-usertaskinstances' every 5000 milliseconds.
2020-11-27 00:48:37,753 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-usertaskinstances' as unhealthy if records go more than 60000 milliseconds without being processed.
2020-11-27 00:48:37,760 INFO [io.sma.rea.mes.kafka] (main) SRMSG18229: Configured topics for channel 'kogito-processdomain-events': [kogito-processinstances-events]
2020-11-27 00:48:37,764 INFO [io.sma.rea.mes.kafka] (main) SRMSG18214: Key deserializer omitted, using String as default
2020-11-27 00:48:37,772 INFO [io.sma.rea.mes.kafka] (main) SRMSG18240: 'throttled' commit strategy used for channel 'kogito-processdomain-events'
2020-11-27 00:48:37,772 INFO [io.sma.rea.mes.kafka] (main) SRMSG18232: Will commit for group 'kogito-data-index-processdomain' every 5000 milliseconds.
2020-11-27 00:48:37,773 INFO [io.sma.rea.mes.kafka] (main) SRMSG18236: Will mark throttled commit strategy for group 'kogito-data-index-processdomain' as unhealthy if records go more than 60000 milliseconds without being processed.
2020-11-27 00:48:37,780 INFO [io.sma.rea.mes.provider] (main) SRMSG00209: Initializing mediators
2020-11-27 00:48:37,789 INFO [io.sma.rea.mes.provider] (main) SRMSG00215: Connecting mediators
2020-11-27 00:48:37,789 INFO [io.sma.rea.mes.provider] (main) SRMSG00216: Attempt to resolve org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onJobEvent
2020-11-27 00:48:37,790 INFO [io.sma.rea.mes.provider] (main) SRMSG00217: Connecting org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onJobEvent to `[kogito-jobs-events]` (org.eclipse.microprofile.reactive.streams.operators.core.PublisherBuilderImpl@64f9f455)
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00216: Attempt to resolve org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onProcessInstanceDomainEvent
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00217: Connecting org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onProcessInstanceDomainEvent to `[kogito-processdomain-events]` (org.eclipse.microprofile.reactive.streams.operators.core.PublisherBuilderImpl@5d5a51b1)
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00216: Attempt to resolve org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onProcessInstanceEvent
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00217: Connecting org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onProcessInstanceEvent to `[kogito-processinstances-events]` (org.eclipse.microprofile.reactive.streams.operators.core.PublisherBuilderImpl@4dc7cd1c)
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00216: Attempt to resolve org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onUserTaskInstanceDomainEvent
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00217: Connecting org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onUserTaskInstanceDomainEvent to `[kogito-usertaskdomain-events]` (org.eclipse.microprofile.reactive.streams.operators.core.PublisherBuilderImpl@50ab56e2)
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00216: Attempt to resolve org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onUserTaskInstanceEvent
2020-11-27 00:48:37,791 INFO [io.sma.rea.mes.provider] (main) SRMSG00217: Connecting org.kie.kogito.index.messaging.ReactiveMessagingEventConsumer#onUserTaskInstanceEvent to `[kogito-usertaskinstances-events]` (org.eclipse.microprofile.reactive.streams.operators.core.PublisherBuilderImpl@7b5b5bfe)
2020-11-27 00:48:37,884 INFO [org.kie.kog.per.pro.ProtobufService] (main) Registering Kogito ProtoBuffer file: kogito-index.proto
2020-11-27 00:48:37,885 DEBUG [org.inf.pro.imp.SerializationContextImpl] (main) Registering proto files : [kogito-index.proto]
2020-11-27 00:48:37,887 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of kogito-index.proto
2020-11-27 00:48:37,891 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : kogito-index.proto
2020-11-27 00:48:37,925 DEBUG [org.kie.kog.ind.inf.sch.ProtoSchemaManager] (main) OnSchemaRegisteredEvent: SchemaRegisteredEvent{schemaDescriptor=SchemaDescriptor{name='kogito-index.proto', schemaContent='package org.kie.kogito.index.model;
option indexed_by_default = true;
/* @Indexed */
message KogitoMetadata {
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 1;
/* @Field(store = Store.YES) */
repeated org.kie.kogito.index.model.ProcessInstanceMeta processInstances = 2;
/* @Field(store = Store.YES) */
repeated org.kie.kogito.index.model.UserTaskInstanceMeta userTasks = 3;
}
/* @Indexed */
message ProcessInstanceMeta {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string processId = 2;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
repeated string roles = 3;
/* @Field(store = Store.YES) */
optional string endpoint = 4;
/* @Field(store = Store.YES) */
optional int32 state = 5;
optional int64 start = 6;
optional int64 end = 7;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessInstanceId = 8;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessId = 9;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string parentProcessInstanceId = 10;
/* @Field(store = Store.YES) */
optional string processName = 11;
/* @Field(store = Store.YES) */
optional int64 lastUpdate = 12;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string businessKey = 13;
}
/* @Indexed */
message ProcessInstance {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) @SortableField */
optional string processId = 2;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
repeated string roles = 3;
optional string variables = 4;
/* @Field(store = Store.YES) */
optional string endpoint = 5;
repeated NodeInstance nodes = 6;
/* @Field(store = Store.YES) @SortableField */
optional int32 state = 7;
/* @SortableField */
optional int64 start = 8;
/* @SortableField */
optional int64 end = 9;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessInstanceId = 10;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string rootProcessId = 11;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string parentProcessInstanceId = 12;
/* @Field(store = Store.YES) @SortableField */
optional string processName = 13;
/* @Field(store = Store.YES) */
optional ProcessInstanceError error = 14;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
repeated string addons = 15;
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 16;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string businessKey = 17;
repeated Milestone milestones = 18;
}
/* @Indexed */
message ProcessInstanceError {
/* @Field(store = Store.YES) @SortableField */
optional string nodeDefinitionId = 1;
/* @Field(store = Store.YES) @SortableField */
optional string message = 2;
}
/* @Indexed */
message NodeInstance {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string name = 2;
/* @Field(store = Store.YES) */
optional string type = 3;
optional int64 enter = 4;
optional int64 exit = 5;
/* @Field(store = Store.YES) */
optional string definitionId = 6;
/* @Field(store = Store.YES) */
optional string nodeId = 7;
}
/* @Indexed */
message Milestone {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string name = 2;
/* @Field(store = Store.YES) */
optional string status = 3;
}
/* @Indexed */
message UserTaskInstance {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) @SortableField */
optional string description = 2;
/* @Field(store = Store.YES) @SortableField */
optional string name = 3;
/* @Field(store = Store.YES) @SortableField */
optional string priority = 4;
/* @Field(store = Store.YES) */
optional string processInstanceId = 5;
/* @Field(store = Store.YES) @SortableField */
optional string processId = 6;
/* @Field(store = Store.YES) */
optional string rootProcessInstanceId = 7;
/* @Field(store = Store.YES) */
optional string rootProcessId = 8;
/* @Field(store = Store.YES) @SortableField */
optional string state = 9;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string actualOwner = 10;
/* @Field(store = Store.YES) */
repeated string adminGroups = 11;
/* @Field(store = Store.YES) */
repeated string adminUsers = 12;
/* @SortableField */
optional int64 completed = 13;
/* @SortableField */
optional int64 started = 14;
/* @Field(store = Store.YES) */
repeated string excludedUsers = 15;
/* @Field(store = Store.YES) */
repeated string potentialGroups = 16;
/* @Field(store = Store.YES) */
repeated string potentialUsers = 17;
optional string inputs = 18;
optional string outputs = 19;
/* @Field(store = Store.YES) @SortableField */
optional string referenceName = 20;
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 21;
/* @Field(store = Store.YES) */
optional string endpoint = 22;
}
/* @Indexed */
message UserTaskInstanceMeta {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) */
optional string description = 2;
/* @Field(store = Store.YES) */
optional string name = 3;
/* @Field(store = Store.YES) */
optional string priority = 4;
/* @Field(store = Store.YES) */
optional string processInstanceId = 5;
/* @Field(store = Store.YES) */
optional string state = 6;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string actualOwner = 7;
/* @Field(store = Store.YES) */
repeated string adminGroups = 8;
/* @Field(store = Store.YES) */
repeated string adminUsers = 9;
optional int64 completed = 10;
optional int64 started = 11;
/* @Field(store = Store.YES) */
repeated string excludedUsers = 12;
/* @Field(store = Store.YES) */
repeated string potentialGroups = 13;
/* @Field(store = Store.YES) */
repeated string potentialUsers = 14;
/* @Field(store = Store.YES) */
optional string referenceName = 15;
/* @Field(store = Store.YES) */
optional int64 lastUpdate = 16;
}
/* @Indexed */
message Job {
/* @Field(store = Store.YES) */
optional string id = 1;
/* @Field(store = Store.YES) @SortableField */
optional string processId = 2;
/* @Field(store = Store.YES) */
optional string processInstanceId = 3;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") @SortableField */
optional string rootProcessId = 4;
/* @Field(store = Store.YES, indexNullAs = "__DEFAULT_NULL_TOKEN__") */
optional string rootProcessInstanceId = 5;
/* @Field(store = Store.YES) @SortableField */
optional int64 expirationTime = 6;
/* @Field(store = Store.YES) @SortableField */
optional int32 priority = 7;
optional string callbackEndpoint = 8;
optional int64 repeatInterval = 9;
optional int32 repeatLimit = 10;
/* @Field(store = Store.YES) */
optional string scheduledId = 11;
/* @SortableField */
optional int32 retries = 12;
/* @Field(store = Store.YES) @SortableField */
optional string status = 13;
/* @Field(store = Store.YES) @SortableField */
optional int64 lastUpdate = 14;
/* @SortableField */
optional int32 executionCounter = 15;
optional string endpoint = 16;
/* @Field(store = Store.YES) */
optional string nodeInstanceId = 17;
}
', entityIndexDescriptors={org.kie.kogito.index.model.Job=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@758871bf, org.kie.kogito.index.model.ProcessInstanceMeta=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@36b97d7a, org.kie.kogito.index.model.ProcessInstance=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@ee2dee2e, org.kie.kogito.index.model.Milestone=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@bd6552f1, org.kie.kogito.index.model.ProcessInstanceError=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@3dc0ded7, org.kie.kogito.index.model.UserTaskInstance=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@8edda24c, org.kie.kogito.index.model.NodeInstance=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@fe8cb12f, org.kie.kogito.index.model.UserTaskInstanceMeta=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@4522ae30, org.kie.kogito.index.model.KogitoMetadata=org.kie.kogito.persistence.api.schema.EntityIndexDescriptor@b8accd45}, processDescriptor=null}, schemaType=SchemaType{type='proto'}}
2020-11-27 00:48:37,926 INFO [org.kie.kog.per.pro.ProtobufService] (main) Registering Kogito ProtoBuffer file: kogito-types.proto
2020-11-27 00:48:37,926 DEBUG [org.inf.pro.imp.SerializationContextImpl] (main) Registering proto files : [kogito-types.proto]
2020-11-27 00:48:37,926 DEBUG [org.inf.pro.des.FileDescriptor] (main) Resolving dependencies of kogito-types.proto
2020-11-27 00:48:37,927 DEBUG [org.inf.pro.des.ResolutionContext] (main) File resolved successfully : kogito-types.proto
2020-11-27 00:48:37,927 DEBUG [org.kie.kog.ind.inf.sch.ProtoSchemaManager] (main) OnSchemaRegisteredEvent: SchemaRegisteredEvent{schemaDescriptor=SchemaDescriptor{name='kogito-types.proto', schemaContent='syntax = "proto2";
package kogito;
message String {
optional string data = 1;
}
message Integer {
optional int32 data = 1;
}
message Long {
optional int64 data = 1;
}
message Double {
optional double data = 1;
}
message Float {
optional float data = 1;
}
message Boolean {
optional bool data = 1;
}
message Date {
option java_package = "java.util";
optional int64 data = 1;
}', entityIndexDescriptors={}, processDescriptor=null}, schemaType=SchemaType{type='proto'}}
2020-11-27 00:48:38,008 INFO [io.quarkus] (main) data-index-service-infinispan 2.0.0-SNAPSHOT on JVM (powered by Quarkus 1.10.0.Final) started in 3.324s. Listening on: http://0.0.0.0:8180
2020-11-27 00:48:38,009 INFO [io.quarkus] (main) Profile prod activated.
2020-11-27 00:48:38,009 INFO [io.quarkus] (main) Installed features: [cdi, infinispan-client, mutiny, oidc, security, smallrye-context-propagation, smallrye-health, smallrye-metrics, smallrye-reactive-messaging, smallrye-reactive-messaging-kafka, vertx, vertx-graphql, vertx-web]
2020-11-27 00:48:38,050 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processdomain-events, groupId=kogito-data-index-processdomain] Error while fetching metadata with correlation id 3 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,050 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-3) [Consumer clientId=kafka-consumer-kogito-usertaskdomain-events, groupId=kogito-data-index-usertaskdomain] Error while fetching metadata with correlation id 3 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,045 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Error while fetching metadata with correlation id 3 : {kogito-jobs-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,061 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Error while fetching metadata with correlation id 3 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,069 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-4) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Error while fetching metadata with correlation id 3 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,165 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-3) [Consumer clientId=kafka-consumer-kogito-usertaskdomain-events, groupId=kogito-data-index-usertaskdomain] Error while fetching metadata with correlation id 6 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,165 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processdomain-events, groupId=kogito-data-index-processdomain] Error while fetching metadata with correlation id 7 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,174 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Error while fetching metadata with correlation id 7 : {kogito-jobs-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,180 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Error while fetching metadata with correlation id 7 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,186 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-4) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Error while fetching metadata with correlation id 7 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,297 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processdomain-events, groupId=kogito-data-index-processdomain] Error while fetching metadata with correlation id 16 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,315 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Error while fetching metadata with correlation id 14 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,321 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-3) [Consumer clientId=kafka-consumer-kogito-usertaskdomain-events, groupId=kogito-data-index-usertaskdomain] Error while fetching metadata with correlation id 15 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,321 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-4) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Error while fetching metadata with correlation id 16 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,329 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Error while fetching metadata with correlation id 16 : {kogito-jobs-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,460 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-4) [Consumer clientId=kafka-consumer-kogito-usertaskinstances-events, groupId=kogito-data-index-usertaskinstances] Error while fetching metadata with correlation id 21 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,462 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-1) [Consumer clientId=kafka-consumer-kogito-processdomain-events, groupId=kogito-data-index-processdomain] Error while fetching metadata with correlation id 22 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,466 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-0) [Consumer clientId=kafka-consumer-kogito-jobs-events, groupId=kogito-data-index-jobs] Error while fetching metadata with correlation id 20 : {kogito-jobs-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,472 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-2) [Consumer clientId=kafka-consumer-kogito-processinstances-events, groupId=kogito-data-index-processinstances] Error while fetching metadata with correlation id 19 : {kogito-processinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:48:38,477 WARN [org.apa.kaf.cli.NetworkClient] (vert.x-kafka-consumer-thread-3) [Consumer clientId=kafka-consumer-kogito-usertaskdomain-events, groupId=kogito-data-index-usertaskdomain] Error while fetching metadata with correlation id 20 : {kogito-usertaskinstances-events=LEADER_NOT_AVAILABLE}
2020-11-27 00:49:36,523 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Add localhost:11222 to failed servers
2020-11-27 00:49:36,524 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004098: Closing connection [id: 0xf157fdaa, L:/127.0.0.1:53190 - R:localhost/127.0.0.1:11222] due to transport error: java.net.SocketTimeoutException: AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.run(HotRodOperation.java:176)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-11-27 00:49:36,526 TRACE [org.inf.cli.hot.imp.tra.net.ChannelPool] (HotRod-client-async-pool-1-1) Closed channel [id: 0xf157fdaa, L:/127.0.0.1:53190 ! R:localhost/127.0.0.1:11222], created = 0, idle = true, active = 0
2020-11-27 00:49:36,528 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Exception encountered in AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}. Retry 0 out of 10: java.net.SocketTimeoutException: AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.run(HotRodOperation.java:176)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-11-27 00:49:36,529 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Not retrying as done (exceptionally=true), retryCount=1
2020-11-27 00:49:36,974 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Add localhost:11222 to failed servers
2020-11-27 00:49:36,974 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004098: Closing connection [id: 0xf157fdaa, L:/127.0.0.1:53190 ! R:localhost/127.0.0.1:11222] due to transport error: java.net.SocketTimeoutException: AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.run(HotRodOperation.java:176)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-11-27 00:49:36,974 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Exception encountered in AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}. Retry 0 out of 10: java.net.SocketTimeoutException: AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.run(HotRodOperation.java:176)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-11-27 00:49:36,975 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Not retrying as done (exceptionally=true), retryCount=1
2020-11-27 00:49:37,076 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Add localhost:11222 to failed servers
2020-11-27 00:49:37,076 WARN [org.inf.HOTROD] (HotRod-client-async-pool-1-1) ISPN004098: Closing connection [id: 0xf157fdaa, L:/127.0.0.1:53190 ! R:localhost/127.0.0.1:11222] due to transport error: java.net.SocketTimeoutException: AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.run(HotRodOperation.java:176)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-11-27 00:49:37,077 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Exception encountered in AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222}. Retry 0 out of 10: java.net.SocketTimeoutException: AdminOperation{(default), flags=0, connection=localhost/127.0.0.1:11222} timed out after 60000 ms
at org.infinispan.client.hotrod.impl.operations.HotRodOperation.run(HotRodOperation.java:176)
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
2020-11-27 00:49:37,077 TRACE [org.inf.cli.hot.imp.ope.RetryOnFailureOperation] (HotRod-client-async-pool-1-1) Not retrying as done (exceptionally=true), retryCount=1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment