[jira] [Commented] (FLINK-15918) Uptime Metric not reset on Job Restart

[ https://issues.apache.org/jira/browse/FLINK-15918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031002#comment-17031002 ] Lakshmi Rao commented on FLINK-15918: - Just adding to what [~thw]  and [~shriya_a] mentioned, our

[jira] [Commented] (FLINK-11254) Unify serialization format of savepoint for switching state backends

[ https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793815#comment-16793815 ] Lakshmi Rao commented on FLINK-11254: - Thanks for this effort [~tzulitai] and [~klion26]. To be

[jira] [Assigned] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao reassigned FLINK-11826: --- Assignee: Lakshmi Rao > Kafka09ITCase.testRateLimitedConsumer fails on Travis >

[jira] [Commented] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16762965#comment-16762965 ] Lakshmi Rao commented on FLINK-11501: - Adding some screenshots of results from testing the Guava

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-11501: Attachment: Ratelimiting-2.png > Add a ratelimiting feature to the FlinkKafkaConsumer >

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-11501: Attachment: RateLimiting-1.png > Add a ratelimiting feature to the FlinkKafkaConsumer >

[jira] [Created] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

Lakshmi Rao created FLINK-11501: --- Summary: Add a ratelimiting feature to the FlinkKafkaConsumer Key: FLINK-11501 URL: https://issues.apache.org/jira/browse/FLINK-11501 Project: Flink Issue

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-11501: Description: There are instances when a Flink job that reads from Kafka can read at a

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-11501: Description: There are instances when a Flink job that reads from Kafka can read at a

[jira] [Created] (FLINK-10171) Allow for assemblePartPath override in the BucketingSink

Lakshmi Rao created FLINK-10171: --- Summary: Allow for assemblePartPath override in the BucketingSink Key: FLINK-10171 URL: https://issues.apache.org/jira/browse/FLINK-10171 Project: Flink Issue

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554917#comment-16554917 ] Lakshmi Rao commented on FLINK-9899: Thanks [~yanghua] !  > Add more metrics to the Kinesis source

[jira] [Comment Edited] (FLINK-9899) Add more metrics to the Kinesis source connector

[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554822#comment-16554822 ] Lakshmi Rao edited comment on FLINK-9899 at 7/24/18 9:35 PM: - [~yanghua] I

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554822#comment-16554822 ] Lakshmi Rao commented on FLINK-9899: [~yanghua] I created a PR with my changes - Let me know what you

[jira] [Updated] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to read more records in the case of long running loops

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9897: --- Summary: Further enhance adaptive reads in Kinesis Connector to read more records in the case of

[jira] [Updated] (FLINK-9899) Add more metrics to the Kinesis source connector

[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9899: --- Affects Version/s: 1.4.2 1.5.1 > Add more metrics to the Kinesis source

[jira] [Updated] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9897: --- Summary: Further enhance adaptive reads in Kinesis Connector to depend on run loop time (was:

[jira] [Updated] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9897: --- Affects Version/s: 1.4.2 1.5.1 > Further enhance adaptiveReads in Kinesis

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554732#comment-16554732 ] Lakshmi Rao commented on FLINK-9899: [~yanghua] Are you planning on working on this?  I have changes

[jira] [Assigned] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao reassigned FLINK-9897: -- Assignee: Lakshmi Rao > Further enhance adaptiveReads in Kinesis Connector to read more

[jira] [Created] (FLINK-9899) Add more metrics to the Kinesis source connector

Lakshmi Rao created FLINK-9899: -- Summary: Add more metrics to the Kinesis source connector Key: FLINK-9899 URL: https://issues.apache.org/jira/browse/FLINK-9899 Project: Flink Issue Type:

[jira] [Created] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

Lakshmi Rao created FLINK-9897: -- Summary: Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops Key: FLINK-9897 URL:

[jira] [Assigned] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao reassigned FLINK-9692: -- Assignee: Lakshmi Rao > Adapt maxRecords parameter in the getRecords call to optimize bytes

[jira] [Updated] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9692: --- Description: The Kinesis connector currently has a [constant

[jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

Lakshmi Rao created FLINK-9692: -- Summary: Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis Key: FLINK-9692 URL: https://issues.apache.org/jira/browse/FLINK-9692

[jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

Lakshmi Rao created FLINK-9691: -- Summary: Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Key: FLINK-9691 URL: https://issues.apache.org/jira/browse/FLINK-9691

[jira] [Resolved] (FLINK-9115) Support addition of part suffix in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao resolved FLINK-9115. Resolution: Duplicate > Support addition of part suffix in BucketingSink >

[jira] [Commented] (FLINK-9115) Support addition of part suffix in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16450027#comment-16450027 ] Lakshmi Rao commented on FLINK-9115: Hi [~Poluliakh], thanks for offering to work on this. As I was

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427291#comment-16427291 ] Lakshmi Rao commented on FLINK-9138: Agreed that event time is not applicable here. Yes, that's right,

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427254#comment-16427254 ] Lakshmi Rao commented on FLINK-9138: [~narayaruna]  [~fhueske] do you have thoughts on how to

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427220#comment-16427220 ] Lakshmi Rao commented on FLINK-9138: Hi [~fhueske], I've marked FLINK-9118 as resolved (and duplicated

[jira] [Resolved] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao resolved FLINK-9118. Resolution: Duplicate > Support a time based rollover of part file in Bucketing Sink >

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427186#comment-16427186 ] Lakshmi Rao commented on FLINK-9138: I had a similar request here: 

[jira] [Updated] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9118: --- Priority: Major (was: Minor) > Support a time based rollover of part file in Bucketing Sink >

[jira] [Commented] (FLINK-9115) Support addition of part suffix in BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-9115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423131#comment-16423131 ] Lakshmi Rao commented on FLINK-9115: I see a similar ask on this thread here earlier this year: 

[jira] [Created] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink

Lakshmi Rao created FLINK-9118: -- Summary: Support a time based rollover of part file in Bucketing Sink Key: FLINK-9118 URL: https://issues.apache.org/jira/browse/FLINK-9118 Project: Flink

[jira] [Created] (FLINK-9115) Support addition of part suffix in BucketingSink

Lakshmi Rao created FLINK-9115: -- Summary: Support addition of part suffix in BucketingSink Key: FLINK-9115 URL: https://issues.apache.org/jira/browse/FLINK-9115 Project: Flink Issue Type: