ok.com>
Authored: Sat May 21 18:32:29 2016 +0800
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Tue Jun 7 10:32:37 2016 +0200
--
runners/flink/README.md | 6 +++---
1 file changed, 3 insertions(
/diff/5dc46357
Branch: refs/heads/master
Commit: 5dc46357c44f4c296c4a00dea47c7ff0e00f9aaa
Parents: 43c8f83 782c7b7
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Tue Jun 7 10:33:02 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Tue Ju
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
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 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
-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 <aljoscha.kret...@gmail.com>
Authored: Sun May 29 08:04:39 2016 +0200
Committer: Al
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
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
mit: 971ea4de225f6efdd9ff862a6ff74ed05299f8a4
Parents: a829d9c
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Wed May 18 17:46:34 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Wed Jun 1 12:0
/diff/e9c0d8d0
Branch: refs/heads/master
Commit: e9c0d8d056a7ecfba447ea9bfeda4366ff44dcff
Parents: a829d9c 971ea4d
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Wed Jun 1 12:07:07 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Wed Ju
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 <aljoscha.kret...@gmail.com>
Authored
/diff/0e4d0a9a
Branch: refs/heads/master
Commit: 0e4d0a9ae0250863d7144ffdcc6c4e9cc099611f
Parents: 69a4141 93ca508
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Sun Jun 19 11:35:19 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Sun Jun
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
: 24bfca230d5db3cb75dd0e30093a10f7523c1238
Parents: 4e60a49
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Tue May 10 13:53:03 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri May 20 08:08:24 2016 +0200
---
-wip-us.apache.org/repos/asf/incubator-beam/diff/bfc1a2ba
Branch: refs/heads/master
Commit: bfc1a2ba041c1b8b0033f886266321e5ee53cf6c
Parents: 58d66a3
Author: Kenneth Knowles <k...@google.com>
Authored: Mon May 2 14:04:20 2016 -0700
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com&g
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
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
-0700
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri May 20 08:08:24 2016 +0200
--
.../beam/runners/flink/FlinkPipelineRunner.java | 16 +
.../runners/flink/FlinkRunnerRegistrar.java | 4 +-
.../r
-us.apache.org/repos/asf/incubator-beam/diff/2d71af71
Branch: refs/heads/master
Commit: 2d71af71c26992c0ccbf2ab6df8f2a0aef5e586b
Parents: 55f39bf
Author: Kenneth Knowles <k...@google.com>
Authored: Fri May 6 10:55:16 2016 -0700
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Commit
://git-wip-us.apache.org/repos/asf/incubator-beam/diff/af8e9887
Branch: refs/heads/master
Commit: af8e98878bbc8678e33a4c00548ccabf6cf55a17
Parents: 2d71af7
Author: Kenneth Knowles <k...@google.com>
Authored: Fri May 6 12:49:55 2016 -0700
Committer: Aljoscha Krettek <aljoscha.kret...@
/incubator-beam/diff/26fa0b21
Branch: refs/heads/master
Commit: 26fa0b21cfda3049e26d47ce174a9b29fe3ec29c
Parents: 1664c96
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Fri May 6 08:26:50 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri May
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
/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 <aljoscha.kret...@gmail.com>
Authored: Fri May 6 09:38:55 2016 +0200
Com
/diff/af8f5935
Branch: refs/heads/master
Commit: af8f5935ca1866012ceb102b9472c8b1ef102d73
Parents: dc98211 23ba976
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Fri May 20 08:08:38 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri May
mit: 23ba976403b308103ea8b7dd0505e5847dd44952
Parents: 24bfca2
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu May 19 14:05:05 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
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 <k...@google.com>
Authored: Fri May 6 10:54:41 2016 -0700
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed
-us.apache.org/repos/asf/incubator-beam/diff/4e60a497
Branch: refs/heads/master
Commit: 4e60a497b313414aa2b2968b8def6c6f753908fe
Parents: 26fa0b2
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Fri May 13 14:17:50 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@
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
/diff/4020e364
Branch: refs/heads/master
Commit: 4020e364598befbd68458f1c6eada6d90a986358
Parents: 874ddef 336e90f
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Tue May 10 22:20:47 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Tue May
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/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 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
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 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 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
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
master
Commit: 9000d95d2b34ab45f799aedb140710986ff19452
Parents: ee1a3bc
Author: David Desberg <david.desb...@uber.com>
Authored: Mon Jul 11 12:24:18 2016 -0700
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Wed J
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 <aljoscha.kret...@gmail.com>
Auth
/diff/9adbecb6
Branch: refs/heads/master
Commit: 9adbecb6aa9bd752a6e6e39f41f80a31128d0918
Parents: 56c5277 b58a19c
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Jul 4 16:56:47 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Mon Ju
: 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 <ieme...@gmail.com>
Authored: Wed Jun 29 23:00:02 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@
ored: Wed Jun 29 23:12:06 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri Jul 1 07:50:35 2016 +0200
--
.../main/java/org/apache/beam/examples/MinimalWordCount.java | 6 +++---
.../java/
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 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
-us.apache.org/repos/asf/incubator-beam/diff/fb322cc7
Branch: refs/heads/master
Commit: fb322cc73aac6ed42b45371751388270d4f0db16
Parents: 31d09eb 2725959
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Sep 8 10:12:15 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@
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
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 <aljoscha.kret...@gmail.com>
Authored:
-us.apache.org/repos/asf/incubator-beam/diff/31d09eb4
Branch: refs/heads/master
Commit: 31d09eb45c4fcd5f88012145e64734785fe4c022
Parents: f33296c c66caf3
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Sep 8 10:11:02 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@
/asf/incubator-beam/diff/27259599
Branch: refs/heads/master
Commit: 2725959996d131b6d189f7f62df3d05e0d361ba0
Parents: 31d09eb
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Sep 5 10:50:14 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed:
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
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
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 <aljoscha.kret...@gmail.com>
Authored: Thu
-us.apache.org/repos/asf/incubator-beam/diff/1dc1f25b
Branch: refs/heads/master
Commit: 1dc1f25b64eed7679e5d30309d5634052d187814
Parents: 33d747e cae9638
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Wed Aug 31 11:05:18 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@
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 <aljoscha.kret...@gmail.com>
Auth
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
-beam/diff/beccdc68
Branch: refs/heads/master
Commit: beccdc6867a5e6bb2517bc4cb31c0cbee202beac
Parents: e82c5d2 837bb2b
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Fri Oct 28 22:48:34 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri Oct
ttp://git-wip-us.apache.org/repos/asf/incubator-beam/diff/837bb2b7
Branch: refs/heads/master
Commit: 837bb2b71e515c9170fa2c031c86a618b085b249
Parents: e82c5d2
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Oct 27 15:31:20 2016 +0200
Committer: Aljoscha Krettek <a
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/1311
[BEAM-931] Fix Findbugs Warnings in Flink Runner
I manually checked via `mvn findbugs:check`. This is not currently
activated in the pre-commit hook, is it?
R: @dhalperi
You
ttp://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a609a19e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a609a19e
Branch: refs/heads/master
Commit: a609a19e6df763c0aa77d83f05e21ec343f6dcdb
Parents: ef750c0
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Auth
-beam/diff/66faf74d
Branch: refs/heads/master
Commit: 66faf74d084e4eba982063c9ca81673b0cfece4b
Parents: ef750c0 a609a19
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Nov 10 10:37:46 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Thu Nov
Github user aljoscha closed the pull request at:
https://github.com/apache/incubator-beam/pull/1311
---
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
10 16:57:43 2016 +0400
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Thu Nov 10 15:47:15 2016 +0100
--
.../flink/translation/FlinkStreamingTransformTranslators.java | 2 --
1 file chang
-beam/diff/8daa8b51
Branch: refs/heads/master
Commit: 8daa8b519fe5b2f3286c3f592a26841a374c057c
Parents: 66faf74 d8f3da6
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Nov 10 15:47:59 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Thu Nov
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
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
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
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 <aljoscha.kret...@gma
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 <aljoscha.kret...@gma
Repository: incubator-beam
Updated Branches:
refs/heads/release-0.3.0-incubating [created] c26b63bae
Repository: incubator-beam
Updated Tags: refs/tags/v0.3.0-incubating-RC1 [created] 47447b7e0
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 <aljoscha.kret...@gmail.com>
Authored: Mon Oct 24 18:54:22 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Mon Oct 24 18:54:22 2016 +0200
--
exampl
hor: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Oct 24 21:04:37 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Mon Oct 24 21:04:37 2016 +0200
--
.../examples/src/main/reso
Repository: incubator-beam
Updated Tags: refs/tags/v0.3.0-incubating-RC1 [deleted] 47447b7e0
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 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 <aljoscha.kret...@gmail.com>
Authored: Mon Oct 24 21:45:25 2016 +0200
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Mon Oct 24 21:45:25 2016 +0200
--
exampl
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/pull/1435
Replace WindowAssignment OldDoFn by FlatMap in FLink Runner
The streaming runner had an OldDoFn that was used for assigning windows
using a WindowFn. This is now done with a FlatMap
-beam/diff/8d1214a3
Branch: refs/heads/master
Commit: 8d1214a3ba94b21102b74d346e73f24ecd9056f2
Parents: 3e4b2fd 4a09772
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Nov 24 15:20:49 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Thu Nov
ter
Commit: 4a097729ac9fc65283f4f11f85812188589c8df3
Parents: 3e4b2fd
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Tue Nov 8 11:03:21 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Thu Nov 24 11:3
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/1446
Ignore UsesStatefulParDo Tests in Flink Streaming Runner
Until we fix BEAM-1036 we need to ignore those tests. Before, only the
tests for the batch runner ignored them.
You can merge
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam/pull/1352
[BEAM-965] Set Correct Output Type on Sources in Flink Stream Runner
R: @mxm
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha
/asf/incubator-beam-site/diff/3f72e67a
Branch: refs/heads/asf-site
Commit: 3f72e67ac42e1fd094472c42bebe03520c8c98e4
Parents: b3cc5a2
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Nov 21 10:35:15 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Co
/incubator-beam-site/diff/0c4bff77
Branch: refs/heads/asf-site
Commit: 0c4bff77b31b4fc2809a4dbaf3ac8193f08187fd
Parents: f5a0847 3f72e67
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Nov 21 10:35:27 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com&g
dullah...@gmail.com>
Authored: Wed Nov 2 09:04:41 2016 +0500
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Mon Nov 21 10:32:01 2016 +0100
--
src/js/language-switch.js | 5 ++---
1 file changed, 2 i
GitHub user aljoscha opened a pull request:
https://github.com/apache/incubator-beam-site/pull/79
[BEAM-899] Add Flink Instructions to quickstart.md
I added a section about runner specific dependencies in the Quickstart.
R: @francesperry
You can merge this pull request
mit/a61832a8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a61832a8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a61832a8
Branch: refs/heads/master
Commit: a61832a83c15e0aa5e3cc1985fc32aa1afb348e6
Parents: 8bfa085
Author: Aljoscha Krettek <aljosch
-beam/diff/ee55f6e3
Branch: refs/heads/master
Commit: ee55f6e39ff429cd406835c789ce89c4b01fb4c4
Parents: 8bfa085 a61832a
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Nov 14 22:07:53 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Mon Nov
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
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
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-noframe.html
--
diff --git
a/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-noframe.html
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/SplittableParDo.html
--
diff --git
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/CloudDebuggerOptions.html
--
diff --git
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/GroupAlsoByWindowViaWindowSetDoFn.html
--
diff --git
/incubator-beam-site/diff/141627ec
Branch: refs/heads/asf-site
Commit: 141627ec4b6e57589deac52b284dcd4ed542e399
Parents: 1841a9a
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Mon Oct 31 17:18:16 2016 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed
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/AfterAllStateMachine.html
--
diff --git
1 - 100 of 266 matches
Mail list logo
