flink-issues mailing list archives: March 2015

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 · Next »Thread · Author · Date
Gábor Hermann (JIRA) [jira] [Created] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on Wed, 11 Mar, 09:27
Gábor Hermann (JIRA) [jira] [Created] (FLINK-1687) Streaming file source API is not in sync with the batch API Wed, 11 Mar, 13:42
Gábor Hermann (JIRA) [jira] [Updated] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API Wed, 11 Mar, 14:04
Gábor Hermann (JIRA) [jira] [Created] (FLINK-1699) Co-task sometimes returns null Fri, 13 Mar, 08:57
Gábor Hermann (JIRA) [jira] [Updated] (FLINK-1699) Co-task sometimes returns null Fri, 13 Mar, 09:03
Gábor Hermann (JIRA) [jira] [Updated] (FLINK-1699) Co-task sometimes returns null Fri, 13 Mar, 09:09
Gábor Hermann (JIRA) [jira] [Assigned] (FLINK-1699) Co-task sometimes returns null Mon, 16 Mar, 09:53
Gábor Hermann (JIRA) [jira] [Commented] (FLINK-1699) Co-task sometimes returns null Mon, 16 Mar, 10:43
Gábor Hermann (JIRA) [jira] [Created] (FLINK-1772) Chain of split/select does not work Mon, 23 Mar, 15:28
Márton Balassi (JIRA) [jira] [Created] (FLINK-1638) SimpleKafkaSource connector Tue, 03 Mar, 13:13
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release Tue, 03 Mar, 20:02
Márton Balassi (JIRA) [jira] [Assigned] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release Tue, 03 Mar, 20:02
Márton Balassi (JIRA) [jira] [Created] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming Wed, 04 Mar, 12:57
Márton Balassi (JIRA) [jira] [Resolved] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation Wed, 04 Mar, 22:10
Márton Balassi (JIRA) [jira] [Assigned] (FLINK-1429) Add documentation for streaming scala api Thu, 05 Mar, 13:22
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming Sun, 08 Mar, 08:57
Márton Balassi (JIRA) [jira] [Resolved] (FLINK-1429) Add documentation for streaming scala api Sun, 08 Mar, 21:38
Márton Balassi (JIRA) [jira] [Updated] (FLINK-1641) Make projection operator chainable Mon, 09 Mar, 14:25
Márton Balassi (JIRA) [jira] [Created] (FLINK-1669) Streaming tests for recovery with distributed process failure Mon, 09 Mar, 17:54
Márton Balassi (JIRA) [jira] [Created] (FLINK-1670) Collect method for streaming Tue, 10 Mar, 09:57
Márton Balassi (JIRA) [jira] [Created] (FLINK-1673) Colocate Flink Kafka consumer Tue, 10 Mar, 12:33
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on Wed, 11 Mar, 14:45
Márton Balassi (JIRA) [jira] [Closed] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on Wed, 11 Mar, 14:45
Márton Balassi (JIRA) [jira] [Created] (FLINK-1688) Add socket sink Wed, 11 Mar, 15:20
Márton Balassi (JIRA) [jira] [Created] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat Wed, 11 Mar, 15:21
Márton Balassi (JIRA) [jira] [Updated] (FLINK-1688) Add socket sink Wed, 11 Mar, 15:21
Márton Balassi (JIRA) [jira] [Updated] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat Wed, 11 Mar, 15:27
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming Mon, 16 Mar, 10:05
Márton Balassi (JIRA) [jira] [Closed] (FLINK-1340) Project restructure Tue, 17 Mar, 10:31
Márton Balassi (JIRA) [jira] [Created] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() Wed, 18 Mar, 17:23
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() Wed, 18 Mar, 21:06
Márton Balassi (JIRA) [jira] [Assigned] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing Fri, 20 Mar, 14:37
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing Fri, 20 Mar, 14:38
Márton Balassi (JIRA) [jira] [Created] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult Sun, 22 Mar, 07:37
Márton Balassi (JIRA) [jira] [Closed] (FLINK-1763) Remove "cancel" from streaming SinkFunction Sun, 22 Mar, 18:01
Márton Balassi (JIRA) [jira] [Resolved] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing Sun, 22 Mar, 18:03
Márton Balassi (JIRA) [jira] [Resolved] (FLINK-1688) Add socket sink Sun, 22 Mar, 18:06
Márton Balassi (JIRA) [jira] [Resolved] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult Mon, 23 Mar, 16:55
Márton Balassi (JIRA) [jira] [Resolved] (FLINK-1544) Extend streaming aggregation tests to include POJOs Wed, 25 Mar, 09:25
Márton Balassi (JIRA) [jira] [Commented] (FLINK-1793) Streaming jobs can't be canceled Fri, 27 Mar, 14:11
Péter Szabó (JIRA) [jira] [Assigned] (FLINK-1595) Add a complex integration test for Streaming API Thu, 05 Mar, 13:04
Péter Szabó (JIRA) [jira] [Assigned] (FLINK-1560) Add ITCases for streaming examples Mon, 09 Mar, 12:36
Péter Szabó (JIRA) [jira] [Created] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy Mon, 09 Mar, 16:06
Péter Szabó (JIRA) [jira] [Assigned] (FLINK-1544) Extend streaming aggregation tests to include POJOs Tue, 10 Mar, 14:18
Péter Szabó (JIRA) [jira] [Created] (FLINK-1701) Serialization problems with TestStreamEnvironment Fri, 13 Mar, 13:00
Péter Szabó (JIRA) [jira] [Assigned] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API Mon, 16 Mar, 16:11
Péter Szabó (JIRA) [jira] [Commented] (FLINK-1701) Serialization problems with TestStreamEnvironment Tue, 17 Mar, 09:43
Péter Szabó (JIRA) [jira] [Assigned] (FLINK-1701) Serialization problems with TestStreamEnvironment Wed, 18 Mar, 20:29
Péter Szabó (JIRA) [jira] [Closed] (FLINK-1701) Serialization problems with TestStreamEnvironment Wed, 18 Mar, 20:33
Péter Szabó (JIRA) [jira] [Created] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window Fri, 20 Mar, 12:45
Péter Szabó (JIRA) [jira] [Created] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied Mon, 30 Mar, 08:07
Péter Szabó (JIRA) [jira] [Updated] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied Mon, 30 Mar, 08:08
Péter Szabó (JIRA) [jira] [Commented] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied Mon, 30 Mar, 09:29
Péter Szabó (JIRA) [jira] [Closed] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied Mon, 30 Mar, 09:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets Sun, 01 Mar, 11:52
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets Sun, 01 Mar, 11:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets Sun, 01 Mar, 12:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets Sun, 01 Mar, 12:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1591) Remove window merge before flatten as an optimization Sun, 01 Mar, 21:15
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1591) Remove window merge before flatten as an optimization Sun, 01 Mar, 21:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1591) Remove window merge before flatten as an optimization Mon, 02 Mar, 09:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1591) Remove window merge before flatten as an optimization Mon, 02 Mar, 09:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1555) Add utility to log the serializers of composite types Mon, 02 Mar, 13:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:04
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:29
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:32
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin Mon, 02 Mar, 15:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Mon, 02 Mar, 16:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets Mon, 02 Mar, 17:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() Tue, 03 Mar, 09:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Tue, 03 Mar, 12:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-999) Configurability of LocalExecutor Tue, 03 Mar, 15:31
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1350) Add blocking intermediate result partitions Tue, 03 Mar, 15:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Tue, 03 Mar, 16:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1555) Add utility to log the serializers of composite types Tue, 03 Mar, 16:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Tue, 03 Mar, 16:30
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Tue, 03 Mar, 16:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6 Tue, 03 Mar, 17:52
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1522) Add tests for the library methods and examples Tue, 03 Mar, 18:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() Tue, 03 Mar, 18:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1522) Add tests for the library methods and examples Tue, 03 Mar, 19:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Tue, 03 Mar, 20:15
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6 Tue, 03 Mar, 20:48
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Tue, 03 Mar, 22:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method Tue, 03 Mar, 22:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() Wed, 04 Mar, 00:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6 Wed, 04 Mar, 08:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs. Wed, 04 Mar, 09:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() Wed, 04 Mar, 09:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings Wed, 04 Mar, 10:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:44
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs Wed, 04 Mar, 10:46
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 · Next »Thread · Author · Date
Box list
Aug 20197690
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