[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 partiti

[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: Flink

[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&focusedCommentId=17554609#comment-17554609 ] Peter Schrott commented on FLINK-28060: --- >From a users perspective I see 2 issues

[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 no

[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 no

[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 no

[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 Type

[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&focusedCommentId=17533738#comment-17533738 ] Peter Schrott commented on FLINK-27552: --- [~eskabetxe] oke! In the mailing list thr

[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&focusedCommentId=17533697#comment-17533697 ] Peter Schrott commented on FLINK-27552: --- [~eskabetxe] if you have a KafkaSink, you

[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&focusedCommentId=17533647#comment-17533647 ] Peter Schrott commented on FLINK-27552: --- If you are using Kafka source / sink you

[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&focusedCommentId=17434165#comment-17434165 ] Peter Schrott commented on FLINK-24544: --- I found a workaround for that issue - whi

[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&focusedCommentId=17431204#comment-17431204 ] Peter Schrott edited comment on FLINK-24544 at 10/20/21, 1:36 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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17431204#comment-17431204 ] Peter Schrott commented on FLINK-24544: --- The underlying problem with deserializati

[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&focusedCommentId=17429243#comment-17429243 ] Peter Schrott edited comment on FLINK-24544 at 10/15/21, 12:04 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&focusedCommentId=17429243#comment-17429243 ] Peter Schrott commented on FLINK-24544: --- I was wondering about the message of the

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14543670#comment-14543670 ] Peter Schrott commented on FLINK-1731: -- Hi flink people, as we now figured out how t

[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-tabpanel&focusedCommentId=14543648#comment-14543648 ] Peter Schrott commented on FLINK-1731: -- Great! Thanks! > Add kMeans clustering algor

[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 m

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14541516#comment-14541516 ] Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:33 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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14541516#comment-14541516 ] Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:29 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-tabpanel&focusedCommentId=14541516#comment-14541516 ] Peter Schrott commented on FLINK-1731: -- Hi [~chiwanpark], the thing is, to fit the m

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14532619#comment-14532619 ] Peter Schrott commented on FLINK-1731: -- For the implementation of the Kmeans algorith

[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-tabpanel&focusedCommentId=14530424#comment-14530424 ] Peter Schrott edited comment on FLINK-1731 at 5/6/15 1:16 PM: --

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14530424#comment-14530424 ] Peter Schrott commented on FLINK-1731: -- FGoessler, philjjoon, peedeeX21 & voelkj are