[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=17125225#comment-17125225 ] Luka Jurukovski commented on FLINK-10195: - [~austince] Your example did inform me to a feature

[jira] [Commented] (FLINK-12107) Use Proxy For DataDog Validation

[ https://issues.apache.org/jira/browse/FLINK-12107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809857#comment-16809857 ] Luka Jurukovski commented on FLINK-12107: - > Since this feature is only available in

[jira] [Closed] (FLINK-12107) Use Proxy For DataDog Validation

[ https://issues.apache.org/jira/browse/FLINK-12107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luka Jurukovski closed FLINK-12107. --- Resolution: Fixed > Use Proxy For DataDog Validation > > >

[jira] [Assigned] (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:all-tabpanel ] Luka Jurukovski reassigned FLINK-10195: --- Assignee: Luka Jurukovski > RabbitMQ Source With Checkpointing Doesn't

[jira] [Created] (FLINK-12107) Use Proxy For DataDog Validation

Luka Jurukovski created FLINK-12107: --- Summary: Use Proxy For DataDog Validation Key: FLINK-12107 URL: https://issues.apache.org/jira/browse/FLINK-12107 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

[ https://issues.apache.org/jira/browse/FLINK-11895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791666#comment-16791666 ] Luka Jurukovski commented on FLINK-11895: - [~yanghua] I think that ticket might be related but

[jira] [Created] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

Luka Jurukovski created FLINK-11895: --- Summary: Allow FileSystem Configs to be altered at Runtime Key: FLINK-11895 URL: https://issues.apache.org/jira/browse/FLINK-11895 Project: Flink

[jira] [Commented] (FLINK-10903) Shade Internal Akka Dependencies

[ https://issues.apache.org/jira/browse/FLINK-10903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693574#comment-16693574 ] Luka Jurukovski commented on FLINK-10903: - Thanks for the in depth response! *Akka* *Shading* I

[jira] [Commented] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693591#comment-16693591 ] Luka Jurukovski commented on FLINK-10904: - I have a shaded jar with a `main` entry point, it

[jira] [Commented] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691287#comment-16691287 ] Luka Jurukovski commented on FLINK-10904: - Had to go through some old messages to find out

[jira] [Commented] (FLINK-10903) Shade Internal Akka Dependencies

[ https://issues.apache.org/jira/browse/FLINK-10903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690362#comment-16690362 ] Luka Jurukovski commented on FLINK-10903: - Simply the akka dependency. Alternatively (unless

[jira] [Created] (FLINK-10904) Expose Classloader before Pipeline execution

Luka Jurukovski created FLINK-10904: --- Summary: Expose Classloader before Pipeline execution Key: FLINK-10904 URL: https://issues.apache.org/jira/browse/FLINK-10904 Project: Flink Issue

[jira] [Created] (FLINK-10903) Shade Internal Akka Dependencies

Luka Jurukovski created FLINK-10903: --- Summary: Shade Internal Akka Dependencies Key: FLINK-10903 URL: https://issues.apache.org/jira/browse/FLINK-10903 Project: Flink Issue Type: Wish

[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=16593585#comment-16593585 ] Luka Jurukovski commented on FLINK-10195: - Just tested using the "basicGet" and a buffer. It

[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=16592649#comment-16592649 ] Luka Jurukovski commented on FLINK-10195: - The option that you describe is the what my ugly code

[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=16592182#comment-16592182 ] Luka Jurukovski commented on FLINK-10195: - [~StephanEwen] For what I can tell no. Although this

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

Luka Jurukovski created FLINK-10195: --- Summary: RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly Key: FLINK-10195 URL: https://issues.apache.org/jira/browse/FLINK-10195 Project: