[jira] [Updated] (BEAM-44) Return the input coder in NullableCoder.of() if it is a NullableCoder

2016-04-06 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-44?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-44: Description: {{NullableCoder.of(NullableCoder.of(foo))}} returns a nested {{NullableCoder}}, which

[jira] [Updated] (BEAM-170) Session windows should not be identified by their bounds

2016-04-04 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-170: - Description: Today, if two session windows for the same key have the same bounds

[jira] [Created] (BEAM-170) Session windows should not be identified by their bounds

2016-04-04 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-170: Summary: Session windows should not be identified by their bounds Key: BEAM-170 URL: https://issues.apache.org/jira/browse/BEAM-170 Project: Beam Issue Type

[jira] [Created] (BEAM-169) Need serialized form and serialVersionUID for user-facing superclasses

2016-04-04 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-169: Summary: Need serialized form and serialVersionUID for user-facing superclasses Key: BEAM-169 URL: https://issues.apache.org/jira/browse/BEAM-169 Project: Beam

[jira] [Comment Edited] (BEAM-162) assert fail using session windows

2016-03-31 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220413#comment-15220413 ] Kenneth Knowles edited comment on BEAM-162 at 3/31/16 6:34 PM: --- I agree

[jira] [Commented] (BEAM-162) assert fail using session windows

2016-03-31 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220413#comment-15220413 ] Kenneth Knowles commented on BEAM-162: -- I agree with your PR, but I think the cause is different than

[jira] [Commented] (BEAM-162) assert fail using session windows

2016-03-31 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220403#comment-15220403 ] Kenneth Knowles commented on BEAM-162: -- I meant should in the normative sense, of course. > ass

[jira] [Commented] (BEAM-162) assert fail using session windows

2016-03-31 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15220369#comment-15220369 ] Kenneth Knowles commented on BEAM-162: -- Elaborating on Ben's comment, only the trigger's {{onFire

[jira] [Updated] (BEAM-163) Warn the user when a PCollection (via Window.into) has smaller allowedLateness than upstream

2016-03-31 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-163: - Description: In this situation, data may be dropped downstream even though it was allowed upstream

[jira] [Created] (BEAM-163) Warn the user when a PCollection (via Window.into) has smaller allowedLateness than upstream

2016-03-31 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-163: Summary: Warn the user when a PCollection (via Window.into) has smaller allowedLateness than upstream Key: BEAM-163 URL: https://issues.apache.org/jira/browse/BEAM-163

[jira] [Commented] (BEAM-149) IntelliJ: Java 8 tests configuration

2016-03-24 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15210583#comment-15210583 ] Kenneth Knowles commented on BEAM-149: -- When it was {{src/test/java}} and {{src/test/java8

[jira] [Created] (BEAM-145) OutputTimeFn#assignOutputTime overrides WindowFn#getOutputTime in unfortunate ways

2016-03-23 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-145: Summary: OutputTimeFn#assignOutputTime overrides WindowFn#getOutputTime in unfortunate ways Key: BEAM-145 URL: https://issues.apache.org/jira/browse/BEAM-145 Project

[jira] [Commented] (BEAM-116) Change runners artifactId to runners-parent

2016-03-19 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197806#comment-15197806 ] Kenneth Knowles commented on BEAM-116: -- +1. I reverted it to "runners" but I am convinced b

[jira] [Updated] (BEAM-115) Beam Runner API

2016-03-14 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-115: - Description: The PipelineRunner API from the SDK is not ideal for the Beam technical vision

[jira] [Updated] (BEAM-115) Beam Runner API

2016-03-14 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-115: - Description: The PipelineRunner API from the SDK is not ideal for the Beam technical vision

[jira] [Created] (BEAM-115) Beam Runner API

2016-03-14 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-115: Summary: Beam Runner API Key: BEAM-115 URL: https://issues.apache.org/jira/browse/BEAM-115 Project: Beam Issue Type: Improvement Components

[jira] [Commented] (BEAM-85) DataflowAssert (BeamAssert ;) needs sanity check that it's used correctly

2016-03-01 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-85?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15175127#comment-15175127 ] Kenneth Knowles commented on BEAM-85: - Yes, they are separable. > DataflowAssert (BeamAssert ;) ne

[jira] [Created] (BEAM-83) Beam SDK has some difficulties upon import to Eclipse as maven project

2016-02-29 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-83: --- Summary: Beam SDK has some difficulties upon import to Eclipse as maven project Key: BEAM-83 URL: https://issues.apache.org/jira/browse/BEAM-83 Project: Beam

[jira] [Created] (BEAM-82) Transitive dependencies in Beam pom.xml have conflicts that could result in old versions if reordered

2016-02-29 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-82: --- Summary: Transitive dependencies in Beam pom.xml have conflicts that could result in old versions if reordered Key: BEAM-82 URL: https://issues.apache.org/jira/browse/BEAM-82

[jira] [Updated] (BEAM-39) Audit trigger implementations to ensure they prefetch appropriately

2016-02-22 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-39: Assignee: Frances Perry (was: Kenneth Knowles) > Audit trigger implementations to ens

[jira] [Created] (BEAM-40) Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate)

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-40: --- Summary: Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate) Key: BEAM-40 URL: https://issues.apache.org/jira/browse/BEAM-40

[jira] [Created] (BEAM-39) Audit trigger implementations to ensure they prefetch appropriately

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-39: --- Summary: Audit trigger implementations to ensure they prefetch appropriately Key: BEAM-39 URL: https://issues.apache.org/jira/browse/BEAM-39 Project: Beam

[jira] [Created] (BEAM-38) Avoid repeated DoFn deserialization

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-38: --- Summary: Avoid repeated DoFn deserialization Key: BEAM-38 URL: https://issues.apache.org/jira/browse/BEAM-38 Project: Beam Issue Type: New Feature

[jira] [Created] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-32: --- Summary: Consider not emitting empty ON_TIME pane unless requested Key: BEAM-32 URL: https://issues.apache.org/jira/browse/BEAM-32 Project: Beam Issue Type

[jira] [Created] (BEAM-31) When triggers are changed via pipeline update, stale finished triggers data applied

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-31: --- Summary: When triggers are changed via pipeline update, stale finished triggers data applied Key: BEAM-31 URL: https://issues.apache.org/jira/browse/BEAM-31 Project

[jira] [Updated] (BEAM-30) In TriggerRunner, avoid reading the set of finished subtriggers when no subtrigger ever finishes.

2016-02-19 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-30?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-30: Component/s: runner-core > In TriggerRunner, avoid reading the set of finished subtriggers w

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

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-29: --- Summary: Bound Instant values used as timestamps at TIMESTAMP_MIN_VALUE and TIMESTAMP_MAX_VALUE Key: BEAM-29 URL: https://issues.apache.org/jira/browse/BEAM-29 Project

[jira] [Created] (BEAM-26) Model for validation of user state upon pipeline update

2016-02-19 Thread Kenneth Knowles (JIRA)
Kenneth Knowles created BEAM-26: --- Summary: Model for validation of user state upon pipeline update Key: BEAM-26 URL: https://issues.apache.org/jira/browse/BEAM-26 Project: Beam Issue Type: Sub

[jira] [Commented] (BEAM-12) Apply GroupByKey transforms on PCollection of normal type other than KV

2016-02-15 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-12?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15147522#comment-15147522 ] Kenneth Knowles commented on BEAM-12: - Note also that the SDK includes a very simple composite {{WithKeys

<    1   2   3   4   5