数据流被错误消息卡住原因:606330F83AB24C58
我正在使用2.1.0 SDK和cloudshell来启动我的工作。
(606330F83AB2470F):工作流失败。原因:(606330F83AB24C58):数据流似乎卡住了。请联系Dataflow团队，网址是http://stackoverflow.com/questions/tagged/google-cloud-dataflow。
共有1个答案
在内部，Dataflow未能创建辅助实例。错误是：
[...]字段“resource.properties.networkinterfaces[0].subnetwork”的值无效：“.如果网络资源处于自定义子网模式，网络接口必须指定子网。[..]
是否可以在启动作业时提供--subnetwork选项？（此处简要描述:https://beam.apache.org/documentation/sdks/javadoc/2.0.0/org/apache/beam/runners/dataflow/options/dataflowPipelineWorkerPoolOptions.html#getsubnetwork--）
-
2017-12-13（03:44:56）工作流失败。原因：数据流似乎被卡住了。请联系T...：工作流失败。原因：数据流似乎被卡住了。请联系Dataflow团队，网址是http://stackoverflow.com/questions/tagged/google-cloud-dataflow。 有人能帮忙做这项工作吗？谢了！
-
我刚刚接触到Firebase函数，最初一切正常，但现在我面临以下错误。我在下面提供错误和我的代码。 下面是我在Firebase函数中收到的错误。 错误：提供给sendToDevice（）的注册令牌必须是非空字符串或非空数组。在FirebaseMessagingeror。FirebaseMessagingError出现错误（本机）。FirebaseError[作为构造函数]（/user_code/n
-
问题内容： 在类下运行以下代码时 我收到以下错误： 我也试过搬家 走出do-while循环但徒劳无功。 问题答案： 问题 问题是，按照javadoc的说明，您执行了该操作，将关闭流 并释放与之关联的所有系统资源 。 为了快速验证，请注释掉： 您可以随时随地回答，没有任何例外。 一个办法 一种解决方案是在所有读取终止后关闭缓冲区读取器：
-
我在我的消费者体内抛出一个AMQP异常。我的期望是，消息将以FIFO顺序返回队列，并在将来的某个时候重新处理。 Spring AMQP似乎没有将消息释放回队列。而是一次又一次地尝试重新处理失败的消息。这会阻止处理新到达的消息。卡在AMQP控制台内的设备将永远处于“未打包”状态。 有什么想法吗？
-
你能帮我理解这个摘录，从Kafka流留档： 在可能正在处理多个主题分区的流任务中，如果用户将应用程序配置为不等待所有分区都包含一些缓冲数据，并从具有最小时间戳的分区中选取以处理下一条记录，则稍后在为其他主题分区提取某些记录时，它们的时间戳可能比从另一个主题分区获取的已处理记录小。 我不明白其中的逻辑：如果您选择具有最小时间戳的分区，为什么以后会获得较小的时间戳？
-
请查找以下数据流作业详细信息：作业ID:2017-10-17_22_03_20-14123260585966292858作业名称：limit-test-file12-1508302687176批次：批次开始时间：2017年10月18日上午10:33:21状态：取消...地区:us-central1 作业日志详细信息：2017-10-18（11:34:56）工作流失败。原因:(b2725d597b8