[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844662#comment-17844662 ] Kenneth William Krugler commented on FLINK-35215: - Hi [~fanrui] - I added a comment to

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841547#comment-17841547 ] Kenneth William Krugler commented on FLINK-35215: - Hi [~fanrui] - thanks for the

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840259#comment-17840259 ] Kenneth William Krugler commented on FLINK-35215: - Hi [~fanrui] - I haven't been

[jira] [Commented] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836325#comment-17836325 ] Kenneth William Krugler commented on FLINK-35076: - Hi [~elon] - please post these

[jira] [Commented] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835871#comment-17835871 ] Kenneth William Krugler commented on FLINK-35076: - There are logical reasons why picking

[jira] [Commented] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store

[ https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832917#comment-17832917 ] Kenneth William Krugler commented on FLINK-34975: - I'd previously explored using

[jira] [Commented] (FLINK-30112) Improve docs re state compression

[ https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786890#comment-17786890 ] Kenneth William Krugler commented on FLINK-30112: - As of

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17570567#comment-17570567 ] Kenneth William Krugler commented on FLINK-28653: - What happens if you explicitly define

[jira] [Commented] (FLINK-21548) keyBy operation produces skewed record distribution for low-cardinality keys

[ https://issues.apache.org/jira/browse/FLINK-21548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337814#comment-17337814 ] Kenneth William Krugler commented on FLINK-21548: - Hi [~izeigerman] - it would be good

[jira] [Updated] (FLINK-22429) Exclude Sub-Tasks in all bot "stale-unassigned" rule of Jira Bot

[ https://issues.apache.org/jira/browse/FLINK-22429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth William Krugler updated FLINK-22429: Summary: Exclude Sub-Tasks in all bot "stale-unassigned" rule of Jira Bot

[jira] [Commented] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329462#comment-17329462 ] Kenneth William Krugler commented on FLINK-9541: [~chesnay] - I'd take on this issue, but

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316425#comment-17316425 ] Kenneth William Krugler commented on FLINK-22139: - Hi [~bhagi__R] - apologies if I

[jira] [Commented] (FLINK-21548) keyBy operation produces skewed record distribution for low-cardinality keys

[ https://issues.apache.org/jira/browse/FLINK-21548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293200#comment-17293200 ] Kenneth William Krugler commented on FLINK-21548: - Yes, if you generate 1M random values

[jira] [Commented] (FLINK-21548) keyBy operation produces skewed record distribution for low-cardinality keys

[ https://issues.apache.org/jira/browse/FLINK-21548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293126#comment-17293126 ] Kenneth William Krugler commented on FLINK-21548: - Hi [~izeigerman] - I don't believe

[jira] [Closed] (FLINK-19794) who wrote the the documents?

[ https://issues.apache.org/jira/browse/FLINK-19794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth William Krugler closed FLINK-19794. --- Resolution: Not A Bug > who wrote the the documents? >

[jira] [Commented] (FLINK-19794) who wrote the the documents?

[ https://issues.apache.org/jira/browse/FLINK-19794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220212#comment-17220212 ] Kenneth William Krugler commented on FLINK-19794: - Hi [~appleyuchi] - the right place to

[jira] [Commented] (FLINK-19264) Identical jobs cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197096#comment-17197096 ] Kenneth William Krugler commented on FLINK-19264: - Hmm, since FLINK-17295 was a recent

[jira] [Commented] (FLINK-19264) MiniCluster is flaky with concurrent job execution

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197023#comment-17197023 ] Kenneth William Krugler commented on FLINK-19264: - I often ran into this same issue, and

[jira] [Comment Edited] (FLINK-19264) MiniCluster is flaky with concurrent job execution

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197023#comment-17197023 ] Kenneth William Krugler edited comment on FLINK-19264 at 9/16/20, 2:52 PM:

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190447#comment-17190447 ] Kenneth William Krugler commented on FLINK-19069: - See also 

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190358#comment-17190358 ] Kenneth William Krugler commented on FLINK-19133: - Yes, we ran into this exact issue

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186823#comment-17186823 ] Kenneth William Krugler commented on FLINK-18934: - On the list, [~dwysakowicz] said:

[jira] [Updated] (FLINK-19087) ResultPartitionWriter should not expose subpartition but only subpartition-readers

[ https://issues.apache.org/jira/browse/FLINK-19087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth William Krugler updated FLINK-19087: Summary: ResultPartitionWriter should not expose subpartition but only

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186231#comment-17186231 ] Kenneth William Krugler commented on FLINK-19069: - I'd recently posted about a related

[jira] [Commented] (FLINK-18961) In the case of FlatMap linking map, if map returns null, an exception will be thrown in FlatMap

[ https://issues.apache.org/jira/browse/FLINK-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178007#comment-17178007 ] Kenneth William Krugler commented on FLINK-18961: - Hi [~chesnay] - the exception is

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177070#comment-17177070 ] Kenneth William Krugler commented on FLINK-18934: - Hi [~kien_truong] - I would suggest

[jira] [Comment Edited] (FLINK-18723) performance test

[ https://issues.apache.org/jira/browse/FLINK-18723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165409#comment-17165409 ] Kenneth William Krugler edited comment on FLINK-18723 at 7/27/20, 3:38 AM:

[jira] [Commented] (FLINK-18723) performance test

[ https://issues.apache.org/jira/browse/FLINK-18723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165409#comment-17165409 ] Kenneth William Krugler commented on FLINK-18723: - Hi [~dahaishuantuoba] - this is a

[jira] [Created] (FLINK-18707) Calling remove() for RockDB ListState iterator does nothing

Kenneth William Krugler created FLINK-18707: --- Summary: Calling remove() for RockDB ListState iterator does nothing Key: FLINK-18707 URL: https://issues.apache.org/jira/browse/FLINK-18707

[jira] [Commented] (FLINK-18436) how to implement the class `MyTupleReducer`in flink official document

[ https://issues.apache.org/jira/browse/FLINK-18436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149465#comment-17149465 ] Kenneth William Krugler commented on FLINK-18436: - Hi [~appleyuchi] - I'm going to

[jira] [Commented] (FLINK-17478) Avro format logical type conversions do not work due to type mismatch

[ https://issues.apache.org/jira/browse/FLINK-17478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101239#comment-17101239 ] Kenneth William Krugler commented on FLINK-17478: - Hi [~gyfora] - is this related to 

[jira] [Commented] (FLINK-16157) StateFun benchmark and performance

[ https://issues.apache.org/jira/browse/FLINK-16157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039409#comment-17039409 ] Kenneth William Krugler commented on FLINK-16157: - Hi [~omidbb] - this would be a good

[jira] [Commented] (FLINK-15634) disableAutoGeneratedUIDs fails with coGroup and join

[ https://issues.apache.org/jira/browse/FLINK-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018636#comment-17018636 ] Kenneth William Krugler commented on FLINK-15634: - Is this a duplicate of 

[jira] [Commented] (FLINK-14798) how to setup a ha flink cluster on k8s?

[ https://issues.apache.org/jira/browse/FLINK-14798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975258#comment-16975258 ] Kenneth William Krugler commented on FLINK-14798: - Hi [~lonely1eaf] - for questions like

[jira] [Commented] (FLINK-14472) Implement back-pressure monitor with non-blocking outputs

[ https://issues.apache.org/jira/browse/FLINK-14472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956148#comment-16956148 ] Kenneth William Krugler commented on FLINK-14472: - Did the issue ever get fixed, where

[jira] [Commented] (FLINK-14197) Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows

[ https://issues.apache.org/jira/browse/FLINK-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938961#comment-16938961 ] Kenneth William Krugler commented on FLINK-14197: - I would suggest posting to the