[jira] [Created] (FLINK-21277) SQLClientSchemaRegistryITCase fails to download testcontainers/ryuk:0.3.0

2021-02-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21277: Summary: SQLClientSchemaRegistryITCase fails to download testcontainers/ryuk:0.3.0 Key: FLINK-21277 URL: https://issues.apache.org/jira/browse/FLINK-21277 Pro

Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-02-04 Thread Jark Wu
Hi all, Regarding "One Parser", I think it's not possible for now because Calcite parser can't parse special characters (e.g. "-") unless quoting them as string literals. That's why the WITH option key are string literals not identifiers. SET table.exec.mini-batch.enabled = true and ADD JAR /loca

[jira] [Created] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

2021-02-04 Thread HunterHunter (Jira)
HunterHunter created FLINK-21278: Summary: NullpointExecption error is reported when using the evictor method to filter the data before the window calculation Key: FLINK-21278 URL: https://issues.apache.org/jira/b

Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-02-04 Thread Ingo Bürk
Hi, regarding the (un-)quoted question, compatibility is of course an important argument, but in terms of consistency I'd find it a bit surprising that WITH handles it differently than SET, and I wonder if that could cause friction for developers when writing their SQL. Regards Ingo On Thu, Feb

Re: [VOTE] FLIP-160: Declarative scheduler

2021-02-04 Thread Till Rohrmann
+1 (binding) Cheers, Till On Wed, Feb 3, 2021 at 5:00 AM Yu Li wrote: > +1 (binding) > > Best Regards, > Yu > > > On Mon, 1 Feb 2021 at 17:21, Matthias Pohl wrote: > > > +1 (non-binding) > > > > Thanks, > > Matthias > > > > On Mon, Feb 1, 2021 at 4:22 AM Zhu Zhu wrote: > > > > > +1 (binding)

[RESULT][VOTE] FLIP-160: Declarative scheduler

2021-02-04 Thread Till Rohrmann
Hi everyone, The voting time for FLIP-160: Declarative scheduler [1] has passed. I'm closing the vote now. There were 8 +1 votes, 5 of which are binding: - Robert Metzger (binding) - Xintong Song (binding) - Yangze (non-binding) - Yang Wang (non-binding) - Zhu Zhu (binding) - Matthias Pohl (non-

Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-02-04 Thread Jark Wu
Hi Ingo, Since we have supported the WITH syntax and SET command since v1.9 [1][2], and we have never received such complaints, I think it's fine for such differences. Besides, the TBLPROPERTIES clause of CREATE TABLE in Hive also requires string literal keys[3], and the SET = doesn't allow quote

[jira] [Created] (FLINK-21279) flink on yarn sink nothing

2021-02-04 Thread Spongebob (Jira)
Spongebob created FLINK-21279: - Summary: flink on yarn sink nothing Key: FLINK-21279 URL: https://issues.apache.org/jira/browse/FLINK-21279 Project: Flink Issue Type: Bug Components: Ta

Re: [VOTE] FLIP-160: Declarative scheduler

2021-02-04 Thread Maximilian Michels
+1 (binding) On 04.02.21 10:18, Till Rohrmann wrote: +1 (binding) Cheers, Till On Wed, Feb 3, 2021 at 5:00 AM Yu Li wrote: +1 (binding) Best Regards, Yu On Mon, 1 Feb 2021 at 17:21, Matthias Pohl wrote: +1 (non-binding) Thanks, Matthias On Mon, Feb 1, 2021 at 4:22 AM Zhu Zhu wrote:

Upgrade calcite version

2021-02-04 Thread 盛森林
Hi, I want to upgrade calcite to 1.22 in the flink branch that fork from apache release 1.9.  Can community give me some suggestion.

[jira] [Created] (FLINK-21280) Investigate a way to disable object reuse in StateFun

2021-02-04 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-21280: Summary: Investigate a way to disable object reuse in StateFun Key: FLINK-21280 URL: https://issues.apache.org/jira/browse/FLINK-21280 Project: Flink Issue T

Re: Proposal to add Google Cloud Storage FileSystem with RecoverableWriter

2021-02-04 Thread Galen Warren
Hi Till -- this is in response to your message before about my proposal to add GCS FileSystem/RecoverableWriter support. I was only subscribed to the dev digest before, and so I didn't actually get an email I could reply to, so sorry for the one-off email. I'm properly subscribed to the dev list no

[jira] [Created] (FLINK-21281) Support DELETE FROM for flink sql

2021-02-04 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-21281: - Summary: Support DELETE FROM for flink sql Key: FLINK-21281 URL: https://issues.apache.org/jira/browse/FLINK-21281 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21282) Support UPDATE for flink sql

2021-02-04 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-21282: - Summary: Support UPDATE for flink sql Key: FLINK-21282 URL: https://issues.apache.org/jira/browse/FLINK-21282 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-21283) Support sql extension for flink sql

2021-02-04 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-21283: - Summary: Support sql extension for flink sql Key: FLINK-21283 URL: https://issues.apache.org/jira/browse/FLINK-21283 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21284) Non-deterministic UDF functions return different values

2021-02-04 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-21284: - Summary: Non-deterministic UDF functions return different values Key: FLINK-21284 URL: https://issues.apache.org/jira/browse/FLINK-21284 Project: Flink Issue Type:

[jira] [Created] (FLINK-21285) Support MERGE INTO for flink sql

2021-02-04 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-21285: - Summary: Support MERGE INTO for flink sql Key: FLINK-21285 URL: https://issues.apache.org/jira/browse/FLINK-21285 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21286) Support BUCKET for flink sql CREATE TABLE

2021-02-04 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-21286: - Summary: Support BUCKET for flink sql CREATE TABLE Key: FLINK-21286 URL: https://issues.apache.org/jira/browse/FLINK-21286 Project: Flink Issue Type: Improvement

Re: [DISCUSS]FLIP-163: SQL Client Improvements

2021-02-04 Thread Jark Wu
Hi all, After an offline discussion with Timo and Kurt, we have reached some consensus. Please correct me if I am wrong or missed anything. 1) We will introduce "table.planner" and "table.execution-mode" instead of "sql-client" prefix, and add `TableEnvironment.create(Configuration)` interface. T

[jira] [Created] (FLINK-21287) Failed to build flink source code

2021-02-04 Thread Lei Qu (Jira)
Lei Qu created FLINK-21287: -- Summary: Failed to build flink source code Key: FLINK-21287 URL: https://issues.apache.org/jira/browse/FLINK-21287 Project: Flink Issue Type: Bug Components: F

[jira] [Created] (FLINK-21288) Support redundant task managers for fine grained resource management

2021-02-04 Thread Xintong Song (Jira)
Xintong Song created FLINK-21288: Summary: Support redundant task managers for fine grained resource management Key: FLINK-21288 URL: https://issues.apache.org/jira/browse/FLINK-21288 Project: Flink

[jira] [Created] (FLINK-21289) Application mode on kubernetes deployment support run PackagedProgram.main with pipeline.classpaths

2021-02-04 Thread Zhou Parker (Jira)
Zhou Parker created FLINK-21289: --- Summary: Application mode on kubernetes deployment support run PackagedProgram.main with pipeline.classpaths Key: FLINK-21289 URL: https://issues.apache.org/jira/browse/FLINK-21289

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-02-04 Thread Kezhu Wang
Hi all, Thanks for starting the discussion! I think there are differences between start-position and checkpoint-state. Checkpoint states are actually intermediate progress-capture in reading data. Source clients don't care about it in coding phase, there are purely implementation details. While s

[jira] [Created] (FLINK-21290) Support Projection push down for Window TVF

2021-02-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-21290: --- Summary: Support Projection push down for Window TVF Key: FLINK-21290 URL: https://issues.apache.org/jira/browse/FLINK-21290 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21291) FlinkKafka Consumer can't dynamic discover the partition update

2021-02-04 Thread zhangyunyun (Jira)
zhangyunyun created FLINK-21291: --- Summary: FlinkKafka Consumer can't dynamic discover the partition update Key: FLINK-21291 URL: https://issues.apache.org/jira/browse/FLINK-21291 Project: Flink