[jira] [Updated] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.)

[ https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott updated FLINK-28185: -- Description: When using the {{OffsetsInitializer.timestamp(.)}} on a topic with empty

[jira] [Created] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.)

Peter Schrott created FLINK-28185: - Summary: "Invalid negative offset" when using OffsetsInitializer.timestamp(.) Key: FLINK-28185 URL: https://issues.apache.org/jira/browse/FLINK-28185 Project:

[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554609#comment-17554609 ] Peter Schrott commented on FLINK-28060: --- >From a users perspective I see 2 issues here: 1)

[jira] [Updated] (FLINK-27592) WebUI - Status CANCELING not showing in overview

[ https://issues.apache.org/jira/browse/FLINK-27592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott updated FLINK-27592: -- Priority: Major (was: Minor) > WebUI - Status CANCELING not showing in overview >

[jira] [Updated] (FLINK-27592) WebUI - Status CANCELING not showing in overview

[ https://issues.apache.org/jira/browse/FLINK-27592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott updated FLINK-27592: -- Description: Cluster Version: 1.15.0, Standalone Job Version: 1.15.0 Status "CANCELING" is

[jira] [Updated] (FLINK-27592) WebUI - Status CANCELING not showing in overview

[ https://issues.apache.org/jira/browse/FLINK-27592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott updated FLINK-27592: -- Description: Cluster Version: 1.15.0, Standalone Job Version: 1.15.0 Status "CANCELING" is

[jira] [Updated] (FLINK-27592) WebUI - Status CANCELING not showing in overview

[ https://issues.apache.org/jira/browse/FLINK-27592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott updated FLINK-27592: -- Description: Cluster Version: 1.15.0, Standalone Job Version: 1.15.0 Status "CANCELING" is

[jira] [Created] (FLINK-27592) WebUI - Status CANCELING not showing in overview

Peter Schrott created FLINK-27592: - Summary: WebUI - Status CANCELING not showing in overview Key: FLINK-27592 URL: https://issues.apache.org/jira/browse/FLINK-27592 Project: Flink Issue

[jira] [Commented] (FLINK-27552) Prometheus metrics disappear after starting a job

[ https://issues.apache.org/jira/browse/FLINK-27552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533738#comment-17533738 ] Peter Schrott commented on FLINK-27552: --- [~eskabetxe] oke! In the mailing list thread Cheasney

[jira] [Commented] (FLINK-27552) Prometheus metrics disappear after starting a job

[ https://issues.apache.org/jira/browse/FLINK-27552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533697#comment-17533697 ] Peter Schrott commented on FLINK-27552: --- [~eskabetxe] if you have a KafkaSink, you need to disable

[jira] [Commented] (FLINK-27552) Prometheus metrics disappear after starting a job

[ https://issues.apache.org/jira/browse/FLINK-27552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533647#comment-17533647 ] Peter Schrott commented on FLINK-27552: --- If you are using Kafka source / sink you might not be

[jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434165#comment-17434165 ] Peter Schrott commented on FLINK-24544: --- I found a workaround for that issue - which works at

[jira] [Comment Edited] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431204#comment-17431204 ] Peter Schrott edited comment on FLINK-24544 at 10/20/21, 1:36 PM: -- The

[jira] [Comment Edited] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431204#comment-17431204 ] Peter Schrott edited comment on FLINK-24544 at 10/20/21, 12:59 PM: ---

[jira] [Comment Edited] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431204#comment-17431204 ] Peter Schrott edited comment on FLINK-24544 at 10/20/21, 12:59 PM: ---

[jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431204#comment-17431204 ] Peter Schrott commented on FLINK-24544: --- The underlying problem with deserialization of records

[jira] [Comment Edited] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429243#comment-17429243 ] Peter Schrott edited comment on FLINK-24544 at 10/15/21, 12:04 PM: --- I

[jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429243#comment-17429243 ] Peter Schrott commented on FLINK-24544: --- I was wondering about the message of the exception: 

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574273#comment-14574273 ] Peter Schrott commented on FLINK-1731: -- [~till.rohrmann] I am not entirely sure if we

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14572577#comment-14572577 ] Peter Schrott commented on FLINK-1731: -- Hi [~fobeligi], sure you can pull it from my

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543670#comment-14543670 ] Peter Schrott commented on FLINK-1731: -- Hi flink people, as we now figured out how

[jira] [Assigned] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott reassigned FLINK-1731: Assignee: Peter Schrott (was: Alexander Alexandrov) Add kMeans clustering algorithm to

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543648#comment-14543648 ] Peter Schrott commented on FLINK-1731: -- Great! Thanks! Add kMeans clustering

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541818#comment-14541818 ] Peter Schrott commented on FLINK-1731: -- As discussed with [~aalexandrov] The initial

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541516#comment-14541516 ] Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:29 AM:

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541516#comment-14541516 ] Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:30 AM:

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541516#comment-14541516 ] Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:33 AM:

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14540465#comment-14540465 ] Peter Schrott commented on FLINK-1731: -- Very nice. The implementation of BreezeVector

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532619#comment-14532619 ] Peter Schrott commented on FLINK-1731: -- For the implementation of the Kmeans

[jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530424#comment-14530424 ] Peter Schrott edited comment on FLINK-1731 at 5/6/15 12:10 PM:

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530424#comment-14530424 ] Peter Schrott commented on FLINK-1731: -- FGoessler, philjjoon, peedeeX21 voelkj are