Mailing list archives: November 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Mike Dias (JIRA) [jira] [Created] (FLINK-4988) Elasticsearch 5.x support Tue, 01 Nov, 03:21
Vishnu Viswanath Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink Tue, 01 Nov, 03:55
Aljoscha Krettek Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API Tue, 01 Nov, 13:52
Mischa Krüger (JIRA) [jira] [Created] (FLINK-4989) Completed job -> Properties: Misleading label Tue, 01 Nov, 15:01
Aljoscha Krettek Re: [DISCUSSION] Timely function interface and timer params Tue, 01 Nov, 15:39
Aljoscha Krettek Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink Tue, 01 Nov, 15:48
Ufuk Celebi Disabling Jenkins for PRs Tue, 01 Nov, 17:23
vishnu.viswanat...@gmail.com Re: Disabling Jenkins for PRs Tue, 01 Nov, 18:15
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4990) Remove JAR option from savepoint disposal Tue, 01 Nov, 20:29
Sean Wang Re: [DISCUSS] FLIP-11: Table API Stream Aggregations Wed, 02 Nov, 03:49
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask Wed, 02 Nov, 07:22
Fabian Hueske Re: [DISCUSS] FLIP-11: Table API Stream Aggregations Wed, 02 Nov, 08:47
Gyula Fora (JIRA) [jira] [Created] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService Wed, 02 Nov, 08:47
Gyula Fóra Re: [DISCUSSION] Timely function interface and timer params Wed, 02 Nov, 08:48
Aljoscha Krettek Re: [DISCUSS] FLIP-2 Extending Window Function Metadata Wed, 02 Nov, 09:16
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult Wed, 02 Nov, 09:51
Ufuk Celebi Re: [DISCUSS] Releasing Flink 1.1.4 Wed, 02 Nov, 10:43
Manu Zhang Re: [DISCUSS] FLIP-2 Extending Window Function Metadata Wed, 02 Nov, 11:58
Thomas FOURNIER Assign a unique id to each line of a dataset Wed, 02 Nov, 12:17
Anton Solovev [FLINK-3848] Add ProjectableTableSource Wed, 02 Nov, 12:53
Fabian Hueske Re: Assign a unique id to each line of a dataset Wed, 02 Nov, 13:04
Fabian Hueske Re: [FLINK-3848] Add ProjectableTableSource Wed, 02 Nov, 13:10
Aljoscha Krettek Re: [DISCUSS] FLIP-2 Extending Window Function Metadata Wed, 02 Nov, 13:14
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-4994) Don't Clear Trigger State and Merging Window Set When Purging Wed, 02 Nov, 13:23
Nikolay Vasilishin [FLINK-4492] Cleanup files from canceled snapshots Wed, 02 Nov, 13:47
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4995) YarnFlinkResourceManagerTest JobManager Lost Leadership test failed Wed, 02 Nov, 14:23
Greg Hogan (JIRA) [jira] [Created] (FLINK-4996) Make CrossHint @Public Wed, 02 Nov, 15:02
Ventura Del Monte (JIRA) [jira] [Created] (FLINK-4997) Extending Window Function Metadata Wed, 02 Nov, 15:04
Maximilian Michels (JIRA) [jira] [Created] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores Wed, 02 Nov, 15:42
Ted Yu (JIRA) [jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers Wed, 02 Nov, 16:01
Till Rohrmann Re: [DISCUSS] Releasing Flink 1.1.4 Wed, 02 Nov, 16:03
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5000) Rename Methods in ManagedInitializationContext Wed, 02 Nov, 17:32
Robert Metzger (JIRA) [jira] [Created] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh Wed, 02 Nov, 20:18
Ted Yu (JIRA) [jira] [Created] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers Wed, 02 Nov, 22:06
Manu Zhang Re: [DISCUSS] FLIP-2 Extending Window Function Metadata Wed, 02 Nov, 22:15
Chen Qin Re: [Discuss] FLIP-13 Side Outputs in Flink Thu, 03 Nov, 03:14
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5003) Provide Access to State Stores in Operator Snapshot Context Thu, 03 Nov, 09:23
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5004) Add task manager option to disable queryable state server Thu, 03 Nov, 12:26
Andrew Roberts (JIRA) [jira] [Created] (FLINK-5005) Publish Scala 2.12 artifacts Thu, 03 Nov, 13:08
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails Thu, 03 Nov, 13:23
Mike Winters [DISCUSS] Proposed updates to Flink project site Thu, 03 Nov, 14:37
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5007) Retain externalized checkpoint on suspension Thu, 03 Nov, 14:46
Nico Kruber (JIRA) [jira] [Created] (FLINK-5008) Update IDE setup documentation Thu, 03 Nov, 15:10
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5009) FS checkpoints leave empty directory Thu, 03 Nov, 15:31
Chen Qin Re: [Discuss] FLIP-13 Side Outputs in Flink Thu, 03 Nov, 15:31
Márton Balassi Re: [DISCUSS] Make FieldAccessor logic consistent with remaining API Thu, 03 Nov, 15:42
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout Thu, 03 Nov, 16:07
Dan Bress (JIRA) [jira] [Created] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing Thu, 03 Nov, 17:02
Maximilian Michels Re: Disabling Jenkins for PRs Thu, 03 Nov, 17:47
Ufuk Celebi Re: Disabling Jenkins for PRs Thu, 03 Nov, 22:32
daviD RideCleansingToKafka Filter Parameter Type Fri, 04 Nov, 09:22
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction Fri, 04 Nov, 09:51
Robert Metzger (JIRA) [jira] [Created] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions Fri, 04 Nov, 09:57
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5014) RocksDBStateBackend misses good toString Fri, 04 Nov, 10:04
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks Fri, 04 Nov, 10:11
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs Fri, 04 Nov, 10:21
Radu Tudoran WindowRunner? Fri, 04 Nov, 10:50
Andrey Melentyev Re: RideCleansingToKafka Filter Parameter Type Fri, 04 Nov, 11:29
daviD Re: RideCleansingToKafka Filter Parameter Type Fri, 04 Nov, 12:10
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources Fri, 04 Nov, 12:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-5018) User configurable source idle timeout to work with WatermarkStatus emitting Fri, 04 Nov, 12:43
Thomas FOURNIER "Cannot resolve map" Fri, 04 Nov, 12:58
Stefan Richter (JIRA) [jira] [Created] (FLINK-5019) Proper isRestored result for tasks that did not write state Fri, 04 Nov, 13:17
Till Rohrmann Re: "Cannot resolve map" Fri, 04 Nov, 13:39
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-5020) Make the GenericWriteAheadSink rescalable. Fri, 04 Nov, 15:13
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-5021) Make the ContinuousFileReaderOperator rescalable. Fri, 04 Nov, 15:25
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down Fri, 04 Nov, 15:27
Alan Gates Hadoop Summit EU 2017 Fri, 04 Nov, 17:13
Maciek Próchniak Re: FLIP-6 and running many "small" jobs Fri, 04 Nov, 19:36
Jaromir Vanek Deterministic processing with out-of-order streams Fri, 04 Nov, 22:38
lido.fl...@web.de Stream processing via Kafka using Android Sat, 05 Nov, 06:50
Xiaogang Shi (JIRA) [jira] [Created] (FLINK-5023) Add get() method in State interface Mon, 07 Nov, 02:04
Xiaogang Shi (JIRA) [jira] [Created] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts Mon, 07 Nov, 02:24
Fabian Hueske Re: Stream processing via Kafka using Android Mon, 07 Nov, 09:33
Niels Basjes (JIRA) [jira] [Created] (FLINK-5025) Job fails because of Optimizer bug Mon, 07 Nov, 10:19
Till Rohrmann Re: Deterministic processing with out-of-order streams Mon, 07 Nov, 11:22
Ovidiu Cristian Marcu RE: TopSpeedWindowing - in error: Could not forward element to next operator Mon, 07 Nov, 11:50
Ovidiu Cristian Marcu RE: [FLINK-3035] Redis as State Backend Mon, 07 Nov, 11:51
Ovidiu Cristian Marcu RE: [FLINK-3035] Redis as State Backend Mon, 07 Nov, 11:56
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5026) Rename TimelyFlatMap to Process Mon, 07 Nov, 13:24
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5027) FileSource finishes successfully with a wrong path Mon, 07 Nov, 15:15
Stephan Ewen (JIRA) [jira] [Created] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation Mon, 07 Nov, 15:57
Jaromir Vanek Re: Deterministic processing with out-of-order streams Mon, 07 Nov, 16:55
amir bahmanyari Re: [FLINK-3035] Redis as State Backend Mon, 07 Nov, 17:20
Till Rohrmann Re: Deterministic processing with out-of-order streams Mon, 07 Nov, 17:27
Vinay Patil Re: Deterministic processing with out-of-order streams Mon, 07 Nov, 18:02
Eron Wright (JIRA) [jira] [Created] (FLINK-5029) Implement KvState SSL Mon, 07 Nov, 19:18
Eron Wright (JIRA) [jira] [Created] (FLINK-5030) Support hostname verification Mon, 07 Nov, 19:42
daviD Could Not Submit Job DataStream Because No Connection to a JobManager Mon, 07 Nov, 19:53
Eron Wright Re: [jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client Mon, 07 Nov, 20:17
Fabian Hueske (JIRA) [jira] [Created] (FLINK-5031) Consecutive DataStream.split() ignored Mon, 07 Nov, 22:35
Boris Osipov (JIRA) [jira] [Created] (FLINK-5032) CsvOutputFormatTest fails on Windows OS Tue, 08 Nov, 06:30
Aljoscha Krettek Re: [DISCUSS] Proposed updates to Flink project site Tue, 08 Nov, 08:12
Ufuk Celebi Re: [DISCUSS] Proposed updates to Flink project site Tue, 08 Nov, 08:43
Till Rohrmann Re: [DISCUSS] Proposed updates to Flink project site Tue, 08 Nov, 10:11
Till Rohrmann Re: Could Not Submit Job DataStream Because No Connection to a JobManager Tue, 08 Nov, 10:14
Stephan Ewen Re: [DISCUSS] Releasing Flink 1.1.4 Tue, 08 Nov, 13:00
Till Rohrmann (JIRA) [jira] [Created] (FLINK-5033) CEP operators don't properly advance time Tue, 08 Nov, 13:17
daviD Re: Could Not Submit Job DataStream Because No Connection to a JobManager Tue, 08 Nov, 13:39
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot Tue, 08 Nov, 16:19
Box list
Jan 201741
Dec 2016366
Nov 2016429
Oct 2016552
Sep 2016426
Aug 2016586
Jul 2016455
Jun 2016386
May 2016405
Apr 2016535
Mar 2016421
Feb 2016502
Jan 2016389
Dec 2015259
Nov 2015589
Oct 2015589
Sep 2015449
Aug 2015478
Jul 2015503
Jun 2015880
May 2015491
Apr 2015583
Mar 2015716
Feb 2015545
Jan 2015600
Dec 2014303
Nov 2014375
Oct 2014283
Sep 2014430
Aug 2014314
Jul 2014390
Jun 2014990