Thanks Marta,
One of the lacking features I noticed is that several example programs are
missing for Java and Scala as in Data Sources section on page Apache Flink 1.10
Documentation: Flink DataSet API Programming Guide
|
|
| |
Apache Flink 1.10 Documentation: Flink DataSet API Programming
Kurt Young created FLINK-18224:
--
Summary: Add document about sql client's tableau result mode
Key: FLINK-18224
URL: https://issues.apache.org/jira/browse/FLINK-18224
Project: Flink
Issue Type:
Congratulations, Benchao!
Weihua Hu 于2020年6月10日周三 上午11:47写道：
> Congratulations, Benchao!
>
> Best
> Weihua Hu
>
> > 2020年6月10日 11:04，Matt Wang 写道：
> >
> > Congratulations, Benchao!
> >
> >
> > ---
> > Best,
> > Matt Wang
> >
> >
> > On 06/9/2020 19:58，Benchao Li wrote：
> > Thank you all, it's
Yang Wang created FLINK-18228:
-
Summary: Release pending pods/containers timely when pending slots
changed
Key: FLINK-18228
URL: https://issues.apache.org/jira/browse/FLINK-18228
Project: Flink
Sorry, I check the code find that '
org/apache/flink/fs/s3presto/common/HadoopConfigLoader'' is shaded on
purpose.
So could you check whether there is a old "presto" jar in your lib
directory?
Best,
Guowei
Claude Murad 于2020年6月10日周三 上午10:06写道：
> Thanks for your reply. The
>
Xintong Song created FLINK-18229:
Summary: Pending worker requests should be properly cleared
Key: FLINK-18229
URL: https://issues.apache.org/jira/browse/FLINK-18229
Project: Flink
Issue
Thanks for that reminder, Seth!
+1 to add a check during CI if possible.
Best,
Yangze Guo
On Wed, Jun 10, 2020 at 3:04 AM Kostas Kloudas wrote:
>
> Thanks for the heads up Seth!
>
> Kostas
>
> On Tue, Jun 9, 2020 at 7:27 PM Seth Wiesman wrote:
> >
> > The tag is new to Jekyll 4.0 which we
Hi, Deepak!
In reply to your email (below): the project proposal [1] focuses on the
Table API / SQL, so I'm afraid that working on the DataSet API
documentation is out of scope for our participation in Google Season of
Docs.
Is there anything within the scope of the proposal that you'd like to
+1 to use {% link %} tag and add check in CI.
Tips: if want to link a Chinese page, should write: [CLI]({% link ops/
cli.zh.md %})
Best,
Jark
On Wed, 10 Jun 2020 at 10:30, Yangze Guo wrote:
> Thanks for that reminder, Seth!
>
> +1 to add a check during CI if possible.
>
> Best,
> Yangze Guo
appleyuchi created FLINK-18227:
--
Summary: official example stuck in flink shell(local mode)
Key: FLINK-18227
URL: https://issues.apache.org/jira/browse/FLINK-18227
Project: Flink
Issue Type:
mzz created FLINK-18230:
---
Summary: Table API has no Functions like sparkSQL explode
Key: FLINK-18230
URL: https://issues.apache.org/jira/browse/FLINK-18230
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-18225:
---
Summary: Add collect method in the Python TableResult
Key: FLINK-18225
URL: https://issues.apache.org/jira/browse/FLINK-18225
Project: Flink
Issue Type: Improvement
Xintong Song created FLINK-18226:
Summary: ResourceManager requests unnecessary new workers if
previous workers are allocated but not registered.
Key: FLINK-18226
URL:
Congratulations, Benchao!
Best
Weihua Hu
> 2020年6月10日 11:04，Matt Wang 写道：
>
> Congratulations, Benchao!
>
>
> ---
> Best,
> Matt Wang
>
>
> On 06/9/2020 19:58，Benchao Li wrote：
> Thank you all, it's a great honor to be a committer of Flink Community.
> Looking forward to do more
Congratulations, Benchao!
---
Best,
Matt Wang
On 06/9/2020 19:58，Benchao Li wrote：
Thank you all, it's a great honor to be a committer of Flink Community.
Looking forward to do more contributions to the community.
Congxian Qiu 于2020年6月9日周二 下午7:47写道：
Congratulations, Benchao!
Best,
Congxian
There seems to be some thread confusion here. @Deepak, I'll reply to you in
the original thread ("Interested in applying as a technical writer").
Sorry, Abdul!
On Wed, Jun 10, 2020 at 1:59 AM Deepak Vohra wrote:
> Thanks Marta,
>
> One of the lacking features I noticed is that several example
Chesnay Schepler created FLINK-18215:
Summary: BashJavaUtils logging message should include log level
Key: FLINK-18215
URL: https://issues.apache.org/jira/browse/FLINK-18215
Project: Flink
Chesnay Schepler created FLINK-18214:
Summary: Incorrect warning if jobstore.cache-size exceeds heap size
Key: FLINK-18214
URL: https://issues.apache.org/jira/browse/FLINK-18214
Project: Flink
Hi Everyone
I am currently going through the documentation for 1.11 and noticed an
issue with the walkthroughs.
Flink currently contains two walkthroughs for new users, one for data
stream and one for table[1, 2]. They both have corresponding maven
archetypes for users to create template
jackylau created FLINK-18213:
Summary: refactor kafka sql connector to use just one shade to
compatible 0.10.0.2 +
Key: FLINK-18213
URL: https://issues.apache.org/jira/browse/FLINK-18213
Project: Flink
Hi
Thanks for bringing this up, Robert.
I agree we may need to investigate better translation/synchronization tools
again.
I'll share some experience when translating the documentation or reviewing
the translation.
1. Translate documentation using the current procedure needs a lot of
resources
Congrats, Benchao!
On Tue, Jun 9, 2020 at 11:41 AM Till Rohrmann wrote:
> Congratulations!
>
> Cheers,
> Till
>
> On Tue, Jun 9, 2020 at 11:19 AM Yang Wang wrote:
>
> > Congratulations!
> >
> > Best,
> > Yang
> >
> > Yu Li 于2020年6月9日周二 下午5:11写道：
> >
> > > Congratulations, Benchao!
> > >
> > >
Congratulations, Benchao!
Best,
Congxian
Marta Paes Moreira 于2020年6月9日周二 下午7:24写道：
> Congrats, Benchao!
>
> On Tue, Jun 9, 2020 at 11:41 AM Till Rohrmann
> wrote:
>
> > Congratulations!
> >
> > Cheers,
> > Till
> >
> > On Tue, Jun 9, 2020 at 11:19 AM Yang Wang wrote:
> >
> > >
Chesnay Schepler created FLINK-18216:
Summary: "Start time" column should not expand if a job is running
Key: FLINK-18216
URL: https://issues.apache.org/jira/browse/FLINK-18216
Project: Flink
Chesnay Schepler created FLINK-18220:
Summary: Improve exception if finalizeOnmaster hits OOM
Key: FLINK-18220
URL: https://issues.apache.org/jira/browse/FLINK-18220
Project: Flink
Issue
Chesnay Schepler created FLINK-18217:
Summary: config.sh#extractExecutionResults does not fail on empty
input
Key: FLINK-18217
URL: https://issues.apache.org/jira/browse/FLINK-18217
Project:
Thank you all, it's a great honor to be a committer of Flink Community.
Looking forward to do more contributions to the community.
Congxian Qiu 于2020年6月9日周二 下午7:47写道：
> Congratulations, Benchao!
> Best,
> Congxian
>
>
> Marta Paes Moreira 于2020年6月9日周二 下午7:24写道：
>
> > Congrats, Benchao!
> >
> >
Wei Zhong created FLINK-18218:
-
Summary: Add yarn perjob, java dependency management e2e tests for
pyflink.
Key: FLINK-18218
URL: https://issues.apache.org/jira/browse/FLINK-18218
Project: Flink
Chesnay Schepler created FLINK-18219:
Summary: Improve exception if jar submission hits OOM
Key: FLINK-18219
URL: https://issues.apache.org/jira/browse/FLINK-18219
Project: Flink
Issue
Hi Everyone!
As we are seeing an influx of documentation PRs in anticipation of the 1.11
release I would like to remind everyone to use the {% link %} tag when
cross-linking pages[1]. This is opposed to creating a link based on
site.baseurl.
Going forward a link such as:
[CLI]({% site.baseurl
Thank you for noticing that, the guide is out of date. I will fix that
immediately!
On Tue, Jun 9, 2020 at 9:34 AM Dawid Wysakowicz
wrote:
> Hi Seth,
>
> Thanks I did not know that.
>
> I am not entirely sure, but I think our documentation guide is slightly
> outdated on that manner (
>
Whoops, responded from the wrong email :)
Thank you for noticing that, the guide is out of date. I will fix that
immediately!
On Tue, Jun 9, 2020 at 9:36 AM Seth Wiesman wrote:
> Thank you for noticing that, the guide is out of date. I will fix that
> immediately!
>
> On Tue, Jun 9, 2020 at
I had a second look at the PR and maybe it'd be important to clarify the
scope.
It seems to only target the website and, if that's the case, then
synchronization might be less of an issue as the core of the website is
pretty static. I'm not sure how useful it is to have a translated website
I am very much in favour of this effort.
Best,
Dawid
On 09/06/2020 16:06, Seth Wiesman wrote:
> Hi Everyone
>
> I am currently going through the documentation for 1.11 and noticed an
> issue with the walkthroughs.
>
> Flink currently contains two walkthroughs for new users, one for data
>
Hi
I think supporting website with another language should be okay. However, I'm
afraid Flink community lacks of resources
to maintain technical documentations of another languages currently.
>From my experiences of translating documentation to Chinese since the past
>year, I found
Chinese
Robert Metzger created FLINK-18221:
--
Summary: SQL client YAML validation incomplete
Key: FLINK-18221
URL: https://issues.apache.org/jira/browse/FLINK-18221
Project: Flink
Issue Type: Bug
Hi Seth,
Thanks I did not know that.
I am not entirely sure, but I think our documentation guide is slightly
outdated on that manner
(https://flink.apache.org/contributing/docs-style.html) Or is there a
mistake in your example? Our guide recommends:
[CLI](|{{site.baseurl}}|{% link ops/cli.md
Robert Metzger created FLINK-18222:
--
Summary: "Avro Confluent Schema Registry nightly end-to-end test"
unstable with "Kafka cluster did not start after 120 seconds"
Key: FLINK-18222
URL:
Thanks for the reminder. I was also not aware of this tag!
How about enforcing the use of this tag through CI?
We could for example grep through the added lines of all changes in docs/
and fail the build if we see the wrong pattern.
On Tue, Jun 9, 2020 at 4:37 PM Seth Wiesman wrote:
> Whoops,
Lorenzo Nicora created FLINK-18223:
--
Summary: AvroSerializer does not correctly instantiate
GenericRecord
Key: FLINK-18223
URL: https://issues.apache.org/jira/browse/FLINK-18223
Project: Flink
The tag is new to Jekyll 4.0 which we only recently updated to.
There are a lot of existing tags that would need to be updated first :)
I opened a ticket to track that work and then yes that would make sense.
Seth
[1] https://issues.apache.org/jira/browse/FLINK-18193
On Tue, Jun 9, 2020 at
Thanks for the heads up Seth!
Kostas
On Tue, Jun 9, 2020 at 7:27 PM Seth Wiesman wrote:
>
> The tag is new to Jekyll 4.0 which we only recently updated to.
>
> There are a lot of existing tags that would need to be updated first :)
> I opened a ticket to track that work and then yes that would
IMO, having the walkthroughs as maven archetypes is not maintainable.
On Tue, Jun 9, 2020 at 2:47 PM Seth Wiesman wrote:
> Hi Konstantin,
>
> I am linking my working branch for what the playground might look like. It
> contains a Java application you can import into your IDE and then fill out
>
Hi everyone,
it seems that guaranteeing any backwards compatibility for Savepoints
stretches the resources of the community too much right now. As Steven
says, the documentation is actually pretty clear on that.
I still think it would be great if we would only break compatibility
knowingly, so
Hi Seth,
I see, that's neat. I think it is a good idea moving the archetypes out of
the main repository into flink-playgrounds.
Best,
Konstantin
On Tue, Jun 9, 2020 at 9:47 PM Seth Wiesman wrote:
> Hi Konstantin,
>
> I am linking my working branch for what the playground might look like.
Hi Seth,
good catch! I agree this is important to fix.
I don't quite understand the resolution you are proposing. The current
walkthrough for the Table API is a *code *walkthrough. How do you plan to
replace this by a dockerized playground? Drop the code walkthrough and add
a pure SQL
Hi Konstantin,
I am linking my working branch for what the playground might look like. It
contains a Java application you can import into your IDE and then fill out
the same way you do currently. It is still a code walkthrough. Docker
allows users to actually run the completed app locally and not
jackylau created FLINK-18208:
Summary: flink es connector exists 2 Spelling mistakes
Key: FLINK-18208
URL: https://issues.apache.org/jira/browse/FLINK-18208
Project: Flink
Issue Type:
Marta Paes Moreira created FLINK-18209:
--
Summary: Replace "charged" words in the Flink codebase.
Key: FLINK-18209
URL: https://issues.apache.org/jira/browse/FLINK-18209
Project: Flink
Congratulations, Benchao!
Best,
Weiguang Wang
From: tison
Date: 2020-06-09 14:58
To: dev
Subject: Re: [ANNOUNCE] New Flink Committer: Benchao Li
Congratulations, Benchao
Best,
tison.
Kurt Young 于2020年6月9日周二 下午2:51写道：
> Congratulations, Benchao!
>
> Best,
> Kurt
>
>
> On Tue, Jun 9,
Congrats!
On Tue, Jun 9, 2020 at 2:10 PM Jark Wu wrote:
> Hi everyone,
>
> On behalf of the PMC, I'm very happy to announce Benchao Li as a new Apache
> Flink committer.
>
> Benchao started contributing to Flink since late 2018. He is very active in
> Flink SQL component,
> and has also
Congratulations, Benchao!
Best Regards,
Yu
On Tue, 9 Jun 2020 at 17:05, Yuan Mei wrote:
> Congrats!
>
> On Tue, Jun 9, 2020 at 2:10 PM Jark Wu wrote:
>
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to announce Benchao Li as a new
> Apache
> > Flink committer.
> >
> > Benchao
JieFang.He created FLINK-18210:
--
Summary: The tmpdir will be clean up when stop historyserver
Key: FLINK-18210
URL: https://issues.apache.org/jira/browse/FLINK-18210
Project: Flink
Issue Type:
Echo Lee created FLINK-18211:
Summary: Dynamic properties setting 'pipeline.jars' will be
overwritten
Key: FLINK-18211
URL: https://issues.apache.org/jira/browse/FLINK-18211
Project: Flink
Congratulations!
Best,
Yang
Yu Li 于2020年6月9日周二 下午5:11写道：
> Congratulations, Benchao!
>
> Best Regards,
> Yu
>
>
> On Tue, 9 Jun 2020 at 17:05, Yuan Mei wrote:
>
> > Congrats!
> >
> > On Tue, Jun 9, 2020 at 2:10 PM Jark Wu wrote:
> >
> > > Hi everyone,
> > >
> > > On behalf of the PMC, I'm
Hi everyone,
On behalf of the PMC, I'm very happy to announce Benchao Li as a new Apache
Flink committer.
Benchao started contributing to Flink since late 2018. He is very active in
Flink SQL component,
and has also participated in many discussions, bug fixes. Over the past few
months, he helped
Congratulations, Benchao. Well deserved!
Best,
Jingsong Lee
On Tue, Jun 9, 2020 at 2:13 PM Forward Xu wrote:
> Congratulations, Benchao
>
> Best,
> Forward
>
> Jark Wu 于2020年6月9日周二 下午2:10写道：
>
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to announce Benchao Li as a new
>
Congratulations, Benchao~!
Thank you~
Xintong Song
On Tue, Jun 9, 2020 at 2:16 PM Jingsong Li wrote:
> Congratulations, Benchao. Well deserved!
>
> Best,
> Jingsong Lee
>
> On Tue, Jun 9, 2020 at 2:13 PM Forward Xu wrote:
>
> > Congratulations, Benchao
> >
> > Best,
> > Forward
> >
> >
Congrats Benchao!
Regards,
Dian
> 在 2020年6月9日，下午2:30，Xintong Song 写道：
>
> Congratulations, Benchao~!
>
> Thank you~
>
> Xintong Song
>
>
>
> On Tue, Jun 9, 2020 at 2:16 PM Jingsong Li wrote:
>
>> Congratulations, Benchao. Well deserved!
>>
>> Best,
>> Jingsong Lee
>>
>> On Tue, Jun 9,
Congratulations, Benchao
Best,
Forward
Jark Wu 于2020年6月9日周二 下午2:10写道：
> Hi everyone,
>
> On behalf of the PMC, I'm very happy to announce Benchao Li as a new Apache
> Flink committer.
>
> Benchao started contributing to Flink since late 2018. He is very active in
> Flink SQL component,
> and
Congratulations!
Best,
Yangze Guo
On Tue, Jun 9, 2020 at 2:32 PM Dian Fu wrote:
>
> Congrats Benchao!
>
> Regards,
> Dian
>
> > 在 2020年6月9日，下午2:30，Xintong Song 写道：
> >
> > Congratulations, Benchao~!
> >
> > Thank you~
> >
> > Xintong Song
> >
> >
> >
> > On Tue, Jun 9, 2020 at 2:16 PM Jingsong
Congratulations!
Best,
Jiayi Liao
On Tue, Jun 9, 2020 at 2:32 PM Dian Fu wrote:
> Congrats Benchao!
>
> Regards,
> Dian
>
> > 在 2020年6月9日，下午2:30，Xintong Song 写道：
> >
> > Congratulations, Benchao~!
> >
> > Thank you~
> >
> > Xintong Song
> >
> >
> >
> > On Tue, Jun 9, 2020 at 2:16 PM Jingsong
Congratulations, Benchao !!!
Leonard Xu 于2020年6月9日周二 下午2:39写道：
> Congratulations, Benchao !
>
> Best,
> Leonard Xu
>
>
>
> > 在 2020年6月9日，14:36，Jiayi Liao 写道：
> >
> > Congratulations!
> >
> >
> > Best,
> > Jiayi Liao
> >
> > On Tue, Jun 9, 2020 at 2:32 PM Dian Fu wrote:
> >
> >> Congrats
Benchao Li created FLINK-18202:
--
Summary: Introduce PB format
Key: FLINK-18202
URL: https://issues.apache.org/jira/browse/FLINK-18202
Project: Flink
Issue Type: New Feature
Congratulations, Benchao!
Best,
Nicholas
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Jiayi Liao created FLINK-18203:
--
Summary: Reduce objects usage in redistributing union states
Key: FLINK-18203
URL: https://issues.apache.org/jira/browse/FLINK-18203
Project: Flink
Issue Type:
Congratulations!
Thanks,
Zhu Zhu
Zhijiang 于2020年6月9日周二 下午3:29写道：
> Congratulations, Benchao!
>
> Best,
> Zhijiang
>
>
> --
> From:SteNicholas
> Send Time:2020年6月9日(星期二) 15:11
> To:dev
> Subject:Re: [ANNOUNCE] New Flink
Congratulations, Benchao!
Best,
Dan Zou
> 2020年6月9日 下午3:47，Zhu Zhu 写道：
>
> Congratulations
Congratulations, Benchao !
Best,
Leonard Xu
> 在 2020年6月9日，14:36，Jiayi Liao 写道：
>
> Congratulations!
>
>
> Best,
> Jiayi Liao
>
> On Tue, Jun 9, 2020 at 2:32 PM Dian Fu wrote:
>
>> Congrats Benchao!
>>
>> Regards,
>> Dian
>>
>>> 在 2020年6月9日，下午2:30，Xintong Song 写道：
>>>
>>>
Hi,
My flink jobs are constantly going down beyond an hour with the below
exception.
This is Flink 1.7 on kubes, with checkpoints to Google storage.
AsynchronousException{java.lang.Exception: Could not materialize
checkpoint 21 for operator Source: Kafka011TableSource(sid, _zpsbd3,
_zpsbd4,
Congratulations, Benchao!
Best,
Kurt
On Tue, Jun 9, 2020 at 2:46 PM Guanghui Zhang wrote:
> Congratulations, Benchao !!!
>
> Leonard Xu 于2020年6月9日周二 下午2:39写道：
>
> > Congratulations, Benchao !
> >
> > Best,
> > Leonard Xu
> >
> >
> >
> > > 在 2020年6月9日，14:36，Jiayi Liao 写道：
> > >
> > >
Congratulations, Benchao
Best,
tison.
Kurt Young 于2020年6月9日周二 下午2:51写道：
> Congratulations, Benchao!
>
> Best,
> Kurt
>
>
> On Tue, Jun 9, 2020 at 2:46 PM Guanghui Zhang
> wrote:
>
> > Congratulations, Benchao !!!
> >
> > Leonard Xu 于2020年6月9日周二 下午2:39写道：
> >
> > > Congratulations, Benchao !
Congratulations, Benchao!
Best,
Zhijiang
--
From:SteNicholas
Send Time:2020年6月9日(星期二) 15:11
To:dev
Subject:Re: [ANNOUNCE] New Flink Committer: Benchao Li
Congratulations, Benchao!
Best,
Nicholas
--
Sent from:
shengsheng lin created FLINK-18204:
--
Summary: NullPointerException when materialize checkpoint
Key: FLINK-18204
URL: https://issues.apache.org/jira/browse/FLINK-18204
Project: Flink
Issue
Yangze Guo created FLINK-18205:
--
Summary: Mitigate the use of reflection in HadoopModule
Key: FLINK-18205
URL: https://issues.apache.org/jira/browse/FLINK-18205
Project: Flink
Issue Type:
JasonLee created FLINK-18206:
Summary: The timestamp is displayed incorrectly
Key: FLINK-18206
URL: https://issues.apache.org/jira/browse/FLINK-18206
Project: Flink
Issue Type: Bug
Congratulations!
Cheers,
Till
On Tue, Jun 9, 2020 at 11:19 AM Yang Wang wrote:
> Congratulations!
>
> Best,
> Yang
>
> Yu Li 于2020年6月9日周二 下午5:11写道：
>
> > Congratulations, Benchao!
> >
> > Best Regards,
> > Yu
> >
> >
> > On Tue, 9 Jun 2020 at 17:05, Yuan Mei wrote:
> >
> > > Congrats!
> > >
Hi Ramya,
it looks as if you should give your Flink pods and also the Flink process a
bit more memory as the process fails with an out of memory error. You could
also try Flink's latest version which comes with native Kubernetes support.
Cheers,
Till
On Tue, Jun 9, 2020 at 8:45 AM Ramya
The Apache Flink community is very happy to announce the release of Apache
Flink Stateful Functions 2.1.0.
Stateful Functions is an API that simplifies building distributed stateful
applications.
It's based on functions with persistent state that can interact dynamically
with strong consistency
I agree with Dawid and others' opinions.
We may not have enough resources to maintain more languages.
Maybe it's time to investigate better translation/synchronization tools
again.
I want to share some background about the current translation process. In
the initial proposal of Chinese
YufeiLiu created FLINK-18212:
Summary: Init lookup join failed when use udf on lookup table
Key: FLINK-18212
URL: https://issues.apache.org/jira/browse/FLINK-18212
Project: Flink
Issue Type: Bug
81 matches
Mail list logo
