[44/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

0-incubating/options -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/options b/content/learn/sdks/javadoc/0.3.0-incubating/options new file mode 100644 index 000..746f61f --- /dev/null +++ b/content/learn/sdks/javadoc/0.3.0-

[43/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/DoFnRunner.ReduceFnExecutor.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-in

[40/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/GroupAlsoByWindowsViaOutputBufferDoFn.html -- diff --git a/content/learn/sdks/javado

[34/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter.html -- diff --git a/

[07/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/DataflowRunner.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/

[25/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate.html -- diff --git a/

[46/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/deprecated-list.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/deprecated-list.html b/content/l

[28/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/AfterDelayFromFirstElementStateMachine.html -- diff --git a/content/learn/s

[22/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/RepeatedlyStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.

[26/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/AfterPaneStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.0

[36/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/ReduceFnRunner.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/org/

[32/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/GBKIntoKeyedWorkItems.html -- diff --git a/content/learn/sdks/javadoc/0.3.

[13/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/TriggerStateMachine.html -- diff --git a/content/learn/sdks/javad

[11/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/DataflowJobAlreadyUpdatedException.html -- diff --git a/content/learn/sdks/javad

[02/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/DataflowPipelineOptions.html -- diff --git a/content/learn/sdks/javadoc/

[16/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/ExecutableTriggerStateMachine.html -- diff --git a/content/learn/

[39/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/GroupByKeyViaGroupByKeyOnly.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-in

[27/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/AfterEachStateMachine.html -- diff --git a/content/learn/sdks/javadoc/0.3.0

[47/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/constant-values.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/constant-values.html b/content/l

[45/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/index-all.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/index-all.html b/content/learn/sdks/ja

[48/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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 b/co

[35/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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 a/content/learn/sdks/javadoc/0.3.0-incubating/org

[04/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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 a/content/learn/sdks/javadoc/0.3

[41/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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 a/content/learn/sdks/javadoc/0.

[19/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-i

[51/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

/incubator-beam-site/diff/141627ec Branch: refs/heads/asf-site Commit: 141627ec4b6e57589deac52b284dcd4ed542e399 Parents: 1841a9a Author: Aljoscha Krettek Authored: Mon Oct 31 17:18:16 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Oct 31 17:18:26 2016 +0100

[29/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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 a/content/learn/sdks/javadoc/0.3.0-

[18/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/TriggerStateMachineRunner.html -- diff --git a/content/learn/sdks/javadoc/0

[21/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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.OnElementContext.html -- diff --git a/content/learn/sdk

[31/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/ReduceFn.Context.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-inc

[14/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/TriggerStateMachine.OnceTriggerStateMachine.html -- diff --git a/

[03/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/DataflowPipelineDebugOptions.html -- diff --git a/content/learn/sdks/jav

[33/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/DoFnRunner.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubatin

[42/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/ElementAndRestriction.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubati

[49/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/141627ec/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-frame.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incubating/allclasses-frame.html b/content

[37/51] [abbrv] [partial] incubator-beam-site git commit: Rebuild site

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/ReduceFn.OnMergeContext.html -- diff --git a/content/learn/sdks/javadoc/0.3.0-incuba

[GitHub] incubator-beam pull request #1311: [BEAM-931] Fix Findbugs Warnings in Flink...

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

[GitHub] incubator-beam pull request #1311: [BEAM-931] Fix Findbugs Warnings in Flink...

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, or if the

[1/2] incubator-beam git commit: [BEAM-931] Fix Findbugs Warnings in Flink Runner

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 Authored: Tue Nov 8 11:56:45 2016 +0

[2/2] incubator-beam git commit: This closes #1311

-beam/diff/66faf74d Branch: refs/heads/master Commit: 66faf74d084e4eba982063c9ca81673b0cfece4b Parents: ef750c0 a609a19 Author: Aljoscha Krettek Authored: Thu Nov 10 10:37:46 2016 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 10 10:37:46 2016 +0100

[2/2] incubator-beam git commit: This closes #1333

-beam/diff/8daa8b51 Branch: refs/heads/master Commit: 8daa8b519fe5b2f3286c3f592a26841a374c057c Parents: 66faf74 d8f3da6 Author: Aljoscha Krettek Authored: Thu Nov 10 15:47:59 2016 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 10 15:47:59 2016 +0100

[1/2] incubator-beam git commit: Remove Leftover Sysout Printing in Flink Runner

400 Committer: Aljoscha Krettek Committed: Thu Nov 10 15:47:15 2016 +0100 -- .../flink/translation/FlinkStreamingTransformTranslators.java | 2 -- 1 file changed, 2 deleti

[GitHub] incubator-beam pull request #1352: [BEAM-965] Set Correct Output Type on Sou...

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

[GitHub] incubator-beam-site pull request #79: [BEAM-899] Add Flink Instructions to q...

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

[1/2] incubator-beam git commit: [BEAM-965] Set Correct Output Type on Sources in Flink Stream Runner

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 Authored: Fri Nov 11

[2/2] incubator-beam git commit: This closes #1352

-beam/diff/ee55f6e3 Branch: refs/heads/master Commit: ee55f6e39ff429cd406835c789ce89c4b01fb4c4 Parents: 8bfa085 a61832a Author: Aljoscha Krettek Authored: Mon Nov 14 22:07:53 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Nov 14 22:07:53 2016 +0100

[2/3] incubator-beam-site git commit: Regenerate Website

/asf/incubator-beam-site/diff/3f72e67a Branch: refs/heads/asf-site Commit: 3f72e67ac42e1fd094472c42bebe03520c8c98e4 Parents: b3cc5a2 Author: Aljoscha Krettek Authored: Mon Nov 21 10:35:15 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Nov 21 10:35:15 2016 +0100

[3/3] incubator-beam-site git commit: This closes #90

/incubator-beam-site/diff/0c4bff77 Branch: refs/heads/asf-site Commit: 0c4bff77b31b4fc2809a4dbaf3ac8193f08187fd Parents: f5a0847 3f72e67 Author: Aljoscha Krettek Authored: Mon Nov 21 10:35:27 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Nov 21 10:35:27 2016 +0100

[1/3] incubator-beam-site git commit: [BEAM-1007] Fixed toggles code, to work in safari

Wed Nov 2 09:04:41 2016 +0500 Committer: Aljoscha Krettek Committed: Mon Nov 21 10:32:01 2016 +0100 -- src/js/language-switch.js | 5 ++--- 1 file changed, 2 insertions(+), 3 deleti

[GitHub] incubator-beam pull request #1435: Replace WindowAssignment OldDoFn by FlatM...

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

[2/2] incubator-beam git commit: This closes #1435

-beam/diff/8d1214a3 Branch: refs/heads/master Commit: 8d1214a3ba94b21102b74d346e73f24ecd9056f2 Parents: 3e4b2fd 4a09772 Author: Aljoscha Krettek Authored: Thu Nov 24 15:20:49 2016 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 24 15:20:49 2016 +0100

[1/2] incubator-beam git commit: Replace WindowAssignment OldDoFn by FlatMap in Flink Runner

ter Commit: 4a097729ac9fc65283f4f11f85812188589c8df3 Parents: 3e4b2fd Author: Aljoscha Krettek Authored: Tue Nov 8 11:03:21 2016 +0100 Committer: Aljoscha Krettek Committed: Thu Nov 24 11:39:30 2016 +0

[GitHub] incubator-beam pull request #1446: Ignore UsesStatefulParDo Tests in Flink S...

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] incubator-beam-site pull request #97: [BEAM-506] Fill in the documentation/r...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam-site/pull/97 [BEAM-506] Fill in the documentation/runners/flink portion of the website The outline of this is based on the doc for the Cloud Dataflow runner. R: @davorbonaci and @mxm You

[GitHub] incubator-beam-site pull request #99: Simplify Flink Runner instructions for...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam-site/pull/99 Simplify Flink Runner instructions for running on cluster R: @davorbonaci I think this should be simple/straighforward enough now 😃 You can merge this pull request into a Git

[GitHub] incubator-beam pull request #1530: [FLINK-1102] Fix Aggregator Registration ...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam/pull/1530 [FLINK-1102] Fix Aggregator Registration in Flink Batch Runner R: @dhalperi This is a quick fix now but we definitely need tests for aggregators, both in streaming and batch

[2/2] incubator-beam git commit: This closes #1530

-beam/diff/b41a46e8 Branch: refs/heads/master Commit: b41a46e86fd38c4a887f31bdf6cb75969f4750d3 Parents: 0a2ed83 869b271 Author: Aljoscha Krettek Authored: Wed Dec 7 15:26:02 2016 +0800 Committer: Aljoscha Krettek Committed: Wed Dec 7 15:26:02 2016 +0800

[1/2] incubator-beam git commit: [FLINK-1102] Fix Aggregator Registration in Flink Batch Runner

mit/869b2710 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/869b2710 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/869b2710 Branch: refs/heads/master Commit: 869b2710efdb90bc3ce5b6e9d4f3b49a3a804a63 Parents: 0a2ed83 Author: Aljoscha Krettek Authored: Wed Dec 7 13:28

[1/2] incubator-beam git commit: [BEAM-1095] Add support set config for reuse-object on flink

016 +0400 Committer: Aljoscha Krettek Committed: Thu Dec 8 09:44:00 2016 +0800 -- .../flink/FlinkPipelineExecutionEnvironment.java| 12 .../apache/beam/runners/flink/FlinkPipelineOptions.java | 5 + 2 fi

[2/2] incubator-beam git commit: This closes #1518

-beam/diff/c53e0b16 Branch: refs/heads/master Commit: c53e0b1623e3ee3c08c329e2716440f031681591 Parents: 3b2e029 1b12520 Author: Aljoscha Krettek Authored: Thu Dec 8 09:44:07 2016 +0800 Committer: Aljoscha Krettek Committed: Thu Dec 8 09:44:07 2016 +0800

[1/2] incubator-beam git commit: [BEAM-1096] Flink streaming side output optimization using SplitStream

:48:35 2016 +0400 Committer: Aljoscha Krettek Committed: Thu Dec 8 09:55:22 2016 +0800 -- .../FlinkStreamingTransformTranslators.java | 28 +--- 1 file changed, 18 insertions(+), 10 deleti

[2/2] incubator-beam git commit: This closes #1520

-beam/diff/6807480a Branch: refs/heads/master Commit: 6807480a97f2315b3f48ad8dd5accb4e30475fa4 Parents: c53e0b1 f1a5704 Author: Aljoscha Krettek Authored: Thu Dec 8 09:55:32 2016 +0800 Committer: Aljoscha Krettek Committed: Thu Dec 8 09:55:32 2016 +0800

[1/2] incubator-beam git commit: [BEAM-1165] Fix unexpected file creation when checking dependencies

asf/incubator-beam/tree/9bd4288f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9bd4288f Branch: refs/heads/master Commit: 9bd4288f13ac3f279b795e93adcfa3f897ef266c Parents: 1e148cd Author: Ismaël Mejía Authored: Thu Dec 15 22:06:18 2016 +0100 Committer: Aljoscha Krettek Committed: Mon

[2/2] incubator-beam git commit: This closes #1632

-beam/diff/203b7b17 Branch: refs/heads/master Commit: 203b7b174ad6e4194baae6965a1e714c4acadf8c Parents: 1e148cd 9bd4288 Author: Aljoscha Krettek Authored: Mon Dec 19 12:09:03 2016 +0100 Committer: Aljoscha Krettek Committed: Mon Dec 19 12:09:03 2016 +0100

[jira] [Commented] (BEAM-236) Implement Windowing in batch execution

[ https://issues.apache.org/jira/browse/BEAM-236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262122#comment-15262122 ] Aljoscha Krettek commented on BEAM-236: --- By the way, don't forget to correct

[jira] [Commented] (BEAM-139) Print mode (batch/streaming) during translation

[ https://issues.apache.org/jira/browse/BEAM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263979#comment-15263979 ] Aljoscha Krettek commented on BEAM-139: --- +1, this is rendered obsolete by BEAM

[jira] [Commented] (BEAM-103) Make UnboundedSourceWrapper parallel

[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263981#comment-15263981 ] Aljoscha Krettek commented on BEAM-103: --- [~mxm] You mentioned once that you alr

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264018#comment-15264018 ] Aljoscha Krettek commented on BEAM-52: -- [~rangadi], [~dhalp...@google.com] is anyon

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264037#comment-15264037 ] Aljoscha Krettek commented on BEAM-52: -- Ok, thanks! I'll get crackin'

[jira] [Commented] (BEAM-103) Make UnboundedSourceWrapper parallel

[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264040#comment-15264040 ] Aljoscha Krettek commented on BEAM-103: --- @mxm I don't now, thought so. :-

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264733#comment-15264733 ] Aljoscha Krettek commented on BEAM-52: -- Ah, I also implemented one here: h

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15265165#comment-15265165 ] Aljoscha Krettek commented on BEAM-52: -- Sure, I'll do that! > Kafka

[jira] [Commented] (BEAM-241) Not easy for runners to get late-data dropping

[ https://issues.apache.org/jira/browse/BEAM-241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266262#comment-15266262 ] Aljoscha Krettek commented on BEAM-241: --- I think the short-term (and maybe also

[jira] [Commented] (BEAM-246) Do not build source jar, javadoc, in default Maven profile.

[ https://issues.apache.org/jira/browse/BEAM-246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15267038#comment-15267038 ] Aljoscha Krettek commented on BEAM-246: --- +1, good idea > Do not build sou

[jira] [Comment Edited] (BEAM-241) Not easy for runners to get late-data dropping

[ https://issues.apache.org/jira/browse/BEAM-241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266262#comment-15266262 ] Aljoscha Krettek edited comment on BEAM-241 at 5/2/16 5:3

[jira] [Commented] (BEAM-241) Not easy for runners to get late-data dropping

[ https://issues.apache.org/jira/browse/BEAM-241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268405#comment-15268405 ] Aljoscha Krettek commented on BEAM-241: --- I see, in there you are also relying on

[jira] [Created] (BEAM-253) Unify Flink Operator Wrappers

Aljoscha Krettek created BEAM-253: - Summary: Unify Flink Operator Wrappers Key: BEAM-253 URL: https://issues.apache.org/jira/browse/BEAM-253 Project: Beam Issue Type: Improvement

[jira] [Assigned] (BEAM-103) Make UnboundedSourceWrapper parallel

[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-103: - Assignee: Aljoscha Krettek (was: Kostas Kloudas) > Make UnboundedSourceWrapper paral

[jira] [Assigned] (BEAM-130) Checkpointing of custom sources and sinks

[ https://issues.apache.org/jira/browse/BEAM-130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-130: - Assignee: Aljoscha Krettek (was: Kostas Kloudas) > Checkpointing of custom sources

[jira] [Resolved] (BEAM-129) Support pubsub IO

[ https://issues.apache.org/jira/browse/BEAM-129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved BEAM-129. --- Resolution: Invalid Subsumed by BEAM-53 > Support pubsub

[jira] [Commented] (BEAM-140) Improve examples provided with the Flink runner

[ https://issues.apache.org/jira/browse/BEAM-140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268726#comment-15268726 ] Aljoscha Krettek commented on BEAM-140: --- +1 for unification > Improve e

[jira] [Commented] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274961#comment-15274961 ] Aljoscha Krettek commented on BEAM-216: --- Btw, this is a duplicate of BE

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274971#comment-15274971 ] Aljoscha Krettek commented on BEAM-242: --- The PR is merged but checkstyle is not

[jira] [Commented] (BEAM-260) Know the getSideInputWindow upper bound so can gc side input state

[ https://issues.apache.org/jira/browse/BEAM-260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15275128#comment-15275128 ] Aljoscha Krettek commented on BEAM-260: --- I thought about this as well while wor

[jira] [Created] (BEAM-270) Use WindowedValue in Flink Batch

Aljoscha Krettek created BEAM-270: - Summary: Use WindowedValue in Flink Batch Key: BEAM-270 URL: https://issues.apache.org/jira/browse/BEAM-270 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-270) Use WindowedValue in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-270: -- Issue Type: Sub-task (was: Improvement) Parent: BEAM-258 > Use WindowedValue in Fl

[jira] [Resolved] (BEAM-130) Checkpointing of custom sources and sinks

[ https://issues.apache.org/jira/browse/BEAM-130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved BEAM-130. --- Resolution: Fixed Resolved in this (closed) PR: https://github.com/apache/incubator-beam/pull

[jira] [Resolved] (BEAM-103) Make UnboundedSourceWrapper parallel

[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved BEAM-103. --- Resolution: Fixed > Make UnboundedSourceWrapper paral

[jira] [Updated] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-270: -- Summary: Support Timestamps/Windows in Flink Batch (was: Use WindowedValue in Flink Batch

[jira] [Assigned] (BEAM-270) Use WindowedValue in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-270: - Assignee: Aljoscha Krettek > Use WindowedValue in Flink Ba

[jira] [Updated] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-270: -- Description: Right now, Flink Batch execution does not use {{WindowedValue}} internally, this

[jira] [Commented] (BEAM-270) Support Timestamps/Windows in Flink Batch

[ https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279741#comment-15279741 ] Aljoscha Krettek commented on BEAM-270: --- I added the window thing here as

[jira] [Closed] (BEAM-236) Implement Windowing in batch execution

[ https://issues.apache.org/jira/browse/BEAM-236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-236. - Resolution: Duplicate Superseded by BEAM-270 > Implement Windowing in batch execut

[jira] [Created] (BEAM-283) CheckpointMark.finalize() is not called in Flink Source Wrapper

Aljoscha Krettek created BEAM-283: - Summary: CheckpointMark.finalize() is not called in Flink Source Wrapper Key: BEAM-283 URL: https://issues.apache.org/jira/browse/BEAM-283 Project: Beam

[jira] [Commented] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286468#comment-15286468 ] Aljoscha Krettek commented on BEAM-286: --- +1, I think the examples can be rem

[jira] [Commented] (BEAM-291) PDone type translation fails

[ https://issues.apache.org/jira/browse/BEAM-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286597#comment-15286597 ] Aljoscha Krettek commented on BEAM-291: --- Could you maybe post the code for

[jira] [Commented] (BEAM-291) PDone type translation fails

[ https://issues.apache.org/jira/browse/BEAM-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286608#comment-15286608 ] Aljoscha Krettek commented on BEAM-291: --- Also, I think {{PDone}} is never to be

[jira] [Commented] (BEAM-48) BigQueryIO.Read reimplemented as BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-48?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286670#comment-15286670 ] Aljoscha Krettek commented on BEAM-48: -- [~dhalp...@google.com] I saw that you me

[jira] [Commented] (BEAM-273) Update Flink Runner version

[ https://issues.apache.org/jira/browse/BEAM-273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286676#comment-15286676 ] Aljoscha Krettek commented on BEAM-273: --- Are there further steps towards updating

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286673#comment-15286673 ] Aljoscha Krettek commented on BEAM-131: --- Can this one be closed now that i

<    1   2   3   >