Repository navigation
Description
建表的时候报错,报错信息: failed to create partition.Timeout。
1.建表语句:
CREATE TABLE table1
(
siteid INT DEFAULT '10',
citycode SMALLINT,
username VARCHAR(32) DEFAULT '',
pv BIGINT SUM DEFAULT '0'
)
AGGREGATE KEY(siteid, citycode, username)
DISTRIBUTED BY HASH(siteid) BUCKETS 10
PROPERTIES("replication_num" = "1");
2.backends信息:
MySQL [(none)]> SHOW PROC '/backends';
+-----------------+-----------+---------------+----------+---------------+--------+----------+---------------------+---------------------+-------+----------------------+-----------------------+-----------+
| Cluster | BackendId | IP | HostName | HeartbeatPort | BePort | HttpPort | LastStartTime | LastHeartbeat | Alive | SystemDecommissioned | ClusterDecommissioned | TabletNum |
+-----------------+-----------+---------------+----------+---------------+--------+----------+---------------------+---------------------+-------+----------------------+-----------------------+-----------+
| | 10376 | 192.168.5.100 | FineBI1 | 10050 | 9060 | 10040 | 2017-08-17 09:31:20 | 2017-08-17 09:36:15 | true | false | false | 0 |
| example_cluster | 10001 | 192.168.5.105 | FineBI2 | 9050 | 9060 | 8040 | 2017-08-16 11:50:53 | 2017-08-17 09:36:15 | true | false | false | 0 |
| example_cluster | 10002 | 192.168.5.106 | FineBI3 | 9050 | 9060 | 8040 | 2017-08-16 11:51:08 | 2017-08-17 09:36:15 | true | false | false | 0 |
+-----------------+-----------+---------------+----------+---------------+--------+----------+---------------------+---------------------+-------+----------------------+-----------------------+-----------+
3 rows in set (0.00 sec)
3.fe log:
2017-08-17 09:40:23,089 INFO 434 [StmtExecutor.analyze():306] the originStmt is =CREATE TABLE table1 ( siteid INT DEFAULT '10', citycode SMALLINT, username VARCHAR(32) DEFAULT '', pv BIGINT SUM DEFAULT '0' ) AGGREGATE KEY(siteid, citycode, username) DISTRIBUTED BY HASH(siteid) BUCKETS 10 PROPERTIES("replication_num" = "1")
2017-08-17 09:40:23,090 INFO 434 [Database.checkQuota():239] database[example_cluster:dbtest] data quota: left bytes: 1024.000 GB / total: 1024.000 GB
2017-08-17 09:40:23,121 WARN 207 [MasterImpl.finishTask():102] backend does not found. host: 127.0.0.1, be port: 9060. task: TFinishTaskRequest(backend:TBackend(host:127.0.0.1, be_port:9060, http_port:8040), task_type:CREATE, signature:10381, task_status:TStatus(status_code:OK, error_msgs:[]), report_version:15028554640082)
2017-08-17 09:40:23,123 WARN 119 [MasterImpl.finishTask():102] backend does not found. host: 127.0.0.1, be port: 9060. task: TFinishTaskRequest(backend:TBackend(host:127.0.0.1, be_port:9060, http_port:8040), task_type:CREATE, signature:10385, task_status:TStatus(status_code:OK, error_msgs:[]), report_version:15028554640083)
2017-08-17 09:40:23,125 WARN 207 [MasterImpl.finishTask():102] backend does not found. host: 127.0.0.1, be port: 9060. task: TFinishTaskRequest(backend:TBackend(host:127.0.0.1, be_port:9060, http_port:8040), task_type:CREATE, signature:10389, task_status:TStatus(status_code:OK, error_msgs:[]), report_version:15028554640084)
2017-08-17 09:40:23,127 WARN 119 [MasterImpl.finishTask():102] backend does not found. host: 127.0.0.1, be port: 9060. task: TFinishTaskRequest(backend:TBackend(host:127.0.0.1, be_port:9060, http_port:8040), task_type:CREATE, signature:10393, task_status:TStatus(status_code:OK, error_msgs:[]), report_version:15028554640085)
2017-08-17 09:40:23,129 WARN 207 [MasterImpl.finishTask():102] backend does not found. host: 127.0.0.1, be port: 9060. task: TFinishTaskRequest(backend:TBackend(host:127.0.0.1, be_port:9060, http_port:8040), task_type:CREATE, signature:10397, task_status:TStatus(status_code:OK, error_msgs:[]), report_version:15028554640086)
2017-08-17 09:40:33,094 WARN 434 [Catalog.createPartitionWithIndices():2786] Failed to create partition[table1]. Timeout. unfinished marks: 10002=10385, 10002=10393, 10002=10381, 10002=10389, 10002=10397
2017-08-17 09:40:34,498 INFO 61 [BDBJEJournal.getFinalizedJournalId():400] database names: 1
2017-08-17 09:40:34,498 INFO 61 [Checkpoint.runOneCycle():94] checkpoint imageVersion 0, checkPointVersion 0
4.be.log:
I0817 09:40:23.095836 25097 command_executor.cpp:249] begin to process create table. [tablet=10379, schema_hash=1421156361]
I0817 09:40:23.095849 25095 command_executor.cpp:249] begin to process create table. [tablet=10383, schema_hash=1421156361]
I0817 09:40:23.095865 25096 command_executor.cpp:249] begin to process create table. [tablet=10387, schema_hash=1421156361]
I0817 09:40:23.137383 25097 command_executor.cpp:333] finish to process create table. [res=0]
I0817 09:40:23.137900 25097 task_worker_pool.cpp:276] finish task success.result: 0
I0817 09:40:23.137923 25097 task_worker_pool.cpp:239] type: 0, signature: 10379 has been erased. queue size: 4
I0817 09:40:23.137938 25097 command_executor.cpp:249] begin to process create table. [tablet=10391, schema_hash=1421156361]
I0817 09:40:23.139243 25095 command_executor.cpp:333] finish to process create table. [res=0]
I0817 09:40:23.140229 25095 task_worker_pool.cpp:276] finish task success.result: 0
I0817 09:40:23.140252 25095 task_worker_pool.cpp:239] type: 0, signature: 10383 has been erased. queue size: 3
I0817 09:40:23.140270 25095 command_executor.cpp:249] begin to process create table. [tablet=10395, schema_hash=1421156361]
I0817 09:40:23.141095 25096 command_executor.cpp:333] finish to process create table. [res=0]
I0817 09:40:23.141538 25096 task_worker_pool.cpp:276] finish task success.result: 0
- 在trash的文件夹里可以看到有dat文件里有表结构信息,所以跟日志一致,be表是创建成功的
Activity
morningman commentedon Aug 17, 2017
应该是相同的问题,参见 #19
这两天会修复
1. Speed up compilation 2. Optimization of sum nullable column (apach…
1. Speed up compilation 2. Optimization of sum nullable column (apach…
1. Speed up compilation 2. Optimization of sum nullable column (apach…
[fix](olapscanner) fix coredump caused by concurrent acccess of olap …
[fix](olapscanner) fix coredump caused by concurrent acccess of olap …
[case]Add case from dev (apache#22)
Revert "[chore](scan) Add session veriable query_max_scan_bytes apach…
[improvement](mtmv) Support union rewrite when the materialized view …
[improvement](mtmv) Support union rewrite when the materialized view …
[Bug](backend-options) fix use after free on BackendOptions::get_loca…
[Bug](backend-options) fix use after free on BackendOptions::get_loca…
[Bug](backend-options) fix use after free on BackendOptions::get_loca…
127 remaining items
[fix](catalog) catalog-SPI abstraction-mismatch review: paimon time-t…
[fix](be) Avoid scan executor shutdown use after free (#65220)
[fix](catalog) catalog-SPI abstraction-mismatch review: paimon time-t…
[fix](catalog) catalog-SPI abstraction-mismatch review: paimon time-t…
[fix](be) Avoid scan executor shutdown use after free (#65220)
[fix](fe) Mark IVM binlog broken after base table replace (apache#21)
[fix](fe) Fix fast insert into values after IVM stream guard (apache#24)
[fix](fe) Mark IVM binlog broken after base table replace (apache#21)
[fix](fe) Fix fast insert into values after IVM stream guard (apache#24)
[fix](fe) Mark IVM binlog broken after base table replace (apache#21)
[fix](fe) Fix fast insert into values after IVM stream guard (apache#24)
[fix](fe) Mark IVM binlog broken after base table replace (apache#21)
[fix](fe) Fix fast insert into values after IVM stream guard (apache#24)
[fix](fe) Mark IVM binlog broken after base table replace (apache#21)
[fix](fe) Fix fast insert into values after IVM stream guard (apache#24)