Operation ListOpenWorkflowExecutions encountered unconfigured table open_executions

Hello Team,

I am trying to install temporal and I am getting following errors. I am not sure why open and closed executions tables are not created (Checked in DB and its not created. Did any one faces similar issues?

Commands Used to create schema and Update Version:

1.temporal-cassandra-tool --tls --tls-disable-host-verification -p 9042 --ep XXX -u temporal -pw XXXX -k temporal setup-schema -v 0.0’
2. temporal-cassandra-tool --tls --tls-disable-host-verification -p 9042 --ep XXXX -u temporal -pw XXXX -k 3.temporal update-schema -d ./schema/cassandra/temporal/versioned’
temporal-cassandra-tool --tls --tls-disable-host-verification -p 9042 --ep XXX -u temporal_visibility -pw XXXX -k temporal_visibility setup-schema -v 0.0’
4. temporal-cassandra-tool --tls --tls-disable-host-verification -p 9042 --ep XXX -u temporal_visibility -pw XXXXX -k temporal_visibility update-schema -d ./schema/cassandra/temporal/versioned’

Errors:

“error”:“operation ListOpenWorkflowExecutions encountered unconfigured table open_executions”

“error”:“operation ListClosedWorkflowExecutions encountered unconfigured table closed_executions”

Version Details:

repository: temporalio/server
tag: 1.16.0

image:
repository: temporalio/web
tag: 1.15.0

Are you setting this up for a new cluster or trying to upgrade existing?
I think for upgrade you only need to run the update-schema commands (see here).

I am trying to set up new cluster

These tables are created here. Did you get any errors when running the visibility setup?

These should be created automatically right? I did not got any errors when running the setup.

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”}

I am also experiencing this, was there a resolution?

I ran into this and see the same issue I had in OP’s comment, which was not running the temporal-cassandra-tool update-schema on the ./schema/cassandra/visibility/versioned directory (indeed, I had been running it on ./schema/cassandra/temporal/versioned twice).

# after running create and schema-setup
export CASSANDRA_KEYSPACE=temporal
temporal-cassandra-tool update-schema --schema-dir ./schema/cassandra/temporal/versioned

export CASSANDRA_KEYSPACE=temporal_visibility
temporal-cassandra-tool update-schema --schema-dir ./schema/cassandra/visibility/versioned