[
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
[
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-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.
> Ren
[
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 enco
[
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 0.2.0
[
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:all-tabpanel
]
Aljoscha Krettek updated BEAM-321:
--
Fix Version/s: (was: 0.2.0-incubating)
> Hash encoded keys in Flink batch m
[
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 m
[
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 Wrapp
[
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
[
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 m
[
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-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 ve
[
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 fl
[
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-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-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.
[
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
[
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-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
here:https://github.com
[
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://github.com
[
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 resu
[
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
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-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-T
[
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 fro
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
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
[
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 Jenk
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-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 run
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-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 a
[
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-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
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-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 Versi
[
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-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 instructi
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-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 Do
[
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-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
[
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 Do
[
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 Run
[
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.
> Fl
[
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 Rele
[
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 Jenk
[
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-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-720:
--
Component/s: runner-flink
> Running WindowedWordCount Integration Test in Fl
[
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
[
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
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-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 popul
[
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-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-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/fl
[
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/fl
[
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 re
[
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 fl
[
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 SplitStr
201 - 266 of 266 matches
Mail list logo
