[jira] [Commented] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429363#comment-17429363 ] xmarker commented on FLINK-24538: - I have push some code( [https://github.com/apache/flink/pull/17502] )

[jira] [Comment Edited] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429345#comment-17429345 ] xmarker edited comment on FLINK-24538 at 10/15/21, 3:57 PM: I investigate

[jira] [Commented] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429345#comment-17429345 ] xmarker commented on FLINK-24538: - I investigate the issue related code and i think the issue may be

[jira] [Commented] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

[ https://issues.apache.org/jira/browse/FLINK-24488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428660#comment-17428660 ] xmarker commented on FLINK-24488: - OK ,think you ! > KafkaRecordSerializationSchemaBuilder does not

[jira] [Commented] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

[ https://issues.apache.org/jira/browse/FLINK-24488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428282#comment-17428282 ] xmarker commented on FLINK-24488: - May be KafkaRecordSerializationSchemaWrapper.serialize called a

[jira] [Commented] (FLINK-24457) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails with NoSuchElement

[ https://issues.apache.org/jira/browse/FLINK-24457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428125#comment-17428125 ] xmarker commented on FLINK-24457: - I investigated the relevant code, I think it may be

[jira] [Commented] (FLINK-24329) PulsarSourceITCase fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417085#comment-17417085 ] xmarker commented on FLINK-24329: - I can help fix the issue,maybe we should use dynamic port 0 as pulsar

[jira] [Comment Edited] (FLINK-24213) Java deadlock in QueryableState ClientTest

[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412349#comment-17412349 ] xmarker edited comment on FLINK-24213 at 9/9/21, 6:29 AM: -- The dead lock seems

[jira] [Commented] (FLINK-24213) Java deadlock in QueryableState ClientTest

[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412349#comment-17412349 ] xmarker commented on FLINK-24213: - The dead lock seems occur in following scene: 1.When

[jira] [Commented] (FLINK-24203) AbstractServerTest fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411677#comment-17411677 ] xmarker commented on FLINK-24203: - [~xtsong] I can help resolve the issue > AbstractServerTest fails

[jira] [Commented] (FLINK-22730) Lookup join condition with CURRENT_DATE fails to filter records

[ https://issues.apache.org/jira/browse/FLINK-22730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350033#comment-17350033 ] xmarker commented on FLINK-22730: - Could you assign this jira to me ?   > Lookup join condition with

[jira] [Issue Comment Deleted] (FLINK-22592) numBuffersInLocal is always zero when using unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-22592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xmarker updated FLINK-22592: Comment: was deleted (was: Could you assign this Jira to me?) > numBuffersInLocal is always zero when

[jira] [Commented] (FLINK-22592) numBuffersInLocal is always zero when using unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-22592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341190#comment-17341190 ] xmarker commented on FLINK-22592: - Could you assign this Jira to me? > numBuffersInLocal is always zero