[jira] [Assigned] (BEAM-419) Non-transient non-serializable instance field in CombineFnUtil$NonSerializableBoundedKeyedCombineFn

[ https://issues.apache.org/jira/browse/BEAM-419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-419: Assignee: (was: Neelesh Srinivas Salian) > Non-transient non-serializable

[jira] [Assigned] (BEAM-409) Incorrect use of Math.ceil in ApproximateQuantiles

[ https://issues.apache.org/jira/browse/BEAM-409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-409: Assignee: (was: Neelesh Srinivas Salian) > Incorrect use of Math.ceil in

[jira] [Assigned] (BEAM-410) ApproximateQuantiles$QuantileBuffer defines compareTo but not equals

[ https://issues.apache.org/jira/browse/BEAM-410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-410: Assignee: (was: Neelesh Srinivas Salian) > ApproximateQuantiles$QuantileB

[jira] [Assigned] (BEAM-407) Inconsistent synchronization in OffsetRangeTracker.copy

[ https://issues.apache.org/jira/browse/BEAM-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-407: Assignee: (was: Neelesh Srinivas Salian) > Inconsistent synchronization i

[jira] [Assigned] (BEAM-400) Direct/InProcess runner should use Pubsub publish time timestamp if timestampLabel is not set

[ https://issues.apache.org/jira/browse/BEAM-400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-400: Assignee: (was: Neelesh Srinivas Salian) > Direct/InProcess runner should

[jira] [Assigned] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold

[ https://issues.apache.org/jira/browse/BEAM-420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-420: Assignee: (was: Neelesh Srinivas Salian) > Non-transient non-serializable

[jira] [Assigned] (BEAM-421) StateTags$CombiningValueStateTag inherits equals from super class but without incorporating its state

[ https://issues.apache.org/jira/browse/BEAM-421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-421: Assignee: (was: Neelesh Srinivas Salian) > StateTags$CombiningValueStateT

[jira] [Assigned] (BEAM-526) Mismatched pipelines give unclear error

[ https://issues.apache.org/jira/browse/BEAM-526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-526: Assignee: (was: Neelesh Srinivas Salian) > Mismatched pipelines give uncl

[jira] [Assigned] (BEAM-659) WindowFn#isCompatible should provide a meaningful reason

[ https://issues.apache.org/jira/browse/BEAM-659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-659: Assignee: (was: Neelesh Srinivas Salian) > WindowFn#isCompatible should p

[jira] [Assigned] (BEAM-1129) Umbrella JIRA for Fixing Findbugs

[ https://issues.apache.org/jira/browse/BEAM-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1129: - Assignee: (was: Neelesh Srinivas Salian) > Umbrella JIRA for Fixing Fi

[jira] [Assigned] (BEAM-454) Validate Pubsub Topic exists when reading

[ https://issues.apache.org/jira/browse/BEAM-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-454: Assignee: (was: Neelesh Srinivas Salian) > Validate Pubsub Topic exists w

[jira] [Comment Edited] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963215#comment-15963215 ] Neelesh Srinivas Salian edited comment on BEAM-1105 at 4/10/17 5:18 PM: -

[jira] [Commented] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963215#comment-15963215 ] Neelesh Srinivas Salian commented on BEAM-1105: --- Feel free to grab [~altay]

[jira] [Commented] (BEAM-526) Mismatched pipelines give unclear error

[ https://issues.apache.org/jira/browse/BEAM-526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959452#comment-15959452 ] Neelesh Srinivas Salian commented on BEAM-526: -- Hi [~altay], apologies for the

[jira] [Updated] (BEAM-1664) Support Kafka0.8.x client in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian updated BEAM-1664: -- Summary: Support Kafka0.8.x client in KafkaIO (was: Support Kafka0.8.x client

[jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner

[ https://issues.apache.org/jira/browse/BEAM-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938482#comment-15938482 ] Neelesh Srinivas Salian commented on BEAM-165: -- [~jbonofre], I can work with yo

[jira] [Assigned] (BEAM-301) Add a Beam SQL DSL

[ https://issues.apache.org/jira/browse/BEAM-301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-301: Assignee: Xu Mingmin (was: Neelesh Srinivas Salian) > Add a Beam SQL DSL > -

[jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner

[ https://issues.apache.org/jira/browse/BEAM-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15888569#comment-15888569 ] Neelesh Srinivas Salian commented on BEAM-165: -- [~jbonofre], should we move for

[jira] [Assigned] (BEAM-1078) Modifying the links in JavaDocs to point to the Beam github repo rather than GCP

[ https://issues.apache.org/jira/browse/BEAM-1078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1078: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Modify

[jira] [Assigned] (BEAM-421) StateTags$CombiningValueStateTag inherits equals from super class but without incorporating its state

[ https://issues.apache.org/jira/browse/BEAM-421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-421: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > StateTags

[jira] [Assigned] (BEAM-526) Mismatched pipelines give unclear error

[ https://issues.apache.org/jira/browse/BEAM-526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-526: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Mismatche

[jira] [Assigned] (BEAM-659) WindowFn#isCompatible should provide a meaningful reason

[ https://issues.apache.org/jira/browse/BEAM-659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-659: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > WindowFn#

[jira] [Assigned] (BEAM-1129) Umbrella JIRA for Fixing Findbugs

[ https://issues.apache.org/jira/browse/BEAM-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1129: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Umbrel

[jira] [Assigned] (BEAM-454) Validate Pubsub Topic exists when reading

[ https://issues.apache.org/jira/browse/BEAM-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-454: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Validate

[jira] [Assigned] (BEAM-1083) Deleting the Weblink for the DatastoreWordCount based on BEAM-498

[ https://issues.apache.org/jira/browse/BEAM-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1083: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Deleti

[jira] [Assigned] (BEAM-301) Add a Beam SQL DSL

[ https://issues.apache.org/jira/browse/BEAM-301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-301: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Add a Bea

[jira] [Assigned] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1105: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Adding

[jira] [Assigned] (BEAM-651) Add public TypedPValue.setTypeDescriptor

[ https://issues.apache.org/jira/browse/BEAM-651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-651: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Add publi

[jira] [Assigned] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold

[ https://issues.apache.org/jira/browse/BEAM-420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-420: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Non-trans

[jira] [Assigned] (BEAM-407) Inconsistent synchronization in OffsetRangeTracker.copy

[ https://issues.apache.org/jira/browse/BEAM-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-407: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Inconsist

[jira] [Assigned] (BEAM-400) Direct/InProcess runner should use Pubsub publish time timestamp if timestampLabel is not set

[ https://issues.apache.org/jira/browse/BEAM-400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-400: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Direct/In

[jira] [Assigned] (BEAM-409) Incorrect use of Math.ceil in ApproximateQuantiles

[ https://issues.apache.org/jira/browse/BEAM-409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-409: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Incorrect

[jira] [Assigned] (BEAM-419) Non-transient non-serializable instance field in CombineFnUtil$NonSerializableBoundedKeyedCombineFn

[ https://issues.apache.org/jira/browse/BEAM-419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-419: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Non-trans

[jira] [Assigned] (BEAM-410) ApproximateQuantiles$QuantileBuffer defines compareTo but not equals

[ https://issues.apache.org/jira/browse/BEAM-410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-410: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Approxima

[jira] [Assigned] (BEAM-879) Renaming DeDupExample to DistinctExample

[ https://issues.apache.org/jira/browse/BEAM-879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-879: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Renaming

[jira] [Assigned] (BEAM-239) Rename RemoveDuplicates to Distinct

[ https://issues.apache.org/jira/browse/BEAM-239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-239: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Rename Re

[jira] [Assigned] (BEAM-29) Bound Instant values used as timestamps at TIMESTAMP_MIN_VALUE and TIMESTAMP_MAX_VALUE

[ https://issues.apache.org/jira/browse/BEAM-29?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-29: --- Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Bound Instan