je-ik commented on code in PR #30403:
URL: https://github.com/apache/beam/pull/30403#discussion_r1501138097
##########
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java:
##########
@@ -143,6 +143,9 @@
*/
public abstract class PTransform<InputT extends PInput, OutputT extends
POutput>
implements Serializable /* See the note above */, HasDisplayData {
+
+ private static final long serialVersionUID = 3383862966597863311L;
Review Comment:
The problem is that Flink needs to serialize the UnboundedSource (after
split) into state to support legacy Read. I'm not sure what is the correct path
of fixing this - we could use Kryo, but UnboundedSource actually is
`Serializable`. How does Dataflow serialize the source? I suppose the same
applies for ReadViaSDF as well.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
