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
+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,
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
Stefan Richter created FLINK-10200:
--
Summary: Consolidate FileBasedStateOutputStream and
FsCheckpointStateOutputStream
Key: FLINK-10200
URL: https://issues.apache.org/jira/browse/FLINK-10200
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
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.
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
>
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
11 matches
Mail list logo