[
https://issues.apache.org/jira/browse/BEAM-5645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661352#comment-16661352
]
Kenneth Knowles commented on BEAM-5645:
---------------------------------------
I think we have code that confirms coders can be serialized/deserialized, hence
shipped with the pipeline. In truth I think that the problem is devising an
appropriate equals. Did this bite you in practice in some way [~jto], so we can
take a more holistic view?
> RowCoder not equal after serialization
> --------------------------------------
>
> Key: BEAM-5645
> URL: https://issues.apache.org/jira/browse/BEAM-5645
> Project: Beam
> Issue Type: Bug
> Components: runner-core
> Affects Versions: 2.6.0
> Reporter: Julien Tournay
> Assignee: Reuven Lax
> Priority: Major
>
> The following code throws an exception:
> {code:scala}
> import org.apache.beam.sdk.coders._
> import org.apache.beam.sdk.schemas.Schema
> val schema =
> Schema
> .builder()
> .addInt32Field("c1")
> .addStringField("c2")
> .addDoubleField("c3")
> .build()
> val coder = RowCoder.of(schema)
> org.apache.beam.sdk.util.SerializableUtils.ensureSerializable(coder)
> {code}
> {code}
> java.lang.IllegalStateException: Coder not equal to original after
> serialization, indicating that the Coder may not implement serialization
> correctly. Before: org.apache.beam.sdk.coders.RowCoder@1323050e, after:
> org.apache.beam.sdk.coders.RowCoder@4c03150a
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
