Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
2dot5
ClickHouse
提交
ac802a8e
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,发现更多精彩内容 >>
未验证
提交
ac802a8e
编写于
7月 17, 2020
作者:
A
alesapin
提交者:
GitHub
7月 17, 2020
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #12543 from ClickHouse/fix_marks_type_on_mutation
Fix incorrect adaptive granularity by default
上级
0c903d3f
42983c54
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
30 addition
and
1 deletion
+30
-1
src/Storages/MergeTree/MergedBlockOutputStream.cpp
src/Storages/MergeTree/MergedBlockOutputStream.cpp
+1
-1
tests/integration/test_adaptive_granularity_different_settings/test.py
...tion/test_adaptive_granularity_different_settings/test.py
+29
-0
未找到文件。
src/Storages/MergeTree/MergedBlockOutputStream.cpp
浏览文件 @
ac802a8e
...
...
@@ -46,7 +46,7 @@ MergedBlockOutputStream::MergedBlockOutputStream(
{
MergeTreeWriterSettings
writer_settings
(
storage
.
global_context
.
getSettings
(),
storage
.
canUseAdaptiveGranularity
()
,
data_part
->
index_granularity_info
.
is_adaptive
,
aio_threshold
,
blocks_are_granules_size
);
...
...
tests/integration/test_adaptive_granularity_different_settings/test.py
浏览文件 @
ac802a8e
...
...
@@ -6,6 +6,9 @@ cluster = ClickHouseCluster(__file__)
node1
=
cluster
.
add_instance
(
'node1'
,
with_zookeeper
=
True
)
node2
=
cluster
.
add_instance
(
'node2'
,
with_zookeeper
=
True
)
# no adaptive granularity by default
node3
=
cluster
.
add_instance
(
'node3'
,
image
=
'yandex/clickhouse-server:19.9.5.36'
,
with_installed_binary
=
True
,
stay_alive
=
True
)
@
pytest
.
fixture
(
scope
=
"module"
)
def
start_cluster
():
try
:
...
...
@@ -47,3 +50,29 @@ def test_attach_detach(start_cluster):
assert
node1
.
query
(
"SELECT COUNT() FROM test"
)
==
"4
\n
"
assert
node2
.
query
(
"SELECT COUNT() FROM test"
)
==
"4
\n
"
def
test_mutate_with_mixed_granularity
(
start_cluster
):
node3
.
query
(
"""
CREATE TABLE test (date Date, key UInt64, value1 String, value2 String)
ENGINE = MergeTree
ORDER BY key PARTITION BY date"""
)
node3
.
query
(
"INSERT INTO test SELECT toDate('2019-10-01') + number % 5, number, toString(number), toString(number * number) FROM numbers(500)"
)
assert
node3
.
query
(
"SELECT COUNT() FROM test"
)
==
"500
\n
"
node3
.
restart_with_latest_version
()
assert
node3
.
query
(
"SELECT COUNT() FROM test"
)
==
"500
\n
"
node3
.
query
(
"ALTER TABLE test MODIFY SETTING enable_mixed_granularity_parts = 1"
)
node3
.
query
(
"INSERT INTO test SELECT toDate('2019-10-01') + number % 5, number, toString(number), toString(number * number) FROM numbers(500, 500)"
)
assert
node3
.
query
(
"SELECT COUNT() FROM test"
)
==
"1000
\n
"
assert
node3
.
query
(
"SELECT COUNT() FROM test WHERE key % 100 == 0"
)
==
"10
\n
"
node3
.
query
(
"ALTER TABLE test DELETE WHERE key % 100 == 0"
,
settings
=
{
"mutations_sync"
:
"2"
})
assert
node3
.
query
(
"SELECT COUNT() FROM test WHERE key % 100 == 0"
)
==
"0
\n
"
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录