[jira] [Commented] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834316#comment-17834316 ] Emre Kartoglu commented on FLINK-34025: --- https://github.com/apache/flink/pull/2459

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817947#comment-17817947 ] Emre Kartoglu commented on FLINK-16686: --- I saw this happen in a Flink 1.15 app tod

[jira] [Updated] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-34025: -- Affects Version/s: 1.20.0 (was: 1.19.0) > Show data skew score on F

[jira] [Reopened] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu reopened FLINK-34025: --- reopening based on the votes I've received for [https://cwiki.apache.org/confluence/display/FLI

[jira] [Comment Edited] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805072#comment-17805072 ] Emre Kartoglu edited comment on FLINK-34025 at 1/15/24 5:02 PM: --

[jira] [Closed] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu closed FLINK-34025. - Resolution: Feedback Received Closing, needs a FLIP first > Show data skew score on Flink Dashb

[jira] [Commented] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804721#comment-17804721 ] Emre Kartoglu commented on FLINK-34025: --- On it, thanks Lijie. > Show data skew sc

[jira] [Commented] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804364#comment-17804364 ] Emre Kartoglu commented on FLINK-34025: --- A potential metric definition for data sk

[jira] [Updated] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-34025: -- Description: *Problem:* Currently users have to click on every operator and check how much da

[jira] [Updated] (FLINK-34025) Show data skew score on Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-34025: -- Description: *Problem:* Currently users have to click on every operator and check how much da

[jira] [Created] (FLINK-34025) Show data skew score on Flink Dashboard

Emre Kartoglu created FLINK-34025: - Summary: Show data skew score on Flink Dashboard Key: FLINK-34025 URL: https://issues.apache.org/jira/browse/FLINK-34025 Project: Flink Issue Type: New Fea

[jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer

[ https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-33991: -- Description: We introduced custom error handling for the Kinesis EFO Consumer as part of http

[jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer

[ https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-33991: -- Description: We introduced custom error handling for the Kinesis EFO Consumer as part of http

[jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer

[ https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-33991: -- Fix Version/s: aws-connector-4.3.0 > Custom Error Handling for Kinesis Polling Consumer > ---

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803167#comment-17803167 ] Emre Kartoglu commented on FLINK-33260: --- We can resolve this in favour of https:/

[jira] [Created] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer

Emre Kartoglu created FLINK-33991: - Summary: Custom Error Handling for Kinesis Polling Consumer Key: FLINK-33991 URL: https://issues.apache.org/jira/browse/FLINK-33991 Project: Flink Issue T

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788688#comment-17788688 ] Emre Kartoglu commented on FLINK-33260: --- Yes we've merged the EFO support. I will

[jira] [Comment Edited] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776198#comment-17776198 ] Emre Kartoglu edited comment on FLINK-33260 at 10/17/23 5:49 PM: -

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776198#comment-17776198 ] Emre Kartoglu commented on FLINK-33260: --- There appears to be an existing mechanism

[jira] [Comment Edited] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776078#comment-17776078 ] Emre Kartoglu edited comment on FLINK-33260 at 10/17/23 9:00 AM: -

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776078#comment-17776078 ] Emre Kartoglu commented on FLINK-33260: --- The current connector offers configuratio

[jira] [Commented] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

[ https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775608#comment-17775608 ] Emre Kartoglu commented on FLINK-33178: --- Hi [~pnowojski] thanks a lot for pointing

[jira] [Closed] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

[ https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu closed FLINK-33178. - Resolution: Duplicate > Highly parallel apps suffer from bottleneck in NativePRNG > ---

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774859#comment-17774859 ] Emre Kartoglu commented on FLINK-33260: --- Looking at the existing Flink connectors,

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774824#comment-17774824 ] Emre Kartoglu commented on FLINK-33260: --- Hi, can you please assign this to me? >

[jira] [Comment Edited] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

[ https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771788#comment-17771788 ] Emre Kartoglu edited comment on FLINK-33178 at 10/5/23 9:06 AM: --

[jira] [Commented] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

[ https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772120#comment-17772120 ] Emre Kartoglu commented on FLINK-33178: --- Adding 1.17.1 to affected versions based

[jira] [Updated] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

[ https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-33178: -- Affects Version/s: 1.17.1 > Highly parallel apps suffer from bottleneck in NativePRNG > -

[jira] [Commented] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

[ https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771788#comment-17771788 ] Emre Kartoglu commented on FLINK-33178: --- [~martijnvisser] Thanks for the comment.

[jira] [Created] (FLINK-33178) Highly parallel apps suffer from bottleneck in NativePRNG

Emre Kartoglu created FLINK-33178: - Summary: Highly parallel apps suffer from bottleneck in NativePRNG Key: FLINK-33178 URL: https://issues.apache.org/jira/browse/FLINK-33178 Project: Flink

[jira] [Commented] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702614#comment-17702614 ] Emre Kartoglu commented on FLINK-22828: --- Can you please assign this to me [~dannyc

[jira] [Created] (FLINK-23167) Port Kinesis Table API e2e tests to release-1.12 branch

Emre Kartoglu created FLINK-23167: - Summary: Port Kinesis Table API e2e tests to release-1.12 branch Key: FLINK-23167 URL: https://issues.apache.org/jira/browse/FLINK-23167 Project: Flink Iss

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369493#comment-17369493 ] Emre Kartoglu commented on FLINK-23009: --- [~xintongsong] I'm having a look. Reverti

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365391#comment-17365391 ] Emre Kartoglu commented on FLINK-23009: --- release 1.12: https://github.com/apache/f

[jira] [Updated] (FLINK-23009) Bump up Guava in Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-23009: -- Description: *Background* We maintain a copy of the Flink connector in our AWS GitHub group:

[jira] [Updated] (FLINK-23009) Bump up Guava in Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emre Kartoglu updated FLINK-23009: -- Component/s: Connectors / Kinesis > Bump up Guava in Kinesis Connector > -

[jira] [Created] (FLINK-23009) Bump up Guava in Kinesis Connector

Emre Kartoglu created FLINK-23009: - Summary: Bump up Guava in Kinesis Connector Key: FLINK-23009 URL: https://issues.apache.org/jira/browse/FLINK-23009 Project: Flink Issue Type: Improvement