Do not override type descriptor in WithTimestamps
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6fa8057f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6fa8057f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6fa8057f Branch: refs/heads/python-sdk Commit: 6fa8057fe1db97615872915dcd81b2bca9b44e63 Parents: e92a157 Author: Kenneth Knowles <k...@google.com> Authored: Thu Nov 17 11:07:32 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Nov 18 15:09:43 2016 -0800 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/transforms/WithTimestamps.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6fa8057f/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java index 00ac8e4..64e7c45 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java @@ -99,9 +99,8 @@ public class WithTimestamps<T> extends PTransform<PCollection<T>, PCollection<T> @Override public PCollection<T> apply(PCollection<T> input) { - return input - .apply("AddTimestamps", ParDo.of(new AddTimestampsDoFn<T>(fn, allowedTimestampSkew))) - .setTypeDescriptorInternal(input.getTypeDescriptor()); + return input.apply( + "AddTimestamps", ParDo.of(new AddTimestampsDoFn<T>(fn, allowedTimestampSkew))); } private static class AddTimestampsDoFn<T> extends DoFn<T, T> {