Jark Wu created FLINK-19948:
---
Summary: CAST(now() as bigint) throws compile exception
Key: FLINK-19948
URL: https://issues.apache.org/jira/browse/FLINK-19948
Project: Flink
Issue Type: Bug
Danny Chen created FLINK-19949:
--
Summary: Unescape CSV format line delimiter character
Key: FLINK-19949
URL: https://issues.apache.org/jira/browse/FLINK-19949
Project: Flink
Issue Type: Improvem
I'm answering your user ML mail. Please only ask your question once.
Dev ML is only used to coordinate Flink development, which kinda makes
sense in your case after we verified in your first thread that indeed Flink
should provide such things.
On Tue, Nov 3, 2020 at 3:14 AM santhosh venkat
wrote
jackylau created FLINK-19950:
Summary: LookupJoin can not support view or subquery and so on. o
Key: FLINK-19950
URL: https://issues.apache.org/jira/browse/FLINK-19950
Project: Flink
Issue Type:
Hi devs,
I'd like to start a new FLIP to introduce the Hybrid Source. The hybrid
source is a source that contains a list of concrete sources. The hybrid
source reads from each contained source in the defined order. It switches
from source A to the next source B when source A finishes.
In practice
Robert Metzger created FLINK-19951:
--
Summary: PyFlink end-to-end test stuck in "Reading kafka messages"
Key: FLINK-19951
URL: https://issues.apache.org/jira/browse/FLINK-19951
Project: Flink
jackylau created FLINK-19952:
Summary: flink SecurityOptions.class use depracted method so mant
times
Key: FLINK-19952
URL: https://issues.apache.org/jira/browse/FLINK-19952
Project: Flink
Issue
Hi Gordon,
Thanks for driving this discussion!
I would go with the second suggestion - having two consecutive StateFun
releases 2.2.1 and 2.2.2, since the Flink-1.11.3 release
might take a while, and this hot-fix release is important enough to get out
as early as possible.
Cheers,
Igal.
On Mo
@Steven would it be possible to initially copy some of the code into the
iceberg source and later replace it by a dependency on the Flink file
source?
On Mon, Nov 2, 2020 at 8:33 PM Steven Wu wrote:
> Stephan, thanks a lot for explaining the file connector. that makes sense.
>
> I was asking bec
Matthias created FLINK-19953:
Summary: Translation in docs/ops/memory/mem_setup.zh.md
Key: FLINK-19953
URL: https://issues.apache.org/jira/browse/FLINK-19953
Project: Flink
Issue Type: Improvemen
Andrey Zagrebin created FLINK-19954:
---
Summary: Move execution deployment tracking logic from legacy EG
code to SchedulerNG
Key: FLINK-19954
URL: https://issues.apache.org/jira/browse/FLINK-19954
Pro
Thanks a lot for starting this thread.
How many users are affected by the problem? Is it somebody else besides the
initial issue reporter?
If it is just one person, I would suggest to rather help pushing the 1.11.3
release over the line or work on more StateFun features ;)
On Tue, Nov 3, 2020 at 1
Hi guys:
refer:
https://stackoverflow.com/questions/13027475/cpu-and-memory-usage-of-jemalloc-as-compared-to-glibc-malloc
code: https://github.com/jemalloc/jemalloc-experiments
https://code.woboq.org/userspace/glibc/benchtests/
Best Regards!
Billy xie(谢志民)
On Fri, Oct
Hi Robert,
So far we've only seen a single user report the issue, but the severity of
FLINK-19692 is actually pretty huge.
TL;DR: If a checkpoint / savepoint that contains feedback events (which is
considered normal under typical StateFun operations) is attempted to be
restored from, the restore w
Hi Gordon,
thanks a lot for this clarification.
In this case I would vote for releasing StateFun 2.2.1 asap and not wait
for 1.11.3.
Thanks a lot for your efforts!
On Tue, Nov 3, 2020 at 3:38 PM Tzu-Li (Gordon) Tai
wrote:
> Hi Robert,
>
> So far we've only seen a single user report the issue,
Robert Metzger created FLINK-19955:
--
Summary: Document cross-version compatibility
Key: FLINK-19955
URL: https://issues.apache.org/jira/browse/FLINK-19955
Project: Flink
Issue Type: Improvem
@Stephan Ewen yeah, we can do that. don't worry about
it. your earlier email had the perfect explanation on why file source
shouldn't be backported.
On Tue, Nov 3, 2020 at 3:37 AM Stephan Ewen wrote:
> @Steven would it be possible to initially copy some of the code into the
> iceberg source and
Hi devs,
I'd like to start a discussion of FLIP-151: Incremental snapshots for
heap-based state backend [1]
Heap backend, while being limited state sizes fitting into memory, also has
some advantages compared to RocksDB backend:
1. Serialization once per checkpoint, not per state modification. Th
Rex Remind created FLINK-19956:
--
Summary: $ does not work on variables without being qualified in
Scala
Key: FLINK-19956
URL: https://issues.apache.org/jira/browse/FLINK-19956
Project: Flink
Is
Cheng Pan created FLINK-19957:
-
Summary: flink-sql-connector-hive incompatible with cdh6
Key: FLINK-19957
URL: https://issues.apache.org/jira/browse/FLINK-19957
Project: Flink
Issue Type: Bug
Congratulations! Congxian
Best,
Godfrey
Fabian Hueske 于2020年11月2日周一 下午7:00写道：
> 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 Co
Congratulations! Congxian
Best,
Guowei
On Wed, Nov 4, 2020 at 10:36 AM godfrey he wrote:
> Congratulations! Congxian
>
> Best,
> Godfrey
>
> Fabian Hueske 于2020年11月2日周一 下午7:00写道：
>
> > Congrats Congxian!
> >
> > Cheers, Fabian
> >
> > Am Mo., 2. Nov. 2020 um 10:33 Uhr schrieb Yang Wang <
> da
Guowei Ma created FLINK-19958:
-
Summary: Unified exception signature in Sink API
Key: FLINK-19958
URL: https://issues.apache.org/jira/browse/FLINK-19958
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-19959:
---
Summary: Multiple input creation algorithm will deduce an
incorrect input order if the inputs are related under PIPELINED shuffle mode
Key: FLINK-19959
URL: https://issues.apache.or
Jingsong Lee created FLINK-19960:
Summary: Introduce PartitionFieldExtractor to extract partition
field from split
Key: FLINK-19960
URL: https://issues.apache.org/jira/browse/FLINK-19960
Project: Flin
> The collect() utils can be picked back, I see no issue with that (it is
isolated utilities).
Just checking on all the requested backports mentioned in this thread, and
figuring out which ones seem to still be unassigned / open.
Is someone working on backporting
https://github.com/apache/flink/c
Hi @ Billy
I found there existed many benchmark case existed in the two repos, which
benchmark case did you run?
Best
Yun Tang
From: Xie Billy
Sent: Tuesday, November 3, 2020 22:08
To: dev@flink.apache.org
Subject: Re: [DISCUSS][docker] Adopt Jemalloc as defau
Robert Metzger created FLINK-19961:
--
Summary: Bash e2e utility run_test_with_timeout is (sometimes?)
not properly stopping it's watchdog
Key: FLINK-19961
URL: https://issues.apache.org/jira/browse/FLINK-19961
Thanks for the efforts so far with pushing for 1.11.3.
I'd like to provide a mid-week update on how we're looking with all the
pending blockers and backports:
*Blockers**:*
Currently all blockers either have an open PR, or have been merged. I'll
highlight below the blockers *that still require r
29 matches
Mail list logo
