mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-04 21:42:39 +00:00
b9469e2729
Sometimes replica may be readonly for a long time, and this will make some INSERT queries fail, but it does not make sense to INSERT into readonly replica, so let's ignore them. But note, that this will require to extend TableStatus (not extend, but introduce new version), that will have is_readonly field. Also before background INSERT into Distributed does not uses getManyChecked() which means that they do not request TableStatus packet, while now they would, though this is minor (just a note). v2: Add a note about max_replica_delay_for_distributed_queries for INSERT v3: Skip read-only replicas for async INSERT into Distributed v4: Remove extra @insert parameter for ConnectionPool*::get* It make sense only when the table name had passed -- ConnectionPoolWithFailover::getManyChecked() v5: rebase on top LoggerPtr v6: rebase v7: rebase v8: move TryResult::is_readonly into the end Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com> |
||
---|---|---|
.. | ||
examples | ||
fuzzers | ||
MySQL | ||
PostgreSQL | ||
tests | ||
AccurateComparison.h | ||
BackgroundSchedulePool.cpp | ||
BackgroundSchedulePool.h | ||
BaseSettings.cpp | ||
BaseSettings.h | ||
BaseSettingsProgramOptions.h | ||
Block.cpp | ||
Block.h | ||
BlockInfo.cpp | ||
BlockInfo.h | ||
callOnTypeIndex.h | ||
CMakeLists.txt | ||
ColumnNumbers.h | ||
ColumnsWithTypeAndName.h | ||
ColumnWithTypeAndName.cpp | ||
ColumnWithTypeAndName.h | ||
CompareHelper.h | ||
DecimalComparison.h | ||
DecimalFunctions.h | ||
Defines.h | ||
ExternalResultDescription.cpp | ||
ExternalResultDescription.h | ||
ExternalTable.cpp | ||
ExternalTable.h | ||
Field.cpp | ||
Field.h | ||
InterpolateDescription.cpp | ||
InterpolateDescription.h | ||
iostream_debug_helpers.cpp | ||
iostream_debug_helpers.h | ||
IResolvedFunction.h | ||
Joins.cpp | ||
Joins.h | ||
LogsLevel.h | ||
MultiEnum.h | ||
Names.h | ||
NamesAndAliases.h | ||
NamesAndTypes.cpp | ||
NamesAndTypes.h | ||
PlainRanges.cpp | ||
PlainRanges.h | ||
PostgreSQLProtocol.cpp | ||
PostgreSQLProtocol.h | ||
Protocol.h | ||
ProtocolDefines.h | ||
QualifiedTableName.h | ||
QueryProcessingStage.cpp | ||
QueryProcessingStage.h | ||
Range.cpp | ||
Range.h | ||
ServerSettings.cpp | ||
ServerSettings.h | ||
ServerUUID.cpp | ||
ServerUUID.h | ||
Settings.cpp | ||
Settings.h | ||
SettingsChangesHistory.h | ||
SettingsEnums.cpp | ||
SettingsEnums.h | ||
SettingsFields.cpp | ||
SettingsFields.h | ||
SettingsQuirks.cpp | ||
SettingsQuirks.h | ||
SortCursor.h | ||
SortDescription.cpp | ||
SortDescription.h | ||
TypeId.h | ||
Types_fwd.h | ||
Types.h | ||
UUID.cpp | ||
UUID.h | ||
ValuesWithType.h | ||
ValueWithType.h |