[
https://issues.apache.org/jira/browse/BEAM-5645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16788257#comment-16788257
]
Reuven Lax commented on BEAM-5645:
----------------------------------
Do we simply need to add an equals() override?
On Fri, Mar 8, 2019 at 3:13 AM Julien Tournay (JIRA) <j...@apache.org>
> 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
> 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)
