Why assignTimestampsAndWatermarks parallelism same as map，it will not fired？

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

Re: [Discussion] Flink Pulsar Connector

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

[jira] [Created] (FLINK-9251) Move MemoryStateBackend to flink-state-backends

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:

[jira] [Created] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis

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:

[jira] [Created] (FLINK-9249) Add convenience profile for skipping non-essential plugins

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

Re: [DISCUSS] Releasing Flink 1.5.0

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

Re: [Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink

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.

Re: [Discussion] Flink Pulsar Connector

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

Re: [Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

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

[jira] [Created] (FLINK-9248) Create a SQL Client Avro format fat-jar

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

[jira] [Created] (FLINK-9247) Allow creating table sources/sinks from an Avro schema

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

[jira] [Created] (FLINK-9246) HistoryServer job overview broken

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

[jira] [Created] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

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

[jira] [Created] (FLINK-9244) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

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