flink-issues mailing list archives: October 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · Next »Thread · Author · Date
tzulitai [GitHub] flink issue #2579: [FLINK-4618] FlinkKafkaConsumer09 should start from the n... Sat, 01 Oct, 01:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka Sat, 01 Oct, 01:19
tzulitai [GitHub] flink issue #2579: [FLINK-4618] FlinkKafkaConsumer09 should start from the n... Sat, 01 Oct, 01:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka Sat, 01 Oct, 01:37
KurtYoung [GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager Sat, 01 Oct, 06:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor Sat, 01 Oct, 07:00
Sudhanshu Sekhar Lenka (JIRA) [jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Sat, 01 Oct, 07:06
tzulitai [GitHub] flink issue #2579: [FLINK-4618] FlinkKafkaConsumer09 should start from the n... Sat, 01 Oct, 10:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka Sat, 01 Oct, 10:08
asfgit [GitHub] flink pull request #2579: [FLINK-4618] FlinkKafkaConsumer09 should start fro... Sat, 01 Oct, 10:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka Sat, 01 Oct, 10:12
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka Sat, 01 Oct, 10:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka Sat, 01 Oct, 10:25
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
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sat, 01 Oct, 10:51
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sat, 01 Oct, 10:52
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sat, 01 Oct, 10:53
Melmoth (JIRA) [jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used Sat, 01 Oct, 11:36
Melmoth (JIRA) [jira] [Updated] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are 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
Eron Wright (JIRA) [jira] [Commented] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used Sun, 02 Oct, 01:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sun, 02 Oct, 04:06
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sun, 02 Oct, 04:06
tzulitai [GitHub] flink pull request #: Sun, 02 Oct, 07:29
tzulitai [GitHub] flink pull request #: Sun, 02 Oct, 07:29
tzulitai [GitHub] flink pull request #: Sun, 02 Oct, 07:29
tzulitai [GitHub] flink pull request #: Sun, 02 Oct, 07:29
tzulitai [GitHub] flink pull request #: Sun, 02 Oct, 07:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Sun, 02 Oct, 07:34
itiel (JIRA) [jira] [Created] (FLINK-4726) Quickstart: Java API - Broken Sun, 02 Oct, 11:41
itiel (JIRA) [jira] [Updated] (FLINK-4726) Quickstart: Java API - Broken Sun, 02 Oct, 11:42
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-4478) Implement heartbeat logic Sun, 02 Oct, 22:01
kenmy [GitHub] flink issue #2576: [2.0] [FLINK-4315] Remove Hadoop Dependency from flink-ja... Mon, 03 Oct, 07:02
kenmy [GitHub] flink pull request #2576: [2.0] [FLINK-4315] Remove Hadoop Dependency from f... Mon, 03 Oct, 07:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java Mon, 03 Oct, 07:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java Mon, 03 Oct, 07:02
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
lw-lin [GitHub] flink issue #2557: [FLINK-3734] Close stream state handles after state resto... Mon, 03 Oct, 08:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() Mon, 03 Oct, 08:55
lw-lin [GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat... Mon, 03 Oct, 08:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() Mon, 03 Oct, 08:56
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read Mon, 03 Oct, 09:02
Márton Balassi (JIRA) [jira] [Updated] (FLINK-3204) TaskManagers are not shutting down properly on YARN Mon, 03 Oct, 09:38
Faye Beligianni (JIRA) [jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list Mon, 03 Oct, 09:41
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 11:00
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 11:01
Martin Junghanns (JIRA) [jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values Mon, 03 Oct, 12:03
tzulitai [GitHub] flink pull request #2580: [FLINK-4723] [kafka-connector] Unify committed off... Mon, 03 Oct, 12:46
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Mon, 03 Oct, 12:47
greghogan [GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization Mon, 03 Oct, 13:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values Mon, 03 Oct, 13:42
asfgit [GitHub] flink pull request #2528: [FLINK-4643] [gelly] Average Clustering Coefficien... Mon, 03 Oct, 14:56
asfgit [GitHub] flink pull request #2527: [FLINK-4624] Allow for null values in Graph Summar... Mon, 03 Oct, 14:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4643) Average Clustering Coefficient Mon, 03 Oct, 14:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values Mon, 03 Oct, 14:56
Greg Hogan (JIRA) [jira] [Updated] (FLINK-4643) Average Clustering Coefficient Mon, 03 Oct, 14:57
Greg Hogan (JIRA) [jira] [Closed] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values Mon, 03 Oct, 14:57
Greg Hogan (JIRA) [jira] [Closed] (FLINK-4643) Average Clustering Coefficient Mon, 03 Oct, 14:58
fholger [GitHub] flink pull request #2581: [FLINK-4709] Fix resource leak in InputStreamFSInp... Mon, 03 Oct, 15:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream Mon, 03 Oct, 15:19
tzulitai [GitHub] flink issue #2580: [FLINK-4723] [kafka-connector] Unify committed offsets to... Mon, 03 Oct, 15:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Mon, 03 Oct, 15:41
Ted Yu (JIRA) [jira] [Resolved] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() Mon, 03 Oct, 15:50
mtanski [GitHub] flink issue #2002: Support for bz2 compression in flink-core Mon, 03 Oct, 16:02
Sudhanshu Sekhar Lenka (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:36
mtanski [GitHub] flink pull request #2002: Support for bz2 compression in flink-core Mon, 03 Oct, 16:42
Sudhanshu Sekhar Lenka (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:46
Sudhanshu Sekhar Lenka (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:49
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:56
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:56
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:59
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 16:59
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
Sudhanshu Sekhar Lenka (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Mon, 03 Oct, 18:13
Vasia Kalavri (JIRA) [jira] [Updated] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration Mon, 03 Oct, 18:59
Vasia Kalavri (JIRA) [jira] [Commented] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration Mon, 03 Oct, 18:59
Greg Hogan (JIRA) [jira] [Commented] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration Mon, 03 Oct, 19:28
Vasia Kalavri (JIRA) [jira] [Commented] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration Mon, 03 Oct, 20:00
Greg Hogan (JIRA) [jira] [Commented] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration Mon, 03 Oct, 20:20
tillrohrmann [GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager Mon, 03 Oct, 20:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4478) Implement heartbeat logic Mon, 03 Oct, 20:38
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper Mon, 03 Oct, 20:40
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-4406) Implement job master registration at resource manager Mon, 03 Oct, 20:40
tillrohrmann [GitHub] flink issue #2565: [FLINK-4406] [cluster management] Implement job master re... Mon, 03 Oct, 20:40
tillrohrmann [GitHub] flink issue #2550: [FLINK-4657] Implement HighAvailabilityServices based on ... Mon, 03 Oct, 20:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4406) Implement job master registration at resource manager Mon, 03 Oct, 20:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper Mon, 03 Oct, 20:41
greghogan [GitHub] flink pull request #2582: [FLINK-4728] [core,optimizer] Replace reference eq... Mon, 03 Oct, 20:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4728) Replace reference equality with object equality Mon, 03 Oct, 20:42
Neelesh Srinivas Salian (JIRA) [jira] [Commented] (FLINK-3999) Rename the `running` flag in the drivers to `canceled` Mon, 03 Oct, 23:31
vijikarthi [GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl... Tue, 04 Oct, 01:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3930) Implement Service-Level Authorization Tue, 04 Oct, 01:03
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Tue, 04 Oct, 02:59
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Tue, 04 Oct, 03:02
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Tue, 04 Oct, 03:05
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 Tue, 04 Oct, 03:18
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · Next »Thread · Author · Date
Box list
May 20194901
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300