[jira] [Updated] (BEAM-1425) Window should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1425: -- Labels: backward-incompatible starter (was: backward-incompatible) > Window should comply with

[jira] [Updated] (BEAM-1353) Beam should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1353: -- Labels: backward-incompatible easy starter (was: backward-incompatible) > Beam should comply

[jira] [Updated] (BEAM-1342) Rectify any egregious violations of the IO authoring guide in our IOs

[ https://issues.apache.org/jira/browse/BEAM-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1342: -- Fix Version/s: First stable release > Rectify any egregious violations of the IO authoring guide

[jira] [Updated] (BEAM-73) IO design pattern: Decouple Parsers and Coders

[ https://issues.apache.org/jira/browse/BEAM-73?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-73: Fix Version/s: First stable release > IO design pattern: Decouple Parsers and Coders >

[jira] [Updated] (BEAM-1353) Beam should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1353: -- Fix Version/s: First stable release > Beam should comply with PTransform style guide >

[jira] [Updated] (BEAM-1418) MapElements and FlatMapElements should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1418: -- Fix Version/s: First stable release > MapElements and FlatMapElements should comply with

[jira] [Updated] (BEAM-1415) PubsubIO should comply with PTransfrom style guide

[ https://issues.apache.org/jira/browse/BEAM-1415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1415: -- Fix Version/s: First stable release > PubsubIO should comply with PTransfrom style guide >

[jira] [Updated] (BEAM-1415) PubsubIO should comply with PTransfrom style guide

[ https://issues.apache.org/jira/browse/BEAM-1415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1415: -- Labels: backward-incompatible easy starter (was: backward-incompatible) > PubsubIO should

[jira] [Commented] (BEAM-184) Using Merging Windows and/or Triggers without a downstream aggregation should fail

[ https://issues.apache.org/jira/browse/BEAM-184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903673#comment-15903673 ] Kenneth Knowles commented on BEAM-184: -- I think with pipeline surgery in Java we are at a point where

[jira] [Assigned] (BEAM-184) Using Merging Windows and/or Triggers without a downstream aggregation should fail

[ https://issues.apache.org/jira/browse/BEAM-184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-184: Assignee: Thomas Groh > Using Merging Windows and/or Triggers without a downstream

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

[ https://issues.apache.org/jira/browse/BEAM-170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-170: - Fix Version/s: First stable release > Session windows should not be identified by their bounds >

[jira] [Updated] (BEAM-184) Using Merging Windows and/or Triggers without a downstream aggregation should fail

[ https://issues.apache.org/jira/browse/BEAM-184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-184: - Fix Version/s: First stable release > Using Merging Windows and/or Triggers without a downstream

svn commit: r18644 - in /dev/beam/0.6.0: apache-beam-0.6.0.tar.gz.asc apache-beam-0.6.0.tar.gz.md5 apache-beam-0.6.0.tar.gz.sha1

Author: altay Date: Thu Mar 9 19:21:03 2017 New Revision: 18644 Log: Add signatures/hashes for python tarball. Added: dev/beam/0.6.0/apache-beam-0.6.0.tar.gz.asc dev/beam/0.6.0/apache-beam-0.6.0.tar.gz.md5 dev/beam/0.6.0/apache-beam-0.6.0.tar.gz.sha1 Added:

[jira] [Updated] (BEAM-775) Remove Aggregators from the Java SDK

[ https://issues.apache.org/jira/browse/BEAM-775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-775: - Fix Version/s: First stable release > Remove Aggregators from the Java SDK >

[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: - Fix Version/s: First stable release > Move PipelineOptions from Pipeline.create() to Pipeline.run()

[jira] [Updated] (BEAM-1327) Replace OutputTimeFn with enum

[ https://issues.apache.org/jira/browse/BEAM-1327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1327: -- Fix Version/s: First stable release > Replace OutputTimeFn with enum >

[jira] [Updated] (BEAM-1345) Mark @Experimental pieces of the SDK that have been added but are not ready to be frozen

[ https://issues.apache.org/jira/browse/BEAM-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1345: -- Fix Version/s: First stable release > Mark @Experimental pieces of the SDK that have been added

[jira] [Updated] (BEAM-1340) Remove or make private public bits of the SDK that shouldn't be public

[ https://issues.apache.org/jira/browse/BEAM-1340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1340: -- Fix Version/s: First stable release > Remove or make private public bits of the SDK that

[jira] [Updated] (BEAM-1247) Session state should not be lost when discardingFiredPanes

[ https://issues.apache.org/jira/browse/BEAM-1247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1247: -- Fix Version/s: First stable release > Session state should not be lost when discardingFiredPanes

[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: - Fix Version/s: First stable release > Decouple side input window mapping from WindowFn >

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

[ https://issues.apache.org/jira/browse/BEAM-32?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-32: Fix Version/s: First stable release > Consider not emitting empty ON_TIME pane unless requested >

[jira] [Updated] (BEAM-1521) Pass element (and/or generic context) for choosing a table in BigQueryIO

[ https://issues.apache.org/jira/browse/BEAM-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1521: -- Labels: backward-incompatible (was: backwards-incompatible) > Pass element (and/or generic

[GitHub] beam-site pull request #175: Documentation changes for 0.6.0 release

GitHub user aaltay opened a pull request: https://github.com/apache/beam-site/pull/175 Documentation changes for 0.6.0 release R: @davorbonaci @sb2nov You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam-site asf-site

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #12

See Changes: [jbonofre] [BEAM-1184] Add integration tests to ElasticsearchIO [amitsela33] Test runner to stop on EOT watermark, or timeout.

[jira] [Updated] (BEAM-1676) SdkCoreApiSurfaceTest Failed in JDK7 and OpenJDK7&8 on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-1676: --- Summary: SdkCoreApiSurfaceTest Failed in JDK7 and OpenJDK7&8 on Jenkins (was: SdkCoreApiSurfaceTest Failed in

[jira] [Updated] (BEAM-1676) SdkCoreApiSurfaceTest Failed in JDK7 and OpenJDK7&8

[ https://issues.apache.org/jira/browse/BEAM-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-1676: --- Description: After running beam_PostCommit_Java_MavenInstall in different JDK versions (JDK7, OpenJDK7&8) on

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.8 (latest),beam #12

See -- [...truncated 473.90 KB...] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec - in

[jira] [Created] (BEAM-1676) SdkCoreApiSurfaceTest Failed in JDK7 and OpenJDK7&8

Mark Liu created BEAM-1676: -- Summary: SdkCoreApiSurfaceTest Failed in JDK7 and OpenJDK7&8 Key: BEAM-1676 URL: https://issues.apache.org/jira/browse/BEAM-1676 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-1674) Flink user state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903587#comment-15903587 ] Kenneth Knowles commented on BEAM-1674: --- The user needs to get a timer callback late enough that they

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1872

See

[jira] [Commented] (BEAM-664) Port Dataflow SDK WordCount walkthrough to Beam site

[ https://issues.apache.org/jira/browse/BEAM-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903563#comment-15903563 ] Davor Bonaci commented on BEAM-664: --- [~hadarhg] / [~frances], what's the accurate status of this task and

[jira] [Commented] (BEAM-1650) Add IntelliJ code style xml to the project repo and website

[ https://issues.apache.org/jira/browse/BEAM-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903560#comment-15903560 ] Aviem Zur commented on BEAM-1650: - We might be able to leverage

[jira] [Commented] (BEAM-1401) Sinks in Beam should supported windowed unbounded PCollections

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

[jira] [Assigned] (BEAM-1401) Sinks in Beam should supported windowed unbounded PCollections

[ https://issues.apache.org/jira/browse/BEAM-1401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1401: - Assignee: Kenneth Knowles (was: Davor Bonaci) > Sinks in Beam should supported windowed

[jira] [Resolved] (BEAM-892) revamp quickstart

[ https://issues.apache.org/jira/browse/BEAM-892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-892. --- Resolution: Fixed Fix Version/s: Not applicable > revamp quickstart > - > >

[jira] [Updated] (BEAM-166) Version annotations in capability matrix

[ https://issues.apache.org/jira/browse/BEAM-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-166: -- Issue Type: Wish (was: Bug) > Version annotations in capability matrix >

[jira] [Resolved] (BEAM-900) Spark quickstart instructions

[ https://issues.apache.org/jira/browse/BEAM-900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-900. --- Resolution: Fixed Fix Version/s: Not applicable > Spark quickstart instructions >

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

[ https://issues.apache.org/jira/browse/BEAM-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903550#comment-15903550 ] Davor Bonaci commented on BEAM-1175: I believe we have recently removed runner-facing Javadoc from

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

[ https://issues.apache.org/jira/browse/BEAM-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1175: -- Assignee: Kenneth Knowles (was: James Malone) > Separate runners-core Javadoc from SDK

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

[ https://issues.apache.org/jira/browse/BEAM-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1175. Resolution: Fixed Fix Version/s: Not applicable > Separate runners-core Javadoc from SDK

[jira] [Resolved] (BEAM-1552) Beam contrib guide does not fully explain normal dev flow

[ https://issues.apache.org/jira/browse/BEAM-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1552. Resolution: Fixed Fix Version/s: Not applicable > Beam contrib guide does not fully explain

[jira] [Assigned] (BEAM-1367) Need a way to force a page to be set to a specific language for code blocks

[ https://issues.apache.org/jira/browse/BEAM-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1367: -- Assignee: (was: Davor Bonaci) > Need a way to force a page to be set to a specific language

[jira] [Commented] (BEAM-1552) Beam contrib guide does not fully explain normal dev flow

[ https://issues.apache.org/jira/browse/BEAM-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903538#comment-15903538 ] Davor Bonaci commented on BEAM-1552: PR got merged, so I assume this is done. Resolving. Feel free to

[jira] [Commented] (BEAM-977) Fill in Python SDK page

[ https://issues.apache.org/jira/browse/BEAM-977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903521#comment-15903521 ] Davor Bonaci commented on BEAM-977: --- Seems like already done:

[jira] [Commented] (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:comment-tabpanel=15903534#comment-15903534 ] Davor Bonaci commented on BEAM-792: --- [~hadarhg], any more thoughts perhaps? Generally speaking, the

[jira] [Commented] (BEAM-1650) Add IntelliJ code style xml to the project repo and website

[ https://issues.apache.org/jira/browse/BEAM-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903530#comment-15903530 ] Davor Bonaci commented on BEAM-1650: [~aviemzur], what are you thoughts on how hard would it be to

[jira] [Updated] (BEAM-1650) Add IntelliJ code style xml to the project repo and website

[ https://issues.apache.org/jira/browse/BEAM-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-1650: --- Component/s: (was: sdk-ideas) > Add IntelliJ code style xml to the project repo and website >

[jira] [Commented] (BEAM-791) In WC Walkthrough: Document how logging works on Apache Flink

[ https://issues.apache.org/jira/browse/BEAM-791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903524#comment-15903524 ] Davor Bonaci commented on BEAM-791: --- [~hadarhg], can you please provide any more details what are you

[jira] [Assigned] (BEAM-834) Add HTML/md versions of technical reference docs

[ https://issues.apache.org/jira/browse/BEAM-834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-834: - Assignee: (was: Kenneth Knowles) > Add HTML/md versions of technical reference docs >

[jira] [Updated] (BEAM-667) Include code snippets from real examples

[ https://issues.apache.org/jira/browse/BEAM-667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-667: -- Fix Version/s: First stable release > Include code snippets from real examples >

[jira] [Resolved] (BEAM-977) Fill in Python SDK page

[ https://issues.apache.org/jira/browse/BEAM-977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-977. --- Resolution: Fixed Fix Version/s: Not applicable > Fill in Python SDK page >

[jira] [Updated] (BEAM-1013) Recheck all existing programming guide code snippets for correctness

[ https://issues.apache.org/jira/browse/BEAM-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-1013: --- Fix Version/s: First stable release > Recheck all existing programming guide code snippets for

[jira] [Assigned] (BEAM-1015) Need language specific tabs that allow both regular text and code blocks

[ https://issues.apache.org/jira/browse/BEAM-1015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1015: -- Assignee: (was: James Malone) > Need language specific tabs that allow both regular text

[jira] [Resolved] (BEAM-916) Update the "Using the Documentation" doc (/documentation/)

[ https://issues.apache.org/jira/browse/BEAM-916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-916. --- Resolution: Fixed Fix Version/s: Not applicable > Update the "Using the Documentation" doc

[jira] [Resolved] (BEAM-504) Fill in the documentation/sdks/java portion of the website

[ https://issues.apache.org/jira/browse/BEAM-504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-504. --- Resolution: Fixed Fix Version/s: Not applicable > Fill in the documentation/sdks/java portion of

[jira] [Assigned] (BEAM-504) Fill in the documentation/sdks/java portion of the website

[ https://issues.apache.org/jira/browse/BEAM-504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-504: - Assignee: Hadar Hod (was: James Malone) > Fill in the documentation/sdks/java portion of the

[jira] [Commented] (BEAM-916) Update the "Using the Documentation" doc (/documentation/)

[ https://issues.apache.org/jira/browse/BEAM-916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903512#comment-15903512 ] Davor Bonaci commented on BEAM-916: --- Seems like already done: https://beam.apache.org/documentation/.

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),beam #11

See -- [...truncated 473.55 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.297 sec - in

[jira] [Commented] (BEAM-509) Fill in the Additonal Resources page of the website

[ https://issues.apache.org/jira/browse/BEAM-509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903507#comment-15903507 ] Davor Bonaci commented on BEAM-509: --- Seems like it is done:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #11

See -- [...truncated 474.55 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.288 sec - in

[jira] [Commented] (BEAM-1660) withCoder() error in JdbcIO JavaDoc example

[ https://issues.apache.org/jira/browse/BEAM-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903486#comment-15903486 ] Xu Mingmin commented on BEAM-1660: -- create a new task BEAM-1675 to deprecate withCoder() in JdbcIO >

[GitHub] beam-site pull request #174: Finding a typo in a code block

Github user asfgit closed the pull request at: https://github.com/apache/beam-site/pull/174 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[1/3] beam-site git commit: Finding a typo in a code block

Repository: beam-site Updated Branches: refs/heads/asf-site 6dd302c0f -> 7b78cc342 Finding a typo in a code block I found a typo in the Markdown code block. The ``` should be gone. Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit:

[2/3] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/51425e85 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/51425e85 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/51425e85

[jira] [Created] (BEAM-1675) deprecate withCoder() in JdbcIO

Xu Mingmin created BEAM-1675: Summary: deprecate withCoder() in JdbcIO Key: BEAM-1675 URL: https://issues.apache.org/jira/browse/BEAM-1675 Project: Beam Issue Type: New Feature

[jira] [Commented] (BEAM-357) Build doesn't pass on windows

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

[jira] [Commented] (BEAM-1640) data file missing when submit a job on Flink

[ https://issues.apache.org/jira/browse/BEAM-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903472#comment-15903472 ] Xu Mingmin commented on BEAM-1640: -- [~aljoscha], it fails with Flink 1.2.0, Beam 0.6.0-SNAPSHOT. The same

[GitHub] beam pull request #496: [BEAM-357] fixing build on windows

Github user rmannibucau closed the pull request at: https://github.com/apache/beam/pull/496 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1871

See

[jira] [Resolved] (BEAM-1562) Use a "signal" to stop streaming tests as they finish.

[ https://issues.apache.org/jira/browse/BEAM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1562. - Resolution: Fixed Fix Version/s: First stable release > Use a "signal" to stop streaming tests as

[jira] [Resolved] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1582. - Resolution: Fixed Fix Version/s: First stable release > ResumeFromCheckpointStreamingTest flakes

[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 ] Jean-Baptiste Onofré updated BEAM-1184: --- Fix Version/s: First stable release > Add integration tests for ElasticsearchIO >

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),beam #10

See Changes: [amitsela33] Test runner to stop on EOT watermark, or timeout. -- [...truncated 475.15

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),beam #10

See Changes: [amitsela33] Test runner to stop on EOT watermark, or timeout. -- [...truncated 473.62 KB...] Tests run:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #10

See Changes: [amitsela33] Test runner to stop on EOT watermark, or timeout. -- [...truncated 474.60

[2/2] beam git commit: This closes #2168

This closes #2168 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/efc701ed Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/efc701ed Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/efc701ed Branch:

[GitHub] beam pull request #2168: [BEAM-1582, BEAM-1562] Stop streaming tests on EOT ...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2168 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

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

[1/2] beam git commit: Test runner to stop on EOT watermark, or timeout.

Repository: beam Updated Branches: refs/heads/master 7954896a5 -> efc701ed6 Test runner to stop on EOT watermark, or timeout. Remove timeout since it is already a pipeline option. Advance to infinity at the end of pipelines. Add EOT watermark and expected assertions test options.

[jira] [Commented] (BEAM-1674) Flink user state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903196#comment-15903196 ] Aljoscha Krettek commented on BEAM-1674: [~lzljs3620320] Do you maybe have an idea about this? I

[jira] [Updated] (BEAM-1674) Flink user state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1674: --- Summary: Flink user state GC depends on order of timer firing (was: User state GC depends on

[jira] [Commented] (BEAM-1674) User state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903183#comment-15903183 ] Aljoscha Krettek commented on BEAM-1674: [~kenn] I'm afraid we can't simply use timers with

[jira] [Created] (BEAM-1674) User state GC depends on order of timer firing

Aljoscha Krettek created BEAM-1674: -- Summary: User state GC depends on order of timer firing Key: BEAM-1674 URL: https://issues.apache.org/jira/browse/BEAM-1674 Project: Beam Issue Type:

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903135#comment-15903135 ] Eugene Kirpichov commented on BEAM-68: -- I think this needs a discussion on the Beam dev@ mailing list.

[jira] [Commented] (BEAM-1660) withCoder() error in JdbcIO JavaDoc example

[ https://issues.apache.org/jira/browse/BEAM-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903124#comment-15903124 ] Eugene Kirpichov commented on BEAM-1660: Agreed about the coder issue: we should take advantage of

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Dataflow #2506

See

[jira] [Commented] (BEAM-1640) data file missing when submit a job on Flink

[ https://issues.apache.org/jira/browse/BEAM-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903038#comment-15903038 ] Aljoscha Krettek commented on BEAM-1640: Which Flink version are you using? > data file missing

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2854

See

[jira] [Assigned] (BEAM-1673) PubSubIO can't write attributes

[ https://issues.apache.org/jira/browse/BEAM-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1673: -- Assignee: Jean-Baptiste Onofré (was: Daniel Halperin) > PubSubIO can't write

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1870

See

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),beam #9

See -- [...truncated 475.00 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.279 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #9

See -- [...truncated 474.59 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.338 sec - in

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1461

See

Jenkins build is unstable: beam_PostCommit_Java_RunnableOnService_Flink #1869

See

[GitHub] beam pull request #2210: [BEAM-1674] Add unicode type to the typeDict attrib...

GitHub user yuya-tajima opened a pull request: https://github.com/apache/beam/pull/2210 [BEAM-1674] Add unicode type to the typeDict attribute in Python SDK When I executed Biq Query exection on the Google Cloud Dataflow, the following error occurred. ```

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902802#comment-15902802 ] Aljoscha Krettek commented on BEAM-1641: Wow, that's a tough one. I think we might first have to

[jira] [Commented] (BEAM-1673) PubSubIO can't write attributes

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

[GitHub] beam pull request #2209: [BEAM-1673] Fix PubSubIO write attribute issue

GitHub user bchen-talend opened a pull request: https://github.com/apache/beam/pull/2209 [BEAM-1673] Fix PubSubIO write attribute issue Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Created] (BEAM-1673) PubSubIO can't write attributes

Bin Chen created BEAM-1673: -- Summary: PubSubIO can't write attributes Key: BEAM-1673 URL: https://issues.apache.org/jira/browse/BEAM-1673 Project: Beam Issue Type: Bug Components:

[GitHub] beam-site pull request #174: Finding a typo in a code block

GitHub user sungjunyoung opened a pull request: https://github.com/apache/beam-site/pull/174 Finding a typo in a code block I found a typo in the Markdown code block. The ``` should be gone. You can merge this pull request into a Git repository by running: $ git pull

<    1   2   3   >