[jira] [Comment Edited] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

2019-05-17 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841524#comment-16841524 ] Konstantin Knauf edited comment on FLINK-12381 at 5/17/19 8:22 AM: ---

[jira] [Assigned] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

2019-05-16 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-12381: Assignee: Konstantin Knauf > W/o HA, upon a full restart, checkpointing crashes

[jira] [Commented] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

2019-05-16 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841524#comment-16841524 ] Konstantin Knauf commented on FLINK-12381: -- [~till.rohrmann] I am happy to take this. Let me

[jira] [Commented] (FLINK-10611) Documentation should describe how to choose between Rolling & Streaming file sink

2019-05-14 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839442#comment-16839442 ] Konstantin Knauf commented on FLINK-10611: -- [~kkl0u] Is there any reason to pick the

[jira] [Created] (FLINK-12508) Expand Documentation on Testing DataStream API programs

2019-05-14 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-12508: Summary: Expand Documentation on Testing DataStream API programs Key: FLINK-12508 URL: https://issues.apache.org/jira/browse/FLINK-12508 Project: Flink

[jira] [Created] (FLINK-12212) Clarify documentation about async checkpointing

2019-04-16 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-12212: Summary: Clarify documentation about async checkpointing Key: FLINK-12212 URL: https://issues.apache.org/jira/browse/FLINK-12212 Project: Flink

[jira] [Updated] (FLINK-12169) Improve Javadoc of MessageAcknowledgingSourceBase

2019-04-12 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12169: - Component/s: Connectors/ RabbitMQ > Improve Javadoc of MessageAcknowledgingSourceBase >

[jira] [Created] (FLINK-12169) Improve Javadoc of MessageAcknowledgingSourceBase

2019-04-12 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-12169: Summary: Improve Javadoc of MessageAcknowledgingSourceBase Key: FLINK-12169 URL: https://issues.apache.org/jira/browse/FLINK-12169 Project: Flink

[jira] [Commented] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812463#comment-16812463 ] Konstantin Knauf commented on FLINK-12119: -- [~Zentol] I happy to do it if you give me a

[jira] [Commented] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812343#comment-16812343 ] Konstantin Knauf commented on FLINK-12119: -- Thanks for the feeback [~Zentol]. Sounds good. 

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-05 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security

[jira] [Created] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-05 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-12119: Summary: Add OWASP Dependency Check to Flink Build Key: FLINK-12119 URL: https://issues.apache.org/jira/browse/FLINK-12119 Project: Flink Issue

[jira] [Created] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

2019-03-01 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-11793: Summary: Make KafkaProducer more resilient to Kafka Broker Failures Key: FLINK-11793 URL: https://issues.apache.org/jira/browse/FLINK-11793 Project: Flink

[jira] [Created] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

2019-03-01 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-11792: Summary: Make KafkaConsumer more resilient to Kafka Broker Failures Key: FLINK-11792 URL: https://issues.apache.org/jira/browse/FLINK-11792 Project: Flink

[jira] [Commented] (FLINK-11615) Webfrontend is not accessible in 1.7.x

2019-02-14 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768119#comment-16768119 ] Konstantin Knauf commented on FLINK-11615: -- Did you make sure to include the

[jira] [Updated] (FLINK-11473) Clarify Documenation on Latency Tracking

2019-01-30 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11473: - Description: The documenation on Latency Tracking states: {noformat} All intermediate

[jira] [Updated] (FLINK-11473) Clarify Documenation on Latency Tracking

2019-01-30 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11473: - Summary: Clarify Documenation on Latency Tracking (was: Clarify Documenation on

[jira] [Created] (FLINK-11473) Clarify Documenation on Latency Markers

2019-01-30 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-11473: Summary: Clarify Documenation on Latency Markers Key: FLINK-11473 URL: https://issues.apache.org/jira/browse/FLINK-11473 Project: Flink Issue Type:

[jira] [Closed] (FLINK-10923) Make SlotPool Status Machine-Readable

2018-12-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf closed FLINK-10923. Resolution: Not A Problem > Make SlotPool Status Machine-Readable >

[jira] [Commented] (FLINK-10923) Make SlotPool Status Machine-Readable

2018-12-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706810#comment-16706810 ] Konstantin Knauf commented on FLINK-10923: -- [~twalthr] I will close the issue based on Till's

[jira] [Commented] (FLINK-10923) Make SlotPool Status Machine-Readable

2018-11-27 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700884#comment-16700884 ] Konstantin Knauf commented on FLINK-10923: -- [~till.rohrmann] I think you are right. Let's put

[jira] [Created] (FLINK-10991) Dockerfile in flink-container does not work with RocksDBStatebackend

2018-11-22 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10991: Summary: Dockerfile in flink-container does not work with RocksDBStatebackend Key: FLINK-10991 URL: https://issues.apache.org/jira/browse/FLINK-10991

[jira] [Created] (FLINK-10923) Make SlotPool Status Machine-Readable

2018-11-18 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10923: Summary: Make SlotPool Status Machine-Readable Key: FLINK-10923 URL: https://issues.apache.org/jira/browse/FLINK-10923 Project: Flink Issue Type:

[jira] [Closed] (FLINK-10905) HadoopConfigLoader logs Credentials on DEBUG level

2018-11-15 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf closed FLINK-10905. Resolution: Invalid Release Note: This was invalid. Misinterpreted the logs. >

[jira] [Created] (FLINK-10906) docker-entrypoint.sh logs credentails during startup

2018-11-15 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10906: Summary: docker-entrypoint.sh logs credentails during startup Key: FLINK-10906 URL: https://issues.apache.org/jira/browse/FLINK-10906 Project: Flink

[jira] [Updated] (FLINK-10905) HadoopConfigLoader logs Credentials on DEBUG level

2018-11-15 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10905: - Description: If you set S3 credentials {{via s3.access-key}} and {{s3.secret-key}} the

[jira] [Created] (FLINK-10905) HadoopConfigLoader logs Credentials on DEBUG level

2018-11-15 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10905: Summary: HadoopConfigLoader logs Credentials on DEBUG level Key: FLINK-10905 URL: https://issues.apache.org/jira/browse/FLINK-10905 Project: Flink

[jira] [Commented] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

2018-10-17 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16653182#comment-16653182 ] Konstantin Knauf commented on FLINK-10519: -- Seems to work for now for me. > flink-parent:1.6.1

[jira] [Updated] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

2018-10-11 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10519: - Affects Version/s: 1.6.1 1.5.4 > flink-parent:1.6.1 artifact

[jira] [Commented] (FLINK-9753) Support Parquet for StreamingFileSink

2018-10-07 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16641362#comment-16641362 ] Konstantin Knauf commented on FLINK-9753: - [~Averell] The current implementation follows approach

[jira] [Created] (FLINK-10452) Expose Additional Metrics to Reason about Statesize

2018-09-27 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10452: Summary: Expose Additional Metrics to Reason about Statesize Key: FLINK-10452 URL: https://issues.apache.org/jira/browse/FLINK-10452 Project: Flink

[jira] [Updated] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

2018-09-17 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10353: - Description: If a KafkaProducer with {{Semantic.EXACTLY_ONCE}} is restored from a

[jira] [Updated] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

2018-09-17 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10353: - Description: If a KafkaProducer with {{Semantic.EXACTLY_ONCE}} is restored from a

[jira] [Created] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

2018-09-17 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10353: Summary: Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE Key: FLINK-10353 URL:

[jira] [Commented] (FLINK-10303) Fix critical vulnerabilities Python API

2018-09-13 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613713#comment-16613713 ] Konstantin Knauf commented on FLINK-10303: -- [~Zentol] I think, this was done with Sonar. I just

[jira] [Created] (FLINK-10303) Fix critical vulnerabilities Python API

2018-09-07 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10303: Summary: Fix critical vulnerabilities Python API Key: FLINK-10303 URL: https://issues.apache.org/jira/browse/FLINK-10303 Project: Flink Issue Type:

[jira] [Created] (FLINK-10223) TaskManagers should log their `ResourceID` during startup

2018-08-27 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10223: Summary: TaskManagers should log their `ResourceID` during startup Key: FLINK-10223 URL: https://issues.apache.org/jira/browse/FLINK-10223 Project: Flink

[jira] [Resolved] (FLINK-3785) Add REST resource to query information about checkpointing

2018-08-15 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-3785. - Resolution: Information Provided > Add REST resource to query information about

[jira] [Comment Edited] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2018-07-23 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553008#comment-16553008 ] Konstantin Knauf edited comment on FLINK-8712 at 7/23/18 3:38 PM: --  

[jira] [Commented] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2018-07-23 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553008#comment-16553008 ] Konstantin Knauf commented on FLINK-8712: -   {code:java} Configuration conf = new

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

2017-02-26 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884862#comment-15884862 ] Konstantin Knauf commented on FLINK-2922: - [~uce] Is there a design doc/branch for current work on

[jira] [Commented] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name

2016-06-20 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339724#comment-15339724 ] Konstantin Knauf commented on FLINK-3757: - Thank you for looking into it. I find the javadoc,

[jira] [Updated] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

2016-06-16 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4027: Priority: Critical (was: Major) > FlinkKafkaProducer09 sink can lose messages >

[jira] [Updated] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

2016-06-16 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4027: Priority: Major (was: Critical) > FlinkKafkaProducer09 sink can lose messages >

[jira] [Closed] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-06-15 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf closed FLINK-3758. --- Resolution: Resolved > Add possibility to register accumulators in custom triggers >

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-06-15 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333144#comment-15333144 ] Konstantin Knauf commented on FLINK-3758: - Sure. I see you alreaday open a PR for it. Great. >

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-26 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302555#comment-15302555 ] Konstantin Knauf commented on FLINK-3758: - [~aljoscha] Yes, in particular my goal is to monitor

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-05-10 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15277969#comment-15277969 ] Konstantin Knauf commented on FLINK-3713: - Great, thank you! > DisposeSavepoint message uses

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-05-10 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15277761#comment-15277761 ] Konstantin Knauf commented on FLINK-3713: - [~uce] Any progress on this? The workaround starts to

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-09 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15276266#comment-15276266 ] Konstantin Knauf commented on FLINK-3758: - [~aljoscha] Ping. Going on vacation soon, and what to

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-05 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15272819#comment-15272819 ] Konstantin Knauf commented on FLINK-3758: - [~aljoscha] What do you think of

[jira] [Assigned] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-3758: --- Assignee: Konstantin Knauf > Add possibility to register accumulators in custom

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-05-02 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266976#comment-15266976 ] Konstantin Knauf commented on FLINK-3669: - The problem in the gist, yes. As I said, I could not

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-29 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264132#comment-15264132 ] Konstantin Knauf commented on FLINK-3669: - Hmpf, of course... > WindowOperator registers a lot of

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-28 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262485#comment-15262485 ] Konstantin Knauf commented on FLINK-3669: - [[~aljoscha] Thanks, will do the next time. I tried

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-28 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262000#comment-15262000 ] Konstantin Knauf commented on FLINK-3669: - [~aljoscha] I opened a PR > WindowOperator registers a

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-27 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15260431#comment-15260431 ] Konstantin Knauf commented on FLINK-3669: - I made the changes as suggested, and will open a PR

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-26 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258912#comment-15258912 ] Konstantin Knauf commented on FLINK-3669: - [~aljoscha] Hmpf. You're right. I was actually a little

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-22 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253557#comment-15253557 ] Konstantin Knauf commented on FLINK-3669: - Aljoscha, could you have a look at

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-04-20 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250106#comment-15250106 ] Konstantin Knauf commented on FLINK-3758: - {quote} In the Trigger we would not know when to call

[jira] [Comment Edited] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-04-20 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15250106#comment-15250106 ] Konstantin Knauf edited comment on FLINK-3758 at 4/20/16 3:42 PM: --

[jira] [Created] (FLINK-3785) Add REST resource to query information about checkpointing

2016-04-19 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-3785: --- Summary: Add REST resource to query information about checkpointing Key: FLINK-3785 URL: https://issues.apache.org/jira/browse/FLINK-3785 Project: Flink

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-14 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15240925#comment-15240925 ] Konstantin Knauf commented on FLINK-3669: - Nope, sorry I do not think I will have the time in the

[jira] [Created] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-04-14 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-3758: --- Summary: Add possibility to register accumulators in custom triggers Key: FLINK-3758 URL: https://issues.apache.org/jira/browse/FLINK-3758 Project: Flink

[jira] [Created] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name

2016-04-14 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-3757: --- Summary: addAccumulator does not throw Exception on duplicate accumulator name Key: FLINK-3757 URL: https://issues.apache.org/jira/browse/FLINK-3757 Project:

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232228#comment-15232228 ] Konstantin Knauf commented on FLINK-3669: - Is WindowCheckpointingIT the right place to put a test

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232116#comment-15232116 ] Konstantin Knauf commented on FLINK-3713: - Works as expected. > DisposeSavepoint message uses

[jira] [Assigned] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-07 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-3669: --- Assignee: Konstantin Knauf > WindowOperator registers a lot of timers at StreamTask

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-07 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230891#comment-15230891 ] Konstantin Knauf commented on FLINK-3669: - I have a first draft here:

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-04-07 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230124#comment-15230124 ] Konstantin Knauf commented on FLINK-3713: - I will give that a try and report. > DisposeSavepoint

[jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-04-07 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230058#comment-15230058 ] Konstantin Knauf commented on FLINK-3713: - Just for my understanding: It says there {quote}

[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-06 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15228019#comment-15228019 ] Konstantin Knauf commented on FLINK-3688: - Hi Robert, thanks, for the answer, but I have not

[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-05 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15226941#comment-15226941 ] Konstantin Knauf commented on FLINK-3688: - Could open the PR

[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-04 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225734#comment-15225734 ] Konstantin Knauf commented on FLINK-3688: - I will go ahead an open the PR for 4. this evening. >

[jira] [Comment Edited] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15223402#comment-15223402 ] Konstantin Knauf edited comment on FLINK-3669 at 4/3/16 5:32 PM: - I tried

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15223402#comment-15223402 ] Konstantin Knauf commented on FLINK-3669: - I tried to implement the 1.. The hard part, I think, is

[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15223353#comment-15223353 ] Konstantin Knauf commented on FLINK-3688: - Regarding dropping Watermarks in

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-04-01 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221677#comment-15221677 ] Konstantin Knauf commented on FLINK-3669: - I would like to work on it, but not today. I will give

[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-01 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221514#comment-15221514 ] Konstantin Knauf commented on FLINK-3688: - >From what I know, watermarks should just not be

[jira] [Created] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-01 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-3688: --- Summary: ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime Key: FLINK-3688 URL:

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-03-31 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15219865#comment-15219865 ] Konstantin Knauf commented on FLINK-3669: - In my opionen the 1st option is the cleanest, but I can

[jira] [Commented] (FLINK-3669) WindowOperator registers a log of timers at StreamTask

2016-03-30 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15217614#comment-15217614 ] Konstantin Knauf commented on FLINK-3669: - Hi Aljoscha, I think there is more to it, although

<    1   2