[jira] [Created] (FLINK-29814) Upgrade Stateful Functions to use Flink 1.15

Fil Karnicki created FLINK-29814: Summary: Upgrade Stateful Functions to use Flink 1.15 Key: FLINK-29814 URL: https://issues.apache.org/jira/browse/FLINK-29814 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-27147) Change DataStream's RequestReplyFunctionBuilder to use the netty client

[ https://issues.apache.org/jira/browse/FLINK-27147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520346#comment-17520346 ] Fil Karnicki commented on FLINK-27147: -- hi [~trohrmann] , I recently included mTLS

[jira] [Commented] (FLINK-26617) Pass Kafka headers to remote functions and egresses

[ https://issues.apache.org/jira/browse/FLINK-26617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519583#comment-17519583 ] Fil Karnicki commented on FLINK-26617: -- Hi [~trohrmann], I think that my requiremen

[jira] [Updated] (FLINK-27147) Change DataStream's RequestReplyFunctionBuilder to use the netty client

[ https://issues.apache.org/jira/browse/FLINK-27147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fil Karnicki updated FLINK-27147: - Summary: Change DataStream's RequestReplyFunctionBuilder to use the netty client (was: Move Da

[jira] [Created] (FLINK-27147) Move DataStream's RequestReplyFunctionBuilder to use the netty client

Fil Karnicki created FLINK-27147: Summary: Move DataStream's RequestReplyFunctionBuilder to use the netty client Key: FLINK-27147 URL: https://issues.apache.org/jira/browse/FLINK-27147 Project: Flink

[jira] [Comment Edited] (FLINK-26617) Pass Kafka headers to remote functions and egresses

[ https://issues.apache.org/jira/browse/FLINK-26617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513549#comment-17513549 ] Fil Karnicki edited comment on FLINK-26617 at 3/28/22, 6:19 PM: --

[jira] [Comment Edited] (FLINK-26617) Pass Kafka headers to remote functions and egresses

[ https://issues.apache.org/jira/browse/FLINK-26617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513549#comment-17513549 ] Fil Karnicki edited comment on FLINK-26617 at 3/28/22, 6:19 PM: --

[jira] [Commented] (FLINK-26617) Pass Kafka headers to remote functions and egresses

[ https://issues.apache.org/jira/browse/FLINK-26617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513549#comment-17513549 ] Fil Karnicki commented on FLINK-26617: -- Hi [~trohrmann]. In my current project, ins

[jira] [Closed] (FLINK-26628) Use REST program arguments in StatefulFunctionsJob

[ https://issues.apache.org/jira/browse/FLINK-26628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fil Karnicki closed FLINK-26628. Resolution: Won't Do This is by design. > Use REST program arguments in StatefulFunctionsJob > --

[jira] [Commented] (FLINK-26628) Use REST program arguments in StatefulFunctionsJob

[ https://issues.apache.org/jira/browse/FLINK-26628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513471#comment-17513471 ] Fil Karnicki commented on FLINK-26628: -- Thank you for your input [~trohrmann] and [

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki edited comment on FLINK-26570 at 3/21/22, 9:16 PM: --

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki edited comment on FLINK-26570 at 3/21/22, 9:15 PM: --

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki edited comment on FLINK-26570 at 3/21/22, 9:14 PM: --

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki edited comment on FLINK-26570 at 3/19/22, 11:49 AM: -

[jira] [Commented] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17508137#comment-17508137 ] Fil Karnicki commented on FLINK-26570: -- Hi [~igalshilman] , what do you think about

[jira] [Created] (FLINK-26628) Use REST program arguments in StatefulFunctionsJob

Fil Karnicki created FLINK-26628: Summary: Use REST program arguments in StatefulFunctionsJob Key: FLINK-26628 URL: https://issues.apache.org/jira/browse/FLINK-26628 Project: Flink Issue Type

[jira] [Commented] (FLINK-26617) Pass Kafka headers to remote functions and egresses

[ https://issues.apache.org/jira/browse/FLINK-26617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505359#comment-17505359 ] Fil Karnicki commented on FLINK-26617: -- I started thinking about the steps I'd have

[jira] [Created] (FLINK-26617) Pass Kafka headers to remote functions and egresses

Fil Karnicki created FLINK-26617: Summary: Pass Kafka headers to remote functions and egresses Key: FLINK-26617 URL: https://issues.apache.org/jira/browse/FLINK-26617 Project: Flink Issue Typ

[jira] [Commented] (FLINK-22390) Support for OpenTracing

[ https://issues.apache.org/jira/browse/FLINK-22390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505354#comment-17505354 ] Fil Karnicki commented on FLINK-22390: -- I guess this should be renamed to Support f

[jira] [Commented] (FLINK-26424) RequestTimeoutException

[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505351#comment-17505351 ] Fil Karnicki commented on FLINK-26424: -- In our specific case we rely on zero messag

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki edited comment on FLINK-26570 at 3/12/22, 7:55 PM: --

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki edited comment on FLINK-26570 at 3/12/22, 7:53 PM: --

[jira] [Commented] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505350#comment-17505350 ] Fil Karnicki commented on FLINK-26570: -- hi [~trohrmann] could you please assign thi

[jira] [Comment Edited] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504767#comment-17504767 ] Fil Karnicki edited comment on FLINK-26570 at 3/11/22, 7:48 AM: --

[jira] [Commented] (FLINK-26570) Remote module configuration interpolation

[ https://issues.apache.org/jira/browse/FLINK-26570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504767#comment-17504767 ] Fil Karnicki commented on FLINK-26570: -- Hi [~trohrmann] sounds like a good idea to

[jira] [Created] (FLINK-26570) Remote module configuration interpolation

Fil Karnicki created FLINK-26570: Summary: Remote module configuration interpolation Key: FLINK-26570 URL: https://issues.apache.org/jira/browse/FLINK-26570 Project: Flink Issue Type: Improve

[jira] [Comment Edited] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki edited comment on FLINK-26537 at 3/9/22, 5:56 PM: ---

[jira] [Comment Edited] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki edited comment on FLINK-26537 at 3/9/22, 5:32 PM: ---

[jira] [Comment Edited] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki edited comment on FLINK-26537 at 3/9/22, 5:30 PM: ---

[jira] [Commented] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki commented on FLINK-26537: -- hi [~igal], I think that depending on which

[jira] [Created] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

Fil Karnicki created FLINK-26537: Summary: Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional Key: FLINK-26537 URL: https://issues.apache.org/jira/browse/F

[jira] [Comment Edited] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498493#comment-17498493 ] Fil Karnicki edited comment on FLINK-25866 at 2/28/22, 9:42 AM: --

[jira] [Comment Edited] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498493#comment-17498493 ] Fil Karnicki edited comment on FLINK-25866 at 2/27/22, 7:11 PM: --

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498493#comment-17498493 ] Fil Karnicki commented on FLINK-25866: -- Hi [~igal] I'm almost ready to make a pull

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495524#comment-17495524 ] Fil Karnicki commented on FLINK-25866: -- Hi [~igal] could you assign this Jira to me

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484998#comment-17484998 ] Fil Karnicki commented on FLINK-25866: -- Ok, great, it all checks out and fits our n

[jira] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866 ] Fil Karnicki deleted comment on FLINK-25866: -- was (Author: JIRAUSER284249): Hi, I tried to hack something together at home which would show me being able to get my hands on a resource in a

[jira] [Comment Edited] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484969#comment-17484969 ] Fil Karnicki edited comment on FLINK-25866 at 1/31/22, 10:25 PM: -

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484969#comment-17484969 ] Fil Karnicki commented on FLINK-25866: -- Hi, I tried to hack something together at h

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484624#comment-17484624 ] Fil Karnicki commented on FLINK-25866: -- Hi [~igal]. Will task executors will have a

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484555#comment-17484555 ] Fil Karnicki commented on FLINK-25866: -- Ok that makes sense to me Till. Here's ano

[jira] [Comment Edited] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483756#comment-17483756 ] Fil Karnicki edited comment on FLINK-25866 at 1/28/22, 12:55 PM: -

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483756#comment-17483756 ] Fil Karnicki commented on FLINK-25866: -- How about we make the settings as close to