Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
2dot5
ClickHouse
提交
65982a16
C
ClickHouse
项目概览
2dot5
/
ClickHouse
通知
3
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
C
ClickHouse
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
65982a16
编写于
10月 25, 2017
作者:
A
Alexey Milovidov
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Fixed exception messages [#CLICKHOUSE-2].
上级
93e32e92
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
7 addition
and
7 deletion
+7
-7
dbms/src/Interpreters/ProcessList.cpp
dbms/src/Interpreters/ProcessList.cpp
+2
-2
dbms/src/Storages/MergeTree/MergeTreeData.cpp
dbms/src/Storages/MergeTree/MergeTreeData.cpp
+1
-1
dbms/src/Storages/MergeTree/MergeTreeSettings.h
dbms/src/Storages/MergeTree/MergeTreeSettings.h
+1
-1
dbms/src/Storages/StorageReplicatedMergeTree.cpp
dbms/src/Storages/StorageReplicatedMergeTree.cpp
+3
-3
未找到文件。
dbms/src/Interpreters/ProcessList.cpp
浏览文件 @
65982a16
...
...
@@ -28,7 +28,7 @@ ProcessList::EntryPtr ProcessList::insert(
if
(
!
is_kill_query
&&
max_size
&&
cur_size
>=
max_size
&&
(
!
settings
.
queue_max_wait_ms
.
totalMilliseconds
()
||
!
have_space
.
tryWait
(
mutex
,
settings
.
queue_max_wait_ms
.
totalMilliseconds
())))
throw
Exception
(
"Too m
uch
simultaneous queries. Maximum: "
+
toString
(
max_size
),
ErrorCodes
::
TOO_MUCH_SIMULTANEOUS_QUERIES
);
throw
Exception
(
"Too m
any
simultaneous queries. Maximum: "
+
toString
(
max_size
),
ErrorCodes
::
TOO_MUCH_SIMULTANEOUS_QUERIES
);
/** Why we use current user?
* Because initial one is passed by client and credentials for it is not verified,
...
...
@@ -47,7 +47,7 @@ ProcessList::EntryPtr ProcessList::insert(
{
if
(
!
is_kill_query
&&
settings
.
max_concurrent_queries_for_user
&&
user_process_list
->
second
.
queries
.
size
()
>=
settings
.
max_concurrent_queries_for_user
)
throw
Exception
(
"Too m
uch
simultaneous queries for user "
+
client_info
.
current_user
throw
Exception
(
"Too m
any
simultaneous queries for user "
+
client_info
.
current_user
+
". Current: "
+
toString
(
user_process_list
->
second
.
queries
.
size
())
+
", maximum: "
+
settings
.
max_concurrent_queries_for_user
.
toString
(),
ErrorCodes
::
TOO_MUCH_SIMULTANEOUS_QUERIES
);
...
...
dbms/src/Storages/MergeTree/MergeTreeData.cpp
浏览文件 @
65982a16
...
...
@@ -1558,7 +1558,7 @@ void MergeTreeData::delayInsertIfNeeded(Poco::Event * until)
if
(
parts_count
>=
settings
.
parts_to_throw_insert
)
{
ProfileEvents
::
increment
(
ProfileEvents
::
RejectedInserts
);
throw
Exception
(
"Too m
uch
parts ("
+
toString
(
parts_count
)
+
"). Merges are processing significantly slower than inserts."
,
ErrorCodes
::
TOO_MUCH_PARTS
);
throw
Exception
(
"Too m
any
parts ("
+
toString
(
parts_count
)
+
"). Merges are processing significantly slower than inserts."
,
ErrorCodes
::
TOO_MUCH_PARTS
);
}
const
size_t
max_k
=
settings
.
parts_to_throw_insert
-
settings
.
parts_to_delay_insert
;
/// always > 0
...
...
dbms/src/Storages/MergeTree/MergeTreeSettings.h
浏览文件 @
65982a16
...
...
@@ -47,7 +47,7 @@ struct MergeTreeSettings
/** If table contains at least that many active parts, artificially slow down insert into table. */
\
M(SettingUInt64, parts_to_delay_insert, 150) \
\
/** If more than this number active parts, throw 'Too m
uch
parts ...' exception */
\
/** If more than this number active parts, throw 'Too m
any
parts ...' exception */
\
M(SettingUInt64, parts_to_throw_insert, 300) \
\
/** Max delay of inserting data into MergeTree table in seconds, if there are a lot of unmerged parts. */
\
...
...
dbms/src/Storages/StorageReplicatedMergeTree.cpp
浏览文件 @
65982a16
...
...
@@ -1237,7 +1237,7 @@ bool StorageReplicatedMergeTree::executeLogEntry(const LogEntry & entry)
static
std
::
atomic_uint
total_fetches
{
0
};
if
(
data
.
settings
.
replicated_max_parallel_fetches
&&
total_fetches
>=
data
.
settings
.
replicated_max_parallel_fetches
)
{
throw
Exception
(
"Too m
uch
total fetches from replicas, maximum: "
+
data
.
settings
.
replicated_max_parallel_fetches
.
toString
(),
throw
Exception
(
"Too m
any
total fetches from replicas, maximum: "
+
data
.
settings
.
replicated_max_parallel_fetches
.
toString
(),
ErrorCodes
::
TOO_MUCH_FETCHES
);
}
...
...
@@ -1246,7 +1246,7 @@ bool StorageReplicatedMergeTree::executeLogEntry(const LogEntry & entry)
if
(
data
.
settings
.
replicated_max_parallel_fetches_for_table
&&
current_table_fetches
>=
data
.
settings
.
replicated_max_parallel_fetches_for_table
)
{
throw
Exception
(
"Too m
uch
fetches from replicas for table, maximum: "
+
data
.
settings
.
replicated_max_parallel_fetches_for_table
.
toString
(),
throw
Exception
(
"Too m
any
fetches from replicas for table, maximum: "
+
data
.
settings
.
replicated_max_parallel_fetches_for_table
.
toString
(),
ErrorCodes
::
TOO_MUCH_FETCHES
);
}
...
...
@@ -3382,7 +3382,7 @@ void StorageReplicatedMergeTree::fetchPartition(const ASTPtr & partition, const
LOG_INFO
(
log
,
"Some of parts ("
<<
missing_parts
.
size
()
<<
") are missing. Will try to fetch covering parts."
);
if
(
try_no
>=
5
)
throw
Exception
(
"Too m
uch
retries to fetch parts from "
+
best_replica_path
,
ErrorCodes
::
TOO_MUCH_RETRIES_TO_FETCH_PARTS
);
throw
Exception
(
"Too m
any
retries to fetch parts from "
+
best_replica_path
,
ErrorCodes
::
TOO_MUCH_RETRIES_TO_FETCH_PARTS
);
Strings
parts
=
getZooKeeper
()
->
getChildren
(
best_replica_path
+
"/parts"
);
ActiveDataPartSet
active_parts_set
(
data
.
format_version
,
parts
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录