[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841999#comment-17841999
]
Galen Warren commented on FLINK-35232:
--
[~xtsong] You helped with the original implementation of
[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840942#comment-17840942
]
Galen Warren commented on FLINK-35232:
--
Yes, that's using the RecoverableWriter.
The default retry
[
https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840862#comment-17840862
]
Galen Warren commented on FLINK-35232:
--
In case it's relevant, reading/writing to GCS happens in
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830956#comment-17830956
]
Galen Warren commented on FLINK-34696:
--
I'm not a committer so I can't approve anything on my own,
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829246#comment-17829246
]
Galen Warren commented on FLINK-34696:
--
I'm not aware of any special considerations in
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828412#comment-17828412
]
Galen Warren edited comment on FLINK-34696 at 3/19/24 5:07 PM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828412#comment-17828412
]
Galen Warren edited comment on FLINK-34696 at 3/19/24 5:07 PM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828412#comment-17828412
]
Galen Warren edited comment on FLINK-34696 at 3/19/24 5:06 PM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828412#comment-17828412
]
Galen Warren edited comment on FLINK-34696 at 3/19/24 3:32 PM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828412#comment-17828412
]
Galen Warren commented on FLINK-34696:
--
I think your proposed algorithm is just another way of
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828081#comment-17828081
]
Galen Warren edited comment on FLINK-34696 at 3/18/24 7:35 PM:
---
Re:
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828081#comment-17828081
]
Galen Warren edited comment on FLINK-34696 at 3/18/24 7:21 PM:
---
Re:
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828081#comment-17828081
]
Galen Warren commented on FLINK-34696:
--
Re: {*}Composition{*}: My understanding is that Flink
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827590#comment-17827590
]
Galen Warren commented on FLINK-34696:
--
One more thing, regarding:
{quote}To mitigate this problem,
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827568#comment-17827568
]
Galen Warren edited comment on FLINK-34696 at 3/15/24 5:49 PM:
---
No, this
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827568#comment-17827568
]
Galen Warren commented on FLINK-34696:
--
No, this just moves the storage of the temporary files to a
[
https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827528#comment-17827528
]
Galen Warren commented on FLINK-34696:
--
Yes, the issue is recoverability. However, there is one
[
https://issues.apache.org/jira/browse/FLINK-31619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754199#comment-17754199
]
Galen Warren commented on FLINK-31619:
--
Created pull request: [[FLINK-31619] Upgrade Stateful
[
https://issues.apache.org/jira/browse/FLINK-25993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17622344#comment-17622344
]
Galen Warren commented on FLINK-25993:
--
[~chesnay] [~diagonalbishop]
I found your old discussion
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543637#comment-17543637
]
Galen Warren commented on FLINK-27813:
--
Cool! Glad it was something simple.
>
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543099#comment-17543099
]
Galen Warren commented on FLINK-27813:
--
Are you using RequestReplyFunctionBuilder to build your
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542929#comment-17542929
]
Galen Warren commented on FLINK-27813:
--
Hmm, not sure. The relevant part of the error message seems
[
https://issues.apache.org/jira/browse/FLINK-26462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502469#comment-17502469
]
Galen Warren commented on FLINK-26462:
--
I just ran through the testing steps and everything worked
Galen Warren created FLINK-26451:
Summary: Test GCS FileSystem w/ RecoverableWriter manually
Key: FLINK-26451
URL: https://issues.apache.org/jira/browse/FLINK-26451
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-26375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498194#comment-17498194
]
Galen Warren commented on FLINK-26375:
--
PR created: [[FLINK-26375][statefun-golang-sdk] Fix
Galen Warren created FLINK-26375:
Summary: Fix Statefun Golang SDK to return nil from Context.Caller
when there is no caller
Key: FLINK-26375
URL: https://issues.apache.org/jira/browse/FLINK-26375
[
https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497745#comment-17497745
]
Galen Warren commented on FLINK-26340:
--
Just a note for anyone who might arrive here – we changed
[
https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496903#comment-17496903
]
Galen Warren commented on FLINK-26340:
--
PR created: [[FLINK-26340][statefun-golang-sdk] Add ability
Galen Warren created FLINK-26340:
Summary: Add ability in Golang SDK to create new statefun.Context
from existing one, but with a new underlying context.Context
Key: FLINK-26340
URL:
[
https://issues.apache.org/jira/browse/FLINK-25933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489697#comment-17489697
]
Galen Warren commented on FLINK-25933:
--
PR created:
[
https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Galen Warren closed FLINK-25873.
Resolution: Not A Problem
> Using RocksDB state backend causes java.lang.ClassNotFoundException:
[
https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484241#comment-17484241
]
Galen Warren commented on FLINK-25873:
--
Yes, this was a problem on my end. I hadn't removed the
[
https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484200#comment-17484200
]
Galen Warren commented on FLINK-25873:
--
Actually, this may be a caching issue on my side. I'll
[
https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483905#comment-17483905
]
Galen Warren commented on FLINK-25873:
--
Sorry, link to current location of
Galen Warren created FLINK-25873:
Summary: Using RocksDB state backend causes
java.lang.ClassNotFoundException:
org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream
Key: FLINK-25873
[
https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483803#comment-17483803
]
Galen Warren commented on FLINK-25577:
--
[~xtsong] Thanks! I've really enjoyed working with you as
[
https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481473#comment-17481473
]
Galen Warren commented on FLINK-25577:
--
Here's a second try at a release note:
The
[
https://issues.apache.org/jira/browse/FLINK-25790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481453#comment-17481453
]
Galen Warren commented on FLINK-25790:
--
Created PR: https://github.com/apache/flink/pull/18489
>
Galen Warren created FLINK-25790:
Summary: Support authentication via core-site.xml in GCS
FileSystem plugin
Key: FLINK-25790
URL: https://issues.apache.org/jira/browse/FLINK-25790
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17481128#comment-17481128
]
Galen Warren commented on FLINK-25772:
--
I believe this is a duplicate of [FLINK-25758] GCS
[
https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480732#comment-17480732
]
Galen Warren commented on FLINK-25577:
--
[~MartijnVisser] I'm trying to add the release note, but I
[
https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480728#comment-17480728
]
Galen Warren commented on FLINK-25758:
--
PR created: [https://github.com/apache/flink/pull/18452]
[
https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480685#comment-17480685
]
Galen Warren commented on FLINK-25758:
--
[~MartijnVisser] PR created:
[
https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480471#comment-17480471
]
Galen Warren commented on FLINK-25758:
--
Sure, I'll take a look. Is there a way to run the license
[
https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479647#comment-17479647
]
Galen Warren commented on FLINK-25577:
--
[~MartijnVisser] [~dmvk]
I've created a PR for this:
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479454#comment-17479454
]
Galen Warren commented on FLINK-11838:
--
[~MartijnVisser] I'd say let's handle documentation and
[
https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470705#comment-17470705
]
Galen Warren commented on FLINK-25577:
--
Why don't we leave it open, just so that it doesn't get
[
https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470701#comment-17470701
]
Galen Warren commented on FLINK-25577:
--
I just wanted to mention that it's likely that a GCS
[
https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465402#comment-17465402
]
Galen Warren commented on FLINK-25197:
--
PR created:
[
https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465400#comment-17465400
]
Galen Warren commented on FLINK-25197:
--
PR created:
[
https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Galen Warren updated FLINK-25197:
-
Description:
When using RequestReplyFunctionBuilder to build a stateful functions job, the
job
Galen Warren created FLINK-25197:
Summary: Using Statefun RequestReplyFunctionBuilder fails with
Java 8 date/time type `java.time.Duration` not supported by default: add Module
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398108#comment-17398108
]
Galen Warren commented on FLINK-11838:
--
I know this has taken a long time. I'll have the code in
[
https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350139#comment-17350139
]
Galen Warren commented on FLINK-22757:
--
In case it's relevant here, I'm working on a
[
https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342087#comment-17342087
]
Galen Warren commented on FLINK-19481:
--
I wanted to check in here. Should I wait until this
[
https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338418#comment-17338418
]
Galen Warren commented on FLINK-19481:
--
Hi all, I'm the author of the other
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326990#comment-17326990
]
Galen Warren commented on FLINK-11838:
--
PR is still active.
> Create RecoverableWriter for GCS
>
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320363#comment-17320363
]
Galen Warren commented on FLINK-11838:
--
[~xintongsong],
PR created:
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316376#comment-17316376
]
Galen Warren commented on FLINK-11838:
--
Working on the new PR now ... coming soon.
> Create
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17314079#comment-17314079
]
Galen Warren edited comment on FLINK-11838 at 4/2/21, 8:54 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17314079#comment-17314079
]
Galen Warren commented on FLINK-11838:
--
[~xintongsong] – actually, is that the right thing to do,
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17314067#comment-17314067
]
Galen Warren commented on FLINK-11838:
--
Hi [~xintongsong] – sorry for the long delay. I plan to
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303537#comment-17303537
]
Galen Warren commented on FLINK-11838:
--
Not that I'm aware of. Writing checkpoints/savepoints and
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300332#comment-17300332
]
Galen Warren commented on FLINK-11838:
--
[~BerkayOzturk] No, it's not in a working state. Since that
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295384#comment-17295384
]
Galen Warren commented on FLINK-11838:
--
I just wanted to add an update here so this doesn't go
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288419#comment-17288419
]
Galen Warren commented on FLINK-11838:
--
Hey, I just wanted to check in here. Sorry for the delay,
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284896#comment-17284896
]
Galen Warren commented on FLINK-11838:
--
Ah, OK – I see. It will take me a couple of days to get
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284751#comment-17284751
]
Galen Warren commented on FLINK-11838:
--
That's fine on "compose on persist", I'll leave it out for
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284476#comment-17284476
]
Galen Warren commented on FLINK-11838:
--
{quote}Maybe for the first step, it's good enough to simply
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283950#comment-17283950
]
Galen Warren edited comment on FLINK-11838 at 2/12/21, 9:01 PM:
One more
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283950#comment-17283950
]
Galen Warren commented on FLINK-11838:
--
One more thought/question. While we can potentially compose
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283747#comment-17283747
]
Galen Warren commented on FLINK-11838:
--
Hi [~xintongsong], sorry for the delay here, I had some
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281769#comment-17281769
]
Galen Warren commented on FLINK-11838:
--
Hi [~xintongsong] – a couple more thoughts here.
I think I
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281481#comment-17281481
]
Galen Warren commented on FLINK-11838:
--
Thanks, that all sounds reasonable. I'll take a look at the
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280587#comment-17280587
]
Galen Warren commented on FLINK-11838:
--
Thanks. All of your initial assumptions are correct, though
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279694#comment-17279694
]
Galen Warren commented on FLINK-11838:
--
Thanks [~xtsong]! I really appreciate your help on this.
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279023#comment-17279023
]
Galen Warren commented on FLINK-11838:
--
I have submitted a new
[
https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201123#comment-17201123
]
Galen Warren commented on FLINK-18810:
--
I'd also love to see a Golang SDK and would be willing to
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196268#comment-17196268
]
Galen Warren commented on FLINK-19176:
--
I just created a PR:
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195635#comment-17195635
]
Galen Warren commented on FLINK-19176:
--
Thanks! I'll get to work on that.
> Support ScalaPB as a
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195564#comment-17195564
]
Galen Warren commented on FLINK-19176:
--
Thanks [~igal].
Yep, that's almost exactly how I
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194832#comment-17194832
]
Galen Warren commented on FLINK-19176:
--
Hi [~igal] - I've forked the project and taken a crack at
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194243#comment-17194243
]
Galen Warren commented on FLINK-19176:
--
Thanks for the quick reply! A few comments/questions:
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193217#comment-17193217
]
Galen Warren commented on FLINK-19176:
--
Sorry for the edits – I'm trying to get hyperlinks to
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Galen Warren updated FLINK-19176:
-
Description:
Currently, Stateful Functions supports four options for serialization of
message
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Galen Warren updated FLINK-19176:
-
Description:
Currently, Stateful Functions supports four options for serialization of
message
[
https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Galen Warren updated FLINK-19176:
-
Description:
Currently, Stateful Functions supports four options for serialization of
message
Galen Warren created FLINK-19176:
Summary: Support ScalaPB as a message payload serializer in
Stateful Functions
Key: FLINK-19176
URL: https://issues.apache.org/jira/browse/FLINK-19176
Project: Flink
Galen Warren created FLINK-11055:
Summary: Allow Queryable State to be transformed on the
TaskManager before being returned to the client
Key: FLINK-11055
URL: https://issues.apache.org/jira/browse/FLINK-11055
89 matches
Mail list logo
