Schema Info
Schema Name: sfdl_stage_segment.sms_send_message
- created: 2018-04-20 13:23:13
- disabled: False
- format: raw
- id: 493
- is_partitioned: True
- is_schema_datatyped: False
- name:
{ "database": "sfdl_stage_segment", "table": "sms_send_message" } - type: segment
Schema Versions: 2
-
Version 3711
- created: 2018-04-24 09:22:42
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_send_message`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_send_message`\n(\n `writeKey` string , `timestamp` string , `messageId` string , `userId` string ,`properties` struct< `phone_number` : string , `visit_id` : string , `vendor` : string , `message_name` : string , `experiment_variation` : string , `confirmation_code` : string , `site_id` : string , `vendor_message_id` : string , `experiment_name` : string , `sender_handle_id` : string , `campaign_name` : string , `message` : string , `message_channel` : string >, `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `projectId` string , `_origin` string , `type` string , `event` string , `channel` string , `sentAt` string \n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-segment-sms-stage/separated_dt/send_message'\n", "MSCK REPAIR TABLE sfdl_stage_segment.sms_send_message" ] - hive_path: s3://sfdl-segment-sms-stage/separated_dt/send_message
- id: 3711
- processed: 1
- raw_data:
{ "_metadata": { "nodeVersion": "8.6.0" }, "_origin": "2018-04-24T14:22:31Z|s3://sfdl-segment-sms-stage/segment-logs/V2tM95dEVw/1524528000000/1524579737252.19d37a179806.1.11.1.08deee5e-1bcc-4364-ba4c-8309c97e5d52.gz|segment_separator:37", "channel": "server", "context": { "library": { "name": "analytics-node", "version": "3.2.0" } }, "event": "send_message", "integrations": {}, "messageId": "node-bafmtKQK52BGaoSFPs7hDFZzIFOB02fO", "originalTimestamp": "2018-04-24T13:54:51.391Z", "projectId": "V2tM95dEVw", "properties": { "campaign_name": "reservation", "confirmation_code": "PVQEWSGTU", "experiment_name": null, "experiment_variation": null, "message": "Your storage unit is ready for move-in: https://sparefoot.extrameter.com/reservation/confirmation/PVQEWSGTU\nPlease arrive today during office hours: 9:00 am - 5:00 pm\nAny issues/questions? Call/text here!", "message_channel": "sms", "message_name": "reminder-today", "phone_number": "6103509476", "sender_handle_id": "default", "site_id": 59, "vendor": "QUIQ", "vendor_message_id": "mid.1524578091339.79a2159295a81279e4", "visit_id": "1759bacdc38c35e2454756039" }, "receivedAt": "2018-04-24T13:55:01.802Z", "sentAt": "2018-04-24T13:55:01.392Z", "timestamp": "2018-04-24T13:54:51.801Z", "type": "track", "userId": "6103509476", "version": 2, "writeKey": "iCEzOyc2a3YKXWOsBpNjF2ZlYvfnVCyv" } - schema_attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.campaign_name": "string", "properties.confirmation_code": "string", "properties.experiment_name": "string", "properties.experiment_variation": "string", "properties.message": "string", "properties.message_channel": "string", "properties.message_name": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "properties.site_id": "string", "properties.vendor": "string", "properties.vendor_message_id": "string", "properties.visit_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - schema_name_id: 493
- schema_scan_id: 254817
- updated: 2018-07-06 12:07:30
-
Version 3683
- created: 2018-04-20 13:23:13
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_send_message`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_send_message`\n(\n `type` string , `timestamp` string , `projectId` string , `userId` string , `event` string , `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `messageId` string , `writeKey` string , `_origin` string ,`properties` struct< `phone_number` : string , `visit_id` : string , `experiment_variation` : string , `confirmation_code` : string , `site_id` : string , `vendor_message_id` : string , `experiment_name` : string , `sender_handle_id` : string , `campaign_name` : string , `message` : string , `message_channel` : string >, `channel` string , `sentAt` string \n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-segment-sms-stage/separated_dt/send_message'\n", "MSCK REPAIR TABLE sfdl_stage_segment.sms_send_message" ] - hive_path: s3://sfdl-segment-sms-stage/separated_dt/send_message
- id: 3683
- processed: 1
- raw_data:
{ "_metadata": { "nodeVersion": "8.6.0" }, "_origin": "2018-04-20T18:23:01Z|s3://sfdl-segment-sms-stage/segment-logs/V2tM95dEVw/1524182400000/1524248536909.2774e30fd4dd.1.11.1.5ca65397-eab8-46ed-8dc1-63e9fdd4c835.gz|segment_separator:37", "channel": "server", "context": { "library": { "name": "analytics-node", "version": "3.2.0" } }, "event": "send_message", "integrations": {}, "messageId": "node-FtR5ZlywXN8mrrFL0yImG1msZoHUhmGh", "originalTimestamp": "2018-04-20T18:19:26.279Z", "projectId": "V2tM95dEVw", "properties": { "campaign_name": "reminder-today", "confirmation_code": "SQYYNA25N", "experiment_name": null, "experiment_variation": null, "message": "Your storage unit is ready for move-in: https://sparefoot.extrameter.com/reservation/confirmation/SQYYNA25N\nPlease arrive today during office hours: 9:00 am - 6:00 pm\nAny issues/questions? Call/text here!", "message_channel": "sms", "phone_number": "6103509476", "sender_handle_id": "default", "site_id": -1, "vendor_message_id": "mid.1524248366232.94d90f6692c5ebd9e0", "visit_id": "06742132efcb48fb657a839dd8ca4d14" }, "receivedAt": "2018-04-20T18:19:36.675Z", "sentAt": "2018-04-20T18:19:36.279Z", "timestamp": "2018-04-20T18:19:26.675Z", "type": "track", "userId": "6103509476", "version": 2, "writeKey": "iCEzOyc2a3YKXWOsBpNjF2ZlYvfnVCyv" } - schema_attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.campaign_name": "string", "properties.confirmation_code": "string", "properties.experiment_name": "string", "properties.experiment_variation": "string", "properties.message": "string", "properties.message_channel": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "properties.site_id": "string", "properties.vendor_message_id": "string", "properties.visit_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - schema_name_id: 493
- schema_scan_id: 253349
- updated: 2018-04-20 13:54:54
Schema Scans: 2
Last at 2018-04-24 09:22:42
-
Scan 254817
- duration: 0:00:13.593615
- exit_message:
{ "ddl_changed": true, "ingested_partitions": 2, "partitions_applied": false, "success": true } - id: 254817
- payload:
{ "datatype_dict": null, "file_format": "json", "partition": { "location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2018-04-24/", "name": "dt", "type": "string", "value": "2018-04-24" }, "s3": { "bucket": "sfdl-segment-sms-stage", "hive_path": "s3://sfdl-segment-sms-stage/separated_dt/send_message", "key": "separated_dt/send_message/dt=2018-04-24/1524579737252.19d37a179806.1.11.1.08deee5e-1bcc-4364-ba4c-8309c97e5d52.json.gz" }, "schema": { "name": "sfdl_stage_segment.sms_send_message", "type": "segment" } } - running: False
- schema_name_id: 493
- start_time: 2018-04-24 09:22:42
- success: True
-
Scan 253349
- duration: 0:10:01.839846
- exit_message:
{ "exception": "failed to apply schema `Timeout error, query state is \"RUNNING\" `CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment```: [u'CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`', u'DROP TABLE IF EXISTS `sfdl_stage_segment.sms_send_message`', u\"CREATE EXTERNAL TABLE IF NOT EXISTS\\n`sfdl_stage_segment.sms_send_message`\\n(\\n `type` string , `timestamp` string , `projectId` string , `userId` string , `event` string , `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `messageId` string , `writeKey` string , `_origin` string ,`properties` struct< `phone_number` : string , `visit_id` : string , `experiment_variation` : string , `confirmation_code` : string , `site_id` : string , `vendor_message_id` : string , `experiment_name` : string , `sender_handle_id` : string , `campaign_name` : string , `message` : string , `message_channel` : string >, `channel` string , `sentAt` string \\n)\\nPARTITIONED BY (dt string)\\nROW FORMAT SERDE\\n'org.openx.data.jsonserde.JsonSerDe'\\n \\nSTORED AS INPUTFORMAT\\n 'org.apache.hadoop.mapred.TextInputFormat'\\nOUTPUTFORMAT\\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\\nLOCATION\\n 's3://sfdl-segment-sms-stage/separated_dt/send_message'\\n\", u'MSCK REPAIR TABLE sfdl_stage_segment.sms_send_message']\nTraceback (most recent call last):\n File \"schema_generator/schema_scanner.py\", line 82, in scan\n response = service.run()\n File \"schema_generator/process_hive_table.py\", line 90, in run\n response['ddl_changed'] = table_generator.run()\n File \"schema_generator/table_generator.py\", line 34, in run\n self.apply_latest_version()\n File \"schema_generator/table_generator.py\", line 25, in apply_latest_version\n raise Exception('failed to apply schema `{}`: {}'.format(e.message, ddl_list))\nException: failed to apply schema `Timeout error, query state is \"RUNNING\" `CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment```: [u'CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`', u'DROP TABLE IF EXISTS `sfdl_stage_segment.sms_send_message`', u\"CREATE EXTERNAL TABLE IF NOT EXISTS\\n`sfdl_stage_segment.sms_send_message`\\n(\\n `type` string , `timestamp` string , `projectId` string , `userId` string , `event` string , `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `messageId` string , `writeKey` string , `_origin` string ,`properties` struct< `phone_number` : string , `visit_id` : string , `experiment_variation` : string , `confirmation_code` : string , `site_id` : string , `vendor_message_id` : string , `experiment_name` : string , `sender_handle_id` : string , `campaign_name` : string , `message` : string , `message_channel` : string >, `channel` string , `sentAt` string \\n)\\nPARTITIONED BY (dt string)\\nROW FORMAT SERDE\\n'org.openx.data.jsonserde.JsonSerDe'\\n \\nSTORED AS INPUTFORMAT\\n 'org.apache.hadoop.mapred.TextInputFormat'\\nOUTPUTFORMAT\\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\\nLOCATION\\n 's3://sfdl-segment-sms-stage/separated_dt/send_message'\\n\", u'MSCK REPAIR TABLE sfdl_stage_segment.sms_send_message']\n: Expecting value: line 1 column 1 (char 0)" } - id: 253349
- payload:
{ "datatype_dict": null, "file_format": "json", "partition": { "location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2018-04-20/", "name": "dt", "type": "string", "value": "2018-04-20" }, "s3": { "bucket": "sfdl-segment-sms-stage", "hive_path": "s3://sfdl-segment-sms-stage/separated_dt/send_message", "key": "separated_dt/send_message/dt=2018-04-20/1524248536909.2774e30fd4dd.1.11.1.5ca65397-eab8-46ed-8dc1-63e9fdd4c835.json.gz" }, "schema": { "name": "sfdl_stage_segment.sms_send_message", "type": "segment" } } - running: False
- schema_name_id: 493
- start_time: 2018-04-20 13:23:13
- success: False
- count: 3
- ddl:
[ "ALTER TABLE\n `sfdl_stage_segment.sms_send_message`\nADD\n\n\n PARTITION (dt='2018-09-17') location 's3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2018-09-17/'\n PARTITION (dt='2019-02-01') location 's3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-02-01/'\n PARTITION (dt='2019-11-21') location 's3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-11-21/'\n;" ] - name: dt
- state:
[ { "info": { "id": 64342, "location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2018-09-17/", "name": "dt", "value": "2018-09-17" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2018-09-17 11:38:54", "last_data": "2018-09-17 11:38:54" }, "parquet": { "first_performed": "2018-09-17 15:50:06", "in_progress": null, "job_id": null, "last_performed": "2018-09-17 15:50:06", "queued": false } } }, { "info": { "id": 103799, "location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-02-01/", "name": "dt", "value": "2019-02-01" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2019-02-01 12:11:13", "last_data": "2019-02-01 12:11:13" }, "parquet": { "first_performed": "2019-02-01 12:34:12", "in_progress": null, "job_id": null, "last_performed": "2019-02-01 12:34:12", "queued": false } } }, { "info": { "id": 128790, "location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-11-21/", "name": "dt", "value": "2019-11-21" }, "state": { "arrival": { "athena_discovery": true, "first_data": "2019-11-20 21:08:26", "last_data": "2019-11-20 21:12:39" }, "parquet": { "first_performed": null, "in_progress": null, "job_id": null, "last_performed": null, "queued": true } } } ] - type: string
- attributes:
{ "_origin": "string", "channel": "string", "context.library.name": "string", "context.library.version": "string", "event": "string", "messageId": "string", "originalTimestamp": "string", "projectId": "string", "properties.campaign_name": "string", "properties.confirmation_code": "string", "properties.experiment_name": "string", "properties.experiment_variation": "string", "properties.message": "string", "properties.message_channel": "string", "properties.message_name": "string", "properties.phone_number": "string", "properties.sender_handle_id": "string", "properties.site_id": "string", "properties.vendor": "string", "properties.vendor_message_id": "string", "properties.visit_id": "string", "receivedAt": "string", "sentAt": "string", "timestamp": "string", "type": "string", "userId": "string", "version": "string", "writeKey": "string" } - created: 2018-04-24 09:22:42
- ddl:
{ "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`", "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_send_message`\n(\n `writeKey` string , `timestamp` string , `messageId` string , `userId` string ,`properties` struct< `phone_number` : string , `visit_id` : string , `vendor` : string , `message_name` : string , `experiment_variation` : string , `confirmation_code` : string , `site_id` : string , `vendor_message_id` : string , `experiment_name` : string , `sender_handle_id` : string , `campaign_name` : string , `message` : string , `message_channel` : string >, `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `projectId` string , `_origin` string , `type` string , `event` string , `channel` string , `sentAt` string \n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-segment-sms-stage/separated_dt/send_message'\n", "drop_table": "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_send_message`", "repair_table": "MSCK REPAIR TABLE sfdl_stage_segment.sms_send_message" }
- hostname: schemamanager-5c55c886bf-h2ts4
- name: schema_manager
- process_start: 2025-10-21 13:03:27
- sf_env: stage
- version: 2112174301
{
"name": {
"created": "2018-04-20 13:23:13",
"disabled": false,
"format": "raw",
"id": 493,
"is_partitioned": true,
"is_schema_datatyped": false,
"name": {
"database": "sfdl_stage_segment",
"table": "sms_send_message"
},
"type": "segment"
},
"partition": {
"count": 3,
"ddl": [
"ALTER TABLE\n `sfdl_stage_segment.sms_send_message`\nADD\n\n\n PARTITION (dt='2018-09-17') location 's3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2018-09-17/'\n PARTITION (dt='2019-02-01') location 's3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-02-01/'\n PARTITION (dt='2019-11-21') location 's3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-11-21/'\n;"
],
"name": "dt",
"state": [
{
"info": {
"id": 64342,
"location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2018-09-17/",
"name": "dt",
"value": "2018-09-17"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2018-09-17 11:38:54",
"last_data": "2018-09-17 11:38:54"
},
"parquet": {
"first_performed": "2018-09-17 15:50:06",
"in_progress": null,
"job_id": null,
"last_performed": "2018-09-17 15:50:06",
"queued": false
}
}
},
{
"info": {
"id": 103799,
"location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-02-01/",
"name": "dt",
"value": "2019-02-01"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2019-02-01 12:11:13",
"last_data": "2019-02-01 12:11:13"
},
"parquet": {
"first_performed": "2019-02-01 12:34:12",
"in_progress": null,
"job_id": null,
"last_performed": "2019-02-01 12:34:12",
"queued": false
}
}
},
{
"info": {
"id": 128790,
"location": "s3://sfdl-segment-sms-stage/separated_dt/send_message/dt=2019-11-21/",
"name": "dt",
"value": "2019-11-21"
},
"state": {
"arrival": {
"athena_discovery": true,
"first_data": "2019-11-20 21:08:26",
"last_data": "2019-11-20 21:12:39"
},
"parquet": {
"first_performed": null,
"in_progress": null,
"job_id": null,
"last_performed": null,
"queued": true
}
}
}
],
"type": "string"
},
"schema": {
"attributes": {
"_origin": "string",
"channel": "string",
"context.library.name": "string",
"context.library.version": "string",
"event": "string",
"messageId": "string",
"originalTimestamp": "string",
"projectId": "string",
"properties.campaign_name": "string",
"properties.confirmation_code": "string",
"properties.experiment_name": "string",
"properties.experiment_variation": "string",
"properties.message": "string",
"properties.message_channel": "string",
"properties.message_name": "string",
"properties.phone_number": "string",
"properties.sender_handle_id": "string",
"properties.site_id": "string",
"properties.vendor": "string",
"properties.vendor_message_id": "string",
"properties.visit_id": "string",
"receivedAt": "string",
"sentAt": "string",
"timestamp": "string",
"type": "string",
"userId": "string",
"version": "string",
"writeKey": "string"
},
"created": "2018-04-24 09:22:42",
"ddl": {
"create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_stage_segment`",
"create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_stage_segment.sms_send_message`\n(\n `writeKey` string , `timestamp` string , `messageId` string , `userId` string ,`properties` struct< `phone_number` : string , `visit_id` : string , `vendor` : string , `message_name` : string , `experiment_variation` : string , `confirmation_code` : string , `site_id` : string , `vendor_message_id` : string , `experiment_name` : string , `sender_handle_id` : string , `campaign_name` : string , `message` : string , `message_channel` : string >, `receivedAt` string ,`_metadata` struct< `nodeVersion` : string >, `version` string , `originalTimestamp` string ,`context` struct<`library` : struct< `version` : string , `name` : string >>, `projectId` string , `_origin` string , `type` string , `event` string , `channel` string , `sentAt` string \n)\nPARTITIONED BY (dt string)\nROW FORMAT SERDE\n'org.openx.data.jsonserde.JsonSerDe'\n \nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-segment-sms-stage/separated_dt/send_message'\n",
"drop_table": "DROP TABLE IF EXISTS `sfdl_stage_segment.sms_send_message`",
"repair_table": "MSCK REPAIR TABLE sfdl_stage_segment.sms_send_message"
}
},
"server": {
"hostname": "schemamanager-5c55c886bf-h2ts4",
"name": "schema_manager",
"process_start": "2025-10-21 13:03:27",
"sf_env": "stage",
"version": "2112174301"
}
}