Mailing list archives: October 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Sudhanshu Sekhar Lenka (JIRA) [jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Sat, 01 Oct, 07:06
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sat, 01 Oct, 10:50
Melmoth (JIRA) [jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used Sat, 01 Oct, 11:36
Jordan Ganoff (JIRA) [jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist Sun, 02 Oct, 00:32
itiel (JIRA) [jira] [Created] (FLINK-4726) Quickstart: Java API - Broken Sun, 02 Oct, 11:41
Govindarajan Srinivasaraghavan Using Flink Mon, 03 Oct, 06:08
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read Mon, 03 Oct, 08:48
Nikolay Vasilishin Assign issue Mon, 03 Oct, 09:33
Márton Balassi Re: Assign issue Mon, 03 Oct, 09:38
Greg Hogan Duplicate sort keys Mon, 03 Oct, 14:04
Greg Hogan (JIRA) [jira] [Created] (FLINK-4728) Replace reference equality with object equality Mon, 03 Oct, 18:04
Greg Hogan (JIRA) [jira] [Created] (FLINK-4729) Use optional VertexCentric CombineFunction Mon, 03 Oct, 18:11
Eron Wright [DISCUSS] Mesos version dependency Tue, 04 Oct, 02:06
Stefan Richter (JIRA) [jira] [Created] (FLINK-4730) Introduce CheckpointMetaData Tue, 04 Oct, 07:58
Ufuk Celebi Re: Does the job name affect checkpointing? Tue, 04 Oct, 08:01
Stefan Richter (JIRA) [jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in Tue, 04 Oct, 09:05
Maximilian Michels (JIRA) [jira] [Created] (FLINK-4732) Maven junction plugin security threat Tue, 04 Oct, 09:12
Tzu-Li (Gordon) Tai Re: Releasing Flink 1.1.3 Tue, 04 Oct, 09:12
Fabian Hueske [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 09:38
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-4733) Port WebFrontend to new metric system Tue, 04 Oct, 09:55
Ufuk Celebi Re: Releasing Flink 1.1.3 Tue, 04 Oct, 10:07
Márton Balassi Re: [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 10:08
Márton Balassi Re: Releasing Flink 1.1.3 Tue, 04 Oct, 10:09
Fabian Hueske Re: Releasing Flink 1.1.3 Tue, 04 Oct, 10:11
Tzu-Li (Gordon) Tai Re: Releasing Flink 1.1.3 Tue, 04 Oct, 10:24
Gábor Hermann Flink ML recommender system API Tue, 04 Oct, 10:47
Till Rohrmann Re: Flink ML recommender system API Tue, 04 Oct, 12:04
ram kumar Flink scala or Java - Dataload from CSV to database.. Tue, 04 Oct, 12:18
Flavio Pompermaier Re: [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 12:24
Flavio Pompermaier Re: Flink scala or Java - Dataload from CSV to database.. Tue, 04 Oct, 12:27
Ufuk Celebi Re: [DISCUSS] Mesos version dependency Tue, 04 Oct, 12:59
Greg Hogan (JIRA) [jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position Tue, 04 Oct, 13:51
Theodore Vasiloudis Re: Flink ML recommender system API Tue, 04 Oct, 13:57
Kurt Young (JIRA) [jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls Tue, 04 Oct, 14:59
Márton Balassi Re: [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 15:32
Greg Hogan (JIRA) [jira] [Created] (FLINK-4736) Don't duplicate fields in Ordering Tue, 04 Oct, 15:37
Gábor Hermann Re: Flink ML recommender system API Tue, 04 Oct, 16:01
Anton Mushin Some questions about Table API and FlinkSQL Tue, 04 Oct, 16:04
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat Tue, 04 Oct, 16:06
Timo Walther Re: Some questions about Table API and FlinkSQL Tue, 04 Oct, 16:44
Stephan Ewen Re: Releasing Flink 1.1.3 Tue, 04 Oct, 17:08
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4738) Port TaskManager logic to TaskExecutor Tue, 04 Oct, 17:09
Steffen Hausmann (JIRA) [jira] [Created] (FLINK-4739) Adding packaging details for the Elasticsearch connector Tue, 04 Oct, 18:23
Greg Hogan [Discuss] Upgrade JUnit to 4.12 Tue, 04 Oct, 19:07
Stephan Ewen Re: [Discuss] Upgrade JUnit to 4.12 Tue, 04 Oct, 19:19
Greg Hogan Re: [Discuss] Upgrade JUnit to 4.12 Tue, 04 Oct, 20:11
Greg Hogan (JIRA) [jira] [Created] (FLINK-4740) Upgrade testing libraries Tue, 04 Oct, 20:13
Ufuk Celebi Re: Releasing Flink 1.1.3 Tue, 04 Oct, 21:25
Joseph Sims (JIRA) [jira] [Created] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. Tue, 04 Oct, 22:06
Matt Zimmer (JIRA) [jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown Wed, 05 Oct, 02:24
sunny patel AWS S3 and Reshift Wed, 05 Oct, 06:15
Till Rohrmann Re: [Discuss] Upgrade JUnit to 4.12 Wed, 05 Oct, 07:52
Anton Mushin (JIRA) [jira] [Created] (FLINK-4743) The sqrt/power function not accept the real data types. Wed, 05 Oct, 10:38
Anton Mushin RE: Some questions about Table API and FlinkSQL Wed, 05 Oct, 10:46
Kostas Kloudas Re: Releasing Flink 1.1.3 Wed, 05 Oct, 10:59
Greg Hogan Re: [Discuss] Upgrade JUnit to 4.12 Wed, 05 Oct, 11:58
Stefan Richter (JIRA) [jira] [Created] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state Wed, 05 Oct, 12:02
Timo Walther (JIRA) [jira] [Created] (FLINK-4745) Convert KafkaTableSource test to unit tests Wed, 05 Oct, 12:29
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration Wed, 05 Oct, 12:29
Maximilian Michels Re: Releasing Flink 1.1.3 Wed, 05 Oct, 13:44
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close Wed, 05 Oct, 14:03
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context Wed, 05 Oct, 14:04
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator Wed, 05 Oct, 14:05
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4750) Ensure that active processing time triggers complete before closing operators Wed, 05 Oct, 14:07
Timo Walther KafkaProducer can not be instantiated Wed, 05 Oct, 14:51
Tzu-Li (Gordon) Tai Re: KafkaProducer can not be instantiated Wed, 05 Oct, 15:17
Chesnay Schepler Re: KafkaProducer can not be instantiated Wed, 05 Oct, 15:26
Tzu-Li (Gordon) Tai Re: KafkaProducer can not be instantiated Wed, 05 Oct, 15:37
Tzu-Li (Gordon) Tai Re: KafkaProducer can not be instantiated Wed, 05 Oct, 15:57
Maximilian Michels Re: Releasing Flink 1.1.3 Wed, 05 Oct, 15:59
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4751) Extend Flink's futures to support combining two futures Wed, 05 Oct, 16:15
Ufuk Celebi Re: Releasing Flink 1.1.3 Wed, 05 Oct, 16:53
Fabian Hueske Re: Duplicate sort keys Wed, 05 Oct, 21:19
Vishnu Viswanath Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink Thu, 06 Oct, 02:49
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4752) Improve session window documentation Thu, 06 Oct, 08:28
Ufuk Celebi [VOTE] Release Apache Flink 1.1.3 (RC1) Thu, 06 Oct, 08:29
Maximilian Michels Re: [DISCUSS] Mesos version dependency Thu, 06 Oct, 08:39
Timo Walther Re: KafkaProducer can not be instantiated Thu, 06 Oct, 09:54
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock Thu, 06 Oct, 11:22
d...@web.de Flink Gelly Thu, 06 Oct, 11:29
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-4754) Make number of retained checkpoints user configurable Thu, 06 Oct, 12:03
Vasiliki Kalavri Re: Flink Gelly Thu, 06 Oct, 13:22
Fabian Hueske Re: [VOTE] Release Apache Flink 1.1.3 (RC1) Thu, 06 Oct, 13:37
Till Rohrmann (JIRA) [jira] [Created] (FLINK-4755) Create ContainerID; Rename ResourceID into ProcessID and InstanceID into RegistrationID Thu, 06 Oct, 14:18
Ruwen Moos (JIRA) [jira] [Created] (FLINK-4756) NullPointerException on submiting a job with StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster Thu, 06 Oct, 14:33
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration" Thu, 06 Oct, 16:50
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4758) Remove IOReadableWritable from classes where not needed Thu, 06 Oct, 16:52
Ted Yu (JIRA) [jira] [Created] (FLINK-4759) Unclosed DataOutputViewStream in JavaSerializer Thu, 06 Oct, 17:34
Zhenzhong Xu (JIRA) [jira] [Created] (FLINK-4760) Kafka 09 Consumer failed to initialize state causing job to restart Thu, 06 Oct, 22:47
Vishnu Viswanath Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink Fri, 07 Oct, 06:29
Radu Tudoran RE: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink Fri, 07 Oct, 07:57
Anton Solovev Assign issue Fri, 07 Oct, 08:09
Anton Solovev Recall: Assign issue Fri, 07 Oct, 08:17
Fabian Hueske Re: Assign issue Fri, 07 Oct, 08:18
Anton Solovev Recall: Assign issue Fri, 07 Oct, 08:19
Anton Solovev Assign issue Fri, 07 Oct, 08:19
David Anderson (JIRA) [jira] [Created] (FLINK-4761) Web UI can't display large log files Fri, 07 Oct, 08:35
MOHAMMAD SHAKIR Issue in implementation of window operation Fri, 07 Oct, 08:46
Timo Walther (JIRA) [jira] [Created] (FLINK-4762) Use plural in time interval units Fri, 07 Oct, 09:07
d...@web.de Aw: Re: Flink Gelly Fri, 07 Oct, 09:29
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