Xingcan Cui created FLINK-10201:
---
Summary: The batchTestUtil was mistakenly used in some stream sql
tests
Key: FLINK-10201
URL: https://issues.apache.org/jira/browse/FLINK-10201
Project: Flink
Hi Gyula,
+1 for this feature. State bootstrapping and state analytics will be very
helpful.
On Thu, Aug 23, 2018 at 4:09 AM Gyula Fóra wrote:
> Hi Shuyi,
>
> The tool allows you to convert a Flink DataSet containing the individual
> state rows, (key, state) pairs, into a state for a streaming
Hi Shuyi,
The tool allows you to convert a Flink DataSet containing the individual
state rows, (key, state) pairs, into a state for a streaming operator.
So if you want to bootstrap your state from data on HDFS, you would read
the file in Flink, convert it to the required DataSet format, then you
+1 on the tooling. Also, you mentioned about state bootstrapping problem.
Could you please elaborate on how we can leverage the tooling to solve
state bootstrapping? I think this is a common problem to stream processing,
and it will be great the community can work on it. Thanks.
Shuyi
On Wed, Aug
Thanks,
I guess the first thing that would be great help from anyone interested in
helping is to try it for some streaming state :)
We have tested these tools at King to analyze, transform and perform some
aggregations on our user-states. The major limitation is that it requires
RocksDB savepoint
Stefan Richter created FLINK-10200:
--
Summary: Consolidate FileBasedStateOutputStream and
FsCheckpointStateOutputStream
Key: FLINK-10200
URL: https://issues.apache.org/jira/browse/FLINK-10200
Project:
Dawid Wysakowicz created FLINK-10199:
Summary: StandaloneSessionClusterEntrypoint does not respect
host/ui-port given from jobmanager.sh
Key: FLINK-10199
URL: https://issues.apache.org/jira/browse/FLINK-10199
+1. Being able to analyze the state is a huge operational advantage.
Thanks Gyula for the POC and I would be very interested in contributing to
the work.
--
Rong
On Tue, Aug 21, 2018 at 4:26 AM Till Rohrmann wrote:
> big +1 for this feature. A tool to get your state out of and into Flink
> will
Stefan Richter created FLINK-10198:
--
Summary: Set Env object in DBOptions for RocksDB
Key: FLINK-10198
URL: https://issues.apache.org/jira/browse/FLINK-10198
Project: Flink
Issue Type: Impro
Hi all,
Thanks a lot for your replies, @Piotr Nowojski
@Fabian
Hueske @Xingcan Cui
Option 3 will send empty deletes to downstream operators, but downstream
operators seems don't know how to deal with it.
Assume that upsert source forward deletes by default. Let's see what
problems we have.
*Ta
For the record I was also in favour of option 3. regarding empty deletes.
About stateful Filters on upsert stream. Hequn, I don’t fully understand this:
> However, if UpsertSource can also output empty deletes, these
> empty deletes will be more difficult to control. We don't know where these
> d
sean.miao created FLINK-10197:
-
Summary: flink CEP error when use sql
Key: FLINK-10197
URL: https://issues.apache.org/jira/browse/FLINK-10197
Project: Flink
Issue Type: Bug
Components:
Nicos Maris created FLINK-10196:
---
Summary: API to test streaming pipelines with windows
Key: FLINK-10196
URL: https://issues.apache.org/jira/browse/FLINK-10196
Project: Flink
Issue Type: New Fe
Dear community,
this is the weekly community update thread #33. Please post any news and
updates you want to share with the community to this thread.
# Flink 1.5.3 has been released
The community released Flink 1.5.3 [1]. It contains more than 20 fixes and
improvements. The community recommends
14 matches
Mail list logo
