在其他管道转换继续运行时停止执行管道转换
在此图像中，有2个并行源和2个并行接收器，由于数据源中的某些错误数据为日期2014-08-01，第一次转换失败。一旦2014-08-01转换失败，则2014-08-02转换被取消。2014-08-02转换没有坏数据。
是否有一种方法可以防止另一个转换的取消？
共有1个答案
当前在Dataflow服务中，整个管道要么成功，要么失败，任何失败都将取消管道的其余部分。没有办法改变这种行为；如果要分别成功或失败，则需要运行单独的管道。
请注意，在操作上，您可以从同一个Java主程序运行两个管道；只需创建两个不同的管道对象并分别对它们调用run（）即可。
-
我试图在Apache Beam中运行一个非常简单的程序来尝试它是如何工作的。 在运行此操作时，我得到以下错误 谢谢
-
在以下MIPS指令序列中（整个程序未显示）： 我想确认两条指令之间所需的暂停次数（在5阶段MIPS管道的上下文中-IF、ID/Reg、EX、MEM、WB），有无转发。 我的理解： （a）如无转发： 在这种情况下，需要2个暂停（在周期5中，可以使用寄存器的分相访问在第二条指令的ID阶段读取R1） （b） 如果有转发： 在这种情况下，不需要暂停（周期4中第二条指令的EX-stage可以从周期3中第一条
-
我希望有一个非常快速的简单答案，我在这里阅读了一些其他问题，这些问题参考了SpEL和转义序列，但仍然没有成功。 我想使用和SpEL将属性拆分为字符串列表。属性将是： 所以我需要在管道字符上进行拆分，我可以使用＜code＞在Java中进行拆分。split（\\|）以成功转义管道字符。我尝试过没有斜杠，2个斜杠和4个斜杠，但都不成功。是否可以使用以下代码在管道上拆分？我的客户无论出于什么原因都想继续使
-
我试图在Beam管道完成后，在Google DataFlow上运行一个函数（或管道）。 目前，我已经构建了一个hack来运行该函数，方法是使用 ... func在哪里： 但是有更好的方法吗？
-
我已经尝试将Shell可执行文件设置为C:\windows\system32\cmd.exe和C:\cygwin64\bin\sh.exe，但是我遇到了同样的错误。我怎样才能解决这个问题？
-
在我的netty客户端中，我有一个初始管道，只有一个ChannelInoundHandlerAdapter。使用这个处理程序，我可以处理协议的握手。之后，我需要修改管道以供正常使用。这意味着我需要删除ChannelIn HandlerAdapter并添加LengthFieldPrepender/LengthFieldBasedFrameDecoder、Encoder/Decoder和一个处理程序。