Hi all,
I use the same parallelism between map and assignTimestampsAndWatermarks , and
it not fired, I saw the extractTimestamp and generateWatermark all is fine, but
watermark is always not change and keep as min long value.
And then I changed parallelism and different with map, and windows f
Hi Fabian,
Awesome, glad to hear back from flink community! Hope this is a good
starting point for a tighter collaboration between two communities.
Thank you,
Sijie
On Tue, Apr 24, 2018 at 2:32 AM, Fabian Hueske wrote:
> Hi Sijie, hi Pulsar community!
>
> Thanks for the detailed overview of Pu
Sihua Zhou created FLINK-9251:
-
Summary: Move MemoryStateBackend to flink-state-backends
Key: FLINK-9251
URL: https://issues.apache.org/jira/browse/FLINK-9251
Project: Flink
Issue Type: Improveme
Chesnay Schepler created FLINK-9250:
---
Summary: JoinTaskExternalITCase deadlocks on travis
Key: FLINK-9250
URL: https://issues.apache.org/jira/browse/FLINK-9250
Project: Flink
Issue Type: Bu
Chesnay Schepler created FLINK-9249:
---
Summary: Add convenience profile for skipping non-essential plugins
Key: FLINK-9249
URL: https://issues.apache.org/jira/browse/FLINK-9249
Project: Flink
A user reported a regression from 1.4.2.
A batch job with a DeltaIteration gets stuck when being executed in a
LocalEnvironment [1].
Cheers, Fabian
[1] https://issues.apache.org/jira/browse/FLINK-9242
2018-04-23 21:09 GMT+02:00 Shuyi Chen :
> Hi Aljoscha and Till,
>
> I've added 2 PRs to fix an
Hi Bowen,
Thanks for updating the proposal. This looks pretty good (as I said before).
There are a few areas, that are not yet fully fleshed out:
1. Where should the TTL code reside? In the state backend or in the
operator?
2. How to get notified about state accesses? I guess this depends on 1.
3
Hi Sijie, hi Pulsar community!
Thanks for the detailed overview of Pulsar.
I like the idea of adding a Pulsar connector to Flink.
As Gordon mentioned, the Flink community would like to ensure that the
connector is maintained after being added.
We experienced that connector maintenance, including
Should we raise FLINK-8533 as a blocker for 1.5.0?
@Eron Can you post this in the "[DISCUSS] Releasing Flink 1.5.0" thread to
make sure it doesn't get lost?
Thanks,
Fabian
2018-04-18 13:05 GMT+02:00 Stephan Ewen :
> I see that this is an important issue.
>
> Will try to review this soon. Till a
Timo Walther created FLINK-9248:
---
Summary: Create a SQL Client Avro format fat-jar
Key: FLINK-9248
URL: https://issues.apache.org/jira/browse/FLINK-9248
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-9247:
---
Summary: Allow creating table sources/sinks from an Avro schema
Key: FLINK-9247
URL: https://issues.apache.org/jira/browse/FLINK-9247
Project: Flink
Issue Type
Chesnay Schepler created FLINK-9246:
---
Summary: HistoryServer job overview broken
Key: FLINK-9246
URL: https://issues.apache.org/jira/browse/FLINK-9246
Project: Flink
Issue Type: Bug
Julien Cuquemelle created FLINK-9245:
Summary: Can't create a BucketingSink with a provided
Configuration if no hadoop defaults
Key: FLINK-9245
URL: https://issues.apache.org/jira/browse/FLINK-9245
Julien Cuquemelle created FLINK-9244:
Summary: Can't create a BucketingSink with a provided
Configuration if no hadoop defaults
Key: FLINK-9244
URL: https://issues.apache.org/jira/browse/FLINK-9244
14 matches
Mail list logo
