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

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

[jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky

[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716750#comment-15716750 ] Stas Levin commented on BEAM-1067: -- Not sure

[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=15716726#comment-15716726 ] ASF GitHub Bot commented on BEAM-646: - GitHub user tgroh opened a pull request: https://github.com

[jira] [Commented] (BEAM-485) Can't set Flink runner in code

[ https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716711#comment-15716711 ] Emanuele Cesena commented on BEAM-485: -- I didn’t really had the chance to try, but if it’s resolved, I

[jira] [Created] (BEAM-1080) python sdk apiclient needs proper unit tests

Vikas Kedigehalli created BEAM-1080: --- Summary: python sdk apiclient needs proper unit tests Key: BEAM-1080 URL: https://issues.apache.org/jira/browse/BEAM-1080 Project: Beam Issue Type

[jira] [Updated] (BEAM-1079) Validation speed for really large number of files

[ https://issues.apache.org/jira/browse/BEAM-1079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sourabh Bajaj updated BEAM-1079: Description: Filebased source during validation at pipeline creation does a full glob when it only

[jira] [Commented] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings

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

[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=15716663#comment-15716663 ] ASF GitHub Bot commented on BEAM-646: - Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-1077) @ValidatesRunner test in Python postcommit

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

[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=15716648#comment-15716648 ] ASF GitHub Bot commented on BEAM-646: - Github user asfgit closed the pull request at: https

[jira] [Commented] (BEAM-1070) Service Account Based Authentication Broken

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

[jira] [Created] (BEAM-1079) Validation speed for really large number of files

Sourabh Bajaj created BEAM-1079: --- Summary: Validation speed for really large number of files Key: BEAM-1079 URL: https://issues.apache.org/jira/browse/BEAM-1079 Project: Beam Issue Type

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

[jira] [Commented] (BEAM-580) Add a Datastore delete example

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

[jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky

[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716244#comment-15716244 ] Thomas Weise commented on BEAM-1067: Looks like the file isn't flushed to disk although the pipeline

[jira] [Commented] (BEAM-246) Streamline default Maven profile for user efficiency

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

[jira] [Updated] (BEAM-641) Need to test the generated archetypes projects

[ https://issues.apache.org/jira/browse/BEAM-641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-641: - Priority: Major (was: Critical) > Need to test the generated archetypes proje

[jira] [Updated] (BEAM-682) Invoker Class should be created in Thread Context Classloader

[ https://issues.apache.org/jira/browse/BEAM-682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-682: - Priority: Major (was: Critical) > Invoker Class should be created in Thread Context Classloa

[jira] [Resolved] (BEAM-555) Documentation in BiqQueryIO.java has awkward cut-and-paste error.

[ https://issues.apache.org/jira/browse/BEAM-555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-555. -- Resolution: Fixed Assignee: Frank Yellin (was: Neelesh Srinivas Salian) Fix

[jira] [Updated] (BEAM-555) Documentation in BiqQueryIO.java has awkward cut-and-paste error.

[ https://issues.apache.org/jira/browse/BEAM-555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-555: - Assignee: Neelesh Srinivas Salian (was: Frank Yellin) > Documentation in BiqQueryIO.java

[jira] [Updated] (BEAM-551) Support Dynamic PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-551: - Assignee: Sam McVeety (was: Frances Perry) > Support Dynamic PipelineOpti

[jira] [Resolved] (BEAM-1031) Starter archetype uses OldDoFn

[ https://issues.apache.org/jira/browse/BEAM-1031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1031. --- Resolution: Fixed Fix Version/s: Not applicable > Starter archetype uses OldD

[jira] [Resolved] (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 ] Daniel Halperin resolved BEAM-939. -- Resolution: Fixed > New credentials code broke Dataflow run

[jira] [Resolved] (BEAM-857) Add documentation for configuring Checkstyle-IDEA

[ https://issues.apache.org/jira/browse/BEAM-857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-857. -- Resolution: Fixed Fix Version/s: Not applicable > Add documentation for configur

[jira] [Updated] (BEAM-857) Add documentation for configuring Checkstyle-IDEA

[ https://issues.apache.org/jira/browse/BEAM-857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-857: - Summary: Add documentation for configuring Checkstyle-IDEA (was: Beam's checkstyle.xml broken

[jira] [Updated] (BEAM-351) Add DisplayData to KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-351: - Issue Type: Improvement (was: Bug) > Add DisplayData to Kafk

[jira] [Updated] (BEAM-351) Add DisplayData to KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-351: - Assignee: (was: James Malone) > Add DisplayData to Kafk

[jira] [Closed] (BEAM-1044) tests run before install fails

[ https://issues.apache.org/jira/browse/BEAM-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay closed BEAM-1044. - Resolution: Fixed Fix Version/s: Not applicable > tests run before install fa

[jira] [Updated] (BEAM-246) Streamline default Maven profile for user efficiency

[ https://issues.apache.org/jira/browse/BEAM-246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-246: - Summary: Streamline default Maven profile for user efficiency (was: Do not build source jar

[jira] [Resolved] (BEAM-993) Python SDK build broken due to datastore dependency

[ https://issues.apache.org/jira/browse/BEAM-993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Kedigehalli resolved BEAM-993. Resolution: Fixed Fix Version/s: Not applicable > Python SDK build broken

[jira] [Commented] (BEAM-1044) tests run before install fails

[ https://issues.apache.org/jira/browse/BEAM-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716158#comment-15716158 ] Vikas Kedigehalli commented on BEAM-1044: - A new googledatastore release fixes this issue. https

[jira] [Commented] (BEAM-246) Do not build source jar, javadoc, in default Maven profile.

[ https://issues.apache.org/jira/browse/BEAM-246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716160#comment-15716160 ] Daniel Halperin commented on BEAM-246: -- Implemented over a few weeks in https://github.com/apache

[jira] [Resolved] (BEAM-246) Do not build source jar, javadoc, in default Maven profile.

[ https://issues.apache.org/jira/browse/BEAM-246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-246. -- Resolution: Fixed Assignee: Daniel Halperin Fix Version/s: 0.4.0-incubating >

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

[ https://issues.apache.org/jira/browse/BEAM-480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-480. -- Resolution: Fixed Fix Version/s: Not applicable > Use BigQueryServices abstract

[jira] [Resolved] (BEAM-580) Add a Datastore delete example

[ https://issues.apache.org/jira/browse/BEAM-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-580. -- Resolution: Duplicate Fix Version/s: Not applicable > Add a Datastore delete exam

[jira] [Commented] (BEAM-989) GcsUtil batch remove() and copy() need tests.

[ https://issues.apache.org/jira/browse/BEAM-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716143#comment-15716143 ] Daniel Halperin commented on BEAM-989: -- There was a pretty long discussion on https://github.com

[jira] [Comment Edited] (BEAM-989) GcsUtil batch remove() and copy() need tests.

[ https://issues.apache.org/jira/browse/BEAM-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716143#comment-15716143 ] Daniel Halperin edited comment on BEAM-989 at 12/2/16 8:08 PM

[jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky

[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716134#comment-15716134 ] Daniel Halperin commented on BEAM-1067: --- [~thw] can you take a look

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

[ https://issues.apache.org/jira/browse/BEAM-1067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1067: -- Assignee: Thomas Weise > apex.examples.WordCountTest.testWordCountExample may be fl

[jira] [Resolved] (BEAM-223) KafkaIO: don't use SerializableCoder

[ https://issues.apache.org/jira/browse/BEAM-223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-223. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > KafkaIO: don't use SerializableCo

[jira] [Resolved] (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:all-tabpanel ] Daniel Halperin resolved BEAM-747. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Text checksum verif

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

[ https://issues.apache.org/jira/browse/BEAM-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-252. -- Resolution: Fixed Assignee: Jesse Anderson (was: Kenneth Knowles) Fix Version/s

[jira] [Resolved] (BEAM-926) Findbugs doesn't pass in Microbenchmarks

[ https://issues.apache.org/jira/browse/BEAM-926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-926. -- Resolution: Fixed Fix Version/s: Not applicable Module deleted. > Findbugs doesn't p

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

[ https://issues.apache.org/jira/browse/BEAM-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1043. --- Resolution: Fixed Fix Version/s: Not applicable Immediate bug is fixed now. There may

[jira] [Resolved] (BEAM-810) Beam's uses of archetypes are problematic

[ https://issues.apache.org/jira/browse/BEAM-810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-810. -- Resolution: Information Provided Fix Version/s: Not applicable Information Provided

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

[ https://issues.apache.org/jira/browse/BEAM-475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-475. -- Resolution: Fixed Fix Version/s: Not applicable Many changes have improved quality

[jira] [Resolved] (BEAM-635) Release 0.2.0-incubating - Support Flink Release Version 1.1.2

[ https://issues.apache.org/jira/browse/BEAM-635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-635. -- Resolution: Not A Problem Fix Version/s: Not applicable 0.3.0-incubating and later have

[jira] [Updated] (BEAM-874) sdks/java/microbenchmarks instructions incorrect since benchmarks no longer run

[ https://issues.apache.org/jira/browse/BEAM-874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-874: - Assignee: Ben Chambers (was: Davor Bonaci) > sdks/java/microbenchmarks instructions incorr

[jira] [Resolved] (BEAM-874) sdks/java/microbenchmarks instructions incorrect since benchmarks no longer run

[ https://issues.apache.org/jira/browse/BEAM-874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-874. -- Resolution: Fixed Fix Version/s: Not applicable Module has been deleted. > sdks/j

[jira] [Resolved] (BEAM-268) Suppress Jekyll timestamp clobbering

[ https://issues.apache.org/jira/browse/BEAM-268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-268. -- Resolution: Fixed Assignee: Frances Perry (was: James Malone) Fix Version/s

[jira] [Resolved] (BEAM-748) Issues with local processes in MongoDbIO and JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-748. -- Resolution: Fixed Fix Version/s: Not applicable Seems to have resolved. Feel free

[jira] [Updated] (BEAM-76) FileBasedSource should take a list of files/globs

[ https://issues.apache.org/jira/browse/BEAM-76?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-76: Assignee: Pei He > FileBasedSource should take a list of files/gl

[jira] [Updated] (BEAM-60) FileBasedSource/IOChannelFactory: Custom glob expansion

[ https://issues.apache.org/jira/browse/BEAM-60?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-60: Assignee: Pei He > FileBasedSource/IOChannelFactory: Custom glob expans

[jira] [Resolved] (BEAM-485) Can't set Flink runner in code

[ https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-485. -- Resolution: Pending Closed Fix Version/s: Not applicable (Pending closed, with 3+ months

[jira] [Commented] (BEAM-485) Can't set Flink runner in code

[ https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15716033#comment-15716033 ] Daniel Halperin commented on BEAM-485: -- Hi [~ecesena] -- any updates here? I think we've made great

[jira] [Resolved] (BEAM-512) Fill in the contribute/testing section of the website

[ https://issues.apache.org/jira/browse/BEAM-512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-512. -- Resolution: Fixed Assignee: Jason Kuster (was: James Malone) Fix Version/s

[jira] [Resolved] (BEAM-431) Examples dependencies on runners are a bit much and not enough

[ https://issues.apache.org/jira/browse/BEAM-431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-431. -- Resolution: Fixed Assignee: Daniel Halperin Fix Version/s: Not applicable https

[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: - Summary: AvroCoder may be affected by AVRO-607 (was: AvroCoder may be vulnerable to AVRO-607

[jira] [Resolved] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking

[ https://issues.apache.org/jira/browse/BEAM-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-787. -- Resolution: Fixed Fix Version/s: Not applicable

[jira] [Resolved] (BEAM-945) BigQueryIO.parseTableSpec is package-private

[ https://issues.apache.org/jira/browse/BEAM-945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-945. -- Resolution: Fixed Fix Version/s: 0.4.0-incubating > BigQueryIO.parseTableSpec is pack

[jira] [Created] (BEAM-1076) Datastore Delete template

Vikas Kedigehalli created BEAM-1076: --- Summary: Datastore Delete template Key: BEAM-1076 URL: https://issues.apache.org/jira/browse/BEAM-1076 Project: Beam Issue Type: New Feature

[jira] [Closed] (BEAM-901) Fill in Pipeline Fundamentals docs

[ https://issues.apache.org/jira/browse/BEAM-901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hadar Hod closed BEAM-901. -- Resolution: Fixed Fix Version/s: Not applicable > Fill in Pipeline Fundamentals d

[jira] [Commented] (BEAM-1072) Dataflow should reject unset versions

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

[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=15715678#comment-15715678 ] Jean-Baptiste Onofré commented on BEAM-1074: [~amitsela] may I take this one ? > Set defa

[jira] [Created] (BEAM-1075) Shuffle the input read-values to get maximum parallelism.

Amit Sela created BEAM-1075: --- Summary: Shuffle the input read-values to get maximum parallelism. Key: BEAM-1075 URL: https://issues.apache.org/jira/browse/BEAM-1075 Project: Beam Issue Type: Sub

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

Amit Sela created BEAM-1074: --- Summary: Set default-partitioner in SourceRDD.Unbounded. Key: BEAM-1074 URL: https://issues.apache.org/jira/browse/BEAM-1074 Project: Beam Issue Type: Sub-task

[jira] [Commented] (BEAM-881) Provide a PTransform in IOs providing a "standard" Avro IndexedRecord

[ https://issues.apache.org/jira/browse/BEAM-881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15715662#comment-15715662 ] Jean-Baptiste Onofré commented on BEAM-881: --- Started a PoC about dataformat extension

[jira] [Updated] (BEAM-848) Make post-read (unbounded) shuffle use coders instead of Kryo.

[ https://issues.apache.org/jira/browse/BEAM-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-848: --- Description: The SparkRunner uses {{mapWithState}} to read and manage CheckpointMarks, and this stateful

[jira] [Closed] (BEAM-506) Fill in the documentation/runners/flink portion of the website

[ https://issues.apache.org/jira/browse/BEAM-506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-506. - Resolution: Fixed Fix Version/s: Not applicable > Fill in the documentation/runners/fl

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

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

[jira] [Commented] (BEAM-994) Support for S3 file source and sink

[ https://issues.apache.org/jira/browse/BEAM-994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714564#comment-15714564 ] Jean-Baptiste Onofré commented on BEAM-994: --- It should be addressed by the IOChannelFactory

[jira] [Commented] (BEAM-995) Apache Pig DSL

[ https://issues.apache.org/jira/browse/BEAM-995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714351#comment-15714351 ] Jean-Baptiste Onofré commented on BEAM-995: --- Not sure we have a huge overlap. For me, it's two

[jira] [Assigned] (BEAM-995) Apache Pig DSL

[ https://issues.apache.org/jira/browse/BEAM-995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-995: - Assignee: Jean-Baptiste Onofré (was: James Malone) > Apache Pig

[jira] [Commented] (BEAM-995) Apache Pig DSL

[ https://issues.apache.org/jira/browse/BEAM-995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15714000#comment-15714000 ] Neelesh Srinivas Salian commented on BEAM-995: -- Shall I take this as well? The SQL DSL work

[jira] [Updated] (BEAM-1070) Service Account Based Authentication Broken

[ https://issues.apache.org/jira/browse/BEAM-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-1070: Assignee: Ahmet Altay (was: Frances Perry) > Service Account Based Authentication Bro

[jira] [Updated] (BEAM-1068) Service Account Credentials File Specified via Pipeline Option Ignored

[ https://issues.apache.org/jira/browse/BEAM-1068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-1068: Assignee: Ahmet Altay (was: Frances Perry) > Service Account Credentials File Specified

[jira] [Resolved] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn)

[ https://issues.apache.org/jira/browse/BEAM-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-801. -- Resolution: Fixed Fix Version/s: Not applicable > SplittableParDo must be a pse

[jira] [Commented] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn)

[ https://issues.apache.org/jira/browse/BEAM-801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713305#comment-15713305 ] Eugene Kirpichov commented on BEAM-801: --- This can be closed. > SplittableParDo must be a pse

[jira] [Updated] (BEAM-1073) Staged websites have extra whitespace around links

[ https://issues.apache.org/jira/browse/BEAM-1073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1073: -- Description: cc [~davor] [~frances] e.g., http://apache-beam-website-pull

[jira] [Created] (BEAM-1073) Staged websites have extra whitespace around links

Daniel Halperin created BEAM-1073: - Summary: Staged websites have extra whitespace around links Key: BEAM-1073 URL: https://issues.apache.org/jira/browse/BEAM-1073 Project: Beam Issue Type

[jira] [Commented] (BEAM-506) Fill in the documentation/runners/flink portion of the website

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

[jira] [Commented] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn)

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

[jira] [Closed] (BEAM-895) Transport.newStorageClient requires credentials

[ https://issues.apache.org/jira/browse/BEAM-895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-895. Resolution: Fixed > Transport.newStorageClient requires credenti

[jira] [Commented] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles

[ https://issues.apache.org/jira/browse/BEAM-894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15713239#comment-15713239 ] Pei He commented on BEAM-894: - Closed without the fix for the following reason: @Teardown doesn't guarantee temp

[jira] [Closed] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles

[ https://issues.apache.org/jira/browse/BEAM-894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-894. --- Resolution: Won't Fix Fix Version/s: Not applicable > Using @Teardown to remove temp files from failed bund

[jira] [Closed] (BEAM-952) Dynamically load and register IOChannelFactory

[ https://issues.apache.org/jira/browse/BEAM-952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-952. --- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Dynamically load and register IOChannelFact

[jira] [Updated] (BEAM-990) KafkaIO does not commit offsets to Kafka

[ https://issues.apache.org/jira/browse/BEAM-990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alban Perillat-Merceroz updated BEAM-990: - Description: I use KafkaIO as a source, and I would like consumed offsets

[jira] [Closed] (BEAM-962) Fix games example pipeline options default values conflicts.

[ https://issues.apache.org/jira/browse/BEAM-962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-962. --- Resolution: Fixed Fix Version/s: 0.4.0-incubating > Fix games example pipeline options default values confli

[jira] [Closed] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel()

[ https://issues.apache.org/jira/browse/BEAM-443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-443. --- Resolution: Fixed Fix Version/s: 0.2.0-incubating > PipelineResult needs waitUntilFinish() and can

[jira] [Assigned] (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 ] Mark Liu reassigned BEAM-719: - Assignee: Mark Liu (was: Amit Sela) > Run WindowedWordCount Integration Test in Sp

[jira] [Closed] (BEAM-444) Promote isBlockOnRun() to PipelineOptions.

[ https://issues.apache.org/jira/browse/BEAM-444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-444. --- Resolution: Won't Fix Fix Version/s: Not applicable Obsolete given users can control blocking run

[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 ] Daniel Halperin updated BEAM-719: - Component/s: testing > Run WindowedWordCount Integration Test in Sp

[jira] [Updated] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel()

[ https://issues.apache.org/jira/browse/BEAM-443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-443: - Component/s: sdk-java-core > PipelineResult needs waitUntilFinish() and can

[jira] [Updated] (BEAM-580) Add a Datastore delete example

[ https://issues.apache.org/jira/browse/BEAM-580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-580: - Component/s: sdk-java-gcp > Add a Datastore delete exam

[jira] [Updated] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine

[ https://issues.apache.org/jira/browse/BEAM-765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-765: - Component/s: runner-core > TriggerStateMachine does not need to be separate f

[jira] [Updated] (BEAM-792) In WC Walkthrough: Document how logging works on Apache Spark

[ https://issues.apache.org/jira/browse/BEAM-792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-792: - Component/s: website > In WC Walkthrough: Document how logging works on Apache Sp

[jira] [Updated] (BEAM-444) Promote isBlockOnRun() to PipelineOptions.

[ https://issues.apache.org/jira/browse/BEAM-444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-444: - Component/s: sdk-java-core > Promote isBlockOnRun() to PipelineOpti

[jira] [Updated] (BEAM-599) Return KafkaIO getWatermark log in debug mode

[ https://issues.apache.org/jira/browse/BEAM-599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-599: - Component/s: sdk-java-extensions > Return KafkaIO getWatermark log in debug m

[jira] [Updated] (BEAM-494) All E2E Tests Run Against All Runners In Postcommit

[ https://issues.apache.org/jira/browse/BEAM-494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-494: - Component/s: testing > All E2E Tests Run Against All Runners In Postcom

[jira] [Updated] (BEAM-511) Fill in the contribute/technical-vision section of the website

[ https://issues.apache.org/jira/browse/BEAM-511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-511: - Component/s: website > Fill in the contribute/technical-vision section of the webs

<    4   5   6   7   8   9   10   11   12   13   >