Repository: beam
Updated Branches:
refs/heads/master e33cc24a5 -> f816ad879
Add README.md to KafkaIO
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf1b0a5e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf1b0a5e
This closes #3780
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f816ad87
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f816ad87
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f816ad87
Branch:
This is an automated email from the ASF dual-hosted git repository.
aviemzur pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam-site.git.
from 1b92d41 This closes #279: Expands the section on Coders in Style Guide
new 97b1ec9 Update PMC
new
This is an automated email from the ASF dual-hosted git repository.
aviemzur pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit 6835c8a4f015f0cebaf55a09730e9f3938273f0f
Author: Aviem Zur <aviem...@gmail.com>
AuthorDate: Sun Aug 13 15
This is an automated email from the ASF dual-hosted git repository.
aviemzur pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit 3c2d09447750cee276a1e1f197b53b7ecb40af8c
Merge: 1b92d41 6835c8a
Author: Aviem Zur <aviem...@gmail.com>
Auth
This is an automated email from the ASF dual-hosted git repository.
aviemzur pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit 97b1ec9cbdbb5bd71cde3ec9170f5dd9236e4f78
Author: Aviem Zur <aviem...@gmail.com>
AuthorDate: Fri Aug 11 00
Repository: beam
Updated Branches:
refs/heads/master f54072a1b -> 0064fb37a
[BEAM-2314] Add ValidatesRunner test for merging custom windows
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dfa983ce
Tree:
This closes #3286
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0064fb37
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0064fb37
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0064fb37
Branch:
This closes #3343
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e2ee5955
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e2ee5955
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e2ee5955
Branch:
[BEAM-2359] Fix watermark broadcasting to executors in Spark runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/20820fa5
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/20820fa5
Diff:
Repository: beam
Updated Branches:
refs/heads/master b3099bba2 -> e2ee59557
Move Spark runner streaming tests to post commit.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/22dbb500
Tree:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/3343
[BEAM-2359] Fix watermark broadcasting to executors in Spark runner
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
This closes #2917
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43c44232
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/43c44232
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/43c44232
Branch:
Repository: beam
Updated Branches:
refs/heads/master 9cdae6caf -> 43c44232d
[BEAM-2175] [BEAM-1115] Support for new State and Timer API in Spark batch mode
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5e5fbed7
Tree:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/3126
[BEAM-2279] Add HDFS support to Spark runner profiles in archetypes and
examples
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/3115
[BEAM-2277] Fix URI_SCHEME_PATTERN in FileSystems
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2938
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2938
Cherry-pick pull request #2649 into release-2.0.0 branch
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
[BEAM-1672] Make MetricsContainers accumulable.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/46c2f935
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/46c2f935
Diff:
Repository: beam
Updated Branches:
refs/heads/master db0ec9991 -> 019d3002b
[BEAM-1672] Use Accumulable MetricsContainers in Flink runner.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8c2da9ad
Tree:
This closes #2649
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/019d3002
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/019d3002
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/019d3002
Branch:
This closes #2729
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b73918b5
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b73918b5
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b73918b5
Branch:
[BEAM-1726] Fix Flatten with input copies in Flink Streaming Runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0e2bb180
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0e2bb180
Diff:
[BEAM-1763] Verify PAssert execution in runners which support metrics.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/95ade45e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/95ade45e
Diff:
[BEAM-1726] Fix empty side inputs in Flink Streaming Runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/040d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/040d
Diff:
[BEAM-1726] Fix RuntimeException throwing in FlinkStateInternals
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c44935e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c44935e
Diff:
Repository: beam
Updated Branches:
refs/heads/master 48c8ed176 -> b73918b55
[BEAM-1763] Replace usage of PipelineRule with TestPipeline in Spark runner
tests
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8d91a97b
Tree:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2824
[BEAM-2139] Disable SplittableDoFn ValidatesRunner tests for Streaming
Flink Runner
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
Repository: beam
Updated Branches:
refs/heads/master 1197bef19 -> b414f8de9
[BEAM-2129] Fix flaky KafkaIOTest#testUnboundedSourceMetrics
Gauge results are flaky on Jenkins, instead of asserting on value
assert on the gauge's existence instead.
Project:
This closes #2797
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b414f8de
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b414f8de
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b414f8de
Branch:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2797
[BEAM-2129] Fix flaky KafkaIOTest#testUnboundedSourceMetrics
Gauge results are flaky on Jenkins, instead of asserting on value
assert on the gauge's existence instead.
Be sure to do all
This closes #2344
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/47821ad6
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/47821ad6
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/47821ad6
Branch:
Repository: beam
Updated Branches:
refs/heads/master 81474aeaf -> 47821ad69
[BEAM-1398] KafkaIO metrics.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/930c27f5
Tree:
This closes #2730
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/81474aea
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/81474aea
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/81474aea
Branch:
Repository: beam
Updated Branches:
refs/heads/master bac06331e -> 81474aeaf
[BEAM-2057] Add a test for metrics reporting in Spark runner.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59117737
Tree:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2781
Fix broken build
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like:
`[BEAM
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2746
[BEAM-2029] NullPointerException when using multi output ParDo in Spark
runner in streaming mode.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
Repository: beam
Updated Branches:
refs/heads/master f3cff3695 -> 30dbaf891
[BEAM-1958] Standard IO Metrics in Java SDK
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/41d52be0
Tree:
This closes #2538
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/30dbaf89
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/30dbaf89
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/30dbaf89
Branch:
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2547
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2522
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2649
[BEAM-1672] Accumulable MetricsContainers.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2547
[BEAM-1758] Option to disable metrics reporting.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2538
[BEAM-1958] Standard IO Metrics in Java SDK
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
This closes #2514
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/21a2b96a
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/21a2b96a
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/21a2b96a
Branch:
Repository: beam
Updated Branches:
refs/heads/master dc672f420 -> 21a2b96a1
[BEAM-1950] Add missing 'static' keyword to MicrobatchSource#initReaderCache
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdabd41a
Tree:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2522
[BEAM-1672] Extract interface MetricData
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2514
[BEAM-1950] Add missing 'static' keyword to MicrobatchSource#initReaderCache
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2263
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam-site/pull/208
Add JSON as a planned IO to built-in IOs page.
R: @iemejia
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aviemzur/beam-site add-json
Repository: beam
Updated Branches:
refs/heads/master a0cfccda4 -> efd785f88
[BEAM-1294] Long running UnboundedSource Readers
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d958796b
Tree:
Repository: beam
Updated Branches:
refs/heads/master 03dce6dcc -> e31ca8b0d
[BEAM-1337] Infer state coders
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/42e690e8
Tree:
This closes #2133
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e31ca8b0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e31ca8b0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e31ca8b0
Branch:
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2108
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
This closes #2345
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d35e1b0d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d35e1b0d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d35e1b0d
Branch:
This closes #2162
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/48fee91f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/48fee91f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/48fee91f
Branch:
Repository: beam
Updated Branches:
refs/heads/master 85b820c37 -> 48fee91f7
[BEAM-1397] Introduce IO metrics
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/65b5f001
Tree:
Repository: beam
Updated Branches:
refs/heads/master fe441e34b -> 85b820c37
[BEAM-1792] Use MetricFiltering in Spark runner.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/241ded90
Tree:
This closes #2304
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/85b820c3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/85b820c3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/85b820c3
Branch:
This closes #2151
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b26e10b4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b26e10b4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b26e10b4
Branch:
Repository: beam
Updated Branches:
refs/heads/master 026aec856 -> b26e10b44
[BEAM-1617] Add Gauge metric type to Java SDK
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/63e953c6
Tree:
This closes #2328
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c9e55a43
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c9e55a43
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c9e55a43
Branch:
Repository: beam
Updated Branches:
refs/heads/master 348d33588 -> c9e55a436
[BEAM-1810] Replace usage of RDD#isEmpty on non-serialized RDDs
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b32f0482
Tree:
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2313
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Repository: beam
Updated Branches:
refs/heads/master 5e1be9fa7 -> 9ac1ffcea
[BEAM-1074] Set default-partitioner in SourceRDD.Unbounded
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/623a5696
Tree:
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam-site/pull/190
Simplify merge process section
R: @davorbonaci
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aviemzur/beam-site simplify-merge-process
Regenerate website
Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/c6d92268
Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/c6d92268
Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/c6d92268
Repository: beam-site
Updated Branches:
refs/heads/asf-site f9b4c6e7a -> 41018ed60
Improve committing website changes section in the contribution guide
Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/653218f8
Fix timezone to America/Los_Angeles
Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/b470eb5b
Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/b470eb5b
Diff:
This closes #189
Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/41018ed6
Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/41018ed6
Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/41018ed6
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2263
[BEAM-1726] TestFlinkRunner should assert PAssert success/failure counters
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2261
Remove duplicate build-helper-maven-plugin
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2259
Fix shading opt out in io/google-cloud-platform
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2249
Increment shade-plugin version back to 3.0.0
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam-site/pull/178
Add IntelliJ files to .gitignore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aviemzur/beam-site
add-intellij-files-to-gitignore
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam-site/pull/177
[BEAM-1652] Code style instructions in contribution guide
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aviemzur/beam-site code-style
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2234
[BEAM-1704] Added Create.TimestampedValues.withType
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2195
[BEAM-1651] Add IntelliJ code style xml to the project repository
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2180
[BEAM-1636] UnboundedDataset action() does not materialize RDD
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2082
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/2082
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user aviemzur reopened a pull request:
https://github.com/apache/beam/pull/2082
[BEAM-1397] [BEAM-1398] Introduce IO metrics. Add KafkaIO metrics.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make sure
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2161
[BEAM-1625] BoundedDataset action() does not materialize RDD
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2151
[BEAM-1617] Add Gauge metric type to Java SDK
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2141
[BEAM-1565] Update Spark runner PostCommit Jenkins job.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2133
[BEAM-1337] Infer state coders
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2111
[BEAM-351] Add DisplayData to KafkaIO
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2109
[BEAM-1551] Allow `PAssert`s to take a message
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2108
[BEAM-463] [BEAM-464] [BEAM-466] BoundedHeapCoder, HolderCoder,
QuantileStateCoder -> StandardCoder
Be sure to do all of the following to help us incorporate your contribution
quic
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2096
[BEAM-1092] Shade commonly used libraries (e.g. Guava) to avoid class
conflicts
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2095
[BEAM-1446] Create with TypeDescriptor
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2082
[BEAM-1397] [BEAM-1398] Introduce IO metrics. Add KafkaIO metrics.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2067
[BEAM-1465] No natural place to flush/close resources in FileBasedWriter
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
Github user aviemzur closed the pull request at:
https://github.com/apache/beam/pull/1983
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
GitHub user aviemzur reopened a pull request:
https://github.com/apache/beam/pull/1983
[BEAM-1466] JSON utils extension
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make sure the PR title is formatted like
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2048
[BEAM-1513] Skip slower verifications if '-DskipTests' specified
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2046
[BEAM-1512] Optimize leaf transforms materialization
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/2033
[BEAM-1294] Long running UnboundedSource Readers via Broadcasts
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/1986
Fixed javadoc comment in ResumeFromCheckpointStreamingTest.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user aviemzur opened a pull request:
https://github.com/apache/beam/pull/1983
[BEAM-1466] JSON utils extension
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
1 - 100 of 106 matches
Mail list logo