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
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
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
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:
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
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:
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
Yun Tang created FLINK-13418:
Summary: Avoid InfluxdbReporter to report uncessray tags
Key: FLINK-13418
URL: https://issues.apache.org/jira/browse/FLINK-13418
Project: Flink
Issue Type:
Konstantin Knauf created FLINK-13417:
Summary: Bump Zookeeper to 3.5.5
Key: FLINK-13417
URL: https://issues.apache.org/jira/browse/FLINK-13417
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-13416:
Summary: Refactor documentation of CLI option for yarn cluster mode
Key: FLINK-13416
URL: https://issues.apache.org/jira/browse/FLINK-13416
Project: Flink
Issue
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
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
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
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
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
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
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
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
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
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
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
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.
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
24 matches
Mail list logo
