[
https://issues.apache.org/jira/browse/BEAM-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-5372.
--
Resolution: Fixed
> [Flink Runner] Make minPauseBetweenCheckpoints setting available in
>
[
https://issues.apache.org/jira/browse/BEAM-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-5372:
---
Fix Version/s: 2.7.0
> [Flink Runner] Make minPauseBetweenCheckpoints setting available in
>
[
https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588744#comment-16588744
]
Aljoscha Krettek commented on BEAM-3919:
Unfortunately, I don't think we can fix this right now
[
https://issues.apache.org/jira/browse/BEAM-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-4798.
--
Resolution: Fixed
> IndexOutOfBoundsException when Flink parallelism > 1
>
[
https://issues.apache.org/jira/browse/BEAM-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-4798:
---
Fix Version/s: 2.7.0
> IndexOutOfBoundsException when Flink parallelism > 1
>
[
https://issues.apache.org/jira/browse/BEAM-2930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559894#comment-16559894
]
Aljoscha Krettek commented on BEAM-2930:
Yes, that sounds like a good approach. I upgraded the
[
https://issues.apache.org/jira/browse/BEAM-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-4311.
--
Resolution: Fixed
> Enforce ErrorProne analysis in Flink runner project
>
[
https://issues.apache.org/jira/browse/BEAM-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-4311:
---
Fix Version/s: 2.6.0
> Enforce ErrorProne analysis in Flink runner project
>
[
https://issues.apache.org/jira/browse/BEAM-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-3909:
---
Fix Version/s: 2.5.0
> Add tests for Flink DoFnOperator side-input checkpointing
>
[
https://issues.apache.org/jira/browse/BEAM-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3909.
--
Resolution: Fixed
> Add tests for Flink DoFnOperator side-input checkpointing
>
[
https://issues.apache.org/jira/browse/BEAM-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-4063:
--
Assignee: (was: Aljoscha Krettek)
> Flink runner supports cluster-wide artifact
[
https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-4067:
--
Assignee: (was: Aljoscha Krettek)
> Add portable Flink test runner
>
[
https://issues.apache.org/jira/browse/BEAM-2927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423602#comment-16423602
]
Aljoscha Krettek commented on BEAM-2927:
The problematic piece is this:
[
https://issues.apache.org/jira/browse/BEAM-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3087.
--
Resolution: Fixed
Fix Version/s: 2.5.0
> Extend lock scope in Flink
[
https://issues.apache.org/jira/browse/BEAM-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2393.
--
Resolution: Fixed
Fix Version/s: 2.5.0
> BoundedSource is not fault-tolerant in
[
https://issues.apache.org/jira/browse/BEAM-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened BEAM-622:
---
> Add checkpointing tests for DoFnOperator and WindowDoFnOperator
>
[
https://issues.apache.org/jira/browse/BEAM-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-622.
-
Resolution: Fixed
Fix Version/s: 2.5.0
> Add checkpointing tests for DoFnOperator and
[
https://issues.apache.org/jira/browse/BEAM-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3800.
--
Resolution: Fixed
Fix Version/s: 2.5.0
> Set uids on Flink operators
>
[
https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3919:
--
Assignee: Harshal Tripathi
> checkpoint can not work with flink 1.4.1,1.4.2
>
[
https://issues.apache.org/jira/browse/BEAM-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3919:
--
Assignee: (was: Aljoscha Krettek)
> checkpoint can not work with flink 1.4.1,1.4.2
Aljoscha Krettek created BEAM-3909:
--
Summary: Add tests for Flink DoFnOperator side-input checkpointing
Key: BEAM-3909
URL: https://issues.apache.org/jira/browse/BEAM-3909
Project: Beam
Aljoscha Krettek created BEAM-3905:
--
Summary: Update Flink Runner to Flink 1.5.0
Key: BEAM-3905
URL: https://issues.apache.org/jira/browse/BEAM-3905
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405185#comment-16405185
]
Aljoscha Krettek commented on BEAM-2393:
Yes, it's very good to worry about those things!
I
[
https://issues.apache.org/jira/browse/BEAM-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402220#comment-16402220
]
Aljoscha Krettek commented on BEAM-2393:
Ah, I think that explains it. This call in the source:
[
https://issues.apache.org/jira/browse/BEAM-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3043.
--
Resolution: Fixed
> Set user-specified Transform names on Flink operations
>
[
https://issues.apache.org/jira/browse/BEAM-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397890#comment-16397890
]
Aljoscha Krettek commented on BEAM-2393:
Have you enabled DEBUG logging in Flink? What do the logs
[
https://issues.apache.org/jira/browse/BEAM-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3675:
--
Assignee: (was: Aljoscha Krettek)
> FlinkRunner: Logging server
>
[
https://issues.apache.org/jira/browse/BEAM-3673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3673:
--
Assignee: (was: Aljoscha Krettek)
> FlinkRunner: Harness manager for connecting
[
https://issues.apache.org/jira/browse/BEAM-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3753.
--
Resolution: Fixed
Fix Version/s: (was: 2.4.0)
2.5.0
> Integration
[
https://issues.apache.org/jira/browse/BEAM-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened BEAM-3043:
Reopen to change fixVersion
> Set user-specified Transform names on Flink operations
>
[
https://issues.apache.org/jira/browse/BEAM-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened BEAM-3753:
Reopen to change fixVersion.
> Integration ITCase tests are not executed
>
[
https://issues.apache.org/jira/browse/BEAM-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-3043:
---
Fix Version/s: (was: 2.4.0)
2.5.0
> Set user-specified Transform names
[
https://issues.apache.org/jira/browse/BEAM-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3043.
--
Resolution: Fixed
Fix Version/s: 2.4.0
> Set user-specified Transform names on Flink
[
https://issues.apache.org/jira/browse/BEAM-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3753.
--
Resolution: Fixed
Fix Version/s: 2.4.0
> Integration ITCase tests are not executed
>
[
https://issues.apache.org/jira/browse/BEAM-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3768.
--
Resolution: Fixed
Assignee: Thomas Groh (was: Aljoscha Krettek)
This was resolved via
[
https://issues.apache.org/jira/browse/BEAM-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-3768:
---
Issue Type: Bug (was: Test)
> Compile error for Flink translation
>
[
https://issues.apache.org/jira/browse/BEAM-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383585#comment-16383585
]
Aljoscha Krettek commented on BEAM-3768:
[~robertwb] & [~rmannibucau] I commented on the PR:
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-2140:
---
Fix Version/s: 2.4.0
> Fix SplittableDoFn ValidatesRunner tests in FlinkRunner
>
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2140.
--
Resolution: Fixed
> Fix SplittableDoFn ValidatesRunner tests in FlinkRunner
>
[
https://issues.apache.org/jira/browse/BEAM-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3728:
--
Assignee: (was: Aljoscha Krettek)
> Failing ParDoTest for Flink Runner
>
[
https://issues.apache.org/jira/browse/BEAM-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372906#comment-16372906
]
Aljoscha Krettek commented on BEAM-3728:
Also cc [~romain.manni-bucau] as the implementor. I
Aljoscha Krettek created BEAM-3728:
--
Summary: Failing ParDoTest for Flink Runner
Key: BEAM-3728
URL: https://issues.apache.org/jira/browse/BEAM-3728
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-3673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358208#comment-16358208
]
Aljoscha Krettek commented on BEAM-3673:
[~bsidhom] Am I supposed to be assigned to all of those
Aljoscha Krettek created BEAM-3648:
--
Summary: Support Splittable DoFn in Flink Batch Runner
Key: BEAM-3648
URL: https://issues.apache.org/jira/browse/BEAM-3648
Project: Beam
Issue Type: New
[
https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353712#comment-16353712
]
Aljoscha Krettek commented on BEAM-2806:
[~jbonofre] I merged this in master in commit
[
https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-2806:
---
Fix Version/s: 2.3.0
> support View.CreatePCollectionView in FlinkRunner
>
[
https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2806.
--
Resolution: Fixed
> support View.CreatePCollectionView in FlinkRunner
>
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3186.
--
Resolution: Fixed
> In-flight data loss when restoring from savepoint
>
[
https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3589.
--
Resolution: Fixed
> Flink runner breaks with ClassCastException on UnboundedSource
>
[
https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-3589:
---
Fix Version/s: 2.3.0
> Flink runner breaks with ClassCastException on UnboundedSource
>
[
https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352250#comment-16352250
]
Aljoscha Krettek commented on BEAM-3589:
[~jbonofre] This was now fixed as part of another fix in
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352248#comment-16352248
]
Aljoscha Krettek commented on BEAM-3186:
[~jbonofre] This was fixed on master in these commits:
[
https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348631#comment-16348631
]
Aljoscha Krettek commented on BEAM-3589:
[~grzegorz_kolakowski] I think I'm too tired today but
[
https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-2806:
--
Assignee: Grzegorz Kołakowski (was: Aljoscha Krettek)
> support
[
https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3589:
--
Assignee: Grzegorz Kołakowski
> Flink runner breaks with ClassCastException on
[
https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3186:
--
Assignee: Dawid Wysakowicz (was: Aljoscha Krettek)
> In-flight data loss when
[
https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16348542#comment-16348542
]
Aljoscha Krettek commented on BEAM-3414:
Still working on getting that PR in, yes.
>
[
https://issues.apache.org/jira/browse/BEAM-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16341059#comment-16341059
]
Aljoscha Krettek commented on BEAM-3087:
There was one user that had a problem because of this but
[
https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16341057#comment-16341057
]
Aljoscha Krettek edited comment on BEAM-3494 at 1/26/18 1:32 PM:
-
How are
[
https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16341057#comment-16341057
]
Aljoscha Krettek commented on BEAM-3494:
How are you enabling checkpointing? Also, could you please
[
https://issues.apache.org/jira/browse/BEAM-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3472:
--
Assignee: (was: Aljoscha Krettek)
> Create a callback triggered at the end of a
[
https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3494:
--
Assignee: (was: Aljoscha Krettek)
> Snapshot state of aggregated data of apache
[
https://issues.apache.org/jira/browse/BEAM-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16341044#comment-16341044
]
Aljoscha Krettek commented on BEAM-3529:
There should probably also be {{ValidatesRunner}} tests
[
https://issues.apache.org/jira/browse/BEAM-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3370:
--
Assignee: (was: Aljoscha Krettek)
> Add ability to stage directories with compiled
[
https://issues.apache.org/jira/browse/BEAM-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3359:
--
Assignee: (was: Aljoscha Krettek)
> Unable to change "flinkMaster" from "[auto]" in
[
https://issues.apache.org/jira/browse/BEAM-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313338#comment-16313338
]
Aljoscha Krettek commented on BEAM-3379:
Could you check whether this PR fixes it?
[
https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16313329#comment-16313329
]
Aljoscha Krettek commented on BEAM-3414:
I openen a PR for a related bug and I think this issue
[
https://issues.apache.org/jira/browse/BEAM-3043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3043:
--
Assignee: (was: Aljoscha Krettek)
> Set user-specified Transform names on Flink
[
https://issues.apache.org/jira/browse/BEAM-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated BEAM-2873:
---
Summary: Detect number of shards for file sink in Flink Streaming Runner
(was: Detect number
[
https://issues.apache.org/jira/browse/BEAM-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-2873:
--
Assignee: (was: Aljoscha Krettek)
> Detect number of sharsd for file sink in Flink
[
https://issues.apache.org/jira/browse/BEAM-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2377.
--
Resolution: Invalid
Fix Version/s: (was: 2.3.0)
Not applicable
Now
[
https://issues.apache.org/jira/browse/BEAM-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240093#comment-16240093
]
Aljoscha Krettek commented on BEAM-1601:
I'm not aware of any work on this, no.
> Flink Runner
Aljoscha Krettek created BEAM-3087:
--
Summary: Extend lock scope in Flink UnboundedSourceWrapper
Key: BEAM-3087
URL: https://issues.apache.org/jira/browse/BEAM-3087
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned BEAM-3087:
--
Assignee: (was: Aljoscha Krettek)
> Extend lock scope in Flink
Aljoscha Krettek created BEAM-3043:
--
Summary: Set user-specified Transform names on Flink operations
Key: BEAM-3043
URL: https://issues.apache.org/jira/browse/BEAM-3043
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-3027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-3027.
--
Resolution: Fixed
> Output type of SourceID-stripper is not correctly set
>
Aljoscha Krettek created BEAM-3027:
--
Summary: Output type of SourceID-stripper is not correctly set
Key: BEAM-3027
URL: https://issues.apache.org/jira/browse/BEAM-3027
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184169#comment-16184169
]
Aljoscha Krettek commented on BEAM-2995:
How are you starting your cluster? There was also some
[
https://issues.apache.org/jira/browse/BEAM-2975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182151#comment-16182151
]
Aljoscha Krettek commented on BEAM-2975:
These changes also broke the PostCommit tests for the
[
https://issues.apache.org/jira/browse/BEAM-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16176119#comment-16176119
]
Aljoscha Krettek commented on BEAM-2980:
I think this is a more specific version of BEAM-2975.
>
[
https://issues.apache.org/jira/browse/BEAM-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened BEAM-2377:
Commit was reverted.
> Cross compile flink runner to scala 2.11
>
[
https://issues.apache.org/jira/browse/BEAM-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2973.
--
Resolution: Fixed
Fix Version/s: Not applicable
This was fixed in the revert commit
[
https://issues.apache.org/jira/browse/BEAM-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2377.
--
Resolution: Fixed
Fix Version/s: 2.2.0
Implemented in
[
https://issues.apache.org/jira/browse/BEAM-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2948.
--
Resolution: Fixed
Fix Version/s: 2.2.0
Fixed in 14ea5abe3c3900e5cb423a8580fbdcc6e28fe376
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170437#comment-16170437
]
Aljoscha Krettek commented on BEAM-2140:
As I commented on the PR, I have a solution that is
[
https://issues.apache.org/jira/browse/BEAM-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-1688.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Getting listener timeout after waiting for
[
https://issues.apache.org/jira/browse/BEAM-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167598#comment-16167598
]
Aljoscha Krettek commented on BEAM-2712:
[~jkff] See my comment on BEAM-2948, I think for Flink we
[
https://issues.apache.org/jira/browse/BEAM-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167532#comment-16167532
]
Aljoscha Krettek commented on BEAM-2948:
Yes, that's true but we probably have to wait a few more
[
https://issues.apache.org/jira/browse/BEAM-2807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed BEAM-2807.
--
Resolution: Fixed
Fix Version/s: 2.2.0
Fixed in 81d0c436691d33a7ea1bd808413e1aa08e1c4d10
[
https://issues.apache.org/jira/browse/BEAM-2943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166276#comment-16166276
]
Aljoscha Krettek commented on BEAM-2943:
Could you verify that
[
https://issues.apache.org/jira/browse/BEAM-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166124#comment-16166124
]
Aljoscha Krettek commented on BEAM-2948:
I think the problem is that Beam will only "instantiate"
Aljoscha Krettek created BEAM-2873:
--
Summary: Detect number of sharsd for file sink in Flink Streaming
Runner
Key: BEAM-2873
URL: https://issues.apache.org/jira/browse/BEAM-2873
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16150656#comment-16150656
]
Aljoscha Krettek commented on BEAM-2831:
[~kenn] Do you think we can change {{SerializableCoder}}
[
https://issues.apache.org/jira/browse/BEAM-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16148985#comment-16148985
]
Aljoscha Krettek edited comment on BEAM-2831 at 8/31/17 1:41 PM:
-
Could you
[
https://issues.apache.org/jira/browse/BEAM-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16148985#comment-16148985
]
Aljoscha Krettek commented on BEAM-2831:
Could you try running it with this modified
[
https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16146873#comment-16146873
]
Aljoscha Krettek commented on BEAM-2457:
(This is on the Cloudera Quickstart VM)
I noticed that
[
https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145017#comment-16145017
]
Aljoscha Krettek commented on BEAM-2457:
The error in 2.2.0-SNAPSHOT occurs because we no longer
[
https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143897#comment-16143897
]
Aljoscha Krettek commented on BEAM-2806:
I tried this on the Flink Runner (both batch and
[
https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143846#comment-16143846
]
Aljoscha Krettek commented on BEAM-2457:
Is there any update on this? I have a jar file that I
[
https://issues.apache.org/jira/browse/BEAM-2806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16141378#comment-16141378
]
Aljoscha Krettek commented on BEAM-2806:
Could you please provide a complete minimal example that
1 - 100 of 252 matches
Mail list logo
