我在一个舞台上积压了一大堆内容,直到最近,雪斗还在吞噬这些内容。我想当我暂停雪斗一段时间,然后重新启动时,它就停止了摄取;但我不能确定。查询雪管的状态,我看到:
{"executionState":"RUNNING","oldestFileTimestamp":"2021-05-13T12:15:25.086Z","pendingFileCount":282,"notificationChannelName":"arn:aws:sqs:XXXXXXXXXXXXXXXXXXXXXXXXXXXX","numOutstandingMessagesOnChannel":0,"lastReceivedMessageTimestamp":"2021-05-19T08:15:27.482Z","lastForwardedMessageTimestamp":"2021-05-19T08:15:27.531Z"}
最后一段被摄取的内容的日期是2021-05-13 12:52:16.913。
如何加载在2021-05-1312:52:16.913之后落地的内容,以及如何让雪管在落地时重新摄取新内容?
发布于 2021-05-20 22:05:16
尝试再次暂停管道,然后使用创建或替换管道重新创建管道...选项。如果执行此操作,请确保将所有权等与任何其他权限一起授予原始所有者(如果在不同角色下运行
然后运行SELECT SYSTEM$PIPE_FORCE_RESUME( 'MY_PIPE‘);
我使用这种方法对管道进行了多次更改,它并没有让我失望。话虽如此,我们使用内部阶段,所以我不能肯定它将如何表现与外部阶段
https://stackoverflow.com/questions/67599613
复制相似问题