我在Mac上使用DirectRunner测试了Dataflow管道,并收到了许多类似这样的“警告”消息,也许我知道如何清除它们,因为它太多了,我什至看不到调试消息。
谢谢
Apr 05, 2018 2:14:48 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element com.apigee.analytics.platform.core.service.schema.EventRow@4a590d0b
最佳答案
自equals()
expects以来,确保所有序列化值都具有正确的SerializableCoder
实现可能会有所帮助:
您可以为POJO实现自己的Coder
。 SerializableCoder不保证根据docs进行确定性编码:
This article explains custom coders in details。