Mailing list archives: October 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · Next »Thread · Author · Date
[jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09
Sudhanshu Sekhar Lenka (JIRA)   [jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Sat, 01 Oct, 07:06
[jira] [Created] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer
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
[jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used
Melmoth (JIRA)   [jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used Sat, 01 Oct, 11:36
[jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist
Jordan Ganoff (JIRA)   [jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist Sun, 02 Oct, 00:32
[jira] [Created] (FLINK-4726) Quickstart: Java API - Broken
itiel (JIRA)   [jira] [Created] (FLINK-4726) Quickstart: Java API - Broken Sun, 02 Oct, 11:41
Govindarajan Srinivasaraghavan Using Flink Mon, 03 Oct, 06:08
[jira] [Created] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read
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
Assign issue
Nikolay Vasilishin   Assign issue Mon, 03 Oct, 09:33
Márton Balassi     Re: Assign issue Mon, 03 Oct, 09:38
Anton Solovev   Assign issue Fri, 07 Oct, 08:09
Fabian Hueske     Re: Assign issue Fri, 07 Oct, 08:18
Anton Solovev   Assign issue Fri, 07 Oct, 08:19
Alexander Shoshin   Assign issue Wed, 12 Oct, 11:14
Fabian Hueske     Re: Assign issue Wed, 12 Oct, 11:18
Greg Hogan Duplicate sort keys Mon, 03 Oct, 14:04
Fabian Hueske   Re: Duplicate sort keys Wed, 05 Oct, 21:19
[jira] [Created] (FLINK-4728) Replace reference equality with object equality
Greg Hogan (JIRA)   [jira] [Created] (FLINK-4728) Replace reference equality with object equality Mon, 03 Oct, 18:04
[jira] [Created] (FLINK-4729) Use optional VertexCentric CombineFunction
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
Ufuk Celebi   Re: [DISCUSS] Mesos version dependency Tue, 04 Oct, 12:59
Maximilian Michels     Re: [DISCUSS] Mesos version dependency Thu, 06 Oct, 08:39
[jira] [Created] (FLINK-4730) Introduce CheckpointMetaData
Stefan Richter (JIRA)   [jira] [Created] (FLINK-4730) Introduce CheckpointMetaData Tue, 04 Oct, 07:58
Re: Does the job name affect checkpointing?
Ufuk Celebi   Re: Does the job name affect checkpointing? Tue, 04 Oct, 08:01
[jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in
Stefan Richter (JIRA)   [jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in Tue, 04 Oct, 09:05
[jira] [Created] (FLINK-4732) Maven junction plugin security threat
Maximilian Michels (JIRA)   [jira] [Created] (FLINK-4732) Maven junction plugin security threat Tue, 04 Oct, 09:12
Re: Releasing Flink 1.1.3
Tzu-Li (Gordon) Tai   Re: Releasing Flink 1.1.3 Tue, 04 Oct, 09:12
Ufuk Celebi     Re: Releasing Flink 1.1.3 Tue, 04 Oct, 10:07
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
Stephan Ewen           Re: Releasing Flink 1.1.3 Tue, 04 Oct, 17:08
Ufuk Celebi             Re: Releasing Flink 1.1.3 Tue, 04 Oct, 21:25
Kostas Kloudas               Re: Releasing Flink 1.1.3 Wed, 05 Oct, 10:59
Maximilian Michels                 Re: Releasing Flink 1.1.3 Wed, 05 Oct, 13:44
Maximilian Michels                   Re: Releasing Flink 1.1.3 Wed, 05 Oct, 15:59
Ufuk Celebi                     Re: Releasing Flink 1.1.3 Wed, 05 Oct, 16:53
Kostas Kloudas                       Re: Releasing Flink 1.1.3 Fri, 07 Oct, 14:48
Fabian Hueske [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 09:38
Márton Balassi   Re: [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 10:08
Flavio Pompermaier     Re: [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 12:24
Márton Balassi       Re: [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 Tue, 04 Oct, 15:32
[jira] [Created] (FLINK-4733) Port WebFrontend to new metric system
Chesnay Schepler (JIRA)   [jira] [Created] (FLINK-4733) Port WebFrontend to new metric system Tue, 04 Oct, 09:55
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
Theodore Vasiloudis     Re: Flink ML recommender system API Tue, 04 Oct, 13:57
Gábor Hermann       Re: Flink ML recommender system API Tue, 04 Oct, 16:01
ram kumar Flink scala or Java - Dataload from CSV to database.. Tue, 04 Oct, 12:18
Flavio Pompermaier   Re: Flink scala or Java - Dataload from CSV to database.. Tue, 04 Oct, 12:27
[jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position
Greg Hogan (JIRA)   [jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position Tue, 04 Oct, 13:51
[jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls
Kurt Young (JIRA)   [jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls Tue, 04 Oct, 14:59
[jira] [Created] (FLINK-4736) Don't duplicate fields in Ordering
Greg Hogan (JIRA)   [jira] [Created] (FLINK-4736) Don't duplicate fields in Ordering Tue, 04 Oct, 15:37
Anton Mushin Some questions about Table API and FlinkSQL Tue, 04 Oct, 16:04
Timo Walther   Re: Some questions about Table API and FlinkSQL Tue, 04 Oct, 16:44
Anton Mushin     RE: Some questions about Table API and FlinkSQL Wed, 05 Oct, 10:46
[jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat
Stephan Ewen (JIRA)   [jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat Tue, 04 Oct, 16:06
[jira] [Created] (FLINK-4738) Port TaskManager logic to TaskExecutor
Till Rohrmann (JIRA)   [jira] [Created] (FLINK-4738) Port TaskManager logic to TaskExecutor Tue, 04 Oct, 17:09
[jira] [Created] (FLINK-4739) Adding packaging details for the Elasticsearch connector
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
Till Rohrmann       Re: [Discuss] Upgrade JUnit to 4.12 Wed, 05 Oct, 07:52
Greg Hogan         Re: [Discuss] Upgrade JUnit to 4.12 Wed, 05 Oct, 11:58
[jira] [Created] (FLINK-4740) Upgrade testing libraries
Greg Hogan (JIRA)   [jira] [Created] (FLINK-4740) Upgrade testing libraries Tue, 04 Oct, 20:13
[jira] [Created] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.
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
[jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown
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
[jira] [Created] (FLINK-4743) The sqrt/power function not accept the real data types.
Anton Mushin (JIRA)   [jira] [Created] (FLINK-4743) The sqrt/power function not accept the real data types. Wed, 05 Oct, 10:38
[jira] [Created] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state
Stefan Richter (JIRA)   [jira] [Created] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state Wed, 05 Oct, 12:02
[jira] [Created] (FLINK-4745) Convert KafkaTableSource test to unit tests
Timo Walther (JIRA)   [jira] [Created] (FLINK-4745) Convert KafkaTableSource test to unit tests Wed, 05 Oct, 12:29
[jira] [Created] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration
Till Rohrmann (JIRA)   [jira] [Created] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration Wed, 05 Oct, 12:29
[jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close
Stephan Ewen (JIRA)   [jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close Wed, 05 Oct, 14:03
[jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context
Stephan Ewen (JIRA)   [jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context Wed, 05 Oct, 14:04
[jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator
Stephan Ewen (JIRA)   [jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator Wed, 05 Oct, 14:05
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