Chesnay Schepler created FLINK-23659:
Summary: Cleanup Prometheus reporter
Key: FLINK-23659
URL: https://issues.apache.org/jira/browse/FLINK-23659
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-23658:
Summary: Cleanup JMX reporter
Key: FLINK-23658
URL: https://issues.apache.org/jira/browse/FLINK-23658
Project: Flink
Issue Type: Sub-task
C
Chesnay Schepler created FLINK-23657:
Summary: Cleanup metric reporter modules
Key: FLINK-23657
URL: https://issues.apache.org/jira/browse/FLINK-23657
Project: Flink
Issue Type: Technical
The Apache Flink community is very happy to announce the release of Apache
Flink 1.13.2, which is the second bugfix release for the Apache Flink 1.13
series.
Apache Flink® is an open-source stream processing framework for distributed,
high-performing, always-available, and accurate data stream
Yubin Li created FLINK-23656:
Summary: flink-sql-parser compile failed
Key: FLINK-23656
URL: https://issues.apache.org/jira/browse/FLINK-23656
Project: Flink
Issue Type: Bug
Components:
liwei li created FLINK-23655:
Summary: Custom transformation name displayed on the web, when
using Flink Table & SQL API, just like the name method of
SingleOutputStreamOperator , or remove the SQL content display directly.
Key: FLIN
Nicolas Raga created FLINK-23654:
Summary: Allow configuration for number of jobmanager-future
threads
Key: FLINK-23654
URL: https://issues.apache.org/jira/browse/FLINK-23654
Project: Flink
David Anderson created FLINK-23653:
--
Summary: improve training exercises and tests so they are better
examples
Key: FLINK-23653
URL: https://issues.apache.org/jira/browse/FLINK-23653
Project: Flink
Arvid Heise created FLINK-23652:
---
Summary: Implement FLIP-179
Key: FLINK-23652
URL: https://issues.apache.org/jira/browse/FLINK-23652
Project: Flink
Issue Type: Improvement
Components
Hi Dawid,
thanks for clarification. Having looked into the related classes again, I
agree that exposing the current StreamStatus would severly limit future
developments. I guess to expose it in the Sink, we would need to have a new
WatermarkStatus in eventtime package (as per Eron's suggestion) th
Dear devs,
I'd like to open a vote on FLIP-180: Adjust StreamStatus and Idleness
definition [1] which was discussed in this thread [2].
The vote will be open for at least 72 hours unless there is an objection or
not enough votes.
Best,
Arvid
[1]
https://cwiki.apache.org/confluence/display/FLINK
We are heavy users of RocksDB and have had several issues with memory
managed in Kubernetes, most of them actually went away when we upgraded
from Flink 1.9 to 1.13.
Do we know why there's such a huge performance regression? Can we improve
this somehow with some flag tweaking? It would be great if
Hi Yun,
Thank you for the elaborate explanation and even more so for the super hard
work that you're doing digging into RocksDB and chasing after hundreds of
commits in order to fix them so we can all benefit.
I can say for myself that optimizing towards memory is more important
ATM for us, and I'
Great to hear from everybody. I've created an invite for Thu, Aug 11, 9am
CEST and invited Gabor and Yangze. Let me know if somebody else wants to
join as well. I'll add her then to the calendar invite.
Cheers,
Till
On Thu, Aug 5, 2021 at 3:50 AM Yangze Guo wrote:
> Thanks Konstantin for bringi
Eelis Kostiainen created FLINK-23651:
Summary: Support RabbitMQ connectors in Python DataStream API
Key: FLINK-23651
URL: https://issues.apache.org/jira/browse/FLINK-23651
Project: Flink
JING ZHANG created FLINK-23650:
--
Summary: A sql contains 'Case when' could not run successfully
when choose Hive Dialect
Key: FLINK-23650
URL: https://issues.apache.org/jira/browse/FLINK-23650
Project: F
Hey all,
Just a couple of comments from my side as I was called here.
+1 for making stream status just about watermarks.
I observe that AbstractStreamOperator is hardcoded to derive the output
channel's status from the input channel's status. May I suggest
we refactor
"AbstractS
Stephan Ewen created FLINK-23649:
Summary: Add RocksDB packages to parent-first classloading
patterns.
Key: FLINK-23649
URL: https://issues.apache.org/jira/browse/FLINK-23649
Project: Flink
Piotr Nowojski created FLINK-23648:
--
Summary: Drop StreamTwoInputProcessor in favour of
StreamMultipleInputProcessor
Key: FLINK-23648
URL: https://issues.apache.org/jira/browse/FLINK-23648
Project: F
Roman Khachatryan created FLINK-23647:
-
Summary: UnalignedCheckpointStressITCase crashed on azure
Key: FLINK-23647
URL: https://issues.apache.org/jira/browse/FLINK-23647
Project: Flink
Is
Hi bowen,
Thanks for starting this discussion.
I think you can describe your design/implementation in detail. I understand
local_ref can help us optimize, but it still needs many details, such as
how to reuse function results in codegen. We need a cleaner solution to
avoid polluting our CodeGen c
Thanks liwei for the contribution.
I will take a look and help to merge~
Best,
Jingsong
On Thu, Aug 5, 2021 at 6:24 PM Till Rohrmann wrote:
> Hi Liwei,
>
> Thanks for helping the community. At the moment most of the committers are
> busy with finishing their work for the upcoming feature freez
Timo Walther created FLINK-23646:
Summary: Use pipeline name consistently across DataStream API and
Table API
Key: FLINK-23646
URL: https://issues.apache.org/jira/browse/FLINK-23646
Project: Flink
Hi,
At the moment many community members are busy with finishing their work for
the upcoming feature freeze. This can cause slow responsiveness on the JIRA
tickets. Once the feature freeze is past, people will surely get back to
you.
Cheers,
Till
On Mon, Aug 2, 2021 at 8:43 AM 卫博文 wrote:
> Hi,
Hi Liwei,
Thanks for helping the community. At the moment most of the committers are
busy with finishing their work for the upcoming feature freeze. This might
cause some delay in responses. We'll get back to your PR as soon as someone
has capacity.
cc Jark and Timo.
Cheers,
Till
On Sun, Aug 1,
Coming back to my previous comment: I would actually propose to separate
the discussion about whether to expose the WatermarkStatus in the sinks or
not from correcting the StreamStatus and Idleness definition in order to
keep the scope of this FLIP as small as possible. If there is a good reason
to
loyi created FLINK-23645:
Summary: Sqlclient doesn't response CTRL-C correctly before
Executor ResultView opening.
Key: FLINK-23645
URL: https://issues.apache.org/jira/browse/FLINK-23645
Project: Flink
Chesnay Schepler created FLINK-23644:
Summary: Resolve maven warnings for duplicate dependencies/plugins
Key: FLINK-23644
URL: https://issues.apache.org/jira/browse/FLINK-23644
Project: Flink
YUJIANBO created FLINK-23643:
Summary: I repeated the same problem: ROW/RANGE not allowed with
RANK, DENSE_RANK or ROW_NUMBER functions
Key: FLINK-23643
URL: https://issues.apache.org/jira/browse/FLINK-23643
xiaojin.wy created FLINK-23642:
--
Summary: A result of SELECT (not (CAST (((CAST
(IS_ALPHA(-421305765) AS BOOLEAN)) OR (CAST ((SHA1(CAST ('鲇T' AS STRING ))) AS
BOOLEAN))) AS BOOLEAN))) IS NULL should return true
Key: FLINK-23642
xiaojin.wy created FLINK-23641:
--
Summary: A bad data should not stop and fail the job
Key: FLINK-23641
URL: https://issues.apache.org/jira/browse/FLINK-23641
Project: Flink
Issue Type: Bug
Fabian Paul created FLINK-23640:
---
Summary: Create a KafkaRecordSerializationSchemas valueOnly helper
Key: FLINK-23640
URL: https://issues.apache.org/jira/browse/FLINK-23640
Project: Flink
Issue
Dear devs,
I would like to start a discussion for FLIP-186: Refactor
DataStreamUtils#reinterpretAsKeyedStream[1].
As we know, this API has a limitation that the partitioning of the base
stream must be exactly the same as Flink's internal partitioning[2].
Currently, Flink would first select the k
Fabian Paul created FLINK-23639:
---
Summary: Migrate Table API to new KafkaSink
Key: FLINK-23639
URL: https://issues.apache.org/jira/browse/FLINK-23639
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23638:
--
Summary: Field names are not kept after apply
ProjectToWindowRule#ProjectToLogicalProjectAndWindowRule
Key: FLINK-23638
URL: https://issues.apache.org/jira/browse/FLINK-23638
Till Rohrmann created FLINK-23637:
-
Summary: MeasurementInfoProviderTest.testNormalizingTags fails on
Azure
Key: FLINK-23637
URL: https://issues.apache.org/jira/browse/FLINK-23637
Project: Flink
Hi Piotr,
1. Can we push for better benchmark coverage in the RocksDB project in the
future?
2. Sure, I think we could contribute what we did in flink-benchmarks to
improve their JMH benchmark [1]. And I will ask them how often will they run
the benchmark.
1. Can we try to catch this
37 matches
Mail list logo
