[jira] [Commented] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted

[ https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895988#comment-17895988 ] Galen Warren commented on FLINK-36455: -- [~arvid] Thanks for this! Do you think this

[jira] [Commented] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted

[ https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887988#comment-17887988 ] Galen Warren commented on FLINK-36455: -- Thanks for checking, much appreciated. I ma

[jira] [Commented] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted

[ https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887949#comment-17887949 ] Galen Warren commented on FLINK-36455: -- Gotcha, thanks. Presumably that wouldn't in

[jira] [Commented] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted

[ https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887940#comment-17887940 ] Galen Warren commented on FLINK-36455: -- [~arvid] I'm trying to understand the scope

[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841999#comment-17841999 ] Galen Warren commented on FLINK-35232: -- [~xtsong] You helped with the original impl

[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840942#comment-17840942 ] Galen Warren commented on FLINK-35232: -- Yes, that's using the RecoverableWriter. T

[jira] [Commented] (FLINK-35232) Support for retry settings on GCS connector

[ https://issues.apache.org/jira/browse/FLINK-35232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840862#comment-17840862 ] Galen Warren commented on FLINK-35232: -- In case it's relevant, reading/writing to G

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830956#comment-17830956 ] Galen Warren commented on FLINK-34696: -- I'm not a committer so I can't approve anyt

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829246#comment-17829246 ] Galen Warren commented on FLINK-34696: -- I'm not aware of any special considerations

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828412#comment-17828412 ] Galen Warren edited comment on FLINK-34696 at 3/19/24 5:07 PM: ---

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828412#comment-17828412 ] Galen Warren edited comment on FLINK-34696 at 3/19/24 5:07 PM: ---

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828412#comment-17828412 ] Galen Warren edited comment on FLINK-34696 at 3/19/24 5:06 PM: ---

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828412#comment-17828412 ] Galen Warren edited comment on FLINK-34696 at 3/19/24 3:32 PM: ---

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828412#comment-17828412 ] Galen Warren commented on FLINK-34696: -- I think your proposed algorithm is just ano

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828081#comment-17828081 ] Galen Warren edited comment on FLINK-34696 at 3/18/24 7:35 PM: ---

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828081#comment-17828081 ] Galen Warren edited comment on FLINK-34696 at 3/18/24 7:21 PM: ---

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828081#comment-17828081 ] Galen Warren commented on FLINK-34696: -- Re: {*}Composition{*}: My understanding is

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827590#comment-17827590 ] Galen Warren commented on FLINK-34696: -- One more thing, regarding: {quote}To mitiga

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827568#comment-17827568 ] Galen Warren edited comment on FLINK-34696 at 3/15/24 5:49 PM: ---

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827568#comment-17827568 ] Galen Warren commented on FLINK-34696: -- No, this just moves the storage of the temp

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827528#comment-17827528 ] Galen Warren commented on FLINK-34696: -- Yes, the issue is recoverability. However,

[jira] [Commented] (FLINK-31619) Upgrade Stateful Functions to Flink 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754199#comment-17754199 ] Galen Warren commented on FLINK-31619: -- Created pull request: [[FLINK-31619] Upgrad

[jira] [Commented] (FLINK-25993) Option to disable Kryo.setRegistrationRequired(false)

[ https://issues.apache.org/jira/browse/FLINK-25993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622344#comment-17622344 ] Galen Warren commented on FLINK-25993: -- [~chesnay] [~diagonalbishop]  I found your

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543637#comment-17543637 ] Galen Warren commented on FLINK-27813: -- Cool! Glad it was something simple. > java

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543099#comment-17543099 ] Galen Warren commented on FLINK-27813: -- Are you using RequestReplyFunctionBuilder t

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542929#comment-17542929 ] Galen Warren commented on FLINK-27813: -- Hmm, not sure. The relevant part of the err

[jira] [Commented] (FLINK-26462) Release Testing: Running Python UDF in different Execution Mode

[ https://issues.apache.org/jira/browse/FLINK-26462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502469#comment-17502469 ] Galen Warren commented on FLINK-26462: -- I just ran through the testing steps and ev

[jira] [Created] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually

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 Type:

[jira] [Commented] (FLINK-26375) Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller

[ https://issues.apache.org/jira/browse/FLINK-26375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498194#comment-17498194 ] Galen Warren commented on FLINK-26375: -- PR created: [[FLINK-26375][statefun-golang-

[jira] [Created] (FLINK-26375) Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller

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 Pro

[jira] [Commented] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497745#comment-17497745 ] Galen Warren commented on FLINK-26340: -- Just a note for anyone who might arrive her

[jira] [Commented] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496903#comment-17496903 ] Galen Warren commented on FLINK-26340: -- PR created: [[FLINK-26340][statefun-golang-

[jira] [Created] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

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

[jira] [Commented] (FLINK-25933) Allow configuring different transports in RequestReplyFunctionBuilder

[ https://issues.apache.org/jira/browse/FLINK-25933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489697#comment-17489697 ] Galen Warren commented on FLINK-25933: -- PR created: https://github.com/apache/flink

[jira] [Closed] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

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

[jira] [Commented] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

[ https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484241#comment-17484241 ] Galen Warren commented on FLINK-25873: -- Yes, this was a problem on my end. I hadn't

[jira] [Commented] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

[ https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484200#comment-17484200 ] Galen Warren commented on FLINK-25873: -- Actually, this may be a caching issue on my

[jira] [Commented] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

[ https://issues.apache.org/jira/browse/FLINK-25873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483905#comment-17483905 ] Galen Warren commented on FLINK-25873: -- Sorry, link to current location of Checkpoi

[jira] [Created] (FLINK-25873) Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream

Galen Warren created FLINK-25873: Summary: Using RocksDB state backend causes java.lang.ClassNotFoundException: org.apache.flink.runtime.state.CheckpointStreamFactory$CheckpointStateOutputStream Key: FLINK-25873

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483803#comment-17483803 ] Galen Warren commented on FLINK-25577: -- [~xtsong] Thanks! I've really enjoyed worki

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481473#comment-17481473 ] Galen Warren commented on FLINK-25577: -- Here's a second try at a release note: The

[jira] [Commented] (FLINK-25790) Support authentication via core-site.xml in GCS FileSystem plugin

[ https://issues.apache.org/jira/browse/FLINK-25790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481453#comment-17481453 ] Galen Warren commented on FLINK-25790: -- Created PR: https://github.com/apache/flink

[jira] [Created] (FLINK-25790) Support authentication via core-site.xml in GCS FileSystem plugin

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

[jira] [Commented] (FLINK-25772) GCS filesystem fails license checker

[ https://issues.apache.org/jira/browse/FLINK-25772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481128#comment-17481128 ] Galen Warren commented on FLINK-25772: -- I believe this is a duplicate of [FLINK-257

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480732#comment-17480732 ] Galen Warren commented on FLINK-25577: -- [~MartijnVisser] I'm trying to add the rele

[jira] [Commented] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480728#comment-17480728 ] Galen Warren commented on FLINK-25758: -- PR created: [https://github.com/apache/flin

[jira] [Commented] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480685#comment-17480685 ] Galen Warren commented on FLINK-25758: -- [~MartijnVisser] PR created: https://github

[jira] [Commented] (FLINK-25758) GCS Filesystem implementation fails on Java 11 tests due to licensing issues

[ https://issues.apache.org/jira/browse/FLINK-25758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480471#comment-17480471 ] Galen Warren commented on FLINK-25758: -- Sure, I'll take a look. Is there a way to r

[jira] [Commented] (FLINK-25577) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479647#comment-17479647 ] Galen Warren commented on FLINK-25577: -- [~MartijnVisser] [~dmvk]  I've created a P

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479454#comment-17479454 ] Galen Warren commented on FLINK-11838: -- [~MartijnVisser] I'd say let's handle docum

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470705#comment-17470705 ] Galen Warren commented on FLINK-25577: -- Why don't we leave it open, just so that it

[jira] [Commented] (FLINK-25577) Update GCS documentation not to use no longer supported flink-shaded-hadoop artifacts

[ https://issues.apache.org/jira/browse/FLINK-25577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470701#comment-17470701 ] Galen Warren commented on FLINK-25577: -- I just wanted to mention that it's likely t

[jira] [Commented] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2

[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465402#comment-17465402 ] Galen Warren commented on FLINK-25197: -- PR created: https://github.com/apache/flink

[jira] [Commented] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2

[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465400#comment-17465400 ] Galen Warren commented on FLINK-25197: -- PR created: https://github.com/apache/flink

[jira] [Updated] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2.c

[ 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

[jira] [Created] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2.c

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 "org.apache.flink.shaded.jackson2.com.fasterxml.jackson.datatype:jack

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398108#comment-17398108 ] Galen Warren commented on FLINK-11838: -- I know this has taken a long time. I'll hav

[jira] [Commented] (FLINK-22757) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350139#comment-17350139 ] Galen Warren commented on FLINK-22757: -- In case it's relevant here, I'm working on

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342087#comment-17342087 ] Galen Warren commented on FLINK-19481: -- I wanted to check in here. Should I wait un

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17338418#comment-17338418 ] Galen Warren commented on FLINK-19481: -- Hi all, I'm the author of the other [PR|ht

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326990#comment-17326990 ] Galen Warren commented on FLINK-11838: -- PR is still active. > Create RecoverableWr

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320363#comment-17320363 ] Galen Warren commented on FLINK-11838: -- [~xintongsong], PR created: [https://githu

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316376#comment-17316376 ] Galen Warren commented on FLINK-11838: -- Working on the new PR now ... coming soon.

[jira] [Comment Edited] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314079#comment-17314079 ] Galen Warren edited comment on FLINK-11838 at 4/2/21, 8:54 PM: ---

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314079#comment-17314079 ] Galen Warren commented on FLINK-11838: -- [~xintongsong] – actually, is that the righ

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314067#comment-17314067 ] Galen Warren commented on FLINK-11838: -- Hi [~xintongsong] – sorry for the long dela

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303537#comment-17303537 ] Galen Warren commented on FLINK-11838: -- Not that I'm aware of. Writing checkpoints/

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300332#comment-17300332 ] Galen Warren commented on FLINK-11838: -- [~BerkayOzturk] No, it's not in a working s

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295384#comment-17295384 ] Galen Warren commented on FLINK-11838: -- I just wanted to add an update here so this

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288419#comment-17288419 ] Galen Warren commented on FLINK-11838: -- Hey, I just wanted to check in here. Sorry

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284896#comment-17284896 ] Galen Warren commented on FLINK-11838: -- Ah, OK – I see. It will take me a couple of

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284751#comment-17284751 ] Galen Warren commented on FLINK-11838: -- That's fine on "compose on persist", I'll l

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284476#comment-17284476 ] Galen Warren commented on FLINK-11838: -- {quote}Maybe for the first step, it's good

[jira] [Comment Edited] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283950#comment-17283950 ] Galen Warren edited comment on FLINK-11838 at 2/12/21, 9:01 PM: --

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283950#comment-17283950 ] Galen Warren commented on FLINK-11838: -- One more thought/question. While we can pot

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283747#comment-17283747 ] Galen Warren commented on FLINK-11838: -- Hi [~xintongsong], sorry for the delay here

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281769#comment-17281769 ] Galen Warren commented on FLINK-11838: -- Hi [~xintongsong] – a couple more thoughts

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281481#comment-17281481 ] Galen Warren commented on FLINK-11838: -- Thanks, that all sounds reasonable. I'll ta

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17280587#comment-17280587 ] Galen Warren commented on FLINK-11838: -- Thanks. All of your initial assumptions are

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279694#comment-17279694 ] Galen Warren commented on FLINK-11838: -- Thanks [~xtsong]! I really appreciate your

[jira] [Commented] (FLINK-11838) Create RecoverableWriter for GCS

[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279023#comment-17279023 ] Galen Warren commented on FLINK-11838: -- I have submitted a new [PR|https://github.c

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201123#comment-17201123 ] Galen Warren commented on FLINK-18810: -- I'd also love to see a Golang SDK and would

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196268#comment-17196268 ] Galen Warren commented on FLINK-19176: -- I just created a PR: [https://github.com/ap

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195635#comment-17195635 ] Galen Warren commented on FLINK-19176: -- Thanks! I'll get to work on that. > Suppor

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195564#comment-17195564 ] Galen Warren commented on FLINK-19176: -- Thanks [~igal]. Yep, that's almost exactly

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194832#comment-17194832 ] Galen Warren commented on FLINK-19176: -- Hi [~igal] - I've forked the project and ta

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194243#comment-17194243 ] Galen Warren commented on FLINK-19176: -- Thanks for the quick reply! A few comments/

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193217#comment-17193217 ] Galen Warren commented on FLINK-19176: -- Sorry for the edits – I'm trying to get hyp

[jira] [Updated] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

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

[jira] [Updated] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

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

[jira] [Updated] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

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

[jira] [Created] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

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

[jira] [Created] (FLINK-11055) Allow Queryable State to be transformed on the TaskManager before being returned to the client

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