[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733211#comment-17733211 ] Ben Augarten commented on FLINK-30093: -- Thanks [~libenchao], at first I thought tha

[jira] [Comment Edited] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731015#comment-17731015 ] Ben Augarten edited comment on FLINK-30093 at 6/9/23 4:18 PM:

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731015#comment-17731015 ] Ben Augarten commented on FLINK-30093: -- Hey, thanks for the contribution. I'm runni

[jira] [Commented] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529741#comment-17529741 ] Ben Augarten commented on FLINK-27420: -- [~xtsong] – thanks, I posted a PR against m

[jira] [Commented] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529041#comment-17529041 ] Ben Augarten commented on FLINK-27420: -- Thanks for adding that context! For 1.14 &

[jira] [Created] (FLINK-27420) Suspended SlotManagers fail to reregister metrics when started again

Ben Augarten created FLINK-27420: Summary: Suspended SlotManagers fail to reregister metrics when started again Key: FLINK-27420 URL: https://issues.apache.org/jira/browse/FLINK-27420 Project: Flink

[jira] [Updated] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Augarten updated FLINK-27420: - Summary: Suspended SlotManager fail to reregister metrics when started again (was: Suspended Sl

[jira] [Updated] (FLINK-25236) Add a mechanism to generate and validate a jobgraph with a checkpoint before submission

[ https://issues.apache.org/jira/browse/FLINK-25236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Augarten updated FLINK-25236: - Description: I've mostly worked on flink 1.9-1.12, but I believe this is still an issue today. 

[jira] [Created] (FLINK-25236) Add a mechanism to generate and validate a jobgraph with a checkpoint before submission

Ben Augarten created FLINK-25236: Summary: Add a mechanism to generate and validate a jobgraph with a checkpoint before submission Key: FLINK-25236 URL: https://issues.apache.org/jira/browse/FLINK-25236

[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=17338455#comment-17338455 ] Ben Augarten commented on FLINK-19481: -- Hey Robert and Galen, I appreciate you both

[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=17337835#comment-17337835 ] Ben Augarten commented on FLINK-19481: -- We've been using a non-hadoop implementatio

[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=17208844#comment-17208844 ] Ben Augarten commented on FLINK-19481: -- [~yunta] yes, that's right. Checkpoint on G

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

Ben Augarten created FLINK-19481: Summary: Add support for a flink native GCS FileSystem Key: FLINK-19481 URL: https://issues.apache.org/jira/browse/FLINK-19481 Project: Flink Issue Type: Imp