[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&focusedCommentId=17031002#comment-17031002 ] Lakshmi Rao commented on FLINK-15918: - Just adding to what [~thw]  and [~shriya_a] m

[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&focusedCommentId=16793815#comment-16793815 ] Lakshmi Rao commented on FLINK-11254: - Thanks for this effort [~tzulitai] and [~klio

[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&focusedCommentId=16762965#comment-16762965 ] Lakshmi Rao commented on FLINK-11501: - Adding some screenshots of results from testi

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

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

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

[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&focusedCommentId=16554917#comment-16554917 ] Lakshmi Rao commented on FLINK-9899: Thanks [~yanghua] !  > Add more metrics to the

[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&focusedCommentId=16554822#comment-16554822 ] Lakshmi Rao edited comment on FLINK-9899 at 7/24/18 9:35 PM: -

[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&focusedCommentId=16554822#comment-16554822 ] Lakshmi Rao commented on FLINK-9899: [~yanghua] I created a PR with my changes - Let

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

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

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

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

[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&focusedCommentId=16554732#comment-16554732 ] Lakshmi Rao commented on FLINK-9899: [~yanghua] Are you planning on working on this? 

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

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

[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: https://issues.apache.org/jira/browse/FLINK-989

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

[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 value|https://github.com/apache/flink/b

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

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

[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&focusedCommentId=16450027#comment-16450027 ] Lakshmi Rao commented on FLINK-9115: Hi [~Poluliakh], thanks for offering to work on t

[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&focusedCommentId=16427291#comment-16427291 ] Lakshmi Rao commented on FLINK-9138: Agreed that event time is not applicable here. Ye

[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&focusedCommentId=16427254#comment-16427254 ] Lakshmi Rao commented on FLINK-9138: [~narayaruna]  [~fhueske] do you have thoughts on

[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&focusedCommentId=16427220#comment-16427220 ] Lakshmi Rao commented on FLINK-9138: Hi [~fhueske], I've marked FLINK-9118 as resolved

[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&focusedCommentId=16427186#comment-16427186 ] Lakshmi Rao commented on FLINK-9138: I had a similar request here: https://issues.apac

[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&focusedCommentId=16423131#comment-16423131 ] Lakshmi Rao commented on FLINK-9115: I see a similar ask on this thread here earlier t

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

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