[jira] [Commented] (BEAM-1176) Make our test suites use @Rule TestPipeline

[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764778#comment-15764778 ] Luke Cwik commented on BEAM-1176: - I took a look at AvroIOGeneratedClassTest, ApproximateUniqueTest

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

[ https://issues.apache.org/jira/browse/BEAM-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764746#comment-15764746 ] ASF GitHub Bot commented on BEAM-362: - GitHub user kennknowles opened a pull request: https

[jira] [Commented] (BEAM-1176) Make our test suites use @Rule TestPipeline

[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764731#comment-15764731 ] ASF GitHub Bot commented on BEAM-1176: -- GitHub user staslev opened a pull request: https

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764476#comment-15764476 ] ASF GitHub Bot commented on BEAM-79: Github user manuzhang closed the pull request at: https

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15764357#comment-15764357 ] ASF GitHub Bot commented on BEAM-79: GitHub user manuzhang opened a pull request: https://github.com

[jira] [Comment Edited] (BEAM-1176) Make our test suites use @Rule TestPipeline

[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763964#comment-15763964 ] Stas Levin edited comment on BEAM-1176 at 12/20/16 11:20 AM: - I've started

[jira] [Commented] (BEAM-1176) Make our test suites use @Rule TestPipeline

[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763964#comment-15763964 ] Stas Levin commented on BEAM-1176: -- I've started migrating the tests to using the {{TestPipeline

[jira] [Comment Edited] (BEAM-1176) Make our test suites use @Rule TestPipeline

[ https://issues.apache.org/jira/browse/BEAM-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763964#comment-15763964 ] Stas Levin edited comment on BEAM-1176 at 12/20/16 11:18 AM: - I've started

[jira] [Assigned] (BEAM-1184) Add integration tests for ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot reassigned BEAM-1184: -- Assignee: Etienne Chauchot (was: Stephen Sisk) > Add integration te

[jira] [Commented] (BEAM-1101) Remove inconsistencies in Python PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763421#comment-15763421 ] ASF GitHub Bot commented on BEAM-1101: -- Github user pabloem closed the pull request at: https

[jira] [Commented] (BEAM-1101) Remove inconsistencies in Python PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763422#comment-15763422 ] ASF GitHub Bot commented on BEAM-1101: -- GitHub user pabloem reopened a pull request: https

[jira] [Commented] (BEAM-1180) Implement GearpumpPipelineResult

[ https://issues.apache.org/jira/browse/BEAM-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15763017#comment-15763017 ] ASF GitHub Bot commented on BEAM-1180: -- GitHub user manuzhang opened a pull request: https

[jira] [Updated] (BEAM-1184) Add integration tests for ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-1184: --- Assignee: Stephen Sisk (was: Davor Bonaci) > Add integration tests for Elasticsearc

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

[ https://issues.apache.org/jira/browse/BEAM-1089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762985#comment-15762985 ] Jason Kuster commented on BEAM-1089: Example of a PR with a lot of spam: https://github.com/apache

[jira] [Commented] (BEAM-1131) Consider japicmp for testing backwards-compatibility

[ https://issues.apache.org/jira/browse/BEAM-1131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762982#comment-15762982 ] Jason Kuster commented on BEAM-1131: Repo here: https://siom79.github.io/japicmp/ > Consider japi

[jira] [Created] (BEAM-1185) Remove the word Pipeline from the name of all PipelineRunner implementations

Ahmet Altay created BEAM-1185: - Summary: Remove the word Pipeline from the name of all PipelineRunner implementations Key: BEAM-1185 URL: https://issues.apache.org/jira/browse/BEAM-1185 Project: Beam

[jira] [Updated] (BEAM-1184) Add integration tests for ElasticsearchIO

[ https://issues.apache.org/jira/browse/BEAM-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk updated BEAM-1184: --- Issue Type: Test (was: Bug) > Add integration tests for Elasticsearc

[jira] [Created] (BEAM-1184) Add integration tests for ElasticsearchIO

Stephen Sisk created BEAM-1184: -- Summary: Add integration tests for ElasticsearchIO Key: BEAM-1184 URL: https://issues.apache.org/jira/browse/BEAM-1184 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762641#comment-15762641 ] ASF GitHub Bot commented on BEAM-59: Github user asfgit closed the pull request at: https

[jira] [Created] (BEAM-1183) oauth2 client logger warning

Ahmet Altay created BEAM-1183: - Summary: oauth2 client logger warning Key: BEAM-1183 URL: https://issues.apache.org/jira/browse/BEAM-1183 Project: Beam Issue Type: Bug Components: sdk

[jira] [Commented] (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:comment-tabpanel=15762533#comment-15762533 ] ASF GitHub Bot commented on BEAM-27: GitHub user kennknowles opened a pull request: https

[jira] [Created] (BEAM-1182) Direct runner should enforce encodability of unbounded source checkpoints

Eugene Kirpichov created BEAM-1182: -- Summary: Direct runner should enforce encodability of unbounded source checkpoints Key: BEAM-1182 URL: https://issues.apache.org/jira/browse/BEAM-1182 Project

[jira] [Commented] (BEAM-1181) Investigate: does BigQueryIO honor write disposition in all cases?

[ https://issues.apache.org/jira/browse/BEAM-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762278#comment-15762278 ] Daniel Halperin commented on BEAM-1181: --- [~pei...@gmail.com] can you please take a look, when you get

[jira] [Created] (BEAM-1181) Investigate: does BigQueryIO honor write disposition in all cases?

Daniel Halperin created BEAM-1181: - Summary: Investigate: does BigQueryIO honor write disposition in all cases? Key: BEAM-1181 URL: https://issues.apache.org/jira/browse/BEAM-1181 Project: Beam

[jira] [Closed] (BEAM-1178) Make naming of logger objects consistent

[ https://issues.apache.org/jira/browse/BEAM-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-1178. -- Resolution: Fixed Fix Version/s: Not applicable > Make naming of logger objects consist

[jira] [Commented] (BEAM-1143) Timestamps on Jenkins log lines

[ https://issues.apache.org/jira/browse/BEAM-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762129#comment-15762129 ] ASF GitHub Bot commented on BEAM-1143: -- Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-1143) Timestamps on Jenkins log lines

[ https://issues.apache.org/jira/browse/BEAM-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762107#comment-15762107 ] ASF GitHub Bot commented on BEAM-1143: -- GitHub user kennknowles opened a pull request: https

[jira] [Commented] (BEAM-1143) Timestamps on Jenkins log lines

[ https://issues.apache.org/jira/browse/BEAM-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15762042#comment-15762042 ] ASF GitHub Bot commented on BEAM-1143: -- Github user asfgit closed the pull request at: https

[jira] [Updated] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample is be flaky

[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1067: -- Summary: apex.examples.WordCountTest.testWordCountExample is be flaky

[jira] [Commented] (BEAM-841) Releases should produce proper MD5/SHA1 checksums

[ https://issues.apache.org/jira/browse/BEAM-841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15761711#comment-15761711 ] ASF GitHub Bot commented on BEAM-841: - Github user wikier closed the pull request at: https

[jira] [Closed] (BEAM-1165) Unexpected file created when checking dependencies on clean repo

[ https://issues.apache.org/jira/browse/BEAM-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-1165. -- Resolution: Fixed Fix Version/s: 0.5.0-incubating > Unexpected file created when check

[jira] [Commented] (BEAM-1165) Unexpected file created when checking dependencies on clean repo

[ https://issues.apache.org/jira/browse/BEAM-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760886#comment-15760886 ] ASF GitHub Bot commented on BEAM-1165: -- Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-480) Use BigQueryServices abstraction in BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760579#comment-15760579 ] ASF GitHub Bot commented on BEAM-480: - Github user peihe closed the pull request at: https

[jira] [Commented] (BEAM-1146) Decrease spark runner startup overhead

[ https://issues.apache.org/jira/browse/BEAM-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760560#comment-15760560 ] Amit Sela commented on BEAM-1146: - As for {{Spark}} and {{Kryo}} - we can't change Spark dependencies

[jira] [Created] (BEAM-1180) Implement GearpumpPipelineResult

Manu Zhang created BEAM-1180: Summary: Implement GearpumpPipelineResult Key: BEAM-1180 URL: https://issues.apache.org/jira/browse/BEAM-1180 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-841) Releases should produce proper MD5/SHA1 checksums

[ https://issues.apache.org/jira/browse/BEAM-841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760315#comment-15760315 ] Jean-Baptiste Onofré commented on BEAM-841: --- We use the gpg sign from the Apache POM: http

[jira] [Resolved] (BEAM-1162) Create RedisIO

[ https://issues.apache.org/jira/browse/BEAM-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-1162. Resolution: Duplicate Fix Version/s: Not applicable > Create Redi

[jira] [Updated] (BEAM-440) Create.values() returns a type-unsafe Coder

[ https://issues.apache.org/jira/browse/BEAM-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-440: - Assignee: Jason White > Create.values() returns a type-unsafe Co

[jira] [Commented] (BEAM-440) Create.values() returns a type-unsafe Coder

[ https://issues.apache.org/jira/browse/BEAM-440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760233#comment-15760233 ] Kenneth Knowles commented on BEAM-440: -- The root issue here is actually worse. There are two facets. 1

[jira] [Updated] (BEAM-440) Create.values() returns a type-unsafe Coder

[ https://issues.apache.org/jira/browse/BEAM-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-440: - Description: {{Create.values()}} with no arguments will default to a {{VoidCoder}}, unless one

[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: - Component/s: (was: runner-core) sdk-java-core beam-model

[jira] [Updated] (BEAM-885) Move PipelineOptions from Pipeline.create() to Pipeline.run()

[ https://issues.apache.org/jira/browse/BEAM-885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-885: - Component/s: beam-model-runner-api > Move PipelineOptions from Pipeline.create() to Pipeline.

[jira] [Updated] (BEAM-646) Get runners out of the apply()

[ https://issues.apache.org/jira/browse/BEAM-646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-646: - Component/s: beam-model-runner-api > Get runners out of the ap

[jira] [Updated] (BEAM-260) Know the getSideInputWindow upper bound so can gc side input state

[ https://issues.apache.org/jira/browse/BEAM-260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-260: - Component/s: beam-model-runner-api > Know the getSideInputWindow upper bound so can gc side in

[jira] [Updated] (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 updated BEAM-742: - Component/s: beam-model-runner-api > Move trigger state machines to runners-core, convert trigg

[jira] [Updated] (BEAM-846) Decouple side input window mapping from WindowFn

[ https://issues.apache.org/jira/browse/BEAM-846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-846: - Component/s: beam-model-runner-api > Decouple side input window mapping from Windo

[jira] [Commented] (BEAM-1159) DoFnSignature should have info on the fn's side inputs and outputs

[ https://issues.apache.org/jira/browse/BEAM-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760080#comment-15760080 ] Kenneth Knowles commented on BEAM-1159: --- The expected resolution of this ticket was actually designed

[jira] [Resolved] (BEAM-1149) Side input access fails in direct runner (possibly others too) when input element in multiple windows

[ https://issues.apache.org/jira/browse/BEAM-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1149. --- Resolution: Fixed > Side input access fails in direct runner (possibly others too) when in

[jira] [Commented] (BEAM-1164) Allow a DoFn to opt in to mutating it's input

[ https://issues.apache.org/jira/browse/BEAM-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15760074#comment-15760074 ] Kenneth Knowles commented on BEAM-1164: --- I think with the new {{DoFn}} there is a fairly elegant

[jira] [Created] (BEAM-1179) Update assertions of source_test_utils from camelcase to underscore-separated

Chamikara Jayalath created BEAM-1179: Summary: Update assertions of source_test_utils from camelcase to underscore-separated Key: BEAM-1179 URL: https://issues.apache.org/jira/browse/BEAM-1179

[jira] [Commented] (BEAM-1178) Make naming of logger objects consistent

[ https://issues.apache.org/jira/browse/BEAM-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15759358#comment-15759358 ] ASF GitHub Bot commented on BEAM-1178: -- GitHub user iemejia opened a pull request: https

[jira] [Created] (BEAM-1178) Make naming of logger objects consistent

Ismaël Mejía created BEAM-1178: -- Summary: Make naming of logger objects consistent Key: BEAM-1178 URL: https://issues.apache.org/jira/browse/BEAM-1178 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-1177) Input DStream "bundles" should be in serialized form and include relevant metadata.

[ https://issues.apache.org/jira/browse/BEAM-1177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15758852#comment-15758852 ] Amit Sela commented on BEAM-1177: - Instead of simply emitting {{Iterable<byte[]>}} per partition, I'l

[jira] [Updated] (BEAM-1177) Input DStream "bundles" should be in serialized form and include relevant metadata.

[ https://issues.apache.org/jira/browse/BEAM-1177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-1177: Description: Currently, the input partitions hold "bundles" of read eleme

[jira] [Created] (BEAM-1177) Input DStream "bundles" should be in serialized form and include relevant metadata.

Amit Sela created BEAM-1177: --- Summary: Input DStream "bundles" should be in serialized form and include relevant metadata. Key: BEAM-1177 URL: https://issues.apache.org/jira/browse/BEAM-1177 Pro

[jira] [Updated] (BEAM-848) A better shuffle after reading from within mapWithState.

[ https://issues.apache.org/jira/browse/BEAM-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-848: --- Summary: A better shuffle after reading from within mapWithState. (was: Make post-read (unbounded) shuffle use

[jira] [Commented] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded.

[ https://issues.apache.org/jira/browse/BEAM-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15758766#comment-15758766 ] ASF GitHub Bot commented on BEAM-1074: -- Github user amitsela closed the pull request at: https

[jira] [Commented] (BEAM-1126) Expose UnboundedSource split backlog in number of events

[ https://issues.apache.org/jira/browse/BEAM-1126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15758431#comment-15758431 ] ASF GitHub Bot commented on BEAM-1126: -- Github user aviemzur closed the pull request at: https

[jira] [Updated] (BEAM-651) 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 updated BEAM-651: - Summary: Making TypedPValue.setTypeDescriptorInternal no longer Internal (was: Consider making

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

[ https://issues.apache.org/jira/browse/BEAM-651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-651: - Summary: Add public TypedPValue.setTypeDescriptor (was: Making

[jira] [Updated] (BEAM-35) Remove timer multiplexing and give timers identifiers

[ https://issues.apache.org/jira/browse/BEAM-35?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-35: Issue Type: Improvement (was: New Feature) > Remove timer multiplexing and give timers identifi

[jira] [Updated] (BEAM-864) RAT check fails on DEPENDENCIES

[ https://issues.apache.org/jira/browse/BEAM-864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-864: - Summary: RAT check fails on DEPENDENCIES (was: Update to latest Apache Maven-Parent) > RAT ch

[jira] [Updated] (BEAM-808) Increase "spark.port.maxRetries" to avoid BindException in ROS.

[ https://issues.apache.org/jira/browse/BEAM-808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-808: - Issue Type: Bug (was: Improvement) > Increase "spark.port.maxRetries" to avoid

[jira] [Updated] (BEAM-830) Launcher for ApexRunner execution on YARN cluster

[ https://issues.apache.org/jira/browse/BEAM-830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-830: - Issue Type: New Feature (was: Improvement) > Launcher for ApexRunner execution on YARN clus

[jira] [Updated] (BEAM-1060) Make DoFnTester use new DoFn

[ https://issues.apache.org/jira/browse/BEAM-1060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1060: -- Issue Type: New Feature (was: Improvement) > Make DoFnTester use new D

[jira] [Updated] (BEAM-252) Make Regex Transform

[ https://issues.apache.org/jira/browse/BEAM-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-252: - Issue Type: New Feature (was: Improvement) > Make Regex Transf

[jira] [Updated] (BEAM-1060) Make DoFnTester use new DoFn

[ https://issues.apache.org/jira/browse/BEAM-1060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1060: -- Issue Type: Improvement (was: New Feature) > Make DoFnTester use new D

[jira] [Updated] (BEAM-939) New credentials code broke Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-939: - Issue Type: Bug (was: New Feature) > New credentials code broke Dataflow run

[jira] [Updated] (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 updated BEAM-651: - Issue Type: New Feature (was: Wish) > Consider making TypedPValue.setTypeDescriptorInter

[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: - Issue Type: Bug (was: New Feature) > WindowedWordCountIT fails due to not setting "

[jira] [Updated] (BEAM-261) Apache Apex Runner

[ https://issues.apache.org/jira/browse/BEAM-261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-261: - Issue Type: New Feature (was: Wish) > Apache Apex Run

[jira] [Created] (BEAM-1176) Make our test suites use @Rule TestPipeline

Kenneth Knowles created BEAM-1176: - Summary: Make our test suites use @Rule TestPipeline Key: BEAM-1176 URL: https://issues.apache.org/jira/browse/BEAM-1176 Project: Beam Issue Type

[jira] [Resolved] (BEAM-85) PAssert needs sanity check that it's used correctly

[ https://issues.apache.org/jira/browse/BEAM-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-85. - Resolution: Fixed Fix Version/s: 0.5.0-incubating When used as a `@Rule` this is now the case

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

[ https://issues.apache.org/jira/browse/BEAM-85?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15757718#comment-15757718 ] ASF GitHub Bot commented on BEAM-85: Github user asfgit closed the pull request at: https

[jira] [Commented] (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:comment-tabpanel=15757625#comment-15757625 ] ASF GitHub Bot commented on BEAM-27: Github user asfgit closed the pull request at: https

[jira] [Resolved] (BEAM-853) Force streaming execution on batch pipelines for testing.

[ https://issues.apache.org/jira/browse/BEAM-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-853. Resolution: Fixed Fix Version/s: 0.5.0-incubating > Force streaming execution on batch pipeli

[jira] [Commented] (BEAM-545) Pipelines and their executions naming changes

[ https://issues.apache.org/jira/browse/BEAM-545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15756581#comment-15756581 ] ASF GitHub Bot commented on BEAM-545: - GitHub user dhalperi opened a pull request: https

[jira] [Created] (BEAM-1175) Separate runners-core Javadoc from SDK Javadoc, and perhaps other artifacts

Kenneth Knowles created BEAM-1175: - Summary: Separate runners-core Javadoc from SDK Javadoc, and perhaps other artifacts Key: BEAM-1175 URL: https://issues.apache.org/jira/browse/BEAM-1175 Project

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

[ https://issues.apache.org/jira/browse/BEAM-498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15756230#comment-15756230 ] ASF GitHub Bot commented on BEAM-498: - Github user asfgit closed the pull request at: https

[jira] [Issue Comment Deleted] (BEAM-975) Issue with MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza Nouri updated BEAM-975: Comment: was deleted (was: Retry cannot be a solution since this issue kills mongo process. ) > Is

[jira] [Commented] (BEAM-975) Issue with MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15756214#comment-15756214 ] Reza Nouri commented on BEAM-975: - Retry cannot be a solution since this issue kills mongo process

[jira] [Commented] (BEAM-975) Issue with MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15756213#comment-15756213 ] Reza Nouri commented on BEAM-975: - Retry cannot be a solution since this issue kills mongo process

[jira] [Commented] (BEAM-475) High-quality javadoc for Beam

[ https://issues.apache.org/jira/browse/BEAM-475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15756032#comment-15756032 ] ASF GitHub Bot commented on BEAM-475: - Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-475) High-quality javadoc for Beam

[ https://issues.apache.org/jira/browse/BEAM-475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755901#comment-15755901 ] ASF GitHub Bot commented on BEAM-475: - GitHub user dhalperi opened a pull request: https

[jira] [Created] (BEAM-1174) URI Java library unexpected behavior.

Pei He created BEAM-1174: Summary: URI Java library unexpected behavior. Key: BEAM-1174 URL: https://issues.apache.org/jira/browse/BEAM-1174 Project: Beam Issue Type: Sub-task Reporter

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

[ https://issues.apache.org/jira/browse/BEAM-498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755809#comment-15755809 ] ASF GitHub Bot commented on BEAM-498: - GitHub user jkff opened a pull request: https://github.com

[jira] [Created] (BEAM-1173) TestSparkRunner should use a PipelineVisitor to determine expected assertions.

Amit Sela created BEAM-1173: --- Summary: TestSparkRunner should use a PipelineVisitor to determine expected assertions. Key: BEAM-1173 URL: https://issues.apache.org/jira/browse/BEAM-1173 Project: Beam

[jira] [Created] (BEAM-1172) Precommit integration tests should include some merging windows

Kenneth Knowles created BEAM-1172: - Summary: Precommit integration tests should include some merging windows Key: BEAM-1172 URL: https://issues.apache.org/jira/browse/BEAM-1172 Project: Beam

[jira] [Updated] (BEAM-318) AvroCoder may be affected by AVRO-607

[ https://issues.apache.org/jira/browse/BEAM-318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-318: - Assignee: (was: Daniel Halperin) > AvroCoder may be affected by AVRO-

[jira] [Commented] (BEAM-646) Get runners out of the apply()

[ https://issues.apache.org/jira/browse/BEAM-646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755666#comment-15755666 ] ASF GitHub Bot commented on BEAM-646: - Github user asfgit closed the pull request at: https

[jira] [Updated] (BEAM-1139) Investigate failures in precommit - Apex & Kryo

[ https://issues.apache.org/jira/browse/BEAM-1139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1139: -- Assignee: (was: Kenneth Knowles) > Investigate failures in precommit - Apex &am

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

[ https://issues.apache.org/jira/browse/BEAM-1089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755653#comment-15755653 ] ASF GitHub Bot commented on BEAM-1089: -- GitHub user kennknowles opened a pull request: https

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

[ https://issues.apache.org/jira/browse/BEAM-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755649#comment-15755649 ] ASF GitHub Bot commented on BEAM-362: - Github user asfgit closed the pull request at: https

[jira] [Updated] (BEAM-1170) Streaming watermark should be easier to read

[ https://issues.apache.org/jira/browse/BEAM-1170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers updated BEAM-1170: --- Component/s: runner-dataflow > Streaming watermark should be easier to r

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

[ https://issues.apache.org/jira/browse/BEAM-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755599#comment-15755599 ] ASF GitHub Bot commented on BEAM-362: - Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-1040) Hadoop InputFormat - IO Transform for reads

[ https://issues.apache.org/jira/browse/BEAM-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755524#comment-15755524 ] Stephen Sisk commented on BEAM-1040: Work is in progress on this. Hoping to have another update mid

[jira] [Created] (BEAM-1171) Source.getDefaultOutputCoder() - add a version that allows access to a CoderRegistry

Stephen Sisk created BEAM-1171: -- Summary: Source.getDefaultOutputCoder() - add a version that allows access to a CoderRegistry Key: BEAM-1171 URL: https://issues.apache.org/jira/browse/BEAM-1171 Project

[jira] [Created] (BEAM-1170) Streaming watermark should be easier to read

Joshua Litt created BEAM-1170: - Summary: Streaming watermark should be easier to read Key: BEAM-1170 URL: https://issues.apache.org/jira/browse/BEAM-1170 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-1108) Remove deprecated Dataflow Runner options and update documentation

[ https://issues.apache.org/jira/browse/BEAM-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755477#comment-15755477 ] ASF GitHub Bot commented on BEAM-1108: -- Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-1169) MetricsTest matchers should loosen expectations on physical values

[ https://issues.apache.org/jira/browse/BEAM-1169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15755377#comment-15755377 ] Ben Chambers commented on BEAM-1169: Alternatively, we may need the Runner to define how Metrics

<    1   2   3   4   5   6   7   8   9   10   >