[jira] [Resolved] (BEAM-438) Rename one of PTransform.apply and PInput.apply

[ https://issues.apache.org/jira/browse/BEAM-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-438. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Rename one of PTransform.ap

[jira] [Assigned] (BEAM-438) Rename one of PTransform.apply and PInput.apply

[ https://issues.apache.org/jira/browse/BEAM-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-438: Assignee: Kenneth Knowles > Rename one of PTransform.apply and PInput.ap

[jira] [Resolved] (BEAM-651) Consider making TypedPValue.setTypeDescriptorInternal no longer Internal

[ https://issues.apache.org/jira/browse/BEAM-651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-651. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Consider mak

[jira] [Created] (BEAM-1089) Jenkins comments on PRs are too many & too large

Kenneth Knowles created BEAM-1089: - Summary: Jenkins comments on PRs are too many & too large Key: BEAM-1089 URL: https://issues.apache.org/jira/browse/BEAM-1089 Project: Beam Issue

Re: Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1705

Fix is roll forwards via https://github.com/apache/incubator-beam/pull/1488 On Thu, Dec 1, 2016 at 8:57 PM, Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See RunnableOnService_Dataflow/1705/changes> > >

Re: Jenkins build is still unstable: beam_PostCommit_MavenVerify #1948

This is a Dataflow-specific linking error. I am investigating and proceeding with a temporary rollback. On Wed, Nov 30, 2016 at 3:06 PM, Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See > >

[jira] [Closed] (BEAM-23) User-facing state and timers for ParDo(DoFn)

[ https://issues.apache.org/jira/browse/BEAM-23?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-23. --- Resolution: Duplicate Fix Version/s: Not applicable > User-facing state and timers for ParDo(D

[jira] [Updated] (BEAM-41) State for "Set" data, supporting efficient membership checks

[ https://issues.apache.org/jira/browse/BEAM-41?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-41: Issue Type: New Feature (was: Sub-task) Parent: (was: BEAM-23) > State for "S

[jira] [Updated] (BEAM-42) State for "Map" data, supporting efficient key lookup, etc.

[ https://issues.apache.org/jira/browse/BEAM-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-42: Issue Type: New Feature (was: Sub-task) Parent: (was: BEAM-23) > State for "M

[jira] [Updated] (BEAM-27) Add user-ready API for interacting with timers

[ https://issues.apache.org/jira/browse/BEAM-27?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-27: Issue Type: New Feature (was: Sub-task) Parent: (was: BEAM-23) > Add user-ready

[jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn

[ https://issues.apache.org/jira/browse/BEAM-37?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-37: Issue Type: New Feature (was: Sub-task) Parent: (was: BEAM-23) > Run DoFnWithCont

[jira] [Reopened] (BEAM-230) Remove WindowedValue#valueInEmptyWindows

[ https://issues.apache.org/jira/browse/BEAM-230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reopened BEAM-230: -- Assignee: Kenneth Knowles (was: Thomas Groh) > Remove WindowedValue#valueInEmptyWind

[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows

[ https://issues.apache.org/jira/browse/BEAM-230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702714#comment-15702714 ] Kenneth Knowles commented on BEAM-230: -- This wasn't actually removed completely. > Rem

[jira] [Commented] (BEAM-1043) Dependency problems found in runner-apex

[ https://issues.apache.org/jira/browse/BEAM-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15690895#comment-15690895 ] Kenneth Knowles commented on BEAM-1043: --- I haven't dug that deep into Maven's resolution. It seems

[jira] [Updated] (BEAM-1029) ParDo should validate window merging against StateSpec being auto-combinable

[ https://issues.apache.org/jira/browse/BEAM-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1029: -- Summary: ParDo should validate window merging against StateSpec being auto-combinable

[jira] [Created] (BEAM-1035) Support for new State API in SparkRunner

Kenneth Knowles created BEAM-1035: - Summary: Support for new State API in SparkRunner Key: BEAM-1035 URL: https://issues.apache.org/jira/browse/BEAM-1035 Project: Beam Issue Type: New

[jira] [Created] (BEAM-1038) Support for new State API in DataflowRunner

Kenneth Knowles created BEAM-1038: - Summary: Support for new State API in DataflowRunner Key: BEAM-1038 URL: https://issues.apache.org/jira/browse/BEAM-1038 Project: Beam Issue Type: New

[jira] [Created] (BEAM-1037) Support for new State API in ApexRunner

Kenneth Knowles created BEAM-1037: - Summary: Support for new State API in ApexRunner Key: BEAM-1037 URL: https://issues.apache.org/jira/browse/BEAM-1037 Project: Beam Issue Type: New Feature

[jira] [Created] (BEAM-1036) Support for new State API in FlinkRunner

Kenneth Knowles created BEAM-1036: - Summary: Support for new State API in FlinkRunner Key: BEAM-1036 URL: https://issues.apache.org/jira/browse/BEAM-1036 Project: Beam Issue Type: New

[jira] [Created] (BEAM-1030) DoFnSignatures should validate StateSpec against key type

Kenneth Knowles created BEAM-1030: - Summary: DoFnSignatures should validate StateSpec against key type Key: BEAM-1030 URL: https://issues.apache.org/jira/browse/BEAM-1030 Project: Beam Issue

[jira] [Created] (BEAM-1029) DoFnSignatures should validate window merging against StateSpec being auto-combinable

Kenneth Knowles created BEAM-1029: - Summary: DoFnSignatures should validate window merging against StateSpec being auto-combinable Key: BEAM-1029 URL: https://issues.apache.org/jira/browse/BEAM-1029

[jira] [Created] (BEAM-1008) KeyedWorkItemCoder claims three coder arguments in getCoderArguments but only has two generic type variables

Kenneth Knowles created BEAM-1008: - Summary: KeyedWorkItemCoder claims three coder arguments in getCoderArguments but only has two generic type variables Key: BEAM-1008 URL: https://issues.apache.org/jira/browse

[jira] [Created] (BEAM-1004) Autogenerate example archetypes as part of build process

Kenneth Knowles created BEAM-1004: - Summary: Autogenerate example archetypes as part of build process Key: BEAM-1004 URL: https://issues.apache.org/jira/browse/BEAM-1004 Project: Beam Issue

[jira] [Updated] (BEAM-210) Allow control of empty ON_TIME panes analogous to final panes

[ https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-210: - Assignee: Thomas Groh (was: Kenneth Knowles) > Allow control of empty ON_TIME panes analog

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

[ https://issues.apache.org/jira/browse/BEAM-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-39: Assignee: Sam Whittle (was: Kenneth Knowles) > Audit trigger implementations to ensure they prefe

[jira] [Created] (BEAM-967) Add Jenkins postcommit for Apex runner RunnableOnService tests

Kenneth Knowles created BEAM-967: Summary: Add Jenkins postcommit for Apex runner RunnableOnService tests Key: BEAM-967 URL: https://issues.apache.org/jira/browse/BEAM-967 Project: Beam

[jira] [Resolved] (BEAM-561) Add WindowedWordCountIT

[ https://issues.apache.org/jira/browse/BEAM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-561. -- Resolution: Fixed Fix Version/s: 0.3.0-incubating > Add WindowedWordCoun

[jira] [Updated] (BEAM-966) Run WindowedWordCount Integration Test in Apex runner

[ https://issues.apache.org/jira/browse/BEAM-966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-966: - Summary: Run WindowedWordCount Integration Test in Apex runner (was: Running WindowedWordCount

[jira] [Updated] (BEAM-719) Run WindowedWordCount Integration Test in Spark

[ https://issues.apache.org/jira/browse/BEAM-719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-719: - Summary: Run WindowedWordCount Integration Test in Spark (was: Running WindowedWordCount

[jira] [Updated] (BEAM-720) Run WindowedWordCount Integration Test in Flink

[ https://issues.apache.org/jira/browse/BEAM-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-720: - Summary: Run WindowedWordCount Integration Test in Flink (was: Running WindowedWordCount

[jira] [Updated] (BEAM-966) Running WindowedWordCount Integration Test in Apex runner

[ https://issues.apache.org/jira/browse/BEAM-966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-966: - Assignee: Thomas Weise (was: Amit Sela) > Running WindowedWordCount Integration Test in A

[jira] [Created] (BEAM-966) Running WindowedWordCount Integration Test in Apex runner

Kenneth Knowles created BEAM-966: Summary: Running WindowedWordCount Integration Test in Apex runner Key: BEAM-966 URL: https://issues.apache.org/jira/browse/BEAM-966 Project: Beam Issue

[jira] [Updated] (BEAM-959) JdbcIO validation messages need improvement

[ https://issues.apache.org/jira/browse/BEAM-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-959: - Issue Type: Improvement (was: Bug) > JdbcIO validation messages need improvem

[jira] [Updated] (BEAM-960) JdbcIO should infer coder when possible (such as via RowMapper)

[ https://issues.apache.org/jira/browse/BEAM-960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-960: - Issue Type: Improvement (was: Bug) > JdbcIO should infer coder when possible (such as

[jira] [Updated] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-912: - Assignee: (was: Frances Perry) > Range join in B

[jira] [Resolved] (BEAM-922) runner-core does not pass under findbugs

[ https://issues.apache.org/jira/browse/BEAM-922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-922. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > runner-core does not pass un

[jira] [Updated] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-912: - Assignee: Frances Perry (was: Kenneth Knowles) > Range join in B

[jira] [Resolved] (BEAM-947) WindowedWordCountIT fails due to not setting "--output" pipeline options

[ https://issues.apache.org/jira/browse/BEAM-947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-947. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > WindowedWordCountIT fails

[jira] [Updated] (BEAM-688) Failure of beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-688: - Description: The starter archetype has flaky dependencies. It is reported to fail reliably

[jira] [Updated] (BEAM-688) Failure of beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-688: - Priority: Major (was: Minor) > Failure of beam-sdks-java-maven-archetypes-starter with undecla

[jira] [Updated] (BEAM-688) Failure of beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-688: - Summary: Failure of beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[jira] [Commented] (BEAM-688) Repeated 'mvn install' fails on beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15656070#comment-15656070 ] Kenneth Knowles commented on BEAM-688: -- I don't believe it has to be repeated. It causes flakes

[jira] [Commented] (BEAM-747) Text checksum verifier is not resilient to eventually consistent filesystems

[ https://issues.apache.org/jira/browse/BEAM-747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15655332#comment-15655332 ] Kenneth Knowles commented on BEAM-747: -- While we wait to get a reliable fix in, there are only a few

Re: [jira] [Created] (BEAM-961) CountingInput could have starting number

into the codebase. On Thu, Nov 10, 2016 at 1:23 PM, Dan Halperin <dhalp...@google.com> wrote: > Why not support this in a follow-on pardo that shifts the range? > > On Thu, Nov 10, 2016 at 1:22 PM, Kenneth Knowles (JIRA) <j...@apache.org> > wrote: > >>

[jira] [Created] (BEAM-961) CountingInput could have starting number

Kenneth Knowles created BEAM-961: Summary: CountingInput could have starting number Key: BEAM-961 URL: https://issues.apache.org/jira/browse/BEAM-961 Project: Beam Issue Type: New Feature

[jira] [Updated] (BEAM-960) JdbcIO should infer coder when possible (such as via RowMapper)

[ https://issues.apache.org/jira/browse/BEAM-960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-960: - Summary: JdbcIO should infer coder when possible (such as via RowMapper) (was: JdbcIO should infer

[jira] [Created] (BEAM-960) JdbcIO should infer coder based on RowMapper when possible

Kenneth Knowles created BEAM-960: Summary: JdbcIO should infer coder based on RowMapper when possible Key: BEAM-960 URL: https://issues.apache.org/jira/browse/BEAM-960 Project: Beam Issue

[jira] [Created] (BEAM-959) JdbcIO validation messages need improvement

Kenneth Knowles created BEAM-959: Summary: JdbcIO validation messages need improvement Key: BEAM-959 URL: https://issues.apache.org/jira/browse/BEAM-959 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-957) Flake in FlattenTest under DirectRunner

Kenneth Knowles created BEAM-957: Summary: Flake in FlattenTest under DirectRunner Key: BEAM-957 URL: https://issues.apache.org/jira/browse/BEAM-957 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-909) Starter archetype's pom doesn't include the right dependencies

[ https://issues.apache.org/jira/browse/BEAM-909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15652970#comment-15652970 ] Kenneth Knowles commented on BEAM-909: -- The starter archetype is also the cause of flaky failure

[jira] [Commented] (BEAM-909) Starter archetype's pom doesn't include the right dependencies

[ https://issues.apache.org/jira/browse/BEAM-909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15652971#comment-15652971 ] Kenneth Knowles commented on BEAM-909: -- Sorry, this is BEAM-688. Both imply a revamp of the archetype

[jira] [Created] (BEAM-953) Consider moving control of output location out of WordCountIT and WindowedWordCountIT

Kenneth Knowles created BEAM-953: Summary: Consider moving control of output location out of WordCountIT and WindowedWordCountIT Key: BEAM-953 URL: https://issues.apache.org/jira/browse/BEAM-953

[jira] [Commented] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15652072#comment-15652072 ] Kenneth Knowles commented on BEAM-912: -- After conversation with a colleague, we have another suggestion

[jira] [Updated] (BEAM-947) WindowedWordCountIT fails due to not setting "--output" pipeline options

[ https://issues.apache.org/jira/browse/BEAM-947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-947: - Description: Example failure: https://builds.apache.org/job/beam_PreCommit_MavenVerify/4793

[jira] [Created] (BEAM-947) WindowedWordCountIT fails due to not setting "--output" pipeline options

Kenneth Knowles created BEAM-947: Summary: WindowedWordCountIT fails due to not setting "--output" pipeline options Key: BEAM-947 URL: https://issues.apache.org/jira/browse/BEAM-947 Pro

[jira] [Resolved] (BEAM-907) Allow user to use a specific subclass of BoundedWindow in DoFn parameter lists

[ https://issues.apache.org/jira/browse/BEAM-907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-907. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Allow user to use a specific subcl

[jira] [Commented] (BEAM-944) Spark runner causes an exception when creating pipeline options

[ https://issues.apache.org/jira/browse/BEAM-944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648589#comment-15648589 ] Kenneth Knowles commented on BEAM-944: -- If you had {{SparkPipelineOptions}} registered

[jira] [Commented] (BEAM-944) Spark runner causes an exception when creating pipeline options

[ https://issues.apache.org/jira/browse/BEAM-944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648493#comment-15648493 ] Kenneth Knowles commented on BEAM-944: -- Perhaps you can split it into two options classes

[jira] [Comment Edited] (BEAM-944) Spark runner causes an exception when creating pipeline options

[ https://issues.apache.org/jira/browse/BEAM-944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648377#comment-15648377 ] Kenneth Knowles edited comment on BEAM-944 at 11/8/16 6:32 PM: --- I think we

[jira] [Commented] (BEAM-944) Spark runner causes an exception when creating pipeline options

[ https://issues.apache.org/jira/browse/BEAM-944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15648377#comment-15648377 ] Kenneth Knowles commented on BEAM-944: -- Thoughts: # I agree that we should move away from putting

[jira] [Comment Edited] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646524#comment-15646524 ] Kenneth Knowles edited comment on BEAM-912 at 11/8/16 5:11 AM: --- Very good

[jira] [Comment Edited] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646524#comment-15646524 ] Kenneth Knowles edited comment on BEAM-912 at 11/8/16 5:11 AM: --- Very good

[jira] [Updated] (BEAM-912) Range join in Beam

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-912: - Summary: Range join in Beam (was: Trigger can be more flexible) > Range join in B

[jira] [Commented] (BEAM-912) Trigger can be more flexible

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646524#comment-15646524 ] Kenneth Knowles commented on BEAM-912: -- Very good point. My idea does not work for you. Actually

[jira] [Created] (BEAM-942) Gearpump test configuration should exclude merging window tests

Kenneth Knowles created BEAM-942: Summary: Gearpump test configuration should exclude merging window tests Key: BEAM-942 URL: https://issues.apache.org/jira/browse/BEAM-942 Project: Beam

[jira] [Created] (BEAM-941) Replace Xyz.INSTANCE throughout the SDK with either static methods or XyzFactory.default()

Kenneth Knowles created BEAM-941: Summary: Replace Xyz.INSTANCE throughout the SDK with either static methods or XyzFactory.default() Key: BEAM-941 URL: https://issues.apache.org/jira/browse/BEAM-941

[jira] [Created] (BEAM-940) OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod

Kenneth Knowles created BEAM-940: Summary: OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod Key: BEAM-940 URL: https://issues.apache.org/jira/browse/BEAM-940 Project: Beam

[jira] [Commented] (BEAM-936) @DefaultCoder(MyCoder.class) should work if MyCoder has .of()

[ https://issues.apache.org/jira/browse/BEAM-936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645690#comment-15645690 ] Kenneth Knowles commented on BEAM-936: -- Best first step would be to match all the other APIs

[jira] [Commented] (BEAM-936) @DefaultCoder(MyCoder.class) should work if MyCoder has a .of(), .create(), or a zero-args constructor

[ https://issues.apache.org/jira/browse/BEAM-936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645687#comment-15645687 ] Kenneth Knowles commented on BEAM-936: -- I don't know that we have to aggressively match all

[jira] [Updated] (BEAM-936) @DefaultCoder(MyCoder.class) should work if MyCoder has .of()

[ https://issues.apache.org/jira/browse/BEAM-936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-936: - Summary: @DefaultCoder(MyCoder.class) should work if MyCoder has .of() (was: @DefaultCoder

[jira] [Commented] (BEAM-912) Trigger can be more flexible

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645242#comment-15645242 ] Kenneth Knowles commented on BEAM-912: -- Thank you for the drawing, it helps me to understand what you

[jira] [Updated] (BEAM-404) PubsubIO should have a mode that supports maintaining message attributes.

[ https://issues.apache.org/jira/browse/BEAM-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-404: - Issue Type: New Feature (was: Bug) > PubsubIO should have a mode that supports maintaining mess

[jira] [Updated] (BEAM-694) Add TriggerTester methods to check that timers are set

[ https://issues.apache.org/jira/browse/BEAM-694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-694: - Description: TriggerTester exposes a {{fireIfShouldFire(BoundedWIndow)}} method. This is used

[jira] [Updated] (BEAM-694) Add TriggerTester methods to check that timers are set

[ https://issues.apache.org/jira/browse/BEAM-694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-694: - Summary: Add TriggerTester methods to check that timers are set (was: TriggerTester doesn't test

[jira] [Commented] (BEAM-694) TriggerTester doesn't test timer firings

[ https://issues.apache.org/jira/browse/BEAM-694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15637215#comment-15637215 ] Kenneth Knowles commented on BEAM-694: -- +1 Triggers set timers, but do not receive callbacks

[jira] [Updated] (BEAM-694) TriggerTester doesn't test timer firings

[ https://issues.apache.org/jira/browse/BEAM-694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-694: - Priority: Minor (was: Major) > TriggerTester doesn't test timer firi

[jira] [Updated] (BEAM-694) TriggerTester doesn't test timer firings

[ https://issues.apache.org/jira/browse/BEAM-694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-694: - Component/s: runner-core > TriggerTester doesn't test timer firi

[jira] [Updated] (BEAM-694) TriggerTester doesn't test timer firings

[ https://issues.apache.org/jira/browse/BEAM-694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-694: - Labels: easy starter (was: ) > TriggerTester doesn't test timer firi

[jira] [Resolved] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

[ https://issues.apache.org/jira/browse/BEAM-742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-742. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Move trigger state machines to runn

[jira] [Updated] (BEAM-766) Trigger AST should use @AutoValue

[ https://issues.apache.org/jira/browse/BEAM-766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-766: - Labels: easy starter (was: ) > Trigger AST should use @AutoVa

[jira] [Updated] (BEAM-766) Trigger AST should use @AutoValue

[ https://issues.apache.org/jira/browse/BEAM-766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-766: - Assignee: (was: Kenneth Knowles) > Trigger AST should use @AutoVa

[jira] [Updated] (BEAM-101) Data-driven triggers

[ https://issues.apache.org/jira/browse/BEAM-101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-101: - Summary: Data-driven triggers (was: Support data-driven triggers) > Data-driven trigg

[jira] [Comment Edited] (BEAM-912) Trigger can be more flexible

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15637198#comment-15637198 ] Kenneth Knowles edited comment on BEAM-912 at 11/4/16 6:06 PM: --- Hello! Your

[jira] [Assigned] (BEAM-912) Trigger can be more flexible

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-912: Assignee: Kenneth Knowles (was: Frances Perry) > Trigger can be more flexi

[jira] [Commented] (BEAM-912) Trigger can be more flexible

[ https://issues.apache.org/jira/browse/BEAM-912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15637198#comment-15637198 ] Kenneth Knowles commented on BEAM-912: -- Hello! Your example does not actually seem to include triggers

[jira] [Updated] (BEAM-101) Support data-driven triggers

[ https://issues.apache.org/jira/browse/BEAM-101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-101: - Description: For some applications, it's useful to declare a pane/window to be emitted

[jira] [Created] (BEAM-910) Always explicitly specify --output for ITs

Kenneth Knowles created BEAM-910: Summary: Always explicitly specify --output for ITs Key: BEAM-910 URL: https://issues.apache.org/jira/browse/BEAM-910 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-908) Update wordcount walkthrough after PR #1275

Kenneth Knowles created BEAM-908: Summary: Update wordcount walkthrough after PR #1275 Key: BEAM-908 URL: https://issues.apache.org/jira/browse/BEAM-908 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-638: - Summary: Add sink transform to write bounded data per window, pane, [and key] even when PCollection

[jira] [Updated] (BEAM-878) Allow usage of ApiSurfaceTest providing nothing but a whitelist

[ https://issues.apache.org/jira/browse/BEAM-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-878: - Labels: easy easyfix newbie starter (was: ) > Allow usage of ApiSurfaceTest providing noth

[jira] [Updated] (BEAM-878) Allow usage of ApiSurfaceTest providing nothing but a whitelist

[ https://issues.apache.org/jira/browse/BEAM-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-878: - Description: {{ApiSurfaceTest}} in the {{sdks/java/core}} is the class responsible for protecting

[jira] [Updated] (BEAM-878) Allow usage of ApiSurfaceTest providing nothing but a whitelist

[ https://issues.apache.org/jira/browse/BEAM-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-878: - Summary: Allow usage of ApiSurfaceTest providing nothing but a whitelist (was: ApiSurfaceTest

[jira] [Updated] (BEAM-882) Make ApiSurfaceTest detect the java package/module under test

[ https://issues.apache.org/jira/browse/BEAM-882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-882: - Priority: Trivial (was: Major) > Make ApiSurfaceTest detect the java package/module under t

[jira] [Updated] (BEAM-878) Allow usage of ApiSurfaceTest providing nothing but a whitelist

[ https://issues.apache.org/jira/browse/BEAM-878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-878: - Priority: Minor (was: Major) > Allow usage of ApiSurfaceTest providing nothing but a whitel

[jira] [Updated] (BEAM-883) Make ApiSurfaceTest fail if something whitelisted is _not_ exposed

[ https://issues.apache.org/jira/browse/BEAM-883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-883: - Labels: easy easyfix newbie starter (was: ) > Make ApiSurfaceTest fail if something whitelis

[jira] [Updated] (BEAM-883) Make ApiSurfaceTest fail if something whitelisted is _not_ exposed

[ https://issues.apache.org/jira/browse/BEAM-883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-883: - Description: {{ApiSurfaceTest}} in the {{sdks/java/core}} is the class responsible for protecting

[jira] [Updated] (BEAM-882) Make ApiSurfaceTest detect the java package/module under test

[ https://issues.apache.org/jira/browse/BEAM-882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-882: - Labels: easy easyfix newbie starter (was: ) > Make ApiSurfaceTest detect the java package/mod

[jira] [Updated] (BEAM-883) Make ApiSurfaceTest fail if something whitelisted is _not_ exposed

[ https://issues.apache.org/jira/browse/BEAM-883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-883: - Priority: Minor (was: Major) > Make ApiSurfaceTest fail if something whitelisted is _not_ expo

[jira] [Updated] (BEAM-882) Make ApiSurfaceTest detect the java package/module under test

[ https://issues.apache.org/jira/browse/BEAM-882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-882: - Description: {{ApiSurfaceTest}} in the {{sdks/java/core}} is the class responsible for protecting

[jira] [Created] (BEAM-882) Make ApiSurfaceTest detect the java package/module under test

Kenneth Knowles created BEAM-882: Summary: Make ApiSurfaceTest detect the java package/module under test Key: BEAM-882 URL: https://issues.apache.org/jira/browse/BEAM-882 Project: Beam

<    1   2   3   4   5   >