[jira] [Closed] (BEAM-227) Log sdk version in worker-startup logs

[ https://issues.apache.org/jira/browse/BEAM-227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci closed BEAM-227. - Resolution: Invalid Assignee: Davor Bonaci (was: Frances Perry) > Log sdk version in worker-startup

[jira] [Commented] (BEAM-227) Log sdk version in worker-startup logs

[ https://issues.apache.org/jira/browse/BEAM-227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257597#comment-15257597 ] Davor Bonaci commented on BEAM-227: --- Worker-startup is runner-specific -- in this case, Dataflow. So, I'll

[jira] [Commented] (BEAM-222) TestCounterSource does not implement checkpointing contract

[ https://issues.apache.org/jira/browse/BEAM-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257594#comment-15257594 ] Davor Bonaci commented on BEAM-222: --- Done? > TestCounterSource does not implement checkpointing contract

[jira] [Updated] (BEAM-228) Create a merge bot for Beam

[ https://issues.apache.org/jira/browse/BEAM-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-228: -- Component/s: project-management > Create a merge bot for Beam > --- > >

[jira] [Updated] (BEAM-228) Create a merge bot for Beam

[ https://issues.apache.org/jira/browse/BEAM-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-228: -- Assignee: Jason Kuster > Create a merge bot for Beam > --- > >

[jira] [Updated] (BEAM-228) Create a merge bot for Beam

[ https://issues.apache.org/jira/browse/BEAM-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-228: -- Issue Type: New Feature (was: Improvement) > Create a merge bot for Beam > --- >

[jira] [Commented] (BEAM-173) Publish DisplayData for PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257585#comment-15257585 ] Davor Bonaci commented on BEAM-173: --- Done? > Publish DisplayData for PipelineOptions >

[jira] [Commented] (BEAM-168) IntervalBoundedExponentialBackOff change broke Beam-on-Dataflow

[ https://issues.apache.org/jira/browse/BEAM-168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257586#comment-15257586 ] Davor Bonaci commented on BEAM-168: --- Done? > IntervalBoundedExponentialBackOff change broke

[GitHub] incubator-beam pull request: [BEAM-121] Add DisplayData for compos...

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

[2/2] incubator-beam git commit: Register DisplayData from composite IO transforms

Register DisplayData from composite IO transforms Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/15b11ede Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/15b11ede Diff:

[1/2] incubator-beam git commit: Closes #236

Repository: incubator-beam Updated Branches: refs/heads/master ebc703590 -> c59ca3868 Closes #236 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c59ca386 Tree:

[GitHub] incubator-beam pull request: Move ClassForDisplayJava8Test to corr...

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

[1/2] incubator-beam git commit: Move ClassForDisplayJava8Test to correct package

Repository: incubator-beam Updated Branches: refs/heads/master 0f7b81615 -> ebc703590 Move ClassForDisplayJava8Test to correct package Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7aef7a03 Tree:

[3/3] incubator-beam git commit: This closes #240

This closes #240 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0f7b8161 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0f7b8161 Diff:

[2/3] incubator-beam git commit: Move contrib/join-library to sdks/java/extensions.

Move contrib/join-library to sdks/java/extensions. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e2ca8890 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e2ca8890 Diff:

[jira] [Commented] (BEAM-222) TestCounterSource does not implement checkpointing contract

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

[4/6] incubator-beam git commit: Only duplicate valid values

Only duplicate valid values Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a8f9e99f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a8f9e99f Diff:

[6/6] incubator-beam git commit: [BEAM-222] This closes #235

[BEAM-222] This closes #235 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d5814a38 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d5814a38 Diff:

[GitHub] incubator-beam pull request: [BEAM-222] Respect checkpointing cont...

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

[5/6] incubator-beam git commit: Luke's comments

Luke's comments Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4e18be8e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4e18be8e Diff:

[3/6] incubator-beam git commit: Add test

Add test Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/62b61197 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/62b61197 Diff:

[2/6] incubator-beam git commit: Respect checkpointing contract

Respect checkpointing contract Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0236bc18 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0236bc18 Diff:

[1/6] incubator-beam git commit: Thank goodness for checkstyle! I almost committed a change which almost cirtainly would have resulting in global meltdown. Here's to you maven-checkstyle-plugin.

Repository: incubator-beam Updated Branches: refs/heads/master e953cb022 -> d5814a38d Thank goodness for checkstyle! I almost committed a change which almost cirtainly would have resulting in global meltdown. Here's to you maven-checkstyle-plugin. Project:

[jira] [Commented] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257180#comment-15257180 ] Eugene Kirpichov commented on BEAM-217: --- I'm overwhelmed and don't have time to do it right now

[GitHub] incubator-beam pull request: Reorganize Java packages in the Googl...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/239 Reorganize Java packages in the Google Cloud Dataflow runner Move packages from `org.apache.beam.sdk` to `org.apache.beam.runners.dataflow`. R: @bjchambers You can merge this

[GitHub] incubator-beam pull request: [BEAM-22] Track Synchronized Processi...

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Resolved] (BEAM-220) KafkaIO test is flaky

[ https://issues.apache.org/jira/browse/BEAM-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-220. -- Resolution: Fixed We believe this issue is fixed by the changes in the linked PR. > KafkaIO test

[jira] [Commented] (BEAM-220) KafkaIO test is flaky

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

[jira] [Resolved] (BEAM-224) Two assert fails with merging windows and closable triggers

[ https://issues.apache.org/jira/browse/BEAM-224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shields resolved BEAM-224. --- Resolution: Not A Problem Somehow this is from a pipeline using a 1.5.0 jar. > Two assert fails with

[jira] [Resolved] (BEAM-226) Upload JARs to Maven Central

[ https://issues.apache.org/jira/browse/BEAM-226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-226. --- Resolution: Not A Problem It's already done: we have nightly builds containing all

[jira] [Assigned] (BEAM-226) Upload JARs to Maven Central

[ https://issues.apache.org/jira/browse/BEAM-226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-226: - Assignee: Jean-Baptiste Onofré > Upload JARs to Maven Central >

[jira] [Commented] (BEAM-220) KafkaIO test is flaky

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

[GitHub] incubator-beam pull request: Move ClassForDisplayJava8Test to corr...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/238 Move ClassForDisplayJava8Test to correct package Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] incubator-beam pull request: [BEAM-220] fix flaky KafkaIO test

GitHub user rangadi opened a pull request: https://github.com/apache/incubator-beam/pull/237 [BEAM-220] fix flaky KafkaIO test Fix a flaky KafkaIO test. KafkaIO reader reads from Kafka in a separate thread. As a result, `start()` or `advance()` might not read a record with

[jira] [Commented] (BEAM-226) Upload JARs to Maven Central

[ https://issues.apache.org/jira/browse/BEAM-226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15256748#comment-15256748 ] Jesse Anderson commented on BEAM-226: - Until then, here are the basic steps to start using Beam: 1.

[jira] [Created] (BEAM-226) Upload JARs to Maven Central

Jesse Anderson created BEAM-226: --- Summary: Upload JARs to Maven Central Key: BEAM-226 URL: https://issues.apache.org/jira/browse/BEAM-226 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-225) Create Class for Common TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jesse Anderson updated BEAM-225: Description: There should be a built-in class for common types like String, Float, etc. Right now,

[jira] [Updated] (BEAM-225) Create Class for Common TypeDescriptors

[ https://issues.apache.org/jira/browse/BEAM-225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jesse Anderson updated BEAM-225: Description: There should be a built-in class for common types like String, Float, etc. Right now,

[jira] [Created] (BEAM-225) Create Class for Common TypeDescriptors

Jesse Anderson created BEAM-225: --- Summary: Create Class for Common TypeDescriptors Key: BEAM-225 URL: https://issues.apache.org/jira/browse/BEAM-225 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-224) Two assert fails with merging windows and closable triggers

[ https://issues.apache.org/jira/browse/BEAM-224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-224: - Assignee: Mark Shields (was: Frances Perry) > Two assert fails with merging windows and closable

[jira] [Created] (BEAM-224) Two assert fails with merging windows and closable triggers

Mark Shields created BEAM-224: - Summary: Two assert fails with merging windows and closable triggers Key: BEAM-224 URL: https://issues.apache.org/jira/browse/BEAM-224 Project: Beam Issue Type:

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

Daniel Halperin created BEAM-223: Summary: KafkaIO: don't use SerializableCoder Key: BEAM-223 URL: https://issues.apache.org/jira/browse/BEAM-223 Project: Beam Issue Type: Bug