You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/15 12:05:00 UTC

[jira] [Resolved] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar

     [ https://issues.apache.org/jira/browse/FLINK-37725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dawid Wysakowicz resolved FLINK-37725.
--------------------------------------
    Fix Version/s: 2.1.0
         Assignee: Alan Sheinberg
       Resolution: Fixed

Fixed in 53616d61e22491931bec10573eeee316ca762732

> Share PythonCorrelateSplitRule with Async Scalar
> ------------------------------------------------
>
>                 Key: FLINK-37725
>                 URL: https://issues.apache.org/jira/browse/FLINK-37725
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Alan Sheinberg
>            Assignee: Alan Sheinberg
>            Priority: Major
>             Fix For: 2.1.0
>
>
> Move PythonCorrelateSplitRule to be common and so that we can move Async Scalars out of correlate queries, which results in an error today:
> {code:java}
> Caused by: org.codehaus.commons.compiler.CompileException: Line 99, Column 15: Unknown variable or type "f"
>     at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:13080)
>     at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7230) {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)