Hi Jark
Thanks a lot!
Regards!
Aron Tao
Jark Wu 于2020年11月3日周二 下午2:45写道：
> Sorry for the late reviewing. The community is busy preparing for 1.12
> release.
> I guess this is the reason that this PR was missed to review.
> I will help to review this PR later.
>
> Thanks for the contribution!
CloseRiver created FLINK-19947:
--
Summary: Support sink parallelism configuration to Print connector
Key: FLINK-19947
URL: https://issues.apache.org/jira/browse/FLINK-19947
Project: Flink
Issue
CloseRiver created FLINK-19945:
--
Summary: Support sink parallelism configuration to FileSystem
connector
Key: FLINK-19945
URL: https://issues.apache.org/jira/browse/FLINK-19945
Project: Flink
CloseRiver created FLINK-19946:
--
Summary: Support sink parallelism configuration to Hbase connector
Key: FLINK-19946
URL: https://issues.apache.org/jira/browse/FLINK-19946
Project: Flink
Issue
CloseRiver created FLINK-19944:
--
Summary: Support sink parallelism configuration to Hive connector
Key: FLINK-19944
URL: https://issues.apache.org/jira/browse/FLINK-19944
Project: Flink
Issue
CloseRiver created FLINK-19943:
--
Summary: Support sink parallelism configuration to ElasticSearch
connector
Key: FLINK-19943
URL: https://issues.apache.org/jira/browse/FLINK-19943
Project: Flink
CloseRiver created FLINK-19942:
--
Summary: Support sink parallelism configuration to JDBC connector
Key: FLINK-19942
URL: https://issues.apache.org/jira/browse/FLINK-19942
Project: Flink
Issue
CloseRiver created FLINK-19941:
--
Summary: Support sink parallelism configuration to Kafka connector
Key: FLINK-19941
URL: https://issues.apache.org/jira/browse/FLINK-19941
Project: Flink
Issue
Sorry for the late reviewing. The community is busy preparing for 1.12
release.
I guess this is the reason that this PR was missed to review.
I will help to review this PR later.
Thanks for the contribution!
Best,
Jark
On Tue, 3 Nov 2020 at 10:36, JiaTao Tao wrote:
> Here I fix a potential
Caizhi Weng created FLINK-19940:
---
Summary: Task names on web UI should change when an operator chain
is chained with sources
Key: FLINK-19940
URL: https://issues.apache.org/jira/browse/FLINK-19940
Caizhi Weng created FLINK-19939:
---
Summary: Remove redundant union from multiple input node
Key: FLINK-19939
URL: https://issues.apache.org/jira/browse/FLINK-19939
Project: Flink
Issue Type:
Yingjie Cao created FLINK-19938:
---
Summary: Implement shuffle data read scheduling for sort-merge
blocking shuffle
Key: FLINK-19938
URL: https://issues.apache.org/jira/browse/FLINK-19938
Project: Flink
Lsw_aka_laplace created FLINK-19937:
---
Summary: Support sink parallelism for all connectors
Key: FLINK-19937
URL: https://issues.apache.org/jira/browse/FLINK-19937
Project: Flink
Issue
Guowei Ma created FLINK-19936:
-
Summary: Make SinkITCase more stable
Key: FLINK-19936
URL: https://issues.apache.org/jira/browse/FLINK-19936
Project: Flink
Issue Type: Sub-task
Here I fix a potential NPE and contributed my patch, but no one reviewed
after several months (https://github.com/apache/flink/pull/12702), this PR
has conflicts, so I pull a new one (
https://github.com/apache/flink/pull/13836), would someone be nice to take
a look at this?
Regards!
Aron Tao
harold.miao created FLINK-19935:
---
Summary: OOM error occur for sql-client sumit job without JVM heap
setting
Key: FLINK-19935
URL: https://issues.apache.org/jira/browse/FLINK-19935
Project: Flink
Hi,
I'm trying to integrate a dependency injection framework with flink. When I
searched the user-mailing list, I found the following thread in flink which
discussed this in the past:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dependency-Injection-and-Flink-td18880.html
Steven Zhen Wu created FLINK-19934:
--
Summary: [FLIP-27 source] add new API:
SplitEnumeratorContext.execute(Runnable)
Key: FLINK-19934
URL: https://issues.apache.org/jira/browse/FLINK-19934
Project:
Stephan, thanks a lot for explaining the file connector. that makes sense.
I was asking because we were trying to reuse some of the implementations in
the file source for Iceberg source. Flink Iceberg source lives in the
Iceberg repo, which is not possible to code against the master branch of
the
Seth Wiesman created FLINK-19933:
Summary: Execute and collect with limit fails on bounded
datastream jobs
Key: FLINK-19933
URL: https://issues.apache.org/jira/browse/FLINK-19933
Project: Flink
Aljoscha Krettek created FLINK-19932:
Summary: Add integration test for BATCH execution on DataStream API
Key: FLINK-19932
URL: https://issues.apache.org/jira/browse/FLINK-19932
Project: Flink
Dawid Wysakowicz created FLINK-19931:
Summary: Do not emit intermediate results for reduce operation
BATCH execution mode
Key: FLINK-19931
URL: https://issues.apache.org/jira/browse/FLINK-19931
Chesnay Schepler created FLINK-19930:
Summary: Upgrade cassandra-driver-core to 4.X
Key: FLINK-19930
URL: https://issues.apache.org/jira/browse/FLINK-19930
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-19929:
Summary: Upgrade Kinesis dependencies to avoid protobuf 2.6.1
Key: FLINK-19929
URL: https://issues.apache.org/jira/browse/FLINK-19929
Project: Flink
Robert Metzger created FLINK-19928:
--
Summary: Introduce test configuration to detect instabilities
better
Key: FLINK-19928
URL: https://issues.apache.org/jira/browse/FLINK-19928
Project: Flink
Hi Steven!
So far there are no plans to pick back the file system connector code. This
is still evolving and not finalized for 1.12, so I don't feel it is a good
candidate to be backported.
However, with the base connector changes backported, you should be able to
run the file connector code from
Congrats Congxian!
Cheers, Fabian
Am Mo., 2. Nov. 2020 um 10:33 Uhr schrieb Yang Wang :
> Congratulations Congxian!
>
> Best,
> Yang
>
> Zhu Zhu 于2020年11月2日周一 下午5:14写道：
>
> > Congrats Congxian!
> >
> > Thanks,
> > Zhu
> >
> > Pengcheng Liu 于2020年11月2日周一 下午5:01写道：
> >
> > > Congratulations
Hi,
We’re currently thinking about releasing StateFun 2.2.1, to address a
critical bug that causes restores from checkpoints / savepoints to fail
under certain circumstances [1].
To provide a bit more context, the full fix for this issue is two-fold:
1. *Fix restoring from checkpoints /
Robert Metzger created FLINK-19927:
--
Summary: ExecutionStateUpdateListener is only updated when legacy
scheduling is enabled
Key: FLINK-19927
URL: https://issues.apache.org/jira/browse/FLINK-19927
Satyam Shekhar created FLINK-19926:
--
Summary: Wrong results for join post tumble grouping
Key: FLINK-19926
URL: https://issues.apache.org/jira/browse/FLINK-19926
Project: Flink
Issue Type:
godfrey he created FLINK-19925:
--
Summary: Errors$NativeIoException: readAddress(..) failed:
Connection reset by peer
Key: FLINK-19925
URL: https://issues.apache.org/jira/browse/FLINK-19925
Project:
Roman Khachatryan created FLINK-19924:
-
Summary: Disallow unaligned checkpoints for iterative jobs
Key: FLINK-19924
URL: https://issues.apache.org/jira/browse/FLINK-19924
Project: Flink
Andrey Zagrebin created FLINK-19923:
---
Summary: Remove BulkSlotProvider, its implementation and tests
Key: FLINK-19923
URL: https://issues.apache.org/jira/browse/FLINK-19923
Project: Flink
Congratulations Congxian!
Best,
Yang
Zhu Zhu 于2020年11月2日周一 下午5:14写道：
> Congrats Congxian!
>
> Thanks,
> Zhu
>
> Pengcheng Liu 于2020年11月2日周一 下午5:01写道：
>
> > Congratulations Congxian!
> >
> > Matthias Pohl 于2020年11月2日周一 下午3:57写道：
> >
> > > Yup, congratulations Congxian!
> > >
> > > On Mon, Nov
Zhu Zhu created FLINK-19922:
---
Summary: Remove SlotProvider from SchedulerNG
Key: FLINK-19922
URL: https://issues.apache.org/jira/browse/FLINK-19922
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19921:
---
Summary: Remove legacy RestartStrategy
Key: FLINK-19921
URL: https://issues.apache.org/jira/browse/FLINK-19921
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19920:
---
Summary: Remove legacy FailoverStrategy
Key: FLINK-19920
URL: https://issues.apache.org/jira/browse/FLINK-19920
Project: Flink
Issue Type: Sub-task
Zhu Zhu created FLINK-19919:
---
Summary: Remove legacy scheduling in ExecutionGraph components
Key: FLINK-19919
URL: https://issues.apache.org/jira/browse/FLINK-19919
Project: Flink
Issue Type:
Congrats Congxian!
Thanks,
Zhu
Pengcheng Liu 于2020年11月2日周一 下午5:01写道：
> Congratulations Congxian!
>
> Matthias Pohl 于2020年11月2日周一 下午3:57写道：
>
> > Yup, congratulations Congxian!
> >
> > On Mon, Nov 2, 2020 at 8:46 AM Danny Chan wrote:
> >
> > > Congrats, Doctor Qiu! Well deserved!
> > >
> > >
Congratulations Congxian!
Matthias Pohl 于2020年11月2日周一 下午3:57写道：
> Yup, congratulations Congxian!
>
> On Mon, Nov 2, 2020 at 8:46 AM Danny Chan wrote:
>
> > Congrats, Doctor Qiu! Well deserved!
> >
> > Congxian Qiu 于2020年10月31日周六 下午9:45写道：
> >
> > > Thanks all for the support. It's a great
Andrey Zagrebin created FLINK-19918:
---
Summary: RocksIncrementalCheckpointRescalingTest.testScalingDown
fails on Windows
Key: FLINK-19918
URL: https://issues.apache.org/jira/browse/FLINK-19918
Andrey Zagrebin created FLINK-19917:
---
Summary: RocksDBInitTest.testTempLibFolderDeletedOnFail fails on
Windows
Key: FLINK-19917
URL: https://issues.apache.org/jira/browse/FLINK-19917
Project:
Jingsong Lee created FLINK-19916:
Summary: Hadoop3 ShutdownHookManager visit closed ClassLoader
Key: FLINK-19916
URL: https://issues.apache.org/jira/browse/FLINK-19916
Project: Flink
Issue
43 matches
Mail list logo
