[jira] [Commented] (BEAM-2316) GcsUtil matches GCS glob * as though it is **

[ https://issues.apache.org/jira/browse/BEAM-2316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015148#comment-16015148 ] Kenneth Knowles commented on BEAM-2316: --- [~dhalp...@google.com] you may have some stake in the

[jira] [Updated] (BEAM-2316) GcsUtil matches GCS glob * as though it is **

[ https://issues.apache.org/jira/browse/BEAM-2316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2316: -- Summary: GcsUtil matches GCS glob * as though it is ** (was: GCS path matching) > GcsUtil

[jira] [Created] (BEAM-2316) GCS path matching

Kenneth Knowles created BEAM-2316: - Summary: GCS path matching Key: BEAM-2316 URL: https://issues.apache.org/jira/browse/BEAM-2316 Project: Beam Issue Type: Bug Components:

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

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

[GitHub] beam pull request #3172: [BEAM-79] Sync gearpump-runner with master

GitHub user manuzhang opened a pull request: https://github.com/apache/beam/pull/3172 [BEAM-79] Sync gearpump-runner with master Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #23

See -- [...truncated 355.30 KB...] 2017-05-18T02:47:59.093 [INFO] Downloading:

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2853

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #22

See Changes: [tgroh] Translate a Pipeline in SdkComponents [klk] Use stable naming strategy for ByteBuddy invokers -- [...truncated 355.36 KB...]

[jira] [Updated] (BEAM-981) Not possible to directly submit a pipeline on spark cluster

[ https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-981: - Fix Version/s: (was: 2.1.0) > Not possible to directly submit a pipeline on spark cluster >

[GitHub] beam pull request #3170: A couple of worker fixes.

GitHub user robertwb reopened a pull request: https://github.com/apache/beam/pull/3170 A couple of worker fixes. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[GitHub] beam pull request #3170: A couple of worker fixes.

Github user robertwb closed the pull request at: https://github.com/apache/beam/pull/3170 --- 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-2314) Add ValidatesRunner test for custom merging windows

[ https://issues.apache.org/jira/browse/BEAM-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014818#comment-16014818 ] Aljoscha Krettek commented on BEAM-2314: [~echauchot], I thought you might be interested in doing

[jira] [Resolved] (BEAM-2288) Refine DSL interface

[ https://issues.apache.org/jira/browse/BEAM-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin resolved BEAM-2288. -- Resolution: Fixed Fix Version/s: Not applicable > Refine DSL interface > > >

[jira] [Closed] (BEAM-2288) Refine DSL interface

[ https://issues.apache.org/jira/browse/BEAM-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin closed BEAM-2288. > Refine DSL interface > > > Key: BEAM-2288 > URL:

[jira] [Commented] (BEAM-2288) Refine DSL interface

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

[GitHub] beam pull request #3137: [BEAM-2288] Refine DSL interface

Github user XuMingmin closed the pull request at: https://github.com/apache/beam/pull/3137 --- 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

[GitHub] beam pull request #3171: [BEAM-2164] Fix generate-sources.sh if directory co...

GitHub user markflyhigh opened a pull request: https://github.com/apache/beam/pull/3171 [BEAM-2164] Fix generate-sources.sh if directory contains space Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the

[jira] [Commented] (BEAM-2164) Build beam-sdks-java-maven-archetypes-examples Failed If Dir Contains Space

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

[GitHub] beam pull request #3170: A couple of worker fixes.

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/3170 A couple of worker fixes. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[2/2] beam git commit: [BEAM-2288] This closes #3137

[BEAM-2288] This closes #3137 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/25babc99 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/25babc99 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/25babc99 Branch:

[1/2] beam git commit: [BEAM-2288] Refine DSL interface as design doc of BEAM-2010: 1. rename BeamSqlRunner to BeamSQLEnvironment; 2. Move pipeline as external parameter, to integrate with none-DSL co

Repository: beam Updated Branches: refs/heads/DSL_SQL f96f9f680 -> 25babc999 [BEAM-2288] Refine DSL interface as design doc of BEAM-2010: 1. rename BeamSqlRunner to BeamSQLEnvironment; 2. Move pipeline as external parameter, to integrate with none-DSL components; Project:

[jira] [Assigned] (BEAM-2164) Build beam-sdks-java-maven-archetypes-examples Failed If Dir Contains Space

[ https://issues.apache.org/jira/browse/BEAM-2164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu reassigned BEAM-2164: -- Assignee: Mark Liu (was: Jean-Baptiste Onofré) > Build beam-sdks-java-maven-archetypes-examples Failed

[jira] [Commented] (BEAM-1553) OutputTimeFn maybe should be allowed to move elements back in time

[ https://issues.apache.org/jira/browse/BEAM-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014772#comment-16014772 ] Kenneth Knowles commented on BEAM-1553: --- I think just removing the crash is fine. Let it be moved. >

[jira] [Updated] (BEAM-1553) OutputTimeFn maybe should be allowed to move elements back in time

[ https://issues.apache.org/jira/browse/BEAM-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1553: -- Labels: starter (was: ) > OutputTimeFn maybe should be allowed to move elements back in time >

[jira] [Assigned] (BEAM-1553) OutputTimeFn maybe should be allowed to move elements back in time

[ https://issues.apache.org/jira/browse/BEAM-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1553: - Assignee: (was: Kenneth Knowles) > OutputTimeFn maybe should be allowed to move

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #3154

See

[jira] [Created] (BEAM-2315) Add ValidatesRunner test for non-blocking job submission

Aljoscha Krettek created BEAM-2315: -- Summary: Add ValidatesRunner test for non-blocking job submission Key: BEAM-2315 URL: https://issues.apache.org/jira/browse/BEAM-2315 Project: Beam

[jira] [Resolved] (BEAM-1663) Generated package names should be deterministic and consistent across runs.

[ https://issues.apache.org/jira/browse/BEAM-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1663. --- Resolution: Fixed Fix Version/s: 2.1.0 > Generated package names should be

[jira] [Created] (BEAM-2314) Add ValidatesRunner test for custom merging windows

Aljoscha Krettek created BEAM-2314: -- Summary: Add ValidatesRunner test for custom merging windows Key: BEAM-2314 URL: https://issues.apache.org/jira/browse/BEAM-2314 Project: Beam Issue

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2852

See

[jira] [Commented] (BEAM-1663) Generated package names should be deterministic and consistent across runs.

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

[GitHub] beam pull request #3151: [BEAM-1663] Use stable naming strategy for ByteBudd...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3151 --- 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

[2/2] beam git commit: This closes #3151: Use stable naming strategy for ByteBuddy invokers

This closes #3151: Use stable naming strategy for ByteBuddy invokers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5e3c5c65 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5e3c5c65 Diff:

[1/2] beam git commit: Use stable naming strategy for ByteBuddy invokers

Repository: beam Updated Branches: refs/heads/master 467e68f93 -> 5e3c5c657 Use stable naming strategy for ByteBuddy invokers This helps to coalesce related failures across multiple JVM instances, over time, across machines, etc. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3153

See

[jira] [Commented] (BEAM-2313) Continuously execute CassandraIOIT

[ https://issues.apache.org/jira/browse/BEAM-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014641#comment-16014641 ] Jean-Baptiste Onofré commented on BEAM-2313: [~jasonkuster] when you have a chance to take a

[jira] [Assigned] (BEAM-2313) Continuously execute CassandraIOIT

[ https://issues.apache.org/jira/browse/BEAM-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-2313: -- Assignee: Jason Kuster (was: Davor Bonaci) > Continuously execute

[jira] [Created] (BEAM-2313) Continuously execute CassandraIOIT

Jean-Baptiste Onofré created BEAM-2313: -- Summary: Continuously execute CassandraIOIT Key: BEAM-2313 URL: https://issues.apache.org/jira/browse/BEAM-2313 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-2312) Create CamelIO

Jean-Baptiste Onofré created BEAM-2312: -- Summary: Create CamelIO Key: BEAM-2312 URL: https://issues.apache.org/jira/browse/BEAM-2312 Project: Beam Issue Type: Task Components:

[jira] [Commented] (BEAM-981) Not possible to directly submit a pipeline on spark cluster

[ https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014562#comment-16014562 ] Kenneth Knowles commented on BEAM-981: -- I think we should drop the fix version for work that is

[jira] [Updated] (BEAM-2219) All TestRunners or no TestRunners should be registered

[ https://issues.apache.org/jira/browse/BEAM-2219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2219: -- Fix Version/s: (was: 2.1.0) > All TestRunners or no TestRunners should be registered >

[jira] [Updated] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1107: -- Fix Version/s: (was: 2.1.0) > Display user names for steps in the Flink Web UI >

[jira] [Updated] (BEAM-2299) Beam repo build fails in Windows OS

[ https://issues.apache.org/jira/browse/BEAM-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2299: -- Summary: Beam repo build fails in Windows OS (was: Beam repo build failes in Windows OS) >

[jira] [Assigned] (BEAM-2272) Test scope & runtime dependencies need reevaluation

[ https://issues.apache.org/jira/browse/BEAM-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2272: - Assignee: (was: Thomas Groh) > Test scope & runtime dependencies need reevaluation >

[jira] [Updated] (BEAM-1724) ApexRunner should deduplicate when an UnboundedSource requires Deduping

[ https://issues.apache.org/jira/browse/BEAM-1724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1724: -- Fix Version/s: (was: 2.1.0) > ApexRunner should deduplicate when an UnboundedSource requires

[jira] [Updated] (BEAM-2272) Test scope & runtime dependencies need reevaluation

[ https://issues.apache.org/jira/browse/BEAM-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2272: -- Fix Version/s: (was: 2.1.0) > Test scope & runtime dependencies need reevaluation >

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2851

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3835

See Changes: [tgroh] Translate a Pipeline in SdkComponents -- [...truncated 721.16 KB...] 2017-05-17T17:56:31.164 [INFO] Downloading:

[jira] [Commented] (BEAM-1928) Populate Runner API Components from the Java SDK

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

[GitHub] beam pull request #3169: [BEAM-1928] Translate a Pipeline in SdkComponents

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3169 --- 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/2] beam git commit: Translate a Pipeline in SdkComponents

Repository: beam Updated Branches: refs/heads/master d6cc850a9 -> 467e68f93 Translate a Pipeline in SdkComponents Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1a05a6a6 Tree:

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

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

[jira] [Commented] (BEAM-2185) KafkaIO bounded source

[ https://issues.apache.org/jira/browse/BEAM-2185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014439#comment-16014439 ] Raghu Angadi commented on BEAM-2185: Something like {{withEndTime()}} is required, which sets the upper

[jira] [Commented] (BEAM-1872) implement Reshuffle transform

[ https://issues.apache.org/jira/browse/BEAM-1872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16014360#comment-16014360 ] Ahmet Altay commented on BEAM-1872: --- Updated link:

[GitHub] beam pull request #3169: [BEAM-1928] Translate a Pipeline in SdkComponents

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/3169 [BEAM-1928] Translate a Pipeline in SdkComponents Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #21

See -- [...truncated 1.99 MB...] 2017-05-17T15:51:10.871 [INFO] Excluding io.dropwizard.metrics:metrics-jvm:jar:3.1.0 from the shaded jar.

[jira] [Created] (BEAM-2311) Update compatibility matrix Aggregators section for Metrics

Daniel Halperin created BEAM-2311: - Summary: Update compatibility matrix Aggregators section for Metrics Key: BEAM-2311 URL: https://issues.apache.org/jira/browse/BEAM-2311 Project: Beam

[jira] [Commented] (BEAM-2310) support data type: DECIMAL

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

[GitHub] beam pull request #3168: [BEAM-2310] support new data type: DECIMAL

GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3168 [BEAM-2310] support new data type: DECIMAL 1. support new data type: DECIMAL 2. support encoding/decoding for TIME 3. add tests all the supported data types. R: @XuMingmin You

[GitHub] beam-site pull request #247: Add a draft of the Beam FSR blog post

Github user asfgit closed the pull request at: https://github.com/apache/beam-site/pull/247 --- 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: Add a draft of the Beam FSR blog post

Repository: beam-site Updated Branches: refs/heads/asf-site c4a54639e -> 0b8e34de4 Add a draft of the Beam FSR blog post Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/0c8e7595 Tree:

[3/3] beam-site git commit: This closes #247

This closes #247 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/0b8e34de Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/0b8e34de Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/0b8e34de

[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/0b678294 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/0b678294 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/0b678294

[jira] [Commented] (BEAM-1507) java DataflowRunner should warn if the stagingLocation has a TTL

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

[GitHub] beam pull request #3167: [BEAM-1507] adding TTL check for staging location

GitHub user hepeknet opened a pull request: https://github.com/apache/beam/pull/3167 [BEAM-1507] adding TTL check for staging location Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Assigned] (BEAM-2310) support data type: DECIMAL

[ https://issues.apache.org/jira/browse/BEAM-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu reassigned BEAM-2310: -- Assignee: (was: Xu Mingmin) > support data type: DECIMAL > -- > >

[jira] [Created] (BEAM-2310) support data type: DECIMAL

James Xu created BEAM-2310: -- Summary: support data type: DECIMAL Key: BEAM-2310 URL: https://issues.apache.org/jira/browse/BEAM-2310 Project: Beam Issue Type: Bug Components: dsl-sql

[GitHub] beam pull request #3166: [BEAM-2309] implement VALUES

GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3166 [BEAM-2309] implement VALUES 1. implement VALUES 2. add support for data type CHAR(to be able to test VALUES) R: @XuMingmin You can merge this pull request into a Git repository by

beam-site git commit: Regenerate website after merge

Repository: beam-site Updated Branches: refs/heads/asf-site 222ba1259 -> c4a54639e Regenerate website after merge Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/c4a54639 Tree:

[GitHub] beam-site pull request #247: Add a draft of the Beam FSR blog post

GitHub user dhalperi opened a pull request: https://github.com/apache/beam-site/pull/247 Add a draft of the Beam FSR blog post R: @davorbonaci I played with tables for 10 minutes but I realized that the existing tables are YAML+HTML (cap matrix) and decided this was