数据流apache beam插入到replicatedreplacingmergetree

ibrsph3r  于 2021-07-15  发布在  ClickHouse
关注(0)|答案(0)|浏览(375)

我已经复制了replacingmergetree(表1),我已经在此基础上构建了3个同样类型的mv。我正在尝试将流数据(使用dataflow(beam))插入表1。当我改为复制时,它通常作为普通的replacingmergetree工作,我得到下面的错误。有什么问题?
2020-02-24 17:07:37.365来自worker的isterror消息:ru.yandex.clickhouse.except.clickhouse异常: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.checkforerrorandthrow(clickhousestatementimpl。java:875)ru.yandex.clickhouse.clickhousestatementimpl.sendstream(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.clickhouse.clickhouseio$writefn.flush(clickhouseio。java:427) org.apache.beam.sdk.io.clickhouse.clickhouseio$writefn.finishbundle(clickhouseio。java:403)原因:java.lang.throwable:code: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:875)ru.yandex.clickhouse.clickhousestatementimpl.sendstream(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.clickhouse.clickhouseio$writefn.flush(clickhouseio。java:427) org.apache.beam.sdk.io.clickhouse.clickhouseio$writefn.finishbundle(clickhouseio。java:403)org.apache.beam.sdk.io.clickhouse.autovalue\u clickhouseio\u writefn$dofninvoker.invokefinishbundle(未知源)org.apache.beam.runners.dataflow.worker.repacked.org.apache.beam.runners.core.simpledofnrunner.finishbundle(simpledofnrunner)。java:232) org.apache.beam.runners.dataflow.worker.simplepardofn.finishbundle(simplepardofn。java:423)org.apache.beam.runners.dataflow.worker.util.common.worker.pardooperation.finish(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:1073) java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1149)java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:624)java.lang.thread.run(线程。java:748)ru.yandex.clickhouse.except.clickhouse异常:clickhouse异常,代码306,主机35.202.46.77,端口8123;代码:306,e.displaytext()=db::exception:堆栈大小太大。堆栈地址:0x7fe5abdfc000,帧地址:0x7fe5ac1fc210,堆栈大小: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.checkforerrorandthrow(clickhousestatementimpl。java:875)ru.yandex.clickhouse.clickhousestatementimpl.sendstream(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.clickhouse.clickhouseio$writefn.flush(clickhouseio。java:427) org.apache.beam.sdk.io.clickhouse.clickhouseio$writefn.finishbundle(clickhouseio。java:403)原因:java.lang.throwable:code:306,e.displaytext()=db::exception:堆栈大小太大。堆栈地址:0x7fe5abdfc000,帧地址:0x7fe5ac1fc210,堆栈大小: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:875)ru.yandex.clickhouse.clickhousestatementimpl.sendstream(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.clickhouse.clickhouseio$writefn.flush(clickhouseio。java:427) org.apache.beam.sdk.io.clickhouse.clickhouseio$writefn.finishbundle(clickhouseio。java:403)org.apache.beam.sdk.io.clickhouse.autovalue\u clickhouseio\u writefn$dofninvoker.invokefinishbundle(未知源)org.apache.beam.runners.dataflow.worker.repacked.org.apache.beam.runners.core.simpledofnrunner.finishbundle(simpledofnrunner)。java:232) org.apache.beam.runners.dataflow.worker.simplepardofn.finishbundle(simplepardofn。java:423)org.apache.beam.runners.dataflow.worker.util.common.worker.pardooperation.finish(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:1073) java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1149)java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:624)java.lang.thread.run(线程。java:748)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题