Jackie
09/01/2020, 10:41 PMJackie
09/01/2020, 10:42 PMTim Chan
09/01/2020, 10:46 PM{
"schemaName": "motion",
"dimensionFieldSpecs": [
{
"name": "sensor_id",
"dataType": "STRING"
},
{
"name": "config_details",
"dataType": "STRING"
},
{
"name": "has_motion",
"dataType": "BOOLEAN"
}
],
"metricFieldSpecs": [],
"dateTimeFieldSpecs": [
{
"name": "time_stamp",
"dataType": "LONG",
"format": "1:MILLISECONDS:EPOCH",
"granularity": "1:MILLISECONDS"
}
]
}
Tim Chan
09/01/2020, 10:46 PM{
"tableName": "motion",
"tableType": "REALTIME",
"segmentsConfig": {
"timeColumnName": "timestampInEpoch",
"timeType": "MILLISECONDS",
"schemaName": "motion",
"replicasPerPartition": "1"
},
"tenants": {},
"tableIndexConfig": {
"loadMode": "MMAP",
"streamConfigs": {
"streamType": "kafka",
"stream.kafka.consumer.type": "lowlevel",
"stream.kafka.topic.name": "ash-logger.etldb.derived.motion",
"stream.kafka.decoder.class.name": "org.apache.pinot.plugin.stream.kafka.KafkaJSONMessageDecoder",
"stream.kafka.consumer.factory.class.name": "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",
"stream.kafka.broker.list": "kafka-dev-1-kafka-bootstrap.kafka-dev-1:9092",
"realtime.segment.flush.threshold.time": "3600000",
"realtime.segment.flush.threshold.size": "50000",
"stream.kafka.consumer.prop.auto.offset.reset": "smallest"
}
},
"metadata": {
"customConfigs": {}
}
}
Tim Chan
09/01/2020, 10:49 PMtime_stamp
is 1599000470000
Tim Chan
09/01/2020, 10:49 PMtimeColumnName
for configTim Chan
09/01/2020, 10:49 PMTim Chan
09/01/2020, 10:49 PMTim Chan
09/01/2020, 10:49 PMNeha Pawar
Tim Chan
09/01/2020, 10:53 PMpinot-admin.sh
to create this table. how would i go about dropping it and recreating it with the proper config?Neha Pawar
Neha Pawar
Tim Chan
09/01/2020, 10:54 PMTim Chan
09/01/2020, 11:09 PMTim Chan
09/01/2020, 11:09 PMTim Chan
09/01/2020, 11:09 PM2020/09/01 23:09:14.532 WARN [TopStateHandoffReportStage] [HelixController-pipeline-default-pinot-(d1b54062_DEFAULT)] Event d1b54062_DEFAULT : Cannot confirm top state missing start time. Use the current system time as the start time.
Tim Chan
09/01/2020, 11:10 PMTim Chan
09/01/2020, 11:10 PMJackie
09/01/2020, 11:10 PMTim Chan
09/01/2020, 11:11 PMTim Chan
09/01/2020, 11:11 PMPradeep
09/02/2020, 1:45 AMKishore G
Jack
09/02/2020, 3:18 AMPradeep
09/02/2020, 3:19 AMPradeep
09/02/2020, 3:19 AMJack
09/02/2020, 3:21 AMJack
09/02/2020, 3:21 AMPradeep
09/02/2020, 3:23 AM