zl created FLINK-26722:
--
Summary: the result is wrong when using file connector with csv
format
Key: FLINK-26722
URL: https://issues.apache.org/jira/browse/FLINK-26722
Project: Flink
Issue Type: Bug
zoucao created FLINK-26723:
--
Summary: Fix the content of exception in SourceCoordinatorContext
Key: FLINK-26723
URL: https://issues.apache.org/jira/browse/FLINK-26723
Project: Flink
Issue Type: Impr
Yun Gao created FLINK-26724:
---
Summary:
FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due
to Container startup failed
Key: FLINK-26724
URL: https://issues.apache.org/jira/browse/FLINK-26724
Timo Walther created FLINK-26725:
Summary: Support the new type inference in Scala Table API
aggregate functions
Key: FLINK-26725
URL: https://issues.apache.org/jira/browse/FLINK-26725
Project: Flink
zoucao created FLINK-26726:
--
Summary: Remove the unregistered task from readersAwaitingSplit
Key: FLINK-26726
URL: https://issues.apache.org/jira/browse/FLINK-26726
Project: Flink
Issue Type: Impro
Huang Xingbo created FLINK-26727:
Summary: Fix the implementation of sub-interpreter in Thread Mode
Key: FLINK-26727
URL: https://issues.apache.org/jira/browse/FLINK-26727
Project: Flink
Issu
Hi Guys:
FYI, I have integrated your comments and drawn the FLIP-215[1], I will
create another thread to vote for it.
[1]:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-215%3A+Introduce+FlinkSessionJob+CRD+in+the+kubernetes+operator
Best,
Aitozi.
Aitozi 于2022年3月17日周四 11:16写道：
>
CaoYu created FLINK-26728:
-
Summary: Support min operation in DataStream
Key: FLINK-26728
URL: https://issues.apache.org/jira/browse/FLINK-26728
Project: Flink
Issue Type: New Feature
Compo
CaoYu created FLINK-26730:
-
Summary: Support max operation in DataStream
Key: FLINK-26730
URL: https://issues.apache.org/jira/browse/FLINK-26730
Project: Flink
Issue Type: New Feature
Compo
CaoYu created FLINK-26729:
-
Summary: Support minby operation in DataStream
Key: FLINK-26729
URL: https://issues.apache.org/jira/browse/FLINK-26729
Project: Flink
Issue Type: New Feature
Com
CaoYu created FLINK-26731:
-
Summary: Support maxby operation in DataStream
Key: FLINK-26731
URL: https://issues.apache.org/jira/browse/FLINK-26731
Project: Flink
Issue Type: New Feature
Com
Hi community:
I'd like to start a vote on FLIP-215: Introduce FlinkSessionJob CRD in
the kubernetes operator [1] which has been discussed in the thread [2].
The vote will be open for at least 72 hours unless there is an objection or
not enough votes.
[1]:
https://cwiki.apache.org/confluence/d
jackylau created FLINK-26732:
Summary: DefaultResourceAllocationStrategy need more log info to
troubleshoot
Key: FLINK-26732
URL: https://issues.apache.org/jira/browse/FLINK-26732
Project: Flink
Marios Trivyzas created FLINK-26733:
---
Summary: Deprecate TableConfig ctor and use getDefault() instead
Key: FLINK-26733
URL: https://issues.apache.org/jira/browse/FLINK-26733
Project: Flink
Thank Aitozi, a FLIP might be an overkill at this point but no harm in
voting on it anyways :)
Looks good!
Gyula
On Fri, Mar 18, 2022 at 10:25 AM Aitozi wrote:
> Hi Guys:
>
> FYI, I have integrated your comments and drawn the FLIP-215[1], I will
> create another thread to vote for it.
>
>
zhangjingcun created FLINK-26734:
Summary: Various usage examples of adding window operation
Key: FLINK-26734
URL: https://issues.apache.org/jira/browse/FLINK-26734
Project: Flink
Issue Type:
I think this is a simple and valuable addition that will also be a building
block for other important future features.
+1
Gyula
On Fri, Mar 18, 2022 at 10:30 AM Aitozi wrote:
> Hi community:
> I'd like to start a vote on FLIP-215: Introduce FlinkSessionJob CRD in
> the kubernetes operator
Great work. Since we are introducing a new public API, it deserves a FLIP.
And the FLIP will help the later contributors catch up soon.
Best,
Yang
Gyula Fóra 于2022年3月18日周五 18:11写道：
> Thank Aitozi, a FLIP might be an overkill at this point but no harm in
> voting on it anyways :)
>
> Looks good!
+1(binding)
Thanks for your contribution.
Best,
Yang
Gyula Fóra 于2022年3月18日周五 18:44写道：
> I think this is a simple and valuable addition that will also be a building
> block for other important future features.
>
> +1
>
> Gyula
>
> On Fri, Mar 18, 2022 at 10:30 AM Aitozi wrote:
>
> > Hi commun
+1(non-binding)
Thanks for the work!
Best,
Biao Geng
Yang Wang 于2022年3月18日周五 19:01写道：
> +1(binding)
>
> Thanks for your contribution.
>
> Best,
> Yang
>
> Gyula Fóra 于2022年3月18日周五 18:44写道：
>
> > I think this is a simple and valuable addition that will also be a
> building
> > block for other i
Daniel Hristov created FLINK-26735:
--
Summary: RMQSource queueing mechanism leads to OOM
Key: FLINK-26735
URL: https://issues.apache.org/jira/browse/FLINK-26735
Project: Flink
Issue Type: Bug
+1 (non-binding)
nice addition to the operator
Cheers,
Matyas
On Fri, Mar 18, 2022 at 12:10 PM Biao Geng wrote:
> +1(non-binding)
> Thanks for the work!
>
> Best,
> Biao Geng
>
> Yang Wang 于2022年3月18日周五 19:01写道：
>
> > +1(binding)
> >
> > Thanks for your contribution.
> >
> > Best,
> > Yang
> >
Ryan Skraba created FLINK-26736:
---
Summary: [JUnit5 Migration] Module: flink-avro-confluent-registry
Key: FLINK-26736
URL: https://issues.apache.org/jira/browse/FLINK-26736
Project: Flink
Issue
Currently, when the execution of a stateful function fails, the call is
retried using an exponential backoff scheme -- the initial delay is 10ms
(original sync client) or 2ms (async Netty client), and it doubles on every
subsequent failure, without limit, until the call succeeds or its budgeted
tim
24 matches
Mail list logo
