У меня есть ReplicatedReplacingMergeTree (таблица1), я построил 3 MV по этому же типу. Я пытаюсь вставить потоковые данные (используя поток данных (луч)) в таблицу1. Раньше он работал как обычный ReplacingMergeTree, когда я перехожу на реплицированный, я получаю ошибку ниже в чем проблема?
2020-02-24 17: 07: 37.365 ISTError сообщение от работника: ru.yandex.clickhouse.except.ClickHouseException: исключение ClickHouse, код: 306, хост: 35.202. 46,77, порт: 8123; Код: 306, e.displayText () = DB :: Exception: слишком большой размер стека. Адрес стека: 0x7feae15fe000, адрес фрейма: 0x7feae19fe210, размер стека: 4197872, максимальный размер стека: 8392704 (версия 19.17.4.11 (официальная сборка)) ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. java: 58) ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. java: 28) ru.yandex.clickhouse.ClickHouseStatementImpl. java: 851) ru.yandex.clickhouse.Writer.send (Writer. java: 106) ru.yandex.clickhouse.Writer.send (Writer. java: 141) ru.yandex.clickhouse.ClickHouseStatementImpl. sendRowBinaryStream (ClickHouseStatementImpl. java: 764) ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream (ClickHouseStatementImpl. java: 758) org. apache .beam.sdk.io.clickIO5 $ HH (ClickHouseIO. java: 427) org. apache .beam.sdk.io.clickhouse.ClickHouseIO $ Wri teFn.finishBundle (ClickHouseIO. java: 403) Причина: java .lang.Throwable: Код: 306, e.displayText () = DB :: Exception: слишком большой размер стека. Адрес стека: 0x7feae15fe000, адрес фрейма: 0x7feae19fe210, размер стека: 4197872, максимальный размер стека: 8392704 (версия 19.17.4.11 (официальная сборка)) ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. java: 53) ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. java: 28) ru.yandex.clickhouse.ClickHouseStatementImpl.checkForErrorAndThrow (ClickHouseStatementImpl. java: ClickImp.House. java: 851) ru.yandex.clickhouse.Writer.send (Writer. java: 106) ru.yandex.clickhouse.Writer.send (Writer. java: 141) ru.yandex.clickhouse.ClickHouseStatementImpl. sendRowBinaryStream (ClickHouseStatementImpl. java: 764) ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream (ClickHouseStatementImpl. java: 758) org. apache .beam.sdk.io.clickIO29Househouse (ClickHouseIO. java: 427) org. apache .beam.sdk.io.clickhouse.ClickHouseIO $ Wri teFn.finishBundle (ClickHouseIO. java: 403) org. apache .beam.sdk.io.clickhouse.AutoValue_ClickHouseIO_WriteFn $ DoFnInvoker.invokeFinishBundle (Неизвестный источник) org. apache .bedflowaged.workerworkerworker .org. apache .beam.runners.core.SimpleDoFnRunner.finishBundle (SimpleDoFnRunner. java: 232) org. apache .beam.runners.dataflow.worker.SimpleParDoFn.finishBundle (SimpleParDoFn. 42) java ) org. apache .beam.runners.dataflow.worker.util.common.worker.ParDoOperation.fini sh (ParDoOperation. java: 56) org. apache .beam.runners.dataflow.worker. util.common.worker.MapTaskExecutor.execute (MapTaskExecutor. java: 85) org. apache .beam.runners.dataflow.worker.StreamingDataflowWorker.process (StreamingDataflowWorker. java: 1350) org. apache. beam.runners.dataflow.worker.StreamingDataflowWorker.access $ 1100 (StreamingDataflowWorker. java: 152) org. apache .beam.runners.dataflow.worker.StreamingDataflowWorker $ 7.run (StreamingDataflowWorker. java 10 1050 *) * .util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolEx ecutor. java: 1149) java .util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor. java: 624) java .lang.Thread.run (Тема. java: 748) ru. yandex.clickhouse.except.ClickHouseException: исключение ClickHouse, код: 306, хост: 35.202.46.77, порт: 8123; Код: 306, эл. displayText () = DB :: Exception: слишком большой размер стека. Адрес стека: 0x7fe5abdfc000, адрес фрейма: 0x7fe5ac1fc210, размер стека: 4197872, максимальный размер стека: 8392704 (версия 19.17.4.11 (официальная сборка)) ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. *5856*: ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. java: 28) ru.yandex.clickhouse.ClickHouseStatementImpl. java: 851) ru.yandex.clickhouse.Writer.send (Writer. java: 106) ru.yandex.clickhouse.Writer.send (Writer. java: 141) ru.yandex.clickhouse.ClickHouseStatementImpl. sendRowBinaryStream (ClickHouseStatementImpl. java: 764) ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream (ClickHouseStatementImpl. java: 758) org. apache .beam.sdk.io.clickIO656 (ClickHouseIO. java: 427) org. apache .beam.sdk.io.clickhouse.ClickHouseIO $ Wri teFn.finishBundle (ClickHouseIO. java: 403) Причина: java .lang.Throwable: Код: 306, e.displayText () = DB :: Exception: слишком большой размер стека. Адрес стека: 0x7fe5abdfc000, адрес фрейма: 0x7fe5ac1fc210, размер стека: 4197872, максимальный размер стека: 8392704 (версия 19.17.4.11 (официальная сборка)) ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. * 53 *): ru.yandex.clickhouse.except.ClickHouseExceptionSpecifier.specify (ClickHouseExceptionSpecifier. java: 28) ru.yandex.clickhouse.ClickHouseStatementImpl. java: 851) ru.yandex.clickhouse.Writer.send (Writer. java: 106) ru.yandex.clickhouse.Writer.send (Writer. java: 141) ru.yandex.clickhouse.ClickHouseStatementImpl. sendRowBinaryStream (ClickHouseStatementImpl. java: 764) ru.yandex.clickhouse.ClickHouseStatementImpl.sendRowBinaryStream (ClickHouseStatementImpl. java: 758) org. apache .beam.sdk.io.clickIO $HhouseHouse). (ClickHouseIO. java: 427) org. apache .beam.sdk.io.clickhouse.ClickHouseIO $ Wri teFn.finishBundle (ClickHouseIO. java: 403) org. apache .beam.sdk.io.clickhouse.AutoValue_ClickHouseIO_WriteFn $ DoFnInvoker.invokeFinishBundle (Неизвестный источник) org. apache .bedflow.workworkererworker .org. apache .beam.runners.core.SimpleDoFnRunner.finishBundle (SimpleDoFnRunner. java: 232) org. apache .beam.runners.dataflow.worker.SimpleParDoFn.finishBundle (SimpleParDoFn. 423 * 1088) ) org. apache .beam.runners.dataflow.worker.util.common.worker.ParDoOperation.fini sh (ParDoOperation. java: 56) org. apache .beam.runners.dataflow.worker. util.common.worker.MapTaskExecutor.execute (MapTaskExecutor. java: 85) org. apache .beam.runners.dataflow.worker.StreamingDataflowWorker.process (StreamingDataflowWorker. java: 1350) org. apache. beam.runners.dataflow.worker.StreamingDataflowWorker.access $ 1100 (StreamingDataflowWorker. java: 152) org. apache .beam.runners.dataflow.worker.StreamingDataflowWorker $ 7.run (StreamingDataflowWorker. java) 1099: * .util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolEx ecutor. java: 1149) java .util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor. java: 624) java .lang.Thread.run (Тема. java: 748)