GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/122
Fix misleading Javadoc on Trigger.onElement()
This has been bothering me for a while and I always have to go back to the
code to check whether my assumption is right. The comment should
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/274
[BEAM-103][BEAM-130] Make Flink Source Parallel and Checkpointed
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x ] Make
/diff/4020e364
Branch: refs/heads/master
Commit: 4020e364598befbd68458f1c6eada6d90a986358
Parents: 874ddef 336e90f
Author: Aljoscha Krettek
Authored: Tue May 10 22:20:47 2016 +0200
Committer: Aljoscha Krettek
Committed: Tue May 10 22:20:47 2016 +0200
asf/incubator-beam/diff/336e90fa
Branch: refs/heads/master
Commit: 336e90fa795885e670ff3a523a6fefa6033c2663
Parents: 874ddef
Author: Aljoscha Krettek
Authored: Tue May 3 13:35:35 2016 +0200
Committer: Aljoscha Krettek
Committed: Tue May 10 22:20:08 2016 +0
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/328
[BEAM-270] Support Timestamps/Windows in Flink Batch
This change sits on top of #291
With this we can run all of the `RunnableOnService` tests on the Flink
batch runner. Almost
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/335
[BEAM-270] Support Timestamps/Windows in Flink Batch
This is a cleanup version of #328
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/335
---
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
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/343
[BEAM-270] Support Timestamps/Windows in Flink Batch
This is a cleanup version of #328, this time for real.
The interesting things are in
`FlinkPartialReduceFunction
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/347
[BEAM-295] Remove erroneous close() calls in Flink Create Sources
Collector.close() should only be called by internal Flink components,
not by user functions.
You can merge this pull
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/328
---
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
-us.apache.org/repos/asf/incubator-beam/diff/4e60a497
Branch: refs/heads/master
Commit: 4e60a497b313414aa2b2968b8def6c6f753908fe
Parents: 26fa0b2
Author: Aljoscha Krettek
Authored: Fri May 13 14:17:50 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
-us.apache.org/repos/asf/incubator-beam/diff/55f39bf7
Branch: refs/heads/master
Commit: 55f39bf7cbe65980ed4233146517d608977ddaf6
Parents: bfc1a2b
Author: Kenneth Knowles
Authored: Fri May 6 10:54:41 2016 -0700
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
://git-wip-us.apache.org/repos/asf/incubator-beam/diff/af8e9887
Branch: refs/heads/master
Commit: af8e98878bbc8678e33a4c00548ccabf6cf55a17
Parents: 2d71af7
Author: Kenneth Knowles
Authored: Fri May 6 12:49:55 2016 -0700
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
/incubator-beam/diff/26fa0b21
Branch: refs/heads/master
Commit: 26fa0b21cfda3049e26d47ce174a9b29fe3ec29c
Parents: 1664c96
Author: Aljoscha Krettek
Authored: Fri May 6 08:26:50 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/24bfca23/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/TfIdfITCase.java
--
diff --git
a/runners/flink/runner/src/test/java/org/apache/beam/runners/flink
/incubator-beam/tree/1664c96d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1664c96d
Branch: refs/heads/master
Commit: 1664c96db5951d74b5ab9a5850def1dbef8adea6
Parents: af8e988
Author: Aljoscha Krettek
Authored: Fri May 6 09:38:55 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri
/diff/af8f5935
Branch: refs/heads/master
Commit: af8f5935ca1866012ceb102b9472c8b1ef102d73
Parents: dc98211 23ba976
Author: Aljoscha Krettek
Authored: Fri May 20 08:08:38 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:38 2016 +0200
mit: 23ba976403b308103ea8b7dd0505e5847dd44952
Parents: 24bfca2
Author: Aljoscha Krettek
Authored: Thu May 19 14:05:05 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
--
examples/java8/pom.xml | 12
1 file changed,
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/24bfca23/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkReduceFunction.java
--
diff --git
a/runners/flink/runner/src/main/java
-us.apache.org/repos/asf/incubator-beam/tree/58d66a34
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/58d66a34
Branch: refs/heads/master
Commit: 58d66a344985eecc9cc3f43c0ecd5dbc7b4fb2e6
Parents: dc98211
Author: Kenneth Knowles
Authored: Mon May 2 13:11:12 2016 -0700
Committer: Aljoscha
-us.apache.org/repos/asf/incubator-beam/diff/2d71af71
Branch: refs/heads/master
Commit: 2d71af71c26992c0ccbf2ab6df8f2a0aef5e586b
Parents: 55f39bf
Author: Kenneth Knowles
Authored: Fri May 6 10:55:16 2016 -0700
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
: 24bfca230d5db3cb75dd0e30093a10f7523c1238
Parents: 4e60a49
Author: Aljoscha Krettek
Authored: Tue May 10 13:53:03 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
--
runners/flink/runner/pom.xml| 10 -
.../apache
-wip-us.apache.org/repos/asf/incubator-beam/diff/bfc1a2ba
Branch: refs/heads/master
Commit: bfc1a2ba041c1b8b0033f886266321e5ee53cf6c
Parents: 58d66a3
Author: Kenneth Knowles
Authored: Mon May 2 14:04:20 2016 -0700
Committer: Aljoscha Krettek
Committed: Fri May 20 08:08:24 2016 +0200
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/24bfca23/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java
--
diff --git
a/runners/flink/runner/src/main/java/o
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/396
Remove Some Code leftover from Earlier Refactoring
R: @mxm
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator-beam
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/397
Clean up Flink Runner POMs
This moves the Kafka dependency form the runner POM to the examples POM.
R: @mxm
You can merge this pull request into a Git repository by running
/incubator-beam/diff/1cd64bb1
Branch: refs/heads/master
Commit: 1cd64bb1a7c24db8e7a8e5ecdd2971a4611e3620
Parents: 36a27f5 c24d5ff
Author: Aljoscha Krettek
Authored: Mon May 30 14:23:45 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon May 30 14:23:45 2016 +0200
010
Author: Aljoscha Krettek
Authored: Sun May 29 08:29:50 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon May 30 14:23:19 2016 +0200
--
runners/flink/examples/pom.xml | 6 ++
runners/flink/runner/pom.xml | 9 +++--
-beam/tree/4fe7010b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4fe7010b
Branch: refs/heads/master
Commit: 4fe7010bdb7692914fc6c2821c95caea0cab770d
Parents: 36a27f5
Author: Aljoscha Krettek
Authored: Sun May 29 08:04:39 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon May 30
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/397
---
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
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/347
---
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
mit: 971ea4de225f6efdd9ff862a6ff74ed05299f8a4
Parents: a829d9c
Author: Aljoscha Krettek
Authored: Wed May 18 17:46:34 2016 +0200
Committer: Aljoscha Krettek
Committed: Wed Jun 1 12:06:43 2016 +0200
--
.../wrappers/streaming
/diff/e9c0d8d0
Branch: refs/heads/master
Commit: e9c0d8d056a7ecfba447ea9bfeda4366ff44dcff
Parents: a829d9c 971ea4d
Author: Aljoscha Krettek
Authored: Wed Jun 1 12:07:07 2016 +0200
Committer: Aljoscha Krettek
Committed: Wed Jun 1 12:07:07 2016 +0200
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/409
[BEAM-321] Fix Flink Comparators
`KvCoderComparator` and `CoderComparator` were hashing the key directly
while doing comparisons on the encoded form. This lead to
inconsistencies in
:29 2016 +0800
Committer: Aljoscha Krettek
Committed: Tue Jun 7 10:32:37 2016 +0200
--
runners/flink/README.md | 6 +++---
1 file changed, 3 insertions(+), 3 deleti
/diff/5dc46357
Branch: refs/heads/master
Commit: 5dc46357c44f4c296c4a00dea47c7ff0e00f9aaa
Parents: 43c8f83 782c7b7
Author: Aljoscha Krettek
Authored: Tue Jun 7 10:33:02 2016 +0200
Committer: Aljoscha Krettek
Committed: Tue Jun 7 10:33:02 2016 +0200
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/883
Address comments of Flink Side-Input PR
R: @mxm
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator-beam flink-fixes
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/883
---
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
wip-us.apache.org/repos/asf/incubator-beam/tree/cae96380
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cae96380
Branch: refs/heads/master
Commit: cae96380f15fc293d00b444148e5d08c3f14d909
Parents: 33d747e
Author: Aljoscha Krettek
Authored: Thu Aug 25 11:00:39 2016 +0200
Commit
://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1dc1f25b
Branch: refs/heads/master
Commit: 1dc1f25b64eed7679e5d30309d5634052d187814
Parents: 33d747e cae9638
Author: Aljoscha Krettek
Authored: Wed Aug 31 11:05:18 2016 +0200
Committer: Aljoscha Krettek
Committed: Wed Aug 31 11:05:18
ttp://git-wip-us.apache.org/repos/asf/incubator-beam/tree/98da6e8f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/98da6e8f
Branch: refs/heads/master
Commit: 98da6e8fb014d2a93b7441f6b2b131968d874ab6
Parents: 1dc1f25
Author: Aljoscha Krettek
Authored: Wed Aug 31 13:42:30 2016 +0
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/921
[FLINK-616] Update Flink Runner to Flink 1.1.2
R: @mxm for review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/922
Fix shaded imports in Flink Runner
R: @mxm for review
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator-beam flink-fix
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/921
---
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
://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fb322cc7
Branch: refs/heads/master
Commit: fb322cc73aac6ed42b45371751388270d4f0db16
Parents: 31d09eb 2725959
Author: Aljoscha Krettek
Authored: Thu Sep 8 10:12:15 2016 +0200
Committer: Aljoscha Krettek
Committed: Thu Sep 8 10:12:15
://git-wip-us.apache.org/repos/asf/incubator-beam/diff/31d09eb4
Branch: refs/heads/master
Commit: 31d09eb45c4fcd5f88012145e64734785fe4c022
Parents: f33296c c66caf3
Author: Aljoscha Krettek
Authored: Thu Sep 8 10:11:02 2016 +0200
Committer: Aljoscha Krettek
Committed: Thu Sep 8 10:11:02
/asf/incubator-beam/diff/27259599
Branch: refs/heads/master
Commit: 2725959996d131b6d189f7f62df3d05e0d361ba0
Parents: 31d09eb
Author: Aljoscha Krettek
Authored: Mon Sep 5 10:50:14 2016 +0200
Committer: Aljoscha Krettek
Committed: Thu Sep 8 10:12:06 2016 +0200
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/922
---
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
ttp://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c66caf33
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c66caf33
Branch: refs/heads/master
Commit: c66caf3364ae5c20bdf0fbf41a8ef61d4e53c495
Parents: f33296c
Author: Aljoscha Krettek
Authored: Mon Sep 5 18:17:11 2016 +0
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/1021
[BEAM-615] Add Support for Processing-Time Timers in FlinkRunner
This adds support for processing-time timers that are checkpointed.
There are no tests for this yet but I ran this
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/483
Use native Flink rebalance for Reshuffle Transform
R: @mxm
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator-beam
ttp://git-wip-us.apache.org/repos/asf/incubator-beam/tree/93ca508b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/93ca508b
Branch: refs/heads/master
Commit: 93ca508bbdf558772e909df099148a9d03a1e6d4
Parents: 69a4141
Author: Aljoscha Krettek
Authored: Wed Jun 1 11:56:18 2016 +0
/diff/0e4d0a9a
Branch: refs/heads/master
Commit: 0e4d0a9ae0250863d7144ffdcc6c4e9cc099611f
Parents: 69a4141 93ca508
Author: Aljoscha Krettek
Authored: Sun Jun 19 11:35:19 2016 +0200
Committer: Aljoscha Krettek
Committed: Sun Jun 19 11:35:19 2016 +0200
: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2d3d0f4c
Branch: refs/heads/master
Commit: 2d3d0f4c2bbfddaf36e6b1068739c9ea48587d6d
Parents: df1d5f6
Author: Ismaël MejÃa
Authored: Wed Jun 29 23:00:02 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri Jul 1 07:50:35 2016 +0200
/diff/b4c123cd
Branch: refs/heads/master
Commit: b4c123cd4d41234c28926e302c8ea7c8900d3672
Parents: df1d5f6 d8c01c8
Author: Aljoscha Krettek
Authored: Fri Jul 1 07:53:18 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri Jul 1 07:53:18 2016 +0200
016 +0200
Committer: Aljoscha Krettek
Committed: Fri Jul 1 07:50:35 2016 +0200
--
.../main/java/org/apache/beam/examples/MinimalWordCount.java | 6 +++---
.../java/org/apache/beam/examples/MinimalWordCountJava8.java | 6 +++---
/diff/9adbecb6
Branch: refs/heads/master
Commit: 9adbecb6aa9bd752a6e6e39f41f80a31128d0918
Parents: 56c5277 b58a19c
Author: Aljoscha Krettek
Authored: Mon Jul 4 16:56:47 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon Jul 4 16:56:47 2016 +0200
ree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b58a19ce
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b58a19ce
Branch: refs/heads/master
Commit: b58a19cebebddbfb5bc8ebe9cc2766c5eccbda59
Parents: 56c5277
Author: Aljoscha Krettek
Authored: Fri Jun 17 15:16:19 2016 +0
/diff/1a7cd411
Branch: refs/heads/master
Commit: 1a7cd4112aab68d05dc59700883f63a082ea38e0
Parents: ee1a3bc 9000d95
Author: Aljoscha Krettek
Authored: Wed Jul 13 14:16:02 2016 +0200
Committer: Aljoscha Krettek
Committed: Wed Jul 13 14:16:02 2016 +0200
master
Commit: 9000d95d2b34ab45f799aedb140710986ff19452
Parents: ee1a3bc
Author: David Desberg
Authored: Mon Jul 11 12:24:18 2016 -0700
Committer: Aljoscha Krettek
Committed: Wed Jul 13 14:15:54 2016 +0200
--
.../FlinkStreamingTransformTra
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/737
Add Side-Input Support in Flink Streaming Runner
This does several things in somewhat isolated steps:
- Unify the operator wrappers. Before there where 4 different DoFn/Window
Author: aljoscha
Date: Fri Oct 21 16:55:14 2016
New Revision: 16619
Log:
Add aljoscha to incubator/beam/KEYS
Modified:
release/incubator/beam/KEYS
Modified: release/incubator/beam/KEYS
==
--- release/incubator/beam
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/1166
Fixes for Javadoc and ReduceFnRunner
Not sure if this is really wrong in `ReduceFnRunner`, was just a hunch.
R: @kennknowles
You can merge this pull request into a Git
Author: aljoscha
Date: Mon Oct 24 14:43:26 2016
New Revision: 16654
Log:
Add aljoscha to dev/incubator/beam/KEYS
Modified:
dev/incubator/beam/KEYS
Modified: dev/incubator/beam/KEYS
==
--- dev/incubator/beam/KEYS
mit/c26b63ba
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c26b63ba
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c26b63ba
Branch: refs/heads/master
Commit: c26b63baecde9105d32e3ba03874eb782162ecda
Parents: 69ae8bd
Author: Aljoscha Krettek
Authored: Mon Oct 24 17:36
mit/8dfadbf0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8dfadbf0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8dfadbf0
Branch: refs/heads/master
Commit: 8dfadbf01acc4fed6f604fe531e87730bab2b2bc
Parents: c26b63b
Author: Aljoscha Krettek
Authored: Mon Oct 24 17:36
Repository: incubator-beam
Updated Branches:
refs/heads/release-0.3.0-incubating [created] c26b63bae
tor-beam/commit/7a9ce4a4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7a9ce4a4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7a9ce4a4
Branch: refs/heads/release-0.3.0-incubating
Commit: 7a9ce4a40e39b8afd66039434607c7cb2c0df4eb
Parents: c26b63b
Author: Aljos
nts: 7a9ce4a
Author: Aljoscha Krettek
Authored: Mon Oct 24 18:54:22 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon Oct 24 18:54:22 2016 +0200
--
examples/java/pom.xml | 2 +-
examples/java8/pom.
Repository: incubator-beam
Updated Tags: refs/tags/v0.3.0-incubating-RC1 [created] 47447b7e0
hor: Aljoscha Krettek
Authored: Mon Oct 24 21:04:37 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon Oct 24 21:04:37 2016 +0200
--
.../examples/src/main/resources/archetype-resources/pom.xml | 8
.../starter/src/m
tor-beam/commit/564bbcc4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/564bbcc4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/564bbcc4
Branch: refs/heads/release-0.3.0-incubating
Commit: 564bbcc4bc0ef12933302fa3e63c6942d4ee94dc
Parents: e2d8a62
Author: Aljos
Repository: incubator-beam
Updated Tags: refs/tags/v0.3.0-incubating-RC1 [deleted] 47447b7e0
Repository: incubator-beam
Updated Branches:
refs/heads/release-0.3.0-incubating 564bbcc4b -> e2d8a62e3 (forced update)
tor-beam/commit/a4985be4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a4985be4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a4985be4
Branch: refs/heads/release-0.3.0-incubating
Commit: a4985be4a2ba7a6780e8f637d313518add8b2c11
Parents: e2d8a62
Author: Aljos
Repository: incubator-beam
Updated Tags: refs/tags/v0.3.0-incubating-RC1 [created] 5d86ff7f0
nts: a4985be
Author: Aljoscha Krettek
Authored: Mon Oct 24 21:45:25 2016 +0200
Committer: Aljoscha Krettek
Committed: Mon Oct 24 21:45:25 2016 +0200
--
examples/java/pom.xml | 2 +-
examples/java8/pom.
Author: aljoscha
Date: Mon Oct 24 20:48:49 2016
New Revision: 16664
Log:
Add Apache Beam 0.3.0-incubating RC1 Files
Added:
dev/incubator/beam/0.3.0-incubating/
dev/incubator/beam/0.3.0-incubating/apache-beam-0.3.0-incubating-source-release.zip
(with props)
dev/incubator/beam
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam-site/pull/52
Add pointers to 0.3.0-incubating release artifacts
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator-beam-site
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/1207
Fix Failing Flink RunnableOnService Tests
The problem was that the DoFnInvoker was invoking
createAggregatorForDoFn in the AggregatorFactory several times and
Flink only allows
ttp://git-wip-us.apache.org/repos/asf/incubator-beam/diff/837bb2b7
Branch: refs/heads/master
Commit: 837bb2b71e515c9170fa2c031c86a618b085b249
Parents: e82c5d2
Author: Aljoscha Krettek
Authored: Thu Oct 27 15:31:20 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri Oct 28 22:48:04 2016 +0
-beam/diff/beccdc68
Branch: refs/heads/master
Commit: beccdc6867a5e6bb2517bc4cb31c0cbee202beac
Parents: e82c5d2 837bb2b
Author: Aljoscha Krettek
Authored: Fri Oct 28 22:48:34 2016 +0200
Committer: Aljoscha Krettek
Committed: Fri Oct 28 22:48:34 2016 +0200
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam-site/pull/57
Some additions to the Release Guide
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/incubator-beam-site
update-release
Author: aljoscha
Date: Mon Oct 31 13:37:28 2016
New Revision: 16746
Log:
Add Beam 0.3.0-incubating release artifacts
Added:
release/incubator/beam/0.3.0-incubating/
release/incubator/beam/0.3.0-incubating/apache-beam-0.3.0-incubating-source-release.zip
(with props)
release
Repository: incubator-beam
Updated Tags: refs/tags/v0.3.0-incubating [created] fb7f162ab
Repository: incubator-beam-site
Updated Branches:
refs/heads/asf-site c60d96902 -> 141627ec4
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.TeardownPo
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowPipelineRegistrar.Runner.html
--
diff --git
a/content/learn/sdks/javadoc
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/DefaultTriggerStateMachine.html
--
diff --git
a/content/learn/sdks/javadoc/
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/package-tree.html
--
diff --git
a/content/learn/sdks/javadoc/0.3.0-incubati
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html
--
diff --git
a/content/learn/sdks/
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/class-use/UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter.html
--
diff
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html
--
diff --git
a/content/learn
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/FinishedTriggersBitSet.html
--
diff --git
a/content/learn/sdks/javadoc/0.3.
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/class-use/DataflowPipelineTranslator.TranslationContext.html
--
diff --git
a/con
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/AfterPaneStateMachine.html
--
diff --git
a/content/learn/sdks/jav
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/triggers/class-use/RepeatedlyStateMachine.html
--
diff --git
a/content/learn/sdks/ja
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/class-use/DataflowJobException.html
--
diff --git
a/content/learn/sdks/javadoc/0
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/contribute/contribution-guide/index.html
--
diff --git a/content/contribute/contribution-guide/index.html
b/content/contribute/contribution-guide/ind
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/core/PaneInfoTracker.html
--
diff --git
a/content/learn/sdks/javadoc/0.3.0-incubating/org
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/org/apache/beam/runners/dataflow/DataflowJobUpdatedException.html
--
diff --git
a/content/learn/sdks/javadoc/0.3.
1 - 100 of 289 matches
Mail list logo
