Hi @tihomir -
Just a FYI when I run a visibility schema I don’t see open and closed executions tables created in logs. do you think is there any bug in the temporal version I am using.
2022-05-06T14:15:36.736Z INFO Validating connection to cassandra cluster. {“logging-call-at”: “cqlclient.go:113”}
2022-05-06T14:15:36.946Z INFO Connection validation succeeded. {“logging-call-at”: “cqlclient.go:119”}
2022-05-06T14:15:36.946Z INFO Starting schema setup {“config”: {“SchemaFilePath”:"",“InitialVersion”:“0.0”,“Overwrite”:false,“DisableVersioning”:false}, “logging-call-at”: “setuptask.go:57”}
2022-05-06T14:15:36.946Z DEBUG Setting up version tables {“logging-call-at”: “setuptask.go:67”}
2022-05-06T14:15:39.947Z DEBUG Setting initial schema version to 0.0 {“logging-call-at”: “setuptask.go:118”}
2022-05-06T14:15:39.953Z DEBUG Updating schema update log {“logging-call-at”: “setuptask.go:123”}
2022-05-06T14:15:39.958Z INFO Schema setup complete {“logging-call-at”: “setuptask.go:131”}
2022-05-06T14:16:02.040Z INFO Validating connection to cassandra cluster. {“logging-call-at”: “cqlclient.go:113”}
2022-05-06T14:16:02.249Z INFO Connection validation succeeded. {“logging-call-at”: “cqlclient.go:119”}
2022-05-06T14:16:02.249Z INFO UpdateSchemeTask started {“config”: {“DBName”:"",“TargetVersion”:"",“SchemaDir”:"./schema/cassandra/temporal/versioned",“IsDryRun”:false}, “logging-call-at”: “updatetask.go:97”}
2022-05-06T14:16:02.253Z DEBUG Schema Dirs: [v1.0 v1.1 v1.2 v1.3 v1.4 v1.5 v1.6 v1.7] {“logging-call-at”: “updatetask.go:186”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.0/schema.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.1/cluster_metadata.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.2/queue.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.3/visibility.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.4/executions.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.4/cluster_metadata.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.5/event.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.5/executions.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.6/executions.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.6/cluster_metadata_info.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z INFO Processing schema file: ./schema/cassandra/temporal/versioned/v1.7/executions.cql {“logging-call-at”: “updatetask.go:232”}
2022-05-06T14:16:02.254Z DEBUG ---- Executing updates for version 1.0 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:02.254Z DEBUG CREATE TYPE serialized_event_batch (encoding_type text,version int,data blob); {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:03.989Z DEBUG CREATE TABLE executions (shard_id int,type int, namespace_id uuid,workflow_id text,run_id uuid,current_run_id uuid,visibility_ts timestamp, task_id bigint, shard blob,shard_encoding text,execution blob,execution_encoding text,execution_state blob,execution_state_encoding text,transfer blob,transfer_encoding text,replication blob,replication_encoding text,timer blob,timer_encoding text,next_event_id bigint, range_id bigint, activity_map map<bigint, blob>,activity_map_encoding text,timer_map map<text, blob>,timer_map_encoding text,child_executions_map map<bigint, blob>,child_executions_map_encoding text,request_cancel_map map<bigint, blob>,request_cancel_map_encoding text,signal_map map<bigint, blob>,signal_map_encoding text,signal_requested set,buffered_events_list list<frozen<serialized_event_batch>>,replication_metadata blob, replication_metadata_encoding text,workflow_last_write_version bigint,workflow_state int,checksum blob,checksum_encoding text,PRIMARY KEY (shard_id, type, namespace_id, workflow_id, run_id, visibility_ts, task_id)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:05.199Z DEBUG CREATE TABLE history_node (tree_id uuid,branch_id uuid,node_id bigint, txn_id bigint, data blob, data_encoding text, PRIMARY KEY ((tree_id), branch_id, node_id, txn_id )) WITH CLUSTERING ORDER BY (branch_id ASC, node_id ASC, txn_id DESC)AND COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:06.231Z DEBUG CREATE TABLE history_tree (tree_id uuid,branch_id uuid,branch blob,branch_encoding text,PRIMARY KEY ((tree_id), branch_id )) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:07.614Z DEBUG CREATE TABLE tasks (namespace_id uuid,task_queue_name text,task_queue_type int, type int, task_id bigint, range_id bigint, task blob,task_encoding text,task_queue blob,task_queue_encoding text,PRIMARY KEY ((namespace_id, task_queue_name, task_queue_type), type, task_id)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:08.191Z DEBUG CREATE TABLE namespaces_by_id (id uuid,name text,PRIMARY KEY (id)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’ }; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:09.594Z DEBUG CREATE TABLE namespaces (namespaces_partition int,name text,id uuid,detail blob,detail_encoding text,is_global_namespace boolean,notification_version bigint,PRIMARY KEY (namespaces_partition, name)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:10.550Z DEBUG CREATE TABLE queue (queue_type int,message_id bigint,message_payload blob,PRIMARY KEY (queue_type, message_id)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:11.120Z DEBUG CREATE TABLE queue_metadata (queue_type int,cluster_ack_level map<text, bigint>,version bigint,PRIMARY KEY (queue_type)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:12.124Z DEBUG CREATE TABLE cluster_metadata (metadata_partition int,immutable_data blob,immutable_data_encoding text,PRIMARY KEY (metadata_partition)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:13.499Z DEBUG CREATE TABLE cluster_membership(membership_partition tinyint,host_id uuid,rpc_address inet,rpc_port smallint,role tinyint,session_start timestamp,last_heartbeat timestamp,PRIMARY KEY (membership_partition, role, host_id)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:14.097Z DEBUG CREATE INDEX cm_lastheartbeat_idx on cluster_membership (last_heartbeat); {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:15.219Z DEBUG CREATE INDEX cm_sessionstart_idx on cluster_membership (session_start); {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:16.233Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:16.244Z DEBUG Schema updated from 0.0 to 1.0 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:16.244Z DEBUG ---- Executing updates for version 1.1 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:16.244Z DEBUG ALTER TABLE cluster_metadata ADD data blob; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:17.636Z DEBUG ALTER TABLE cluster_metadata ADD data_encoding text; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:18.050Z DEBUG ALTER TABLE cluster_metadata ADD version bigint; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:19.209Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:19.214Z DEBUG Schema updated from 1.0 to 1.1 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:19.214Z DEBUG ---- Executing updates for version 1.2 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:19.214Z DEBUG ALTER TABLE queue ADD message_encoding text; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:20.609Z DEBUG ALTER TABLE queue_metadata ADD data blob; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:21.215Z DEBUG ALTER TABLE queue_metadata ADD data_encoding text; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:22.589Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:22.594Z DEBUG Schema updated from 1.1 to 1.2 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:22.594Z DEBUG ---- Executing updates for version 1.3 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:22.594Z DEBUG ALTER TABLE executions ADD visibility_task_data blob; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:23.159Z DEBUG ALTER TABLE executions ADD visibility_task_encoding text; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:24.565Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:24.569Z DEBUG Schema updated from 1.2 to 1.3 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:24.569Z DEBUG ---- Executing updates for version 1.4 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:24.569Z DEBUG ALTER TABLE executions DROP replication_metadata; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:25.998Z DEBUG ALTER TABLE executions DROP replication_metadata_encoding; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:27.663Z DEBUG ALTER TABLE cluster_metadata DROP immutable_data; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:28.520Z DEBUG ALTER TABLE cluster_metadata DROP immutable_data_encoding; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:29.929Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:29.935Z DEBUG Schema updated from 1.3 to 1.4 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:29.935Z DEBUG ---- Executing updates for version 1.5 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:29.935Z DEBUG ALTER TABLE history_node ADD prev_txn_id bigint; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:30.927Z DEBUG ALTER TABLE executions Add db_record_version bigint; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:32.540Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:32.546Z DEBUG Schema updated from 1.4 to 1.5 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:32.546Z DEBUG ---- Executing updates for version 1.6 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:32.546Z DEBUG ALTER TABLE executions ADD tiered_storage_task_data blob; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:33.920Z DEBUG ALTER TABLE executions ADD tiered_storage_task_encoding text; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:35.525Z DEBUG CREATE TABLE cluster_metadata_info (metadata_partition int,cluster_name text,data blob,data_encoding text,version bigint,PRIMARY KEY (metadata_partition, cluster_name)) WITH COMPACTION = {‘class’: ‘org.apache.cassandra.db.compaction.LeveledCompactionStrategy’}; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:36.147Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:36.152Z DEBUG Schema updated from 1.5 to 1.6 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:36.152Z DEBUG ---- Executing updates for version 1.7 ---- {“logging-call-at”: “updatetask.go:150”}
2022-05-06T14:16:36.152Z DEBUG ALTER TABLE executions DROP tiered_storage_task_data; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:37.631Z DEBUG ALTER TABLE executions DROP tiered_storage_task_encoding; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:38.659Z DEBUG ALTER TABLE executions ADD task_data blob; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:39.656Z DEBUG ALTER TABLE executions ADD task_encoding text; {“logging-call-at”: “updatetask.go:152”}
2022-05-06T14:16:41.023Z DEBUG ---- Done ---- {“logging-call-at”: “updatetask.go:158”}
2022-05-06T14:16:41.028Z DEBUG Schema updated from 1.6 to 1.7 {“logging-call-at”: “updatetask.go:142”}
2022-05-06T14:16:41.028Z INFO UpdateSchemeTask done {“logging-call-at”: “updatetask.go:120”}