Robert Metzger created FLINK-19534:
--
Summary: build_wheels: linux failed with "ValueError: Incompatible
component merge"
Key: FLINK-19534
URL: https://issues.apache.org/jira/browse/FLINK-19534
Projec
This sounds good. Maybe there are others in the community who can help with
the review before the Jark and Leonard are back.
Cheers,
Till
On Wed, Oct 7, 2020 at 7:33 PM Dylan Forciea wrote:
> Actually…. It looks like what I did covers both cases. I’ll see about
> getting some unit tests and doc
Jiangjie Qin created FLINK-19535:
Summary: SourceCoordinator should avoid fail job multiple times.
Key: FLINK-19535
URL: https://issues.apache.org/jira/browse/FLINK-19535
Project: Flink
Issue
java.lang.NoSuchMethodError:
org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest.newInstance(IFLjava/util/List;Ljava/util/List;Ljava/util/List;Lorg/apache/hadoop/yarn/api/records/ResourceBlacklistRequest;)Lorg/apache/hadoop/yarn/api/protocolrecords/AllocateRequest;
at
org.apache.hadoo
Hello, I'm having trouble finding a way to add logic to an existing
SinkFunction.
What I would like to do is wrap an input SinkFunction inside another one that
will perform its logic and then perform some additional logic, e.g.:
SinkFunction wrapFunction(SinkFunction function) {
return new Si
Arvid Heise created FLINK-19536:
---
Summary: Fix inconsistent priority notification
Key: FLINK-19536
URL: https://issues.apache.org/jira/browse/FLINK-19536
Project: Flink
Issue Type: Bug
Affe
Piotr Nowojski created FLINK-19537:
--
Summary: Processed in-flight bytes metric is not accurate
Key: FLINK-19537
URL: https://issues.apache.org/jira/browse/FLINK-19537
Project: Flink
Issue Ty
Seth Wiesman created FLINK-19538:
Summary: Support more complex routers in remote ingress definitions
Key: FLINK-19538
URL: https://issues.apache.org/jira/browse/FLINK-19538
Project: Flink
Is
Roman Khachatryan created FLINK-19539:
-
Summary: JMXReporterFactoryTest fails on Azure
Key: FLINK-19539
URL: https://issues.apache.org/jira/browse/FLINK-19539
Project: Flink
Issue Type: B
I’ve updated the unit tests and documentation, and I was running the azure test
pipeline as described in the instructions. However, it appears that what seems
to be an unrelated test for the JMX code failed. Is this a matter of me not
setting things up correctly? I wanted to ensure everything lo
Xinhao Li created FLINK-19540:
-
Summary: How to reduce or disable checkpoint logs in Flink
Key: FLINK-19540
URL: https://issues.apache.org/jira/browse/FLINK-19540
Project: Flink
Issue Type: Impro
I think any solution here is inherently fragile since future versions of
flink can have different abstract classes or interfaces you won't know it
has to support. But for a given release, something you can consider is a
wrapper class that extends/implements the ones you support. Then, during
the me
Jingsong Lee created FLINK-19541:
Summary: Improve hiveConfDir for HiveCatalog
Key: FLINK-19541
URL: https://issues.apache.org/jira/browse/FLINK-19541
Project: Flink
Issue Type: Task
Hi,
This exception is because you don't have proper HBase dependency in your
cluster.
Please refer to the HBase documentation about how to add HBase dependency
jars to HADOOP_CLASSPATH.
Flink will load all jars under HADOOP_CLASSPATH automatically.
Btw, dev mailing list is used for discussing dev
Hi devs,
I'm happy to announce that FLIP-144[1] is officially approved.
The vote has been opened for more than 72h + weekends, and we have
received 4 votes, 3 of which are binding, and no vetos. Thanks everyone for
participating.
* Till (binding)
* tison (binding)
* Xintong (binding)
* Yang Wang
Yang Wang created FLINK-19542:
-
Summary: Implement LeaderElectionService and
LeaderRetrievalService based on Kubernetes API
Key: FLINK-19542
URL: https://issues.apache.org/jira/browse/FLINK-19542
Project:
Yang Wang created FLINK-19543:
-
Summary: Implement RunningJobsRegistry, JobGraphStore based on
Kubernetes API
Key: FLINK-19543
URL: https://issues.apache.org/jira/browse/FLINK-19543
Project: Flink
Yang Wang created FLINK-19544:
-
Summary: Implement CheckpointRecoveryFactory based on Kubernetes
API
Key: FLINK-19544
URL: https://issues.apache.org/jira/browse/FLINK-19544
Project: Flink
Issue
Yang Wang created FLINK-19545:
-
Summary: Add e2e test for native Kubernetes HA
Key: FLINK-19545
URL: https://issues.apache.org/jira/browse/FLINK-19545
Project: Flink
Issue Type: Sub-task
Yang Wang created FLINK-19546:
-
Summary: Add document for native Kubernetes HA
Key: FLINK-19546
URL: https://issues.apache.org/jira/browse/FLINK-19546
Project: Flink
Issue Type: Sub-task
Hi Dylan,
Sorry for the late reply. We've just come back from a long holiday.
Thanks for reporting this problem. First, I think this is a bug that
`autoCommit` is false by default (JdbcRowDataInputFormat.Builder).
We can fix the default to true in 1.11 series, and I think this can solve
your prob
Yuan Mei created FLINK-19547:
Summary: Partial record clean Up after receiver task fails and
restart
Key: FLINK-19547
URL: https://issues.apache.org/jira/browse/FLINK-19547
Project: Flink
Issue
fa zheng created FLINK-19548:
Summary: Report correct progress to yarn resource manager
Key: FLINK-19548
URL: https://issues.apache.org/jira/browse/FLINK-19548
Project: Flink
Issue Type: Improvem
Di Xu created FLINK-19549:
-
Summary: [CI] ##[error]The job running on agent Azure Pipelines 5
ran longer than the maximum time of 260 minutes.
Key: FLINK-19549
URL: https://issues.apache.org/jira/browse/FLINK-19549
Congratulations!
Zhu Zhu 于2020年10月7日周三 下午8:05写道：
> Thank you all! It's my great pleasure to work with you to
> continuously improve Flink and grow the community!
>
> Thanks,
> Zhu
>
> Matthias Pohl 于2020年10月6日周二 下午9:39写道：
>
> > Congratulations! :)
> >
> > Best,
> > Matthias
> >
> > On Tue, Oct
Congratulations! Zhu Zhu.
Best,
Yangze Guo
On Fri, Oct 9, 2020 at 12:58 PM Benchao Li wrote:
>
> Congratulations!
>
> Zhu Zhu 于2020年10月7日周三 下午8:05写道：
>
> > Thank you all! It's my great pleasure to work with you to
> > continuously improve Flink and grow the community!
> >
> > Thanks,
> > Zhu
>
Congrats, Zhu Zhu ~
Best,
Danny Chan
在 2020年10月9日 +0800 PM1:05，dev@flink.apache.org，写道：
>
> Congrats, Zhu Zhu
Roman Khachatryan created FLINK-19550:
-
Summary: StreamingFileSink can't be interrupted when writing to S3
Key: FLINK-19550
URL: https://issues.apache.org/jira/browse/FLINK-19550
Project: Flink
Hi, devs & users
As discussed in FLIP-131 [1], Flink will make DataStream the unified API for
processing bounded and unbounded data in both streaming and blocking modes.
However, one long-standing problem for the streaming mode is that currently
Flink does not support checkpoints after some tas
Congratulations, Zhu！
Best
Yun Tang
From: Danny Chan
Sent: Friday, October 9, 2020 13:51
To: dev@flink.apache.org
Subject: Re: [ANNOUNCE] New PMC member: Zhu Zhu
Congrats, Zhu Zhu ~
Best,
Danny Chan
在 2020年10月9日 +0800 PM1:05，dev@flink.apache.org，写道：
>
> Congrat
Hi, devs & users
Very sorry for the spoiled formats, I resent the discussion as follows.
As discussed in FLIP-131[1], Flink will make DataStream the unified API for
processing bounded and unbounded data in both streaming and blocking modes.
However, one long-standing problem for the streaming m
Zhijiang created FLINK-19551:
Summary: Follow up improvements for shuffle service
Key: FLINK-19551
URL: https://issues.apache.org/jira/browse/FLINK-19551
Project: Flink
Issue Type: Improvement
32 matches
Mail list logo
