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

[ https://issues.apache.org/jira/browse/FLINK-29814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-29814: - Assignee: Galen Warren > Upgrade Stateful Functions to use Flink 1.15 >

[jira] [Commented] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

[ https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574752#comment-17574752 ] Till Rohrmann commented on FLINK-28747: --- I think this is Protobuf's behaviour. If Protobuf sees

[jira] [Comment Edited] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

[ https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574267#comment-17574267 ] Till Rohrmann edited comment on FLINK-28747 at 8/2/22 2:57 PM: --- Thanks for

[jira] [Commented] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

[ https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574267#comment-17574267 ] Till Rohrmann commented on FLINK-28747: --- Thanks for reporting this issue [~stepweiwu]. Without

[jira] [Commented] (FLINK-26845) Document testing guidelines

[ https://issues.apache.org/jira/browse/FLINK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514598#comment-17514598 ] Till Rohrmann commented on FLINK-26845: --- Hi [~Alcántara], I think a good start would be to

[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=17514596#comment-17514596 ] Till Rohrmann commented on FLINK-26617: --- If this is a requirement, then I guess we need to send

[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=17513271#comment-17513271 ] Till Rohrmann commented on FLINK-26570: --- Thanks for opening this PR [~Fil Karnicki]. I will take a

[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=17513229#comment-17513229 ] Till Rohrmann commented on FLINK-26628: --- I think [~igal] is right here [~Fil Karnicki]. Flink's

[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=17513227#comment-17513227 ] Till Rohrmann commented on FLINK-26617: --- Thanks for creating this ticket [~Fil Karnicki]. I think

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

[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513212#comment-17513212 ] Till Rohrmann commented on FLINK-26424: --- Yes, such a feature will definitely be an opt-in feature.

[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=17504762#comment-17504762 ] Till Rohrmann commented on FLINK-26570: --- Thanks for creating this ticket [~Fil Karnicki]. I like

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502807#comment-17502807 ] Till Rohrmann commented on FLINK-23190: --- Sorry for not getting back to your PR [~loyi].

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

[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502804#comment-17502804 ] Till Rohrmann commented on FLINK-26424: --- I think we will soon solve this problem. There is no PR

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

[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502111#comment-17502111 ] Till Rohrmann commented on FLINK-26424: --- I think the idea would be that you can define an egress

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

[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500597#comment-17500597 ] Till Rohrmann commented on FLINK-26424: --- I agree that a single failed remote function call should

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

[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499964#comment-17499964 ] Till Rohrmann commented on FLINK-26424: --- Hi [~ychensha], I assume you are using StateFun's

[jira] [Commented] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497256#comment-17497256 ] Till Rohrmann commented on FLINK-26086: --- Thanks for fixing this issue [~nyingping]. > fixed some

[jira] [Assigned] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26086: - Assignee: nyingping > fixed some causing ambiguities including the 'shit' comment >

[jira] [Assigned] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26340: - Assignee: Galen Warren > Add ability in Golang SDK to create new statefun.Context from

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495941#comment-17495941 ] Till Rohrmann commented on FLINK-18356: --- What is the state of this ticket [~chesnay]? > Exit code

[jira] [Assigned] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26274: - Assignee: Konstantin Knauf > Test local recovery works across TaskManager process

[jira] [Assigned] (FLINK-26191) Incorrect license in Elasticsearch connectors

[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26191: - Assignee: Fabian Paul > Incorrect license in Elasticsearch connectors >

[jira] [Commented] (FLINK-25977) Close sink client and sink http client for KDS/KDF Sinks

[ https://issues.apache.org/jira/browse/FLINK-25977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495939#comment-17495939 ] Till Rohrmann commented on FLINK-25977: --- PR is reviewed. Waiting for CI to pass. > Close sink

[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=17495578#comment-17495578 ] Till Rohrmann commented on FLINK-25866: --- Hi [~Fil Karnicki], I've assigned you to this ticket. The

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

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25866: - Assignee: Fil Karnicki > Support additional TLS configuration. >

[jira] [Updated] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26274: -- Fix Version/s: 1.15.0 > Test local recovery works across TaskManager process restarts >

[jira] [Created] (FLINK-26274) Test local recovery works across TaskManager process restarts

Till Rohrmann created FLINK-26274: - Summary: Test local recovery works across TaskManager process restarts Key: FLINK-26274 URL: https://issues.apache.org/jira/browse/FLINK-26274 Project: Flink

[jira] [Updated] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26274: -- Affects Version/s: 1.15.0 > Test local recovery works across TaskManager process restarts >

[jira] [Updated] (FLINK-23870) Test the ability for ignoring in-flight data on recovery

[ https://issues.apache.org/jira/browse/FLINK-23870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23870: -- Component/s: Runtime / Checkpointing > Test the ability for ignoring in-flight data on

[jira] [Created] (FLINK-26271) TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed

Till Rohrmann created FLINK-26271: - Summary: TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed Key: FLINK-26271 URL: https://issues.apache.org/jira/browse/FLINK-26271 Project: Flink

[jira] [Commented] (FLINK-25851) CassandraConnectorITCase.testRetrialAndDropTables shows table already exists errors on AZP

[ https://issues.apache.org/jira/browse/FLINK-25851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495356#comment-17495356 ] Till Rohrmann commented on FLINK-25851: ---

[jira] [Assigned] (FLINK-25346) FLIP-197: API stability graduation process

[ https://issues.apache.org/jira/browse/FLINK-25346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25346: - Assignee: (was: Till Rohrmann) > FLIP-197: API stability graduation process >

[jira] [Closed] (FLINK-26014) Document how to use the working directory for faster local recoveries

[ https://issues.apache.org/jira/browse/FLINK-26014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26014. - Resolution: Fixed Fixed via d893292893837037c15c07e16c9fe2b39ec44319

[jira] [Assigned] (FLINK-23403) Decrease default values for heartbeat timeout and interval

[ https://issues.apache.org/jira/browse/FLINK-23403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-23403: - Assignee: (was: Till Rohrmann) > Decrease default values for heartbeat timeout and

[jira] [Assigned] (FLINK-25345) FLIP-196: Source API stability guarantees

[ https://issues.apache.org/jira/browse/FLINK-25345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25345: - Assignee: (was: Till Rohrmann) > FLIP-196: Source API stability guarantees >

[jira] [Updated] (FLINK-26197) Allow playground egress to keep connection open and push messages

[ https://issues.apache.org/jira/browse/FLINK-26197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26197: -- Labels: playground (was: ) > Allow playground egress to keep connection open and push

[jira] [Created] (FLINK-26197) Allow playground egress to keep connection open and push messages

Till Rohrmann created FLINK-26197: - Summary: Allow playground egress to keep connection open and push messages Key: FLINK-26197 URL: https://issues.apache.org/jira/browse/FLINK-26197 Project: Flink

[jira] [Closed] (FLINK-26153) Add script to update README playground links for Statefun

[ https://issues.apache.org/jira/browse/FLINK-26153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26153. - Fix Version/s: statefun-3.3.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-26158) Update statefun-playground examples to use playground ingress/egress

[ https://issues.apache.org/jira/browse/FLINK-26158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26158. - Fix Version/s: statefun-3.3.0 statefun-3.2.1 Resolution: Fixed Fixed

[jira] [Closed] (FLINK-26155) Add playground ingress/egress for curl interaction

[ https://issues.apache.org/jira/browse/FLINK-26155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26155. - Fix Version/s: statefun-3.3.0 statefun-3.2.1 Resolution: Fixed Fixed

[jira] [Created] (FLINK-26158) Update statefun-playground examples to use playground ingress/egress

Till Rohrmann created FLINK-26158: - Summary: Update statefun-playground examples to use playground ingress/egress Key: FLINK-26158 URL: https://issues.apache.org/jira/browse/FLINK-26158 Project:

[jira] [Updated] (FLINK-26155) Add playground ingress/egress for curl interaction

[ https://issues.apache.org/jira/browse/FLINK-26155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26155: -- Summary: Add playground ingress/egress for curl interaction (was: Add playground

[jira] [Created] (FLINK-26155) Add playground ingress/egress for cURL interaction

Till Rohrmann created FLINK-26155: - Summary: Add playground ingress/egress for cURL interaction Key: FLINK-26155 URL: https://issues.apache.org/jira/browse/FLINK-26155 Project: Flink Issue

[jira] [Created] (FLINK-26153) Add script to update README playground links for Statefun

Till Rohrmann created FLINK-26153: - Summary: Add script to update README playground links for Statefun Key: FLINK-26153 URL: https://issues.apache.org/jira/browse/FLINK-26153 Project: Flink

[jira] [Closed] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js

[ https://issues.apache.org/jira/browse/FLINK-25898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25898. - Fix Version/s: statefun-3.3.0 statefun-3.2.1 Resolution: Fixed Fixed

[jira] [Created] (FLINK-26098) TableAPI does not forward idleness configuration from DataStream

Till Rohrmann created FLINK-26098: - Summary: TableAPI does not forward idleness configuration from DataStream Key: FLINK-26098 URL: https://issues.apache.org/jira/browse/FLINK-26098 Project: Flink

[jira] [Commented] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers failed

[ https://issues.apache.org/jira/browse/FLINK-25981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490783#comment-17490783 ] Till Rohrmann commented on FLINK-25981: --- Ok, I think we can ignore the latest occurrence. There

[jira] [Commented] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers failed

[ https://issues.apache.org/jira/browse/FLINK-25981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490781#comment-17490781 ] Till Rohrmann commented on FLINK-25981: --- The new stack trace is {code}

[jira] [Updated] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers failed

[ https://issues.apache.org/jira/browse/FLINK-25981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25981: -- Summary:

[jira] [Closed] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26036. - Resolution: Fixed Fixed via 314f91df7019bf1ce1ede52b8ba7f2d0a1c44aac >

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490730#comment-17490730 ] Till Rohrmann commented on FLINK-26036: --- Another instance w/o the latest fix:

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490731#comment-17490731 ] Till Rohrmann commented on FLINK-24119: ---

[jira] [Commented] (FLINK-26081) Update document,becasue of add maven wrapper.

[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490726#comment-17490726 ] Till Rohrmann commented on FLINK-26081: --- Sure, I've assigned you. > Update document,becasue of

[jira] [Assigned] (FLINK-26081) Update document,becasue of add maven wrapper.

[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26081: - Assignee: Aiden Gong > Update document,becasue of add maven wrapper. >

[jira] [Assigned] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js

[ https://issues.apache.org/jira/browse/FLINK-25898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25898: - Assignee: Till Rohrmann > Add README.md to flink-statefun/statefun-sdk-js >

[jira] [Closed] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26034. - Resolution: Fixed Fixed via cc5616d1f1a3566f8a4dbb7a016251cf0f34b47a > Add maven wrapper for

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490351#comment-17490351 ] Till Rohrmann commented on FLINK-26036: --- I think the solution is to move the {{isRunning()}} check

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490349#comment-17490349 ] Till Rohrmann commented on FLINK-26036: --- The problem seems to be the following: When shutting down

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490131#comment-17490131 ] Till Rohrmann commented on FLINK-26036: --- Thanks for the pointer [~gaoyunhaii]. I will take another

[jira] [Closed] (FLINK-25975) add doc for how to use AvroParquetRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-25975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25975. - Resolution: Fixed Fixed via 222b72f2de43bb60b2f4741fde023493967d20f7 > add doc for how to use

[jira] [Closed] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26036. - Resolution: Fixed Fixed via f839f12e2e425d8c32279fb505a8c624bbc2a266 >

[jira] [Assigned] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26034: - Assignee: Aiden Gong > Add maven wrapper for flink > --- > >

[jira] [Closed] (FLINK-26032) log job info in the ContextEnvironment

[ https://issues.apache.org/jira/browse/FLINK-26032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-26032. - Fix Version/s: 1.15.0 Resolution: Fixed Fixed via

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489424#comment-17489424 ] Till Rohrmann commented on FLINK-26036: --- The problem seems to be the shutdown hook introduced with

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489415#comment-17489415 ] Till Rohrmann commented on FLINK-26036: --- The problem seems to be that a restarted {{TaskManager}}

[jira] [Updated] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26036: -- Fix Version/s: 1.15.0 >

[jira] [Assigned] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26036: - Assignee: Till Rohrmann >

[jira] [Commented] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489364#comment-17489364 ] Till Rohrmann commented on FLINK-26034: --- This could indeed be helpful. Especially since we rely on

[jira] [Updated] (FLINK-26034) Add maven wrapper for flink

[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-26034: -- Summary: Add maven wrapper for flink (was: Add maven wapper for flink) > Add maven wrapper

[jira] [Assigned] (FLINK-25933) Allow configuring different transports in RequestReplyFunctionBuilder

[ https://issues.apache.org/jira/browse/FLINK-25933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25933: - Assignee: Galen Warren > Allow configuring different transports in

[jira] [Assigned] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

[ https://issues.apache.org/jira/browse/FLINK-26003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26003: - Assignee: (was: Till Rohrmann) > Use Jackson serialization for persisting

[jira] [Commented] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489003#comment-17489003 ] Till Rohrmann commented on FLINK-23240: --- It might be a problem for standalone setups where the

[jira] [Commented] (FLINK-26005) TableEnvironment.createTemporarySystemFunction cause NPE when using leftOuterLateralJoin

[ https://issues.apache.org/jira/browse/FLINK-26005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489002#comment-17489002 ] Till Rohrmann commented on FLINK-26005: --- I think [~twalthr] made it a subtask. >

[jira] [Created] (FLINK-26014) Document how to use the working directory for faster local recoveries

Till Rohrmann created FLINK-26014: - Summary: Document how to use the working directory for faster local recoveries Key: FLINK-26014 URL: https://issues.apache.org/jira/browse/FLINK-26014 Project:

[jira] [Closed] (FLINK-25817) FLIP-201: Persist local state in working directory

[ https://issues.apache.org/jira/browse/FLINK-25817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25817. - Fix Version/s: 1.15.0 Resolution: Fixed Fixed via 4b39e4ad438 f95a0c7e867 1a1415119f9

[jira] [Created] (FLINK-26005) TableEnvironment.createTemporarySystemFunction cause NPE when using leftOuterLateralJoin

Till Rohrmann created FLINK-26005: - Summary: TableEnvironment.createTemporarySystemFunction cause NPE when using leftOuterLateralJoin Key: FLINK-26005 URL: https://issues.apache.org/jira/browse/FLINK-26005

[jira] [Created] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

Till Rohrmann created FLINK-26003: - Summary: Use Jackson serialization for persisting TaskExecutor state to working directory Key: FLINK-26003 URL: https://issues.apache.org/jira/browse/FLINK-26003

[jira] [Comment Edited] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488663#comment-17488663 ] Till Rohrmann edited comment on FLINK-23240 at 2/8/22, 8:40 AM: The

[jira] [Commented] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488665#comment-17488665 ] Till Rohrmann commented on FLINK-23240: --- cc [~dmvk] >

[jira] [Updated] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23240: -- Affects Version/s: 1.15.0 >

[jira] [Commented] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488664#comment-17488664 ] Till Rohrmann commented on FLINK-23240: --- I am promoting this issue to be a blocker until we have

[jira] [Commented] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488663#comment-17488663 ] Till Rohrmann commented on FLINK-23240: --- The problem seems to be that the

[jira] [Updated] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23240: -- Priority: Blocker (was: Critical) >

[jira] [Assigned] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25937: - Assignee: David Morávek > SQL Client end-to-end test e2e fails on AZP >

[jira] [Assigned] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25825: - Assignee: RocMarshal > MySqlCatalogITCase fails on azure >

[jira] [Assigned] (FLINK-25968) Possible class leaks in flink-table / sql modules

[ https://issues.apache.org/jira/browse/FLINK-25968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25968: - Assignee: Timo Walther > Possible class leaks in flink-table / sql modules >

[jira] [Updated] (FLINK-25968) Possible class leaks in flink-table / sql modules

[ https://issues.apache.org/jira/browse/FLINK-25968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25968: -- Priority: Blocker (was: Critical) > Possible class leaks in flink-table / sql modules >

[jira] [Updated] (FLINK-25968) Possible class leaks in flink-table / sql modules

[ https://issues.apache.org/jira/browse/FLINK-25968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25968: -- Fix Version/s: 1.15.0 > Possible class leaks in flink-table / sql modules >

[jira] [Updated] (FLINK-25968) Possible class leaks in flink-table / sql modules

[ https://issues.apache.org/jira/browse/FLINK-25968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25968: -- Priority: Critical (was: Major) > Possible class leaks in flink-table / sql modules >

[jira] [Updated] (FLINK-23240) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23240: -- Component/s: Runtime / Coordination >

[jira] [Updated] (FLINK-25992) JobDispatcherITCase.testRecoverFromCheckpointAfterLosingAndRegainingLeadership fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25992: -- Summary: JobDispatcherITCase.testRecoverFromCheckpointAfterLosingAndRegainingLeadership

[jira] [Closed] (FLINK-25935) Add a harness based entry point to simply getting started.

[ https://issues.apache.org/jira/browse/FLINK-25935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25935. - Resolution: Fixed Fixed via 66b8cd0453990b4e56a48392388391dd4e6eafa0 > Add a harness based

[jira] [Closed] (FLINK-25934) Modernize statefun playground examples

[ https://issues.apache.org/jira/browse/FLINK-25934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25934. - Resolution: Fixed Fixed via 5f082918129f4253797fb698adfe5f16bbc94166

[jira] [Commented] (FLINK-25981) ZooKeeperMultipleComponentLeaderElectionDriverTest failed

[ https://issues.apache.org/jira/browse/FLINK-25981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488138#comment-17488138 ] Till Rohrmann commented on FLINK-25981: --- Hmm, from the logs it looks as if there is no new leader

[jira] [Assigned] (FLINK-25934) Modernize statefun playground examples

[ https://issues.apache.org/jira/browse/FLINK-25934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25934: - Assignee: Till Rohrmann > Modernize statefun playground examples >

[jira] [Commented] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions

[ https://issues.apache.org/jira/browse/FLINK-25893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488033#comment-17488033 ] Till Rohrmann commented on FLINK-25893: --- For option 1) I think a leading {{Dispatcher}} would

[jira] [Updated] (FLINK-25924) KDF Integration tests intermittently fails

[ https://issues.apache.org/jira/browse/FLINK-25924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25924: -- Affects Version/s: 1.15.0 > KDF Integration tests intermittently fails >

[jira] [Updated] (FLINK-25924) KDF Integration tests intermittently fails

[ https://issues.apache.org/jira/browse/FLINK-25924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25924: -- Fix Version/s: (was: 1.15.0) > KDF Integration tests intermittently fails >

[jira] [Closed] (FLINK-25885) ClusterEntrypointTest.testWorkingDirectoryIsDeletedIfApplicationCompletes failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25885. - Fix Version/s: 1.15.0 Resolution: Fixed Fixed via

[jira] [Comment Edited] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486454#comment-17486454 ] Till Rohrmann edited comment on FLINK-21752 at 2/3/22, 1:03 PM: Yes, I

  1   2   3   4   5   6   7   8   9   10   >