KILL

このページでは、KILL QUERY ステートメントと KILL MUTATION ステートメントについて説明します。デフォルトでは、一致する対象がない場合でも例外は発生せずに終了します。KILL QUERY については、現在の KILL ステートメントを除いた結果、WHERE 式の条件を満たす対象行が system.processes に残らない場合に、また KILL MUTATION については、WHERE 式に一致する行が system.mutations に 1 行もない場合に例外をスローさせるには、kill_throw_if_noop を true に設定します。 ON CLUSTER で実行した場合は、一致結果がホスト間で集計されないため、一致する対象がなくても例外はスローされません。

KILL QUERY

KILL QUERY [ON CLUSTER cluster]
  WHERE <where expression to SELECT FROM system.processes query>
  [SYNC|ASYNC|TEST]
  [FORMAT format]

現在実行中のクエリを強制終了しようとします。終了対象のクエリは、KILL クエリの WHERE 句で定義された条件を使用して、system.processes テーブルから選択されます。例: まず、未完了のクエリの一覧を取得する必要があります。この SQL クエリでは、実行時間が長い順に表示されます。単一の ClickHouse ノードでの一覧:

SELECT
  initial_query_id,
  query_id,
  formatReadableTimeDelta(elapsed) AS time_delta,
  query,
  *
  FROM system.processes
  WHERE query ILIKE 'SELECT%'
  ORDER BY time_delta DESC;

ClickHouseクラスターの一覧:

SELECT
  initial_query_id,
  query_id,
  formatReadableTimeDelta(elapsed) AS time_delta,
  query,
  *
  FROM clusterAllReplicas(default, system.processes)
  WHERE query ILIKE 'SELECT%'
  ORDER BY time_delta DESC;

クエリを強制終了します。

-- Forcibly terminates all queries with the specified query_id:
KILL QUERY WHERE query_id='2-857d-4a57-9ee0-327da5d60a90'

-- Synchronously terminates all queries run by 'username':
KILL QUERY WHERE user='username' SYNC

ClickHouse Cloud またはセルフマネージドのクラスターでクエリを停止する場合は、すべてのレプリカでクエリが停止されるよう、必ず ON CLUSTER [cluster-name] オプションを使用してください

読み取り専用ユーザーは、自分自身のクエリしか停止できません。 system.processes に対する SELECT 権限が付与されていないユーザーでも、クエリ ID を指定すれば自分自身のクエリを停止できます。 KILL QUERY WHERE query_id = '<id>'。その権限も KILL QUERY 権限も持たないユーザーが、自分が実行していないクエリの ID を指定した場合、クエリは停止されず、エラーも報告されず、結果の行も返されません。ただし、 kill_throw_if_noop が有効な場合は、何も実行されなかったことが例外として報告されます。一方、KILL QUERY 権限を持っていてもその SELECT 権限を持たないユーザーは、SELECT 権限がないため拒否されます。その他の WHERE 条件と ON CLUSTER には、引き続き上記の権限が必要です。デフォルトでは、クエリの非同期バージョン (ASYNC) が使用され、クエリが停止したことの確認は待機しません。同期バージョン (SYNC) は、すべてのクエリが停止するまで待機し、各プロセスの停止時にその情報を表示します。レスポンスには kill_status カラムが含まれ、このカラムは次の値を取ります。

finished – クエリは正常に停止されました。
waiting – クエリに停止シグナルを送信した後、その終了を待機しています。
その他の値は、クエリを停止できない理由を示します。

テストクエリ (TEST) は、ユーザーの権限を確認し、停止対象のクエリの一覧を表示するだけです。

KILL MUTATION

長時間実行されている、または完了していないミューテーションがある場合、ClickHouseサービスの動作状態が悪化している可能性があります。ミューテーションは非同期で実行されるため、システム上の利用可能なリソースをすべて消費してしまうことがあります。必要に応じて、次のいずれかを行ってください。

新しいミューテーション、INSERT、SELECT をすべて一時停止し、ミューテーションの queue が処理を完了するまで待ちます。
または、KILL コマンドを送信して、これらのミューテーションの一部を手動で停止します。

KILL MUTATION
  WHERE <where expression to SELECT FROM system.mutations query>
  [TEST]
  [FORMAT format]

現在実行中のミューテーションのキャンセルと削除を試みます。キャンセルするミューテーションは、KILL クエリの WHERE 句で指定したフィルタを使用して system.mutations テーブルから選択されます。テストクエリ (TEST) は、ユーザーの権限を確認し、停止対象のミューテーションの一覧を表示するだけです。例: 未完了のミューテーション数の count() を取得します: 単一の ClickHouse ノードにおけるミューテーション数:

SELECT count(*)
FROM system.mutations
WHERE is_done = 0;

ClickHouseレプリカクラスターのミューテーション数:

SELECT count(*)
FROM clusterAllReplicas('default', system.mutations)
WHERE is_done = 0;

未完了のミューテーションの一覧をクエリします: 単一のClickHouseノードのミューテーション一覧:

SELECT mutation_id, *
FROM system.mutations
WHERE is_done = 0;

ClickHouse クラスター内のミューテーション一覧:

SELECT mutation_id, *
FROM clusterAllReplicas('default', system.mutations)
WHERE is_done = 0;

必要に応じてミューテーションを強制終了します:

-- Cancel and remove all mutations of the single table:
KILL MUTATION WHERE database = 'default' AND table = 'table'

-- Cancel the specific mutation:
KILL MUTATION WHERE database = 'default' AND table = 'table' AND mutation_id = 'mutation_3.txt'

このクエリは、ミューテーションが停止して完了できなくなった場合に有用です (たとえば、ミューテーションのクエリ内の関数が、テーブル内のデータに適用された際に例外をスローする場合) 。ミューテーションによってすでに行われた変更はロールバックされません。

system.mutations テーブルの is_killed=1 カラム (ClickHouse Cloud のみ) は、必ずしもそのミューテーションが完全に終了したことを意味するわけではありません。ミューテーションが is_killed=1 かつ is_done=0 の状態のまま、長時間残ることがあります。これは、別の長時間実行中のミューテーションが、強制終了されたミューテーションをブロックしている場合に発生する可能性があります。これは正常な状態です。

SQLリファレンス

データ型

エンジン

関数

フォーマット

設定

システムテーブル

データレイク

KILL QUERY

KILL MUTATION

​KILL QUERY

​KILL MUTATION

KILL QUERY

KILL MUTATION