Hi,
1. Currently, much work in FLINK-4256 is about failover improvements in the
bouded dataset scenario.
2. For the streaming scenario, a new shuffle plugin + proper failover
strategy could avoid the "stop-the-word" recovery.
3. We have already done many works about the new shuffle in the old Flin
Hi,
We are using Flink for streaming and find the "stop-the-world" recovery
behavior of Flink prohibitive for use cases that prioritize availability.
Partial recovery as outlined in FLIP-1 would probably alleviate these
concerns.
https://cwiki.apache.org/confluence/display/FLINK/FLIP-1+%3A+Fine+G
Hi Melissa,
Is there a rate for Apache Members/Committers?
I recently saw Flink is offering that for their forthcoming EU Summit:
https://lists.apache.org/thread.html/%3CCAAdrtT2geJjp
Also, @sha...@apache.org and @dev
, that one (Flink EU conference) might be good
to get on the Apache Calendar
Hi,
While considering different options to launch Beam jobs through the Flink
REST API, I noticed that the implementation of JarRunHandler places quite a
few restrictions on how the entry point shall construct a Flink job, by
extracting and manipulating the job graph.
That's normally not a proble
Hi Biao!
Thanks for reviving this. I would like to join this discussion, but am
quite occupied with the 1.9 release, so can we maybe pause this discussion
for a week or so?
In the meantime I can share some suggestion based on prior experiments:
How to do watermarks / timestamp extractors in a si
Hi!
The join implementations used for the DataSet API and for the Blink Planner
are quite intricate. They make use of these custom memory segments, to
operate as much as possible on bytes, to control JVM memory utilization and
to save serialization costs.
That makes the implementation super compli
Jark Wu created FLINK-13430:
---
Summary: Configure sending travis build notifications to
bui...@flink.apache.org
Key: FLINK-13430
URL: https://issues.apache.org/jira/browse/FLINK-13430
Project: Flink
The mailing list has been created, you can now subscribe to it.
On Wed, Jul 24, 2019 at 1:43 PM Jark Wu wrote:
> Thanks Robert for helping out that.
>
> Best,
> Jark
>
> On Wed, 24 Jul 2019 at 19:16, Robert Metzger wrote:
>
> > I've requested the creation of the list, and made Jark, Chesnay and
Timo Walther created FLINK-13429:
Summary: SQL Client end-to-end test fails on Travis
Key: FLINK-13429
URL: https://issues.apache.org/jira/browse/FLINK-13429
Project: Flink
Issue Type: Bug
Joao Boto created FLINK-13428:
-
Summary: StreamingFileSink allow part file name to be configurable
Key: FLINK-13428
URL: https://issues.apache.org/jira/browse/FLINK-13428
Project: Flink
Issue Typ
Jingsong Lee created FLINK-13427:
Summary: HiveCatalog's createFunction not work when function name
is upper
Key: FLINK-13427
URL: https://issues.apache.org/jira/browse/FLINK-13427
Project: Flink
Guowei Ma created FLINK-13426:
-
Summary: TaskExecutor uses the wrong Registrationid in the
heartbeat with RM.
Key: FLINK-13426
URL: https://issues.apache.org/jira/browse/FLINK-13426
Project: Flink
Hi,
while doing a join, a MutableHashTable is created and filled while building.
After building it is closed and the probing can begin.
I would like to start probing while building the hash table still runs.
(ignoring the fact that this would lead to join misses...)
Anyone having an idea how on
pingle wang created FLINK-13425:
---
Summary: Table api sqlUpdate execute case when expression occur
data error
Key: FLINK-13425
URL: https://issues.apache.org/jira/browse/FLINK-13425
Project: Flink
Rui Li created FLINK-13424:
--
Summary: HiveCatalog should add hive version in conf
Key: FLINK-13424
URL: https://issues.apache.org/jira/browse/FLINK-13424
Project: Flink
Issue Type: Bug
Com
Jeff Zhang created FLINK-13423:
--
Summary: Unable to find aggregation function in hive 1
Key: FLINK-13423
URL: https://issues.apache.org/jira/browse/FLINK-13423
Project: Flink
Issue Type: Improve
richt richt created FLINK-13422:
---
Summary: git doc file's link display correct
Key: FLINK-13422
URL: https://issues.apache.org/jira/browse/FLINK-13422
Project: Flink
Issue Type: Wish
Hi devs,
Since 1.9 is nearly released, I think we could get back to FLIP-27. I
believe it should be included in 1.10.
There are so many things mentioned in document of FLIP-27. [1] I think we'd
better discuss them separately. However the wiki is not a good place to
discuss. I wrote google doc abo
Zhu Zhu created FLINK-13421:
---
Summary: Unexpected ConcurrentModificationException when RM notify
JM about allocation failure
Key: FLINK-13421
URL: https://issues.apache.org/jira/browse/FLINK-13421
Project:
Thanks for pushing the discussion, Dawid! I’m also fine with option #3.
Aljoscha
> On 24. Jul 2019, at 12:04, Dawid Wysakowicz wrote:
>
> Hi all,
>
> Thank you Xuefu for clarifying your opinion. Now we have 3 votes for both of
> the options. To conclude this discussion I am willing to change
Jeff Zhang created FLINK-13420:
--
Summary: Supported hive versions are hard coded
Key: FLINK-13420
URL: https://issues.apache.org/jira/browse/FLINK-13420
Project: Flink
Issue Type: Improvement
Timo Walther created FLINK-13419:
Summary: TableEnvironment.explain() has side-effects on
ExecutionConfig
Key: FLINK-13419
URL: https://issues.apache.org/jira/browse/FLINK-13419
Project: Flink
22 matches
Mail list logo
