[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543637#comment-17543637 ] Galen Warren commented on FLINK-27813: -- Cool! Glad it was something simple. > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 > - > > Key: FLINK-27813 > URL: https://issues.apache.org/jira/browse/FLINK-27813 > Project: Flink > Issue Type: Bug > Components: API / State Processor >Affects Versions: statefun-3.2.0 >Reporter: Oleksandr Kazimirov >Priority: Blocker > Attachments: screenshot-1.png > > > Issue was met after migration from > flink-statefun:3.1.1-java11 > to > flink-statefun:3.2.0-java11 > > {code:java} > ts.execution-paymentManualValidationRequestEgress-egress, Sink: > ua.aval.payments.execution-norkomExecutionRequested-egress, Sink: > ua.aval.payments.execution-shareStatusToManualValidation-egress) (1/1)#15863 > (98a1f6bef9a435ef9d0292fefeb64022) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalStateException: Unable to parse Netty > transport spec.\n\tat > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.parseTransportSpec(NettyRequestReplyClientFactory.java:56)\n\tat > > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.createTransportClient(NettyRequestReplyClientFactory.java:39)\n\tat > > org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider.functionOfType(HttpFunctionProvider.java:49)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:70)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:47)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.load(StatefulFunctionRepository.java:71)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.get(StatefulFunctionRepository.java:59)\n\tat > > org.apache.flink.statefun.flink.core.functions.LocalFunctionGroup.enqueue(LocalFunctionGroup.java:48)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.enqueue(Reductions.java:153)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.apply(Reductions.java:148)\n\tat > > org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator.processElement(FunctionGroupOperator.java:90)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.sendDownstream(FeedbackUnionOperator.java:180)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.processElement(FeedbackUnionOperator.java:86)\n\tat > > org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)\n\tat > > org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)\n\tat > > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)\n\tat > > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)\n\tat > > org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)\n\tat > org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)\n\tat > org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)\n\tat > java.base/java.lang.Thread.run(Unknown Source)\nCaused by: > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException: > Time interval unit label 'm' does not match any of the recognized units: > DAYS: (d | day | days), HOURS: (h | hour | hours), MINUTES: (
[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543624#comment-17543624 ] Oleksandr commented on FLINK-27813: --- [~galenwarren] I found the issue in the configuration in module.yaml we used such a config in 3.1.0: {code:java} kind: io.statefun.endpoints.v2/http spec: functions: ua.test.execution/* urlPathTemplate: http://test-{{ $.Values.global.platformEnvironment }}.svc.cluster.local:8080/v1/functions transport: type: io.statefun.transports.v1/async timeouts: call: 6m{code} now in 3.2.0 - *6m* should be *6min* > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 > - > > Key: FLINK-27813 > URL: https://issues.apache.org/jira/browse/FLINK-27813 > Project: Flink > Issue Type: Bug > Components: API / State Processor >Affects Versions: statefun-3.2.0 >Reporter: Oleksandr >Priority: Blocker > Attachments: screenshot-1.png > > > Issue was met after migration from > flink-statefun:3.1.1-java11 > to > flink-statefun:3.2.0-java11 > > {code:java} > ts.execution-paymentManualValidationRequestEgress-egress, Sink: > ua.aval.payments.execution-norkomExecutionRequested-egress, Sink: > ua.aval.payments.execution-shareStatusToManualValidation-egress) (1/1)#15863 > (98a1f6bef9a435ef9d0292fefeb64022) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalStateException: Unable to parse Netty > transport spec.\n\tat > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.parseTransportSpec(NettyRequestReplyClientFactory.java:56)\n\tat > > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.createTransportClient(NettyRequestReplyClientFactory.java:39)\n\tat > > org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider.functionOfType(HttpFunctionProvider.java:49)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:70)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:47)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.load(StatefulFunctionRepository.java:71)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.get(StatefulFunctionRepository.java:59)\n\tat > > org.apache.flink.statefun.flink.core.functions.LocalFunctionGroup.enqueue(LocalFunctionGroup.java:48)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.enqueue(Reductions.java:153)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.apply(Reductions.java:148)\n\tat > > org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator.processElement(FunctionGroupOperator.java:90)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.sendDownstream(FeedbackUnionOperator.java:180)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.processElement(FeedbackUnionOperator.java:86)\n\tat > > org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)\n\tat > > org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)\n\tat > > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)\n\tat > > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)\n\tat > > org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)\n\tat > org.apache.flink.runtime.taskmanager.Task.doRun(Task.j
[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543616#comment-17543616 ] Oleksandr commented on FLINK-27813: --- We have job manager running that is configured via module.yaml(egress and ingress for kafka topics). Our stateful functions are on a separate remote service built on top of Spring boot with controller: {code:java} @RequestMapping("/v1/functions") @RequiredArgsConstructor public class FunctionRouteController { private final RequestReplyHandler handler; @PostMapping(consumes = MediaType.APPLICATION_OCTET_STREAM_VALUE) public CompletableFuture onRequest(@RequestBody byte[] request) { return handler .handle(Slices.wrap(request)) .thenApply(Slice::toByteArray); } } {code} where actually used 'org.apache.flink.statefun.sdk.java.handlerConcurrentRequestReplyHandler' and we just define beans: {code:java} @Bean public StatefulFunctions statefulFunctions(StatefulFunctions autoRegisteredStatefulFunctions) { // obtain a request-reply handler based on the spec above StatefulFunctions statefulFunctions = new StatefulFunctions() .withStatefulFunction(fallbackFn()) .withStatefulFunction(transactionFn()); autoRegisteredStatefulFunctions.functionSpecs().values().forEach(statefulFunctions::withStatefulFunction); return statefulFunctions; } @Bean public RequestReplyHandler requestReplyHandler(StatefulFunctions statefulFunctions) { return statefulFunctions.requestReplyHandler(); } {code} statefulFunctions.requestReplyHandler() is : {code:java} public RequestReplyHandler requestReplyHandler() { return new ConcurrentRequestReplyHandler(this.specs); } {code} > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 > - > > Key: FLINK-27813 > URL: https://issues.apache.org/jira/browse/FLINK-27813 > Project: Flink > Issue Type: Bug > Components: API / State Processor >Affects Versions: statefun-3.2.0 >Reporter: Oleksandr >Priority: Blocker > Attachments: screenshot-1.png > > > Issue was met after migration from > flink-statefun:3.1.1-java11 > to > flink-statefun:3.2.0-java11 > > {code:java} > ts.execution-paymentManualValidationRequestEgress-egress, Sink: > ua.aval.payments.execution-norkomExecutionRequested-egress, Sink: > ua.aval.payments.execution-shareStatusToManualValidation-egress) (1/1)#15863 > (98a1f6bef9a435ef9d0292fefeb64022) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalStateException: Unable to parse Netty > transport spec.\n\tat > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.parseTransportSpec(NettyRequestReplyClientFactory.java:56)\n\tat > > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.createTransportClient(NettyRequestReplyClientFactory.java:39)\n\tat > > org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider.functionOfType(HttpFunctionProvider.java:49)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:70)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:47)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.load(StatefulFunctionRepository.java:71)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.get(StatefulFunctionRepository.java:59)\n\tat > > org.apache.flink.statefun.flink.core.functions.LocalFunctionGroup.enqueue(LocalFunctionGroup.java:48)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.enqueue(Reductions.java:153)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.apply(Reductions.java:148)\n\tat > > org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator.processElement(FunctionGroupOperator.java:90)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.sendDownstream(FeedbackUnionOperator.java:180)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.processElement(FeedbackUnionOperator.java:86)\n\tat > > org.apache.flink.st
[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543099#comment-17543099 ] Galen Warren commented on FLINK-27813: -- Are you using RequestReplyFunctionBuilder to build your statefun job? > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 > - > > Key: FLINK-27813 > URL: https://issues.apache.org/jira/browse/FLINK-27813 > Project: Flink > Issue Type: Bug > Components: API / State Processor >Affects Versions: statefun-3.2.0 >Reporter: Oleksandr >Priority: Blocker > Attachments: screenshot-1.png > > > Issue was met after migration from > flink-statefun:3.1.1-java11 > to > flink-statefun:3.2.0-java11 > > {code:java} > ts.execution-paymentManualValidationRequestEgress-egress, Sink: > ua.aval.payments.execution-norkomExecutionRequested-egress, Sink: > ua.aval.payments.execution-shareStatusToManualValidation-egress) (1/1)#15863 > (98a1f6bef9a435ef9d0292fefeb64022) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalStateException: Unable to parse Netty > transport spec.\n\tat > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.parseTransportSpec(NettyRequestReplyClientFactory.java:56)\n\tat > > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.createTransportClient(NettyRequestReplyClientFactory.java:39)\n\tat > > org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider.functionOfType(HttpFunctionProvider.java:49)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:70)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:47)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.load(StatefulFunctionRepository.java:71)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.get(StatefulFunctionRepository.java:59)\n\tat > > org.apache.flink.statefun.flink.core.functions.LocalFunctionGroup.enqueue(LocalFunctionGroup.java:48)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.enqueue(Reductions.java:153)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.apply(Reductions.java:148)\n\tat > > org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator.processElement(FunctionGroupOperator.java:90)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.sendDownstream(FeedbackUnionOperator.java:180)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.processElement(FeedbackUnionOperator.java:86)\n\tat > > org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)\n\tat > > org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)\n\tat > > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)\n\tat > > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)\n\tat > > org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)\n\tat > org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)\n\tat > org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)\n\tat > java.base/java.lang.Thread.run(Unknown Source)\nCaused by: > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException: > Time interval unit label 'm' does not match any of the recognized units: > DAYS: (d | day | days), HOURS: (h | h
[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543094#comment-17543094 ] Oleksandr commented on FLINK-27813: --- [~galenwarren] we have such specs for example: {code:java} public static final ValueSpec ORIGINAL_CALLER = ValueSpec.named("originalCaller") .thatExpireAfterWrite(ChronoUnit.MONTHS.getDuration()) .withUtf8StringType(); public static final ValueSpec CALLER_ID = ValueSpec.named("callerId") .thatExpireAfterWrite(ChronoUnit.MONTHS.getDuration()) .withUtf8StringType(); public static final ValueSpec RESPONSE_STORAGE = ValueSpec.named("SightResponse") .thatExpireAfterWrite(ChronoUnit.MONTHS.getDuration()) .withCustomType(SightValidationResponse.TYPE); public static final ValueSpec ACT_RESPONSE_STORAGE = ValueSpec.named("ActResponse") .thatExpireAfterWrite(ChronoUnit.MONTHS.getDuration()) .withCustomType(ProtobufTypes.sepAckType()); public static final ValueSpec REQUEST_ATTEMPT = ValueSpec.named("attempt") .thatExpireAfterWrite(ChronoUnit.HOURS.getDuration()) .withIntType(); public static final ValueSpec RETRYABLE_RUNNER_VALUE_SPEC = ValueSpec .named("retryableRunner") .withCustomType(RetryableRunner.TYPE); public static final ValueSpec VALIDATION_IN_PROGRESS = ValueSpec.named("MonitoringValidationInProgress") .thatExpireAfterWrite(ChronoUnit.WEEKS.getDuration()) .withBooleanType();{code} > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 > - > > Key: FLINK-27813 > URL: https://issues.apache.org/jira/browse/FLINK-27813 > Project: Flink > Issue Type: Bug > Components: API / State Processor >Affects Versions: statefun-3.2.0 >Reporter: Oleksandr >Priority: Blocker > Attachments: screenshot-1.png > > > Issue was met after migration from > flink-statefun:3.1.1-java11 > to > flink-statefun:3.2.0-java11 > > {code:java} > ts.execution-paymentManualValidationRequestEgress-egress, Sink: > ua.aval.payments.execution-norkomExecutionRequested-egress, Sink: > ua.aval.payments.execution-shareStatusToManualValidation-egress) (1/1)#15863 > (98a1f6bef9a435ef9d0292fefeb64022) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalStateException: Unable to parse Netty > transport spec.\n\tat > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.parseTransportSpec(NettyRequestReplyClientFactory.java:56)\n\tat > > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.createTransportClient(NettyRequestReplyClientFactory.java:39)\n\tat > > org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider.functionOfType(HttpFunctionProvider.java:49)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:70)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:47)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.load(StatefulFunctionRepository.java:71)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.get(StatefulFunctionRepository.java:59)\n\tat > > org.apache.flink.statefun.flink.core.functions.LocalFunctionGroup.enqueue(LocalFunctionGroup.java:48)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.enqueue(Reductions.java:153)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.apply(Reductions.java:148)\n\tat > > org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator.processElement(FunctionGroupOperator.java:90)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.sendDownstream(FeedbackUnionOperator.java:180)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.processElement(FeedbackUnionOperator.java:86)\n\tat > > org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)\n\tat > > org.
[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542929#comment-17542929 ] Galen Warren commented on FLINK-27813: -- Hmm, not sure. The relevant part of the error message seems to be this: Time interval unit label 'm' does not match any of the recognized units: DAYS: (d | day | days), HOURS: (h | hour | hours), MINUTES: (min | minute | minutes), SECONDS: (s | sec | secs | second | seconds), MILLISECONDS: (ms | milli | millis | millisecond | milliseconds), MICROSECONDS: (µs | micro | micros | microsecond | microseconds), NANOSECONDS: (ns | nano | nanos | nanosecond | nanoseconds) Do you have a time unit in your spec labeled with an 'm'? > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 > - > > Key: FLINK-27813 > URL: https://issues.apache.org/jira/browse/FLINK-27813 > Project: Flink > Issue Type: Bug > Components: API / State Processor >Affects Versions: statefun-3.2.0 >Reporter: Oleksandr >Priority: Blocker > Attachments: screenshot-1.png > > > Issue was met after migration from > flink-statefun:3.1.1-java11 > to > flink-statefun:3.2.0-java8 > > {code:java} > ts.execution-paymentManualValidationRequestEgress-egress, Sink: > ua.aval.payments.execution-norkomExecutionRequested-egress, Sink: > ua.aval.payments.execution-shareStatusToManualValidation-egress) (1/1)#15863 > (98a1f6bef9a435ef9d0292fefeb64022) switched from RUNNING to FAILED with > failure cause: java.lang.IllegalStateException: Unable to parse Netty > transport spec.\n\tat > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.parseTransportSpec(NettyRequestReplyClientFactory.java:56)\n\tat > > org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory.createTransportClient(NettyRequestReplyClientFactory.java:39)\n\tat > > org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider.functionOfType(HttpFunctionProvider.java:49)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:70)\n\tat > > org.apache.flink.statefun.flink.core.functions.PredefinedFunctionLoader.load(PredefinedFunctionLoader.java:47)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.load(StatefulFunctionRepository.java:71)\n\tat > > org.apache.flink.statefun.flink.core.functions.StatefulFunctionRepository.get(StatefulFunctionRepository.java:59)\n\tat > > org.apache.flink.statefun.flink.core.functions.LocalFunctionGroup.enqueue(LocalFunctionGroup.java:48)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.enqueue(Reductions.java:153)\n\tat > > org.apache.flink.statefun.flink.core.functions.Reductions.apply(Reductions.java:148)\n\tat > > org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator.processElement(FunctionGroupOperator.java:90)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)\n\tat > > org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)\n\tat > > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.sendDownstream(FeedbackUnionOperator.java:180)\n\tat > > org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator.processElement(FeedbackUnionOperator.java:86)\n\tat > > org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)\n\tat > > org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)\n\tat > > org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)\n\tat > > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)\n\tat > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)\n\tat > > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)\n\tat > > org.apache.flink.runtime.ta