GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1900
[BEAM-59] Beam FileSystem: ResourceIdentifier and its local and gcs
implementation.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1911
Fix broken licenses check for in jenkins files.
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 peihe opened a pull request:
https://github.com/apache/beam/pull/1825
[BEAM-1258] Improve logging in BigQueryIO.verifyTableEmpty().
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1823
[BEAM-1235] BigQueryIO.Write: log failed load/copy jobs.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1826
[BEAM-59] Beam FileSystem.setDefaultConfig: remove scheme from the
signature.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1862
Upgrade google-auto-value to 1.3
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 peihe opened a pull request:
https://github.com/apache/beam/pull/1808
[BEAM-59] Beam FileSystem: initial implementation.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1838
Refactor BigQueryServices to have TableReference in methods signatures.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/1448
---
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 peihe opened a pull request:
https://github.com/apache/beam/pull/1968
[BEAM-1453] LocalResourceIdTest: disable unicode tests.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1977
[BEAM-59] GcsUtil: refactor and expose getObject() and listObjects() APIs.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/2022
[BEAM-59] Beam GcsFileSystem: implementation of match().
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1759
[BEAM-1258] DONT_RETRY_NOT_FOUND in BigQueryServicesImpl.isTableEmpty().
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/1760
[BEAM-1258] BigQueryServicesImpl.getTable() returns null when tables not
found.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make
GitHub user peihe opened a pull request:
https://github.com/apache/beam-site/pull/191
Change peihe company affiliation to Alibaba.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/peihe/beam-site asf-site
Alternatively you can
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/2262
[BEAM-1739] fix IndexOutOfBoundsException when index in Create overflows.
Two fixes includes:
1. Avoid integer overflow in Create.
2. Stop calling advance() in UnboundedReadFromBoundedSource
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/2628
---
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 peihe opened a pull request:
https://github.com/apache/beam/pull/2175
[BEAM-59] Beam FileSystems: add match(), copy(), rename(), delete()
utilities.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/2457
Start jstorm runner moduel in feature branch with empty runner
implementation.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3582
[BEAM-2630] TestPipeline: construct job/app names based on Description in
junit TestRule.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3593
ReshuffleTest: replace Iterable equal tests with matchers.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/2672
Merge branch 'master' upto commit 686b774 into jstorm-runner
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3705
[BEAM-165] Initial implementation of the MapReduce runner.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3734
to merge Pr-3624 with fixups
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https://issues.apache.org/jira
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/3117
---
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 peihe opened a pull request:
https://github.com/apache/beam/pull/3117
[BEAM-2280] Remove generated archetype folders.
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 peihe opened a pull request:
https://github.com/apache/beam/pull/3446
[BEAM-210] WindowingStrategy: add OnTimeBehavior to control whether to emit
empty ON_TIME pane.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3245
Flink runner: specify CheckpointingMode and CheckpointingTimeout through
PipelineOptions.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3234
fix FlinkAccumulatorCombiningStateWithContext read null accum bug
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3235
Backport 2
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-] Description
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3289
Flink runner: support MapState in FlinkStateInternals.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3276
Flink runner: support per transform parallelism through PipelineOptions.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3275
Flink runner: refactor the translator into two phases: rewriting and
translating.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/2823
Add JStormPipelineTranslator, TransformTranslator and TranslatorRegistry.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/2823
---
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 peihe opened a pull request:
https://github.com/apache/beam/pull/3812
jstorm-runner: support SourceMetrics, distribution metrics, and saves
MetricsResults after cancelling.
Follow this checklist to help us incorporate your contribution quickly and
easily
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/3812
---
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3792
[BEAM-2824]: support PipelineResult.waitUntilFinish() in JStormRunner local
mode and uses it in TestJStormRunner.
Follow this checklist to help us incorporate your contribution quickly and
easily
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3791
[BEAM-2824] support gauge and PipelineResults.metrics() in local mode.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3834
mr-runner: add mapreduce-runner profile for examples, archetypes and â¦
â¦IT tests.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3807
[BEAM-1763] Ensure run waitUntilFinish in TestPipeline.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3841
flink-runner: constructs exception string only when neccessary, it reâ¦
â¦duces per-element expensive calls(String.format and getSimpleName) in
FlinkAssignContext.
Follow this checklist
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/3806
---
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/3739
[Ignore, Test] spark-runner: upgrade to spark 2.0.2.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
GitHub user peihe reopened a pull request:
https://github.com/apache/beam/pull/3705
[BEAM-165] Initial implementation of the MapReduce runner.
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
Github user peihe closed the pull request at:
https://github.com/apache/beam/pull/3705
---
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 peihe opened a pull request:
https://github.com/apache/beam/pull/4091
Merge branch 'master' upto commit 269bf89 into mr-runner
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
GitHub user peihe opened a pull request:
https://github.com/apache/beam/pull/4107
Merge branch 'master' into jstorm-runner at commit 727253e
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
48 matches
Mail list logo
