Edsion_Lin created FLINK-18510:
--
Summary: Job Listener接口不生效
Key: FLINK-18510
URL: https://issues.apache.org/jira/browse/FLINK-18510
Project: Flink
Issue Type: Bug
Components: API / Cor
mzz created FLINK-18511:
---
Summary: Unsupported call: TUMBLE_END(TIME(0), INTERVAL SECOND(3)
NOT NULL)
Key: FLINK-18511
URL: https://issues.apache.org/jira/browse/FLINK-18511
Project: Flink
Issue Type:
Congrats Piotr! Well deserved!
Thanks,
Biao /'bɪ.aʊ/
On Tue, 7 Jul 2020 at 13:03, Congxian Qiu wrote:
> Congratulations Piotr!
>
> Best,
> Congxian
>
>
> Zhijiang 于2020年7月7日周二 下午12:25写道：
>
> > Congratulations Piotr!
> >
> > Best,
> > Zhijiang
> >
> >
> > -
Congratulations Piotr!
Best,
Congxian
Zhijiang 于2020年7月7日周二 下午12:25写道：
> Congratulations Piotr!
>
> Best,
> Zhijiang
>
>
> --
> From:Rui Li
> Send Time:2020年7月7日(星期二) 11:55
> To:dev
> Cc:pnowojski
> Subject:Re: [ANNOUNCE] New P
Congratulations Piotr!
Best,
Zhijiang
--
From:Rui Li
Send Time:2020年7月7日(星期二) 11:55
To:dev
Cc:pnowojski
Subject:Re: [ANNOUNCE] New PMC member: Piotr Nowojski
Congrats!
On Tue, Jul 7, 2020 at 11:25 AM Yangze Guo wrote:
> Congr
Congrats!
On Tue, Jul 7, 2020 at 11:25 AM Yangze Guo wrote:
> Congratulations!
>
> Best,
> Yangze Guo
>
> On Tue, Jul 7, 2020 at 11:01 AM Jiayi Liao
> wrote:
> >
> > Congratulations Piotr!
> >
> > Best,
> > Jiayi Liao
> >
> > On Tue, Jul 7, 2020 at 10:54 AM Jark Wu wrote:
> >
> > > Congratulat
Congratulations!
Best,
Yangze Guo
On Tue, Jul 7, 2020 at 11:01 AM Jiayi Liao wrote:
>
> Congratulations Piotr!
>
> Best,
> Jiayi Liao
>
> On Tue, Jul 7, 2020 at 10:54 AM Jark Wu wrote:
>
> > Congratulations Piotr!
> >
> > Best,
> > Jark
> >
> > On Tue, 7 Jul 2020 at 10:50, Yuan Mei wrote:
> >
Congratulations Piotr!
Best,
Jiayi Liao
On Tue, Jul 7, 2020 at 10:54 AM Jark Wu wrote:
> Congratulations Piotr!
>
> Best,
> Jark
>
> On Tue, 7 Jul 2020 at 10:50, Yuan Mei wrote:
>
> > Congratulations, Piotr!
> >
> > On Tue, Jul 7, 2020 at 1:07 AM Stephan Ewen wrote:
> >
> > > Hi all!
> > >
>
Congratulations Piotr!
Best,
Jark
On Tue, 7 Jul 2020 at 10:50, Yuan Mei wrote:
> Congratulations, Piotr!
>
> On Tue, Jul 7, 2020 at 1:07 AM Stephan Ewen wrote:
>
> > Hi all!
> >
> > It is my pleasure to announce that Piotr Nowojski joined the Flink PMC.
> >
> > Many of you may know Piotr from
底限 created FLINK-18509:
--
Summary: add ignite idbc dialect
Key: FLINK-18509
URL: https://issues.apache.org/jira/browse/FLINK-18509
Project: Flink
Issue Type: New Feature
Components: Connectors
Congratulations, Piotr!
On Tue, Jul 7, 2020 at 1:07 AM Stephan Ewen wrote:
> Hi all!
>
> It is my pleasure to announce that Piotr Nowojski joined the Flink PMC.
>
> Many of you may know Piotr from the work he does on the data processing
> runtime and the network stack, from the mailing list, or
Jingsong Lee created FLINK-18508:
Summary: Dynamic source supports statistics and parallelism report
Key: FLINK-18508
URL: https://issues.apache.org/jira/browse/FLINK-18508
Project: Flink
Iss
Hi everyone,
Leonard and I prepared a FLIP about refactoring current Descriptor API,
i.e. TableEnvironment#connect(). We would like to propose a new descriptor
API to register connectors in Table API.
Since Flink 1.9, the community focused more on the new SQL DDL feature.
After a series of releas
Dian Fu created FLINK-18507:
---
Summary: Move get_config implementation to TableEnvironment to
eliminate the duplication
Key: FLINK-18507
URL: https://issues.apache.org/jira/browse/FLINK-18507
Project: Flink
Congratulations, Piotr!
Best Regards,
Yu
On Tue, 7 Jul 2020 at 10:20, Benchao Li wrote:
> Congratulations!
>
> Paul Lam 于2020年7月7日周二 上午10:12写道：
>
> > Congrats Piotr! Well deserved!
> >
> > Best,
> > Paul Lam
> >
> > > 2020年7月7日 10:07，Yun Gao 写道：
> > >
> > > Congratulations Piotr !
> > >
> >
Congratulations!
Paul Lam 于2020年7月7日周二 上午10:12写道：
> Congrats Piotr! Well deserved!
>
> Best,
> Paul Lam
>
> > 2020年7月7日 10:07，Yun Gao 写道：
> >
> > Congratulations Piotr !
> >
> > Best,
> > Yun
> >
> >
> > --
> > Sender:Austin Bennet
Yu Li created FLINK-18506:
-
Summary: The generated flink-docker file misses flink version in
Tags
Key: FLINK-18506
URL: https://issues.apache.org/jira/browse/FLINK-18506
Project: Flink
Issue Type: B
Congrats Piotr! Well deserved!
Best,
Paul Lam
> 2020年7月7日 10:07，Yun Gao 写道：
>
> Congratulations Piotr !
>
> Best,
> Yun
>
>
> --
> Sender:Austin Bennett
> Date:2020/07/07 10:06:15
> Recipient:
> Theme:Re: [ANNOUNCE] New PMC memb
Congratulations Piotr~!
> 2020年7月7日 上午10:07，Yun Gao 写道：
>
> Congratulations Piotr !
>
> Best,
> Yun
>
>
> --
> Sender:Austin Bennett
> Date:2020/07/07 10:06:15
> Recipient:
> Theme:Re: [ANNOUNCE] New PMC member: Piotr Nowojski
>
Congratulations Piotr !
Best,
Yun
--
Sender:Austin Bennett
Date:2020/07/07 10:06:15
Recipient:
Theme:Re: [ANNOUNCE] New PMC member: Piotr Nowojski
Thanks for what you do, Piotr!
On Mon, Jul 6, 2020, 7:02 PM Matt Wang wrote:
> C
Congratulations Piotr!
Best,
Forward
Matt Wang 于2020年7月7日周二 上午10:02写道：
> Congratulations!
>
>
> --
>
> Best,
> Matt Wang
>
>
> On 07/7/2020 09:45，Xingbo Huang wrote：
> Congratulations Piotr!
>
> Best,
> Xingbo
>
> Dian Fu 于2020年7月7日周二 上午9:43写道：
>
> Congrats, Piotr!
>
> 在 2020年7月7日，上午7:06，Jef
Thanks for what you do, Piotr!
On Mon, Jul 6, 2020, 7:02 PM Matt Wang wrote:
> Congratulations!
>
>
> --
>
> Best,
> Matt Wang
>
>
> On 07/7/2020 09:45，Xingbo Huang wrote：
> Congratulations Piotr!
>
> Best,
> Xingbo
>
> Dian Fu 于2020年7月7日周二 上午9:43写道：
>
> Congrats, Piotr!
>
> 在 2020年7月7日，上午7:06
Congratulations!
--
Best,
Matt Wang
On 07/7/2020 09:45，Xingbo Huang wrote：
Congratulations Piotr!
Best,
Xingbo
Dian Fu 于2020年7月7日周二 上午9:43写道：
Congrats, Piotr!
在 2020年7月7日，上午7:06，Jeff Zhang 写道：
Congratulations Piotr!
Thomas Weise 于2020年7月7日周二 上午4:45写道：
Congratulations!
On Mon, Jul 6
Thanks Jinsong for the suggestions.
+1 for #1, as users are constantly puzzled by the inconsistencies between
the Table / SQL module and SQL Client.
Best,
Weike
On Mon, Jul 6, 2020 at 11:55 AM Jingsong Li wrote:
> +1 for expanding the scope of #2, a SQL test framework(Should not be too
> heav
Congratulations Piotr!
Best,
Xingbo
Dian Fu 于2020年7月7日周二 上午9:43写道：
> Congrats, Piotr!
>
> > 在 2020年7月7日，上午7:06，Jeff Zhang 写道：
> >
> > Congratulations Piotr!
> >
> > Thomas Weise 于2020年7月7日周二 上午4:45写道：
> >
> >> Congratulations!
> >>
> >>
> >> On Mon, Jul 6, 2020 at 10:58 AM Seth Wiesman
> w
Congrats, Piotr!
> 在 2020年7月7日，上午7:06，Jeff Zhang 写道：
>
> Congratulations Piotr!
>
> Thomas Weise 于2020年7月7日周二 上午4:45写道：
>
>> Congratulations!
>>
>>
>> On Mon, Jul 6, 2020 at 10:58 AM Seth Wiesman wrote:
>>
>>> Congratulations Piotr!
>>>
>>> On Mon, Jul 6, 2020 at 12:53 PM Peter Huang
>>
Congratulations Piotr! Well deserved!
Best,
Jingsong
On Tue, Jul 7, 2020 at 9:37 AM Xintong Song wrote:
> Congratulations Piotr~!
>
> Thank you~
>
> Xintong Song
>
>
>
> On Tue, Jul 7, 2020 at 9:35 AM Zhu Zhu wrote:
>
> > Congratulations!
> >
> >
> > Leonard Xu 于2020年7月7日周二 上午9:16写道：
> >
> >
Congratulations Piotr~!
Thank you~
Xintong Song
On Tue, Jul 7, 2020 at 9:35 AM Zhu Zhu wrote:
> Congratulations!
>
>
> Leonard Xu 于2020年7月7日周二 上午9:16写道：
>
> > Congratulations Piotr!
> >
> > Best,
> > Leonard Xu
> > > 在 2020年7月7日，07:06，Jeff Zhang 写道：
> > >
> > > Congratulations Piotr!
> > >
Congratulations!
Leonard Xu 于2020年7月7日周二 上午9:16写道：
> Congratulations Piotr!
>
> Best,
> Leonard Xu
> > 在 2020年7月7日，07:06，Jeff Zhang 写道：
> >
> > Congratulations Piotr!
> >
> > Thomas Weise 于2020年7月7日周二 上午4:45写道：
> >
> >> Congratulations!
> >>
> >>
> >> On Mon, Jul 6, 2020 at 10:58 AM Seth Wies
Congratulations Piotr!
Best,
Leonard Xu
> 在 2020年7月7日，07:06，Jeff Zhang 写道：
>
> Congratulations Piotr!
>
> Thomas Weise 于2020年7月7日周二 上午4:45写道：
>
>> Congratulations!
>>
>>
>> On Mon, Jul 6, 2020 at 10:58 AM Seth Wiesman wrote:
>>
>>> Congratulations Piotr!
>>>
>>> On Mon, Jul 6, 2020 at 12
Roc Marshal created FLINK-18505:
---
Summary: correct the content of 'sourceSinks.zh.md'
Key: FLINK-18505
URL: https://issues.apache.org/jira/browse/FLINK-18505
Project: Flink
Issue Type: Task
Congratulations Piotr!
Thomas Weise 于2020年7月7日周二 上午4:45写道：
> Congratulations!
>
>
> On Mon, Jul 6, 2020 at 10:58 AM Seth Wiesman wrote:
>
> > Congratulations Piotr!
> >
> > On Mon, Jul 6, 2020 at 12:53 PM Peter Huang
> > wrote:
> >
> > > Congratulations!
> > >
> > > On Mon, Jul 6, 2020 at 10:3
Chris Nix created FLINK-18504:
-
Summary: Mismatch between CsvTableSource constructor and builder
params
Key: FLINK-18504
URL: https://issues.apache.org/jira/browse/FLINK-18504
Project: Flink
Iss
Congratulations!
On Mon, Jul 6, 2020 at 10:58 AM Seth Wiesman wrote:
> Congratulations Piotr!
>
> On Mon, Jul 6, 2020 at 12:53 PM Peter Huang
> wrote:
>
> > Congratulations!
> >
> > On Mon, Jul 6, 2020 at 10:36 AM Arvid Heise wrote:
> >
> > > Congratulations!
> > >
> > > On Mon, Jul 6, 2020 a
Thanks for the excellent proposal!
Big +1 for introducing EFO as an incremental feature while retaining
backward compatibility! This will make it easier for users to adopt.
Thanks for mentioning the reasons why one might not want to use EFO.
Regarding "Streams with a single consumer would not ben
+1
On Mon, Jul 6, 2020 at 12:15 AM Konstantin Knauf wrote:
> +1
>
> On Thu, Jul 2, 2020 at 8:16 PM Aljoscha Krettek
> wrote:
>
> > +1
> >
> > Aljoscha
> >
> > On 01.07.20 15:14, Tzu-Li (Gordon) Tai wrote:
> > > +1
> > >
> > > On Wed, Jul 1, 2020, 8:57 PM Cranmer, Danny
> wrote:
> > >
> > >> H
fanrui created FLINK-18503:
--
Summary: bug occurs when `HeapReducingState#add` method handles
null
Key: FLINK-18503
URL: https://issues.apache.org/jira/browse/FLINK-18503
Project: Flink
Issue Type:
Congratulations Piotr!
On Mon, Jul 6, 2020 at 12:53 PM Peter Huang
wrote:
> Congratulations!
>
> On Mon, Jul 6, 2020 at 10:36 AM Arvid Heise wrote:
>
> > Congratulations!
> >
> > On Mon, Jul 6, 2020 at 7:07 PM Stephan Ewen wrote:
> >
> > > Hi all!
> > >
> > > It is my pleasure to announce that
Congratulations!
On Mon, Jul 6, 2020 at 10:36 AM Arvid Heise wrote:
> Congratulations!
>
> On Mon, Jul 6, 2020 at 7:07 PM Stephan Ewen wrote:
>
> > Hi all!
> >
> > It is my pleasure to announce that Piotr Nowojski joined the Flink PMC.
> >
> > Many of you may know Piotr from the work he does on
Hi Prasanna,
overcommitting cores was actually a recommended technique a while ago to
counter-balance I/O. So it's not bad per se.
However, with slot sharing each core is already doing the work for source,
transform, sink, so it's not necessary. So I'd go with slots = cores and I
rather strongly
Congratulations!
On Mon, Jul 6, 2020 at 7:07 PM Stephan Ewen wrote:
> Hi all!
>
> It is my pleasure to announce that Piotr Nowojski joined the Flink PMC.
>
> Many of you may know Piotr from the work he does on the data processing
> runtime and the network stack, from the mailing list, or the rel
Hi all!
It is my pleasure to announce that Piotr Nowojski joined the Flink PMC.
Many of you may know Piotr from the work he does on the data processing
runtime and the network stack, from the mailing list, or the release
manager work.
Congrats, Piotr!
Best,
Stephan
Hi ,
I used t2.medium machines for the task manager nodes. It has 2 CPU and 4GB
memory.
But the task manager screen shows that there are 4 slots.
Generally we should match the number of slots to the number of cores.
[image: image.png]
Our pipeline is Source -> Simple Transform -> Sink.
What h
* I mistyped the rejected_query, it should be
CREATE VIEW AS post_agg_stream SELECT currencyId, AVG(rate)* as *rate*
FROM *currency_rates
CREATE VIEW AS rejected_query
SELECT
...FROM
transactions AS t
JOIN post_agg_stream FOR SYSTEM_TIME AS OF t.transactionTime AS r
ON r.currency = t.curr
Hey Leonard,
Agreed, this is a fun discussion!
(1) For support changelog source backed CDC tools, a problem is that can we
> use the temporal table as a general source table which may followed by some
> aggregation operations, more accurate is wether the aggregation operator
> can use the DELETE
Hi everyone,
Thanks a lot for the great discussions so far.
After reading through the long discussion, I still have one question.
Currently the temporal table function supports both event time and proc
time joining.
If we use "FOR SYSTEM_TIME AS OF" syntax without "TEMPORAL" keyword in DDL,
does
Roc Marshal created FLINK-18502:
---
Summary: Add 'legacySourceSinks.zh.md' into the
'flink/docs/dev/table' directory
Key: FLINK-18502
URL: https://issues.apache.org/jira/browse/FLINK-18502
Project: Flink
Hi, Seth
Thanks for your explanation of user cases, and you’re wright the look up
join/table is one kind of temporal table join/table which tracks latest
snapshot of external DB-like tables, it's why we proposed use same temporal
join syntax.
In fact, I have invested and checked Debezuim form
Fabian Paul created FLINK-18501:
---
Summary: Mapping of Pluggable Filesystems to scheme is not
properly logged
Key: FLINK-18501
URL: https://issues.apache.org/jira/browse/FLINK-18501
Project: Flink
As an aside, I conceptually view temporal table joins to be semantically
equivalent to look up table joins. They are just two different ways of
consuming the same data.
Seth
On Mon, Jul 6, 2020 at 8:56 AM Seth Wiesman wrote:
> Hi Leonard,
>
> Regarding DELETE operations I tend to have the oppos
Hi Leonard,
Regarding DELETE operations I tend to have the opposite reaction. I spend a
lot of time working with production Flink users across a large number of
organizations and to say we don't support temporal tables that include
DELETEs will be a blocker for adoption. Even organizations that cl
Danny Chen created FLINK-18500:
--
Summary: Make the legacy planner exception more clear when
resolving computed columns types for schema
Key: FLINK-18500
URL: https://issues.apache.org/jira/browse/FLINK-18500
David Anderson created FLINK-18499:
--
Summary: Update Flink Exercises to 1.11
Key: FLINK-18499
URL: https://issues.apache.org/jira/browse/FLINK-18499
Project: Flink
Issue Type: Improvement
David Anderson created FLINK-18498:
--
Summary: Update Flink Playgrounds to 1.11
Key: FLINK-18498
URL: https://issues.apache.org/jira/browse/FLINK-18498
Project: Flink
Issue Type: Improvement
Piotr Nowojski created FLINK-18497:
--
Summary: Publish Docerfiles for release 1.11.0
Key: FLINK-18497
URL: https://issues.apache.org/jira/browse/FLINK-18497
Project: Flink
Issue Type: Task
Dear community,
happy to share this (and last) week's community update. Flink 1.11 is
finally ready to be released. Besides that a few design discussions in
different areas of Apache Flink, like enhanced fan out for Flink's Kinesis
Source or Temporal Table support in pure Flink SQL, and of course
Zhu Zhu created FLINK-18496:
---
Summary: Anchors are not generated based on ZH characters
Key: FLINK-18496
URL: https://issues.apache.org/jira/browse/FLINK-18496
Project: Flink
Issue Type: Bug
jackylau created FLINK-18495:
Summary: flink filterpushdown can not take effect in blink planner
Key: FLINK-18495
URL: https://issues.apache.org/jira/browse/FLINK-18495
Project: Flink
Issue Type:
I'm happy to announce that we have unanimously approved the 1.11.0 release.
There are 17 approving votes, 8 of which are binding:
- Stephan (binding)
- Till (binding)
- Aljoscha (binding)
- Robert (binding)
- Chesnay (binding)
- Dawid (binding)
- Jark (binding)
- Jincheng (binding)
- Leonard Xu (
wuleiflink created FLINK-18494:
--
Summary: The job was migrated from flink1.9.0 to 1.10.1, and there
were incompatibilities: No enum constant
org.apache.flink.table.types.logical.LogicalTypeRoot.ANY
Key: FLINK-18494
+1
On Thu, Jul 2, 2020 at 8:16 PM Aljoscha Krettek wrote:
> +1
>
> Aljoscha
>
> On 01.07.20 15:14, Tzu-Li (Gordon) Tai wrote:
> > +1
> >
> > On Wed, Jul 1, 2020, 8:57 PM Cranmer, Danny wrote:
> >
> >> Hi all,
> >>
> >> I'd like to start a voting thread for FLIP-128 [1], which we've reached
> co
61 matches
Mail list logo
