zeyuwang
zeyuwang
The server port(1260 and 1630) is occupied?
@zhoujinsong @JamesIsHuang maybe you call `ams.sh start` repeatedly? And when you want restart ams you only called `ams.sh start` but not call stop?
i Add arg to support streaming or batch executionMode，it works. And it works by jdbc:flink://host:port?planner=blink&executionType=streaming
> > i Add arg to support streaming or batch executionMode，it works. And it works by jdbc:flink://host:port?planner=blink&executionType=streaming > > Has your code been submitted? no, it just work in my...
@openinx @stevenzwu Could you help take a look?
@openinx Could you help take a look again?
@MOBIN-F It's true, this PR translate update to -D and +I.
> > @MOBIN-F It's true, this PR translate update to -D and +I. > > It will query the record(1,qq). but this record is from before the update, Is that...
> I wonder if this patch requires Flink 1.13, or it'll also work for 1.12? @xinbinhuang It work for both Flink 1.12 and 1.13.
> Thanks ,After testing, the PR is problematic, there will be duplicate data in batch read, not suitable for Upsert stream and join scenario also have problems, > I'm trying...