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/datastream/testing/#juni

Moving off of TypeInformation in Flink 1.11

2022-01-06 Thread Sofya T. Irwin
Hi, I’m moving my Flink 1.11 application onto the Blink Table Planner; and off of TypeInformation and onto DataTypes in preparation for upgrading Flink to Flink 1.13 or higher. I’m having trouble moving off of TypeInformation. Specifically I have a section of code that maps a DataStream[Messag

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
Hi, I'm trying to investigate a SQL job using a time-windowed join that is exhibiting a large, growing state. The join syntax is most similar to the interval join ( https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/joins.html ). A few questions: 1. Am I correct in understa