You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-2794) Exactly-once support - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 10:20:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2795) Print JobExecutionResult for interactively invoked jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 12:12:26 UTC, 0 replies.
- Pulling Streaming out of staging and project restructure - posted by Stephan Ewen <se...@apache.org> on 2015/10/01 12:25:59 UTC, 23 replies.
- [jira] [Created] (FLINK-2796) CLI -q flag to supress the output does not work - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 15:44:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 15:48:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2798) Prepare new web dashboard for executing in on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/01 16:51:26 UTC, 0 replies.
- Hash-based aggregation - posted by Gábor Gévay <gg...@gmail.com> on 2015/10/01 20:33:39 UTC, 1 replies.
- [jira] [Created] (FLINK-2799) Yarn tests cannot be executed with DEBUG log level - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/02 01:46:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2800) kryo serialization problem - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2015/10/02 09:46:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2801) Rework Storm Compatibility Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 10:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/02 10:24:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2803) Add test case for Flink's memory allocation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 11:19:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2804) Support blocking job submission with Job Manager recovery - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/02 11:56:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2805) Make user jars available for all job managers to recover - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/02 12:09:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2806) No TypeInfo for Scala's Nothing type - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/02 12:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2807) Add javadocs/comments to new windowing mechanics - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/02 13:05:27 UTC, 0 replies.
- An update on the DataStream API refactoring WiP - posted by Kostas Tzoumas <kt...@apache.org> on 2015/10/02 14:40:07 UTC, 5 replies.
- [jira] [Created] (FLINK-2808) Rework / Extend the StatehandleProvider - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 14:56:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2809) DataSet[Unit] doesn't work - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/02 15:09:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2810) Warn user if bc not installed - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/02 15:19:26 UTC, 0 replies.
- Re: Release Flink 0.10 - posted by Robert Metzger <rm...@apache.org> on 2015/10/02 15:49:32 UTC, 5 replies.
- [jira] [Created] (FLINK-2811) Add page with configuration overview - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/02 17:37:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/02 17:41:26 UTC, 0 replies.
- Rethink the "always copy" policy for streaming topologies - posted by Stephan Ewen <se...@apache.org> on 2015/10/02 17:53:49 UTC, 7 replies.
- [jira] [Created] (FLINK-2813) Document off-heap configuration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 18:15:26 UTC, 0 replies.
- streaming GroupBy + Fold - posted by Martin Neumann <mn...@sics.se> on 2015/10/02 18:37:00 UTC, 11 replies.
- [jira] [Created] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/02 22:08:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/03 05:44:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2816) Memory allocation module as a separate maven artifact - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/10/03 10:20:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2817) FileMonitoring function throws NPE when location is empty - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/04 07:12:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/04 20:37:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/05 09:14:26 UTC, 0 replies.
- Re: Extending and improving our "How to contribute" page - posted by Fabian Hueske <fh...@gmail.com> on 2015/10/05 14:09:15 UTC, 8 replies.
- [DISCUSS] Introducing a review process for pull requests - posted by Fabian Hueske <fh...@gmail.com> on 2015/10/05 14:18:50 UTC, 19 replies.
- Towards Flink 0.10 - posted by Maximilian Michels <mx...@apache.org> on 2015/10/05 16:20:57 UTC, 11 replies.
- [jira] [Created] (FLINK-2820) Configuration not passed to JobGraphGenerator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/05 21:46:27 UTC, 0 replies.
- Iteration feedback partitioning does not work properly - posted by Gyula Fóra <gy...@gmail.com> on 2015/10/06 00:11:19 UTC, 7 replies.
- [jira] [Created] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/06 02:19:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2822) Windowing classes incorrectly import scala.Serializable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/06 12:40:26 UTC, 0 replies.
- Failing test - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/06 14:57:02 UTC, 1 replies.
- [jira] [Created] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/06 15:14:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2824) Iteration feedback partitioning does not work as expected - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/06 20:03:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/06 21:52:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/07 01:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/07 01:29:27 UTC, 0 replies.
- [DISCUSS] flink-external - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/07 11:42:18 UTC, 16 replies.
- TM failure when deploying a large number of sources - posted by Gyula Fóra <gy...@apache.org> on 2015/10/07 14:13:29 UTC, 4 replies.
- [jira] [Created] (FLINK-2828) Add interfaces for Table API input formats - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/07 14:45:26 UTC, 0 replies.
- Running the job in Flink webInterface - posted by santosh_rajaguru <sa...@gmail.com> on 2015/10/07 15:31:23 UTC, 3 replies.
- [jira] [Created] (FLINK-2829) Confusing error message when Flink cannot create enough task threads - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/07 16:21:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2830) Add Fold Window Operation for new Windowing API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/07 16:53:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2831) Failinf Test: WrapperSetupHelperTest - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/07 19:22:26 UTC, 0 replies.
- Will to contribute - posted by Dawid Wysakowicz <wy...@gmail.com> on 2015/10/07 19:29:15 UTC, 3 replies.
- [jira] [Created] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/07 20:42:27 UTC, 0 replies.
- Test Failed in flink-streaming-core - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/08 00:21:08 UTC, 0 replies.
- Cannot run Storm WordCountLocal - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/08 01:18:07 UTC, 1 replies.
- [jira] [Created] (FLINK-2833) Unstage Gelly and Module refactoring - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/08 11:21:27 UTC, 0 replies.
- Re: How do network transmissions in Flink work? - posted by Ufuk Celebi <uc...@apache.org> on 2015/10/08 13:06:57 UTC, 0 replies.
- [jira] [Created] (FLINK-2834) Global round-robin for temporary directories - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/08 15:15:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2835) Update Documenation for new Streaming API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/08 15:53:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2836) Cyclic Topologies not supported - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/08 15:57:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/08 16:10:26 UTC, 0 replies.
- No error on dangling dataflow parts - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/08 16:18:19 UTC, 6 replies.
- [jira] [Created] (FLINK-2838) Inconsistent use of URL and Path classes for resources - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/09 10:33:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/09 13:33:26 UTC, 0 replies.
- [DISCUSS] Collecting Instable Tests - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/09 13:47:12 UTC, 5 replies.
- [jira] [Created] (FLINK-2840) KMeans library for Flink ML - posted by "Devang Bacharwar (JIRA)" <ji...@apache.org> on 2015/10/09 14:00:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 15:09:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2842) S3FileSystem is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 15:57:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2843) Add documentation for DataSet outer joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 16:25:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2844) Remove old web interface and default to the new one - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/09 17:31:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/09 17:46:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/09 21:44:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/10 01:35:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/10/10 03:49:05 UTC, 0 replies.
- JobManager not reachable - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/11 18:55:34 UTC, 12 replies.
- [jira] [Created] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/13 15:05:06 UTC, 0 replies.
- Apache flink with Elastic Search - posted by santosh_rajaguru <sa...@gmail.com> on 2015/10/13 15:08:08 UTC, 7 replies.
- [jira] [Created] (FLINK-2850) Limit the types of jobs which can run in detached mode - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/13 15:38:05 UTC, 0 replies.
- Flaky ScalaShellLocalStartupITCase - posted by Sachin Goel <sa...@gmail.com> on 2015/10/13 16:14:25 UTC, 4 replies.
- [jira] [Created] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/14 14:05:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2852) Fix flaky ScalaShellITSuite - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/14 16:47:05 UTC, 0 replies.
- Question on Storm Split Streams - posted by Stephan Ewen <se...@apache.org> on 2015/10/14 21:07:14 UTC, 2 replies.
- [jira] [Created] (FLINK-2853) Apply JMH on Flink benchmarks - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/15 05:04:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/15 11:03:05 UTC, 0 replies.
- A proposal about skew data handling in Flink - posted by "Li, Chengxiang" <ch...@intel.com> on 2015/10/15 12:24:59 UTC, 4 replies.
- [jira] [Created] (FLINK-2855) Add a documentation section for Gelly library methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/15 12:50:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2856) Introduce flink.version property into quickstart archetype - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 13:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2857) Gelly API improvements - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/15 14:15:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/15 15:15:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2859) Add links to docs and JIRA issues in FlinkML roadmap - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/16 11:27:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/16 12:45:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2861) Fields grouping on split streams fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 15:18:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2862) FlinkTopologyBuilder should use proper generic types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 15:19:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2863) Kafka producer does not fail in case of write failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 17:42:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2864) Make State of General-Purpose Window Operators Fault-Tolerant - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/16 18:18:05 UTC, 0 replies.
- [URGENT] Documentation is broken for Dataset API programming guide - posted by Henry Saputra <he...@gmail.com> on 2015/10/17 03:48:31 UTC, 2 replies.
- [jira] [Created] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/18 20:34:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/19 06:06:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/19 06:29:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2868) Missing null check for operatorChain in StreamTask#invoke() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/19 06:49:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/19 08:43:05 UTC, 0 replies.
- Kafka source stuck while canceling - posted by Gyula Fóra <gy...@gmail.com> on 2015/10/19 12:06:31 UTC, 2 replies.
- Powered by Flink - posted by Kostas Tzoumas <kt...@apache.org> on 2015/10/19 14:50:30 UTC, 11 replies.
- [jira] [Created] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/19 16:57:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:17:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/19 19:13:05 UTC, 0 replies.
- Parsing JSON - posted by "Papp, Stefan" <St...@Teradata.com> on 2015/10/20 09:03:12 UTC, 0 replies.
- Re: Parsing JSON - posted by Flavio Pompermaier <po...@okkam.it> on 2015/10/20 09:12:51 UTC, 1 replies.
- [jira] [Created] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:10:27 UTC, 0 replies.
- [DISCUSS] Java code style - posted by Ufuk Celebi <uc...@apache.org> on 2015/10/20 14:31:58 UTC, 39 replies.
- [jira] [Created] (FLINK-2874) Certain Avro generated getters/setters not recognized - posted by "Ulf Karlsson (JIRA)" <ji...@apache.org> on 2015/10/20 14:53:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2875) Add createRemoveEnvironment variant for HA - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 15:10:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2876) Minutiae - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/20 16:08:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2877) Move Streaming API out of Staging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/20 16:47:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2878) JobManager warns: Unexpected leader address pattern - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/20 17:04:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2879) Links in documentation are broken - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/10/20 17:26:27 UTC, 0 replies.
- Travis Error Java 8 - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/20 18:18:26 UTC, 3 replies.
- [jira] [Created] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/20 18:23:27 UTC, 0 replies.
- Forwarding Strategies - posted by Greg Hogan <co...@greghogan.com> on 2015/10/20 18:39:05 UTC, 1 replies.
- [jira] [Created] (FLINK-2881) WebRuntimeMonitor overly restrictive file patterns - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/20 20:07:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2882) Improve performance of string conversions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/20 21:42:27 UTC, 0 replies.
- Scaling Flink - posted by Greg Hogan <co...@greghogan.com> on 2015/10/20 23:06:07 UTC, 3 replies.
- [jira] [Created] (FLINK-2883) Combinable reduce produces wrong result - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/21 01:13:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/21 04:52:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2885) Path to Python resources is not constructed correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 10:41:27 UTC, 0 replies.
- Using Flink Streaming to write to multiple output files in HDFS - posted by Andra Lungu <lu...@gmail.com> on 2015/10/21 11:40:50 UTC, 2 replies.
- [jira] [Created] (FLINK-2886) NettyClient parses wrong configuration key for number of client threads - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/21 13:43:27 UTC, 0 replies.
- Checkpoints keep waiting on source locks - posted by Gyula Fóra <gy...@gmail.com> on 2015/10/21 13:47:57 UTC, 3 replies.
- [jira] [Created] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/21 15:15:27 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc0) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/21 19:10:45 UTC, 31 replies.
- Design document for FLINK-2254 - posted by Saumitra Shahapure <sa...@gmail.com> on 2015/10/21 19:45:59 UTC, 4 replies.
- [jira] [Created] (FLINK-2888) Default state not copied for AbstractHeapKvState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:14:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/22 05:05:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/22 08:02:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/22 08:10:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/22 10:24:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2893) Rename recovery configuration keys - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/22 12:49:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2894) Flink does not allow to specify default serializer for Kryo - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/22 14:51:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2895) Duplicate immutable object creation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 15:18:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2896) Right-hand side menu items of website are missing in narrow browsers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 15:24:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 16:41:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2898) Invert Travis CI build order - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 17:12:27 UTC, 0 replies.
- FastR-Flink: a new open source Truffle project - posted by "Kunft, Andreas" <an...@tu-berlin.de> on 2015/10/22 18:54:45 UTC, 5 replies.
- Re: Record API removal - posted by Chesnay Schepler <ch...@apache.org> on 2015/10/22 19:32:25 UTC, 0 replies.
- [jira] [Created] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/10/22 22:00:30 UTC, 0 replies.
- [jira] [Created] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 22:59:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 23:07:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2902) Web interface sort tasks newest first - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 23:17:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2903) Web interface numeric localization - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 23:18:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2904) Web interface truncated task counts - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 23:19:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2905) Add intersect method to Graph class - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/23 10:35:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2906) Remove Record-API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 10:42:27 UTC, 0 replies.
- From 0.10 to 1.0 - posted by Maximilian Michels <mx...@apache.org> on 2015/10/23 11:59:43 UTC, 6 replies.
- [jira] [Created] (FLINK-2907) Bloom filter for Join - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/23 18:29:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2908) Web interface redraw web plan when browser resized - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/23 19:30:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2909) Gelly Graph Generators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/23 20:54:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2910) Combine tests for binary graph operators - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/24 11:49:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2911) AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/24 14:32:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/24 16:18:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/24 18:06:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/24 18:11:27 UTC, 0 replies.
- Broken link for master Javadocs - posted by Suneel Marthi <sm...@apache.org> on 2015/10/25 02:45:00 UTC, 7 replies.
- [jira] [Created] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/25 11:02:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2916) Add more context information for the StateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/25 11:59:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/25 16:40:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/10/25 23:11:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/26 06:33:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/26 08:47:27 UTC, 0 replies.
- Web Page Issue - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/26 10:12:58 UTC, 16 replies.
- [jira] [Created] (FLINK-2921) Add online documentation of sample methods - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/26 11:16:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2922) Add Queryable Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/26 15:57:27 UTC, 0 replies.
- Scala 2.10/2.11 Maven dependencies - posted by Maximilian Michels <mx...@apache.org> on 2015/10/26 16:04:43 UTC, 7 replies.
- [jira] [Created] (FLINK-2923) Make it possible to mix-and-match StateBackends with KvState implementations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/26 19:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2924) Create database state backend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/26 19:42:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2925) Client does not show root cause of Exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/26 19:43:27 UTC, 0 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc0) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/26 22:56:41 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc1) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/26 23:06:14 UTC, 11 replies.
- [jira] [Created] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/10/27 14:19:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2927) Provide default required configuration keys in flink-conf of binary distribution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:39:27 UTC, 0 replies.
- [gelly] Spargel model rework - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/10/27 17:40:41 UTC, 6 replies.
- [jira] [Created] (FLINK-2928) Confusing job status visualisation in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:44:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2929) Recovery of jobs on cluster restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:50:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2930) ExecutionConfig execution retry delay not respected - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:56:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2931) Add global recovery timestamp to state restore - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/27 18:11:27 UTC, 0 replies.
- Flink "Material" - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/27 21:46:35 UTC, 2 replies.
- Re: [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc1) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/27 22:11:32 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc2) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/27 22:17:29 UTC, 24 replies.
- [jira] [Created] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http - posted by "Frederick F. Kautz IV (JIRA)" <ji...@apache.org> on 2015/10/27 22:45:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "Frederick F. Kautz IV (JIRA)" <ji...@apache.org> on 2015/10/28 00:39:27 UTC, 0 replies.
- Fast strategy for intersect - posted by Martin Junghanns <m....@mailbox.org> on 2015/10/28 13:15:00 UTC, 2 replies.
- [jira] [Created] (FLINK-2934) Remove placehoder pages in Web dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/28 13:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2935) Allow scala shell to read yarn properties - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/10/28 16:12:27 UTC, 0 replies.
- Caching information from a stream - posted by Andra Lungu <lu...@gmail.com> on 2015/10/28 16:30:05 UTC, 3 replies.
- [jira] [Created] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/28 23:40:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/29 10:20:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2938) Streaming docs not in sink with latest state changes - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 11:24:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2939) Add button to cancel jobs in new web frontend - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 11:29:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 11:54:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/29 12:29:27 UTC, 0 replies.
- Diagnosing TaskManager disappearance - posted by Greg Hogan <co...@greghogan.com> on 2015/10/29 13:46:15 UTC, 10 replies.
- neo4j - Flink connector - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/10/29 14:51:29 UTC, 2 replies.
- New JobManager web frontend - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/10/29 16:49:23 UTC, 1 replies.
- [jira] [Created] (FLINK-2942) Dangling operators in web UI's program visualization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 17:34:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 18:36:27 UTC, 0 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc2) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/30 09:04:01 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc3) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/30 09:05:23 UTC, 3 replies.
- [jira] [Created] (FLINK-2944) Collect, expose and display operator-specific stats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/30 10:22:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2945) Shutting down a local Flink instance on Windows doesn't clean up blob cache - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/30 14:34:27 UTC, 0 replies.
- [VOTE] [RESULT] Release Apache Flink 0.10.0 (release-0.10.0-rc3) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/30 15:44:37 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.0 (release-0.10.0-rc4) - posted by Maximilian Michels <mx...@apache.org> on 2015/10/30 15:49:14 UTC, 1 replies.
- [jira] [Created] (FLINK-2946) Add orderBy() to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/30 18:55:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2947) Coloured Scala Shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/30 19:49:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2948) Cannot compile example code in SVM quickstart guide - posted by "Do Le Quoc (JIRA)" <ji...@apache.org> on 2015/10/30 20:20:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2949) Add method 'writeSequencefile' to DataSet - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/10/31 00:55:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2950) Markdown presentation problem in SVM documentation - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/31 05:21:27 UTC, 0 replies.