Hi Quan,
Thanks for your reply.
Actually, I did not try this way.
But, there are two factors we should consider:
1. The local state storage is not equals to RocksDB, otherwise Flink
does not need to provide a queryable state client. What's more, querying
the RocksDB is still an addres
Hi,
How about take states from RocksDB directly, in this case, TM host is
unnecessary.
Best
Quan Shi
From: vino yang
Sent: Thursday, April 25, 2019 10:18:20 PM
To: dev; user
Cc: Stefan Richter; Aljoscha Krettek; kklou...@gmail.com
Subject: [DISCUSS] Improve Qu
Cliff Resnick created FLINK-12334:
-
Summary: change to MockStreamTask breaks
OneInputStreamOperatorTestHarness
Key: FLINK-12334
URL: https://issues.apache.org/jira/browse/FLINK-12334
Project: Flink
Vishal Santoshi created FLINK-12333:
---
Summary: Add documentation around save point with cancel lifecycle
through REST
Key: FLINK-12333
URL: https://issues.apache.org/jira/browse/FLINK-12333
Project
Hi all,
I want to share my thought with you about improving the queryable state and
introducing a QueryServerProxy component.
I think the current queryable state's client is hard to use. Because it
needs users to know the TaskManager's address and proxy's port. Actually,
some business users who d
Hi Beckett，
Thanks for your feedback, See my comments inline
>>> How do user specify the listener? *
What I proposal is to register JobListener in ExecutionEnvironment. I don't
think we should make ClusterClient as public api.
>>> Where should the listener run? *
I don't think it is proper to
Thanks for the proposal, Jeff. Adding a listener to allow users handle
events during the job lifecycle makes a lot of sense to me.
Here are my two cents.
* How do user specify the listener? *
It is not quite clear to me whether we consider ClusterClient as a public
interface? From what I understa
Biao Liu created FLINK-12332:
Summary: Cancel running tasks if exist before shutting down TM
Key: FLINK-12332
URL: https://issues.apache.org/jira/browse/FLINK-12332
Project: Flink
Issue Type: Imp
zhijiang created FLINK-12331:
Summary: Introduce partition/gate setup to decouple task
registration with NetworkEnvironment
Key: FLINK-12331
URL: https://issues.apache.org/jira/browse/FLINK-12331
Project:
Hi Rong,
t is definitely do-able to use Plugins for TableFactories discovery, but it
would require more extensive changes/discussions. Couple of challenges there:
1. Currently TableFactories come from user job’s jar, which would mean support
for dynamically loaded plugins or Pluggable TableFact
On Thu, Apr 25, 2019 at 6:04 AM jincheng sun wrote:
>
> Hi Robert,
>
> In addition to the questions described by Dian, I also want to know what
> difficult problems Py4j's solution will encounter in add UDF support, which
> you mentioned as follows:
>
>> Using something like Py4j is an easy way
Hi Smirnov,
Actually there is a way to tell Flink that data is already partitioned.
You can try the reinterpretAsKeyedStream[1] method. I must warn you
though this is an experimental feature.
Best,
Dawid
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/experimental.htm
On Thu, Apr 25, 2019 at 5:59 AM Dian Fu wrote:
>
> Thanks everyone for the discussion here.
>
> Regarding to the Java/Scala UDF and the built-in UDF to execute in the
> current Flink way (directly in JVM, not via RPC), I share the same thoughts
> with Max and Robert and I think it will not be a
sunjincheng created FLINK-12330:
---
Summary: Add integrated Tox for ensuring compatibility with the
python2/3 version
Key: FLINK-12330
URL: https://issues.apache.org/jira/browse/FLINK-12330
Project: Flink
14 matches
Mail list logo
