2023-03-06T09:24:43.278-08:00 WARN CBAS.cbas Updating log level to DEBUG (1) 2023-03-06T09:24:43.279-08:00 INFO CBAS.cbas ++++++++++++ starting cbas main ++++++++++++ 2023-03-06T09:24:43.279-08:00 INFO CBAS.cbas uuid: 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:43.279-08:00 INFO CBAS.cbas IPv4 addresses: [127.0.0.1 172.23.104.91] 2023-03-06T09:24:43.279-08:00 INFO CBAS.cbas IPv6 addresses: [] 2023-03-06T09:24:43.279-08:00 INFO CBAS.cbas setting ipv4 required, ipv6 optional 2023-03-06T09:24:43.284-08:00 INFO CBAS.cbas a single io device was provided; auto-adjusting... 2023-03-06T09:24:43.285-08:00 INFO CBAS.cbas configuring io devices based on available memory (1024): 1 2023-03-06T09:24:43.285-08:00 INFO CBAS.cbas io devices were adjusted to a total of: 1 2023-03-06T09:24:43.285-08:00 INFO CBAS.cbas setting java.home to bundled jre (/opt/couchbase/lib/cbas/runtime) 2023-03-06T09:24:43.456-08:00 INFO CBAS.cbas initialized cluster encryption with data encryption as false 2023-03-06T09:24:43.467-08:00 INFO CBAS.cbas clusterCompatibility init'd to 458754 2023-03-06T09:24:43.470-08:00 INFO CBAS.cbas initEventLogger: Started SystemEventLogger 2023-03-06T09:24:43.473-08:00 INFO CBAS.cbas Starting clusterCompatibility monitor 2023-03-06T09:24:43.474-08:00 WARN CBAS.cbas config has been refreshed by ns server. New value 7 2023-03-06T09:24:43.474-08:00 WARN CBAS.cbas cluster encryption has been refreshed by ns server 2023-03-06T09:24:43.474-08:00 WARN CBAS.cbas tls config has been refreshed by ns server 2023-03-06T09:24:45.019-08:00 INFO CBAS.cbas Initialized starting partitionId to 0 for node 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:45.019-08:00 INFO CBAS.cbas Initialized controllerId to 0 for node 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:45.024-08:00 INFO CBAS.cbas no CC / Metadata node defined in metakv- will pick *this* node, 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:45.030-08:00 INFO CBAS.cbas our node is within topology refresh 74ffe1c2d48a0a6d46f9fd352553f7a1/1; ensuring driver is running... 2023-03-06T09:24:47.032-08:00 INFO CBAS.cbas initializing audit service at: http://127.0.0.1:8091 2023-03-06T09:24:47.046-08:00 INFO CBAS.cbas audit: created new audit service 2023-03-06T09:24:47.056-08:00 INFO CBAS.cbas ignoring optional family address IPv6: listen tcp6 [::1]:8095: bind: cannot assign requested address 2023-03-06T09:24:47.056-08:00 INFO CBAS.cbas ignoring optional family address IPv6: listen tcp6 [::1]:18095: bind: cannot assign requested address 2023-03-06T09:24:47.056-08:00 INFO CBAS.cbas setting max number of CPUs to: 4 2023-03-06T09:24:47.056-08:00 INFO CBAS.cbas allocating 435MiB/871MiB for heap min/max (reserved 153MiB of 1024MiB service quota for non-heap allocations) 2023-03-06T09:24:47.057-08:00 INFO CBAS.cbas nodeConfigMap: map[additionalCcNodes:[] address:0.0.0.0 analyticsCbHome:/opt/couchbase analyticsCcHttpPort:9111 analyticsHttpAdminListenPort:9110 analyticsHttpListenAddress:[127.0.0.1 172.23.104.91] analyticsHttpListenPort:8095 analyticsHttpsListenAddress:[127.0.0.1 172.23.104.91] analyticsHttpsListenPort:18095 analyticsNodeName:127.0.0.1:8091 analyticsSslEnabled:true cbasAddress:127.0.0.1 cbasPort:9122 ccAddress:0.0.0.0 ccAnalyticsHttpListenPort:9111 ccAnalyticsMetadataPartitionId:-1 ccClientListenPort:9113 ccClusterListenPort:9112 ccConsoleListenPort:9114 ccControllerId:0 ccHeartbeatMaxMisses:20 ccHeartbeatPeriod:30000 ccPublicAddress:127.0.0.1 clusterAddress:127.0.0.1 clusterCompatibility:458754 clusterListenPort:9115 clusterPort:9112 dataListenPort:9116 defaultDir:/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0 developerPreview:false initialRun:false iodevices:[/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0] logDir:/opt/couchbase/var/lib/couchbase/logs messagingListenPort:9118 metadataCallbackPort:9119 metadataListenPort:9121 metadataNode:3f6082be197409ab968bd40b3be18c32 ncservicePort:-1 nsServerAddress:127.0.0.1 nsServerPort:8091 nsServerSslPort:18091 numReplicas:0 productVersion:7.2.0-5183 publicAddress:127.0.0.1 replicationEnabled:true replicationFactor:4096 replicationListenPort:9120 replicationLogBufferPagesize:262144 replicationStrategy:all resultListenPort:9117 sslEnabled:false startingPartitionId:0 txnLogBufferPagesize:262144] 2023-03-06T09:24:47.065-08:00 INFO CBAS.cbas running /opt/couchbase/lib/cbas/runtime/bin/java args:[-XX:+ExitOnOutOfMemoryError -XX:MaxGCPauseMillis=60000 -XX:+UseParallelGC -XX:ActiveProcessorCount=4 -Xms435m -Xmx871m -Dfile.encoding=UTF-8 -Djava.io.tmpdir=/opt/couchbase/var/lib/couchbase/tmp -Djava.net.preferIPv6Addresses=false --add-opens=jdk.management/com.sun.management.internal=ALL-UNNAMED --add-opens=java.management/sun.management=ALL-UNNAMED --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED -Dproduct.version=7.2.0-5183 -DlogRolloverThresholdBytes=41943040 -DlogRolloverMaxFiles=10 -Dnetworkaddress.cache.ttl=15 -Djdk.tls.rejectClientInitiatedRenegotiation=true -Dcom.couchbase.analytics.bootstrapLogLevel=DEBUG -DlogDir=/opt/couchbase/var/lib/couchbase/logs -cp /opt/couchbase/lib/cbas/repo/cbas-install-7.2.0.jar com.couchbase.analytics.control.AnalyticsDriver --jsonconfig /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/config.json --nc -node-id 3f6082be197409ab968bd40b3be18c32 --cc] 2023-03-06T09:24:47.071-08:00 INFO CBAS.cbas analytics driver is running; pid: 3986 2023-03-06T09:24:49.798-08:00 WARN CBAS.util.PreferSystemPropertiesPropertySource [main] System properties is the preferred source of log4j properties 2023-03-06T09:24:50.739-08:00 INFO CBAS.config.ConfigManager [main] no INI file specified; skipping parsing 2023-03-06T09:24:50.861-08:00 INFO CBAS.config.PropertiesAccessor [main] configured partitions: {3f6082be197409ab968bd40b3be18c32=[ID:0, Original Node: 3f6082be197409ab968bd40b3be18c32, IODevice: 0, Active Node: null, Pending Activation: false]} from config org.apache.hyracks.control.common.application.ConfigManagerApplicationConfig@4a1c0752 2023-03-06T09:24:50.862-08:00 INFO CBAS.config.PropertiesAccessor [main] Build properties not found on classpath. Version API will return empty object 2023-03-06T09:24:52.640-08:00 INFO CBAS.nc.NodeControllerService [main] Setting uncaught exception handler org.apache.hyracks.api.lifecycle.LifeCycleComponentManager@6812fa3a 2023-03-06T09:24:52.728-08:00 INFO CBAS.config.ConfigManager [main] no command line args supplied 2023-03-06T09:24:52.729-08:00 INFO CBAS.config.ConfigManager [main] no INI file specified; skipping parsing 2023-03-06T09:24:52.739-08:00 INFO CBAS.config.ConfigManager [main] no command line args supplied 2023-03-06T09:24:52.753-08:00 INFO CBAS.config.PropertiesAccessor [main] configured partitions: {3f6082be197409ab968bd40b3be18c32=[ID:0, Original Node: 3f6082be197409ab968bd40b3be18c32, IODevice: 0, Active Node: null, Pending Activation: false]} from config org.apache.hyracks.control.common.application.ConfigManagerApplicationConfig@37468787 2023-03-06T09:24:52.753-08:00 INFO CBAS.config.PropertiesAccessor [main] Build properties not found on classpath. Version API will return empty object 2023-03-06T09:24:53.072-08:00 INFO CBAS.cc.ClusterControllerService [main] Starting ClusterControllerService: com.couchbase.analytics.bootstrap.AnalyticsClusterControllerService@fe34b86 2023-03-06T09:24:53.269-08:00 INFO CBAS.bootstrap.CCApplication [main] Starting Asterix cluster controller 2023-03-06T09:24:54.425-08:00 INFO CBAS.util.ExitUtil [main] successfully registered shutdown hook Thread[Thread-6,5,main] 2023-03-06T09:24:54.548-08:00 INFO CBAS.util.SingleThreadEventProcessor [ActiveNotificationHandler] Started ActiveNotificationHandler 2023-03-06T09:24:54.604-08:00 INFO CBAS.rebalance.TopologyManager [main] initialized topology manager with {"version":1,"revision":-1,"balanced":true,"ccNodeId":"3f6082be197409ab968bd40b3be18c32","metadataPartition":-1,"numReplicas":0,"partitions":[]} 2023-03-06T09:24:54.670-08:00 INFO CBAS.bootstrap.AsterixStateProxy [main] Asterix Distributed State Proxy Bound 2023-03-06T09:24:54.761-08:00 INFO CBAS.bootstrap.ClusterMonitor [Local cluster monitor pool stream consumer] bootstrapped buckets to [] 2023-03-06T09:24:54.762-08:00 INFO CBAS.bootstrap.Auditor [Local cluster monitor pool stream consumer] processing audit settings update: (uid now 55497325) 2023-03-06T09:24:54.810-08:00 INFO CBAS.bootstrap.Auditor [Local cluster monitor pool stream consumer] auditor bootstrap complete 2023-03-06T09:24:55.221-08:00 INFO CBAS.bootstrap.ClusterLifecycleListener [main] Starting cluster event handler 2023-03-06T09:24:55.240-08:00 INFO CBAS.cc.ClusterControllerService [main] Started ClusterControllerService 2023-03-06T09:24:55.260-08:00 INFO CBAS.bootstrap.MetadataLockDump [main] Metadata lock dumps will be included in diagnostics & periodic thread dumps 2023-03-06T09:24:55.260-08:00 INFO CBAS.nc.NodeControllerService [main] Starting NodeControllerService 2023-03-06T09:24:55.299-08:00 INFO CBAS.trace.Tracer [main] Initialize Tracer org.apache.hyracks.util.trace.Tracer.Traces.3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.307-08:00 INFO CBAS.trace.Tracer [main] Set categories for Tracer org.apache.hyracks.util.trace.Tracer.Traces.3f6082be197409ab968bd40b3be18c32 to [] 2023-03-06T09:24:55.319-08:00 INFO CBAS.bootstrap.AnalyticsApplicationUtil [main] JVM properties: {"java.awt.graphicsenv":"sun.awt.X11GraphicsEnvironment","java.awt.printerjob":"sun.print.PSPrinterJob","java.class.path":"/opt/couchbase/lib/cbas/repo/cbas-install-7.2.0.jar","java.class.version":"55.0","java.home":"/opt/couchbase/lib/cbas/runtime","java.io.tmpdir":"/opt/couchbase/var/lib/couchbase/tmp","java.library.path":"/opt/couchbase/lib:/opt/couchbase/lib/memcached::/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib","java.net.preferIPv6Addresses":"false","java.rmi.server.hostname":"127.0.0.1","java.runtime.name":"OpenJDK Runtime Environment","java.runtime.version":"11.0.18+10","java.specification.name":"Java Platform API Specification","java.specification.vendor":"Oracle Corporation","java.specification.version":"11","java.util.logging.manager":"org.apache.logging.log4j.jul.LogManager","java.vendor":"Eclipse Adoptium","java.vendor.url":"https://adoptium.net/","java.vendor.url.bug":"https://github.com/adoptium/adoptium-support/issues","java.vendor.version":"Temurin-11.0.18+10","java.version":"11.0.18","java.version.date":"2023-01-17","java.vm.compressedOopsMode":"32-bit","java.vm.info":"mixed mode","java.vm.name":"OpenJDK 64-Bit Server VM","java.vm.specification.name":"Java Virtual Machine Specification","java.vm.specification.vendor":"Oracle Corporation","java.vm.specification.version":"11","java.vm.vendor":"Eclipse Adoptium","java.vm.version":"11.0.18+10"} 2023-03-06T09:24:55.322-08:00 INFO CBAS.config.PropertiesAccessor [main] configured partitions: {3f6082be197409ab968bd40b3be18c32=[ID:0, Original Node: 3f6082be197409ab968bd40b3be18c32, IODevice: 0, Active Node: null, Pending Activation: false]} from config org.apache.hyracks.control.common.config.ConfigManager$2@7910f355 2023-03-06T09:24:55.322-08:00 INFO CBAS.config.PropertiesAccessor [main] Build properties not found on classpath. Version API will return empty object 2023-03-06T09:24:55.344-08:00 INFO CBAS.bootstrap.AnalyticsNCApplication [main] Starting Couchbase Analytics driver, version: {"build.date":"Fri Feb 17 02:09:39 UTC 2023","build.number":"5183","build.version":"7.2.0"} 2023-03-06T09:24:55.346-08:00 INFO CBAS.bootstrap.NCApplication [main] Starting Asterix node controller: 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.502-08:00 INFO CBAS.nc.TransactionSubsystem [main] Checkpoint Properties: {"class" : "CheckpointProperties", "checkpoint-dir-path" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log", "lsn-threshold" : 67108864, "poll-frequency" : 120, "history-to-keep" : 2, "dataset-checkpoint-interval" : 3600} 2023-03-06T09:24:55.508-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Checkpoint directory = /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log 2023-03-06T09:24:55.509-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Checkpoint directory /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/ didn't exist. Creating one 2023-03-06T09:24:55.509-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Getting latest checkpoint 2023-03-06T09:24:55.510-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:55.518-08:00 INFO CBAS.logging.LogManager [main] the log dir (/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log) is empty. returning empty list 2023-03-06T09:24:55.541-08:00 INFO CBAS.logging.LogManager [main] Created log file /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/transaction_log_0 2023-03-06T09:24:55.542-08:00 INFO CBAS.logging.LogManager [main] initializing log anchor with log file Id: 0 at offset: 0 2023-03-06T09:24:55.542-08:00 INFO CBAS.logging.LogManager [main] LogManager starts logging in LSN: 0 2023-03-06T09:24:55.569-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Getting latest checkpoint 2023-03-06T09:24:55.569-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:55.570-08:00 INFO CBAS.nc.RecoveryManager [main] The checkpoint file doesn't exist: systemState = PERMANENT_DATA_LOSS 2023-03-06T09:24:55.571-08:00 WARN CBAS.nc.NCAppRuntimeContext [main] Deleting the storage dir. initialRun = false, systemState = PERMANENT_DATA_LOSS 2023-03-06T09:24:55.572-08:00 INFO CBAS.nc.NCAppRuntimeContext [main] The value of maxScheduledFlushes is not provided. Setting maxConcurrentFlushes = 1. 2023-03-06T09:24:55.669-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Getting latest checkpoint 2023-03-06T09:24:55.670-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:55.670-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Getting latest checkpoint 2023-03-06T09:24:55.670-08:00 INFO CBAS.recovery.AbstractCheckpointManager [main] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:55.670-08:00 INFO CBAS.nc.RecoveryManager [main] The checkpoint file doesn't exist: systemState = PERMANENT_DATA_LOSS 2023-03-06T09:24:55.671-08:00 INFO CBAS.bootstrap.NCApplication [main] System state: PERMANENT_DATA_LOSS 2023-03-06T09:24:55.671-08:00 INFO CBAS.bootstrap.NCApplication [main] Node ID: 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.671-08:00 INFO CBAS.bootstrap.NCApplication [main] Stores: {3f6082be197409ab968bd40b3be18c32=[/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage]} 2023-03-06T09:24:55.734-08:00 INFO CBAS.nc.NodeControllerService [main] addCc: /127.0.0.1:9112 2023-03-06T09:24:55.749-08:00 INFO CBAS.nc.NodeControllerService [main] Registering with Cluster Controller ClusterControllerRemoteProxy [/127.0.0.1:9112] 2023-03-06T09:24:55.812-08:00 INFO CBAS.work.RegisterNodeWork [Worker:ClusterController] registering node: 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.824-08:00 WARN CBAS.cluster.NodeManager [Worker:ClusterController] +addNode: 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.826-08:00 INFO CBAS.cluster.NodeManager [Worker:ClusterController] adding node to registry 2023-03-06T09:24:55.827-08:00 INFO CBAS.cluster.NodeManager [Worker:ClusterController] updating cluster capacity 2023-03-06T09:24:55.830-08:00 INFO CBAS.work.RegisterNodeWork [Worker:ClusterController] registered node: 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.831-08:00 INFO CBAS.bootstrap.ClusterLifecycleListener [Worker:ClusterController] NC: 3f6082be197409ab968bd40b3be18c32 joined 2023-03-06T09:24:55.832-08:00 INFO CBAS.utils.ClusterStateManager [Worker:ClusterController] Registering configuration parameters for node id 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:24:55.918-08:00 INFO CBAS.nc.NodeControllerService [main] Registering with Cluster Controller ClusterControllerRemoteProxy [/127.0.0.1:9112] completed 2023-03-06T09:24:55.919-08:00 INFO CBAS.nc.NodeControllerService [main] Started NodeControllerService 2023-03-06T09:24:55.922-08:00 INFO CBAS.util.ExitUtil [main] successfully registered shutdown hook Thread[ShutdownHook-3f6082be197409ab968bd40b3be18c32,5,main] 2023-03-06T09:24:55.922-08:00 INFO CBAS.work.AbortAllJobsWork [Worker:3f6082be197409ab968bd40b3be18c32] Aborting all tasks for controller CC:0 2023-03-06T09:24:55.933-08:00 INFO CBAS.work.EnsureAllCcTasksCompleted [Executor-11:3f6082be197409ab968bd40b3be18c32] Ensuring all tasks of CC CC:0 have completed 2023-03-06T09:24:55.943-08:00 INFO CBAS.work.EnsureAllCcTasksCompleted [Executor-11:3f6082be197409ab968bd40b3be18c32] all tasks of CC CC:0 have completed 2023-03-06T09:24:56.418-08:00 WARN CBAS.server.AnalyticsHttpsServerInitializer [main] Configured SSL Context using configuration {"certificatePath":"/opt/couchbase/var/lib/couchbase/config/certs/chain.pem","trustedCAPath":"/opt/couchbase/var/lib/couchbase/config/certs/ca.pem","privateKeyPath":"/opt/couchbase/var/lib/couchbase/config/certs/pkey.pem","clientCertAuthType":"NONE","supportedCiphers":["TLS_AES_256_GCM_SHA384","TLS_CHACHA20_POLY1305_SHA256","TLS_AES_128_GCM_SHA256","TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384","TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256","TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384","TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256","TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA","TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA","TLS_RSA_WITH_AES_256_CBC_SHA","TLS_RSA_WITH_AES_128_CBC_SHA"],"minTlsVersion":1.2,"preferServerCipherSuites":true,"supportedProtocols":["TLSv1.3","TLSv1.2"],"clientAuth":"NONE"} 2023-03-06T09:24:56.427-08:00 INFO CBAS.bootstrap.NsServerHelper [main] starting coordinator service 2023-03-06T09:24:56.427-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Getting latest checkpoint 2023-03-06T09:24:56.428-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:56.428-08:00 INFO CBAS.nc.RecoveryManager [Executor-11:3f6082be197409ab968bd40b3be18c32] The checkpoint file doesn't exist: systemState = PERMANENT_DATA_LOSS 2023-03-06T09:24:56.432-08:00 INFO CBAS.cbas starting coordinator 2023-03-06T09:24:56.432-08:00 INFO CBAS.cbas Starting replicas monitor 2023-03-06T09:24:56.433-08:00 INFO CBAS.bootstrap.NsServerHelper [main] Coordinator service started 2023-03-06T09:24:56.436-08:00 INFO CBAS.bootstrap.DeadlockWatchdog [main] The deadlock watchdog started at 300s frequency 2023-03-06T09:24:56.480-08:00 INFO CBAS.bootstrap.PeriodicThreadDump [main] Periodic thread dumps will be logged at DEBUG level every 300 seconds 2023-03-06T09:24:56.484-08:00 INFO CBAS.message.RegistrationTasksRequestMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] sending RegistrationTasksRequestMessage{state=BOOTSTRAPPING, nodeId='3f6082be197409ab968bd40b3be18c32', nodeStatus=IDLE, activePartitions=[0]} to CC 2023-03-06T09:24:56.502-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-9:ClusterController] Received message: RegistrationTasksRequestMessage{state=BOOTSTRAPPING, nodeId='3f6082be197409ab968bd40b3be18c32', nodeStatus=IDLE, activePartitions=[0]} 2023-03-06T09:24:56.504-08:00 INFO CBAS.replication.NcLifecycleCoordinator [Executor-9:ClusterController] Building registration tasks for node 3f6082be197409ab968bd40b3be18c32 with status IDLE and system state: BOOTSTRAPPING and active partitions [0] 2023-03-06T09:24:56.531-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: org.apache.asterix.app.replication.message.RegistrationTasksResponseMessage@3065d046 2023-03-06T09:24:56.538-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: UpdateNodeStatusTask{status=BOOTING, activePartitions=[0]} 2023-03-06T09:24:56.538-08:00 INFO CBAS.task.UpdateNodeStatusTask [Executor-11:3f6082be197409ab968bd40b3be18c32] updating node active partitions to [0] 2023-03-06T09:24:56.539-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: UpdateNodeStatusTask{status=BOOTING, activePartitions=[0]} 2023-03-06T09:24:56.539-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: LocalStorageCleanupTask{metadataPartitionId=-1} 2023-03-06T09:24:56.546-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: LocalStorageCleanupTask{metadataPartitionId=-1} 2023-03-06T09:24:56.547-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "StartReplicationServiceTask" } 2023-03-06T09:24:56.547-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "StartReplicationServiceTask" } 2023-03-06T09:24:56.548-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "MetadataBootstrapTask" } 2023-03-06T09:24:56.548-08:00 WARN CBAS.nc.ReplicaManager [Executor-11:3f6082be197409ab968bd40b3be18c32] promoting partition -1 2023-03-06T09:24:56.559-08:00 INFO CBAS.management.ReplicationChannel [3f6082be197409ab968bd40b3be18c32 Replication Channel Thread] opened Replication Channel @ IP Address: 0.0.0.0:9120 2023-03-06T09:24:56.560-08:00 INFO CBAS.nc.RecoveryManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Logs analysis phase completed. 2023-03-06T09:24:56.572-08:00 INFO CBAS.nc.RecoveryManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Analysis log count update/entityCommit/jobCommit/abort = 0/0/0/0 2023-03-06T09:24:56.574-08:00 INFO CBAS.nc.RecoveryManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Logs REDO phase completed. Redo logs count: 0 2023-03-06T09:24:56.578-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Getting latest checkpoint 2023-03-06T09:24:56.578-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:56.578-08:00 INFO CBAS.nc.RecoveryManager [Executor-11:3f6082be197409ab968bd40b3be18c32] The checkpoint file doesn't exist: systemState = PERMANENT_DATA_LOSS 2023-03-06T09:24:56.578-08:00 INFO CBAS.nc.NCAppRuntimeContext [Executor-11:3f6082be197409ab968bd40b3be18c32] Bootstrapping metadata 2023-03-06T09:24:56.605-08:00 INFO CBAS.metadata.CachingTxnIdFactory [Executor-11:3f6082be197409ab968bd40b3be18c32] block exhausted; obtaining new block from supplier 2023-03-06T09:24:56.610-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-9:ClusterController] Received message: TxnIdBlockRequest 2023-03-06T09:24:56.613-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-12:3f6082be197409ab968bd40b3be18c32] Received message: TxnIdBlockResponse 2023-03-06T09:24:56.987-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished enlistment of metadata B-trees in new universe 2023-03-06T09:24:57.029-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Dataverse/0/Dataverse", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.457-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Dataset/0/Dataset", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.471-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Index/0/Index", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.541-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished inserting initial datasets. 2023-03-06T09:24:57.547-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Datatype/0/Datatype", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.697-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished inserting initial datatypes. 2023-03-06T09:24:57.705-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Node/0/Node", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.710-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Nodegroup/0/Nodegroup", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.719-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/DatasourceAdapter/0/DatasourceAdapter", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.721-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished inserting built-in adapters. 2023-03-06T09:24:57.730-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/FeedPolicy/0/FeedPolicy", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.734-08:00 INFO CBAS.feeds.BuiltinFeedPolicies [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished adding built-in feed policies. 2023-03-06T09:24:57.741-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/CompactionPolicy/0/CompactionPolicy", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.746-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished creating metadata B-trees. 2023-03-06T09:24:57.776-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting DDL recovery ... 2023-03-06T09:24:57.828-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed DDL recovery. 2023-03-06T09:24:57.861-08:00 INFO CBAS.bootstrap.MetadataBootstrap [Executor-11:3f6082be197409ab968bd40b3be18c32] Finished inserting initial datasets. 2023-03-06T09:24:57.871-08:00 INFO CBAS.context.GlobalVirtualBufferCache [Executor-11:3f6082be197409ab968bd40b3be18c32] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Link/0/Link", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:24:57.874-08:00 INFO CBAS.nc.NCAppRuntimeContext [Executor-11:3f6082be197409ab968bd40b3be18c32] Metadata node bound 2023-03-06T09:24:57.875-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "MetadataBootstrapTask" } 2023-03-06T09:24:57.875-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "CheckpointTask" } 2023-03-06T09:24:57.876-08:00 INFO CBAS.recovery.CheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting sharp checkpoint... 2023-03-06T09:24:57.901-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Dataverse/0/Dataverse", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:57.995-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Dataset/0/Dataset", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.016-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Datatype/0/Datatype", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.046-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Index/0/Index", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.064-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Node/0/Node", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.082-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Nodegroup/0/Nodegroup", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.101-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/DatasourceAdapter/0/DatasourceAdapter", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.120-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/FeedPolicy/0/FeedPolicy", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.141-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/CompactionPolicy/0/CompactionPolicy", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.172-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-14:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Link/0/Link", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:24:58.187-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Listing of files in the checkpoint dir returned empty 2023-03-06T09:24:58.200-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Persisting checkpoint file to /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/checkpoint_0 which doesn't exist yet 2023-03-06T09:24:58.219-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed persisting checkpoint file to /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/checkpoint_0 which now exists 2023-03-06T09:24:58.219-08:00 INFO CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Listing of files in the checkpoint dir returned [/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/checkpoint_0] 2023-03-06T09:24:58.220-08:00 WARN CBAS.recovery.AbstractCheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Reading checkpoint file: /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/checkpoint_0 2023-03-06T09:24:58.220-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Terminating LogFlusher thread ... 2023-03-06T09:24:58.222-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] LogFlusher thread is terminated. 2023-03-06T09:24:58.222-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] closing current log file with id(0) 2023-03-06T09:24:58.223-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Created log file /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/transaction_log_1 2023-03-06T09:24:58.224-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Deleted log file /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/txn-log/transaction_log_0 2023-03-06T09:24:58.225-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] initializing log anchor with log file Id: 1 at offset: 0 2023-03-06T09:24:58.225-08:00 INFO CBAS.logging.LogManager [Executor-11:3f6082be197409ab968bd40b3be18c32] LogManager starts logging in LSN: 268435456 2023-03-06T09:24:58.225-08:00 INFO CBAS.recovery.CheckpointManager [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed sharp checkpoint. 2023-03-06T09:24:58.226-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "CheckpointTask" } 2023-03-06T09:24:58.226-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "StartLifecycleComponentsTask" } 2023-03-06T09:24:58.226-08:00 INFO CBAS.task.StartLifecycleComponentsTask [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting lifecycle components 2023-03-06T09:24:58.227-08:00 INFO CBAS.task.StartLifecycleComponentsTask [Executor-11:3f6082be197409ab968bd40b3be18c32] Coredump directory for NC is: /opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/coredump 2023-03-06T09:24:58.227-08:00 INFO CBAS.lifecycle.LifeCycleComponentManager [Executor-11:3f6082be197409ab968bd40b3be18c32] LifecycleComponentManager configured org.apache.hyracks.api.lifecycle.LifeCycleComponentManager@6812fa3a 2023-03-06T09:24:58.228-08:00 INFO CBAS.task.StartLifecycleComponentsTask [Executor-11:3f6082be197409ab968bd40b3be18c32] Configured:org.apache.hyracks.api.lifecycle.LifeCycleComponentManager@6812fa3a 2023-03-06T09:24:58.230-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "StartLifecycleComponentsTask" } 2023-03-06T09:24:58.231-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "ExportMetadataNodeTask", "export-stub" : true } 2023-03-06T09:24:58.280-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "ExportMetadataNodeTask", "export-stub" : true } 2023-03-06T09:24:58.281-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "BindMetadataNodeTask" } 2023-03-06T09:24:58.296-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "BindMetadataNodeTask" } 2023-03-06T09:24:58.296-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: UpdateNodeStatusTask{status=ACTIVE, activePartitions=[0]} 2023-03-06T09:24:58.296-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: UpdateNodeStatusTask{status=ACTIVE, activePartitions=[0]} 2023-03-06T09:24:58.297-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: { "class" : "CheckRebalanceRequiredTask" } 2023-03-06T09:24:58.360-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: { "class" : "CheckRebalanceRequiredTask" } 2023-03-06T09:24:58.360-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Starting startup task: com.couchbase.analytics.bootstrap.RegisterProxyablePrefixesTask@1b9e5210 2023-03-06T09:24:58.362-08:00 INFO CBAS.message.RegistrationTasksResponseMessage [Executor-11:3f6082be197409ab968bd40b3be18c32] Completed startup task: com.couchbase.analytics.bootstrap.RegisterProxyablePrefixesTask@1b9e5210 2023-03-06T09:24:58.423-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-9:ClusterController] Received message: NCLifecycleTaskReportMessage{nodeId='3f6082be197409ab968bd40b3be18c32', success=true, exception=null, localCounters=NcLocalCounters{maxResourceId=100, maxTxnId=512, maxJobId=0}, activePartitions=[0, -1]} 2023-03-06T09:24:58.426-08:00 INFO CBAS.utils.ClusterStateManager [Executor-9:ClusterController] Metadata node 3f6082be197409ab968bd40b3be18c32 is now active 2023-03-06T09:24:58.431-08:00 INFO CBAS.utils.ClusterStateManager [Executor-9:ClusterController] updating cluster state from UNUSABLE to PENDING 2023-03-06T09:24:58.440-08:00 INFO CBAS.utils.ClusterStateManager [Executor-9:ClusterController] Cluster State is now PENDING 2023-03-06T09:24:58.440-08:00 INFO CBAS.utils.ClusterStateManager [Executor-9:ClusterController] updating cluster state from PENDING to RECOVERING 2023-03-06T09:24:58.441-08:00 INFO CBAS.utils.ClusterStateManager [Executor-9:ClusterController] Cluster State is now RECOVERING 2023-03-06T09:24:58.447-08:00 INFO CBAS.bootstrap.GlobalRecoveryManager [Executor-10:ClusterController] Starting Global Recovery 2023-03-06T09:24:58.477-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: StorageCleanupRequestMessage 2023-03-06T09:24:58.504-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-9:ClusterController] Received message: { "response" : "success"} 2023-03-06T09:24:58.506-08:00 WARN CBAS.topology.PartitionsTopology [Executor-10:ClusterController] updating initial topology 2023-03-06T09:24:58.510-08:00 INFO CBAS.rebalance.ReplicaPlacementUtil [Executor-10:ClusterController] ordered surviving nodes: [3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:24:58.516-08:00 INFO CBAS.rebalance.TopologyManager [Executor-10:ClusterController] Updating partitions topology to {"version":1,"revision":0,"balanced":true,"ccNodeId":"3f6082be197409ab968bd40b3be18c32","metadataPartition":-1,"numReplicas":0,"partitions":[{"id":"0","origin":"3f6082be197409ab968bd40b3be18c32","master":"3f6082be197409ab968bd40b3be18c32","replicas":[]},{"id":"-1","origin":"3f6082be197409ab968bd40b3be18c32","master":"3f6082be197409ab968bd40b3be18c32","replicas":[]}]} 2023-03-06T09:24:58.535-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-11:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.messaging.TopologyMessage@37e8a38a 2023-03-06T09:24:58.538-08:00 INFO CBAS.rebalance.TopologyMonitor [Executor-13:3f6082be197409ab968bd40b3be18c32] got topology from cc: {"version":1,"revision":0,"balanced":true,"ccNodeId":"3f6082be197409ab968bd40b3be18c32","metadataPartition":-1,"numReplicas":0,"partitions":[{"id":"0","origin":"3f6082be197409ab968bd40b3be18c32","master":"3f6082be197409ab968bd40b3be18c32","replicas":[]},{"id":"-1","origin":"3f6082be197409ab968bd40b3be18c32","master":"3f6082be197409ab968bd40b3be18c32","replicas":[]}]} 2023-03-06T09:24:58.550-08:00 INFO CBAS.rebalance.TopologyMonitor [Topology Monitor] keeping partitions [-1, 0] 2023-03-06T09:24:59.537-08:00 INFO CBAS.rebalance.TopologyCoordinator [Executor-10:ClusterController] partitions topology rev 0 is now in-sync 2023-03-06T09:24:59.546-08:00 INFO CBAS.bootstrap.GlobalRecoveryManager [Executor-10:ClusterController] Global Recovery Completed. Refreshing cluster state... 2023-03-06T09:24:59.546-08:00 INFO CBAS.utils.ClusterStateManager [Executor-10:ClusterController] updating cluster state from RECOVERING to ACTIVE 2023-03-06T09:24:59.547-08:00 INFO CBAS.active.ActiveNotificationHandler [Executor-9:ClusterController] Starting active recovery 2023-03-06T09:24:59.547-08:00 INFO CBAS.utils.ClusterStateManager [Executor-10:ClusterController] Cluster State is now ACTIVE 2023-03-06T09:27:08.195-08:00 INFO CBAS.server.QueryServiceServlet [HighPriorityHttpExecutor(port:8095)-1] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id;","pretty":false,"mode":"immediate","clientContextID":null,"clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:08.242-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-9:ClusterController] Received message: ExecuteStatementRequestMessage(id=1, from=3f6082be197409ab968bd40b3be18c32): select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id; 2023-03-06T09:27:15.246-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.1 2023-03-06T09:27:15.285-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=1): 55 characters 2023-03-06T09:27:16.107-08:00 INFO CBAS.bootstrap.ClusterMonitor [Local cluster monitor pool stream consumer] updated buckets to [travel-sample] (was []) 2023-03-06T09:27:23.347-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-14] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE ANALYTICS SCOPE `travel-sample`.inventory;","pretty":false,"mode":"immediate","clientContextID":"ea4ed9a1-b568-408e-913d-80e4ca4ffd51","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:23.354-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=3, from=3f6082be197409ab968bd40b3be18c32): CREATE ANALYTICS SCOPE `travel-sample`.inventory; 2023-03-06T09:27:23.388-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:97391794-6169-4640-8bf0-51aa0365d672] Created analytics scope `travel-sample`.inventory 2023-03-06T09:27:23.419-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=3): 0 characters 2023-03-06T09:27:23.434-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-15] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"DISCONNECT LINK `travel-sample`.inventory.Local;","pretty":false,"mode":"immediate","clientContextID":"a4f94da0-8abe-4bd9-bd60-b3c2546f8b55","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:23.445-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=4, from=3f6082be197409ab968bd40b3be18c32): DISCONNECT LINK `travel-sample`.inventory.Local; 2023-03-06T09:27:23.480-08:00 INFO CBAS.lang.ConnectionStatement [QueryTranslator:c1bbd7b1-59a2-422b-be57-f96c8820c74d] Link: Link{name='`travel-sample`.inventory.Local', type='CB_LOCAL', active='true'} found 2023-03-06T09:27:23.481-08:00 INFO CBAS.lang.ConnectionStatement [QueryTranslator:c1bbd7b1-59a2-422b-be57-f96c8820c74d] Buckets not specified. Searching... 2023-03-06T09:27:23.481-08:00 INFO CBAS.lang.ConnectionStatement [QueryTranslator:c1bbd7b1-59a2-422b-be57-f96c8820c74d] Buckets found: [] 2023-03-06T09:27:23.515-08:00 INFO CBAS.lang.DisconnectLinkStatement [QueryTranslator:c1bbd7b1-59a2-422b-be57-f96c8820c74d] Disconnected link `travel-sample`.inventory.Local 2023-03-06T09:27:23.569-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=4): 0 characters 2023-03-06T09:27:23.582-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-0] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"ALTER COLLECTION `travel-sample`.inventory.airline ENABLE ANALYTICS;","pretty":false,"mode":"immediate","clientContextID":"588a6804-2b27-4fd4-8555-2237926e6603","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:23.591-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=5, from=3f6082be197409ab968bd40b3be18c32): ALTER COLLECTION `travel-sample`.inventory.airline ENABLE ANALYTICS; 2023-03-06T09:27:23.897-08:00 INFO CBAS.context.GlobalVirtualBufferCache [QueryTranslator:470cb209-80a3-42a4-bc0d-3a89df6cd091] Registered metadata index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_-1/Metadata/Bucket/0/Bucket", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:27:23.958-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:470cb209-80a3-42a4-bc0d-3a89df6cd091] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/travel-sample/^inventory/airline/0/airline 2023-03-06T09:27:24.055-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-12:ClusterController] Received message: ResourceIdRequestMessage 2023-03-06T09:27:24.069-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-22:3f6082be197409ab968bd40b3be18c32] Received message: ResourceIdRequestResponseMessage{resourceId=101, blockSize=25, exception=null} 2023-03-06T09:27:24.130-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.2 2023-03-06T09:27:24.183-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:470cb209-80a3-42a4-bc0d-3a89df6cd091] Created analytics collection `travel-sample`.inventory.airline on data service collection travel-sample.inventory.airline 2023-03-06T09:27:24.192-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=5): 0 characters 2023-03-06T09:27:24.202-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-1] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"ALTER COLLECTION `travel-sample`.inventory.airport ENABLE ANALYTICS;","pretty":false,"mode":"immediate","clientContextID":"5270b1f2-be15-4f37-a1c2-3b9043087211","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:24.209-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=6, from=3f6082be197409ab968bd40b3be18c32): ALTER COLLECTION `travel-sample`.inventory.airport ENABLE ANALYTICS; 2023-03-06T09:27:24.239-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:a16225af-f694-41bf-92a9-124c9c9fb137] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/travel-sample/^inventory/airport/0/airport 2023-03-06T09:27:24.326-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.3 2023-03-06T09:27:24.369-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:a16225af-f694-41bf-92a9-124c9c9fb137] Created analytics collection `travel-sample`.inventory.airport on data service collection travel-sample.inventory.airport 2023-03-06T09:27:24.405-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=6): 0 characters 2023-03-06T09:27:24.422-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-2] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"ALTER COLLECTION `travel-sample`.inventory.route ENABLE ANALYTICS;","pretty":false,"mode":"immediate","clientContextID":"c77fb24d-d74a-4460-bfae-610c2796ad79","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:24.433-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=7, from=3f6082be197409ab968bd40b3be18c32): ALTER COLLECTION `travel-sample`.inventory.route ENABLE ANALYTICS; 2023-03-06T09:27:24.491-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:a08fb978-8ac1-4bc9-aa6f-b1099e26e58a] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/travel-sample/^inventory/route/0/route 2023-03-06T09:27:24.574-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.4 2023-03-06T09:27:24.595-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:a08fb978-8ac1-4bc9-aa6f-b1099e26e58a] Created analytics collection `travel-sample`.inventory.route on data service collection travel-sample.inventory.route 2023-03-06T09:27:24.613-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=7): 0 characters 2023-03-06T09:27:24.636-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-3] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"ALTER COLLECTION `travel-sample`.inventory.landmark ENABLE ANALYTICS;","pretty":false,"mode":"immediate","clientContextID":"c729fc9b-f19f-4130-bf39-5c8cd08f169e","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:24.650-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=8, from=3f6082be197409ab968bd40b3be18c32): ALTER COLLECTION `travel-sample`.inventory.landmark ENABLE ANALYTICS; 2023-03-06T09:27:24.676-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:19ad357b-0111-4a5b-ae32-b14a9858d636] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/travel-sample/^inventory/landmark/0/landmark 2023-03-06T09:27:24.740-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.5 2023-03-06T09:27:24.780-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:19ad357b-0111-4a5b-ae32-b14a9858d636] Created analytics collection `travel-sample`.inventory.landmark on data service collection travel-sample.inventory.landmark 2023-03-06T09:27:24.794-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=8): 0 characters 2023-03-06T09:27:24.827-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-4] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"ALTER COLLECTION `travel-sample`.inventory.hotel ENABLE ANALYTICS;","pretty":false,"mode":"immediate","clientContextID":"ce0cbd9f-c20b-40e6-9510-07b4d58be2a3","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:24.830-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=9, from=3f6082be197409ab968bd40b3be18c32): ALTER COLLECTION `travel-sample`.inventory.hotel ENABLE ANALYTICS; 2023-03-06T09:27:24.856-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:72fa089d-76d5-4ddf-a3af-fba147baaae4] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/travel-sample/^inventory/hotel/0/hotel 2023-03-06T09:27:24.924-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.6 2023-03-06T09:27:24.938-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:72fa089d-76d5-4ddf-a3af-fba147baaae4] Created analytics collection `travel-sample`.inventory.hotel on data service collection travel-sample.inventory.hotel 2023-03-06T09:27:24.950-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=9): 0 characters 2023-03-06T09:27:24.967-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-5] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CONNECT LINK `travel-sample`.inventory.Local;","pretty":false,"mode":"immediate","clientContextID":"28d4e821-c931-4848-8cf5-5677448fcfba","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:24.974-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=10, from=3f6082be197409ab968bd40b3be18c32): CONNECT LINK `travel-sample`.inventory.Local; 2023-03-06T09:27:24.979-08:00 INFO CBAS.lang.ConnectLinkStatement [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Connecting [`travel-sample`.inventory.Local[]] 2023-03-06T09:27:24.980-08:00 INFO CBAS.lang.ConnectionStatement [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Link: Link{name='`travel-sample`.inventory.Local', type='CB_LOCAL', active='false'} found 2023-03-06T09:27:24.980-08:00 INFO CBAS.lang.ConnectionStatement [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Buckets not specified. Searching... 2023-03-06T09:27:24.995-08:00 INFO CBAS.lang.ConnectionStatement [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Buckets found: [{ "class" : "Bucket", "dataverse" : "`travel-sample`.inventory", "link" : "Local", "bucket" : "travel-sample", "uuid" : "", "running" : false }] 2023-03-06T09:27:25.161-08:00 INFO CBAS.util.EventLoopProvider [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Initializing Couchbase Environment 2023-03-06T09:27:29.000-08:00 INFO CBAS.metadata.BucketEventsListener [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Bucket UUID is about to be changed from to 8aa9ffdb1e91be49424defc4591dd758 and persisted on disk. 2023-03-06T09:27:29.001-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, `travel-sample`.inventory.landmark] 2023-03-06T09:27:29.191-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@719a536 2023-03-06T09:27:29.200-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@48d60b75 2023-03-06T09:27:29.214-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@42310de3 2023-03-06T09:27:29.217-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@3e09078 2023-03-06T09:27:29.418-08:00 INFO CBAS.util.EventLoopProvider [Worker:3f6082be197409ab968bd40b3be18c32] Initializing Couchbase Environment 2023-03-06T09:27:29.445-08:00 INFO CBAS.metadata.BucketManifestMonitor [Local/travel-sample bucket streaming] manifest updated: CollectionsManifest{uid=0x1} 2023-03-06T09:27:29.448-08:00 INFO CBAS.metadata.BucketEventsListener [Local/travel-sample bucket streaming] refreshManifest: CollectionsManifest{uid=0x1} maintains status quo 2023-03-06T09:27:29.448-08:00 INFO CBAS.metadata.BucketManifestMonitor [Local/travel-sample bucket streaming] manifest refreshed on {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"STARTING"} 2023-03-06T09:27:29.496-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-20:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0-1023:0,0,0"],"mins":{"travel-sample/inventory":{"airline":["0-1023:0,0,0"]}}} 2023-03-06T09:27:29.517-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-21:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0-1023:0,0,0"],"mins":{"travel-sample/inventory":{"hotel":["0-1023:0,0,0"]}}} 2023-03-06T09:27:29.519-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-16:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0-1023:0,0,0"],"mins":{"travel-sample/inventory":{"landmark":["0-1023:0,0,0"]}}} 2023-03-06T09:27:29.584-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-22:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0-1023:0,0,0"],"mins":{"travel-sample/inventory":{"airport":["0-1023:0,0,0"]}}} 2023-03-06T09:27:29.776-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@150bae5f 2023-03-06T09:27:29.779-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:27:29.780-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.7:TAID:TID:ANID:ODID:12:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:27:29.808-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0-1023:0,0,0"],"mins":{"travel-sample/inventory":{"route":["0-1023:0,0,0"]}}} 2023-03-06T09:27:29.812-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, `travel-sample`.inventory.landmark] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:27:29.844-08:00 INFO CBAS.lang.ConnectLinkStatement [QueryTranslator:80814f65-31d9-4786-8a64-d9af1d00f63f] Connected bucket travel-sample on link `travel-sample`.inventory.Local 2023-03-06T09:27:29.848-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:27:29.850-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:27:29.895-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=10): 0 characters 2023-03-06T09:27:29.929-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-29:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:27:29.936-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-7] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.airline_view(airline_iata_code STRING NOT UNKNOWN, airline_icao_code STRING, airline_callsign STRING, airline_name STRING, country STRING) DEFAULT NULL PRIMARY KEY (airline_iata_code) NOT ENFORCED AS SELECT iata AS airline_iata_code, icao AS airline_icao_code, callsign AS airline_callsign, name AS airline_name, country FROM `travel-sample`.inventory.airline;","pretty":false,"mode":"immediate","clientContextID":"1d420ae8-248d-4154-936f-9c28bae1cc19","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:29.948-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=11, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.airline_view(airline_iata_code STRING NOT UNKNOWN, airline_icao_code STRING, airline_callsign STRING, airline_name STRING, country STRING) DEFAULT NULL PRIMARY KEY (airline_iata_code) NOT ENFORCED AS SELECT iata AS airline_iata_code, icao AS airline_icao_code, callsign AS airline_callsign, name AS airline_name, country FROM `travel-sample`.inventory.airline; 2023-03-06T09:27:30.088-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:8f51d02b-828a-428c-8f91-9390036b309a] Created view `travel-sample`.inventory.airline_view 2023-03-06T09:27:30.119-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=11): 0 characters 2023-03-06T09:27:30.212-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-8] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.airport_view(airport_iata_code STRING NOT UNKNOWN, airport_icao_code STRING, airport_name STRING, city STRING, country STRING, tz STRING, airport_geo_lat DOUBLE, airport_geo_lon DOUBLE, airport_geo_alt bigint) DEFAULT NULL PRIMARY KEY (airport_iata_code) NOT ENFORCED AS SELECT faa AS airport_iata_code, icao AS airport_icao_code, airportname AS airport_name, city, country, tz, geo.lat AS airport_geo_lat, geo.lon AS airport_geo_lon, geo.alt AS airport_geo_alt FROM `travel-sample`.inventory.airport;","pretty":false,"mode":"immediate","clientContextID":"d1da6517-e5f7-441e-b0d1-8864bba0abc7","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:30.215-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=12, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.airport_view(airport_iata_code STRING NOT UNKNOWN, airport_icao_code STRING, airport_name STRING, city STRING, country STRING, tz STRING, airport_geo_lat DOUBLE, airport_geo_lon DOUBLE, airport_geo_alt bigint) DEFAULT NULL PRIMARY KEY (airport_iata_code) NOT ENFORCED AS SELECT faa AS airport_iata_code, icao AS airport_icao_code, airportname AS airport_name, city, country, tz, geo.lat AS airport_geo_lat, geo.lon AS airport_geo_lon, geo.alt AS airport_geo_alt FROM `travel-sample`.inventory.airport; 2023-03-06T09:27:30.253-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:27d3a7b6-2d2e-4b57-ac48-645abb4f1247] Created view `travel-sample`.inventory.airport_view 2023-03-06T09:27:30.261-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=12): 0 characters 2023-03-06T09:27:30.290-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-9] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.route_view(route_id BIGINT NOT UNKNOWN, airline_iata_code STRING NOT UNKNOWN, source_airport_iata_code STRING NOT UNKNOWN, dest_airport_iata_code STRING NOT UNKNOWN, route_stops BIGINT, route_equipment STRING, route_distance DOUBLE) DEFAULT NULL PRIMARY KEY (route_id) NOT ENFORCED FOREIGN KEY (airline_iata_code) REFERENCES `travel-sample`.inventory.airline_view NOT ENFORCED FOREIGN KEY (source_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED FOREIGN KEY (dest_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED AS SELECT id AS route_id, airline AS airline_iata_code, sourceairport AS source_airport_iata_code, destinationairport AS dest_airport_iata_code, stops AS route_stops, equipment AS route_equipment, distance AS route_distance from `travel-sample`.inventory.route;","pretty":false,"mode":"immediate","clientContextID":"0e0fa224-374a-44fa-ac0b-048ec52d7ba1","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:30.295-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=13, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.route_view(route_id BIGINT NOT UNKNOWN, airline_iata_code STRING NOT UNKNOWN, source_airport_iata_code STRING NOT UNKNOWN, dest_airport_iata_code STRING NOT UNKNOWN, route_stops BIGINT, route_equipment STRING, route_distance DOUBLE) DEFAULT NULL PRIMARY KEY (route_id) NOT ENFORCED FOREIGN KEY (airline_iata_code) REFERENCES `travel-sample`.inventory.airline_view NOT ENFORCED FOREIGN KEY (source_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED FOREIGN KEY (dest_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED AS SELECT id AS route_id, airline AS airline_iata_code, sourceairport AS source_airport_iata_code, destinationairport AS dest_airport_iata_code, stops AS route_stops, equipment AS route_equipment, distance AS route_distance from `travel-sample`.inventory.route; 2023-03-06T09:27:30.360-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:8cd3ff61-f9f9-4e58-8827-9a38f4f78c92] Created view `travel-sample`.inventory.route_view 2023-03-06T09:27:30.376-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=13): 0 characters 2023-03-06T09:27:30.410-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-10] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.route_view(route_id BIGINT NOT UNKNOWN, airline_iata_code STRING NOT UNKNOWN, source_airport_iata_code STRING NOT UNKNOWN, dest_airport_iata_code STRING NOT UNKNOWN, route_stops BIGINT, route_equipment STRING, route_distance DOUBLE) DEFAULT NULL PRIMARY KEY (route_id) NOT ENFORCED FOREIGN KEY (airline_iata_code) REFERENCES `travel-sample`.inventory.airline_view NOT ENFORCED FOREIGN KEY (source_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED FOREIGN KEY (dest_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED AS SELECT id AS route_id, airline AS airline_iata_code, sourceairport AS source_airport_iata_code, destinationairport AS dest_airport_iata_code, stops AS route_stops, equipment AS route_equipment, distance AS route_distance FROM `travel-sample`.inventory.route;","pretty":false,"mode":"immediate","clientContextID":"c8a4b883-4e0e-4b3e-83b3-4537fde6a914","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:30.417-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=14, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.route_view(route_id BIGINT NOT UNKNOWN, airline_iata_code STRING NOT UNKNOWN, source_airport_iata_code STRING NOT UNKNOWN, dest_airport_iata_code STRING NOT UNKNOWN, route_stops BIGINT, route_equipment STRING, route_distance DOUBLE) DEFAULT NULL PRIMARY KEY (route_id) NOT ENFORCED FOREIGN KEY (airline_iata_code) REFERENCES `travel-sample`.inventory.airline_view NOT ENFORCED FOREIGN KEY (source_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED FOREIGN KEY (dest_airport_iata_code) REFERENCES `travel-sample`.inventory.airport_view NOT ENFORCED AS SELECT id AS route_id, airline AS airline_iata_code, sourceairport AS source_airport_iata_code, destinationairport AS dest_airport_iata_code, stops AS route_stops, equipment AS route_equipment, distance AS route_distance FROM `travel-sample`.inventory.route; 2023-03-06T09:27:30.514-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:3214f629-2f94-4231-9734-18b47415bb7d] Replaced view `travel-sample`.inventory.route_view 2023-03-06T09:27:30.578-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=14): 0 characters 2023-03-06T09:27:30.610-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-11] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.route_schedule_view(route_id bigint NOT UNKNOWN, sched_day BIGINT NOT UNKNOWN, sched_time TIME NOT UNKNOWN, sched_flight STRING) DEFAULT NULL PRIMARY KEY (route_id, sched_day, sched_time) NOT ENFORCED FOREIGN KEY (route_id) REFERENCES `travel-sample`.inventory.route_view NOT ENFORCED AS SELECT r.id AS route_id, s.day AS sched_day, s.utc AS sched_time, s.flight AS sched_flight FROM `travel-sample`.inventory.route r UNNEST r.schedule s;","pretty":false,"mode":"immediate","clientContextID":"3aef1280-6e73-40dc-bc01-61cb45e13214","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:30.613-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=15, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.route_schedule_view(route_id bigint NOT UNKNOWN, sched_day BIGINT NOT UNKNOWN, sched_time TIME NOT UNKNOWN, sched_flight STRING) DEFAULT NULL PRIMARY KEY (route_id, sched_day, sched_time) NOT ENFORCED FOREIGN KEY (route_id) REFERENCES `travel-sample`.inventory.route_view NOT ENFORCED AS SELECT r.id AS route_id, s.day AS sched_day, s.utc AS sched_time, s.flight AS sched_flight FROM `travel-sample`.inventory.route r UNNEST r.schedule s; 2023-03-06T09:27:30.735-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:b0219343-d4f5-4390-bb68-87c90af7fade] Created view `travel-sample`.inventory.route_schedule_view 2023-03-06T09:27:30.755-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=15): 0 characters 2023-03-06T09:27:30.763-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-12] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.landmark_view(landmark_id BIGINT NOT UNKNOWN, landmark_name STRING, landmark_address STRING, landmark_phone STRING, landmark_url STRING, landmark_hours STRING, landmark_price STRING, landmark_description STRING, landmark_geo_lat DOUBLE, landmark_geo_lon DOUBLE, country STRING, city STRING) DEFAULT NULL PRIMARY KEY(landmark_id) NOT ENFORCED AS SELECT id AS landmark_id, name AS landmark_name, address AS landmark_address, phone AS landmark_phone, url AS landmark_url, hours AS landmark_hours, prices AS landmark_price, content AS landmark_description, geo.lat AS landmark_geo_lat, geo.lon AS landmark_geo_lon, country, city FROM `travel-sample`.inventory.landmark;","pretty":false,"mode":"immediate","clientContextID":"d9c4f8b3-be5e-42a8-8227-5f4b6274113d","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:30.768-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=16, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.landmark_view(landmark_id BIGINT NOT UNKNOWN, landmark_name STRING, landmark_address STRING, landmark_phone STRING, landmark_url STRING, landmark_hours STRING, landmark_price STRING, landmark_description STRING, landmark_geo_lat DOUBLE, landmark_geo_lon DOUBLE, country STRING, city STRING) DEFAULT NULL PRIMARY KEY(landmark_id) NOT ENFORCED AS SELECT id AS landmark_id, name AS landmark_name, address AS landmark_address, phone AS landmark_phone, url AS landmark_url, hours AS landmark_hours, prices AS landmark_price, content AS landmark_description, geo.lat AS landmark_geo_lat, geo.lon AS landmark_geo_lon, country, city FROM `travel-sample`.inventory.landmark; 2023-03-06T09:27:30.802-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:075a05f0-9354-4f5e-a328-496c3f59f8fd] Created view `travel-sample`.inventory.landmark_view 2023-03-06T09:27:30.825-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=16): 0 characters 2023-03-06T09:27:30.899-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-13] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.hotel_view(hotel_id bigint NOT UNKNOWN, hotel_name STRING, hotel_address STRING, hotel_phone STRING, hotel_url STRING, hotel_price STRING, hotel_description STRING, hotel_free_breakfast BOOLEAN, hotel_free_internet BOOLEAN, hotel_free_parking BOOLEAN, hotel_geo_lat DOUBLE, hotel_geo_lon DOUBLE, country STRING, city STRING) DEFAULT NULL PRIMARY KEY(hotel_id) NOT ENFORCED AS SELECT id AS hotel_id, name AS hotel_name, address AS hotel_address, phone AS hotel_phone, url AS hotel_url, price AS hotel_price, description AS hotel_description, free_breakfast AS hotel_free_breakfast, free_internet AS hotel_free_internet, free_parking AS hotel_free_parking, geo.lat AS hotel_geo_lat, geo.lon AS hotel_geo_lon, country, city FROM `travel-sample`.inventory.hotel;","pretty":false,"mode":"immediate","clientContextID":"f51b15a7-76d1-43de-a7ea-bdd649456105","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:30.913-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=17, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.hotel_view(hotel_id bigint NOT UNKNOWN, hotel_name STRING, hotel_address STRING, hotel_phone STRING, hotel_url STRING, hotel_price STRING, hotel_description STRING, hotel_free_breakfast BOOLEAN, hotel_free_internet BOOLEAN, hotel_free_parking BOOLEAN, hotel_geo_lat DOUBLE, hotel_geo_lon DOUBLE, country STRING, city STRING) DEFAULT NULL PRIMARY KEY(hotel_id) NOT ENFORCED AS SELECT id AS hotel_id, name AS hotel_name, address AS hotel_address, phone AS hotel_phone, url AS hotel_url, price AS hotel_price, description AS hotel_description, free_breakfast AS hotel_free_breakfast, free_internet AS hotel_free_internet, free_parking AS hotel_free_parking, geo.lat AS hotel_geo_lat, geo.lon AS hotel_geo_lon, country, city FROM `travel-sample`.inventory.hotel; 2023-03-06T09:27:30.976-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:dedf2ba4-c61f-4431-ba0b-c9928d819404] Created view `travel-sample`.inventory.hotel_view 2023-03-06T09:27:30.983-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=17): 0 characters 2023-03-06T09:27:31.026-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-14] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.hotel_review_view(hotel_id BIGINT NOT UNKNOWN, review_author STRING NOT UNKNOWN, review_timestamp DATETIME NOT UNKNOWN, review_rating_overall BIGINT, review_content STRING) DEFAULT NULL DATETIME 'YYYY-MM-DD hh:mm:ss z' PRIMARY KEY (hotel_id, review_author, review_timestamp) NOT ENFORCED FOREIGN KEY (hotel_id) REFERENCES `travel-sample`.inventory.hotel_view NOT ENFORCED AS SELECT h.id AS hotel_id, r.author AS review_author, r.date AS review_timestamp, r.ratings.Overall AS review_rating_overall, r.content AS review_content FROM `travel-sample`.inventory.hotel h UNNEST h.reviews r;","pretty":false,"mode":"immediate","clientContextID":"a38c8f2b-66b0-4206-a026-70bdfcd014b4","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:31.029-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=18, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.hotel_review_view(hotel_id BIGINT NOT UNKNOWN, review_author STRING NOT UNKNOWN, review_timestamp DATETIME NOT UNKNOWN, review_rating_overall BIGINT, review_content STRING) DEFAULT NULL DATETIME 'YYYY-MM-DD hh:mm:ss z' PRIMARY KEY (hotel_id, review_author, review_timestamp) NOT ENFORCED FOREIGN KEY (hotel_id) REFERENCES `travel-sample`.inventory.hotel_view NOT ENFORCED AS SELECT h.id AS hotel_id, r.author AS review_author, r.date AS review_timestamp, r.ratings.Overall AS review_rating_overall, r.content AS review_content FROM `travel-sample`.inventory.hotel h UNNEST h.reviews r; 2023-03-06T09:27:31.085-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:144b06f4-ee4f-4b2b-bbe7-8e2dddcec9f3] Created view `travel-sample`.inventory.hotel_review_view 2023-03-06T09:27:31.103-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=18): 0 characters 2023-03-06T09:27:31.118-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-15] handleRequest: {"host":"127.0.0.1:8095","path":"/query/service","statement":"CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.hotel_endorsement_view(hotel_id bigint NOT UNKNOWN, endorsement_author STRING NOT UNKNOWN) DEFAULT NULL PRIMARY KEY (hotel_id, endorsement_author) NOT ENFORCED FOREIGN KEY (hotel_id) REFERENCES `travel-sample`.inventory.hotel_view NOT ENFORCED AS SELECT distinct h.id AS hotel_id, e AS endorsement_author FROM `travel-sample`.inventory.hotel h UNNEST h.public_likes e;","pretty":false,"mode":"immediate","clientContextID":"94e99a94-df34-4fc5-9c3f-3cdd2c4aba31","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":59999,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:31.120-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=19, from=3f6082be197409ab968bd40b3be18c32): CREATE OR REPLACE ANALYTICS VIEW `travel-sample`.inventory.hotel_endorsement_view(hotel_id bigint NOT UNKNOWN, endorsement_author STRING NOT UNKNOWN) DEFAULT NULL PRIMARY KEY (hotel_id, endorsement_author) NOT ENFORCED FOREIGN KEY (hotel_id) REFERENCES `travel-sample`.inventory.hotel_view NOT ENFORCED AS SELECT distinct h.id AS hotel_id, e AS endorsement_author FROM `travel-sample`.inventory.hotel h UNNEST h.public_likes e; 2023-03-06T09:27:31.165-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:717c7f5a-1e17-474c-ba45-1e43ae1b0799] Created view `travel-sample`.inventory.hotel_endorsement_view 2023-03-06T09:27:31.187-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=19): 0 characters 2023-03-06T09:27:34.554-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.7:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/hotel/0/hotel", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:27:35.477-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.7:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airport/0/airport", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:27:37.064-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.7:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/route/0/route", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:27:37.649-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.7:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airline/0/airline", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:27:38.281-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.7:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/landmark/0/landmark", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:27:43.693-08:00 INFO CBAS.server.QueryServiceServlet [HighPriorityHttpExecutor(port:8095)-4] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id;","pretty":false,"mode":"immediate","clientContextID":null,"clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:27:43.707-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-15:ClusterController] Received message: ExecuteStatementRequestMessage(id=20, from=3f6082be197409ab968bd40b3be18c32): select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id; 2023-03-06T09:27:45.611-08:00 WARN CBAS.server.HttpServerHandler [nioEventLoopGroup-5-3] Failure handling HTTP Request java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[?:?] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:233) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:223) ~[?:?] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:356) ~[?:?] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:259) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:27:45.687-08:00 WARN CBAS.server.HttpServerHandler [nioEventLoopGroup-5-6] Failure handling HTTP Request java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[?:?] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:233) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:223) ~[?:?] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:356) ~[?:?] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:259) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:27:45.687-08:00 WARN CBAS.server.HttpServerHandler [nioEventLoopGroup-5-4] Failure handling HTTP Request java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[?:?] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:233) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:223) ~[?:?] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:356) ~[?:?] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:259) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:27:45.612-08:00 WARN CBAS.server.HttpServerHandler [nioEventLoopGroup-5-7] Failure handling HTTP Request java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[?:?] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:233) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:223) ~[?:?] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:356) ~[?:?] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:259) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:27:45.613-08:00 WARN CBAS.server.HttpServerHandler [nioEventLoopGroup-5-8] Failure handling HTTP Request java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[?:?] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:233) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:223) ~[?:?] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:356) ~[?:?] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:259) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:27:45.612-08:00 WARN CBAS.server.HttpServerHandler [nioEventLoopGroup-5-5] Failure handling HTTP Request java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:?] at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) ~[?:?] at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:276) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:233) ~[?:?] at sun.nio.ch.IOUtil.read(IOUtil.java:223) ~[?:?] at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:356) ~[?:?] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:259) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:357) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.87.Final.jar:4.1.87.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:27:54.398-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.8 2023-03-06T09:27:54.442-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=20): 55 characters 2023-03-06T09:29:52.190-08:00 INFO CBAS.cc.ClusterControllerIPCI [IPC Network Listener Thread [/0.0.0.0:9112]] exception in/or processing message java.io.InvalidClassException: org.apache.hyracks.control.common.controllers.NodeRegistration; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 2 at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:560) ~[?:?] at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2020) ~[?:?] at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?] at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserialize(JavaSerializationBasedPayloadSerializerDeserializer.java:66) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserializeObject(JavaSerializationBasedPayloadSerializerDeserializer.java:37) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserialize(CCNCFunctions.java:1564) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserializeObject(CCNCFunctions.java:1458) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.Message.read(Message.java:117) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCHandle.processIncomingMessages(IPCHandle.java:169) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.read(IPCConnectionManager.java:440) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.processSelectedKeys(IPCConnectionManager.java:261) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.doRun(IPCConnectionManager.java:231) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.run(IPCConnectionManager.java:213) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] 2023-03-06T09:35:58.566-08:00 INFO CBAS.cc.ClusterControllerIPCI [IPC Network Listener Thread [/0.0.0.0:9112]] exception in/or processing message java.io.InvalidClassException: org.apache.hyracks.control.common.controllers.NodeRegistration; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 2 at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:560) ~[?:?] at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2020) ~[?:?] at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?] at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserialize(JavaSerializationBasedPayloadSerializerDeserializer.java:66) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserializeObject(JavaSerializationBasedPayloadSerializerDeserializer.java:37) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserialize(CCNCFunctions.java:1564) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserializeObject(CCNCFunctions.java:1458) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.Message.read(Message.java:117) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCHandle.processIncomingMessages(IPCHandle.java:169) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.read(IPCConnectionManager.java:440) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.processSelectedKeys(IPCConnectionManager.java:261) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.doRun(IPCConnectionManager.java:231) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.run(IPCConnectionManager.java:213) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] 2023-03-06T09:42:04.926-08:00 INFO CBAS.cc.ClusterControllerIPCI [IPC Network Listener Thread [/0.0.0.0:9112]] exception in/or processing message java.io.InvalidClassException: org.apache.hyracks.control.common.controllers.NodeRegistration; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 2 at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:560) ~[?:?] at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2020) ~[?:?] at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?] at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserialize(JavaSerializationBasedPayloadSerializerDeserializer.java:66) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserializeObject(JavaSerializationBasedPayloadSerializerDeserializer.java:37) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserialize(CCNCFunctions.java:1564) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserializeObject(CCNCFunctions.java:1458) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.Message.read(Message.java:117) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCHandle.processIncomingMessages(IPCHandle.java:169) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.read(IPCConnectionManager.java:440) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.processSelectedKeys(IPCConnectionManager.java:261) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.doRun(IPCConnectionManager.java:231) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.run(IPCConnectionManager.java:213) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] 2023-03-06T09:42:06.379-08:00 INFO CBAS.server.QueryServiceServlet [HighPriorityHttpExecutor(port:8095)-3] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id;","pretty":false,"mode":"immediate","clientContextID":null,"clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:42:06.386-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: ExecuteStatementRequestMessage(id=194, from=3f6082be197409ab968bd40b3be18c32): select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id; 2023-03-06T09:42:09.843-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.9 2023-03-06T09:42:09.852-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=194): 55 characters 2023-03-06T09:43:57.099-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-5] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"create dataset if not exists route on `travel-sample`.inventory.route","pretty":false,"mode":"immediate","clientContextID":"dd1e914f-365c-4e77-8ebb-b89f7c864bd6","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:43:57.102-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-23:ClusterController] Received message: ExecuteStatementRequestMessage(id=240, from=3f6082be197409ab968bd40b3be18c32): create dataset if not exists route on `travel-sample`.inventory.route; 2023-03-06T09:43:57.123-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-14:ClusterController : WaitForCompletionForJobId: JID:0.7] Sending stop messages to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:43:57.123-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-14:ClusterController : WaitForCompletionForJobId: JID:0.7] Sending to 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:43:57.127-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMessage{kind=STOP_ACTIVITY, runtimeId=(Local/travel-sample)[0]:BO} 2023-03-06T09:43:57.130-08:00 INFO CBAS.runtime.BucketOperatorNodePushable [Executor-48:3f6082be197409ab968bd40b3be18c32] (Local/travel-sample)[0]:BO aborting 2023-03-06T09:43:58.140-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.7:TAID:TID:ANID:ODID:12:0:0:0:(Local/travel-sample)[0]:BO] State is being set from STARTED to STOPPED 2023-03-06T09:43:58.142-08:00 INFO CBAS.active.ActiveSourceOperatorNodePushable [SAO:JID:0.7:TAID:TID:ANID:ODID:12:0:0:0] deinitialize() returning on ActiveSourceOperatorNodePushable 2023-03-06T09:43:58.146-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_DEREGISTERED 2023-03-06T09:43:58.163-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-50:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/hotel/0/hotel", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:43:58.183-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-51:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airline/0/airline", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:43:58.280-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-54:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/route/0/route", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:43:58.413-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-51:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airport/0/airport", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:43:58.495-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-50:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/landmark/0/landmark", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:43:58.718-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.7 2023-03-06T09:43:58.736-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:8d7c7daf-2bdf-452e-be18-f0ca7bc5e4f8] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/Default/route/0/route 2023-03-06T09:43:58.758-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.10 2023-03-06T09:43:58.773-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:8d7c7daf-2bdf-452e-be18-f0ca7bc5e4f8] Created analytics collection Default.route on data service collection travel-sample.inventory.route 2023-03-06T09:43:59.178-08:00 INFO CBAS.metadata.BucketEventsListener [QueryTranslator:8d7c7daf-2bdf-452e-be18-f0ca7bc5e4f8] Bucket UUID is about to be changed from to 8aa9ffdb1e91be49424defc4591dd758 and persisted on disk. 2023-03-06T09:43:59.182-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, `travel-sample`.inventory.landmark] 2023-03-06T09:43:59.210-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@56e37a57 2023-03-06T09:43:59.213-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@794e1d37 2023-03-06T09:43:59.218-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@54a00df5 2023-03-06T09:43:59.225-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@2397a9ea 2023-03-06T09:43:59.229-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@6e6b5e0d 2023-03-06T09:43:59.283-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-29:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:43:59.287-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=240): 0 characters 2023-03-06T09:43:59.295-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-30:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,21,21","1:41066628587699,21,21","2:177758718421559,79,79","3:236929104110827,24,2...,"mins":{"travel-sample/inventory":{"hotel":["0:82952508806235,21,21","1:41066628587699,21,21","2:177758718421559,79,79","3:236929104110827,24,2...}}} 2023-03-06T09:43:59.298-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-23:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,88,88","1:41066628587699,39,39","2:177758718421559,68,68","3:236929104110827,75,7...,"mins":{"travel-sample/inventory":{"landmark":["0:82952508806235,88,88","1:41066628587699,39,39","2:177758718421559,68,68","3:236929104110827,75,7...}}} 2023-03-06T09:43:59.311-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,96,96","1:41066628587699,77,77","2:177758718421559,80,80","3:236929104110827,80,8...,"mins":{"Default":{"route":["0-1023:0,0,0"]},"travel-sample/inventory":{"route":["0:82952508806235,96,96","1:41066628587699,77,77","2:177758718421559,80,80","3:236929104110827,80,8...}}} 2023-03-06T09:43:59.321-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,21,21","1:41066628587699,21,21","2:177758718421559,21,21","3:236929104110827,50,5...,"mins":{"travel-sample/inventory":{"airline":["0:82952508806235,21,21","1:41066628587699,21,21","2:177758718421559,21,21","3:236929104110827,50,5...}}} 2023-03-06T09:43:59.327-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,21,21","1:41066628587699,76,76","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"airport":["0:82952508806235,21,21","1:41066628587699,76,76","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:43:59.341-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, `travel-sample`.inventory.landmark] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:43:59.347-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:43:59.347-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:43:59.354-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.11:TAID:TID:ANID:ODID:14:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:43:59.379-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-61:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:43:59.467-08:00 INFO CBAS.server.QueryServiceServlet [HighPriorityHttpExecutor(port:8095)-5] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id;","pretty":false,"mode":"immediate","clientContextID":null,"clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:43:59.480-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=242, from=3f6082be197409ab968bd40b3be18c32): select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id; 2023-03-06T09:44:00.639-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.11:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/Default/route/0/route", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:44:04.279-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.12 2023-03-06T09:44:04.292-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=242): 56 characters 2023-03-06T09:44:15.381-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-10] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"CREATE DATASET IF NOT EXISTS airport ON `travel-sample`.inventory.airport","pretty":false,"mode":"immediate","clientContextID":"57264862-cf18-47dc-b7fe-94a54ebd33de","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:44:15.387-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: ExecuteStatementRequestMessage(id=250, from=3f6082be197409ab968bd40b3be18c32): CREATE DATASET IF NOT EXISTS airport ON `travel-sample`.inventory.airport; 2023-03-06T09:44:15.396-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-11:ClusterController : WaitForCompletionForJobId: JID:0.11] Sending stop messages to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:44:15.396-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-11:ClusterController : WaitForCompletionForJobId: JID:0.11] Sending to 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:44:15.397-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMessage{kind=STOP_ACTIVITY, runtimeId=(Local/travel-sample)[0]:BO} 2023-03-06T09:44:15.399-08:00 INFO CBAS.runtime.BucketOperatorNodePushable [Executor-48:3f6082be197409ab968bd40b3be18c32] (Local/travel-sample)[0]:BO aborting 2023-03-06T09:44:16.408-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.11:TAID:TID:ANID:ODID:14:0:0:0:(Local/travel-sample)[0]:BO] State is being set from STARTED to STOPPED 2023-03-06T09:44:16.411-08:00 INFO CBAS.active.ActiveSourceOperatorNodePushable [SAO:JID:0.11:TAID:TID:ANID:ODID:14:0:0:0] deinitialize() returning on ActiveSourceOperatorNodePushable 2023-03-06T09:44:16.413-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_DEREGISTERED 2023-03-06T09:44:16.418-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-54:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [2,2] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airline/0/airline", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 1, "num-scheduled-flushes":1, "current-memory-component":0} 2023-03-06T09:44:16.419-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-50:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [2,2] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/landmark/0/landmark", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 1, "num-scheduled-flushes":1, "current-memory-component":0} 2023-03-06T09:44:16.447-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-51:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/Default/route/0/route", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:44:16.447-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-54:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [2,2] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/route/0/route", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 1, "num-scheduled-flushes":1, "current-memory-component":0} 2023-03-06T09:44:17.254-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-50:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [2,2] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/hotel/0/hotel", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 1, "num-scheduled-flushes":1, "current-memory-component":0} 2023-03-06T09:44:17.255-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-51:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [2,2] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airport/0/airport", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 1, "num-scheduled-flushes":1, "current-memory-component":0} 2023-03-06T09:44:17.274-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.11 2023-03-06T09:44:17.286-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:0ed425b3-1d59-44ea-ae1b-20023ca0f5eb] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/Default/airport/0/airport 2023-03-06T09:44:17.344-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.13 2023-03-06T09:44:17.358-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:0ed425b3-1d59-44ea-ae1b-20023ca0f5eb] Created analytics collection Default.airport on data service collection travel-sample.inventory.airport 2023-03-06T09:44:17.728-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, `travel-sample`.inventory.landmark, Default.airport] 2023-03-06T09:44:17.742-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@3f858aee 2023-03-06T09:44:17.752-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@4b26056c 2023-03-06T09:44:17.757-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@4aa0059f 2023-03-06T09:44:17.766-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@41e6afcd 2023-03-06T09:44:17.769-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@52a78fe5 2023-03-06T09:44:17.776-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:44:17.780-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"landmark":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...}}} 2023-03-06T09:44:17.783-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:44:17.791-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=250): 0 characters 2023-03-06T09:44:17.793-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"hotel":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...}}} 2023-03-06T09:44:17.799-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.14:TAID:TID:ANID:ODID:16:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:44:17.824-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airport":["0-1023:0,0,0"]},"travel-sample/inventory":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:44:17.832-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:44:17.835-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, `travel-sample`.inventory.landmark, Default.airport] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:44:17.835-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:44:17.835-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:44:17.847-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-22:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:44:17.988-08:00 INFO CBAS.server.QueryServiceServlet [HighPriorityHttpExecutor(port:8095)-13] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id;","pretty":false,"mode":"immediate","clientContextID":null,"clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:44:17.997-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-30:ClusterController] Received message: ExecuteStatementRequestMessage(id=252, from=3f6082be197409ab968bd40b3be18c32): select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id; 2023-03-06T09:44:18.584-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.14:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/Default/airport/0/airport", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:44:22.273-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.15 2023-03-06T09:44:22.281-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=252): 56 characters 2023-03-06T09:44:27.558-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-14] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"CREATE DATASET IF NOT EXISTS airline ON `travel-sample`.inventory.airline","pretty":false,"mode":"immediate","clientContextID":"ec969c0d-6e42-42e4-8207-006821230f1c","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:44:27.560-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-29:ClusterController] Received message: ExecuteStatementRequestMessage(id=258, from=3f6082be197409ab968bd40b3be18c32): CREATE DATASET IF NOT EXISTS airline ON `travel-sample`.inventory.airline; 2023-03-06T09:44:27.569-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-11:ClusterController : WaitForCompletionForJobId: JID:0.14] Sending stop messages to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:44:27.569-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-11:ClusterController : WaitForCompletionForJobId: JID:0.14] Sending to 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:44:27.571-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMessage{kind=STOP_ACTIVITY, runtimeId=(Local/travel-sample)[0]:BO} 2023-03-06T09:44:27.572-08:00 INFO CBAS.runtime.BucketOperatorNodePushable [Executor-48:3f6082be197409ab968bd40b3be18c32] (Local/travel-sample)[0]:BO aborting 2023-03-06T09:44:28.577-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.14:TAID:TID:ANID:ODID:16:0:0:0:(Local/travel-sample)[0]:BO] State is being set from STARTED to STOPPED 2023-03-06T09:44:28.579-08:00 INFO CBAS.active.ActiveSourceOperatorNodePushable [SAO:JID:0.14:TAID:TID:ANID:ODID:16:0:0:0] deinitialize() returning on ActiveSourceOperatorNodePushable 2023-03-06T09:44:28.581-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_DEREGISTERED 2023-03-06T09:44:28.591-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-51:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [3,3] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airport/0/airport", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[3,3]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 2, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:44:28.594-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-50:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/Default/airport/0/airport", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:44:28.639-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.14 2023-03-06T09:44:28.686-08:00 INFO CBAS.utils.DatasetUtil [QueryTranslator:98a63a38-d79e-4e4f-b6d1-de038b47abac] CREATING File Splits: Node: 3f6082be197409ab968bd40b3be18c32 IO Device: 0 managed path: storage/partition_0/Default/airline/0/airline 2023-03-06T09:44:28.711-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.16 2023-03-06T09:44:28.720-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:98a63a38-d79e-4e4f-b6d1-de038b47abac] Created analytics collection Default.airline on data service collection travel-sample.inventory.airline 2023-03-06T09:44:29.142-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] 2023-03-06T09:44:29.151-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@41383fbf 2023-03-06T09:44:29.153-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@61eef07d 2023-03-06T09:44:29.167-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@f5efd7b 2023-03-06T09:44:29.177-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@7a4a6867 2023-03-06T09:44:29.177-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-28:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:44:29.179-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@4427970d 2023-03-06T09:44:29.185-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=258): 0 characters 2023-03-06T09:44:29.186-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"hotel":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...}}} 2023-03-06T09:44:29.199-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airline":["0-1023:0,0,0"]},"travel-sample/inventory":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:44:29.200-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.17:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:44:29.210-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"landmark":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...}}} 2023-03-06T09:44:29.216-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:44:29.225-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:44:29.227-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:44:29.228-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:44:29.228-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:44:29.242-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-59:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:44:29.363-08:00 INFO CBAS.server.QueryServiceServlet [HighPriorityHttpExecutor(port:8095)-5] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id;","pretty":false,"mode":"immediate","clientContextID":null,"clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":false,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":0,"sqlCompat":false,"scanConsistency":null,"scanWait":null} 2023-03-06T09:44:29.370-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-14:ClusterController] Received message: ExecuteStatementRequestMessage(id=260, from=3f6082be197409ab968bd40b3be18c32): select meta.* from (SELECT ds.DataverseName, ds.DataverseName || '.' || ds.DatasetName AS datasetFullyQualifiedName, ds.DatasetName AS id, TRUE AS isDataset, ds.BucketName AS bucketName, ds.ScopeName AS scopeName, ds.CollectionName AS collectionName, ds.BucketDataverseName as linkDataverseName, ds.`Filter` AS `filter`, ds.LinkName, ds.DatasetType, ds.ViewDetails, concat2(', ', (select value FieldName || ' ' || ( CASE WHEN lower(FieldType) = 'int64' THEN 'BIGINT' ELSE upper(FieldType) END) || ( CASE WHEN NOT IsNullable AND NOT IsMissable THEN ' NOT UNKNOWN' ELSE '' END) from t.Derived.Record.Fields)) AS TypeString, ( SELECT idx.IndexName, idx.SearchKey, idx.SearchKeyType FROM Metadata.`Index` AS idx WHERE idx.IsPrimary = false AND idx.DatasetName = ds.DatasetName AND idx.DataverseName = ds.DataverseName) AS indexes, ds.ExternalDetails.Properties AS externalDetails FROM Metadata.`Dataset` AS ds left join Metadata.Datatype t on ds.DataverseName = t.DataverseName and t.DatatypeName = ds.DatatypeName WHERE (ds.BucketName IS NOT missing OR ds.DatasetType = 'EXTERNAL' OR ds.DatasetType = 'VIEW')UNION ALL SELECT dv.DataverseName, TRUE AS isDataverse, ( SELECT l.Name FROM Metadata.`Link` AS l WHERE l.DataverseName = dv.DataverseName) AS links FROM Metadata.`Dataverse` AS dv WHERE dv.DataverseName != 'Metadata' UNION ALL SELECT DataverseName, Name, IsActive, `Type` as LinkType, TRUE as isLink FROM Metadata.`Link`) meta order by meta.isDataverse desc, meta.isLink desc, meta.DataverseName, meta.LinkName, meta.id; 2023-03-06T09:44:29.869-08:00 INFO CBAS.context.GlobalVirtualBufferCache [SA:JID:0.17:TAID:TID:ANID:ODID:1:0:0:0:0] Registered primary index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/Default/airline/0/airline", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":0, "current-memory-component":0} to the global VBC 2023-03-06T09:44:33.274-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.18 2023-03-06T09:44:33.280-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=260): 56 characters 2023-03-06T09:45:13.245-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-8] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"ANALYZE ANALYTICS COLLECTION route","pretty":false,"mode":"immediate","clientContextID":"8df5efb2-f0c8-45d6-addd-24b255b944cf","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:45:13.247-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: ExecuteStatementRequestMessage(id=280, from=3f6082be197409ab968bd40b3be18c32): ANALYZE ANALYTICS COLLECTION route; 2023-03-06T09:45:13.256-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-14:ClusterController : WaitForCompletionForJobId: JID:0.17] Sending stop messages to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:45:13.256-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-14:ClusterController : WaitForCompletionForJobId: JID:0.17] Sending to 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:45:13.257-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMessage{kind=STOP_ACTIVITY, runtimeId=(Local/travel-sample)[0]:BO} 2023-03-06T09:45:13.258-08:00 INFO CBAS.runtime.BucketOperatorNodePushable [Executor-48:3f6082be197409ab968bd40b3be18c32] (Local/travel-sample)[0]:BO aborting 2023-03-06T09:45:14.263-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.17:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from STARTED to STOPPED 2023-03-06T09:45:14.267-08:00 INFO CBAS.active.ActiveSourceOperatorNodePushable [SAO:JID:0.17:TAID:TID:ANID:ODID:18:0:0:0] deinitialize() returning on ActiveSourceOperatorNodePushable 2023-03-06T09:45:14.269-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_DEREGISTERED 2023-03-06T09:45:14.277-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-50:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [1,1] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/Default/airline/0/airline", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[1,1]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"null"}], "disk" : 0, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:45:14.277-08:00 INFO CBAS.impls.AbstractLSMIndex [Executor-51:3f6082be197409ab968bd40b3be18c32] Flushing component with id: [3,3] in the index {"class" : "LSMBTree", "dir" : "/opt/couchbase/var/lib/couchbase/data/@analytics/v_iodevice_0/storage/partition_0/travel-sample/^inventory/airline/0/airline", "memory" : [{"class":"LSMBTreeMemoryComponent", "state":"READABLE_UNWRITABLE_FLUSHING", "writers":0, "readers":1, "pendingFlushes":0, "id":"[3,3]"}, {"class":"LSMBTreeMemoryComponent", "state":"INACTIVE", "writers":0, "readers":0, "pendingFlushes":0, "id":"[2,2]"}], "disk" : 2, "num-scheduled-flushes":1, "current-memory-component":1} 2023-03-06T09:45:14.299-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.17 2023-03-06T09:45:14.358-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.19 2023-03-06T09:45:14.385-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.20 2023-03-06T09:45:14.752-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.21 2023-03-06T09:45:14.763-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:ea0da2d8-be50-4df1-8e11-d7390606491d] Analyzed analytics collection Default.route 2023-03-06T09:45:15.119-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] 2023-03-06T09:45:15.128-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@41b0a634 2023-03-06T09:45:15.130-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@488b43e9 2023-03-06T09:45:15.133-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@46c25c79 2023-03-06T09:45:15.135-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@4bfbd6ec 2023-03-06T09:45:15.138-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@fbe48a1 2023-03-06T09:45:15.159-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-29:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:45:15.160-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.22:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:45:15.173-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"landmark":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...}}} 2023-03-06T09:45:15.179-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=280): 0 characters 2023-03-06T09:45:15.181-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"hotel":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...}}} 2023-03-06T09:45:15.191-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:15.198-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:15.205-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:15.207-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:45:15.208-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:45:15.208-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:45:15.218-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-39:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:45:21.012-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-11] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"ANALYZE ANALYTICS COLLECTION airport","pretty":false,"mode":"immediate","clientContextID":"de9ff392-a8fd-4789-ac0f-7eedd040650c","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:45:21.014-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: ExecuteStatementRequestMessage(id=283, from=3f6082be197409ab968bd40b3be18c32): ANALYZE ANALYTICS COLLECTION airport; 2023-03-06T09:45:21.019-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-14:ClusterController : WaitForCompletionForJobId: JID:0.22] Sending stop messages to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:45:21.019-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-14:ClusterController : WaitForCompletionForJobId: JID:0.22] Sending to 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:45:21.020-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMessage{kind=STOP_ACTIVITY, runtimeId=(Local/travel-sample)[0]:BO} 2023-03-06T09:45:21.021-08:00 INFO CBAS.runtime.BucketOperatorNodePushable [Executor-48:3f6082be197409ab968bd40b3be18c32] (Local/travel-sample)[0]:BO aborting 2023-03-06T09:45:22.027-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.22:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from STARTED to STOPPED 2023-03-06T09:45:22.031-08:00 INFO CBAS.active.ActiveSourceOperatorNodePushable [SAO:JID:0.22:TAID:TID:ANID:ODID:18:0:0:0] deinitialize() returning on ActiveSourceOperatorNodePushable 2023-03-06T09:45:22.032-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_DEREGISTERED 2023-03-06T09:45:22.033-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.22 2023-03-06T09:45:22.055-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.23 2023-03-06T09:45:22.065-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.24 2023-03-06T09:45:22.125-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.25 2023-03-06T09:45:22.129-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:44046ca3-985c-4b23-8174-b7750f245a88] Analyzed analytics collection Default.airport 2023-03-06T09:45:22.497-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] 2023-03-06T09:45:22.505-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@2387ca34 2023-03-06T09:45:22.508-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@71444fa2 2023-03-06T09:45:22.511-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@7ea608d3 2023-03-06T09:45:22.513-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@666f458a 2023-03-06T09:45:22.519-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@7b24e519 2023-03-06T09:45:22.529-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-29:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:45:22.531-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=283): 0 characters 2023-03-06T09:45:22.533-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.26:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:45:22.551-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"hotel":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...}}} 2023-03-06T09:45:22.580-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"landmark":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...}}} 2023-03-06T09:45:22.595-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:22.600-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:22.604-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:22.607-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:45:22.607-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:45:22.607-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:45:22.617-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-63:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:45:27.668-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-13] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"ANALYZE ANALYTICS COLLECTION airline","pretty":false,"mode":"immediate","clientContextID":"939bef28-ed1d-4ed3-bc3e-ad85c57ef834","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:45:27.670-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: ExecuteStatementRequestMessage(id=287, from=3f6082be197409ab968bd40b3be18c32): ANALYZE ANALYTICS COLLECTION airline; 2023-03-06T09:45:27.675-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-30:ClusterController : WaitForCompletionForJobId: JID:0.26] Sending stop messages to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:45:27.675-08:00 INFO CBAS.active.ActiveEntityEventsListener [Executor-30:ClusterController : WaitForCompletionForJobId: JID:0.26] Sending to 3f6082be197409ab968bd40b3be18c32 2023-03-06T09:45:27.676-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMessage{kind=STOP_ACTIVITY, runtimeId=(Local/travel-sample)[0]:BO} 2023-03-06T09:45:27.678-08:00 INFO CBAS.runtime.BucketOperatorNodePushable [Executor-48:3f6082be197409ab968bd40b3be18c32] (Local/travel-sample)[0]:BO aborting 2023-03-06T09:45:28.685-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.26:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from STARTED to STOPPED 2023-03-06T09:45:28.688-08:00 INFO CBAS.active.ActiveSourceOperatorNodePushable [SAO:JID:0.26:TAID:TID:ANID:ODID:18:0:0:0] deinitialize() returning on ActiveSourceOperatorNodePushable 2023-03-06T09:45:28.690-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_DEREGISTERED 2023-03-06T09:45:28.693-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.26 2023-03-06T09:45:28.714-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.27 2023-03-06T09:45:28.726-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.28 2023-03-06T09:45:28.775-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.29 2023-03-06T09:45:28.780-08:00 INFO CBAS.lang.CBStatementExecutor [QueryTranslator:bc6813a8-da50-4492-a8fb-ba560f3e3616] Analyzed analytics collection Default.airline 2023-03-06T09:45:29.126-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] beginning starting state calculation for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] 2023-03-06T09:45:29.139-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@7d994234 2023-03-06T09:45:29.141-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@5ed6e23d 2023-03-06T09:45:29.146-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@1ca1af11 2023-03-06T09:45:29.148-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@2148918e 2023-03-06T09:45:29.150-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: com.couchbase.analytics.adapter.ShadowStatesRequest@16f7ff71 2023-03-06T09:45:29.161-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-29:ClusterController] Received message: (Local/travel-sample)[0]:BO:ActivePartitionMessage-RUNTIME_REGISTERED 2023-03-06T09:45:29.163-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=287): 0 characters 2023-03-06T09:45:29.164-08:00 INFO CBAS.dataflow.FeedRecordDataFlowController [SAO:JID:0.30:TAID:TID:ANID:ODID:18:0:0:0:(Local/travel-sample)[0]:BO] State is being set from CREATED to STARTED 2023-03-06T09:45:29.171-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"landmark":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,68,68","3:236929104110827,87,8...}}} 2023-03-06T09:45:29.192-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...,"mins":{"travel-sample/inventory":{"hotel":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,79,79","3:236929104110827,87,8...}}} 2023-03-06T09:45:29.202-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-27:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airport":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:29.203-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-11:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"route":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:29.207-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-32:ClusterController] Received message: {"class":"ShadowStatesResponse","max":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...,"mins":{"Default":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...},"travel-sample/inventory":{"airline":["0:82952508806235,97,97","1:41066628587699,79,79","2:177758718421559,81,81","3:236929104110827,87,8...}}} 2023-03-06T09:45:29.209-08:00 INFO CBAS.adapter.CouchbaseConnectorFactory [travel-sample (local) aggregated shadow state calculator] got starting state calculated for [`travel-sample`.inventory.hotel, `travel-sample`.inventory.airport, Default.route, `travel-sample`.inventory.route, `travel-sample`.inventory.airline, Default.airline, `travel-sample`.inventory.landmark, Default.airport] (listener {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"}) 2023-03-06T09:45:29.210-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] {"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} delivering 5 shadow states 2023-03-06T09:45:29.210-08:00 INFO CBAS.metadata.BucketEventsListener [{"class":"BucketEventsListener","entityId":"travel-sample/inventory/Local/travel-sample","state":"RUNNING"} aggregated shadow state deliverer] Sending generic message of type [Lorg.apache.commons.lang3.tuple.Pair; to ABSOLUTE:[3f6082be197409ab968bd40b3be18c32] 2023-03-06T09:45:29.219-08:00 INFO CBAS.messaging.NCMessageBroker [Executor-55:3f6082be197409ab968bd40b3be18c32] Received message: ActiveManagerMultiMessage{kind=GENERIC_EVENT, runtimeIds=[(Local/travel-sample)[0]:BO]} 2023-03-06T09:47:15.001-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-3] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"42437110-485b-4480-9634-cdbb9df59df4","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:47:15.003-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: ExecuteStatementRequestMessage(id=331, from=3f6082be197409ab968bd40b3be18c32): SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:47:15.245-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:335381dd-7a6b-447f-a91a-7c6601816ae8] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:47:15.255-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:335381dd-7a6b-447f-a91a-7c6601816ae8] ***running sample query*** 2023-03-06T09:47:15.255-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:335381dd-7a6b-447f-a91a-7c6601816ae8] ***returning from sample query*** 2023-03-06T09:47:15.333-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.31 2023-03-06T09:47:15.356-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:335381dd-7a6b-447f-a91a-7c6601816ae8] ***running sample query*** 2023-03-06T09:47:15.356-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:335381dd-7a6b-447f-a91a-7c6601816ae8] ***returning from sample query*** 2023-03-06T09:47:15.390-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.32 2023-03-06T09:47:15.877-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.33 2023-03-06T09:47:15.882-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=331): 56 characters 2023-03-06T09:47:48.169-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-10] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"explain SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+hashjoin probe(a) *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"c06c6f2f-ffff-4124-85c8-af6939004151","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:47:48.171-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-30:ClusterController] Received message: ExecuteStatementRequestMessage(id=345, from=3f6082be197409ab968bd40b3be18c32): explain SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+hashjoin probe(a) */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:47:48.437-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:4d9ff3d9-3132-41ce-a751-d4e01b8e298c] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:47:48.437-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:4d9ff3d9-3132-41ce-a751-d4e01b8e298c] ***running sample query*** 2023-03-06T09:47:48.437-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:4d9ff3d9-3132-41ce-a751-d4e01b8e298c] ***returning from sample query*** 2023-03-06T09:47:48.476-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.34 2023-03-06T09:47:48.487-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:4d9ff3d9-3132-41ce-a751-d4e01b8e298c] ***running sample query*** 2023-03-06T09:47:48.488-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:4d9ff3d9-3132-41ce-a751-d4e01b8e298c] ***returning from sample query*** 2023-03-06T09:47:48.521-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.35 2023-03-06T09:47:48.675-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=345): 23228 characters 2023-03-06T09:48:02.545-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-14] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"explain SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+hashjoin probe(a) *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"71516355-f560-4a8d-9039-39303e4e8ba2","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:48:02.547-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: ExecuteStatementRequestMessage(id=352, from=3f6082be197409ab968bd40b3be18c32): explain SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+hashjoin probe(a) */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:48:02.729-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:f655a1df-5165-47c6-b322-cb508658c100] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:48:02.730-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:f655a1df-5165-47c6-b322-cb508658c100] ***running sample query*** 2023-03-06T09:48:02.730-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:f655a1df-5165-47c6-b322-cb508658c100] ***returning from sample query*** 2023-03-06T09:48:02.767-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.36 2023-03-06T09:48:02.781-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:f655a1df-5165-47c6-b322-cb508658c100] ***running sample query*** 2023-03-06T09:48:02.782-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:f655a1df-5165-47c6-b322-cb508658c100] ***returning from sample query*** 2023-03-06T09:48:02.819-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.37 2023-03-06T09:48:02.950-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=352): 23228 characters 2023-03-06T09:48:11.218-08:00 INFO CBAS.cc.ClusterControllerIPCI [IPC Network Listener Thread [/0.0.0.0:9112]] exception in/or processing message java.io.InvalidClassException: org.apache.hyracks.control.common.controllers.NodeRegistration; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 2 at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:560) ~[?:?] at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2020) ~[?:?] at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?] at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserialize(JavaSerializationBasedPayloadSerializerDeserializer.java:66) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserializeObject(JavaSerializationBasedPayloadSerializerDeserializer.java:37) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserialize(CCNCFunctions.java:1564) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserializeObject(CCNCFunctions.java:1458) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.Message.read(Message.java:117) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCHandle.processIncomingMessages(IPCHandle.java:169) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.read(IPCConnectionManager.java:440) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.processSelectedKeys(IPCConnectionManager.java:261) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.doRun(IPCConnectionManager.java:231) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.run(IPCConnectionManager.java:213) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] 2023-03-06T09:48:18.661-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-3] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+hashjoin probe(a) *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"0f5d2015-7351-400e-bb80-ff06d87a9064","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:48:18.663-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-30:ClusterController] Received message: ExecuteStatementRequestMessage(id=360, from=3f6082be197409ab968bd40b3be18c32): SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+hashjoin probe(a) */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:48:18.868-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:2f2c7e46-cb35-4e8c-ae35-c006f78167c3] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:48:18.868-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:2f2c7e46-cb35-4e8c-ae35-c006f78167c3] ***running sample query*** 2023-03-06T09:48:18.869-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:2f2c7e46-cb35-4e8c-ae35-c006f78167c3] ***returning from sample query*** 2023-03-06T09:48:18.911-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.38 2023-03-06T09:48:18.922-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:2f2c7e46-cb35-4e8c-ae35-c006f78167c3] ***running sample query*** 2023-03-06T09:48:18.922-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:2f2c7e46-cb35-4e8c-ae35-c006f78167c3] ***returning from sample query*** 2023-03-06T09:48:18.953-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.39 2023-03-06T09:48:19.306-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.40 2023-03-06T09:48:19.310-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=360): 56 characters 2023-03-06T09:48:45.129-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-9] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"explain SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+hashjoin probe(r) *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"c3594180-84d2-46a6-acc3-c0b0d12184ff","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:48:45.132-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: ExecuteStatementRequestMessage(id=371, from=3f6082be197409ab968bd40b3be18c32): explain SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+hashjoin probe(r) */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:48:45.324-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:11ec54a4-9a6c-42d2-8367-47582d84d5cb] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:48:45.324-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:11ec54a4-9a6c-42d2-8367-47582d84d5cb] ***running sample query*** 2023-03-06T09:48:45.324-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:11ec54a4-9a6c-42d2-8367-47582d84d5cb] ***returning from sample query*** 2023-03-06T09:48:45.361-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.41 2023-03-06T09:48:45.371-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:11ec54a4-9a6c-42d2-8367-47582d84d5cb] ***running sample query*** 2023-03-06T09:48:45.372-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:11ec54a4-9a6c-42d2-8367-47582d84d5cb] ***returning from sample query*** 2023-03-06T09:48:45.397-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.42 2023-03-06T09:48:45.546-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=371): 23199 characters 2023-03-06T09:48:56.615-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-13] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"explain SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+hashjoin probe(r) *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"89f9838b-1284-447d-9de9-24795defa3ab","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:48:56.617-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-31:ClusterController] Received message: ExecuteStatementRequestMessage(id=377, from=3f6082be197409ab968bd40b3be18c32): explain SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+hashjoin probe(r) */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:48:56.797-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:9fcd0af8-f6f3-4c0e-be1d-8b8d8efd85c0] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:48:56.797-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:9fcd0af8-f6f3-4c0e-be1d-8b8d8efd85c0] ***running sample query*** 2023-03-06T09:48:56.798-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:9fcd0af8-f6f3-4c0e-be1d-8b8d8efd85c0] ***returning from sample query*** 2023-03-06T09:48:56.835-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.43 2023-03-06T09:48:56.844-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:9fcd0af8-f6f3-4c0e-be1d-8b8d8efd85c0] ***running sample query*** 2023-03-06T09:48:56.844-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:9fcd0af8-f6f3-4c0e-be1d-8b8d8efd85c0] ***returning from sample query*** 2023-03-06T09:48:56.874-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.44 2023-03-06T09:48:57.018-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=377): 23199 characters 2023-03-06T09:49:13.322-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-1] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+hashjoin probe(r) *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"0037b452-52ca-45d0-8d81-ff7e077afe6b","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:49:13.324-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: ExecuteStatementRequestMessage(id=385, from=3f6082be197409ab968bd40b3be18c32): SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+hashjoin probe(r) */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:49:13.523-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:3c9bf88c-d906-4b28-a564-337713bfa4a9] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:49:13.523-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:3c9bf88c-d906-4b28-a564-337713bfa4a9] ***running sample query*** 2023-03-06T09:49:13.524-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:3c9bf88c-d906-4b28-a564-337713bfa4a9] ***returning from sample query*** 2023-03-06T09:49:13.563-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.45 2023-03-06T09:49:13.572-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:3c9bf88c-d906-4b28-a564-337713bfa4a9] ***running sample query*** 2023-03-06T09:49:13.573-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:3c9bf88c-d906-4b28-a564-337713bfa4a9] ***returning from sample query*** 2023-03-06T09:49:13.601-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.46 2023-03-06T09:49:13.923-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.47 2023-03-06T09:49:13.927-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=385): 56 characters 2023-03-06T09:53:37.456-08:00 INFO CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-7] handleRequest: {"host":"172.23.104.91:8091","path":"/query/service","statement":"explain SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+ productivity *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"5bc721bb-da9e-46bd-a758-0172072a2ecb","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":true,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} 2023-03-06T09:53:37.457-08:00 INFO CBAS.messaging.CCMessageBroker [Executor-26:ClusterController] Received message: ExecuteStatementRequestMessage(id=461, from=3f6082be197409ab968bd40b3be18c32): explain SELECT COUNT(DISTINCT r.destinationairport)\nFROM airport a\n JOIN route r ON r.sourceairport /*+ productivity */ = a.faa\nWHERE a.city = 'San Francisco'\n AND a.country = 'United States'; 2023-03-06T09:53:37.637-08:00 WARN CBAS.config.ConfigManager [QueryTranslator:1fe4534f-5760-4371-a4c7-71691a7430ab] NC option [nc] storage.buffercache.pagesize being accessed outside of NC-scoped configuration. 2023-03-06T09:53:37.637-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:1fe4534f-5760-4371-a4c7-71691a7430ab] ***running sample query*** 2023-03-06T09:53:37.637-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:1fe4534f-5760-4371-a4c7-71691a7430ab] ***returning from sample query*** 2023-03-06T09:53:37.671-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.48 2023-03-06T09:53:37.681-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:1fe4534f-5760-4371-a4c7-71691a7430ab] ***running sample query*** 2023-03-06T09:53:37.681-08:00 INFO CBAS.cbo.CBStats [QueryTranslator:1fe4534f-5760-4371-a4c7-71691a7430ab] ***returning from sample query*** 2023-03-06T09:53:37.704-08:00 INFO CBAS.work.JobCleanupWork [Worker:ClusterController] Cleanup for job: JID:0.49 2023-03-06T09:53:37.710-08:00 INFO CBAS.translator.QueryTranslator [QueryTranslator:1fe4534f-5760-4371-a4c7-71691a7430ab] null java.lang.NullPointerException: null at org.apache.asterix.optimizer.rules.cbo.JoinEnum.findJoinNodeIndexByName(JoinEnum.java:303) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.findJoinSelectivity(Stats.java:94) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.getSelectivityFromAnnotation(Stats.java:158) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.getSelectivityFromAnnotationMain(Stats.java:173) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.JoinEnum.findJoinConditions(JoinEnum.java:379) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at com.couchbase.analytics.optimizer.rules.cbo.CBJoinEnum.findJoinConditions(CBJoinEnum.java:143) ~[cbas-connector-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.JoinEnum.enumerateJoins(JoinEnum.java:737) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.EnumerateJoinsRule.rewritePre(EnumerateJoinsRule.java:149) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:79) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.compiler.rewriter.rulecontrollers.SequentialOnceRuleController.rewriteWithRuleCollection(SequentialOnceRuleController.java:43) ~[algebricks-compiler-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runOptimizationSets(HeuristicOptimizer.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runLogicalOptimizationSets(HeuristicOptimizer.java:83) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.optimize(HeuristicOptimizer.java:63) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.compiler.api.HeuristicCompilerFactoryBuilder$CompilerImpl.optimize(HeuristicCompilerFactoryBuilder.java:163) ~[algebricks-compiler-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.api.common.APIFramework.compileQuery(APIFramework.java:271) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.rewriteCompileQuery(QueryTranslator.java:3775) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.lambda$handleQuery$2(QueryTranslator.java:4680) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.createAndRunJob(QueryTranslator.java:4818) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.deliverResult(QueryTranslator.java:4725) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.handleQuery(QueryTranslator.java:4695) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.compileAndExecute(QueryTranslator.java:491) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.message.ExecuteStatementRequestMessage.handle(ExecuteStatementRequestMessage.java:180) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.messaging.CCMessageBroker.receivedMessage(CCMessageBroker.java:64) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.cc.work.ApplicationMessageWork.lambda$notifyMessageBroker$0(ApplicationMessageWork.java:68) ~[hyracks-control-cc-7.2.0-5183.jar:7.2.0-5183] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:53:37.712-08:00 ERRO CBAS.apache.asterix [Executor-26:ClusterController] Unexpected exception java.lang.NullPointerException: null at org.apache.asterix.optimizer.rules.cbo.JoinEnum.findJoinNodeIndexByName(JoinEnum.java:303) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.findJoinSelectivity(Stats.java:94) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.getSelectivityFromAnnotation(Stats.java:158) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.getSelectivityFromAnnotationMain(Stats.java:173) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.JoinEnum.findJoinConditions(JoinEnum.java:379) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at com.couchbase.analytics.optimizer.rules.cbo.CBJoinEnum.findJoinConditions(CBJoinEnum.java:143) ~[cbas-connector-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.JoinEnum.enumerateJoins(JoinEnum.java:737) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.EnumerateJoinsRule.rewritePre(EnumerateJoinsRule.java:149) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:79) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.compiler.rewriter.rulecontrollers.SequentialOnceRuleController.rewriteWithRuleCollection(SequentialOnceRuleController.java:43) ~[algebricks-compiler-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runOptimizationSets(HeuristicOptimizer.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runLogicalOptimizationSets(HeuristicOptimizer.java:83) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.optimize(HeuristicOptimizer.java:63) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.compiler.api.HeuristicCompilerFactoryBuilder$CompilerImpl.optimize(HeuristicCompilerFactoryBuilder.java:163) ~[algebricks-compiler-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.api.common.APIFramework.compileQuery(APIFramework.java:271) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.rewriteCompileQuery(QueryTranslator.java:3775) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.lambda$handleQuery$2(QueryTranslator.java:4680) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.createAndRunJob(QueryTranslator.java:4818) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.deliverResult(QueryTranslator.java:4725) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.handleQuery(QueryTranslator.java:4695) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.compileAndExecute(QueryTranslator.java:491) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.message.ExecuteStatementRequestMessage.handle(ExecuteStatementRequestMessage.java:180) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.messaging.CCMessageBroker.receivedMessage(CCMessageBroker.java:64) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.cc.work.ApplicationMessageWork.lambda$notifyMessageBroker$0(ApplicationMessageWork.java:68) ~[hyracks-control-cc-7.2.0-5183.jar:7.2.0-5183] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:53:37.724-08:00 INFO CBAS.messaging.NCMessageBroker [Worker:3f6082be197409ab968bd40b3be18c32] Received message: ExecuteStatementResponseMessage(id=461): 0 characters 2023-03-06T09:53:37.727-08:00 WARN CBAS.server.QueryServiceServlet [HttpExecutor(port:8095)-7] handleException: unexpected exception: {"host":"172.23.104.91:8091","path":"/query/service","statement":"explain SELECT COUNT(DISTINCT r.destinationairport)\\nFROM airport a\\n JOIN route r ON r.sourceairport \\/*+ productivity *\\/ = a.faa\\nWHERE a.city = 'San Francisco'\\n AND a.country = 'United States'","pretty":false,"mode":"immediate","clientContextID":"5bc721bb-da9e-46bd-a758-0172072a2ecb","clientType":"ASTERIX","dataverse":null,"format":"CLEAN_JSON","timeout":9223372036854775807,"maxResultReads":1,"planFormat":"JSON","expressionTree":false,"rewrittenExpressionTree":false,"logicalPlan":false,"optimizedLogicalPlan":true,"job":false,"profile":"counts","signature":true,"multiStatement":false,"parseOnly":false,"readOnly":false,"maxWarnings":10,"sqlCompat":false,"scanConsistency":"not_bounded","scanWait":null} java.lang.NullPointerException: null at org.apache.asterix.optimizer.rules.cbo.JoinEnum.findJoinNodeIndexByName(JoinEnum.java:303) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.findJoinSelectivity(Stats.java:94) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.getSelectivityFromAnnotation(Stats.java:158) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.Stats.getSelectivityFromAnnotationMain(Stats.java:173) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.JoinEnum.findJoinConditions(JoinEnum.java:379) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at com.couchbase.analytics.optimizer.rules.cbo.CBJoinEnum.findJoinConditions(CBJoinEnum.java:143) ~[cbas-connector-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.JoinEnum.enumerateJoins(JoinEnum.java:737) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.optimizer.rules.cbo.EnumerateJoinsRule.rewritePre(EnumerateJoinsRule.java:149) ~[asterix-algebra-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:79) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.compiler.rewriter.rulecontrollers.SequentialOnceRuleController.rewriteWithRuleCollection(SequentialOnceRuleController.java:43) ~[algebricks-compiler-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runOptimizationSets(HeuristicOptimizer.java:92) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runLogicalOptimizationSets(HeuristicOptimizer.java:83) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.optimize(HeuristicOptimizer.java:63) ~[algebricks-core-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.algebricks.compiler.api.HeuristicCompilerFactoryBuilder$CompilerImpl.optimize(HeuristicCompilerFactoryBuilder.java:163) ~[algebricks-compiler-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.api.common.APIFramework.compileQuery(APIFramework.java:271) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.rewriteCompileQuery(QueryTranslator.java:3775) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.lambda$handleQuery$2(QueryTranslator.java:4680) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.createAndRunJob(QueryTranslator.java:4818) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.deliverResult(QueryTranslator.java:4725) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.handleQuery(QueryTranslator.java:4695) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.translator.QueryTranslator.compileAndExecute(QueryTranslator.java:491) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.app.message.ExecuteStatementRequestMessage.handle(ExecuteStatementRequestMessage.java:180) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.asterix.messaging.CCMessageBroker.receivedMessage(CCMessageBroker.java:64) ~[asterix-app-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.cc.work.ApplicationMessageWork.lambda$notifyMessageBroker$0(ApplicationMessageWork.java:68) ~[hyracks-control-cc-7.2.0-5183.jar:7.2.0-5183] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2023-03-06T09:54:17.719-08:00 INFO CBAS.cc.ClusterControllerIPCI [IPC Network Listener Thread [/0.0.0.0:9112]] exception in/or processing message java.io.InvalidClassException: org.apache.hyracks.control.common.controllers.NodeRegistration; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 2 at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:560) ~[?:?] at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2020) ~[?:?] at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?] at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?] at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?] at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?] at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserialize(JavaSerializationBasedPayloadSerializerDeserializer.java:66) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.JavaSerializationBasedPayloadSerializerDeserializer.deserializeObject(JavaSerializationBasedPayloadSerializerDeserializer.java:37) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserialize(CCNCFunctions.java:1564) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.control.common.ipc.CCNCFunctions$SerializerDeserializer.deserializeObject(CCNCFunctions.java:1458) ~[hyracks-control-common-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.Message.read(Message.java:117) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCHandle.processIncomingMessages(IPCHandle.java:169) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.read(IPCConnectionManager.java:440) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.processSelectedKeys(IPCConnectionManager.java:261) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.doRun(IPCConnectionManager.java:231) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183] at org.apache.hyracks.ipc.impl.IPCConnectionManager$NetworkThread.run(IPCConnectionManager.java:213) ~[hyracks-ipc-7.2.0-5183.jar:7.2.0-5183]