hi everyone,
I would like to bring up another topic about the return value of
TableResult#collect() method.
Currently, the return type is `Iterator`, we meet some problems when
implementing FLINK-14807[1].
In current design, the sink operator has a buffer pool which buffers the
data from upstream
Dian Fu created FLINK-17768:
---
Summary:
UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel
is instable
Key: FLINK-17768
URL: https://issues.apache.org/jira/browse/FLINK-17768
hailong wang created FLINK-17767:
Summary: Tumble and Hop window support offset
Key: FLINK-17767
URL: https://issues.apache.org/jira/browse/FLINK-17767
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-17766:
Summary: Use checkpoint lock instead of fine-grained locking in
Kafka AbstractFetcher
Key: FLINK-17766
URL: https://issues.apache.org/jira/browse/FLINK-17766
+1
Thanks,
Zhu Zhu
Yun Tang 于2020年5月16日周六 下午11:18写道：
>
> +1 (non-binding)
>
> Yun Tang
>
> From: Benchao Li
> Sent: Saturday, May 16, 2020 22:00
> To: dev
> Subject: Re: [VOTE] Guarantee that @PublicEvolving classes are API and
> binary compatible across bug f
Till Rohrmann created FLINK-17765:
-
Summary: Verbose client error messages
Key: FLINK-17765
URL: https://issues.apache.org/jira/browse/FLINK-17765
Project: Flink
Issue Type: Bug
Com
Jeff Zhang created FLINK-17763:
--
Summary: No log files when starting scala-shell
Key: FLINK-17763
URL: https://issues.apache.org/jira/browse/FLINK-17763
Project: Flink
Issue Type: Bug
xushiwei created FLINK-17764:
Summary: Update tips about the default planner when the parameter
planner is not recognized
Key: FLINK-17764
URL: https://issues.apache.org/jira/browse/FLINK-17764
Project: F
+1 (non-binding)
Yun Tang
From: Benchao Li
Sent: Saturday, May 16, 2020 22:00
To: dev
Subject: Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary
compatible across bug fix releases (x.y.u and x.y.v)
+1 (non-binding)
Piotr Nowojski 于2020年5月1
Leonard Xu created FLINK-17762:
--
Summary: Postgres Catalog should pass table's primary key to
catalogTable
Key: FLINK-17762
URL: https://issues.apache.org/jira/browse/FLINK-17762
Project: Flink
If we cannot get rid of union state, I think we should introduce memory control
on the serialized TDDs when deploying
tasks instead of how union state is implemented when assign state in
StateAssignmentOperation.
The duplicated TaskStateSnapshot would not really increase much memory as the
ByteS
Jiangjie Qin created FLINK-17761:
Summary: FutureCompletingBlockingQueue should have a capacity
limit.
Key: FLINK-17761
URL: https://issues.apache.org/jira/browse/FLINK-17761
Project: Flink
Zhu Zhu created FLINK-17760:
---
Summary: Rework tests to not rely on legacy scheduling logics in
ExecutionGraph anymore
Key: FLINK-17760
URL: https://issues.apache.org/jira/browse/FLINK-17760
Project: Flink
Zhu Zhu created FLINK-17759:
---
Summary: Remove RestartIndividualStrategy
Key: FLINK-17759
URL: https://issues.apache.org/jira/browse/FLINK-17759
Project: Flink
Issue Type: Sub-task
Compone
Zhu Zhu created FLINK-17758:
---
Summary: Remove AdaptedRestartPipelinedRegionStrategyNG
Key: FLINK-17758
URL: https://issues.apache.org/jira/browse/FLINK-17758
Project: Flink
Issue Type: Sub-task
+1 (non-binding)
Piotr Nowojski 于2020年5月16日周六 下午8:10写道：
> +1
>
> Piotrek
>
> > On 16 May 2020, at 13:21, Yu Li wrote:
> >
> > +1 (not sure whether my vote is binding, I guess yes since this is a
> > development-oriented vote?)
> >
> > Minor:
> > bq. This means that a version x.y.u is API and bi
Danny Chen created FLINK-17757:
--
Summary: Implement format factory for Avro serialization and
deseriazation schema of RowData type
Key: FLINK-17757
URL: https://issues.apache.org/jira/browse/FLINK-17757
Hi, Amr!
You can certainly apply for Google Season of Docs with the Flink project.
All you have to do is have a look at our project ideas [1], think about
what you'd be interested in working on and submit your application once the
application phase opens (June 9th) [2].
Let me know if there is an
Hi, Yuvraj!
Thanks for your interest in contributing to Flink during Google Season of
Docs!
You can start by reading FLIP-60 [1] and thinking about what areas of the
documentation you'd like to focus on. There is a lot of work to be done, so
there is some flexibility for you to choose topics that
Kurt Young created FLINK-17756:
--
Summary: Drop table/view shouldn't take affect on each other
Key: FLINK-17756
URL: https://issues.apache.org/jira/browse/FLINK-17756
Project: Flink
Issue Type: B
+1
Piotrek
> On 16 May 2020, at 13:21, Yu Li wrote:
>
> +1 (not sure whether my vote is binding, I guess yes since this is a
> development-oriented vote?)
>
> Minor:
> bq. This means that a version x.y.u is API and binary compatible to x.y.v
> with u <= v wrt all @PublicEvolving classes.
> I g
Hi, Roopal.
Thanks for reaching out, we're glad to see that you're interested in giving
the Flink docs a try!
To participate in Google Season of Docs (GSoD), you'll have to submit an
application once the application period opens (June 9th). Because FLIP-60
is very broad, the first step would be t
Thanks, Robert!
I made the wrong assumption that most people would be familiar with how
mailing lists work and should have been clearer in the announcement.
On Sat, May 16, 2020 at 8:35 AM Robert Metzger wrote:
> FYI: I'm a moderator of the dev@ list, and we've received about 5 emails
> from ap
+1 (not sure whether my vote is binding, I guess yes since this is a
development-oriented vote?)
Minor:
bq. This means that a version x.y.u is API and binary compatible to x.y.v
with u <= v wrt all @PublicEvolving classes.
I guess you mean "with u *>* v" to keep backward compatibility instead of
f
Hi,
I am trying to run individual unit test files, and every time it spends
lots of time(almost 4-5 minutes) on some build process, and then I get
error, like this:
Error running 'FlinkKafkaConsumerBaseTest': Command line is too long
I recently switched from IntelliJ Ulimate to CE. Can that be t
Okay, thank you for all the feedback.
So we should definitely work on getting rid of the Union State, or at least
change the way it is implemented (avoid duplicate serializer snapshots).
Can you estimate from which size of the cluster on the JM heap usage
becomes critical (if we increased the thr
Roey Shem Tov created FLINK-17755:
-
Summary: Expiring states should be given as side output
Key: FLINK-17755
URL: https://issues.apache.org/jira/browse/FLINK-17755
Project: Flink
Issue Type:
Definitely +1
Dian Fu 于2020年5月16日周六 下午5:48写道：
> +1 (non-binding)
>
> Regards,
> Dian
>
> > 在 2020年5月16日，下午2:33，Congxian Qiu 写道：
> >
> > +1 (non-binding)
> > Best,
> > Congxian
> >
> >
> > Yangze Guo 于2020年5月16日周六 上午12:51写道：
> >
> >> +1
> >>
> >> Best,
> >> Yangze Guo
> >>
> >> On Sat, May 16,
Piotr Nowojski created FLINK-17754:
--
Summary: Walkthrough Table Java nightly end-to-end test failed to
compile
Key: FLINK-17754
URL: https://issues.apache.org/jira/browse/FLINK-17754
Project: Flink
+1 for Monday morning in Europe.
Regards,
Dian
> 在 2020年5月16日，下午1:51，Congxian Qiu 写道：
>
> +1 for Monday morning in Europe.
> Best,
> Congxian
>
>
> Danny Chan 于2020年5月16日周六 上午10:40写道：
>
>> +1 for Monday morning in Europe.
>>
>> Best,
>> Danny Chan
>> 在 2020年5月15日 +0800 PM10:51，Zhijiang > .
+1 (non-binding)
Regards,
Dian
> 在 2020年5月16日，下午2:33，Congxian Qiu 写道：
>
> +1 (non-binding)
> Best,
> Congxian
>
>
> Yangze Guo 于2020年5月16日周六 上午12:51写道：
>
>> +1
>>
>> Best,
>> Yangze Guo
>>
>> On Sat, May 16, 2020 at 12:26 AM Yuan Mei wrote:
>>>
>>> +1
>>>
>>> On Sat, May 16, 2020 at 12
godfrey he created FLINK-17753:
--
Summary: watermark defined in ddl does not work in Table api
Key: FLINK-17753
URL: https://issues.apache.org/jira/browse/FLINK-17753
Project: Flink
Issue Type: B
Jark Wu created FLINK-17752:
---
Summary: Align the timestamp format with Flink SQL types in JSON
format
Key: FLINK-17752
URL: https://issues.apache.org/jira/browse/FLINK-17752
Project: Flink
Issue T
godfrey he created FLINK-17751:
--
Summary: proctime defined in ddl can't work with over window in
Table api
Key: FLINK-17751
URL: https://issues.apache.org/jira/browse/FLINK-17751
Project: Flink
Roman Khachatryan created FLINK-17750:
-
Summary:
YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint failed on azure
Key: FLINK-17750
URL: https://issues.apache.org/jira/browse/FLINK-17750
35 matches
Mail list logo
