Hi all,
The issue has been discussed before here -
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Sharing-state-between-subtasks-td24489.html
Our use case requires event time join of two streams and we use
ConnectedStreams for the same. Within the CoProcessFunction, we buffer
reco
Yi Tang created FLINK-21942:
---
Summary: KubernetesLeaderRetrievalDriver not closed after
terminated which lead to connection leak
Key: FLINK-21942
URL: https://issues.apache.org/jira/browse/FLINK-21942
Proje
Guowei Ma created FLINK-21941:
-
Summary: testSavepointRescalingOutPartitionedOperatorStateList fail
Key: FLINK-21941
URL: https://issues.apache.org/jira/browse/FLINK-21941
Project: Flink
Issue Ty
Jingsong Lee created FLINK-21940:
Summary: Rowtime/proctime should be obtained from getTimestamp
instead of getLong
Key: FLINK-21940
URL: https://issues.apache.org/jira/browse/FLINK-21940
Project: Fli
Dian Fu created FLINK-21939:
---
Summary: Support batch mode in Python DataStream API for process
operation
Key: FLINK-21939
URL: https://issues.apache.org/jira/browse/FLINK-21939
Project: Flink
Issu
Also noticed the actual states stored in _metadata still contains entropy
marker after we fix metadata directory issue. This issue seems related to
code refactory as well as doesn't conveyed in tests.
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Dian Fu created FLINK-21938:
---
Summary: Add documentation about how to test Python UDFs
Key: FLINK-21938
URL: https://issues.apache.org/jira/browse/FLINK-21938
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-21937:
---
Summary: Support batch mode in Python DataStream API for basic
operations
Key: FLINK-21937
URL: https://issues.apache.org/jira/browse/FLINK-21937
Project: Flink
Issue
Arvid Heise created FLINK-21936:
---
Summary: Disable checkpointing of inflight data in pointwise
connections for unaligned checkpoints
Key: FLINK-21936
URL: https://issues.apache.org/jira/browse/FLINK-21936
Hi Dawid,
Thanks for the heads up.
Regarding the "Rebase and merge" button. I find that merge option useful,
especially for small simple changes and for backports. The following should
help to safeguard from the issue encountered previously:
https://github.com/jazzband/pip-tools/issues/1085
Than
make it easier to read
@Nullable
private static EntropyInjectingFileSystem getEntropyFs(FileSystem fs) {
LOG.warn(fs.getClass().toGenericString());
if (fs instanceof EntropyInjectingFileSystem) {
return (EntropyInjectingFileSy
Stephan Ewen created FLINK-21935:
Summary: Remove "state.backend.async" option.
Key: FLINK-21935
URL: https://issues.apache.org/jira/browse/FLINK-21935
Project: Flink
Issue Type: Improvement
Hi Till,
Thanks for sharing pointers related to entropy injection feature on 1.11.
We did some investigation and so far it seems like an edge case handling
bug.
Testing Environment:
flink 1.11.2 release with plugins
plugins/s3-fs-hadoop/flink-s3-fs-hadoop
state.backend.rocksdb.timer-service.fac
unsubscribe
Leonard Xu (Jira) 于2021年3月16日周二 下午8:05写道：
> Leonard Xu created FLINK-21820:
> --
>
> Summary: JDBC connector shouldn't read all rows in per
> statement by default
> Key: FLINK-21820
> URL: https://issues.a
Timo Walther created FLINK-21934:
Summary: Add new StreamTableEnvironment.toDataStream
Key: FLINK-21934
URL: https://issues.apache.org/jira/browse/FLINK-21934
Project: Flink
Issue Type: Sub-t
Danny Cranmer created FLINK-21933:
-
Summary: [kinesis][efo] EFO consumer treats interrupts as
retryable exceptions
Key: FLINK-21933
URL: https://issues.apache.org/jira/browse/FLINK-21933
Project: Flin
Igal Shilman created FLINK-21932:
Summary: Add a Python SDK showcase to the playground
Key: FLINK-21932
URL: https://issues.apache.org/jira/browse/FLINK-21932
Project: Flink
Issue Type: Task
Matthias created FLINK-21931:
Summary: Watermark documentation needs to be fixed
Key: FLINK-21931
URL: https://issues.apache.org/jira/browse/FLINK-21931
Project: Flink
Issue Type: Bug
C
hehuiyuan created FLINK-21930:
-
Summary: There are some error for hive_read_writer.md
Key: FLINK-21930
URL: https://issues.apache.org/jira/browse/FLINK-21930
Project: Flink
Issue Type: Wish
Robert Metzger created FLINK-21929:
--
Summary: flink-statebackend-rocksdb crashes with Error occurred in
starting fork
Key: FLINK-21929
URL: https://issues.apache.org/jira/browse/FLINK-21929
Project:
Hi devs, users!
1. *Feature freeze date*
We are approaching the end of March which we agreed would be the time
for a Feature Freeze. From the knowledge I've gather so far it still
seems to be a viable plan. I think it is a good time to agree on a
particular date, when it should happen. We suggest
Hi,
I discussed with Xingtong and Yingjie offline and we agreed that the name
`taskmanager.memory.framework.off-heap.batch-shuffle.size` can better
reflect the current memory usage. So we decided to use the name Till
suggested.
Thank you all for your valuable feedback.
Best,
Guowei
On Mon, Mar 22
Ufuk Celebi created FLINK-21928:
---
Summary: DuplicateJobSubmissionException after JobManager failover
Key: FLINK-21928
URL: https://issues.apache.org/jira/browse/FLINK-21928
Project: Flink
Issue
runsun created FLINK-21927:
--
Summary: ExpressionReducer compile fail when running long term
Key: FLINK-21927
URL: https://issues.apache.org/jira/browse/FLINK-21927
Project: Flink
Issue Type: Bug
Xintong Song created FLINK-21926:
Summary: Document Fine Grained Resource Management
Key: FLINK-21926
URL: https://issues.apache.org/jira/browse/FLINK-21926
Project: Flink
Issue Type: Sub-tas
Xintong Song created FLINK-21925:
Summary: Support configuring fine grained resource requirements
via DataStream API
Key: FLINK-21925
URL: https://issues.apache.org/jira/browse/FLINK-21925
Project: Fl
Thanks everyone for your votes!
The proposal has passed with the following votes:
+1 (Binding): 3 (Becket, Till, Dian)
+1 (Non-binding): 0
-1: 0
Thanks,
Dong
On Mon, Mar 22, 2021 at 7:34 PM Dian Fu wrote:
> +1
>
> Regards,
> Dian
>
> On Fri, Mar 19, 2021 at 6:39 PM Till Rohrmann
> wrote:
>
>
Xintong Song created FLINK-21924:
Summary: Fine Grained Resource Management
Key: FLINK-21924
URL: https://issues.apache.org/jira/browse/FLINK-21924
Project: Flink
Issue Type: New Feature
Hi everyone,
The discussion has stalled a bit on this thread. I would proceed to a vote
on the currently documented proposal tomorrow if there are no further
concerns or opinions.
Best,
Konstantin
On Fri, Mar 12, 2021 at 5:24 PM Konstantin Knauf wrote:
> Hi Leonard,
>
> Thank you for your fee
29 matches
Mail list logo
