tim yu created FLINK-22804:
--
Summary: "CREATE VIEW" statement loses computed columns, metadata
columns, watermark and table constraint
Key: FLINK-22804
URL: https://issues.apache.org/jira/browse/FLINK-22804
Tejas Budukh created FLINK-22803:
Summary: Running multiple CEP patterns
Key: FLINK-22803
URL: https://issues.apache.org/jira/browse/FLINK-22803
Project: Flink
Issue Type: Bug
Compo
Arvid,
Thanks for the feedback. I investigated the japicmp configuration, and I
see that SinkWriter is marked Experimental (not Public or PublicEvolving).
I think this means that SinkWriter need not be excluded. As you mentioned,
SinkFunction is already excluded. I've updated the FLIP with an
ex
|The Apache Flink community is very happy to announce the release of
Apache Flink 1.13.1, which is the first bugfix release for the Apache
Flink 1.13 series.|
|Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
streami
Dear devs,
I'm happy to announce that we have unanimously approved this release.
There are 8 approving votes, 3 of which are binding:
* Matthias Pohl
* Roc Marshal
* Jing Zhang
* Chesnay Schepler (binding)
* Dawid Wysakowicz (binding)
* Xingbo Huang
* Le
Enrique Lacal created FLINK-22802:
-
Summary: Bump Fabric8 Kubernetes Client to
Key: FLINK-22802
URL: https://issues.apache.org/jira/browse/FLINK-22802
Project: Flink
Issue Type: Improvement
Thank you all for the votes. I am happy to say we approved the release.
I will write a separate summary mail.
Best,
Dawid
On 28/05/2021 14:40, Robert Metzger wrote:
> +1 (binding)
>
> - Tried out reactive mode in from the scala 2.11 binary locally (with
> scale up & stop with savepoint)
> - revi
Hi Konstantin,
>From my understanding, this syntax has 2 major benefits:
1. Just like you said, it saves the effort to specify the schema,
especially when involving hundreds of fields.
2. When using CREATE TABLE xx AS TABLE yy, it gives us the possibility to
enable schema evolution, and it seems
Ejaskhan created FLINK-22801:
Summary: Support for property file injection in module.yaml
Key: FLINK-22801
URL: https://issues.apache.org/jira/browse/FLINK-22801
Project: Flink
Issue Type: Bug
+1 (binding)
- Tried out reactive mode in from the scala 2.11 binary locally (with scale
up & stop with savepoint)
- reviewed website update
- randomly checked a jar file in the staging repo (flink-python jar looks
okay (I just checked superifically))
On Fri, May 28, 2021 at 5:16 AM Leonard Xu
Jin Xu created FLINK-22800:
--
Summary: Default EXACTLY_ONCE consumer (FLINK-6988) has not set
isolation.level
Key: FLINK-22800
URL: https://issues.apache.org/jira/browse/FLINK-22800
Project: Flink
I
Matthias created FLINK-22799:
Summary: Missing documentation: No state backwards compatibility
is not support for Flink SQL
Key: FLINK-22799
URL: https://issues.apache.org/jira/browse/FLINK-22799
Project:
Hi Eron,
1. fair point. It still feels odd to have writeWatermark in the
SinkFunction (it's supposed to be functional as you mentioned), but I agree
that invokeWatermark is not better. So unless someone has a better idea,
I'm fine with it.
2.+3. I tried to come up with scenarios for a longer time.
Hi everyone,
quick question for my understanding: how is this different to
CREATE TABLE IF NOT EXISTS my_table (
...
) WITH (
...
);
INSERT INTO my_table SELECT ...;
?
Is it only about a) not having to specify the schema and b) a more
condensed syntax?
Cheers,
Konstantin
On Fri, May 28, 2021
Thanks Danny for starting the discussion of extending CTAS syntax.
I think this is a very useful feature for data integration and ETL jobs (a
big use case of Flink).
Many users complain a lot that manually defining schemas for sources and
sinks is hard.
CTAS helps users to write ETL jobs without d
Jin Xu created FLINK-22798:
--
Summary: Exception handling of transactional producer
Key: FLINK-22798
URL: https://issues.apache.org/jira/browse/FLINK-22798
Project: Flink
Issue Type: Bug
Co
Hi Danny,
Thanks for starting this discussion.
Big +1 for this feature. Both CTAS AND CREATE TABLE LIKE are very useful
features. IMO, it is clear to separate them into two parts in the `syntax`
character. 😀
First, I have two related problems:
1. Would `create table` in CTAS trigger to cre
Nicolaus Weidner created FLINK-22797:
Summary: Improve incremental checkpoints documentation
Key: FLINK-22797
URL: https://issues.apache.org/jira/browse/FLINK-22797
Project: Flink
Issue T
Wei-Che Wei created FLINK-22796:
---
Summary: Update mem_setup_tm documentation
Key: FLINK-22796
URL: https://issues.apache.org/jira/browse/FLINK-22796
Project: Flink
Issue Type: Sub-task
manguozhi created FLINK-22795:
-
Summary: flink sql 1.13 通过 -f 执行位于hdfs上的SQL文件失败。
Key: FLINK-22795
URL: https://issues.apache.org/jira/browse/FLINK-22795
Project: Flink
Issue Type: Bug
C
20 matches
Mail list logo
