Hi everyone,
>From the discussion, it seems to me that we have different opinions
whether to have an ASF umbrella repository or to host them outside of the
ASF. It also seems that this is not really the problem to solve. Since
there are many good arguments for either approach, we could simply star
JING ZHANG created FLINK-24708:
--
Summary: `ConvertToNotInOrInRule` has a bug which leads to wrong
result
Key: FLINK-24708
URL: https://issues.apache.org/jira/browse/FLINK-24708
Project: Flink
I
Hi Jingsong,
Thanks for creating this FLIP. I don't have a lot to add because I am not
very familiar with the SQL components. While reading the FLIP I was
wondering what would we need in Flink to build something like the BDT
feature outside of Flink as a kind of extension? Would something like thi
Thanks for creating this FLIP Sergey. I think what you propose sounds like
very good improvements for the SQL client. This should make the client a
lot more ergonomic :-)
Cheers,
Till
On Fri, Oct 29, 2021 at 11:26 AM Sergey Nuyanzin
wrote:
> Hi Martijn,
>
> Thank you for your suggestion with PO
Hi Lijie,
Thanks for drafting this FLIP together with Zhu Zhu :-)
I like the idea of making the parallelism of operators of a bounded job
dependent on the data size. This makes the job adjust automatically when
the data sources/sizes change.
I can see this work well in combination with the activ
Hi Jiangjie,
Thanks for the review! Please find below my explanations.
On Fri, Oct 29, 2021 at 8:49 PM Becket Qin wrote:
> Hi Dong and Zhiping,
>
> Thanks for writing up the FLIP and sorry for the belated review. The FLIP
> looks good to me overall. Just a few minor comments / questions about
David Morávek created FLINK-24707:
-
Summary: Upgrade Curator framework dependecy.
Key: FLINK-24707
URL: https://issues.apache.org/jira/browse/FLINK-24707
Project: Flink
Issue Type: Improvemen
Hi Dong and Zhiping,
Thanks for writing up the FLIP and sorry for the belated review. The FLIP
looks good to me overall. Just a few minor comments / questions about
WithParams.
1. Currently all the methods in the WithParams interface have a default
implementation. It is not clear to me what exact
Chesnay Schepler created FLINK-24706:
Summary: AkkaInvocationHandler silently ignores deserialization
errors
Key: FLINK-24706
URL: https://issues.apache.org/jira/browse/FLINK-24706
Project: Flink
HideOnBush created FLINK-24705:
--
Summary: Flink blood relationship
Key: FLINK-24705
URL: https://issues.apache.org/jira/browse/FLINK-24705
Project: Flink
Issue Type: New Feature
Compon
lincoln lee created FLINK-24704:
---
Summary: Exception occurs when the input record loses monotonicity
on the sort key field of UpdatableTopNFunction
Key: FLINK-24704
URL: https://issues.apache.org/jira/browse/FLINK-2
Alexander Fedulov created FLINK-24703:
-
Summary: Add support for reading CSV files based on StreamFormat
(new file source API)
Key: FLINK-24703
URL: https://issues.apache.org/jira/browse/FLINK-24703
Mathias Fußenegger created FLINK-24702:
--
Summary: toUpperCase/toLowerCase calls may cause problems with
some system locales
Key: FLINK-24702
URL: https://issues.apache.org/jira/browse/FLINK-24702
Caizhi Weng created FLINK-24701:
---
Summary: "late events" link in "Timely Stream Processing" document
is not working
Key: FLINK-24701
URL: https://issues.apache.org/jira/browse/FLINK-24701
Project: Flink
Hi Martijn,
Thank you for your suggestion with POC.
Yes I will do that and come back to this thread probably after the weekend
On Thu, Oct 28, 2021 at 4:38 PM Martijn Visser
wrote:
> Hi Sergey,
>
> Thanks for taking the initiative to create a FLIP and propose improvements
> on the SQL client. A
Thanks a lot @Chesnay, I would try again.
Chesnay Schepler 于2021年10月29日周五 下午4:21写道：
> When you 'run azure', check the build after a minute or so and you
> should see that the failed job is running again.
>
>
>
> On 29/10/2021 10:19, Chesnay Schepler wrote:
> > It's working just fine. You need to
Timo Walther created FLINK-24700:
Summary: Clarify semantics of filter, projection, partition, and
metadata pushdown
Key: FLINK-24700
URL: https://issues.apache.org/jira/browse/FLINK-24700
Project: Fl
Chesnay Schepler created FLINK-24699:
Summary: Move scalastyle execution to validation phase
Key: FLINK-24699
URL: https://issues.apache.org/jira/browse/FLINK-24699
Project: Flink
Issue T
When you 'run azure', check the build after a minute or so and you
should see that the failed job is running again.
On 29/10/2021 10:19, Chesnay Schepler wrote:
It's working just fine. You need to rebase your branch because on your
branch flink-python is simply broken.
On 29/10/2021 08:57,
It's working just fine. You need to rebase your branch because on your
branch flink-python is simply broken.
On 29/10/2021 08:57, JING ZHANG wrote:
Hi Chesnay,
I meet with something weird.
I submit a pull request https://github.com/apache/flink/pull/17571, it
trigger a ci
(https://dev.azure.c
jianzhang.yjz created FLINK-24698:
-
Summary: Unified operator used in transformation
Key: FLINK-24698
URL: https://issues.apache.org/jira/browse/FLINK-24698
Project: Flink
Issue Type: Improve
Hang Ruan created FLINK-24697:
-
Summary: Kafka table source cannot change the auto.offset.reset
setting
Key: FLINK-24697
URL: https://issues.apache.org/jira/browse/FLINK-24697
Project: Flink
Iss
Piotr Nowojski created FLINK-24696:
--
Summary: Translate how to configure unaligned checkpoints into
Chinese
Key: FLINK-24696
URL: https://issues.apache.org/jira/browse/FLINK-24696
Project: Flink
Piotr Nowojski created FLINK-24695:
--
Summary: Update how to configure unaligned checkpoints in the
documentation
Key: FLINK-24695
URL: https://issues.apache.org/jira/browse/FLINK-24695
Project: Flink
Piotr Nowojski created FLINK-24694:
--
Summary: Translate "Checkpointing under backpressure" page into
Chinese
Key: FLINK-24694
URL: https://issues.apache.org/jira/browse/FLINK-24694
Project: Flink
Piotr Nowojski created FLINK-24693:
--
Summary: Update Chinese version of "Checkpoints" page
Key: FLINK-24693
URL: https://issues.apache.org/jira/browse/FLINK-24693
Project: Flink
Issue Type:
249968...@qq.com
sh_0...@126.com
Zhou Parker created FLINK-24692:
---
Summary: kubernetes session mode deployment failed since slot
allocation timeout
Key: FLINK-24692
URL: https://issues.apache.org/jira/browse/FLINK-24692
Project: Flink
29 matches
Mail list logo
