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

2024-04-16 Thread Danny Cranmer (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Danny Cranmer updated FLINK-33991:
--
Affects Version/s: (was: aws-connector-4.2.0)

> Custom Error Handling for Kinesis Polling Consumer 
> ---
>
> Key: FLINK-33991
> URL: https://issues.apache.org/jira/browse/FLINK-33991
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / Kinesis
>Reporter: Emre Kartoglu
>Assignee: Emre Kartoglu
>Priority: Major
> Fix For: aws-connector-4.4.0
>
>
> We introduced custom error handling for the Kinesis EFO Consumer as part of 
> https://issues.apache.org/jira/browse/FLINK-33260
> PR for the EFO consumer: 
> [https://github.com/apache/flink-connector-aws/pull/110]
>  
> This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
> same codebase.
> Current configuration for the EFO consumer looks like:
> {code:java}
> flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
> flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
>  {code}
> We should re-use the same code for the polling consumer.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

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

2024-04-16 Thread Danny Cranmer (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Danny Cranmer updated FLINK-33991:
--
Fix Version/s: aws-connector-4.4.0
   (was: aws-connector-4.3.0)

> Custom Error Handling for Kinesis Polling Consumer 
> ---
>
> Key: FLINK-33991
> URL: https://issues.apache.org/jira/browse/FLINK-33991
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / Kinesis
>Affects Versions: aws-connector-4.2.0
>Reporter: Emre Kartoglu
>Assignee: Emre Kartoglu
>Priority: Major
> Fix For: aws-connector-4.4.0
>
>
> We introduced custom error handling for the Kinesis EFO Consumer as part of 
> https://issues.apache.org/jira/browse/FLINK-33260
> PR for the EFO consumer: 
> [https://github.com/apache/flink-connector-aws/pull/110]
>  
> This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
> same codebase.
> Current configuration for the EFO consumer looks like:
> {code:java}
> flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
> flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
>  {code}
> We should re-use the same code for the polling consumer.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

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

2024-01-04 Thread Emre Kartoglu (Jira) 


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

PR for the EFO consumer: 
[https://github.com/apache/flink-connector-aws/pull/110]

 

This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
same codebase.

Current configuration for the EFO consumer looks like:
{code:java}
flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
 {code}
We should re-use the same code for the polling consumer.

  was:
We introduced custom error handling for the Kinesis EFO Consumer as part of 
https://issues.apache.org/jira/browse/FLINK-33260

PR for the EFO consumer: 
[https://github.com/apache/flink-connector-aws/pull/110]

 

This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
same codebase.

Current configuration for the EFO consumer looks like:
{code:java}
flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
 {code}
We should re-use the same code for the polling consumer.}}{}}}


> Custom Error Handling for Kinesis Polling Consumer 
> ---
>
> Key: FLINK-33991
> URL: https://issues.apache.org/jira/browse/FLINK-33991
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / Kinesis
>Affects Versions: aws-connector-4.2.0
>Reporter: Emre Kartoglu
>Priority: Major
>
> We introduced custom error handling for the Kinesis EFO Consumer as part of 
> https://issues.apache.org/jira/browse/FLINK-33260
> PR for the EFO consumer: 
> [https://github.com/apache/flink-connector-aws/pull/110]
>  
> This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
> same codebase.
> Current configuration for the EFO consumer looks like:
> {code:java}
> flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
> flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
>  {code}
> We should re-use the same code for the polling consumer.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

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

2024-01-04 Thread Emre Kartoglu (Jira) 


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

PR for the EFO consumer: 
[https://github.com/apache/flink-connector-aws/pull/110]

 

This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
same codebase.

Current configuration for the EFO consumer looks like:
{code:java}
flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
 {code}
We should re-use the same code for the polling consumer.}}{}}}

  was:
We introduced custom error handling for the Kinesis EFO Consumer as part of 
https://issues.apache.org/jira/browse/FLINK-33260

PR for the EFO consumer: https://github.com/apache/flink-connector-aws/pull/110

 

This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
same codebase.

Current configuration for the EFO consumer looks like:

{{}}
{code:java}
flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
 {code}
{{}}

We should re-use the same code for the polling consumer.{{{}{}}}


> Custom Error Handling for Kinesis Polling Consumer 
> ---
>
> Key: FLINK-33991
> URL: https://issues.apache.org/jira/browse/FLINK-33991
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / Kinesis
>Affects Versions: aws-connector-4.2.0
>Reporter: Emre Kartoglu
>Priority: Major
>
> We introduced custom error handling for the Kinesis EFO Consumer as part of 
> https://issues.apache.org/jira/browse/FLINK-33260
> PR for the EFO consumer: 
> [https://github.com/apache/flink-connector-aws/pull/110]
>  
> This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
> same codebase.
> Current configuration for the EFO consumer looks like:
> {code:java}
> flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
> flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
>  {code}
> We should re-use the same code for the polling consumer.}}{}}}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

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

2024-01-04 Thread Emre Kartoglu (Jira) 


 [ 
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 
> ---
>
> Key: FLINK-33991
> URL: https://issues.apache.org/jira/browse/FLINK-33991
> Project: Flink
>  Issue Type: Improvement
>  Components: Connectors / Kinesis
>Affects Versions: aws-connector-4.2.0
>Reporter: Emre Kartoglu
>Priority: Major
> Fix For: aws-connector-4.3.0
>
>
> We introduced custom error handling for the Kinesis EFO Consumer as part of 
> https://issues.apache.org/jira/browse/FLINK-33260
> PR for the EFO consumer: 
> [https://github.com/apache/flink-connector-aws/pull/110]
>  
> This ticket is to apply the same logic to the Kinesis Polling Consumer in the 
> same codebase.
> Current configuration for the EFO consumer looks like:
> {code:java}
> flink.shard.consumer.error.recoverable[0].exception=java.net.UnknownHostException
> flink.shard.consumer.error.recoverable[1].exception=java.net.SocketTimeoutException
>  {code}
> We should re-use the same code for the polling consumer.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)