[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) > Sup

[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 parallel >

[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/27

[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 Flink Bat

[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] [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 working on

[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 yet gl

[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 BEAM-9. > Create

[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 examples provi

[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 IO > - > >

[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 and sin

[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 parallel >

[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 Co

[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 the f

[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:33 PM: ---

[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 source jar, jav

[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 long-t

[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! > KafkaIO - bounded/unbound

[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: https://github

[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. :-) > Make Unb

[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' :-) > KafkaIO - b

[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 anyone of

[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 already ha

[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-235. >

[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 correctly handle

<    1   2