[jira] [Updated] (FLINK-32626) Distinguish non-existent job from non-existent savepoint in Get Savepoint REST API

[ https://issues.apache.org/jira/browse/FLINK-32626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-32626: -- Description: The current `GET /jobs/:jobid/savepoints/:triggerid` API endpoint

[jira] [Updated] (FLINK-32626) Distinguish non-existent job from non-existent savepoint in Get Savepoint REST API

[ https://issues.apache.org/jira/browse/FLINK-32626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-32626: -- Summary: Distinguish non-existent job from non-existent savepoint in Get Savep

[jira] [Updated] (FLINK-32626) Distinguish non-existent job from non-existent savepoint in Get Savepoint REST API

[ https://issues.apache.org/jira/browse/FLINK-32626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-32626: -- Description: The current `GET /jobs/:jobid/savepoints/:triggerid` API endpoint

[jira] [Created] (FLINK-32626) Get Savepoint REST API doesn't distinguish non-existent job from non-existent savepoint

Austin Cawley-Edwards created FLINK-32626: - Summary: Get Savepoint REST API doesn't distinguish non-existent job from non-existent savepoint Key: FLINK-32626 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Updated] (FLINK-10212) REST API for listing all the available save points

[ https://issues.apache.org/jira/browse/FLINK-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-10212: -- Description: *Background* I'm one of the authors of the open-source Flink job

[jira] [Updated] (FLINK-30445) Add Flink Web3 Connector

[ https://issues.apache.org/jira/browse/FLINK-30445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-30445: -- Description: Web3 is very hot. But you could search GitHub open source blockch

[jira] [Commented] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646786#comment-17646786 ] Austin Cawley-Edwards commented on FLINK-29863: --- Because we're using Jacks

[jira] [Commented] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646692#comment-17646692 ] Austin Cawley-Edwards commented on FLINK-29863: --- What might be the issue o

[jira] [Commented] (FLINK-26335) prometheus/metrics - java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/FLINK-26335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610148#comment-17610148 ] Austin Cawley-Edwards commented on FLINK-26335: ---  Hey [~mlnogueira], thank

[jira] [Created] (FLINK-27356) Incorrect Number of Methods Listed for SplitReader

Austin Cawley-Edwards created FLINK-27356: - Summary: Incorrect Number of Methods Listed for SplitReader Key: FLINK-27356 URL: https://issues.apache.org/jira/browse/FLINK-27356 Project: Flink

[jira] [Commented] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418252#comment-17418252 ] Austin Cawley-Edwards commented on FLINK-24208: --- Great, we're on the same

[jira] [Comment Edited] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417718#comment-17417718 ] Austin Cawley-Edwards edited comment on FLINK-24208 at 9/20/21, 5:48 PM: -

[jira] [Commented] (FLINK-24275) Allow idempotent job cancellation

[ https://issues.apache.org/jira/browse/FLINK-24275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417720#comment-17417720 ] Austin Cawley-Edwards commented on FLINK-24275: --- I see two options: * Tre

[jira] [Comment Edited] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417718#comment-17417718 ] Austin Cawley-Edwards edited comment on FLINK-24208 at 9/20/21, 4:24 PM: -

[jira] [Commented] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417718#comment-17417718 ] Austin Cawley-Edwards commented on FLINK-24208: --- [~chesnay], definitely on

[jira] [Created] (FLINK-24275) Allow idempotent job cancellation

Austin Cawley-Edwards created FLINK-24275: - Summary: Allow idempotent job cancellation Key: FLINK-24275 URL: https://issues.apache.org/jira/browse/FLINK-24275 Project: Flink Issue Typ

[jira] [Commented] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414559#comment-17414559 ] Austin Cawley-Edwards commented on FLINK-24208: --- The sketch looks great [~

[jira] [Updated] (FLINK-24208) Allow idempotent savepoint triggering

[ https://issues.apache.org/jira/browse/FLINK-24208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-24208: -- Component/s: Runtime / REST > Allow idempotent savepoint triggering >

[jira] [Commented] (FLINK-20244) RMQSource does not ACK duplicated messages

[ https://issues.apache.org/jira/browse/FLINK-20244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367701#comment-17367701 ] Austin Cawley-Edwards commented on FLINK-20244: --- Thanks for the ping [~cmi

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351899#comment-17351899 ] Austin Cawley-Edwards edited comment on FLINK-22698 at 5/26/21, 4:23 PM: -

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351899#comment-17351899 ] Austin Cawley-Edwards commented on FLINK-22698: --- [~nicholasjiang] – yes, I

[jira] [Assigned] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-22698: - Assignee: Michał Ciesielczyk > RabbitMQ source does not stop unless mes

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349300#comment-17349300 ] Austin Cawley-Edwards commented on FLINK-22698: --- Hi [~cmick] – that cause

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347771#comment-17347771 ] Austin Cawley-Edwards edited comment on FLINK-22698 at 5/19/21, 4:48 PM: -

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347771#comment-17347771 ] Austin Cawley-Edwards commented on FLINK-22698: --- Hey [~nicholasjiang] – I

[jira] [Created] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

Austin Cawley-Edwards created FLINK-22698: - Summary: RabbitMQ source does not stop unless message arrives in queue Key: FLINK-22698 URL: https://issues.apache.org/jira/browse/FLINK-22698 Proje

[jira] [Commented] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix.

[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332718#comment-17332718 ] Austin Cawley-Edwards commented on FLINK-22441: --- Adding the "drop Scala 2.

[jira] [Commented] (FLINK-19711) Parsing of invalid CSV fails even with ignoreParseErrors is enabled

[ https://issues.apache.org/jira/browse/FLINK-19711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324629#comment-17324629 ] Austin Cawley-Edwards commented on FLINK-19711: --- I had difficulty reproduc

[jira] [Assigned] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-21538: - Assignee: (was: Austin Cawley-Edwards) > Elasticsearch6DynamicSinkI

[jira] [Closed] (FLINK-22165) How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv

[ https://issues.apache.org/jira/browse/FLINK-22165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards closed FLINK-22165. - Resolution: Invalid > How to set rabbitmq correlationId when using rabbitmq sink

[jira] [Commented] (FLINK-22165) How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv

[ https://issues.apache.org/jira/browse/FLINK-22165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317576#comment-17317576 ] Austin Cawley-Edwards commented on FLINK-22165: --- Hi there! Please send thi

[jira] [Updated] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

[ https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17859: -- Fix Version/s: 1.8.0 > [flink-s3-fs-presto] Upgrade the dependent presto-hive

[jira] [Updated] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

[ https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17859: -- Affects Version/s: 1.7.2 > [flink-s3-fs-presto] Upgrade the dependent presto-h

[jira] [Commented] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

[ https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315886#comment-17315886 ] Austin Cawley-Edwards commented on FLINK-17859: --- This has been updated as

[jira] [Commented] (FLINK-22084) RescalingITCase fails with adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315716#comment-17315716 ] Austin Cawley-Edwards commented on FLINK-22084: --- That is unfortunate, and

[jira] [Commented] (FLINK-22084) RescalingITCase fails with adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315603#comment-17315603 ] Austin Cawley-Edwards commented on FLINK-22084: --- [~trohrmann] very likely

[jira] [Assigned] (FLINK-22084) RescalingITCase fails with adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-22084: - Assignee: Austin Cawley-Edwards > RescalingITCase fails with adaptive s

[jira] [Commented] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305213#comment-17305213 ] Austin Cawley-Edwards commented on FLINK-21844: --- Does this mean a user mus

[jira] [Updated] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-21844: -- Description: I believe we should not automatically change the maxParallelism w

[jira] [Assigned] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-21844: - Assignee: Austin Cawley-Edwards > Do not auto-configure maxParallelism

[jira] [Comment Edited] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300636#comment-17300636 ] Austin Cawley-Edwards edited comment on FLINK-21538 at 3/15/21, 4:13 PM: -

[jira] [Assigned] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-21538: - Assignee: Austin Cawley-Edwards > Elasticsearch6DynamicSinkITCase.testW

[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300636#comment-17300636 ] Austin Cawley-Edwards commented on FLINK-21538: --- Test debug build here: h

[jira] [Commented] (FLINK-18755) RabbitMQ QoS Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-18755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167847#comment-17167847 ] Austin Cawley-Edwards commented on FLINK-18755: --- Thank you so much! I don'

[jira] [Updated] (FLINK-18755) RabbitMQ QoS Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-18755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-18755: -- Description: Please add documentation for the new QoS settings in the RabbitMQ

[jira] [Updated] (FLINK-18755) RabbitMQ QoS Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-18755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-18755: -- Issue Type: Improvement (was: Bug) > RabbitMQ QoS Chinese Documentation > ---

[jira] [Created] (FLINK-18755) RabbitMQ QoS Chinese Documentation

Austin Cawley-Edwards created FLINK-18755: - Summary: RabbitMQ QoS Chinese Documentation Key: FLINK-18755 URL: https://issues.apache.org/jira/browse/FLINK-18755 Project: Flink Issue Ty

[jira] [Issue Comment Deleted] (FLINK-17559) Backpressure seems to be broken when not going through network

[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17559: -- Comment: was deleted (was: I think we can close this as well [~dwysakowicz], i

[jira] [Commented] (FLINK-17559) Backpressure seems to be broken when not going through network

[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167462#comment-17167462 ] Austin Cawley-Edwards commented on FLINK-17559: --- I think we can close this

[jira] [Comment Edited] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162230#comment-17162230 ] Austin Cawley-Edwards edited comment on FLINK-17529 at 7/21/20, 6:01 PM: -

[jira] [Updated] (FLINK-17529) Upgrade com.rabbitmq:amqp-client to latest 5.x

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17529: -- Summary: Upgrade com.rabbitmq:amqp-client to latest 5.x (was: Upgrade com.rab

[jira] [Updated] (FLINK-17529) Upgrade com.rabbitmq:amqp-client to 5.x

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17529: -- Summary: Upgrade com.rabbitmq:amqp-client to 5.x (was: Replace Deprecated RMQ

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162230#comment-17162230 ] Austin Cawley-Edwards commented on FLINK-17529: --- Perhaps we should make th

[jira] [Updated] (FLINK-17529) Upgrade com.rabbitmq:amqp-client to 5.x

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17529: -- Priority: Major (was: Minor) > Upgrade com.rabbitmq:amqp-client to 5.x >

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17134241#comment-17134241 ] Austin Cawley-Edwards commented on FLINK-10195: --- [~aljoscha] that would be

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125362#comment-17125362 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/4/20, 2:50 PM: --

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125362#comment-17125362 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/3/20, 11:15 PM: -

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121227#comment-17121227 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/3/20, 10:29 PM: -

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125362#comment-17125362 ] Austin Cawley-Edwards commented on FLINK-10195: --- Yes, that is correct, tho

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125362#comment-17125362 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/3/20, 10:27 PM: -

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121227#comment-17121227 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/3/20, 5:07 PM: --

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121227#comment-17121227 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/1/20, 6:50 PM: --

[jira] [Comment Edited] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121227#comment-17121227 ] Austin Cawley-Edwards edited comment on FLINK-10195 at 6/1/20, 6:49 PM: --

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121227#comment-17121227 ] Austin Cawley-Edwards commented on FLINK-10195: --- Hey all, just bringing th

[jira] [Comment Edited] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108575#comment-17108575 ] Austin Cawley-Edwards edited comment on FLINK-7267 at 5/15/20, 7:05 PM: ---

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108575#comment-17108575 ] Austin Cawley-Edwards commented on FLINK-7267: -- I put in a PR for option A,

[jira] [Comment Edited] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards edited comment on FLINK-7267 at 5/12/20, 1:25 PM: ---

[jira] [Comment Edited] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards edited comment on FLINK-7267 at 5/11/20, 11:46 PM: --

[jira] [Issue Comment Deleted] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-7267: - Comment: was deleted (was: It might also be worth adding a common base class for

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104972#comment-17104972 ] Austin Cawley-Edwards commented on FLINK-7267: -- It might also be worth addin

[jira] [Comment Edited] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104955#comment-17104955 ] Austin Cawley-Edwards edited comment on FLINK-17529 at 5/11/20, 11:01 PM:

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104955#comment-17104955 ] Austin Cawley-Edwards commented on FLINK-17529: --- After more investigation,

[jira] [Comment Edited] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards edited comment on FLINK-7267 at 5/11/20, 10:33 PM: --

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104943#comment-17104943 ] Austin Cawley-Edwards commented on FLINK-7267: -- This seems like a reasonable

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104529#comment-17104529 ] Austin Cawley-Edwards commented on FLINK-17529: --- That would be great, than

[jira] [Comment Edited] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100286#comment-17100286 ] Austin Cawley-Edwards edited comment on FLINK-17529 at 5/6/20, 10:23 PM: -

[jira] [Commented] (FLINK-17204) The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable ​​when declaring the queue.

[ https://issues.apache.org/jira/browse/FLINK-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101232#comment-17101232 ] Austin Cawley-Edwards commented on FLINK-17204: --- Thank you!! > The RMQSou

[jira] [Updated] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17529: -- Description: The RMQ QueueingConsumer is used in the RMQSource to get a simple

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100286#comment-17100286 ] Austin Cawley-Edwards commented on FLINK-17529: --- Coming from https://issue

[jira] [Updated] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17529: -- Priority: Minor (was: Major) > Replace Deprecated RMQ QueueingConsumer >

[jira] [Updated] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17529: -- Issue Type: Improvement (was: Bug) > Replace Deprecated RMQ QueueingConsumer

[jira] [Commented] (FLINK-17204) The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable ​​when declaring the queue.

[ https://issues.apache.org/jira/browse/FLINK-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100184#comment-17100184 ] Austin Cawley-Edwards commented on FLINK-17204: --- Thanks for assigning [~al

[jira] [Created] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

Austin Cawley-Edwards created FLINK-17529: - Summary: Replace Deprecated RMQ QueueingConsumer Key: FLINK-17529 URL: https://issues.apache.org/jira/browse/FLINK-17529 Project: Flink Iss