[
https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15748240#comment-15748240
]
Aljoscha Krettek commented on BEAM-1148:
Just out of curiosity, what are they going to be replaced
[
https://issues.apache.org/jira/browse/BEAM-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-1096:
---
Assignee: Alexey Diomin
> flink streaming side output optimization using SplitStream
>
[
https://issues.apache.org/jira/browse/BEAM-1095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-1095:
---
Assignee: Alexey Diomin
> Add support set config for reuse-object on flink
>
[
https://issues.apache.org/jira/browse/BEAM-1095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-1095.
--
Resolution: Fixed
Fix Version/s: 0.4.0-incubating
> Add support set config for
[
https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15730375#comment-15730375
]
Aljoscha Krettek commented on BEAM-1107:
Yep, you're right but even in the black text the operation
[
https://issues.apache.org/jira/browse/BEAM-1102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-1102.
--
Resolution: Fixed
Fix Version/s: 0.4.0-incubating
> Flink Batch Runner does not populate
Aljoscha Krettek created BEAM-1103:
--
Summary: Add Tests For Aggregators in Flink Runner
Key: BEAM-1103
URL: https://issues.apache.org/jira/browse/BEAM-1103
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-1102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727742#comment-15727742
]
Aljoscha Krettek commented on BEAM-1102:
The problem is this part in {{FlinkProcessContextBase}}:
[
https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-1092:
---
Comment: was deleted
(was: Is 1) necessary if we do 2).
I think shading is very necessary
[
https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727530#comment-15727530
]
Aljoscha Krettek commented on BEAM-1092:
Is 1) necessary if we do 2)?
I think shading is very
[
https://issues.apache.org/jira/browse/BEAM-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727529#comment-15727529
]
Aljoscha Krettek commented on BEAM-1092:
Is 1) necessary if we do 2).
I think shading is very
[
https://issues.apache.org/jira/browse/BEAM-506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-506.
-
Resolution: Fixed
Fix Version/s: Not applicable
> Fill in the documentation/runners/flink
[
https://issues.apache.org/jira/browse/BEAM-506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-506:
-
Assignee: Aljoscha Krettek (was: James Malone)
> Fill in the documentation/runners/flink
[
https://issues.apache.org/jira/browse/BEAM-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-1007.
--
Resolution: Fixed
Fix Version/s: Not applicable
> Runner Toggles in Quickstart.md Don't
[
https://issues.apache.org/jira/browse/BEAM-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-1007:
---
Attachment: Screen Shot 2016-11-19 at 00.00.45.png
> Runner Toggles in Quickstart.md Don't
[
https://issues.apache.org/jira/browse/BEAM-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15678046#comment-15678046
]
Aljoscha Krettek commented on BEAM-1007:
[~mabdullah353], I assigned to you because you initially
Aljoscha Krettek created BEAM-1007:
--
Summary: Runner Toggles in Quickstart.md Don't Work in Safari
Key: BEAM-1007
URL: https://issues.apache.org/jira/browse/BEAM-1007
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-899.
-
Resolution: Fixed
Fix Version/s: 0.4.0-incubating
> Flink quickstart instructions
>
[
https://issues.apache.org/jira/browse/BEAM-965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-965.
-
Resolution: Fixed
> Source Transformations Don't Set Correct Output Type in Flink Streaming Runner
[
https://issues.apache.org/jira/browse/BEAM-899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15659390#comment-15659390
]
Aljoscha Krettek commented on BEAM-899:
---
Sorry for the delay, I'm working on this myself now.
> Flink
Aljoscha Krettek created BEAM-965:
-
Summary: Source Operations Don't Set Correct Output Type in Flink
Streaming Runner
Key: BEAM-965
URL: https://issues.apache.org/jira/browse/BEAM-965
Project: Beam
Aljoscha Krettek created BEAM-956:
-
Summary: Execute ReduceFnRunner Directly in Flink Runner
Key: BEAM-956
URL: https://issues.apache.org/jira/browse/BEAM-956
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-931.
-
Resolution: Fixed
Fix Version/s: 0.4.0-incubating
> Findbugs doesn't pass in Flink runner
>
[
https://issues.apache.org/jira/browse/BEAM-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-806:
--
Fix Version/s: (was: 0.3.0-incubating)
0.4.0-incubating
> Maven Release
Aljoscha Krettek created BEAM-864:
-
Summary: Update to latest Apache Maven-Parent
Key: BEAM-864
URL: https://issues.apache.org/jira/browse/BEAM-864
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15616689#comment-15616689
]
Aljoscha Krettek commented on BEAM-862:
---
No problemo!
> Flink PostCommit Fails On Jenkins
>
[
https://issues.apache.org/jira/browse/BEAM-862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-862.
-
Resolution: Fixed
> Flink PostCommit Fails On Jenkins
> -
>
>
Aljoscha Krettek created BEAM-862:
-
Summary: Flink PostCommit Fails On Jenkins
Key: BEAM-862
URL: https://issues.apache.org/jira/browse/BEAM-862
Project: Beam
Issue Type: Bug
Aljoscha Krettek created BEAM-843:
-
Summary: Use New DoFn Directly in Flink Runner
Key: BEAM-843
URL: https://issues.apache.org/jira/browse/BEAM-843
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602937#comment-15602937
]
Aljoscha Krettek commented on BEAM-696:
---
Just a clarification, the Flink runner does not pre combine
[
https://issues.apache.org/jira/browse/BEAM-806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-806:
--
Priority: Blocker (was: Major)
> Maven Release Plugin Does Not Set Archetype Versions
>
Aljoscha Krettek created BEAM-806:
-
Summary: Maven Release Plugin Does Not Set Archetype Versions
Key: BEAM-806
URL: https://issues.apache.org/jira/browse/BEAM-806
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-633.
-
Resolution: Duplicate
Fix Version/s: (was: 0.3.0-incubating)
Not
[
https://issues.apache.org/jira/browse/BEAM-633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened BEAM-633:
---
Reopening to close as non-resolved so that it doesn't show up in the release
notes.
> Be able to
[
https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-102:
--
Summary: Support Side Inputs in Flink Streaming Runner (was: Side Inputs
for Streaming)
>
[
https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569001#comment-15569001
]
Aljoscha Krettek commented on BEAM-696:
---
Flink doesn't use bundles but it just keeps all the elements
[
https://issues.apache.org/jira/browse/BEAM-696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565001#comment-15565001
]
Aljoscha Krettek commented on BEAM-696:
---
Just to make it clear what the Flink runner does for this:
[
https://issues.apache.org/jira/browse/BEAM-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-720:
--
Component/s: runner-flink
> Running WindowedWordCount Integration Test in Flink
>
[
https://issues.apache.org/jira/browse/BEAM-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-615:
-
Assignee: Aljoscha Krettek (was: Kenneth Knowles)
> Add Support for Processing-Time
[
https://issues.apache.org/jira/browse/BEAM-644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522966#comment-15522966
]
Aljoscha Krettek commented on BEAM-644:
---
[~kenn] I was referring to "two clusters of elements from two
[
https://issues.apache.org/jira/browse/BEAM-644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15515875#comment-15515875
]
Aljoscha Krettek commented on BEAM-644:
---
Yes, as a replacement for {{outputWithTimestamp}} and
[
https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15507706#comment-15507706
]
Aljoscha Krettek commented on BEAM-638:
---
I don't think it's possible to provide such a function.
What
[
https://issues.apache.org/jira/browse/BEAM-260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15498458#comment-15498458
]
Aljoscha Krettek commented on BEAM-260:
---
The doc looks good, I'm not sure how many people will see
[
https://issues.apache.org/jira/browse/BEAM-616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-616.
---
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
> Update Flink Runner to 1.1.2
>
Aljoscha Krettek created BEAM-616:
-
Summary: Update Flink Runner to 1.1.2
Key: BEAM-616
URL: https://issues.apache.org/jira/browse/BEAM-616
Project: Beam
Issue Type: Improvement
Aljoscha Krettek created BEAM-615:
-
Summary: Add Support for Processing-Time Timers in FlinkRunner
Window Operator
Key: BEAM-615
URL: https://issues.apache.org/jira/browse/BEAM-615
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438508#comment-15438508
]
Aljoscha Krettek commented on BEAM-485:
---
Hi [~ecesena], could you check whether this bug is still
[
https://issues.apache.org/jira/browse/BEAM-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-253.
---
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
Implemented here:
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-315.
---
Resolution: Fixed
> Flink Runner compares keys unencoded which may produce incorrect results
>
[
https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-102.
---
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
Implemented
[
https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15436708#comment-15436708
]
Aljoscha Krettek commented on BEAM-286:
---
Now that the PR is in I think the reorganization/cleanup can
Aljoscha Krettek created BEAM-581:
-
Summary: Support Verifiers in TestFlinkRunner
Key: BEAM-581
URL: https://issues.apache.org/jira/browse/BEAM-581
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402815#comment-15402815
]
Aljoscha Krettek commented on BEAM-321:
---
I think we agreed a while back to only put the "fix version"
[
https://issues.apache.org/jira/browse/BEAM-322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402355#comment-15402355
]
Aljoscha Krettek commented on BEAM-322:
---
The fix for this is included in this commit of my side-input
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402329#comment-15402329
]
Aljoscha Krettek commented on BEAM-321:
---
This was fixed a while ago in master and is part of the
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-321:
--
Fix Version/s: (was: 0.3.0-incubating)
0.2.0-incubating
> Hash encoded
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-321:
--
Fix Version/s: (was: 0.2.0-incubating)
> Hash encoded keys in Flink batch mode
>
[
https://issues.apache.org/jira/browse/BEAM-322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-322:
--
Fix Version/s: (was: 0.2.0-incubating)
> Compare encoded keys in streaming mode
>
[
https://issues.apache.org/jira/browse/BEAM-322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-322:
-
Assignee: Aljoscha Krettek
> Compare encoded keys in streaming mode
>
[
https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15382327#comment-15382327
]
Aljoscha Krettek commented on BEAM-242:
---
The weekend before last weekend I worked on some stuff that
[
https://issues.apache.org/jira/browse/BEAM-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-253:
-
Assignee: Aljoscha Krettek
> Unify Flink Operator Wrappers
> -
[
https://issues.apache.org/jira/browse/BEAM-438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372575#comment-15372575
]
Aljoscha Krettek commented on BEAM-438:
---
+1 I've seen people do the former several times.
> Rename
[
https://issues.apache.org/jira/browse/BEAM-300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-300.
-
Resolution: Duplicate
Fix Version/s: 0.2.0-incubating
Flink was updated to 1.0.3 a while
[
https://issues.apache.org/jira/browse/BEAM-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-392.
---
Resolution: Fixed
Fix Version/s: 0.2.0-incubating
> Update flink runner to use flink
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-321.
---
Resolution: Fixed
Fix Version/s: (was: 0.1.0-incubating)
[
https://issues.apache.org/jira/browse/BEAM-297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-297.
---
Resolution: Fixed
Fix Version/s: (was: 0.1.0-incubating)
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312560#comment-15312560
]
Aljoscha Krettek commented on BEAM-315:
---
Thanks for the updates! I'll keep investigating.
> Flink
[
https://issues.apache.org/jira/browse/BEAM-322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-322:
--
Description: Right now, hashing of keys happens on the value itself not on
the encoded
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-321:
--
Description: Right now, hashing of keys happens on the value itself not on
the encoded
[
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-321:
--
Summary: Hash encoded keys in Flink batch mode (was: Compare encoded keys
in batch mode)
> Hash
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310277#comment-15310277
]
Aljoscha Krettek commented on BEAM-315:
---
I think we should make this issue into two issues. Leave this
[
https://issues.apache.org/jira/browse/BEAM-295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-295.
---
Resolution: Fixed
Fix Version/s: 0.1.0-incubating
> Flink Create Functions call
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309976#comment-15309976
]
Aljoscha Krettek commented on BEAM-315:
---
I played around this morning and finally found the problem
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-315:
-
Assignee: Aljoscha Krettek
> GroupByKey/CoGroupByKey doesn't group correctly in batch mode
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15307827#comment-15307827
]
Aljoscha Krettek commented on BEAM-315:
---
I attached a version that uses a {{String}} as key. With
[
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-315:
--
Attachment: CoGroupPipelineStringKey.java
This is a version of the same program that uses a
[
https://issues.apache.org/jira/browse/BEAM-307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300147#comment-15300147
]
Aljoscha Krettek commented on BEAM-307:
---
It might be that we have to create separate packages for
[
https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15295691#comment-15295691
]
Aljoscha Krettek commented on BEAM-286:
---
For the Flink runner there is already such a separation. The
[
https://issues.apache.org/jira/browse/BEAM-258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-258.
---
Resolution: Fixed
Fix Version/s: 0.1.0-incubating
> Execute selected RunnableOnService
[
https://issues.apache.org/jira/browse/BEAM-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved BEAM-270.
---
Resolution: Fixed
Fix Version/s: 0.1.0-incubating
> Support Timestamps/Windows in Flink
[
https://issues.apache.org/jira/browse/BEAM-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15290997#comment-15290997
]
Aljoscha Krettek commented on BEAM-297:
---
Now that the issue is created could you please update your
Aljoscha Krettek created BEAM-295:
-
Summary: Flink Create Functions call Collector.close()
Key: BEAM-295
URL: https://issues.apache.org/jira/browse/BEAM-295
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286673#comment-15286673
]
Aljoscha Krettek commented on BEAM-131:
---
Can this one be closed now that it is superseded by the more
[
https://issues.apache.org/jira/browse/BEAM-273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286676#comment-15286676
]
Aljoscha Krettek commented on BEAM-273:
---
Are there further steps towards updating the Flink version or
[
https://issues.apache.org/jira/browse/BEAM-48?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286670#comment-15286670
]
Aljoscha Krettek commented on BEAM-48:
--
[~dhalp...@google.com] I saw that you merged the PR. Can we now
[
https://issues.apache.org/jira/browse/BEAM-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286608#comment-15286608
]
Aljoscha Krettek commented on BEAM-291:
---
Also, I think {{PDone}} is never to be used as the return
[
https://issues.apache.org/jira/browse/BEAM-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286597#comment-15286597
]
Aljoscha Krettek commented on BEAM-291:
---
Could you maybe post the code for the example? With my latest
[
https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286468#comment-15286468
]
Aljoscha Krettek commented on BEAM-286:
---
+1, I think the examples can be removed. AFAIK they are only
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
[
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 execution
>
[
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 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)
>
[
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
>
[
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://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
[
https://issues.apache.org/jira/browse/BEAM-260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275128#comment-15275128
]
Aljoscha Krettek commented on BEAM-260:
---
I thought about this as well while working on the Flink
[
https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274971#comment-15274971
]
Aljoscha Krettek commented on BEAM-242:
---
The PR is merged but checkstyle is not yet globally enabled,
[
https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274961#comment-15274961
]
Aljoscha Krettek commented on BEAM-216:
---
Btw, this is a duplicate of BEAM-9.
> Create Storm Runner
>
[
https://issues.apache.org/jira/browse/BEAM-140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268726#comment-15268726
]
Aljoscha Krettek commented on BEAM-140:
---
+1 for unification
> Improve examples provided with the
[
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
> -
>
>
1 - 100 of 114 matches
Mail list logo
