Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle #439

2018-06-06 Thread Apache Jenkins Server
See 




[jira] [Work logged] (BEAM-4488) Contributor's guide needs to document how to install Python SDK from source

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4488?focusedWorklogId=109633=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109633
 ]

ASF GitHub Bot logged work on BEAM-4488:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:31
Start Date: 07/Jun/18 04:31
Worklog Time Spent: 10m 
  Work Description: pabloem commented on a change in pull request #464: 
[BEAM-4488], [BEAM-4489], [BEAM-4490] Improvements to contribution guide
URL: https://github.com/apache/beam-site/pull/464#discussion_r193622173
 
 

 ##
 File path: src/contribute/index.md
 ##
 @@ -19,45 +19,59 @@ The Apache Beam community welcomes contributions from 
anyone!
 
 There are lots of opportunities:
 
- - write new examples
+ - ask or answer questions on [u...@beam.apache.org]({{ site.baseurl
+}}/community/contact-us/) or
+[stackoverflow](https://stackoverflow.com/questions/tagged/apache-beam)
+ - review proposed design ideas on [d...@beam.apache.org]({{ site.baseurl
+}}/community/contact-us/)
  - improve the documentation
+ - contribute bug reports
 
 Review comment:
   Maybe link Jira? : ) https://issues.apache.org/jira/projects/BEAM/issues


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109633)
Time Spent: 50m  (was: 40m)

> Contributor's guide needs to document how to install Python SDK from source
> ---
>
> Key: BEAM-4488
> URL: https://issues.apache.org/jira/browse/BEAM-4488
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>  Time Spent: 50m
>  Remaining Estimate: 0h
>
> Currently it is not documented, though it does appear in the quickstart



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4488) Contributor's guide needs to document how to install Python SDK from source

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4488?focusedWorklogId=109632=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109632
 ]

ASF GitHub Bot logged work on BEAM-4488:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:31
Start Date: 07/Jun/18 04:31
Worklog Time Spent: 10m 
  Work Description: pabloem commented on a change in pull request #464: 
[BEAM-4488], [BEAM-4489], [BEAM-4490] Improvements to contribution guide
URL: https://github.com/apache/beam-site/pull/464#discussion_r193622481
 
 

 ##
 File path: src/contribute/index.md
 ##
 @@ -78,29 +97,90 @@ necessary things to run those tests. For example:
 $ ./gradlew -p sdks/java/io/cassandra check
 $ ./gradlew -p runners/flink check
 
-### Testing the Python SDK
+You can see what build tasks are available with
+
+$ ./gradlew tasks
+
+or for a module,
+
+$ ./gradlew sdks/java/io/cassandra tasks
+
+### Developing with an IDE
+
+Generate an IDEA project .ipr file with:
+
+$ ./gradlew idea
+
+### Pull requests
+
+When your change is ready to be reviewed and merged, create a pull request.
+Format the pull request title like [BEAM-XXX] Fixes bug in 
ApproximateQuantiles,
 
 Review comment:
   Maybe add backticks or quotes for the title of the Pull Request?


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109632)
Time Spent: 40m  (was: 0.5h)

> Contributor's guide needs to document how to install Python SDK from source
> ---
>
> Key: BEAM-4488
> URL: https://issues.apache.org/jira/browse/BEAM-4488
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>  Time Spent: 40m
>  Remaining Estimate: 0h
>
> Currently it is not documented, though it does appear in the quickstart



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4488) Contributor's guide needs to document how to install Python SDK from source

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4488?focusedWorklogId=109631=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109631
 ]

ASF GitHub Bot logged work on BEAM-4488:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:31
Start Date: 07/Jun/18 04:31
Worklog Time Spent: 10m 
  Work Description: pabloem commented on a change in pull request #464: 
[BEAM-4488], [BEAM-4489], [BEAM-4490] Improvements to contribution guide
URL: https://github.com/apache/beam-site/pull/464#discussion_r193622831
 
 

 ##
 File path: src/contribute/index.md
 ##
 @@ -78,29 +97,90 @@ necessary things to run those tests. For example:
 $ ./gradlew -p sdks/java/io/cassandra check
 $ ./gradlew -p runners/flink check
 
-### Testing the Python SDK
+You can see what build tasks are available with
+
+$ ./gradlew tasks
+
+or for a module,
+
+$ ./gradlew sdks/java/io/cassandra tasks
+
+### Developing with an IDE
+
+Generate an IDEA project .ipr file with:
+
+$ ./gradlew idea
+
+### Pull requests
+
+When your change is ready to be reviewed and merged, create a pull request.
+Format the pull request title like [BEAM-XXX] Fixes bug in 
ApproximateQuantiles,
+where you replace BEAM-XXX with the appropriate JIRA issue.
+This will automatically link the pull request to the issue.
+
+Pull requests can only be merged by a [beam committer]
+(http://people.apache.org/phonebook.html?unix=beam).
+To find a committer for your area, look for similar code merges or ask on 
+[d...@beam.apache.org]({{ site.baseurl }}/community/contact-us/)
+
+Use @mention in the pull request to notify the reviewer.
+
+The pull request and any changes pushed to it will trigger precommit jobs.
+If a test fails and appears unrelated to your change, you can cause tests
+to be re-run by adding a single line comment on your PR
+
+ retest this please
+
+There are other trigger phrases for post-commit tests found in
+.testinfra/jenkins, but use these sparingly because postcommit
+tests consume shared development resources.
+
+### Developing with the Python SDK
+
+Gradle can build and test python, and is used by the Jenkins jobs, so needs to
+be maintained.
 
 You can directly use the Python toolchain instead of having Gradle orchestrate
-it. This may be faster for you. We recommend setting up a virtual environment
-before testing your code.
+it, which may be faster for you, but it is your preference.
+If you do want to use Python tools directly, we recommend setting up a virtual
+environment before testing your code.
 
 If you update any of the [cythonized](http://cython.org) files in Python SDK,
 you must install the `cython` package before running following command to
 properly test your code. 
 
 The following commands should be run in the `sdks/python` directory.
-This command runs all Python tests.
+This installs Python from source and includes the test and gcp dependencies.
+
+On macOS/Linix:
+
+$ virtualenv env
+$ . ./env/bin/activate
+(env) $ pip install .[gcp,test]
 
-$ python setup.py nosetests
+On Windows:
+
+> c:\Python27\python.exe -m virtualenv
+> env\Scripts\activate
+(env) > pip install .[gcp,test]
+
+This command runs all Python tests. The nose dependency is installed by [test] 
in pip install.
+
+(env) $ python setup.py nosetests
 
 You can use following command to run a single test method.
 
-$ python setup.py nosetests --tests :.
+(env) $ python setup.py nosetests --tests :.
+
+For example:
+(env) $ python setup.py nosetests --tests 
apache_beam.io.textio_test:TextSourceTest.test_progress
 
-Example:
-$ python setup.py nosetests --tests 
apache_beam.io.textio_test:TextSourceTest.test_progress
+You can deactivate the virtualenv when done.
 
-To check just for lint errors, run the following command.
+(env) $ deactivate
+$
+
+To check just for Python lint errors, run the following command.
 
 Review comment:
   We have `tox` commands that run lint tasks. I am not sure, but maybe it'd be 
worth mentioning them
   
   tox -e py27-lint  # For python 2.7
   tox -e py3-lint# For python 3 
   tox -e py27-lint3   # For python 2-3 compatibility
   
   All of these run in precommits


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109631)
Time Spent: 0.5h  (was: 20m)

> Contributor's guide needs to document how to install Python SDK from source
> ---
>
> Key: BEAM-4488
> URL: 

[jira] [Work logged] (BEAM-3608) Pre-shade Guava for things we want to keep using

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3608?focusedWorklogId=109630=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109630
 ]

ASF GitHub Bot logged work on BEAM-3608:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:23
Start Date: 07/Jun/18 04:23
Worklog Time Spent: 10m 
  Work Description: kennknowles commented on issue #5570: [BEAM-3608] 
Pre-shade Guava
URL: https://github.com/apache/beam/pull/5570#issuecomment-395288364
 
 
   I think publishing is very relevant anyhow, right? I expected that these 
artifacts would be actually published even once we are fully migrated. I will 
definitely include publishing in this PR.
   
   I will try a mass migration by search/replace but if that isn't trivial I 
will take a piecemeal approach.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109630)
Time Spent: 1h 50m  (was: 1h 40m)

> Pre-shade Guava for things we want to keep using
> 
>
> Key: BEAM-3608
> URL: https://issues.apache.org/jira/browse/BEAM-3608
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-core, sdk-java-core
>Reporter: Kenneth Knowles
>Assignee: Kenneth Knowles
>Priority: Major
>  Time Spent: 1h 50m
>  Remaining Estimate: 0h
>
> Instead of shading as part of our build, we can shade before build so that it 
> is apparent when reading code, and in IDEs, that a particular class resides 
> in a hidden namespace.
> {{import com.google.common.reflect.TypeToken}}
> becomes something like
> {{import org.apache.beam.private.guava21.com.google.common.reflect.TypeToken}}
> So we can very trivially ban `org.apache.beam.private` from public APIs 
> unless they are annotated {{@Internal}}, and it makes sharing between our own 
> modules never get broken by shading again.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3608) Pre-shade Guava for things we want to keep using

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3608?focusedWorklogId=109629=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109629
 ]

ASF GitHub Bot logged work on BEAM-3608:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:22
Start Date: 07/Jun/18 04:22
Worklog Time Spent: 10m 
  Work Description: kennknowles commented on issue #5570: [BEAM-3608] 
Pre-shade Guava
URL: https://github.com/apache/beam/pull/5570#issuecomment-395288364
 
 
   I think publishing is very relevant anyhow, right? I expected that these 
artifacts would be actually published even once we are fully migrated. I will 
definitely include publishing in this PR.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109629)
Time Spent: 1h 40m  (was: 1.5h)

> Pre-shade Guava for things we want to keep using
> 
>
> Key: BEAM-3608
> URL: https://issues.apache.org/jira/browse/BEAM-3608
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-core, sdk-java-core
>Reporter: Kenneth Knowles
>Assignee: Kenneth Knowles
>Priority: Major
>  Time Spent: 1h 40m
>  Remaining Estimate: 0h
>
> Instead of shading as part of our build, we can shade before build so that it 
> is apparent when reading code, and in IDEs, that a particular class resides 
> in a hidden namespace.
> {{import com.google.common.reflect.TypeToken}}
> becomes something like
> {{import org.apache.beam.private.guava21.com.google.common.reflect.TypeToken}}
> So we can very trivially ban `org.apache.beam.private` from public APIs 
> unless they are annotated {{@Internal}}, and it makes sharing between our own 
> modules never get broken by shading again.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #694

2018-06-06 Thread Apache Jenkins Server
See 


Changes:

[tgroh] [BEAM-409] Avoiding integer division in ceil

[kenn] Relocate everything shaded by Java SDK harness

[tgroh] Remove "beta" from the Cancel Command Prefix

[jbonofre] [BEAM-1017] Add RedisIO

[rangadi] Kafka exactly-once sink. Tested manually with direct runner and on

[rangadi] Disable other sink tests. Need to fix how tests use global

[rangadi] 1) Add a note about metadata expiration. 2) Fetch number of partitions

[rangadi] Add basic metrics.

[rangadi] Input PCollection has the coder for elements. No need to ask for them

[rangadi] Close producers after one minute of inactivity. This closes producers

[rangadi] assign a random shard id once in setup(), rather than each time in

[rangadi] Improve how we use MockProducer in tests. Remove global instance and 
use

[rangadi] Support version 0.11 through ProducerSpEL (reflection). Tests work 
with

[rangadi] Add runner check. Add withReadCommit() to reader.

[rangadi] update JavaDoc for withEOS().

[rangadi] update JavaDoc for withEOS().

[rangadi] Add missing license header in ProducerSpEL.java.

[kenn] Add RawPTransform.migrate(SdkComponents) for re-serialization

[kenn] Add TransformPayloadTranslator.rehydrate to optionally specialize

[kenn] Add custom rehydration for TestStream

[kenn] Add custom rehydration for Combine

[kenn] Add custom rehydration for ParDo

[kenn] Add custom rehydration for WriteFiles

[kenn] Better error message for RehydratedComponents.getCoder

[kenn] Reinstate proto round trip in Java DirectRunner

[kenn] Fix typo in UnboundedSource deserialization error message

[kenn] Support side inputs in CombineTranslation

[kenn] Add NotSerializable.forUrn to key by URN for non-serializable overrides

[kenn] Clearer getOrDefault style in RehydratedComponents

[altay] Wordcount on fnapi pipeline and IT test.

[kenn] DirectRunner: Replace use of RawPTransform with NotSerializable.forUrn

[tgroh] Update PipelineTest.testReplacedNames

[rangadi] [BEAM-2720] Update kafka client version to 0.11.0.1

[kenn] Improve GcsFileSystem errors messages slightly

[kenn] Add ability to stage explicit file list

[kenn] Stage the portable pipeline in Dataflow

[kenn] Stage the pipeline without using a temp file

[kenn] Add assertion that valid jobs must have staged pipeline

[kenn] Remove duplicate mocking in DataflowRunnerTest

[valentyn] Pin runner harness also for official BEAM releases.

[kenn] Add standalone version of seed job

[altay] Created Java snippets file

[kenn] Unit test to repro NPE in PTransformTranslation

[kenn] Do not crash when RawPTransform has null spec

[chamikara] Avoids generating proto files for Windows if grpcio-tools is not

[chamikara] Adding lull tracking for python sampler

[klk] Clone source to a distinguished subdirectory of Jenkins workspace

[ekirpichov] [BEAM-2682] Deletes AvroIOTransformTest

[kenn] Add dep on Apache-licensed findbugs-annotations implementation

[kenn] Make Java core SDK root dir NonNull by default

[kenn] NonNull by default in sdk/coders

[kenn] NonNull by default in sdk/annotations

[kenn] NonNull by default in sdk/runners

[kenn] NonNull by default in sdk/state

[kenn] NonNull by default for sdk/testing

[kenn] Ignore findbugs in AutoValue generated classes

[kenn] NonNull by default in metrics

[altay] Unit test for label pipeline option

[robertwb] Implement FnApi side inputs in Python.

[github] Increase job_beam_PreCommit_Java_MavenInstall timeout from 2.5 to 4

[kenn] Make the main seed job standalone

[kenn] Increase seed job(s) timeout to 30 minutes

[kenn] Increase seed job(s) timeout to 60 minutes

[kenn] Fix typo in seed jobs

[kenn] Rename seed job so it is first in glob used by prior seed job

[kenn] Fix typo in seed job

[kenn] Rearrange .gitignore slightly

[kenn] Fix RAT exclusions

[kenn] Manage RAT plugin more centrally; only toggle skipping

[kenn] Increase Java postcommit timeout to 240

[kenn] Fix remaining nullability errors

[altay] Add zip to the list of accepted extra package file types.

[klk] Stage the pipeline in Python DataflowRunner

[herohde] [BEAM-3005] Add resource limits to provision proto

[herohde] [BEAM-3005] Set JVM max heap size in java container

[herohde] Declare .go and Dockerfile as text in gitattributes

[herohde] Update rat exclusion for python and Go protos

[herohde] CR: [BEAM-3005] Set JVM max heap size in java container

[altay] Add python_requires to setup.py

[lcwik] [BEAM-2566] Decouple SDK harness from Dataflow runner by elevating

[lcwik] Add missing @RunWith to test.

[kirpichov] Many improvements to TikaIO

[kirpichov] Adds ParseResult.failure()

[kenn] Remove coveralls invocations from all jobs

[klk] Remove extraneous type arguments in PAssert

[klk] Remove extraneous type arguments in Latest.java

[klk] Suppress AutoValue warnings in TextIO

[ekirpichov] Reading spanner schema transform

[klk] NonNull by 

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink_Gradle #693

2018-06-06 Thread Apache Jenkins Server
See 


--
GitHub pull request #3295 of commit 7890d77e4a90ab7773e8fd52d8c4abe31eec8c21, 
has merge conflicts.
Setting status of 7890d77e4a90ab7773e8fd52d8c4abe31eec8c21 to PENDING with url 
https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/693/
 and message: 'Build started sha1 is original commit.'
Using context: Jenkins: Apache Flink Runner ValidatesRunner Tests
[EnvInject] - Loading node environment variables.
Building remotely on beam8 (beam) in workspace 

 > git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
 > git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
 > git --version # timeout=10
 > git fetch --tags --progress https://github.com/apache/beam.git 
 > +refs/heads/*:refs/remotes/origin/* 
 > +refs/pull/3295/*:refs/remotes/origin/pr/3295/*
 > git rev-parse 7890d77e4a90ab7773e8fd52d8c4abe31eec8c21^{commit} # timeout=10
Checking out Revision 7890d77e4a90ab7773e8fd52d8c4abe31eec8c21 (detached)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f 7890d77e4a90ab7773e8fd52d8c4abe31eec8c21
Commit message: "fixup! address comments"
 > git rev-list --no-walk 4761ac342f8488714c17931ca269e00f71309d55 # timeout=10
First time build. Skipping changelog.
Cleaning workspace
 > git rev-parse --verify HEAD # timeout=10
Resetting working tree
 > git reset --hard # timeout=10
 > git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the 
SCM step.
[EnvInject] - Injecting as environment variables the properties content 
SPARK_LOCAL_IP=127.0.0.1

[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
FATAL: The Gradle wrapper has not been found in these directories: 

Build step 'Invoke Gradle script' marked build as failure
Recording test results
ERROR: Step ‘Publish JUnit test result report’ failed: No test report files 
were found. Configuration error?


[jira] [Work logged] (BEAM-4326) Enforce ErrorProne analysis in the fn-execution project

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4326?focusedWorklogId=109626=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109626
 ]

ASF GitHub Bot logged work on BEAM-4326:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:07
Start Date: 07/Jun/18 04:07
Worklog Time Spent: 10m 
  Work Description: cademarkegard commented on issue #5542: [BEAM-4326] 
Enforce ErrorProne analysis in the fn-execution project
URL: https://github.com/apache/beam/pull/5542#issuecomment-395286382
 
 
   thanks @swegner !


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109626)
Time Spent: 1.5h  (was: 1h 20m)

> Enforce ErrorProne analysis in the fn-execution project
> ---
>
> Key: BEAM-4326
> URL: https://issues.apache.org/jira/browse/BEAM-4326
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-java-harness
>Reporter: Scott Wegner
>Assignee: Cade Markegard
>Priority: Minor
>  Labels: errorprone, starter
>  Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> Java ErrorProne static analysis was [recently 
> enabled|https://github.com/apache/beam/pull/5161] in the Gradle build 
> process, but only as warnings. ErrorProne errors are generally useful and 
> easy to fix. Some work was done to [make sdks-java-core 
> ErrorProne-clean|https://github.com/apache/beam/pull/5319] and add 
> enforcement. This task is clean ErrorProne warnings and add enforcement in 
> {{beam-sdks-java-fn-execution}}. Additional context discussed on the [dev 
> list|https://lists.apache.org/thread.html/95aae2785c3cd728c2d3378cbdff2a7ba19caffcd4faa2049d2e2f46@%3Cdev.beam.apache.org%3E].
> Fixing this issue will involve:
> # Follow instructions in the [Contribution 
> Guide|https://beam.apache.org/contribute/] to set up a {{beam}} development 
> environment.
> # Run the following command to compile and run ErrorProne analysis on the 
> project: {{./gradlew :beam-sdks-java-fn-execution:assemble}}
> # Fix each ErrorProne warning from the {{sdks/java/fn-execution}} project.
> # In {{sdks/java/fn-execution/build.gradle}}, add {{failOnWarning: true}} to 
> the call the {{applyJavaNature()}} 
> ([example|https://github.com/apache/beam/pull/5319/files#diff-9390c20635aed5f42f83b97506a87333R20]).
> This starter issue is sponsored by [~swegner]. Feel free to [reach 
> out|https://beam.apache.org/community/contact-us/] with questions or code 
> review:
> * JIRA: [~swegner]
> * GitHub: [@swegner|https://github.com/swegner]
> * Slack: [@Scott Wegner|https://s.apache.org/beam-slack-channel]
> * Email: swegner at google dot com



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3089) Issue with setting the parallelism at client level using Flink runner

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3089?focusedWorklogId=109612=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109612
 ]

ASF GitHub Bot logged work on BEAM-3089:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4766: [BEAM-3089] Fix 
job parallelism resolution
URL: https://github.com/apache/beam/pull/4766#issuecomment-395285650
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109612)
Time Spent: 1h 10m  (was: 1h)

> Issue with setting the parallelism at client level using Flink runner
> -
>
> Key: BEAM-3089
> URL: https://issues.apache.org/jira/browse/BEAM-3089
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 2.0.0
> Environment: I am using Flink 1.2.1 running on Docker, with Task 
> Managers distributed across different VMs as part of a Docker Swarm.
>Reporter: Thalita Vergilio
>Assignee: Grzegorz Kołakowski
>Priority: Major
>  Labels: docker, flink, parallel-deployment
> Attachments: flink-ui-parallelism.png
>
>  Time Spent: 1h 10m
>  Remaining Estimate: 0h
>
> When uploading an Apache Beam application using the Flink Web UI, the 
> parallelism set at job submission doesn't get picked up. The same happens 
> when submitting a job using the Flink CLI.
> In both cases, the parallelism ends up defaulting to 1.
> When I set the parallelism programmatically within the Apache Beam code, it 
> works: {{flinkPipelineOptions.setParallelism(4);}}
> I suspect the root of the problem may be in the 
> org.apache.beam.runners.flink.DefaultParallelismFactory class, as it checks 
> for Flink's GlobalConfiguration, which may not pick up runtime values passed 
> to Flink, then defaults to 1 if it doesn't find anything.
> Any ideas on how this could be fixed or worked around? I need to be able to 
> change the parallelism dynamically, so the programmatic approach won't really 
> work for me, nor will setting the Flink configuration at system level.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3761) Fix Python 3 cmp function

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3761?focusedWorklogId=109611=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109611
 ]

ASF GitHub Bot logged work on BEAM-3761:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4774: [BEAM-3761]Fix 
Python 3 cmp usage
URL: https://github.com/apache/beam/pull/4774#issuecomment-395285646
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109611)
Time Spent: 7.5h  (was: 7h 20m)

> Fix Python 3 cmp function
> -
>
> Key: BEAM-3761
> URL: https://issues.apache.org/jira/browse/BEAM-3761
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: holdenk
>Priority: Major
>  Time Spent: 7.5h
>  Remaining Estimate: 0h
>
> Various functions don't exist in Python 3 that did in python 2. This Jira is 
> to fix the use of cmp (which often will involve rewriting __cmp__ as well).
>  
> Note: there are existing PRs for basestring and unicode ( 
> [https://github.com/apache/beam/pull/4697|https://github.com/apache/beam/pull/4697,]
>  , [https://github.com/apache/beam/pull/4730] )
>  
> Note once all of the missing names/functions are fixed we can enable F821 in 
> falke8 python 3.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-593) Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in FlinkRunnerResult

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-593?focusedWorklogId=109625=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109625
 ]

ASF GitHub Bot logged work on BEAM-593:
---

Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #3295: [BEAM-593] 
Refactor Flink execution as preparation for async job control
URL: https://github.com/apache/beam/pull/3295#issuecomment-395285710
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109625)
Time Spent: 10m
Remaining Estimate: 0h

> Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in 
> FlinkRunnerResult
> ---
>
> Key: BEAM-593
> URL: https://issues.apache.org/jira/browse/BEAM-593
> Project: Beam
>  Issue Type: New Feature
>  Components: runner-flink
>Reporter: Pei He
>Assignee: Aljoscha Krettek
>Priority: Major
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> We introduced both functions to PipelineResult.
> Currently, both of them throw UnsupportedOperationException in Flink runner.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3506) JdbcIO: Support writing iterables (i.e. collections) of rows instead of only single rows

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3506?focusedWorklogId=109623=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109623
 ]

ASF GitHub Bot logged work on BEAM-3506:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4457: [BEAM-3506] - Add 
a feature in JdbcIO that allows writing PCollection>
URL: https://github.com/apache/beam/pull/4457#issuecomment-395285699
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109623)
Time Spent: 10m
Remaining Estimate: 3h 50m  (was: 4h)

> JdbcIO: Support writing iterables (i.e. collections) of rows instead of only 
> single rows
> 
>
> Key: BEAM-3506
> URL: https://issues.apache.org/jira/browse/BEAM-3506
> Project: Beam
>  Issue Type: Improvement
>  Components: z-do-not-use-sdk-java-extensions
>Affects Versions: 2.3.0
>Reporter: Knut Olav Loite
>Assignee: Jean-Baptiste Onofré
>Priority: Minor
>  Labels: JdbcIO, jdbc
> Fix For: Not applicable
>
>   Original Estimate: 4h
>  Time Spent: 10m
>  Remaining Estimate: 3h 50m
>
> The current JdbcIO write interface expects a PCollection where T is the 
> row to be written. Each instance of T is then added to a batch and written to 
> the database. The user has little control over how many rows will be added to 
> one batch. If JdbcIO would also support writing a PCollection> 
> the user would have more control over the number of rows in one batch. 
> Especially when writing to cloud databases, such as Google Cloud Spanner, the 
> batching of multiple rows together is important for performance.
> I already have a solution locally and I will submit a pull request.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3446) RedisIO non-prefix read operations

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3446?focusedWorklogId=109620=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109620
 ]

ASF GitHub Bot logged work on BEAM-3446:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4656: [BEAM-3446] Fixes 
RedisIO non-prefix read operations 
URL: https://github.com/apache/beam/pull/4656#issuecomment-395285681
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109620)
Time Spent: 20m  (was: 10m)

> RedisIO non-prefix read operations
> --
>
> Key: BEAM-3446
> URL: https://issues.apache.org/jira/browse/BEAM-3446
> Project: Beam
>  Issue Type: New Feature
>  Components: io-java-redis
>Reporter: Vinay varma
>Assignee: Jean-Baptiste Onofré
>Priority: Major
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> Read operation in RedisIO is for prefix based look ups. While this can be 
> used for exact key matches as well, the number of operations limits the 
> through put of the function.
> I suggest exposing current readAll operation as readbyprefix and using more 
> simpler operations for readAll functionality.
> ex:
> {code:java}
> String output = jedis.get(element);
> if (output != null) {
> processContext.output(KV.of(element, output));
> }
> {code}
> instead of:
> https://github.com/apache/beam/blob/7d240c0bb171af6868f1a6e95196c9dcfc9ac640/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java#L292



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3740) Prototype of retractions support by DirectRunner

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3740?focusedWorklogId=109619=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109619
 ]

ASF GitHub Bot logged work on BEAM-3740:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4742: 
[BEAM-3740][Draft][WIP][Prototype] Retractions in DirectRunner
URL: https://github.com/apache/beam/pull/4742#issuecomment-395285674
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109619)
Time Spent: 1h 10m  (was: 1h)

> Prototype of retractions support by DirectRunner
> 
>
> Key: BEAM-3740
> URL: https://issues.apache.org/jira/browse/BEAM-3740
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-direct
>Reporter: Anton Kedin
>Assignee: Anton Kedin
>Priority: Major
>  Time Spent: 1h 10m
>  Remaining Estimate: 0h
>
> Build prototype retractions support with DirectRunner to identify correct 
> path forward



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-2535?focusedWorklogId=109613=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109613
 ]

ASF GitHub Bot logged work on BEAM-2535:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4700: [BEAM-2535] Added 
control to set output timestamp independent of firing time for event time 
timers. (Direct Runner implementation)
URL: https://github.com/apache/beam/pull/4700#issuecomment-395285656
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109613)
Time Spent: 3h 40m  (was: 3.5h)

> Allow explicit output time independent of firing specification for all timers
> -
>
> Key: BEAM-2535
> URL: https://issues.apache.org/jira/browse/BEAM-2535
> Project: Beam
>  Issue Type: New Feature
>  Components: beam-model, sdk-java-core
>Reporter: Kenneth Knowles
>Assignee: Batkhuyag Batsaikhan
>Priority: Major
>  Time Spent: 3h 40m
>  Remaining Estimate: 0h
>
> Today, we have insufficient control over the event time timestamp of elements 
> output from a timer callback.
> 1. For an event time timer, it is the timestamp of the timer itself.
>  2. For a processing time timer, it is the current input watermark at the 
> time of processing.
> But for both of these, we may want to reserve the right to output a 
> particular time, aka set a "watermark hold".
> A naive implementation of a {{TimerWithWatermarkHold}} would work for making 
> sure output is not droppable, but does not fully explain window expiration 
> and late data/timer dropping.
> In the natural interpretation of a timer as a feedback loop on a transform, 
> timers should be viewed as another channel of input, with a watermark, and 
> items on that channel _all need event time timestamps even if they are 
> delivered according to a different time domain_.
> I propose that the specification for when a timer should fire should be 
> separated (with nice defaults) from the specification of the event time of 
> resulting outputs. These timestamps will determine a side channel with a new 
> "timer watermark" that constrains the output watermark.
>  - We still need to fire event time timers according to the input watermark, 
> so that event time timers fire.
>  - Late data dropping and window expiration will be in terms of the minimum 
> of the input watermark and the timer watermark. In this way, whenever a timer 
> is set, the window is not going to be garbage collected.
>  - We will need to make sure we have a way to "wake up" a window once it is 
> expired; this may be as simple as exhausting the timer channel as soon as the 
> input watermark indicates expiration of a window
> This is mostly aimed at end-user timers in a stateful+timely {{DoFn}}. It 
> seems reasonable to use timers as an implementation detail (e.g. in 
> runners-core utilities) without wanting any of this additional machinery. For 
> example, if there is no possibility of output from the timer callback.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3648) Support Splittable DoFn in Flink Batch Runner

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3648?focusedWorklogId=109616=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109616
 ]

ASF GitHub Bot logged work on BEAM-3648:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4640: [BEAM-3648] 
Support Splittable DoFn in Flink Batch Runner
URL: https://github.com/apache/beam/pull/4640#issuecomment-395285663
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109616)
Time Spent: 2h 50m  (was: 2h 40m)

> Support Splittable DoFn in Flink Batch Runner
> -
>
> Key: BEAM-3648
> URL: https://issues.apache.org/jira/browse/BEAM-3648
> Project: Beam
>  Issue Type: New Feature
>  Components: runner-flink
>Reporter: Aljoscha Krettek
>Assignee: Aljoscha Krettek
>Priority: Major
>  Time Spent: 2h 50m
>  Remaining Estimate: 0h
>




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-2080) Add custom maven enforcer rules to catch banned classes and dependencies

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-2080?focusedWorklogId=109622=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109622
 ]

ASF GitHub Bot logged work on BEAM-2080:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #2688: [BEAM-2080]: Add a 
custom enforcer rule to check for banned classes.
URL: https://github.com/apache/beam/pull/2688#issuecomment-395285692
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109622)
Time Spent: 10m
Remaining Estimate: 0h

> Add custom maven enforcer rules to catch banned classes and dependencies
> 
>
> Key: BEAM-2080
> URL: https://issues.apache.org/jira/browse/BEAM-2080
> Project: Beam
>  Issue Type: Improvement
>  Components: build-system
>Affects Versions: Not applicable
>Reporter: Vikas Kedigehalli
>Assignee: Vikas Kedigehalli
>Priority: Minor
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> The maven enforcer plugin standard rules aren't sufficient to catch certain 
> issues like:
> * An artifact built as an uber/bundled jar (usually with shade plugin) 
> including banned classes. 
> * An artifact pom that depends on banned dependencies. (bannedDependencies 
> rule provided by enforcer plugin doesn't work always because it doesn't look 
> at the dependency-reduced-pom generated by shade plugin)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3786) Back FileSystem by VFS

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3786?focusedWorklogId=109617=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109617
 ]

ASF GitHub Bot logged work on BEAM-3786:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4803: [BEAM-3786] basic 
vfs filesystem boostrap
URL: https://github.com/apache/beam/pull/4803#issuecomment-395285668
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109617)
Time Spent: 20m  (was: 10m)

> Back FileSystem by VFS
> --
>
> Key: BEAM-3786
> URL: https://issues.apache.org/jira/browse/BEAM-3786
> Project: Beam
>  Issue Type: Task
>  Components: sdk-java-core
>Reporter: Romain Manni-Bucau
>Assignee: Romain Manni-Bucau
>Priority: Major
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> A ticket to not forget the discussion about reusing commons-vfs to benefit 
> from its API and connectivity under the hood and automatically behind beam 
> file[system|io] API.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-867) Support set/delete of timers by ID in Flink runner

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-867?focusedWorklogId=109624=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109624
 ]

ASF GitHub Bot logged work on BEAM-867:
---

Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4119: [BEAM-867] Add 
schema update options to BigQueryIO
URL: https://github.com/apache/beam/pull/4119#issuecomment-395285705
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109624)
Time Spent: 10m
Remaining Estimate: 0h

> Support set/delete of timers by ID in Flink runner
> --
>
> Key: BEAM-867
> URL: https://issues.apache.org/jira/browse/BEAM-867
> Project: Beam
>  Issue Type: New Feature
>  Components: runner-flink
>Reporter: Kenneth Knowles
>Assignee: Aljoscha Krettek
>Priority: Major
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> This is a prerequisite for full support of BEAM-27, and related to BEAM-35.
> My current understanding is that this might be actually removed from Flink 
> itself, and needs implementation in terms of state. It might be reasonable to 
> just remove deletion from Beam; it is just a nice-to-have for user experience 
> IMO, and perhaps a performance help for certain runners.
> (Since I am filing individual tickets for each runner, generalized discussion 
> should probably be on the dev list directly on or BEAM-35)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-2530) Make Beam compatible with next Java LTS version

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-2530?focusedWorklogId=109621=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109621
 ]

ASF GitHub Bot logged work on BEAM-2530:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4497: [BEAM-2530] Make 
classloader handling more compatible with JDK 9
URL: https://github.com/apache/beam/pull/4497#issuecomment-395285689
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109621)
Time Spent: 2h 40m  (was: 2.5h)

> Make Beam compatible with next Java LTS version
> ---
>
> Key: BEAM-2530
> URL: https://issues.apache.org/jira/browse/BEAM-2530
> Project: Beam
>  Issue Type: Improvement
>  Components: build-system
>Affects Versions: Not applicable
>Reporter: Ismaël Mejía
>Priority: Minor
>  Labels: java9
> Fix For: Not applicable
>
>  Time Spent: 2h 40m
>  Remaining Estimate: 0h
>
> The goal of this task is to validate that the Java SDK and the Java Direct 
> Runner (and its tests) work as intended on the next Java LTS version (Java 11 
> /18.9). For this we will base the compilation on the java.base profile and 
> include other core Java modules when needed.  
> *Notes:*
> - Ideally validation of the IOs/extensions will be included but if serious 
> issues are found they will be tracked independently.
> - The goal of using the Java Platform module system is out of the scope of 
> this work.
> - Support for other runners will be a tracked as a separate effort because 
> other runners depend strongly in the support of the native runner ecosystems.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-1251) Python 3 Support

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-1251?focusedWorklogId=109614=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109614
 ]

ASF GitHub Bot logged work on BEAM-1251:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4820: [BEAM-1251] 
Upgrade from buffer to memoryview for Python 3
URL: https://github.com/apache/beam/pull/4820#issuecomment-395285658
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109614)
Time Spent: 9h  (was: 8h 50m)

> Python 3 Support
> 
>
> Key: BEAM-1251
> URL: https://issues.apache.org/jira/browse/BEAM-1251
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Eyad Sibai
>Priority: Trivial
>  Time Spent: 9h
>  Remaining Estimate: 0h
>
> I have been trying to use google datalab with python3. As I see there are 
> several packages that does not support python3 yet which google datalab 
> depends on. This is one of them.
> https://github.com/GoogleCloudPlatform/DataflowPythonSDK/issues/6



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3519) GCP IO exposes netty on its API surface, causing conflicts with runners

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3519?focusedWorklogId=109615=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109615
 ]

ASF GitHub Bot logged work on BEAM-3519:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4651: 
[BEAM-3519][BEAM-3668] Shaded netty related dependencies of 
google-cloud-platform module
URL: https://github.com/apache/beam/pull/4651#issuecomment-395285661
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109615)
Time Spent: 3h 40m  (was: 3.5h)

> GCP IO exposes netty on its API surface, causing conflicts with runners
> ---
>
> Key: BEAM-3519
> URL: https://issues.apache.org/jira/browse/BEAM-3519
> Project: Beam
>  Issue Type: Bug
>  Components: io-java-gcp
>Reporter: Ismaël Mejía
>Assignee: Chamikara Jayalath
>Priority: Critical
>  Time Spent: 3h 40m
>  Remaining Estimate: 0h
>
> Google Cloud Platform IOs module leaks netty this causes conflicts in 
> particular with execution systems that use conflicting versions of such 
> modules. 
>  For the case there is a dependency conflict with the Spark Runner version of 
> netty, see: BEAM-3492



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3314) RedisIO: RedisConnectionConfiguration withEndpoint does not set host correctly.

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3314?focusedWorklogId=109618=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109618
 ]

ASF GitHub Bot logged work on BEAM-3314:


Author: ASF GitHub Bot
Created on: 07/Jun/18 04:01
Start Date: 07/Jun/18 04:01
Worklog Time Spent: 10m 
  Work Description: stale[bot] commented on issue #4228: BEAM-3314 Endpoint 
host port configuration reset issue
URL: https://github.com/apache/beam/pull/4228#issuecomment-395285670
 
 
   This pull request has been marked as stale due to 60 days of inactivity. It 
will be closed in 1 week if no further activity occurs. If you think that’s 
incorrect or this pull request requires a review, please simply write any 
comment. If closed, you can revive the PR at any time and @mention a reviewer 
or discuss it on the d...@beam.apache.org list. Thank you for your 
contributions.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109618)
Time Spent: 1h 50m  (was: 1h 40m)

> RedisIO: RedisConnectionConfiguration withEndpoint does not set host 
> correctly.
> ---
>
> Key: BEAM-3314
> URL: https://issues.apache.org/jira/browse/BEAM-3314
> Project: Beam
>  Issue Type: Bug
>  Components: io-java-redis
>Affects Versions: 2.2.0
>Reporter: Vinay varma
>Assignee: Jean-Baptiste Onofré
>Priority: Minor
>  Time Spent: 1h 50m
>  Remaining Estimate: 0h
>
> {code:java}
> public Read withEndpoint(String host, int port) {
>   checkArgument(host != null, "host can not be null");
>   checkArgument(port > 0, "port can not be negative or 0");
>   return builder()
>   
> .setConnectionConfiguration(connectionConfiguration().withHost(host))
>   
> .setConnectionConfiguration(connectionConfiguration().withPort(port))
>   .build();
> }
> {code}
> think because setConnectionConfiguration sets the object back into the 
> builder, the second set was overwriting the effects of setting the host.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4517) Add maven status in README

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4517?focusedWorklogId=109606=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109606
 ]

ASF GitHub Bot logged work on BEAM-4517:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:23
Start Date: 07/Jun/18 03:23
Worklog Time Spent: 10m 
  Work Description: lukecwik closed pull request #5574: [BEAM-4517] Add 
maven status in README
URL: https://github.com/apache/beam/pull/5574
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git a/README.md b/README.md
index 7d01686f315..16907679631 100644
--- a/README.md
+++ b/README.md
@@ -23,6 +23,7 @@
 
 ## Status
 
+[![Maven 
Version](https://maven-badges.herokuapp.com/maven-central/org.apache.beam/beam-sdks-java-core/badge.svg)](http://search.maven.org/#search|gav|1|g:"org.apache.beam")
 [![Build 
Status](https://builds.apache.org/buildStatus/icon?job=beam_PostCommit_Java_GradleBuild)](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild)
 [![Coverage 
Status](https://coveralls.io/repos/github/apache/beam/badge.svg?branch=master)](https://coveralls.io/github/apache/beam?branch=master)
 


 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109606)
Time Spent: 0.5h  (was: 20m)

> Add maven status in README
> --
>
> Key: BEAM-4517
> URL: https://issues.apache.org/jira/browse/BEAM-4517
> Project: Beam
>  Issue Type: Improvement
>  Components: project-management
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> Add maven status in the README.md file. This is very convenient for users to 
> know the latest release.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109604=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109604
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:22
Start Date: 07/Jun/18 03:22
Worklog Time Spent: 10m 
  Work Description: asfgit commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395280304
 
 
   Error: PR failed in verification; check the Jenkins job for more information.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109604)
Time Spent: 2h  (was: 1h 50m)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 2h
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[beam] 01/01: [BEAM-4517] Add maven status in README

2018-06-06 Thread lcwik
This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 51b6adf3f9376ab32218abd4f08fd9b6dfa364df
Merge: f89e19b bb329c0
Author: Lukasz Cwik 
AuthorDate: Wed Jun 6 20:23:03 2018 -0700

[BEAM-4517] Add maven status in README

 README.md | 1 +
 1 file changed, 1 insertion(+)

-- 
To stop receiving notification emails like this one, please contact
lc...@apache.org.


[beam] branch master updated (f89e19b -> 51b6adf)

2018-06-06 Thread lcwik
This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from f89e19b  Merge pull request #5499: [BEAM-3214] Add integration test 
for HBaseIO.
 add bb329c0  [BEAM-4517] Add maven status in README
 new 51b6adf  [BEAM-4517] Add maven status in README

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 README.md | 1 +
 1 file changed, 1 insertion(+)

-- 
To stop receiving notification emails like this one, please contact
lc...@apache.org.


[beam-site] branch mergebot updated (652fe94 -> 1f618cd)

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a change to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git.


from 652fe94  This closes #459
 add 1f618cd  Prepare repository for deployment.

No new revisions were added by this update.

Summary of changes:
 content/documentation/programming-guide/index.html | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[jira] [Work logged] (BEAM-4517) Add maven status in README

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4517?focusedWorklogId=109602=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109602
 ]

ASF GitHub Bot logged work on BEAM-4517:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:19
Start Date: 07/Jun/18 03:19
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #5574: [BEAM-4517] Add 
maven status in README
URL: https://github.com/apache/beam/pull/5574#issuecomment-395279941
 
 
   Is there a similar badge we can do for PyPi?


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109602)
Time Spent: 20m  (was: 10m)

> Add maven status in README
> --
>
> Key: BEAM-4517
> URL: https://issues.apache.org/jira/browse/BEAM-4517
> Project: Beam
>  Issue Type: Improvement
>  Components: project-management
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> Add maven status in the README.md file. This is very convenient for users to 
> know the latest release.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109601=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109601
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:19
Start Date: 07/Jun/18 03:19
Worklog Time Spent: 10m 
  Work Description: asfgit closed pull request #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git a/content/documentation/programming-guide/index.html 
b/content/documentation/programming-guide/index.html
index 1fc81dac2..03aada34e 100644
--- a/content/documentation/programming-guide/index.html
+++ b/content/documentation/programming-guide/index.html
@@ -2429,8 +2429,7 @@ 6.2. 
Default coders and the CoderR
 
 6.2.1. Looking up a default coder
 
-You can use the method CoderRegistry.getDefaultCoder to determine the 
default
-Coder for a Java type. You can access the CoderRegistry for a given pipeline
+You can use the method CoderRegistry.getCoder to determine the 
default Coder for a Java type. You can access the CoderRegistry for a given pipeline
 by using the method Pipeline.getCoderRegistry. This allows you to 
determine
 (or set) the default Coder for a Java type on a per-pipeline basis: i.e. “for
 this pipeline, verify that Integer values are encoded using


 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109601)
Time Spent: 1h 50m  (was: 1h 40m)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 1h 50m
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[beam-site] branch asf-site updated (c46fc1e -> 1f618cd)

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam-site.git.


from c46fc1e  Prepare repository for deployment.
 add ac0ff06  [BEAM-4479] Fixed document for Coder
 add f5956dc  [BEAM-4479] change getDefaultCoder to getCoder
 add 652fe94  This closes #459
 new 1f618cd  Prepare repository for deployment.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[beam-site] 01/01: Prepare repository for deployment.

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam-site.git

commit 1f618cdf01e35011c79db9d571aec2107ee62cf0
Author: Mergebot 
AuthorDate: Wed Jun 6 20:19:19 2018 -0700

Prepare repository for deployment.
---
 content/documentation/programming-guide/index.html | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/content/documentation/programming-guide/index.html 
b/content/documentation/programming-guide/index.html
index 03aada3..1fc81da 100644
--- a/content/documentation/programming-guide/index.html
+++ b/content/documentation/programming-guide/index.html
@@ -2429,7 +2429,8 @@ The following table shows the standard mapping:
 
 6.2.1. Looking up a default coder
 
-You can use the method CoderRegistry.getCoder to determine the 
default Coder for a Java type. You can access the CoderRegistry for a given pipeline
+You can use the method CoderRegistry.getDefaultCoder to determine the 
default
+Coder for a Java type. You can access the CoderRegistry for a given pipeline
 by using the method Pipeline.getCoderRegistry. This allows you to 
determine
 (or set) the default Coder for a Java type on a per-pipeline basis: i.e. “for
 this pipeline, verify that Integer values are encoded using

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109600=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109600
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:17
Start Date: 07/Jun/18 03:17
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395279433
 
 
   @asfgit merge
   
   Thanks


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109600)
Time Spent: 1h 40m  (was: 1.5h)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 1h 40m
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[beam-site] branch mergebot updated (8ea8d41 -> 652fe94)

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a change to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git.


 discard 8ea8d41  This closes #460
 discard cc50b2e  [BEAM-2852] Update Nexmark documentation with Kafka support
 new ac0ff06  [BEAM-4479] Fixed document for Coder
 new f5956dc  [BEAM-4479] change getDefaultCoder to getCoder
 new 652fe94  This closes #459

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (8ea8d41)
\
 N -- N -- N   refs/heads/mergebot (652fe94)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 content/documentation/programming-guide/index.html |  3 +--
 src/documentation/sdks/nexmark.md  | 26 ++
 2 files changed, 3 insertions(+), 26 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[beam-site] 02/03: [BEAM-4479] change getDefaultCoder to getCoder

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a commit to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git

commit f5956dc525a43fba403c8962e332ee418f041dc0
Author: Xin Wang 
AuthorDate: Wed Jun 6 00:17:03 2018 +0800

[BEAM-4479] change getDefaultCoder to getCoder
---
 content/documentation/programming-guide/index.html | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/content/documentation/programming-guide/index.html 
b/content/documentation/programming-guide/index.html
index 4271fe6..03aada3 100644
--- a/content/documentation/programming-guide/index.html
+++ b/content/documentation/programming-guide/index.html
@@ -2429,7 +2429,7 @@ The following table shows the standard mapping:
 
 6.2.1. Looking up a default coder
 
-You can access the CoderRegistry for a given pipeline
+You can use the method CoderRegistry.getCoder to determine the 
default Coder for a Java type. You can access the CoderRegistry for a given pipeline
 by using the method Pipeline.getCoderRegistry. This allows you to 
determine
 (or set) the default Coder for a Java type on a per-pipeline basis: i.e. “for
 this pipeline, verify that Integer values are encoded using

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109599=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109599
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:16
Start Date: 07/Jun/18 03:16
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395279433
 
 
   @asfgit merge is a mergebot that is meant to merge code in after checks pass 
like on https://github.com/apache/beam-site/pull/456


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109599)
Time Spent: 1.5h  (was: 1h 20m)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[beam-site] 03/03: This closes #459

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a commit to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git

commit 652fe94a65ce24d8a22881937e4f73020d8a7472
Merge: c46fc1e f5956dc
Author: Mergebot 
AuthorDate: Wed Jun 6 20:16:35 2018 -0700

This closes #459

 content/documentation/programming-guide/index.html | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[beam-site] 01/03: [BEAM-4479] Fixed document for Coder

2018-06-06 Thread mergebot-role
This is an automated email from the ASF dual-hosted git repository.

mergebot-role pushed a commit to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git

commit ac0ff06f909ad03ebdff5fcc0ed65ecaf70f7703
Author: Xin Wang 
AuthorDate: Tue Jun 5 21:40:00 2018 +0800

[BEAM-4479] Fixed document for Coder
---
 content/documentation/programming-guide/index.html | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/content/documentation/programming-guide/index.html 
b/content/documentation/programming-guide/index.html
index 1fc81da..4271fe6 100644
--- a/content/documentation/programming-guide/index.html
+++ b/content/documentation/programming-guide/index.html
@@ -2429,8 +2429,7 @@ The following table shows the standard mapping:
 
 6.2.1. Looking up a default coder
 
-You can use the method CoderRegistry.getDefaultCoder to determine the 
default
-Coder for a Java type. You can access the CoderRegistry for a given pipeline
+You can access the CoderRegistry for a given pipeline
 by using the method Pipeline.getCoderRegistry. This allows you to 
determine
 (or set) the default Coder for a Java type on a per-pipeline basis: i.e. “for
 this pipeline, verify that Integer values are encoded using

-- 
To stop receiving notification emails like this one, please contact
mergebot-r...@apache.org.


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109598=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109598
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 07/Jun/18 03:15
Start Date: 07/Jun/18 03:15
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395279433
 
 
   @asfgit merge is a mergebot that is meant to merge code in after checks pass


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109598)
Time Spent: 1h 20m  (was: 1h 10m)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 1h 20m
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4517) Add maven status in README

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4517?focusedWorklogId=109597=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109597
 ]

ASF GitHub Bot logged work on BEAM-4517:


Author: ASF GitHub Bot
Created on: 07/Jun/18 02:50
Start Date: 07/Jun/18 02:50
Worklog Time Spent: 10m 
  Work Description: vesense opened a new pull request #5574: [BEAM-4517] 
Add maven status in README
URL: https://github.com/apache/beam/pull/5574
 
 
   **Please** add a meaningful description for your change here
   
   This is a very minor change. Add maven status in the README.md file. It 
would be convenient for users to know the latest release.
   
   PREVIEW:
   
   
![image](https://user-images.githubusercontent.com/6711230/41075728-97a120b2-6a40-11e8-8608-b7ba7d647af9.png)
   
   
   
   
   Follow this checklist to help us incorporate your contribution quickly and 
easily:
   
- [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in 
ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA 
issue, if applicable. This will automatically link the pull request to the 
issue.
- [ ] If this contribution is large, please file an Apache [Individual 
Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).
   
   It will help us expedite review of your Pull Request if you tag someone 
(e.g. `@username`) to look at it.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109597)
Time Spent: 10m
Remaining Estimate: 0h

> Add maven status in README
> --
>
> Key: BEAM-4517
> URL: https://issues.apache.org/jira/browse/BEAM-4517
> Project: Beam
>  Issue Type: Improvement
>  Components: project-management
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> Add maven status in the README.md file. This is very convenient for users to 
> know the latest release.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4517) Add maven status in README

2018-06-06 Thread Xin Wang (JIRA)
Xin Wang created BEAM-4517:
--

 Summary: Add maven status in README
 Key: BEAM-4517
 URL: https://issues.apache.org/jira/browse/BEAM-4517
 Project: Beam
  Issue Type: Improvement
  Components: project-management
Reporter: Xin Wang
Assignee: Xin Wang


Add maven status in the README.md file. This is very convenient for users to 
know the latest release.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109596=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109596
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 07/Jun/18 02:21
Start Date: 07/Jun/18 02:21
Worklog Time Spent: 10m 
  Work Description: vesense commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395271616
 
 
   @lukecwik Thanks. Seems like you at the wrong person not @asfgit .


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109596)
Time Spent: 1h 10m  (was: 1h)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 1h 10m
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle #438

2018-06-06 Thread Apache Jenkins Server
See 


--
[...truncated 17.24 MB...]
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
View.AsSingleton/Combine.GloballyAsSingletonView/CreateDataflowView as step s9
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding Create123/Read(CreateSource) as step s10
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding OutputSideInputs as step s11
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/Window.Into()/Window.Assign as step 
s12
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
PAssert$33/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous) as step 
s13
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map 
as step s14
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
PAssert$33/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign as step 
s15
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/GatherAllOutputs/GroupByKey as step 
s16
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/GatherAllOutputs/Values/Values/Map as 
step s17
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/RewindowActuals/Window.Assign as step 
s18
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/KeyForDummy/AddKeys/Map as step s19
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
PAssert$33/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections as step 
s20
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/Create.Values/Read(CreateSource) as 
step s21
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/WindowIntoDummy/Window.Assign as step 
s22
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding 
PAssert$33/GroupGlobally/RemoveDummyTriggering/Flatten.PCollections as step s23
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/FlattenDummyAndContents as step s24
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/NeverTrigger/Flatten.PCollections as 
step s25
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/GroupDummyAndContents as step s26
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/Values/Values/Map as step s27
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GroupGlobally/ParDo(Concat) as step s28
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/GetPane/Map as step s29
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/RunChecks as step s30
Jun 07, 2018 2:10:21 AM 
org.apache.beam.runners.dataflow.DataflowPipelineTranslator$Translator addStep
INFO: Adding PAssert$33/VerifyAssertions/ParDo(DefaultConclude) as step s31
Jun 07, 2018 2:10:21 AM org.apache.beam.runners.dataflow.DataflowRunner run
INFO: Staging pipeline description to 
gs://temp-storage-for-validates-runner-tests//viewtest0testsingletonsideinput-jenkins-0607021018-e6f20ae9/output/results/staging/
Jun 07, 2018 2:10:21 AM org.apache.beam.runners.dataflow.util.PackageUtil 
tryStagePackage
INFO: Uploading <71207 bytes, hash alf8PUcH-CVGDhtUuJAqbw> to 

[jira] [Work logged] (BEAM-4488) Contributor's guide needs to document how to install Python SDK from source

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4488?focusedWorklogId=109583=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109583
 ]

ASF GitHub Bot logged work on BEAM-4488:


Author: ASF GitHub Bot
Created on: 07/Jun/18 00:30
Start Date: 07/Jun/18 00:30
Worklog Time Spent: 10m 
  Work Description: alanmyrvold commented on issue #464: [BEAM-4488], 
[BEAM-4489], [BEAM-4490] Improvements to contribution guide
URL: https://github.com/apache/beam-site/pull/464#issuecomment-395255310
 
 
   @aaltay @pabloem PTAL


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109583)
Time Spent: 20m  (was: 10m)

> Contributor's guide needs to document how to install Python SDK from source
> ---
>
> Key: BEAM-4488
> URL: https://issues.apache.org/jira/browse/BEAM-4488
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> Currently it is not documented, though it does appear in the quickstart



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4488) Contributor's guide needs to document how to install Python SDK from source

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4488?focusedWorklogId=109582=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109582
 ]

ASF GitHub Bot logged work on BEAM-4488:


Author: ASF GitHub Bot
Created on: 07/Jun/18 00:29
Start Date: 07/Jun/18 00:29
Worklog Time Spent: 10m 
  Work Description: alanmyrvold opened a new pull request #464: 
[BEAM-4488], [BEAM-4489], [BEAM-4490] Improvements to contribution guide
URL: https://github.com/apache/beam-site/pull/464
 
 
   [BEAM-4488] How to install Python SDK from source
   [BEAM-4489] Document expectations for tools to use with Python
   [BEAM-4490] Document the pull request workflow


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109582)
Time Spent: 10m
Remaining Estimate: 0h

> Contributor's guide needs to document how to install Python SDK from source
> ---
>
> Key: BEAM-4488
> URL: https://issues.apache.org/jira/browse/BEAM-4488
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> Currently it is not documented, though it does appear in the quickstart



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Build failed in Jenkins: beam_PerformanceTests_MongoDBIO_IT #272

2018-06-06 Thread Apache Jenkins Server
See 


Changes:

[szewinho] [BEAM-3214] Add integration test for HBaseIO.

[axelmagn] Fix ProvisionInfo in DockerJobBundleFactory

--
[...truncated 210.84 KB...]
at 
com.google.cloud.dataflow.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:271)
at 
org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:219)
at 
org.apache.beam.runners.core.SimpleDoFnRunner.access$700(SimpleDoFnRunner.java:69)
at 
org.apache.beam.runners.core.SimpleDoFnRunner$DoFnProcessContext.output(SimpleDoFnRunner.java:517)
at 
org.apache.beam.sdk.transforms.DoFnOutputReceivers$WindowedContextOutputReceiver.output(DoFnOutputReceivers.java:42)
at 
org.apache.beam.sdk.transforms.MapElements$1.processElement(MapElements.java:131)
at 
org.apache.beam.sdk.transforms.MapElements$1$DoFnInvoker.invokeProcessElement(Unknown
 Source)
at 
org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:185)
at 
org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:149)
at 
com.google.cloud.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:323)
at 
com.google.cloud.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:43)
at 
com.google.cloud.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:48)
at 
com.google.cloud.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:200)
at 
com.google.cloud.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:158)
at 
com.google.cloud.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:75)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.executeWork(BatchDataflowWorker.java:391)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.doWork(BatchDataflowWorker.java:360)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:288)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.doWork(DataflowBatchWorkerHarness.java:134)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:114)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:101)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
com.mongodb.MongoTimeoutException: Timed out after 3 ms while waiting 
for a server that matches WritableServerSelector. Client view of cluster state 
is {type=UNKNOWN, servers=[{address=35.226.165.236:27017, type=UNKNOWN, 
state=CONNECTING, exception={com.mongodb.MongoSocketOpenException: Exception 
opening socket}, caused by {java.net.SocketTimeoutException: connect timed 
out}}]
at 
com.mongodb.connection.BaseCluster.createTimeoutException(BaseCluster.java:369)
at com.mongodb.connection.BaseCluster.selectServer(BaseCluster.java:101)
at 
com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.(ClusterBinding.java:75)
at 
com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.(ClusterBinding.java:71)
at 
com.mongodb.binding.ClusterBinding.getWriteConnectionSource(ClusterBinding.java:68)
at 
com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:219)
at 
com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:168)
at 
com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:74)
at com.mongodb.Mongo.execute(Mongo.java:781)
at com.mongodb.Mongo$2.execute(Mongo.java:764)
at 
com.mongodb.MongoCollectionImpl.insertMany(MongoCollectionImpl.java:323)
at 
com.mongodb.MongoCollectionImpl.insertMany(MongoCollectionImpl.java:311)
at 
org.apache.beam.sdk.io.mongodb.MongoDbIO$Write$WriteFn.flush(MongoDbIO.java:667)
at 
org.apache.beam.sdk.io.mongodb.MongoDbIO$Write$WriteFn.processElement(MongoDbIO.java:652)
com.mongodb.MongoTimeoutException: Timed out after 3 ms while waiting 
for a server that matches WritableServerSelector. Client view of cluster state 
is {type=UNKNOWN, servers=[{address=35.226.165.236:27017, type=UNKNOWN, 
state=CONNECTING, exception={com.mongodb.MongoSocketOpenException: Exception 
opening socket}, caused by {java.net.SocketTimeoutException: connect timed 
out}}]
at 

Build failed in Jenkins: beam_PerformanceTests_JDBC #691

2018-06-06 Thread Apache Jenkins Server
See 


Changes:

[szewinho] [BEAM-3214] Add integration test for HBaseIO.

[axelmagn] Fix ProvisionInfo in DockerJobBundleFactory

--
[...truncated 286.78 KB...]
INFO: 2018-06-07T00:14:07.088Z: Fusing consumer Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Write into Hash row 
contents/Combine.perKey(Hashing)/GroupByKey/Reify
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.111Z: Fusing consumer 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Reify 
into 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Partial
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.137Z: Fusing consumer 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Reify
 into 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/Window.Into()/Window.Assign
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.164Z: Fusing consumer 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/ExpandIterable
 into 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.203Z: Fusing consumer 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/GroupByWindow
 into 
JdbcIO.Read/JdbcIO.ReadAll/JdbcIO.Reparallelize/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey/Read
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.221Z: Fusing consumer 
PAssert$1/GroupGlobally/GatherAllOutputs/WithKeys/AddKeys/Map into 
PAssert$1/GroupGlobally/GatherAllOutputs/Reify.Window/ParDo(Anonymous)
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.245Z: Fusing consumer Count All/ProduceDefault 
into Count All/CreateVoid/Read(CreateSource)
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.268Z: Fusing consumer 
Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/GroupByKey+Combine.globally(Top(Natural))/Combine.perKey(Top(Natural))/Combine.GroupedValues/Partial
 into Combine.globally(Top(Natural))/WithKeys/AddKeys/Map
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.304Z: Fusing consumer Hash row 
contents/WithKeys/AddKeys/Map into ParDo(SelectName)
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.332Z: Fusing consumer 
PAssert$1/GroupGlobally/KeyForDummy/AddKeys/Map into 
PAssert$1/GroupGlobally/RewindowActuals/Window.Assign
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.353Z: Fusing consumer 
PAssert$1/GroupGlobally/GatherAllOutputs/Values/Values/Map into 
PAssert$1/GroupGlobally/GatherAllOutputs/GroupByKey/GroupByWindow
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.385Z: Fusing consumer 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey+Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/Combine.GroupedValues/Partial
 into Combine.globally(Top(Reversed))/WithKeys/AddKeys/Map
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.421Z: Fusing consumer Hash row 
contents/Combine.perKey(Hashing)/GroupByKey+Hash row 
contents/Combine.perKey(Hashing)/Combine.GroupedValues/Partial into Hash row 
contents/WithKeys/AddKeys/Map
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.445Z: Fusing consumer 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Write 
into 
Combine.globally(Top(Reversed))/Combine.perKey(Top(Reversed))/GroupByKey/Reify
Jun 07, 2018 12:14:13 AM 
org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process
INFO: 2018-06-07T00:14:07.471Z: Fusing consumer 
PAssert$1/GroupGlobally/GatherAllOutputs/Window.Into()/Window.Assign into 

[jira] [Updated] (BEAM-4516) [SQL] Allow casting to complex types

2018-06-06 Thread Anton Kedin (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Anton Kedin updated BEAM-4516:
--
Description: 
Currently CAST is parsed in the main Calcite's Parser.jj. When parsing the 
target type parameter it only supports primitive types or MULTISET). It's 
impossible to cast to an inline fully specified Row type at the moment (Calcite 
1.16).

Probably CREATE TYPE in Calcite 1.17 is worth looking at, it should support CAST

  was:
Currently CAST is parsed in the main Calcite's Parser.jj. When parsing the 
target type parameter it only supports primitive types or MULTISET). It's 
impossible to cast to a fully ad-hoc specified Row at the moment (Calcite 1.16).

Probably CREATE TYPE in Calcite 1.17 is worth looking at, it should support CAST


> [SQL] Allow casting to complex types
> 
>
> Key: BEAM-4516
> URL: https://issues.apache.org/jira/browse/BEAM-4516
> Project: Beam
>  Issue Type: Improvement
>  Components: dsl-sql
>Reporter: Anton Kedin
>Priority: Major
>
> Currently CAST is parsed in the main Calcite's Parser.jj. When parsing the 
> target type parameter it only supports primitive types or MULTISET). It's 
> impossible to cast to an inline fully specified Row type at the moment 
> (Calcite 1.16).
> Probably CREATE TYPE in Calcite 1.17 is worth looking at, it should support 
> CAST



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4516) [SQL] Allow casting to complex types

2018-06-06 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4516:
-

 Summary: [SQL] Allow casting to complex types
 Key: BEAM-4516
 URL: https://issues.apache.org/jira/browse/BEAM-4516
 Project: Beam
  Issue Type: Improvement
  Components: dsl-sql
Reporter: Anton Kedin


Currently CAST is parsed in the main Calcite's Parser.jj. When parsing the 
target type parameter it only supports primitive types or MULTISET). It's 
impossible to cast to a fully ad-hoc specified Row at the moment (Calcite 1.16).

Probably CREATE TYPE in Calcite 1.17 is worth looking at, it should support CAST



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark_Gradle #670

2018-06-06 Thread Apache Jenkins Server
See 




[jira] [Assigned] (BEAM-4490) Contributor's guide needs to document the flow of a Pull Request for new contributors

2018-06-06 Thread Alan Myrvold (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Alan Myrvold reassigned BEAM-4490:
--

Assignee: Alan Myrvold  (was: Melissa Pashniak)

> Contributor's guide needs to document the flow of a Pull Request for new 
> contributors
> -
>
> Key: BEAM-4490
> URL: https://issues.apache.org/jira/browse/BEAM-4490
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>
> Some assumptions and expectations can be made clear e.g. Precommit tests, 
> tagging a reviewer, etc.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Assigned] (BEAM-4488) Contributor's guide needs to document how to install Python SDK from source

2018-06-06 Thread Alan Myrvold (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Alan Myrvold reassigned BEAM-4488:
--

Assignee: Alan Myrvold  (was: Ahmet Altay)

> Contributor's guide needs to document how to install Python SDK from source
> ---
>
> Key: BEAM-4488
> URL: https://issues.apache.org/jira/browse/BEAM-4488
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>
> Currently it is not documented, though it does appear in the quickstart



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Assigned] (BEAM-4489) Contributor's guide needs to document expectations for tools to use with Python

2018-06-06 Thread Alan Myrvold (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Alan Myrvold reassigned BEAM-4489:
--

Assignee: Alan Myrvold  (was: Ahmet Altay)

> Contributor's guide needs to document expectations for tools to use with 
> Python
> ---
>
> Key: BEAM-4489
> URL: https://issues.apache.org/jira/browse/BEAM-4489
> Project: Beam
>  Issue Type: Improvement
>  Components: sdk-py-core
>Reporter: Pablo Estrada
>Assignee: Alan Myrvold
>Priority: Major
>
> Currently it mentions some python utilities, also gradle. We should improve 
> this to be consistent and clear.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4515) [SQL] Support Row construction with named fields

2018-06-06 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4515:
-

 Summary: [SQL] Support Row construction with named fields
 Key: BEAM-4515
 URL: https://issues.apache.org/jira/browse/BEAM-4515
 Project: Beam
  Issue Type: Improvement
  Components: dsl-sql
Reporter: Anton Kedin


Currently Calcite's ROW() constructor only accepts values and doesn't allow 
names, so `INSERT INTO f_row SELECT ROW('asdfasdf', 'sdfsdfsd')` will fail with 
something like this:


`Cannot assign to target field 'f_row' of type RecordType(VARCHAR f_str1, 
VARCHAR f_str2) from source field 'f_row' of type RecordType(VARCHAR EXPR$0, 
VARCHAR EXPR$1)`
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4514) [SQL] Enable flattening configuration

2018-06-06 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4514:
-

 Summary: [SQL] Enable flattening configuration
 Key: BEAM-4514
 URL: https://issues.apache.org/jira/browse/BEAM-4514
 Project: Beam
  Issue Type: Improvement
  Components: dsl-sql
Reporter: Anton Kedin


Currently the calcite projection also flattens the output row in PlannerImpl.
This causes failure when inserting into a table with a ROW field.

E.g. `INSERT INTO table (f_row_destination) SELECT f_row_source` will not work, 
as f_row_source will be flattened into separate fields and won't match the 
destination schema



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Build failed in Jenkins: beam_PerformanceTests_XmlIOIT_HDFS #262

2018-06-06 Thread Apache Jenkins Server
See 


Changes:

[szewinho] [BEAM-3214] Add integration test for HBaseIO.

[axelmagn] Fix ProvisionInfo in DockerJobBundleFactory

--
Started by timer
[EnvInject] - Loading node environment variables.
Building remotely on beam10 (beam) in workspace 

 > git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
 > git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
 > git --version # timeout=10
 > git fetch --tags --progress https://github.com/apache/beam.git 
 > +refs/heads/*:refs/remotes/origin/* 
 > +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
 > git rev-parse origin/master^{commit} # timeout=10
Checking out Revision f89e19ba2983363e049115c26e49477e7f658ac2 (origin/master)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f f89e19ba2983363e049115c26e49477e7f658ac2
Commit message: "Merge pull request #5499: [BEAM-3214] Add integration test for 
HBaseIO."
 > git rev-list --no-walk 72cbd99d6b62bc7ed16dbd1288cd61d54e8bda37 # timeout=10
Cleaning workspace
 > git rev-parse --verify HEAD # timeout=10
Resetting working tree
 > git reset --hard # timeout=10
 > git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the 
SCM step.
[EnvInject] - Injecting as environment variables the properties content 
SPARK_LOCAL_IP=127.0.0.1

[EnvInject] - Variables injected successfully.
[beam_PerformanceTests_XmlIOIT_HDFS] $ /bin/bash -xe 
/tmp/jenkins4668099613338417426.sh
+ gcloud container clusters get-credentials io-datastores --zone=us-central1-a 
--verbosity=debug
DEBUG: Running [gcloud.container.clusters.get-credentials] with arguments: 
[--verbosity: "debug", --zone: "us-central1-a", NAME: "io-datastores"]
Fetching cluster endpoint and auth data.
DEBUG: Saved kubeconfig to /home/jenkins/.kube/config
kubeconfig entry generated for io-datastores.
INFO: Display format "default".
DEBUG: SDK update checks are disabled.
[beam_PerformanceTests_XmlIOIT_HDFS] $ /bin/bash -xe 
/tmp/jenkins1373052280453962566.sh
+ cp /home/jenkins/.kube/config 

[beam_PerformanceTests_XmlIOIT_HDFS] $ /bin/bash -xe 
/tmp/jenkins104901659497018997.sh
+ kubectl 
--kubeconfig=
 create namespace filebasedioithdfs-262
Error from server (AlreadyExists): namespaces "filebasedioithdfs-262" already 
exists
Build step 'Execute shell' marked build as failure


[jira] [Work logged] (BEAM-3255) Update release process to use Gradle

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3255?focusedWorklogId=109575=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109575
 ]

ASF GitHub Bot logged work on BEAM-3255:


Author: ASF GitHub Bot
Created on: 06/Jun/18 23:21
Start Date: 06/Jun/18 23:21
Worklog Time Spent: 10m 
  Work Description: boyuanzz commented on issue #424: [BEAM-3255] Updating 
release guide to use Gradle commands
URL: https://github.com/apache/beam-site/pull/424#issuecomment-395244298
 
 
   Re: @robertwb, I think so. @alanmyrvold what do you think?


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109575)
Time Spent: 10h 20m  (was: 10h 10m)

> Update release process to use Gradle
> 
>
> Key: BEAM-3255
> URL: https://issues.apache.org/jira/browse/BEAM-3255
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Luke Cwik
>Assignee: Alan Myrvold
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 10h 20m
>  Remaining Estimate: 0h
>
> This task is about configuring Gradle to generate pom's and artifacts 
> required to perform a release and update the nightly release snapshot Jenkins 
> jobs found here 
> https://github.com/apache/beam/blob/master/.test-infra/jenkins/job_beam_Release_NightlySnapshot.groovy
> We will also require some integration tests to run against the released 
> nightly snapshot artifacts to ensure that what was built is valid.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3255) Update release process to use Gradle

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3255?focusedWorklogId=109573=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109573
 ]

ASF GitHub Bot logged work on BEAM-3255:


Author: ASF GitHub Bot
Created on: 06/Jun/18 23:12
Start Date: 06/Jun/18 23:12
Worklog Time Spent: 10m 
  Work Description: boyuanzz commented on issue #424: [BEAM-3255] Updating 
release guide to use Gradle commands
URL: https://github.com/apache/beam-site/pull/424#issuecomment-395242643
 
 
   Hey @alanmyrvold @robertwb , please review this commit: 
https://github.com/apache/beam-site/pull/424/commits/ab15c1bb19ac20c97652cca1c7fc085f6d1b6709
 . Thanks!


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109573)
Time Spent: 10h 10m  (was: 10h)

> Update release process to use Gradle
> 
>
> Key: BEAM-3255
> URL: https://issues.apache.org/jira/browse/BEAM-3255
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Luke Cwik
>Assignee: Alan Myrvold
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 10h 10m
>  Remaining Estimate: 0h
>
> This task is about configuring Gradle to generate pom's and artifacts 
> required to perform a release and update the nightly release snapshot Jenkins 
> jobs found here 
> https://github.com/apache/beam/blob/master/.test-infra/jenkins/job_beam_Release_NightlySnapshot.groovy
> We will also require some integration tests to run against the released 
> nightly snapshot artifacts to ensure that what was built is valid.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4267) Implement a reusable library that can run an ExecutableStage with a given Environment

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4267?focusedWorklogId=109572=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109572
 ]

ASF GitHub Bot logged work on BEAM-4267:


Author: ASF GitHub Bot
Created on: 06/Jun/18 23:10
Start Date: 06/Jun/18 23:10
Worklog Time Spent: 10m 
  Work Description: axelmagn commented on issue #5573: [BEAM-4267] 
Implement flink context factory methods
URL: https://github.com/apache/beam/pull/5573#issuecomment-395242408
 
 
   As discussed offline, I'm going to hand this off to you (@bsidhom) since you 
have a branch with some work on this already, and it connects well with the 
other stuff you've been working on.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109572)
Time Spent: 2.5h  (was: 2h 20m)

> Implement a reusable library that can run an ExecutableStage with a given 
> Environment
> -
>
> Key: BEAM-4267
> URL: https://issues.apache.org/jira/browse/BEAM-4267
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Axel Magnuson
>Assignee: Ben Sidhom
>Priority: Major
>  Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> Build off of the interfaces introduced in 
> [BEAM-3327|https://github.com/apache/beam/pull/5152] to provide a reusable 
> execution library to runners.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3981) Futurize and fix python 2 compatibility for coders package

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3981?focusedWorklogId=109571=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109571
 ]

ASF GitHub Bot logged work on BEAM-3981:


Author: ASF GitHub Bot
Created on: 06/Jun/18 22:41
Start Date: 06/Jun/18 22:41
Worklog Time Spent: 10m 
  Work Description: robertwb commented on issue #5053: [BEAM-3981] Futurize 
coders subpackage
URL: https://github.com/apache/beam/pull/5053#issuecomment-395236495
 
 
   `dict.items()` should have the same performance when compiled with Cython, 
as it unpacks it into item-iterating code without the function call (or 
intermediate object generation). Having two cases for Py2 and Py3 will break 
this optimization (as well as the fact that the case checking code could be 
(relatively) expensive for small dicts.)


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109571)
Time Spent: 19h 20m  (was: 19h 10m)

> Futurize and fix python 2 compatibility for coders package
> --
>
> Key: BEAM-3981
> URL: https://issues.apache.org/jira/browse/BEAM-3981
> Project: Beam
>  Issue Type: Sub-task
>  Components: sdk-py-core
>Reporter: Robbe
>Assignee: Robbe
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 19h 20m
>  Remaining Estimate: 0h
>
> Run automatic conversion with futurize tool on coders subpackage and fix 
> python 2 compatibility. This prepares the subpackage for python 3 support.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3255) Update release process to use Gradle

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3255?focusedWorklogId=109569=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109569
 ]

ASF GitHub Bot logged work on BEAM-3255:


Author: ASF GitHub Bot
Created on: 06/Jun/18 22:39
Start Date: 06/Jun/18 22:39
Worklog Time Spent: 10m 
  Work Description: boyuanzz commented on a change in pull request #424: 
[BEAM-3255] Updating release guide to use Gradle commands
URL: https://github.com/apache/beam-site/pull/424#discussion_r193580872
 
 

 ##
 File path: src/contribute/release-guide.md
 ##
 @@ -334,14 +404,14 @@ candidate into the source tree of the website.
 Add the new Javadoc to [SDK API Reference page]({{ site.baseurl 
}}/documentation/sdks/javadoc/) page, as follows:
 
 * Unpack the Maven artifact `org.apache.beam:beam-sdks-java-javadoc` into some 
temporary location. Call this `${JAVADOC_TMP}`.
-* Copy the generated Javadoc into the website repository: `cp -r 
${JAVADOC_TMP} src/documentation/sdks/javadoc/${VERSION}`.
+* Copy the generated Javadoc into the website repository: `cp -r 
${JAVADOC_TMP} src/documentation/sdks/javadoc/${RELEASE}`.
 * Set up the necessary git commands to account for the new and deleted files 
from the javadoc.
 * Update the Javadoc link on this page to point to the new version (in 
`src/documentation/sdks/javadoc/current.md`).
 
  Create Pydoc
 Add the new Pydoc to [SDK API Reference page]({{ site.baseurl 
}}/documentation/sdks/pydoc/) page, as follows:
 
-* Copy the generated Pydoc into the website repository: `cp -r ${PYDOC_ROOT} 
src/documentation/sdks/pydoc/${VERSION}`.
+* Copy the generated Pydoc into the website repository: `cp -r ${PYDOC_ROOT} 
src/documentation/sdks/pydoc/${RELEASE}`.
 * Remove `.doctrees` directory.
 * Update the Pydoc link on this page to point to the new version (in 
`src/documentation/sdks/pydoc/current.md`).
 
 
 Review comment:
   I think this step will push RC1 tag to github: 
https://github.com/pabloem/beam-site/blob/372c93ecbafbf3a1440492df1e12050dfe939e91/src/contribute/release-guide.md#build-and-stage-java-artifacts-with-maven


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109569)
Time Spent: 10h  (was: 9h 50m)

> Update release process to use Gradle
> 
>
> Key: BEAM-3255
> URL: https://issues.apache.org/jira/browse/BEAM-3255
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Luke Cwik
>Assignee: Alan Myrvold
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 10h
>  Remaining Estimate: 0h
>
> This task is about configuring Gradle to generate pom's and artifacts 
> required to perform a release and update the nightly release snapshot Jenkins 
> jobs found here 
> https://github.com/apache/beam/blob/master/.test-infra/jenkins/job_beam_Release_NightlySnapshot.groovy
> We will also require some integration tests to run against the released 
> nightly snapshot artifacts to ensure that what was built is valid.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Commented] (BEAM-4256) Gradle setupVirtualenv task fails on Jenkins

2018-06-06 Thread Udi Meiri (JIRA)


[ 
https://issues.apache.org/jira/browse/BEAM-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503991#comment-16503991
 ] 

Udi Meiri commented on BEAM-4256:
-

Is this still happening?

> Gradle setupVirtualenv task fails on Jenkins
> 
>
> Key: BEAM-4256
> URL: https://issues.apache.org/jira/browse/BEAM-4256
> Project: Beam
>  Issue Type: Bug
>  Components: sdk-py-core
>Reporter: Łukasz Gajowy
>Assignee: Ahmet Altay
>Priority: Critical
>
> AFAIK the setupVirtualenv task should run "pip install" command in the 
> virtual environment. This works on my local machine, yet on Jenkins, when we 
> run:
> {code:java}
> gradlew clean install -xcheck --stacktrace{code}
>  from within PerfkitBenchmarker tool, we get the following stacktrace:
> {code:java}
> > Task :beam-sdks-python:setupVirtualenv
> Collecting tox==3.0.0
> Using cached 
> https://files.pythonhosted.org/packages/e6/41/4dcfd713282bf3213b0384320fa8841e4db032ddcb80bc08a540159d42a8/tox-3.0.0-py2.py3-none-any.whl
> Collecting grpcio-tools==1.3.5
> Using cached 
> https://files.pythonhosted.org/packages/05/f6/0296e29b1bac6f85d2a8556d48adf825307f73109a3c2c17fb734292db0a/grpcio_tools-1.3.5-cp27-cp27mu-manylinux1_x86_64.whl
> Collecting pluggy<1.0,>=0.3.0 (from tox==3.0.0)
> Using cached 
> https://files.pythonhosted.org/packages/82/05/43e3947125a2137cba4746135c75934ceed1863f27e050fc560052104a71/pluggy-0.6.0-py2-none-any.whl
> Requirement not upgraded as not directly required: six in 
> /usr/local/lib/python2.7/dist-packages (from tox==3.0.0) (1.11.0)
> Requirement not upgraded as not directly required: virtualenv>=1.11.2 in 
> /usr/lib/python2.7/dist-packages (from tox==3.0.0) (15.0.1)
> Collecting py>=1.4.17 (from tox==3.0.0)
> Using cached 
> https://files.pythonhosted.org/packages/67/a5/f77982214dd4c8fd104b066f249adea2c49e25e8703d284382eb5e9ab35a/py-1.5.3-py2.py3-none-any.whl
> Collecting grpcio>=1.3.5 (from grpcio-tools==1.3.5)
> Using cached 
> https://files.pythonhosted.org/packages/0d/54/b647a6323be6526be27b2c90bb042769f1a7a6e59bd1a5f2eeb795bfece4/grpcio-1.11.0-cp27-cp27mu-manylinux1_x86_64.whl
> Collecting protobuf>=3.2.0 (from grpcio-tools==1.3.5)
> Using cached 
> https://files.pythonhosted.org/packages/9d/61/54c3a9cfde6ffe0ca6a1786ddb8874263f4ca32e7693ad383bd8cf935015/protobuf-3.5.2.post1-cp27-cp27mu-manylinux1_x86_64.whl
> Requirement not upgraded as not directly required: enum34>=1.0.4 in 
> /usr/local/lib/python2.7/dist-packages (from 
> grpcio>=1.3.5->grpcio-tools==1.3.5) (1.1.6)
> Collecting futures>=2.2.0 (from grpcio>=1.3.5->grpcio-tools==1.3.5)
> Using cached 
> https://files.pythonhosted.org/packages/2d/99/b2c4e9d5a30f6471e410a146232b4118e697fa3ffc06d6a65efde84debd0/futures-3.2.0-py2-none-any.whl
> Requirement not upgraded as not directly required: setuptools in 
> /usr/local/lib/python2.7/dist-packages (from 
> protobuf>=3.2.0->grpcio-tools==1.3.5) (39.0.1)
> Installing collected packages: pluggy, py, tox, protobuf, futures, grpcio, 
> grpcio-tools
> Could not install packages due to an EnvironmentError: [Errno 13] Permission 
> denied: '/usr/local/lib/python2.7/dist-packages/pluggy-0.6.0.dist-info'
> Consider using the `--user` option or check the permissions.
> > Task :beam-model-job-management:shadowJar
> > Task :beam-sdks-python:setupVirtualenv FAILED
> > Task :beam-model-job-management:jar
> > Task :beam-model-fn-execution:shadowJar
> > Task :beam-sdks-java-core:shadowJar
> Deprecated Gradle features were used in this build, making it incompatible 
> with Gradle 5.0.
> See 
> https://docs.gradle.org/4.7/userguide/command_line_interface.html#sec:command_line_warnings
> BUILD FAILED in 44s
> 133 actionable tasks: 126 executed, 5 from cache, 2 up-to-date{code}
> It looks as if the virtualenv is not used while installing the needed 
> dependencies (why is it trying to install pluggy in /usr/local/lib?). 
> Therefore it throws "PermissionDenied" exception.
>  This affects all Performance tests on Beam's Jenkins. Currently none of the 
> Jenkins jobs can build the whole repository code before the benchmark is 
> started.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4267) Implement a reusable library that can run an ExecutableStage with a given Environment

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4267?focusedWorklogId=109567=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109567
 ]

ASF GitHub Bot logged work on BEAM-4267:


Author: ASF GitHub Bot
Created on: 06/Jun/18 22:15
Start Date: 06/Jun/18 22:15
Worklog Time Spent: 10m 
  Work Description: bsidhom commented on a change in pull request #5573: 
[BEAM-4267] Implement flink context factory methods
URL: https://github.com/apache/beam/pull/5573#discussion_r193576123
 
 

 ##
 File path: 
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageContext.java
 ##
 @@ -37,11 +43,18 @@
   }
 
   public static Factory batchFactory() {
-return null;
+return jobInfo -> {
 
 Review comment:
   This "factory" should manage singleton state in this case. We want to make 
sure there's only a single instance of a DockerJobBundleFactory for a given job 
id. In order to do so, the factory itself needs to be a singleton.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109567)
Time Spent: 2h 20m  (was: 2h 10m)

> Implement a reusable library that can run an ExecutableStage with a given 
> Environment
> -
>
> Key: BEAM-4267
> URL: https://issues.apache.org/jira/browse/BEAM-4267
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Axel Magnuson
>Assignee: Ben Sidhom
>Priority: Major
>  Time Spent: 2h 20m
>  Remaining Estimate: 0h
>
> Build off of the interfaces introduced in 
> [BEAM-3327|https://github.com/apache/beam/pull/5152] to provide a reusable 
> execution library to runners.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3981) Futurize and fix python 2 compatibility for coders package

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3981?focusedWorklogId=109566=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109566
 ]

ASF GitHub Bot logged work on BEAM-3981:


Author: ASF GitHub Bot
Created on: 06/Jun/18 22:08
Start Date: 06/Jun/18 22:08
Worklog Time Spent: 10m 
  Work Description: tvalentyn commented on issue #5053: [BEAM-3981] 
Futurize coders subpackage
URL: https://github.com/apache/beam/pull/5053#issuecomment-395229849
 
 
   An update on `dict.iteritems` vs `dict.items()` vs 
`future.utils.iteritems(dict)` - I did more performance testing of 
encode-decode operation using a microbenchmark (currently in flight: 
https://github.com/apache/beam/pull/5565). 
   
   I don't observe a difference in performance of `dict.iteritems()` and 
`future.utils.iteritems(dict)`. 
   
   As far as `dict.items()` vs `dict.iteritems()` goes, I saw a 2x performance 
slowdown in coder implementation with dict.items() for dictionaries with over 
10 entries, but did not observe a significant difference on dictionaries 
with 1 entries or less. That said I think it would not hurt to keep using 
`iteritems()` for Python 2 as we do now.
   
   With `future.utils.iteritems()`:
   
   ```
   Median time cost:
   Dict[int, int], FastPrimitiveCoder : per element median time cost: 
3.27529e-07 sec  
   ```
   With `dict.iteritems()`:
   ```
   Median time cost:
   Dict[int, int], FastPrimitiveCoder : per element median time cost: 
3.4485e-07 sec
   ```
   With `dict.items()`:
   
   ```
   Median time cost:
   Dict[int, int], FastPrimitiveCoder : per element median time cost: 
7.3393e-07 sec
   ```
   
   I also observe a 2.5x degradation in coder implementation with 
`builtins.range()` compared to `range()` on lists as small as 1000 - 1 
elements. I did not try smaller lists.
   
   With 1 elements, python 2 `range()`:
   ```
   Median time cost:
   List[int], FastPrimitiveCoder  : per element median time cost: 
1.17695e-07 sec
   ```
   
   With `builtins.range():`
   ```
   Median time cost:
   List[int], FastPrimitiveCoder  : per element median time cost: 
3.22402e-07 sec
   ```
   
   We should try to use microbenchmarks for performance evaluations moving 
forward since they can provide feedback in a matter of seconds.
   
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109566)
Time Spent: 19h 10m  (was: 19h)

> Futurize and fix python 2 compatibility for coders package
> --
>
> Key: BEAM-3981
> URL: https://issues.apache.org/jira/browse/BEAM-3981
> Project: Beam
>  Issue Type: Sub-task
>  Components: sdk-py-core
>Reporter: Robbe
>Assignee: Robbe
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 19h 10m
>  Remaining Estimate: 0h
>
> Run automatic conversion with futurize tool on coders subpackage and fix 
> python 2 compatibility. This prepares the subpackage for python 3 support.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4267) Implement a reusable library that can run an ExecutableStage with a given Environment

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4267?focusedWorklogId=109561=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109561
 ]

ASF GitHub Bot logged work on BEAM-4267:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:53
Start Date: 06/Jun/18 21:53
Worklog Time Spent: 10m 
  Work Description: axelmagn commented on issue #5573: [BEAM-4267] 
Implement flink context factory methods
URL: https://github.com/apache/beam/pull/5573#issuecomment-395226232
 
 
   Okay, ready for review.
   
   R: @bsidhom 
   CC: @jkff @angoenka 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109561)
Time Spent: 2h 10m  (was: 2h)

> Implement a reusable library that can run an ExecutableStage with a given 
> Environment
> -
>
> Key: BEAM-4267
> URL: https://issues.apache.org/jira/browse/BEAM-4267
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Axel Magnuson
>Assignee: Ben Sidhom
>Priority: Major
>  Time Spent: 2h 10m
>  Remaining Estimate: 0h
>
> Build off of the interfaces introduced in 
> [BEAM-3327|https://github.com/apache/beam/pull/5152] to provide a reusable 
> execution library to runners.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3255) Update release process to use Gradle

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3255?focusedWorklogId=109560=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109560
 ]

ASF GitHub Bot logged work on BEAM-3255:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:52
Start Date: 06/Jun/18 21:52
Worklog Time Spent: 10m 
  Work Description: alanmyrvold commented on a change in pull request #424: 
[BEAM-3255] Updating release guide to use Gradle commands
URL: https://github.com/apache/beam-site/pull/424#discussion_r193571012
 
 

 ##
 File path: src/contribute/release-guide.md
 ##
 @@ -334,14 +404,14 @@ candidate into the source tree of the website.
 Add the new Javadoc to [SDK API Reference page]({{ site.baseurl 
}}/documentation/sdks/javadoc/) page, as follows:
 
 * Unpack the Maven artifact `org.apache.beam:beam-sdks-java-javadoc` into some 
temporary location. Call this `${JAVADOC_TMP}`.
-* Copy the generated Javadoc into the website repository: `cp -r 
${JAVADOC_TMP} src/documentation/sdks/javadoc/${VERSION}`.
+* Copy the generated Javadoc into the website repository: `cp -r 
${JAVADOC_TMP} src/documentation/sdks/javadoc/${RELEASE}`.
 * Set up the necessary git commands to account for the new and deleted files 
from the javadoc.
 * Update the Javadoc link on this page to point to the new version (in 
`src/documentation/sdks/javadoc/current.md`).
 
  Create Pydoc
 Add the new Pydoc to [SDK API Reference page]({{ site.baseurl 
}}/documentation/sdks/pydoc/) page, as follows:
 
-* Copy the generated Pydoc into the website repository: `cp -r ${PYDOC_ROOT} 
src/documentation/sdks/pydoc/${VERSION}`.
+* Copy the generated Pydoc into the website repository: `cp -r ${PYDOC_ROOT} 
src/documentation/sdks/pydoc/${RELEASE}`.
 * Remove `.doctrees` directory.
 * Update the Pydoc link on this page to point to the new version (in 
`src/documentation/sdks/pydoc/current.md`).
 
 
 Review comment:
   Need to push the RC1 tag to github?
   And verify that the cythonized built python artifacts are on dist.apache.org 
along with the source?


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109560)
Time Spent: 9h 50m  (was: 9h 40m)

> Update release process to use Gradle
> 
>
> Key: BEAM-3255
> URL: https://issues.apache.org/jira/browse/BEAM-3255
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Luke Cwik
>Assignee: Alan Myrvold
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 9h 50m
>  Remaining Estimate: 0h
>
> This task is about configuring Gradle to generate pom's and artifacts 
> required to perform a release and update the nightly release snapshot Jenkins 
> jobs found here 
> https://github.com/apache/beam/blob/master/.test-infra/jenkins/job_beam_Release_NightlySnapshot.groovy
> We will also require some integration tests to run against the released 
> nightly snapshot artifacts to ensure that what was built is valid.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3255) Update release process to use Gradle

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3255?focusedWorklogId=109557=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109557
 ]

ASF GitHub Bot logged work on BEAM-3255:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:48
Start Date: 06/Jun/18 21:48
Worklog Time Spent: 10m 
  Work Description: alanmyrvold commented on a change in pull request #424: 
[BEAM-3255] Updating release guide to use Gradle commands
URL: https://github.com/apache/beam-site/pull/424#discussion_r193569851
 
 

 ##
 File path: src/contribute/release-guide.md
 ##
 @@ -289,30 +355,34 @@ Copy the source release to the dev repository of 
`dist.apache.org`.
 
 1. Make a directory for the new release:
 
-mkdir beam/${VERSION}
-cd beam/${VERSION}
+mkdir beam/${RELEASE}
+cd beam/${RELEASE}
 
-1. Copy and rename the Beam source distribution, hashes, and GPG signature:
+1. Download source zip from GitHub:
 
-cp ${BEAM_ROOT}/target/apache-beam-${VERSION}-source-release.zip .
-cp ${BEAM_ROOT}/target/apache-beam-${VERSION}-source-release.zip.asc .
-cp ${BEAM_ROOT}/sdks/python/target/apache-beam-${VERSION}.zip 
apache-beam-${VERSION}-python.zip
+wget https://github.com/apache/beam/archive/release-${RELEASE}.zip \
+ -O apache-beam-${RELEASE}-source-release.zip
 
-1. Create hashes for source files and sign the python source file file
+1. Create hashes and sign the source distribution:
 
-sha512sum apache-beam-${VERSION}-source-release.zip > 
apache-beam-${VERSION}-source-release.zip.sha512
-gpg --armor --detach-sig apache-beam-${VERSION}-python.zip
-sha512sum apache-beam-${VERSION}-python.zip > 
apache-beam-${VERSION}-python.zip.sha512
+gpg --armor --detach-sig apache-beam-${RELEASE}-source-release.zip
+sha512sum apache-beam-${RELEASE}-source-release.zip > 
apache-beam-${RELEASE}-source-release.zip.sha512
 
 1. Add and commit all the files.
 
-svn add beam/${VERSION}
+svn add beam/${RELEASE}
 svn commit
 
 1. Verify that files are 
[present](https://dist.apache.org/repos/dist/dev/beam).
 
 
 Review comment:
   Need a step to build the python binaries and stage on 
dist.apache.org/dev/beam, like 
https://dist.apache.org/repos/dist/dev/beam/2.5.0/


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109557)
Time Spent: 9h 40m  (was: 9.5h)

> Update release process to use Gradle
> 
>
> Key: BEAM-3255
> URL: https://issues.apache.org/jira/browse/BEAM-3255
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Luke Cwik
>Assignee: Alan Myrvold
>Priority: Major
> Fix For: Not applicable
>
>  Time Spent: 9h 40m
>  Remaining Estimate: 0h
>
> This task is about configuring Gradle to generate pom's and artifacts 
> required to perform a release and update the nightly release snapshot Jenkins 
> jobs found here 
> https://github.com/apache/beam/blob/master/.test-infra/jenkins/job_beam_Release_NightlySnapshot.groovy
> We will also require some integration tests to run against the released 
> nightly snapshot artifacts to ensure that what was built is valid.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4267) Implement a reusable library that can run an ExecutableStage with a given Environment

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4267?focusedWorklogId=109556=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109556
 ]

ASF GitHub Bot logged work on BEAM-4267:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:45
Start Date: 06/Jun/18 21:45
Worklog Time Spent: 10m 
  Work Description: axelmagn commented on issue #5573: [BEAM-4267] 
Implement flink context factory methods
URL: https://github.com/apache/beam/pull/5573#issuecomment-395224104
 
 
   Do not merge yet.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109556)
Time Spent: 2h  (was: 1h 50m)

> Implement a reusable library that can run an ExecutableStage with a given 
> Environment
> -
>
> Key: BEAM-4267
> URL: https://issues.apache.org/jira/browse/BEAM-4267
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Axel Magnuson
>Assignee: Ben Sidhom
>Priority: Major
>  Time Spent: 2h
>  Remaining Estimate: 0h
>
> Build off of the interfaces introduced in 
> [BEAM-3327|https://github.com/apache/beam/pull/5152] to provide a reusable 
> execution library to runners.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4267) Implement a reusable library that can run an ExecutableStage with a given Environment

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4267?focusedWorklogId=109555=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109555
 ]

ASF GitHub Bot logged work on BEAM-4267:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:34
Start Date: 06/Jun/18 21:34
Worklog Time Spent: 10m 
  Work Description: axelmagn opened a new pull request #5573: [BEAM-4267] 
Implement flink context factory methods
URL: https://github.com/apache/beam/pull/5573
 
 
   Implement the previously unsupported batchFactory and getStageBundleFactory 
methods within FlinkExecutableStageContext.  These are the core methods 
relevant to BEAM-4267, but it does not close the bug.
   
   
   Follow this checklist to help us incorporate your contribution quickly and 
easily:
   
- [x] Format the pull request title like `[BEAM-XXX] Fixes bug in 
ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA 
issue, if applicable. This will automatically link the pull request to the 
issue.
- [ ] If this contribution is large, please file an Apache [Individual 
Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).
   
   It will help us expedite review of your Pull Request if you tag someone 
(e.g. `@username`) to look at it.
   


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109555)
Time Spent: 1h 50m  (was: 1h 40m)

> Implement a reusable library that can run an ExecutableStage with a given 
> Environment
> -
>
> Key: BEAM-4267
> URL: https://issues.apache.org/jira/browse/BEAM-4267
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Axel Magnuson
>Assignee: Ben Sidhom
>Priority: Major
>  Time Spent: 1h 50m
>  Remaining Estimate: 0h
>
> Build off of the interfaces introduced in 
> [BEAM-3327|https://github.com/apache/beam/pull/5152] to provide a reusable 
> execution library to runners.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4513) Slack self-service join link is outdated on "Contact us" page

2018-06-06 Thread Mikhail Gryzykhin (JIRA)
Mikhail Gryzykhin created BEAM-4513:
---

 Summary: Slack self-service join link is outdated on "Contact us" 
page
 Key: BEAM-4513
 URL: https://issues.apache.org/jira/browse/BEAM-4513
 Project: Beam
  Issue Type: Bug
  Components: website
Reporter: Mikhail Gryzykhin
Assignee: Melissa Pashniak


On [https://beam.apache.org/community/contact-us/] page there is section for 
slack that contains "Join" link.

That link gets outdated every month. 

We want to either get automated way to get this link valid, or specify 
alternative way to getting on slack.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4477) Support EXISTS operator

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4477?focusedWorklogId=109551=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109551
 ]

ASF GitHub Bot logged work on BEAM-4477:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:20
Start Date: 06/Jun/18 21:20
Worklog Time Spent: 10m 
  Work Description: vectorijk commented on issue #5567: [BEAM-4477] support 
EXISTS operator
URL: https://github.com/apache/beam/pull/5567#issuecomment-394983933
 
 
   R: @kennknowles
   cc: @akedin @apilloud @XuMingmin 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109551)
Time Spent: 0.5h  (was: 20m)

> Support EXISTS operator
> ---
>
> Key: BEAM-4477
> URL: https://issues.apache.org/jira/browse/BEAM-4477
> Project: Beam
>  Issue Type: Sub-task
>  Components: dsl-sql
>Reporter: Kai Jiang
>Assignee: Kai Jiang
>Priority: Major
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4311) Enforce ErrorProne analysis in Flink runner project

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4311?focusedWorklogId=109549=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109549
 ]

ASF GitHub Bot logged work on BEAM-4311:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:13
Start Date: 06/Jun/18 21:13
Worklog Time Spent: 10m 
  Work Description: iemejia commented on issue #5572: [BEAM-4311] Enforce 
ErrorProne analysis in Flink runner
URL: https://github.com/apache/beam/pull/5572#issuecomment-395215687
 
 
   These are mostly static analysis needed fixes to be compatible with the 
Errorprone tool, mind to take a look @aljoscha, thx.
   R: @aljoscha 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109549)
Time Spent: 0.5h  (was: 20m)

> Enforce ErrorProne analysis in Flink runner project
> ---
>
> Key: BEAM-4311
> URL: https://issues.apache.org/jira/browse/BEAM-4311
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Scott Wegner
>Assignee: Tim Robertson
>Priority: Minor
>  Labels: errorprone, starter
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> Java ErrorProne static analysis was [recently 
> enabled|https://github.com/apache/beam/pull/5161] in the Gradle build 
> process, but only as warnings. ErrorProne errors are generally useful and 
> easy to fix. Some work was done to [make sdks-java-core 
> ErrorProne-clean|https://github.com/apache/beam/pull/5319] and add 
> enforcement. This task is clean ErrorProne warnings and add enforcement in 
> {{beam-runners-flink}}. Additional context discussed on the [dev 
> list|https://lists.apache.org/thread.html/95aae2785c3cd728c2d3378cbdff2a7ba19caffcd4faa2049d2e2f46@%3Cdev.beam.apache.org%3E].
> Fixing this issue will involve:
> # Follow instructions in the [Contribution 
> Guide|https://beam.apache.org/contribute/] to set up a {{beam}} development 
> environment.
> # Run the following command to compile and run ErrorProne analysis on the 
> project: {{./gradlew :beam-runners-flink:assemble}}
> # Fix each ErrorProne warning from the {{runners/flink}} project.
> # In {{runners/flink/build.gradle}}, add {{failOnWarning: true}} to the call 
> the {{applyJavaNature()}} 
> ([example|https://github.com/apache/beam/pull/5319/files#diff-9390c20635aed5f42f83b97506a87333R20]).
> This starter issue is sponsored by [~swegner]. Feel free to [reach 
> out|https://beam.apache.org/community/contact-us/] with questions or code 
> review:
> * JIRA: [~swegner]
> * GitHub: [@swegner|https://github.com/swegner]
> * Slack: [@Scott Wegner|https://s.apache.org/beam-slack-channel]
> * Email: swegner at google dot com



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4311) Enforce ErrorProne analysis in Flink runner project

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4311?focusedWorklogId=109548=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109548
 ]

ASF GitHub Bot logged work on BEAM-4311:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:12
Start Date: 06/Jun/18 21:12
Worklog Time Spent: 10m 
  Work Description: iemejia commented on issue #5572: [BEAM-4311] Enforce 
ErrorProne analysis in Flink runner
URL: https://github.com/apache/beam/pull/5572#issuecomment-395215448
 
 
   Run Flink ValidatesRunner


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109548)
Time Spent: 20m  (was: 10m)

> Enforce ErrorProne analysis in Flink runner project
> ---
>
> Key: BEAM-4311
> URL: https://issues.apache.org/jira/browse/BEAM-4311
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Scott Wegner
>Assignee: Tim Robertson
>Priority: Minor
>  Labels: errorprone, starter
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> Java ErrorProne static analysis was [recently 
> enabled|https://github.com/apache/beam/pull/5161] in the Gradle build 
> process, but only as warnings. ErrorProne errors are generally useful and 
> easy to fix. Some work was done to [make sdks-java-core 
> ErrorProne-clean|https://github.com/apache/beam/pull/5319] and add 
> enforcement. This task is clean ErrorProne warnings and add enforcement in 
> {{beam-runners-flink}}. Additional context discussed on the [dev 
> list|https://lists.apache.org/thread.html/95aae2785c3cd728c2d3378cbdff2a7ba19caffcd4faa2049d2e2f46@%3Cdev.beam.apache.org%3E].
> Fixing this issue will involve:
> # Follow instructions in the [Contribution 
> Guide|https://beam.apache.org/contribute/] to set up a {{beam}} development 
> environment.
> # Run the following command to compile and run ErrorProne analysis on the 
> project: {{./gradlew :beam-runners-flink:assemble}}
> # Fix each ErrorProne warning from the {{runners/flink}} project.
> # In {{runners/flink/build.gradle}}, add {{failOnWarning: true}} to the call 
> the {{applyJavaNature()}} 
> ([example|https://github.com/apache/beam/pull/5319/files#diff-9390c20635aed5f42f83b97506a87333R20]).
> This starter issue is sponsored by [~swegner]. Feel free to [reach 
> out|https://beam.apache.org/community/contact-us/] with questions or code 
> review:
> * JIRA: [~swegner]
> * GitHub: [@swegner|https://github.com/swegner]
> * Slack: [@Scott Wegner|https://s.apache.org/beam-slack-channel]
> * Email: swegner at google dot com



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Resolved] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread Luke Cwik (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Luke Cwik resolved BEAM-4479.
-
   Resolution: Fixed
Fix Version/s: Not applicable

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
> Fix For: Not applicable
>
>  Time Spent: 1h
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Assigned] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread Luke Cwik (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Luke Cwik reassigned BEAM-4479:
---

Assignee: Xin Wang  (was: Melissa Pashniak)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
>  Time Spent: 50m
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109547=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109547
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:10
Start Date: 06/Jun/18 21:10
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395215084
 
 
   Thanks for the contribution. I added you as a contributor to the project and 
assigned and closed BEAM-4479 on your behalf.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109547)
Time Spent: 1h  (was: 50m)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Xin Wang
>Priority: Minor
>  Time Spent: 1h
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4479) Fixed document for Coder

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4479?focusedWorklogId=109546=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109546
 ]

ASF GitHub Bot logged work on BEAM-4479:


Author: ASF GitHub Bot
Created on: 06/Jun/18 21:09
Start Date: 06/Jun/18 21:09
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #459: [BEAM-4479] Fixed 
document for Coder
URL: https://github.com/apache/beam-site/pull/459#issuecomment-395214592
 
 
   @asgit merge


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109546)
Time Spent: 50m  (was: 40m)

> Fixed document for Coder
> 
>
> Key: BEAM-4479
> URL: https://issues.apache.org/jira/browse/BEAM-4479
> Project: Beam
>  Issue Type: Improvement
>  Components: website
>Reporter: Xin Wang
>Assignee: Melissa Pashniak
>Priority: Minor
>  Time Spent: 50m
>  Remaining Estimate: 0h
>
> {code:java}CoderRegistry.getDefaultCoder{code} had been removed since 
> release-2.0.0, however, the document wasn't updated. This patch fixed that.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4512) Move DataflowRunner off of Maven build files

2018-06-06 Thread Chamikara Jayalath (JIRA)
Chamikara Jayalath created BEAM-4512:


 Summary: Move DataflowRunner off of Maven build files
 Key: BEAM-4512
 URL: https://issues.apache.org/jira/browse/BEAM-4512
 Project: Beam
  Issue Type: Sub-task
  Components: runner-dataflow
Reporter: Chamikara Jayalath
Assignee: Chamikara Jayalath


Currently DataflowRunner (internally at Google) depends on Beam's Maven build 
files. We have to move some internal build targets to use Gradle so that Maven 
files can be deleted from Beam.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4311) Enforce ErrorProne analysis in Flink runner project

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4311?focusedWorklogId=109536=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109536
 ]

ASF GitHub Bot logged work on BEAM-4311:


Author: ASF GitHub Bot
Created on: 06/Jun/18 20:41
Start Date: 06/Jun/18 20:41
Worklog Time Spent: 10m 
  Work Description: timrobertson100 opened a new pull request #5572: 
[BEAM-4311] Enforce ErrorProne analysis in Flink runner
URL: https://github.com/apache/beam/pull/5572
 
 
   Enforce ErrorProne analysis in Flink runner and addresses the issues raised.
   
   Please note the suppression of the ScheduledFuture check. I couldn't see 
anything meaningful that could be done there.
   
   CC @swegner @iemejia 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109536)
Time Spent: 10m
Remaining Estimate: 0h

> Enforce ErrorProne analysis in Flink runner project
> ---
>
> Key: BEAM-4311
> URL: https://issues.apache.org/jira/browse/BEAM-4311
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Scott Wegner
>Assignee: Tim Robertson
>Priority: Minor
>  Labels: errorprone, starter
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> Java ErrorProne static analysis was [recently 
> enabled|https://github.com/apache/beam/pull/5161] in the Gradle build 
> process, but only as warnings. ErrorProne errors are generally useful and 
> easy to fix. Some work was done to [make sdks-java-core 
> ErrorProne-clean|https://github.com/apache/beam/pull/5319] and add 
> enforcement. This task is clean ErrorProne warnings and add enforcement in 
> {{beam-runners-flink}}. Additional context discussed on the [dev 
> list|https://lists.apache.org/thread.html/95aae2785c3cd728c2d3378cbdff2a7ba19caffcd4faa2049d2e2f46@%3Cdev.beam.apache.org%3E].
> Fixing this issue will involve:
> # Follow instructions in the [Contribution 
> Guide|https://beam.apache.org/contribute/] to set up a {{beam}} development 
> environment.
> # Run the following command to compile and run ErrorProne analysis on the 
> project: {{./gradlew :beam-runners-flink:assemble}}
> # Fix each ErrorProne warning from the {{runners/flink}} project.
> # In {{runners/flink/build.gradle}}, add {{failOnWarning: true}} to the call 
> the {{applyJavaNature()}} 
> ([example|https://github.com/apache/beam/pull/5319/files#diff-9390c20635aed5f42f83b97506a87333R20]).
> This starter issue is sponsored by [~swegner]. Feel free to [reach 
> out|https://beam.apache.org/community/contact-us/] with questions or code 
> review:
> * JIRA: [~swegner]
> * GitHub: [@swegner|https://github.com/swegner]
> * Slack: [@Scott Wegner|https://s.apache.org/beam-slack-channel]
> * Email: swegner at google dot com



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Commented] (BEAM-4126) Delete maven build files

2018-06-06 Thread Luke Cwik (JIRA)


[ 
https://issues.apache.org/jira/browse/BEAM-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503884#comment-16503884
 ] 

Luke Cwik commented on BEAM-4126:
-

[~iemejia] I agree and I started a discuss thread about this and assigned the 
bug to myself specifically to avoid someone deleting this too eagerly.

> Delete maven build files
> 
>
> Key: BEAM-4126
> URL: https://issues.apache.org/jira/browse/BEAM-4126
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Scott Wegner
>Assignee: Luke Cwik
>Priority: Minor
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> Once we are fully-migrated to Gradle, we should proactively remove Maven 
> build files (pom.xml etc) so that it's clear they no longer need to be 
> maintained.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (BEAM-4511) Create a tox environment that uses Py3 interpreter for pre/post commit test suites, once codebase supports Py3.

2018-06-06 Thread Valentyn Tymofieiev (JIRA)
Valentyn Tymofieiev created BEAM-4511:
-

 Summary: Create a tox environment that uses Py3 interpreter for 
pre/post commit test suites, once codebase supports Py3. 
 Key: BEAM-4511
 URL: https://issues.apache.org/jira/browse/BEAM-4511
 Project: Beam
  Issue Type: Improvement
  Components: sdk-py-core
Reporter: Valentyn Tymofieiev






--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-4415) Enable HDFS based Performance Test for ParquetIO

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4415?focusedWorklogId=109530=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109530
 ]

ASF GitHub Bot logged work on BEAM-4415:


Author: ASF GitHub Bot
Created on: 06/Jun/18 20:21
Start Date: 06/Jun/18 20:21
Worklog Time Spent: 10m 
  Work Description: szewi commented on issue #5520: [BEAM-4415] Add jenkins 
job for HDFS ParquetIOIT
URL: https://github.com/apache/beam/pull/5520#issuecomment-395200855
 
 
   Looks good to me. Jenkins job was created and during job execution proper 
testing infra was created and used by Perfkit and deleted afterwards. 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109530)
Time Spent: 1h 50m  (was: 1h 40m)

> Enable HDFS based Performance Test for ParquetIO
> 
>
> Key: BEAM-4415
> URL: https://issues.apache.org/jira/browse/BEAM-4415
> Project: Beam
>  Issue Type: New Feature
>  Components: io-java-parquet, testing
>Reporter: Łukasz Gajowy
>Assignee: Łukasz Gajowy
>Priority: Major
>  Time Spent: 1h 50m
>  Remaining Estimate: 0h
>
> There already is a running job for ParquetIO on Jenkins: 
> [https://builds.apache.org/view/A-D/view/Beam/job/beam_PerformanceTests_ParquetIOIT/]
>  
> There are also Jenkins' Jobs running such tests on an HDFS cluster: 
> [https://builds.apache.org/view/A-D/view/Beam/job/beam_PerformanceTests_AvroIOIT_HDFS/]
>  
> Therefore, we should provide a Performance Test for ParquetIO running on HDFS 
> cluster.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Commented] (BEAM-4126) Delete maven build files

2018-06-06 Thread JIRA


[ 
https://issues.apache.org/jira/browse/BEAM-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503864#comment-16503864
 ] 

Ismaël Mejía commented on BEAM-4126:


We must absolutely wait until the release is out to do this. Otherwise we won't 
be able to compare correclty  the release.

> Delete maven build files
> 
>
> Key: BEAM-4126
> URL: https://issues.apache.org/jira/browse/BEAM-4126
> Project: Beam
>  Issue Type: Sub-task
>  Components: build-system
>Reporter: Scott Wegner
>Assignee: Luke Cwik
>Priority: Minor
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> Once we are fully-migrated to Gradle, we should proactively remove Maven 
> build files (pom.xml etc) so that it's clear they no longer need to be 
> maintained.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Spark_Gradle #669

2018-06-06 Thread Apache Jenkins Server
See 


Changes:

[szewinho] [BEAM-3214] Add integration test for HBaseIO.

--
[...truncated 26.96 MB...]
[Executor task launch worker for task 443] INFO 
org.apache.spark.executor.Executor - Running task 2.0 in stage 547.0 (TID 443)
[Executor task launch worker for task 442] INFO 
org.apache.spark.executor.Executor - Running task 1.0 in stage 547.0 (TID 442)
[Executor task launch worker for task 444] INFO 
org.apache.spark.executor.Executor - Running task 3.0 in stage 547.0 (TID 444)
[Executor task launch worker for task 441] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Getting 0 non-empty 
blocks out of 5 blocks
[Executor task launch worker for task 443] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Getting 0 non-empty 
blocks out of 5 blocks
[Executor task launch worker for task 444] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Getting 0 non-empty 
blocks out of 5 blocks
[Executor task launch worker for task 443] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Started 0 remote fetches 
in 0 ms
[Executor task launch worker for task 441] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Started 0 remote fetches 
in 0 ms
[Executor task launch worker for task 444] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Started 0 remote fetches 
in 0 ms
[Executor task launch worker for task 441] INFO 
org.apache.spark.storage.BlockManager - Found block rdd_2441_0 locally
[Executor task launch worker for task 443] INFO 
org.apache.spark.storage.BlockManager - Found block rdd_2441_2 locally
[Executor task launch worker for task 444] INFO 
org.apache.spark.storage.BlockManager - Found block rdd_2441_3 locally
[Executor task launch worker for task 444] INFO 
org.apache.spark.storage.memory.MemoryStore - Block rdd_2756_3 stored as bytes 
in memory (estimated size 4.0 B, free 13.5 GB)
[Executor task launch worker for task 443] INFO 
org.apache.spark.storage.memory.MemoryStore - Block rdd_2756_2 stored as bytes 
in memory (estimated size 4.0 B, free 13.5 GB)
[dispatcher-event-loop-3] INFO org.apache.spark.storage.BlockManagerInfo - 
Added rdd_2756_2 in memory on localhost:43745 (size: 4.0 B, free: 13.5 GB)
[Executor task launch worker for task 441] INFO 
org.apache.spark.storage.memory.MemoryStore - Block rdd_2756_0 stored as bytes 
in memory (estimated size 4.0 B, free 13.5 GB)
[dispatcher-event-loop-3] INFO org.apache.spark.storage.BlockManagerInfo - 
Added rdd_2756_3 in memory on localhost:43745 (size: 4.0 B, free: 13.5 GB)
[dispatcher-event-loop-3] INFO org.apache.spark.storage.BlockManagerInfo - 
Added rdd_2756_0 in memory on localhost:43745 (size: 4.0 B, free: 13.5 GB)
[Executor task launch worker for task 442] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Getting 0 non-empty 
blocks out of 5 blocks
[Executor task launch worker for task 442] INFO 
org.apache.spark.storage.ShuffleBlockFetcherIterator - Started 0 remote fetches 
in 0 ms
[Executor task launch worker for task 442] INFO 
org.apache.spark.storage.BlockManager - Found block rdd_2441_1 locally
[Executor task launch worker for task 442] INFO 
org.apache.spark.storage.memory.MemoryStore - Block rdd_2756_1 stored as bytes 
in memory (estimated size 4.0 B, free 13.5 GB)
[dispatcher-event-loop-0] INFO org.apache.spark.storage.BlockManagerInfo - 
Added rdd_2756_1 in memory on localhost:43745 (size: 4.0 B, free: 13.5 GB)
[Executor task launch worker for task 441] INFO 
org.apache.spark.executor.Executor - Finished task 0.0 in stage 547.0 (TID 
441). 59881 bytes result sent to driver
[Executor task launch worker for task 444] INFO 
org.apache.spark.executor.Executor - Finished task 3.0 in stage 547.0 (TID 
444). 59881 bytes result sent to driver
[Executor task launch worker for task 443] INFO 
org.apache.spark.executor.Executor - Finished task 2.0 in stage 547.0 (TID 
443). 59881 bytes result sent to driver
[Executor task launch worker for task 442] INFO 
org.apache.spark.executor.Executor - Finished task 1.0 in stage 547.0 (TID 
442). 59881 bytes result sent to driver
[task-result-getter-0] INFO org.apache.spark.scheduler.TaskSetManager - 
Finished task 3.0 in stage 547.0 (TID 444) in 16 ms on localhost (executor 
driver) (1/4)
[task-result-getter-2] INFO org.apache.spark.scheduler.TaskSetManager - 
Finished task 0.0 in stage 547.0 (TID 441) in 17 ms on localhost (executor 
driver) (2/4)
[task-result-getter-1] INFO org.apache.spark.scheduler.TaskSetManager - 
Finished task 2.0 in stage 547.0 (TID 443) in 17 ms on localhost (executor 
driver) (3/4)
[task-result-getter-3] INFO org.apache.spark.scheduler.TaskSetManager - 
Finished task 1.0 in stage 547.0 (TID 442) in 18 ms on localhost (executor 

[jira] [Updated] (BEAM-3214) Add an integration test for HBaseIO Read/Write transforms

2018-06-06 Thread JIRA


 [ 
https://issues.apache.org/jira/browse/BEAM-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ismaël Mejía updated BEAM-3214:
---
Fix Version/s: (was: 2.5.0)
   2.6.0

> Add an integration test for HBaseIO Read/Write transforms
> -
>
> Key: BEAM-3214
> URL: https://issues.apache.org/jira/browse/BEAM-3214
> Project: Beam
>  Issue Type: Test
>  Components: io-java-hbase
>Reporter: Chamikara Jayalath
>Assignee: Kamil Szewczyk
>Priority: Major
> Fix For: 2.6.0
>
>  Time Spent: 5h 50m
>  Remaining Estimate: 0h
>
> We should add an small scale integration test for HBaseIO that can be run as 
> a part of 'beam_PostCommit_Java_MavenInstall' and 
> 'beam_PostCommit_Java_ValidatesRunner*' Jenkins test suites.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3214) Add an integration test for HBaseIO Read/Write transforms

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3214?focusedWorklogId=109529=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109529
 ]

ASF GitHub Bot logged work on BEAM-3214:


Author: ASF GitHub Bot
Created on: 06/Jun/18 20:06
Start Date: 06/Jun/18 20:06
Worklog Time Spent: 10m 
  Work Description: iemejia closed pull request #5499: [BEAM-3214] Add 
integration test for HBaseIO.
URL: https://github.com/apache/beam/pull/5499
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git 
a/.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster-for-local-dev.yml
 
b/.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster-for-local-dev.yml
new file mode 100644
index 000..52433802734
--- /dev/null
+++ 
b/.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster-for-local-dev.yml
@@ -0,0 +1,37 @@
+#Licensed to the Apache Software Foundation (ASF) under one or more
+#contributor license agreements.  See the NOTICE file distributed with
+#this work for additional information regarding copyright ownership.
+#The ASF licenses this file to You under the Apache License, Version 2.0
+#(the "License"); you may not use this file except in compliance with
+#the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+#Unless required by applicable law or agreed to in writing, software
+#distributed under the License is distributed on an "AS IS" BASIS,
+#WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#See the License for the specific language governing permissions and
+#limitations under the License.
+
+# This script provides access to HBase cluster to DirectRunner and any other
+# external application that uses HBase Client API.
+
+apiVersion: v1
+kind: Service
+metadata:
+  name: hbase-external
+  labels:
+name: hbase-external
+spec:
+  ports:
+- name: zookeeper
+  port: 2181
+- name: hbase-master
+  port: 16000
+- name: web
+  port: 16010
+- name: region
+  port: 16201
+  selector:
+name: hbase
+  type: LoadBalancer
\ No newline at end of file
diff --git 
a/.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster.yml 
b/.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster.yml
new file mode 100644
index 000..0c27f426bc9
--- /dev/null
+++ b/.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster.yml
@@ -0,0 +1,100 @@
+#Licensed to the Apache Software Foundation (ASF) under one or more
+#contributor license agreements.  See the NOTICE file distributed with
+#this work for additional information regarding copyright ownership.
+#The ASF licenses this file to You under the Apache License, Version 2.0
+#(the "License"); you may not use this file except in compliance with
+#the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+#Unless required by applicable law or agreed to in writing, software
+#distributed under the License is distributed on an "AS IS" BASIS,
+#WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#See the License for the specific language governing permissions and
+#limitations under the License.
+
+# This script creates single node HBase cluster. This means all three services
+# zookeeper, HBase master and regionserver are running on the same kubernetes 
pod.
+# Service "hbase" allow to reach HBase pod using its FQDN.
+# StatefulSet "hbase" creates one replica of HBase fully configured node. In 
order
+# to access the cluster from outside of GCP please also run this configuration 
file with:
+# hbase-single-node-cluster-for-local-dev.yml
+
+apiVersion: v1
+kind: Service
+metadata:
+  name: hbase
+  labels:
+name: hbase
+spec:
+  clusterIP: None
+  ports:
+- name: zookeeper
+  port: 2181
+  targetPort: 2181
+- name: rest
+  port: 8080
+  targetPort: 8080
+- name: rest-info
+  port: 8085
+  targetPort: 8085
+- name: thrift
+  port: 9090
+  targetPort: 9090
+- name: thrift-info
+  port: 9095
+  targetPort: 9095
+- name: hbase-master
+  port: 16000
+  targetPort: 16000
+- name: web
+  port: 16010
+  targetPort: 16010
+- name: region
+  port: 16201
+  targetPort: 16201
+- name: region-info
+  port: 16301
+  targetPort: 16301
+  selector:
+name: hbase
+
+---
+
+apiVersion: apps/v1
+kind: StatefulSet
+metadata:
+  name: hbase
+spec:
+  selector:
+matchLabels:
+  name: 

[beam] branch master updated (1f712bc -> f89e19b)

2018-06-06 Thread iemejia
This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from 1f712bc  Merge pull request #5563: [BEAM-4491] Fix ProvisionInfo in 
DockerJobBundleFactory
 add 0e0da28  [BEAM-3214] Add integration test for HBaseIO.
 new f89e19b  Merge pull request #5499: [BEAM-3214] Add integration test 
for HBaseIO.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../hbase-single-node-cluster-for-local-dev.yml}   |  28 ++--
 .../SmallITCluster/hbase-single-node-cluster.yml   | 100 
 .../{hadoop => hbase}/SmallITCluster/setup-all.sh  |  26 ++--
 .../SmallITCluster}/setup.sh   |   6 +-
 .../SmallITCluster/teardown-all.sh |  20 +--
 .../kubernetes/hbase/SmallITCluster/teardown.sh|  12 +-
 sdks/java/io/hbase/build.gradle|   4 +
 sdks/java/io/hbase/pom.xml |  11 ++
 .../org/apache/beam/sdk/io/hbase/HBaseIOIT.java| 173 +
 9 files changed, 332 insertions(+), 48 deletions(-)
 copy 
.test-infra/kubernetes/{elasticsearch/LargeProductionCluster/elasticsearch-service-for-local-dev.yaml
 => hbase/SmallITCluster/hbase-single-node-cluster-for-local-dev.yml} (70%)
 create mode 100644 
.test-infra/kubernetes/hbase/SmallITCluster/hbase-single-node-cluster.yml
 copy .test-infra/kubernetes/{hadoop => hbase}/SmallITCluster/setup-all.sh (57%)
 copy .test-infra/kubernetes/{hadoop/LargeITCluster => 
hbase/SmallITCluster}/setup.sh (92%)
 copy .test-infra/kubernetes/{hadoop => hbase}/SmallITCluster/teardown-all.sh 
(67%)
 copy 
sdks/java/build-tools/src/main/resources/docker/git/openjdk8/docker-entrypoint.sh
 => .test-infra/kubernetes/hbase/SmallITCluster/teardown.sh (91%)
 create mode 100644 
sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOIT.java

-- 
To stop receiving notification emails like this one, please contact
ieme...@apache.org.


[beam] 01/01: Merge pull request #5499: [BEAM-3214] Add integration test for HBaseIO.

2018-06-06 Thread iemejia
This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit f89e19ba2983363e049115c26e49477e7f658ac2
Merge: 1f712bc 0e0da28
Author: Ismaël Mejía 
AuthorDate: Wed Jun 6 22:06:50 2018 +0200

Merge pull request #5499: [BEAM-3214] Add integration test for HBaseIO.

 .../hbase-single-node-cluster-for-local-dev.yml|  37 +
 .../SmallITCluster/hbase-single-node-cluster.yml   | 100 
 .../kubernetes/hbase/SmallITCluster/setup-all.sh   |  40 +
 .../kubernetes/hbase/SmallITCluster/setup.sh   |  20 +++
 .../hbase/SmallITCluster/teardown-all.sh   |  29 
 .../kubernetes/hbase/SmallITCluster/teardown.sh|  20 +++
 sdks/java/io/hbase/build.gradle|   4 +
 sdks/java/io/hbase/pom.xml |  11 ++
 .../org/apache/beam/sdk/io/hbase/HBaseIOIT.java| 173 +
 9 files changed, 434 insertions(+)


-- 
To stop receiving notification emails like this one, please contact
ieme...@apache.org.


[jira] [Assigned] (BEAM-4311) Enforce ErrorProne analysis in Flink runner project

2018-06-06 Thread Tim Robertson (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Tim Robertson reassigned BEAM-4311:
---

Assignee: Tim Robertson

> Enforce ErrorProne analysis in Flink runner project
> ---
>
> Key: BEAM-4311
> URL: https://issues.apache.org/jira/browse/BEAM-4311
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-flink
>Reporter: Scott Wegner
>Assignee: Tim Robertson
>Priority: Minor
>  Labels: errorprone, starter
>
> Java ErrorProne static analysis was [recently 
> enabled|https://github.com/apache/beam/pull/5161] in the Gradle build 
> process, but only as warnings. ErrorProne errors are generally useful and 
> easy to fix. Some work was done to [make sdks-java-core 
> ErrorProne-clean|https://github.com/apache/beam/pull/5319] and add 
> enforcement. This task is clean ErrorProne warnings and add enforcement in 
> {{beam-runners-flink}}. Additional context discussed on the [dev 
> list|https://lists.apache.org/thread.html/95aae2785c3cd728c2d3378cbdff2a7ba19caffcd4faa2049d2e2f46@%3Cdev.beam.apache.org%3E].
> Fixing this issue will involve:
> # Follow instructions in the [Contribution 
> Guide|https://beam.apache.org/contribute/] to set up a {{beam}} development 
> environment.
> # Run the following command to compile and run ErrorProne analysis on the 
> project: {{./gradlew :beam-runners-flink:assemble}}
> # Fix each ErrorProne warning from the {{runners/flink}} project.
> # In {{runners/flink/build.gradle}}, add {{failOnWarning: true}} to the call 
> the {{applyJavaNature()}} 
> ([example|https://github.com/apache/beam/pull/5319/files#diff-9390c20635aed5f42f83b97506a87333R20]).
> This starter issue is sponsored by [~swegner]. Feel free to [reach 
> out|https://beam.apache.org/community/contact-us/] with questions or code 
> review:
> * JIRA: [~swegner]
> * GitHub: [@swegner|https://github.com/swegner]
> * Slack: [@Scott Wegner|https://s.apache.org/beam-slack-channel]
> * Email: swegner at google dot com



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Jenkins build is back to normal : beam_PostCommit_Java_GradleBuild #676

2018-06-06 Thread Apache Jenkins Server
See 




[jira] [Work logged] (BEAM-4491) DockerJobBundleFactory's ProvisionInfo is empty.

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4491?focusedWorklogId=109509=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109509
 ]

ASF GitHub Bot logged work on BEAM-4491:


Author: ASF GitHub Bot
Created on: 06/Jun/18 18:27
Start Date: 06/Jun/18 18:27
Worklog Time Spent: 10m 
  Work Description: jkff closed pull request #5563: [BEAM-4491] Fix 
ProvisionInfo in DockerJobBundleFactory
URL: https://github.com/apache/beam/pull/5563
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git 
a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DockerJobBundleFactory.java
 
b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DockerJobBundleFactory.java
index f38cbcdc5bc..c0a69ca1822 100644
--- 
a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DockerJobBundleFactory.java
+++ 
b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DockerJobBundleFactory.java
@@ -31,7 +31,6 @@
 import java.util.concurrent.Executors;
 import javax.annotation.concurrent.ThreadSafe;
 import org.apache.beam.model.fnexecution.v1.BeamFnApi.Target;
-import org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo;
 import org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc;
 import org.apache.beam.model.pipeline.v1.RunnerApi.Environment;
 import org.apache.beam.runners.core.construction.graph.ExecutableStage;
@@ -48,6 +47,7 @@
 import org.apache.beam.runners.fnexecution.environment.RemoteEnvironment;
 import org.apache.beam.runners.fnexecution.logging.GrpcLoggingService;
 import org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter;
+import org.apache.beam.runners.fnexecution.provisioning.JobInfo;
 import 
org.apache.beam.runners.fnexecution.provisioning.StaticGrpcProvisionService;
 import org.apache.beam.runners.fnexecution.state.GrpcStateService;
 import org.apache.beam.runners.fnexecution.state.StateRequestHandler;
@@ -80,7 +80,8 @@
 
   private final LoadingCache 
environmentCache;
 
-  public static DockerJobBundleFactory create(ArtifactSource artifactSource) 
throws Exception {
+  public static DockerJobBundleFactory create(JobInfo jobInfo, ArtifactSource 
artifactSource)
+  throws Exception {
 ServerFactory serverFactory = getServerFactory();
 IdGenerator stageIdGenerator = IdGenerators.incrementingLongs();
 ControlClientPool clientPool = MapControlClientPool.create();
@@ -99,7 +100,7 @@ public static DockerJobBundleFactory create(ArtifactSource 
artifactSource) throw
 new UnimplementedArtifactRetrievalService(), serverFactory);
 GrpcFnServer provisioningServer =
 GrpcFnServer.allocatePortAndCreateFor(
-
StaticGrpcProvisionService.create(ProvisionInfo.newBuilder().build()), 
serverFactory);
+StaticGrpcProvisionService.create(jobInfo.toProvisionInfo()), 
serverFactory);
 DockerEnvironmentFactory environmentFactory =
 DockerEnvironmentFactory.forServices(
 controlServer,
diff --git 
a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/JobInfo.java
 
b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/JobInfo.java
index 374ffeb89ed..16a29f4b7e3 100644
--- 
a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/JobInfo.java
+++ 
b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/JobInfo.java
@@ -21,6 +21,7 @@
 import com.google.auto.value.AutoValue;
 import com.google.protobuf.Struct;
 import java.io.Serializable;
+import org.apache.beam.model.fnexecution.v1.ProvisionApi;
 
 /**
  * A subset of {@link 
org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo} that
@@ -35,4 +36,13 @@ public static JobInfo create(String jobId, String jobName, 
Struct pipelineOption
   public abstract String jobId();
   public abstract String jobName();
   public abstract Struct pipelineOptions();
+
+  public ProvisionApi.ProvisionInfo toProvisionInfo() {
+return ProvisionApi.ProvisionInfo
+.newBuilder()
+.setJobId(jobId())
+.setJobName(jobName())
+.setPipelineOptions(pipelineOptions())
+.build();
+  }
 }


 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

  

[beam] branch master updated (72cbd99 -> 1f712bc)

2018-06-06 Thread jkff
This is an automated email from the ASF dual-hosted git repository.

jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from 72cbd99  Moving to 2.6.0-SNAPSHOT on master branch
 add 8975cbd  Fix ProvisionInfo in DockerJobBundleFactory
 add 1f712bc  Merge pull request #5563: [BEAM-4491] Fix ProvisionInfo in 
DockerJobBundleFactory

No new revisions were added by this update.

Summary of changes:
 .../runners/fnexecution/control/DockerJobBundleFactory.java|  7 ---
 .../apache/beam/runners/fnexecution/provisioning/JobInfo.java  | 10 ++
 2 files changed, 14 insertions(+), 3 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
j...@apache.org.


Build failed in Jenkins: beam_PerformanceTests_MongoDBIO_IT #271

2018-06-06 Thread Apache Jenkins Server
See 


--
[...truncated 290.18 KB...]
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.performSplitTyped(WorkerCustomSources.java:197)
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.performSplitWithApiLimit(WorkerCustomSources.java:181)
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.performSplit(WorkerCustomSources.java:160)
at 
com.google.cloud.dataflow.worker.WorkerCustomSourceOperationExecutor.execute(WorkerCustomSourceOperationExecutor.java:77)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.executeWork(BatchDataflowWorker.java:391)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.doWork(BatchDataflowWorker.java:360)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:288)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.doWork(DataflowBatchWorkerHarness.java:134)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:114)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:101)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
com.mongodb.MongoTimeoutException: Timed out after 3 ms while waiting 
for a server that matches ReadPreferenceServerSelector{readPreference=primary}. 
Client view of cluster state is {type=UNKNOWN, 
servers=[{address=35.224.210.247:27017, type=UNKNOWN, state=CONNECTING, 
exception={com.mongodb.MongoSocketOpenException: Exception opening socket}, 
caused by {java.net.SocketTimeoutException: connect timed out}}]
at 
com.mongodb.connection.BaseCluster.createTimeoutException(BaseCluster.java:369)
at com.mongodb.connection.BaseCluster.selectServer(BaseCluster.java:101)
at 
com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.(ClusterBinding.java:75)
at 
com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.(ClusterBinding.java:71)
at 
com.mongodb.binding.ClusterBinding.getReadConnectionSource(ClusterBinding.java:63)
at 
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:89)
at 
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:84)
at 
com.mongodb.operation.CommandReadOperation.execute(CommandReadOperation.java:55)
at com.mongodb.Mongo.execute(Mongo.java:772)
at com.mongodb.Mongo$2.execute(Mongo.java:759)
at com.mongodb.MongoDatabaseImpl.runCommand(MongoDatabaseImpl.java:130)
at com.mongodb.MongoDatabaseImpl.runCommand(MongoDatabaseImpl.java:124)
at com.mongodb.MongoDatabaseImpl.runCommand(MongoDatabaseImpl.java:114)
at 
org.apache.beam.sdk.io.mongodb.MongoDbIO$BoundedMongoDbSource.split(MongoDbIO.java:332)
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.splitAndValidate(WorkerCustomSources.java:275)
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.performSplitTyped(WorkerCustomSources.java:197)
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.performSplitWithApiLimit(WorkerCustomSources.java:181)
at 
com.google.cloud.dataflow.worker.WorkerCustomSources.performSplit(WorkerCustomSources.java:160)
at 
com.google.cloud.dataflow.worker.WorkerCustomSourceOperationExecutor.execute(WorkerCustomSourceOperationExecutor.java:77)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.executeWork(BatchDataflowWorker.java:391)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.doWork(BatchDataflowWorker.java:360)
at 
com.google.cloud.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:288)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.doWork(DataflowBatchWorkerHarness.java:134)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:114)
at 
com.google.cloud.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:101)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
com.mongodb.MongoTimeoutException: Timed out after 3 ms while waiting 
for 

[jira] [Work logged] (BEAM-4491) DockerJobBundleFactory's ProvisionInfo is empty.

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-4491?focusedWorklogId=109504=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109504
 ]

ASF GitHub Bot logged work on BEAM-4491:


Author: ASF GitHub Bot
Created on: 06/Jun/18 18:13
Start Date: 06/Jun/18 18:13
Worklog Time Spent: 10m 
  Work Description: axelmagn commented on issue #5563: [BEAM-4491] Fix 
ProvisionInfo in DockerJobBundleFactory
URL: https://github.com/apache/beam/pull/5563#issuecomment-395163856
 
 
   If it looks good to you then please merge :+1: 


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109504)
Time Spent: 0.5h  (was: 20m)

> DockerJobBundleFactory's ProvisionInfo is empty.
> 
>
> Key: BEAM-4491
> URL: https://issues.apache.org/jira/browse/BEAM-4491
> Project: Beam
>  Issue Type: Bug
>  Components: runner-core
>Reporter: Axel Magnuson
>Assignee: Axel Magnuson
>Priority: Minor
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> DockerJobBundleFactory creates a ProvisioningService that serves the default 
> empty ProvisionInfo, rather than the ProvisionInfo related to a job.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


Build failed in Jenkins: beam_PerformanceTests_XmlIOIT_HDFS #261

2018-06-06 Thread Apache Jenkins Server
See 


--
Started by timer
[EnvInject] - Loading node environment variables.
Building remotely on beam10 (beam) in workspace 

 > git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
 > git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
 > git --version # timeout=10
 > git fetch --tags --progress https://github.com/apache/beam.git 
 > +refs/heads/*:refs/remotes/origin/* 
 > +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
 > git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 72cbd99d6b62bc7ed16dbd1288cd61d54e8bda37 (origin/master)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f 72cbd99d6b62bc7ed16dbd1288cd61d54e8bda37
Commit message: "Moving to 2.6.0-SNAPSHOT on master branch"
 > git rev-list --no-walk 72cbd99d6b62bc7ed16dbd1288cd61d54e8bda37 # timeout=10
Cleaning workspace
 > git rev-parse --verify HEAD # timeout=10
Resetting working tree
 > git reset --hard # timeout=10
 > git clean -fdx # timeout=10
[EnvInject] - Executing scripts and injecting environment variables after the 
SCM step.
[EnvInject] - Injecting as environment variables the properties content 
SPARK_LOCAL_IP=127.0.0.1

[EnvInject] - Variables injected successfully.
[beam_PerformanceTests_XmlIOIT_HDFS] $ /bin/bash -xe 
/tmp/jenkins6647651646722716607.sh
+ gcloud container clusters get-credentials io-datastores --zone=us-central1-a 
--verbosity=debug
DEBUG: Running [gcloud.container.clusters.get-credentials] with arguments: 
[--verbosity: "debug", --zone: "us-central1-a", NAME: "io-datastores"]
Fetching cluster endpoint and auth data.
DEBUG: Saved kubeconfig to /home/jenkins/.kube/config
kubeconfig entry generated for io-datastores.
INFO: Display format "default".
DEBUG: SDK update checks are disabled.
[beam_PerformanceTests_XmlIOIT_HDFS] $ /bin/bash -xe 
/tmp/jenkins6050753238734858302.sh
+ cp /home/jenkins/.kube/config 

[beam_PerformanceTests_XmlIOIT_HDFS] $ /bin/bash -xe 
/tmp/jenkins1044128836986557744.sh
+ kubectl 
--kubeconfig=
 create namespace filebasedioithdfs-261
Error from server (AlreadyExists): namespaces "filebasedioithdfs-261" already 
exists
Build step 'Execute shell' marked build as failure


[jira] [Commented] (BEAM-4507) Objects that have Fixed Window after a Global Window disappear in Directrunner

2018-06-06 Thread Batkhuyag Batsaikhan (JIRA)


[ 
https://issues.apache.org/jira/browse/BEAM-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503657#comment-16503657
 ] 

Batkhuyag Batsaikhan commented on BEAM-4507:


Reza, could you tell me a bit about what are you trying to accomplish with your 
pipeline?

 

If you are trying to output element with its original timestamp from a timer, 
currently, there is no way to do it. Timers should not output an element with 
timestamp that is earlier than its own timestamp because the element will be 
considered late. There is an attempt to allow timers to hold watermark at user 
specified timestamp (https://issues.apache.org/jira/browse/BEAM-2535). However, 
this had some design complications and did not enough demand to implement it

> Objects that have Fixed Window after a Global Window disappear in Directrunner
> --
>
> Key: BEAM-4507
> URL: https://issues.apache.org/jira/browse/BEAM-4507
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-direct
>Affects Versions: 2.4.0
>Reporter: Reza ardeshir rokni
>Assignee: Batkhuyag Batsaikhan
>Priority: Major
>
> 1- Create a elements that go into a combinar and then drops into a  Keyed 
> Global Window, on entry setup a timer.
> Have the OnTime function:
> 1- c.output the original element with a timestamp == to the original timestamp
> 2- Create a new timestamp with element in the next window
> 2- LOG the output in a DoFn after the keyed state code, you should see all 
> the values.
> 3- Now apply a FixedWindow... and then try and log the output.. the original 
> elements wont appear, but the new OnTime generated ones will.
>  
> Tested in Dataflow runner and things work ok, the direct runner fails. 
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Commented] (BEAM-4507) Objects that have Fixed Window after a Global Window disappear in Directrunner

2018-06-06 Thread Batkhuyag Batsaikhan (JIRA)


[ 
https://issues.apache.org/jira/browse/BEAM-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503648#comment-16503648
 ] 

Batkhuyag Batsaikhan commented on BEAM-4507:


Hi Reza, thanks for filing this Jira. My initial diagnosis is: We can't 
guaranteed that the element will go through a pipeline if the watermark is 
passed the element's timestamp. Basically, when the element is really late.
 # Timers only hold watermark at its timestamp, which is usually set in the 
future from the element's timestamp.
 # When timer fires, the watermark is advanced to the timer's timestamp. 
However, we are outputting element from it with timestamp in the past.
 # If the watermark advances past a fixed window, the window expires. However, 
the element outputted from the timer might get assigned to this expired window.
 # The newly generated element from the timer is outputted consistent to the 
watermark, therefore it succeeds.

Let me know if this diagnosis describes your case correctly.

 

> Objects that have Fixed Window after a Global Window disappear in Directrunner
> --
>
> Key: BEAM-4507
> URL: https://issues.apache.org/jira/browse/BEAM-4507
> Project: Beam
>  Issue Type: Improvement
>  Components: runner-direct
>Affects Versions: 2.4.0
>Reporter: Reza ardeshir rokni
>Assignee: Batkhuyag Batsaikhan
>Priority: Major
>
> 1- Create a elements that go into a combinar and then drops into a  Keyed 
> Global Window, on entry setup a timer.
> Have the OnTime function:
> 1- c.output the original element with a timestamp == to the original timestamp
> 2- Create a new timestamp with element in the next window
> 2- LOG the output in a DoFn after the keyed state code, you should see all 
> the values.
> 3- Now apply a FixedWindow... and then try and log the output.. the original 
> elements wont appear, but the new OnTime generated ones will.
>  
> Tested in Dataflow runner and things work ok, the direct runner fails. 
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3608) Pre-shade Guava for things we want to keep using

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3608?focusedWorklogId=109493=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109493
 ]

ASF GitHub Bot logged work on BEAM-3608:


Author: ASF GitHub Bot
Created on: 06/Jun/18 17:26
Start Date: 06/Jun/18 17:26
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #5570: [BEAM-3608] 
Pre-shade Guava
URL: https://github.com/apache/beam/pull/5570#issuecomment-395149101
 
 
   Do you plan to perform a mass migration so we aren't shading anything (or 
almost everything)?
   Otherwise the publishing path is very relevant.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109493)
Time Spent: 1.5h  (was: 1h 20m)

> Pre-shade Guava for things we want to keep using
> 
>
> Key: BEAM-3608
> URL: https://issues.apache.org/jira/browse/BEAM-3608
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-core, sdk-java-core
>Reporter: Kenneth Knowles
>Assignee: Kenneth Knowles
>Priority: Major
>  Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> Instead of shading as part of our build, we can shade before build so that it 
> is apparent when reading code, and in IDEs, that a particular class resides 
> in a hidden namespace.
> {{import com.google.common.reflect.TypeToken}}
> becomes something like
> {{import org.apache.beam.private.guava21.com.google.common.reflect.TypeToken}}
> So we can very trivially ban `org.apache.beam.private` from public APIs 
> unless they are annotated {{@Internal}}, and it makes sharing between our own 
> modules never get broken by shading again.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Work logged] (BEAM-3608) Pre-shade Guava for things we want to keep using

2018-06-06 Thread ASF GitHub Bot (JIRA)


 [ 
https://issues.apache.org/jira/browse/BEAM-3608?focusedWorklogId=109491=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-109491
 ]

ASF GitHub Bot logged work on BEAM-3608:


Author: ASF GitHub Bot
Created on: 06/Jun/18 17:24
Start Date: 06/Jun/18 17:24
Worklog Time Spent: 10m 
  Work Description: lukecwik commented on issue #5570: [BEAM-3608] 
Pre-shade Guava
URL: https://github.com/apache/beam/pull/5570#issuecomment-395148520
 
 
   Ah, I keep forgetting you need to also specify `-Ppublishing --no-parallel` 
to enable publishing plugins.
   They are disabled because they make the parallel build flaky.


This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Issue Time Tracking
---

Worklog Id: (was: 109491)
Time Spent: 1h 20m  (was: 1h 10m)

> Pre-shade Guava for things we want to keep using
> 
>
> Key: BEAM-3608
> URL: https://issues.apache.org/jira/browse/BEAM-3608
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-core, sdk-java-core
>Reporter: Kenneth Knowles
>Assignee: Kenneth Knowles
>Priority: Major
>  Time Spent: 1h 20m
>  Remaining Estimate: 0h
>
> Instead of shading as part of our build, we can shade before build so that it 
> is apparent when reading code, and in IDEs, that a particular class resides 
> in a hidden namespace.
> {{import com.google.common.reflect.TypeToken}}
> becomes something like
> {{import org.apache.beam.private.guava21.com.google.common.reflect.TypeToken}}
> So we can very trivially ban `org.apache.beam.private` from public APIs 
> unless they are annotated {{@Internal}}, and it makes sharing between our own 
> modules never get broken by shading again.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


  1   2   3   >