Is MiniClusterWithClientResource expected to have a UI?

2023-03-29 Thread Sofya T. Irwin
Hi, I'm experimenting with the MiniClusterWithClientResource, below, and when I print out the URL I'm not able to access a UI. Is the MiniClusterWithClientResource expected to provide a UI? Thanks -Sofya https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/datastre

Moving off of TypeInformation in Flink 1.11

2022-01-06 Thread Sofya T. Irwin
tion. I’m not sure if there’s an equivalent DataType implicit that I should be declaring instead. Or if I should be using some function other than map Do you have any suggestions for how to proceed? I'd like to completely move off of TypeInformation in my app. Thanks, Sofya

Re: org.codehaus.janino.CompilerFactory cannot be cast ....

2021-02-25 Thread sofya
What was the actual solution? Did you have to modify pom? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

user@flink.apache.org

2020-08-28 Thread Sofya T. Irwin
e sure that the state only has data that is only more recent? Thank you, Sofya On Thu, Aug 27, 2020 at 10:49 PM Danny Chan wrote: > Hi, Sofya T. Irwin ~ > > Can you share your case why you need a timed-window join there ? > > Now the sql timed window join is not supported yet, and

user@flink.apache.org

2020-07-30 Thread Sofya T. Irwin
StreamPlanner. Is there any way to ensure that idle state has limited retention for applications using the StreamPlanner? Thanks ahead, Sofya