[jira] [Commented] (FLINK-30945) FTS does not support multiple writers into the same table and topic

[ https://issues.apache.org/jira/browse/FLINK-30945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690568#comment-17690568 ] Xinbin Huang commented on FLINK-30945: -- [~lzljs3620320] would you assign this to me

[jira] [Commented] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

[ https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639773#comment-17639773 ] Xinbin Huang commented on FLINK-23035: -- hey [~Yanfei Lei] , sorry I missed the mess

[jira] [Commented] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569731#comment-17569731 ] Xinbin Huang commented on FLINK-27916: -- [~martijnvisser] I've run the test several

[jira] [Updated] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinbin Huang updated FLINK-27916: - Attachment: Screen Shot 2022-07-21 at 5.51.40 PM.png > HybridSourceReaderTest.testReader failed

[jira] [Commented] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569718#comment-17569718 ] Xinbin Huang commented on FLINK-27916: -- [~martijnvisser] I can help look into this,

[jira] [Commented] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource

[ https://issues.apache.org/jira/browse/FLINK-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567763#comment-17567763 ] Xinbin Huang commented on FLINK-23633: -- [~thw] I've made a PR to implement this. Wo

[jira] [Commented] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource

[ https://issues.apache.org/jira/browse/FLINK-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534465#comment-17534465 ] Xinbin Huang commented on FLINK-23633: -- [~thw] it would be great to assign the issu

[jira] [Commented] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource

[ https://issues.apache.org/jira/browse/FLINK-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534048#comment-17534048 ] Xinbin Huang commented on FLINK-23633: -- Hi [~thw] , may I try to implement this? >

[jira] [Updated] (FLINK-25009) Output slotSharingGroup as part of JsonGraph

[ https://issues.apache.org/jira/browse/FLINK-25009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinbin Huang updated FLINK-25009: - Description: `flink info` currently doesn't output the slotSharingGroup information for each ope

[jira] [Updated] (FLINK-25009) Output slotSharingGroup as part of JsonGraph

[ https://issues.apache.org/jira/browse/FLINK-25009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinbin Huang updated FLINK-25009: - Component/s: Command Line Client > Output slotSharingGroup as part of JsonGraph > --

[jira] [Created] (FLINK-25009) Output slotSharingGroup as part of JsonGraph

Xinbin Huang created FLINK-25009: Summary: Output slotSharingGroup as part of JsonGraph Key: FLINK-25009 URL: https://issues.apache.org/jira/browse/FLINK-25009 Project: Flink Issue Type: Impr

[jira] [Comment Edited] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

[ https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440985#comment-17440985 ] Xinbin Huang edited comment on FLINK-23035 at 11/10/21, 3:29 AM: -

[jira] [Commented] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

[ https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440985#comment-17440985 ] Xinbin Huang commented on FLINK-23035: -- Hi, all. Can you assign this to me if no on