[jira] [Created] (FLINK-24225) Define and implement UPSERT INTO semantics

2021-09-08 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24225: --- Summary: Define and implement UPSERT INTO semantics Key: FLINK-24225 URL: https://issues.apache.org/jira/browse/FLINK-24225 Project: Flink Issu

[jira] [Created] (FLINK-24224) Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work b

2021-09-08 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-24224: Summary: Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work by only stream api . Key:

[jira] [Created] (FLINK-24223) Client should throw exception to warn users when the configurations set by program options conflict with those set by -D

2021-09-08 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-24223: - Summary: Client should throw exception to warn users when the configurations set by program options conflict with those set by -D Key: FLINK-24223 URL: https://issues.apache.org

[jira] [Created] (FLINK-24222) Use ContextClassLoaderExtension in ReporterSetupTest

2021-09-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24222: Summary: Use ContextClassLoaderExtension in ReporterSetupTest Key: FLINK-24222 URL: https://issues.apache.org/jira/browse/FLINK-24222 Project: Flink

[jira] [Created] (FLINK-24221) Translate "JAR Statements" page of "SQL" into Chinese

2021-09-08 Thread wuguihu (Jira)
wuguihu created FLINK-24221: --- Summary: Translate "JAR Statements" page of "SQL" into Chinese Key: FLINK-24221 URL: https://issues.apache.org/jira/browse/FLINK-24221 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-24220) Translate "RESET Statements" page of "SQL" into Chinese

2021-09-08 Thread wuguihu (Jira)
wuguihu created FLINK-24220: --- Summary: Translate "RESET Statements" page of "SQL" into Chinese Key: FLINK-24220 URL: https://issues.apache.org/jira/browse/FLINK-24220 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-24219) Translate "SET Statements" page of "SQL" into Chinese

2021-09-08 Thread wuguihu (Jira)
wuguihu created FLINK-24219: --- Summary: Translate "SET Statements" page of "SQL" into Chinese Key: FLINK-24219 URL: https://issues.apache.org/jira/browse/FLINK-24219 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-24218) Translate "UNLOAD Statements" page of "SQL" into Chinese

2021-09-08 Thread wuguihu (Jira)
wuguihu created FLINK-24218: --- Summary: Translate "UNLOAD Statements" page of "SQL" into Chinese Key: FLINK-24218 URL: https://issues.apache.org/jira/browse/FLINK-24218 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-24217) Translate "LOAD Statements" page of "SQL" into Chinese

2021-09-08 Thread wuguihu (Jira)
wuguihu created FLINK-24217: --- Summary: Translate "LOAD Statements" page of "SQL" into Chinese Key: FLINK-24217 URL: https://issues.apache.org/jira/browse/FLINK-24217 Project: Flink Issue Type: Sub-

Re: [DISCUSS] FLIP-182: Watermark alignment

2021-09-08 Thread Thomas Weise
Thank you Piotr and Arvid for the context. I'm interested in helping with this feature. If I'm able to contribute before October, then I will reach out. Thanks, Thomas On Tue, Sep 7, 2021 at 11:33 PM Arvid Heise wrote: > Just to clarify: I specifically asked Piotr to not persue the FLIP if th

[jira] [Created] (FLINK-24216) org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure

2021-09-08 Thread Yun Gao (Jira)
Yun Gao created FLINK-24216: --- Summary: org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure Key: FLINK-24216 URL: https://issues.apache.org/

[jira] [Created] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment

2021-09-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-24215: --- Summary: Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment Key: FLINK-24215 URL: https://issues.apache.org/jira/browse/FLINK-24215 Projec

[jira] [Created] (FLINK-24214) A submit job failure crashes the sql client

2021-09-08 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24214: --- Summary: A submit job failure crashes the sql client Key: FLINK-24214 URL: https://issues.apache.org/jira/browse/FLINK-24214 Project: Flink Iss

[jira] [Created] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-08 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24213: Summary: Java deadlock in QueryableState ClientTest Key: FLINK-24213 URL: https://issues.apache.org/jira/browse/FLINK-24213 Project: Flink Issue Type

[jira] [Created] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory for customer file name

2021-09-08 Thread LiuZeshan (Jira)
LiuZeshan created FLINK-24212: - Summary: kerberos krb5.conf file is mounted as empty directory for customer file name Key: FLINK-24212 URL: https://issues.apache.org/jira/browse/FLINK-24212 Project: Flink

[jira] [Created] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis

2021-09-08 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24211: Summary: flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis Key: FLINK-24211 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

2021-09-08 Thread Yun Tang (Jira)
Yun Tang created FLINK-24210: Summary: Window related serailizer should not return 0 as its serialized length Key: FLINK-24210 URL: https://issues.apache.org/jira/browse/FLINK-24210 Project: Flink

[jira] [Created] (FLINK-24209) Jdbc connector uses postgres testcontainers in compile scope

2021-09-08 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24209: Summary: Jdbc connector uses postgres testcontainers in compile scope Key: FLINK-24209 URL: https://issues.apache.org/jira/browse/FLINK-24209 Project: Flink

[jira] [Created] (FLINK-24208) Allow idempotent savepoint triggering

2021-09-08 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-24208: -- Summary: Allow idempotent savepoint triggering Key: FLINK-24208 URL: https://issues.apache.org/jira/browse/FLINK-24208 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

2021-09-08 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-24207: --- Summary: Add support of KeyedState in TwoPhaseCommitSinkFunction Key: FLINK-24207 URL: https://issues.apache.org/jira/browse/FLINK-24207 Project: Flink Issue T