flink-issues mailing list archives: August 2016

Site index · List index
Message list« Previous · 1 · 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 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · Next »Thread · Author · Date
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly Tue, 23 Aug, 16:12
Robert Metzger (JIRA) [jira] [Closed] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis Wed, 24 Aug, 09:07
Robert Metzger (JIRA) [jira] [Resolved] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources() Wed, 24 Aug, 09:08
Robert Metzger (JIRA) [jira] [Closed] (FLINK-3343) Exception while using Kafka 0.9 connector Wed, 24 Aug, 09:08
Robert Metzger (JIRA) [jira] [Closed] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis Wed, 24 Aug, 09:08
Robert Metzger (JIRA) [jira] [Resolved] (FLINK-3531) KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis Wed, 24 Aug, 09:09
Robert Metzger (JIRA) [jira] [Resolved] (FLINK-2049) KafkaSink sporadically fails to send message Wed, 24 Aug, 09:12
Robert Metzger (JIRA) [jira] [Resolved] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails Wed, 24 Aug, 09:12
Robert Metzger (JIRA) [jira] [Commented] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x Wed, 24 Aug, 09:18
Robert Metzger (JIRA) [jira] [Created] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website Wed, 24 Aug, 15:05
Robert Metzger (JIRA) [jira] [Commented] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis Thu, 25 Aug, 13:20
Robert Metzger (JIRA) [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable Thu, 25 Aug, 13:23
Robert Metzger (JIRA) [jira] [Updated] (FLINK-4433) Refactor the StreamSource. Thu, 25 Aug, 16:00
Robert Metzger (JIRA) [jira] [Updated] (FLINK-4433) Refactor the StreamSource. Thu, 25 Aug, 16:01
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website Thu, 25 Aug, 16:37
Robert Metzger (JIRA) [jira] [Updated] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input Thu, 25 Aug, 18:57
Robert Metzger (JIRA) [jira] [Created] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable Mon, 29 Aug, 09:03
Robert Metzger (JIRA) [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable Mon, 29 Aug, 09:04
Robert Metzger (JIRA) [jira] [Resolved] (FLINK-4341) Kinesis connector does not emit maximum watermark properly Mon, 29 Aug, 09:50
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem Mon, 29 Aug, 10:28
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem Mon, 29 Aug, 10:29
Robert Metzger (JIRA) [jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input Mon, 29 Aug, 12:57
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. Mon, 29 Aug, 14:08
Robert Metzger (JIRA) [jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME Tue, 30 Aug, 08:49
Sajeev Ramakrishnan (JIRA) [jira] [Created] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload Thu, 11 Aug, 13:00
Sajeev Ramakrishnan (JIRA) [jira] [Commented] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload Fri, 12 Aug, 10:16
Sajeev Ramakrishnan (JIRA) [jira] [Created] (FLINK-4393) Failed to serialize accumulators for task Mon, 15 Aug, 06:24
Sajeev Ramakrishnan (JIRA) [jira] [Commented] (FLINK-4393) Failed to serialize accumulators for task Mon, 15 Aug, 06:25
Sajeev Ramakrishnan (JIRA) [jira] [Commented] (FLINK-4393) Failed to serialize accumulators for task Tue, 16 Aug, 07:35
Scott Kidder (JIRA) [jira] [Created] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform Tue, 09 Aug, 20:20
Scott Kidder (JIRA) [jira] [Commented] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform Tue, 09 Aug, 21:55
Scott Kidder (JIRA) [jira] [Commented] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform Wed, 10 Aug, 02:17
Scott Kidder (JIRA) [jira] [Commented] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform Wed, 17 Aug, 21:27
Scott Kidder (JIRA) [jira] [Updated] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform Wed, 17 Aug, 21:27
Scott Kidder (JIRA) [jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly Fri, 19 Aug, 18:26
Scott Kidder (JIRA) [jira] [Created] (FLINK-4536) Possible thread leak in Task Manager Wed, 31 Aug, 04:42
Scott Kidder (JIRA) [jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager Wed, 31 Aug, 21:13
Scott Kidder (JIRA) [jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager Wed, 31 Aug, 21:18
Sergii Koshel (JIRA) [jira] [Created] (FLINK-4425) "Out Of Memory" during savepoint deserialization Thu, 18 Aug, 14:03
Sergii Koshel (JIRA) [jira] [Updated] (FLINK-4425) "Out Of Memory" during savepoint deserialization Fri, 19 Aug, 11:25
Sergii Koshel (JIRA) [jira] [Commented] (FLINK-4425) "Out Of Memory" during savepoint deserialization Fri, 19 Aug, 11:28
Sergii Koshel (JIRA) [jira] [Commented] (FLINK-4425) "Out Of Memory" during savepoint deserialization Tue, 23 Aug, 10:24
Shannon Carey (JIRA) [jira] [Created] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart Mon, 08 Aug, 20:22
Shannon Carey (JIRA) [jira] [Created] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception Wed, 17 Aug, 22:30
Shannon Carey (JIRA) [jira] [Updated] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception Wed, 17 Aug, 22:31
Shannon Carey (JIRA) [jira] [Commented] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception Tue, 23 Aug, 23:16
Shannon Carey (JIRA) [jira] [Updated] (FLINK-3190) Retry rate limits for DataStream API Wed, 31 Aug, 16:26
Stefan Richter (JIRA) [jira] [Commented] (FLINK-3623) Adjust MurmurHash algorithm Tue, 09 Aug, 19:44
Stefan Richter (JIRA) [jira] [Created] (FLINK-4374) GroupReduce Broken for null Date Thu, 11 Aug, 10:35
Stefan Richter (JIRA) [jira] [Updated] (FLINK-4374) GroupReduce Broken for null Date Thu, 11 Aug, 10:36
Stefan Richter (JIRA) [jira] [Assigned] (FLINK-4374) GroupReduce Broken for null Date Thu, 11 Aug, 10:36
Stefan Richter (JIRA) [jira] [Commented] (FLINK-4374) GroupReduce Broken for null Date Thu, 11 Aug, 12:53
Stefan Richter (JIRA) [jira] [Comment Edited] (FLINK-4374) GroupReduce Broken for null Date Thu, 11 Aug, 12:53
Stefan Richter (JIRA) [jira] [Created] (FLINK-4492) Cleanup files from canceled snapshots Thu, 25 Aug, 14:40
Stefan Richter (JIRA) [jira] [Created] (FLINK-4493) Unify the snapshot output format for keyed-state backends Thu, 25 Aug, 14:44
Stefan Richter (JIRA) [jira] [Created] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests Fri, 26 Aug, 14:07
StefanRRichter [GitHub] flink pull request #2376: [FLINK-3755] Introduce key groups for key-value st... Tue, 16 Aug, 14:58
StefanRRichter [GitHub] flink issue #2376: [FLINK-3755] Introduce key groups for key-value state to ... Tue, 16 Aug, 15:37
StefanRRichter [GitHub] flink pull request #2376: [FLINK-3755] Introduce key groups for key-value st... Mon, 29 Aug, 11:12
StefanRRichter [GitHub] flink pull request #2440: Keyed backend refactor Tue, 30 Aug, 13:34
StefanRRichter [GitHub] flink pull request #2440: [FLINK-3755] Introduce key groups for key-value st... Wed, 31 Aug, 22:02
Stephan Ewen (JIRA) [jira] [Assigned] (FLINK-4285) Non-existing example in Flink quickstart setup documentation Mon, 01 Aug, 08:26
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4285) Non-existing example in Flink quickstart setup documentation Mon, 01 Aug, 08:26
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4243) Change "Scope" to "Namespace" for Metrics Mon, 01 Aug, 08:31
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-4243) Change "Scope" to "Namespace" for Metrics Mon, 01 Aug, 08:31
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 09:13
Stephan Ewen (JIRA) [jira] [Updated] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 09:15
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 09:21
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4292) HCatalog project incorrectly set up Mon, 01 Aug, 10:00
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 10:09
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4293) Malformatted Apache Haders Mon, 01 Aug, 10:14
Stephan Ewen (JIRA) [jira] [Updated] (FLINK-4293) Malformatted Apache Haders Mon, 01 Aug, 10:14
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4298) Clean up Storm Compatibility Dependencies Mon, 01 Aug, 13:58
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 14:54
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 14:56
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 15:04
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 15:05
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks Mon, 01 Aug, 15:25
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-2237) Add hash-based Aggregation Mon, 01 Aug, 15:54
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Mon, 01 Aug, 15:59
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners Mon, 01 Aug, 16:04
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work Mon, 01 Aug, 18:26
Stephan Ewen (JIRA) [jira] [Assigned] (FLINK-4290) CassandraConnectorTest deadlocks Tue, 02 Aug, 10:45
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-4290) CassandraConnectorTest deadlocks Tue, 02 Aug, 10:47
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-4290) CassandraConnectorTest deadlocks Tue, 02 Aug, 10:48
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-4298) Clean up Storm Compatibility Dependencies Tue, 02 Aug, 10:49
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-4298) Clean up Storm Compatibility Dependencies Tue, 02 Aug, 10:50
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue Tue, 02 Aug, 10:51
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue Tue, 02 Aug, 10:51
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-4285) Non-existing example in Flink quickstart setup documentation Tue, 02 Aug, 10:52
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-4285) Non-existing example in Flink quickstart setup documentation Tue, 02 Aug, 10:52
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-4292) HCatalog project incorrectly set up Tue, 02 Aug, 10:56
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-4292) HCatalog project incorrectly set up Tue, 02 Aug, 10:56
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work Tue, 02 Aug, 11:01
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples Tue, 02 Aug, 12:19
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ Tue, 02 Aug, 13:28
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ Tue, 02 Aug, 14:06
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work Tue, 02 Aug, 16:09
Stephan Ewen (JIRA) [jira] [Created] (FLINK-4307) Broken user-facing API for ListState Tue, 02 Aug, 16:18
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples Tue, 02 Aug, 16:34
Message list« Previous · 1 · 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 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · Next »Thread · Author · Date
Box list
Sep 20195384
Aug 201910193
Jul 201911502
Jun 20198159
May 20197326
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