You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Running stream examples (newbie) - posted by Tara Athan <ta...@gmail.com> on 2016/03/01 03:38:04 UTC, 1 replies.
- [VOTE] Release Apache Flink 1.0.0 (RC3) - posted by Robert Metzger <rm...@apache.org> on 2016/03/01 09:08:03 UTC, 9 replies.
- Re: Fix version - posted by Maximilian Michels <mx...@apache.org> on 2016/03/01 11:20:04 UTC, 1 replies.
- [jira] [Created] (FLINK-3553) Don't include watermarks in record count - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/01 11:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3554) Bounded sources should emit a Max Watermark when they are done - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/01 11:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3555) Web interface does not render job information properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/01 11:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3556) Unneeded check in HA blob store configuration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 12:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3558) Many declined checkpoints on startup - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 12:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3557) Scala DataStream fold method should take fold function in secondary parameter list - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/01 12:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3559) Don't print pid file check if no active PID - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 14:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3560) Examples shouldn't always print usage statement - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/01 17:20:18 UTC, 0 replies.
- [CANCELLED][VOTE] Release Apache Flink 1.0.0 (RC3) - posted by Robert Metzger <rm...@apache.org> on 2016/03/01 17:33:00 UTC, 0 replies.
- Apache Big Data - posted by Trevor Grant <tr...@gmail.com> on 2016/03/01 20:35:53 UTC, 4 replies.
- [VOTE] Release Apache Flink 1.0.0 (RC4) - posted by Robert Metzger <rm...@apache.org> on 2016/03/01 22:42:17 UTC, 6 replies.
- [jira] [Created] (FLINK-3561) ExecutionConfig's timestampsEnabled is unused - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/02 10:43:18 UTC, 0 replies.
- Input type validation is killing me - posted by Gyula Fóra <gy...@apache.org> on 2016/03/02 11:15:19 UTC, 8 replies.
- [jira] [Created] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/02 11:33:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/03/02 12:16:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3564) Implement distinct() for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/02 13:05:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/02 14:35:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/02 15:58:18 UTC, 0 replies.
- [CANCELLED][VOTE] Release Apache Flink 1.0.0 (RC4) - posted by Robert Metzger <rm...@apache.org> on 2016/03/02 19:49:32 UTC, 0 replies.
- Release 1.0 Migration Guide - posted by Ufuk Celebi <uc...@apache.org> on 2016/03/03 10:48:41 UTC, 3 replies.
- Re: Incremental checkpoints for Flink - posted by Marius Melzer <ma...@rasumi.net> on 2016/03/03 11:34:32 UTC, 0 replies.
- [jira] [Created] (FLINK-3567) Rework selection when grouping in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 11:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3568) Hadoop's Bzip decompression is not thread safe - posted by "Sebastian Neef (JIRA)" <ji...@apache.org> on 2016/03/03 12:23:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3569) Test cases fail due to Maven Shade plugin - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/03 12:51:18 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.0 (RC5) - posted by Robert Metzger <rm...@apache.org> on 2016/03/03 14:01:11 UTC, 17 replies.
- [jira] [Created] (FLINK-3570) Replace random NIC selection heuristic by InetAddress.getLocalHost - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/03 14:01:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3571) SavepointITCase.testRestoreFailure fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/03 15:42:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3572) SourceStreamTaskTest.testCheckpointing fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/03 15:49:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3573) Implement more String functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 16:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3574) Implement math functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 16:21:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3575) Update Working With State Section in Doc - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/03 16:53:18 UTC, 0 replies.
- RE: Guarantees for object reuse modes and documentation - posted by Ken Krugler <kk...@transpac.com> on 2016/03/04 01:54:08 UTC, 1 replies.
- Remote TaskManager Connection Problem - posted by Deepak Jha <dk...@gmail.com> on 2016/03/04 02:48:31 UTC, 3 replies.
- [jira] [Created] (FLINK-3576) Upgrade Snappy Java to 1.1.2.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/04 04:49:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3577) Display anchor links when hovering over headers. - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/03/04 10:46:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3578) Scala DataStream API does not support Rich Window Functions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/04 12:30:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3579) Improve String concatenation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/04 13:17:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/04 13:36:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3581) Add Non-Keyed Window Trigger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/04 15:08:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/04 15:11:40 UTC, 0 replies.
- [RESULT][VOTE] Release Apache Flink 1.0.0 (RC5) - posted by Robert Metzger <rm...@apache.org> on 2016/03/04 20:17:36 UTC, 0 replies.
- [jira] [Created] (FLINK-3583) Configuration not visible in gui when job is running - posted by "Michał Fijołek (JIRA)" <ji...@apache.org> on 2016/03/04 21:23:40 UTC, 0 replies.
- Tuple performance and the curious JIT compiler - posted by Greg Hogan <co...@greghogan.com> on 2016/03/04 23:37:07 UTC, 11 replies.
- [jira] [Created] (FLINK-3584) WebInterface: Broken graphical display in Chrome - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/03/07 11:32:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3585) Deploy scripts don't support spaces in paths - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/07 17:49:40 UTC, 0 replies.
- Dynamically repartitioned sources - posted by Maxim <mf...@gmail.com> on 2016/03/07 21:18:33 UTC, 1 replies.
- Re: Machine Learning on Apache Fink - posted by Dmitriy Lyubimov <dl...@gmail.com> on 2016/03/08 00:02:21 UTC, 0 replies.
- [jira] [Created] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/03/08 07:43:40 UTC, 0 replies.
- Fwd: Estimated time of r 1.0 - posted by Saar Bar <sa...@gmail.com> on 2016/03/08 10:59:25 UTC, 1 replies.
- [jira] [Created] (FLINK-3587) Bump Calcite version to 1.7.0-SNAPSHOT - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/08 11:19:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3588) Add a streaming (exactly-once) JDBC connector - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 13:54:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3589) Allow setting Operator parallelism to default value - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/08 14:33:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3590) JDBC Format tests don't hide derby logs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 15:01:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3591) Replace Quickstart K-Means Example by Streaming Example - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/08 15:51:40 UTC, 0 replies.
- [ANNOUNCE] Flink 1.0.0 has been released - posted by Kostas Tzoumas <kt...@apache.org> on 2016/03/08 16:17:28 UTC, 3 replies.
- [jira] [Created] (FLINK-3592) Update setup quickstart - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/08 18:44:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3593) DistinctITCase is failing - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/08 19:45:41 UTC, 0 replies.
- Query regarding using storm topology in Flink - posted by "Sharma, Samiksha" <sa...@here.com> on 2016/03/09 02:06:02 UTC, 2 replies.
- [jira] [Created] (FLINK-3594) Unstable KafkaConsumerTestBase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/09 12:07:40 UTC, 0 replies.
- Accessing the Configuration - posted by Márton Balassi <ba...@gmail.com> on 2016/03/09 12:38:13 UTC, 5 replies.
- [jira] [Created] (FLINK-3595) Kafka09 consumer thread does not interrupt when stuck in record emission - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/09 14:34:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3596) DataSet RelNode refactoring - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/09 15:42:40 UTC, 0 replies.
- GSoC Project Proposal Draft: Code Generation in Serializers - posted by Gábor Horváth <xa...@gmail.com> on 2016/03/09 15:51:23 UTC, 4 replies.
- Design Doc: Execution of Table API & SQL queries in Java/Scala programs - posted by Fabian Hueske <fh...@gmail.com> on 2016/03/09 16:52:21 UTC, 0 replies.
- [jira] [Created] (FLINK-3597) Table API operator names should reflect relational expression - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/09 18:50:40 UTC, 0 replies.
- New user of Flink - posted by janardhan shetty <ja...@gmail.com> on 2016/03/09 21:27:31 UTC, 2 replies.
- Flink-1.0.0 JobManager is not running in Docker Container on AWS - posted by Deepak Jha <dk...@gmail.com> on 2016/03/10 06:02:37 UTC, 12 replies.
- a question about operatorChain.broadcastCheckpointBarrier - posted by Ma GuoWei <ma...@outlook.com> on 2016/03/10 06:58:56 UTC, 3 replies.
- [jira] [Created] (FLINK-3598) java.lang.NoSuchMethodError: org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfo - posted by "Rik Schreurs (JIRA)" <ji...@apache.org> on 2016/03/10 10:15:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3599) GSoC: Code Generation in Serializers - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/10 11:23:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3600) Provide clear description network ports usage - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/10 16:12:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3601) JobManagerTest times out on StopSignal test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/10 16:58:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3602) Recursive Types are not supported / crash TypeExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 18:04:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3603) Re-enable Table API explain - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 01:12:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3604) Enable ignored Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 01:16:41 UTC, 0 replies.
- [jira] [Created] (FLINK-3605) DataSet.output(HadoopOutput) always expects a LongWritable as a key and throws an exception when supplied with other Writable Key Types - posted by "Andrew Palumbo (JIRA)" <ji...@apache.org> on 2016/03/11 03:50:40 UTC, 0 replies.
- Update the link in Job.java for Flink examples - posted by janardhan shetty <ja...@gmail.com> on 2016/03/11 06:41:09 UTC, 2 replies.
- [jira] [Created] (FLINK-3606) Expose Configuration from RichFunctions - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/11 10:48:09 UTC, 0 replies.
- [jira] [Created] (FLINK-3607) Decrease default forkCount for tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/11 11:53:05 UTC, 0 replies.
- [jira] [Created] (FLINK-3608) ImmutableSettings error in ElasticsearchSink - posted by "Carlos Gonzalez de Zarate (JIRA)" <ji...@apache.org> on 2016/03/11 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-3609) Revisit selection of Calcite rules - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 12:52:12 UTC, 0 replies.
- zipWithIndex in Python API - posted by Shannon Quinn <sq...@gatech.edu> on 2016/03/11 18:15:43 UTC, 3 replies.
- XGBoost on DataFlow and Flink - posted by Tianqi Chen <tq...@cs.washington.edu> on 2016/03/11 21:32:31 UTC, 6 replies.
- [streaming, scala] Scala DataStream#addSink returns Java DataStreamSink - posted by Márton Balassi <ba...@gmail.com> on 2016/03/12 20:39:20 UTC, 12 replies.
- [jira] [Created] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/13 05:27:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3611) Wrong link in CONTRIBUTING.md - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/03/14 00:03:33 UTC, 0 replies.
- [DISCUSSION] Database state backend - posted by Gyula Fóra <gy...@apache.org> on 2016/03/14 11:20:25 UTC, 3 replies.
- [jira] [Created] (FLINK-3612) Fix/adjust Table API examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 15:47:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3613) Add standard deviation to list of Aggregations - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/03/14 17:02:33 UTC, 0 replies.
- TopologyBuilder throws java.lang.ExceptionInInitializerError - posted by "Sharma, Samiksha" <sa...@here.com> on 2016/03/14 21:03:43 UTC, 1 replies.
- [jira] [Created] (FLINK-3614) Remove Non-Keyed Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/15 11:01:33 UTC, 0 replies.
- [DISCUSS] Removing Non-Keyed WindowOperator - posted by Aljoscha Krettek <al...@apache.org> on 2016/03/15 11:02:55 UTC, 2 replies.
- [jira] [Created] (FLINK-3615) Add support for non-native SQL types - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/15 15:11:34 UTC, 0 replies.
- Association failure ClassNotFoundException - posted by Greg Hogan <co...@greghogan.com> on 2016/03/15 16:19:56 UTC, 4 replies.
- [jira] [Created] (FLINK-3616) Python API version inconsistencies - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/03/15 21:18:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/03/16 01:12:33 UTC, 0 replies.
- a question about CopyingChainOutput - posted by Ma GuoWei <ma...@outlook.com> on 2016/03/16 09:24:27 UTC, 1 replies.
- [jira] [Created] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/03/16 10:28:33 UTC, 0 replies.
- 答复: a question about CopyingChainOutput - posted by Ma GuoWei <ma...@outlook.com> on 2016/03/16 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-3619) SavepointCoordinator test failure - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/16 11:31:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3620) Remove DbStateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/16 12:22:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3621) Misleading documentation of memory configuration parameters - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 13:48:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3622) Improve error messages for invalid joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 18:02:33 UTC, 0 replies.
- Re: 答复: Effort to add SQL / StreamSQL to Flink - posted by Vasiliki Kalavri <va...@gmail.com> on 2016/03/16 18:17:09 UTC, 6 replies.
- [jira] [Created] (FLINK-3623) Adjust MurmurHash algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/16 18:25:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash - posted by "Zoltán Zvara (JIRA)" <ji...@apache.org> on 2016/03/16 18:29:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3625) Graph algorithms to permute graph labels and edges - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/16 20:24:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3626) zipWithIndex in Python API - posted by "Shannon Quinn (JIRA)" <ji...@apache.org> on 2016/03/16 20:54:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3627) Task stuck on lock in StreamSource when cancelling - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/03/16 21:44:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use - posted by "MaGuowei (JIRA)" <ji...@apache.org> on 2016/03/17 03:00:35 UTC, 0 replies.
- [jira] [Created] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()" - posted by "Li Fanxi (JIRA)" <ji...@apache.org> on 2016/03/17 07:48:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3630) Little mistake in documentation - posted by "Riccardo Diomedi (JIRA)" <ji...@apache.org> on 2016/03/17 10:46:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/17 13:47:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3632) Clean up Table API exceptions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/17 14:04:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3633) Job submission silently fails when using user code types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/17 14:32:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3634) Fix documentation for DataSetUtils.zipWithUniqueId() - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/17 14:41:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/17 15:05:33 UTC, 0 replies.
- YARN/Flink Job - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/03/17 23:57:20 UTC, 1 replies.
- [jira] [Created] (FLINK-3636) NoClassDefFoundError while running WindowJoin example - posted by "Zoltán Zvara (JIRA)" <ji...@apache.org> on 2016/03/18 11:56:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs - posted by "Lasse Dalegaard (JIRA)" <ji...@apache.org> on 2016/03/18 14:46:33 UTC, 0 replies.
- Re: Streaming KV store abstraction - posted by Nam-Luc Tran <na...@euranova.eu> on 2016/03/18 18:24:47 UTC, 2 replies.
- [jira] [Created] (FLINK-3638) Invalid default ports in documentation - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/03/21 09:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/21 14:13:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3640) Add support for SQL queries in DataSet programs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/21 14:21:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3641) Document registerCachedFile API call - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/21 14:30:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3642) Disentangle ExecutionConfig - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/21 14:59:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3643) Improve Window Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/21 17:38:25 UTC, 0 replies.
- [DISCUSS] Improving Trigger/Window API and Semantics - posted by Aljoscha Krettek <al...@apache.org> on 2016/03/21 17:46:28 UTC, 3 replies.
- Next steps: SQL / StreamSQL support - posted by Fabian Hueske <fh...@gmail.com> on 2016/03/21 17:56:09 UTC, 1 replies.
- [jira] [Created] (FLINK-3644) WebRuntimMonitor set java.io.tmpdir does not work for change upload dir. - posted by "astralidea (JIRA)" <ji...@apache.org> on 2016/03/22 04:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3645) HDFSCopyUtilitiesTest fails in a Hadoop cluster - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/03/22 09:41:25 UTC, 0 replies.
- RollingSink - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/03/22 10:08:50 UTC, 12 replies.
- [jira] [Created] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/22 12:04:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/22 12:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3648) Introduce Trigger Test Harness - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/22 12:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3649) Document stable API methods maxBy/minBy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/22 15:52:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/22 15:55:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3651) Fix faulty RollingSink Restore - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/22 16:22:25 UTC, 0 replies.
- RichMapPartitionFunction - problems with collect - posted by Sergio Ramírez <sr...@correo.ugr.es> on 2016/03/22 16:53:30 UTC, 3 replies.
- [jira] [Created] (FLINK-3652) Enable UnusedImports check for Scala checkstyle - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/22 16:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3653) recovery.zookeeper.storageDir is not documented on the configuration page - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/22 17:16:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3654) Disable Write-Ahead-Log in RocksDB State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/22 17:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3655) Allow comma-separated multiple directories to be specified for FileInputFormat - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/03/22 19:41:25 UTC, 0 replies.
- Behavior of lib directory shipping on YARN - posted by Stefano Baghino <st...@radicalbit.io> on 2016/03/22 20:42:54 UTC, 4 replies.
- [jira] [Created] (FLINK-3656) Rework TableAPI tests - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/22 21:14:25 UTC, 0 replies.
- a typical ML algorithm flow - posted by Dmitriy Lyubimov <dl...@gmail.com> on 2016/03/22 21:56:37 UTC, 12 replies.
- [jira] [Created] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/03/23 03:56:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 10:19:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3659) Allow ConnectedStreams to Be Keyed on Only One Side - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/23 10:40:25 UTC, 0 replies.
- [DISCUSS] Release 1.0.1 Bugfix release - posted by Aljoscha Krettek <al...@apache.org> on 2016/03/23 11:14:11 UTC, 10 replies.
- [jira] [Created] (FLINK-3660) Measure latency of elements and expose it through web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 11:18:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3661) Make Scala 2.11.x the default Scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/23 14:13:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/23 14:18:25 UTC, 0 replies.
- Proposal: YARN session per-job Kerberos authentication - posted by Stefano Baghino <st...@radicalbit.io> on 2016/03/23 15:55:36 UTC, 3 replies.
- [jira] [Created] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker - posted by "Niels Zeilemaker (JIRA)" <ji...@apache.org> on 2016/03/23 16:36:25 UTC, 0 replies.
- Aggregation Design Questions - posted by "Lisonbee, Todd" <to...@intel.com> on 2016/03/23 17:45:40 UTC, 1 replies.
- [jira] [Created] (FLINK-3664) Create a method to easily Summarize a DataSet - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/03/23 18:21:25 UTC, 0 replies.
- Apache Flink: aligning watermark among parallel tasks - posted by Ozan DENİZ <oz...@outlook.com> on 2016/03/24 09:03:02 UTC, 2 replies.
- [jira] [Created] (FLINK-3665) Range partitioning lacks support to define sort orders - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/24 12:43:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3666) Remove Nephele references - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/24 15:08:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3667) Generalize client<->cluster communication - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/24 15:35:25 UTC, 0 replies.
- Native iterations in PyFlink - posted by Shannon Quinn <sq...@gatech.edu> on 2016/03/24 21:20:14 UTC, 1 replies.
- Kerberos for Streaming & Kafka - posted by Eron Wright <ew...@live.com> on 2016/03/25 00:10:01 UTC, 2 replies.
- [jira] [Created] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/25 18:04:25 UTC, 0 replies.
- watermark in fault tolerance - posted by lonely Feb <lo...@gmail.com> on 2016/03/26 09:15:22 UTC, 1 replies.
- [jira] [Created] (FLINK-3669) WindowOperator registers a log of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/27 09:35:25 UTC, 0 replies.
- A whole bag of ML issues - posted by Trevor Grant <tr...@gmail.com> on 2016/03/28 20:01:23 UTC, 5 replies.
- Expected duration for cascading-flink tests? - posted by Ken Krugler <kk...@transpac.com> on 2016/03/29 00:39:12 UTC, 4 replies.
- Multi-Layer Perceptron - posted by Trevor Grant <tr...@gmail.com> on 2016/03/29 01:04:29 UTC, 0 replies.
- [jira] [Created] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 10:47:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3671) Code generation for POJO serializer - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/03/29 12:08:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3672) Code generation for POJO comparators - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/03/29 12:10:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3673) Annotations for code generation - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/03/29 12:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3674) Add an interface for EventTime aware User Function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/29 12:12:25 UTC, 0 replies.
- 答复: 答复: Effort to add SQL / StreamSQL to Flink - posted by "Jiangsong (Hi)" <hi...@huawei.com> on 2016/03/29 14:02:52 UTC, 1 replies.
- [jira] [Created] (FLINK-3675) YARN ship folder incosistent behavior - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/29 15:24:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3676) WebClient hasn't been removed from the docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 15:36:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 18:28:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3678) Make Flink logs directory configurable - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/29 18:49:25 UTC, 0 replies.
- withBroadcastSet for a DataStream missing? - posted by Stavros Kontopoulos <st...@gmail.com> on 2016/03/29 18:52:53 UTC, 0 replies.
- Range partitioning - posted by Dawid Wysakowicz <wy...@gmail.com> on 2016/03/29 20:47:28 UTC, 1 replies.
- [jira] [Created] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/03/29 22:37:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/03/30 05:16:25 UTC, 0 replies.
- Apache Flink <=> Apache Ignite integration - posted by Raul Kripalani <ra...@apache.org> on 2016/03/30 13:48:08 UTC, 4 replies.
- [jira] [Created] (FLINK-3681) CEP library does not support Java 8 lambdas as select function - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/30 15:07:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3682) CEP operator does not set the processing timestamp correctly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/30 15:27:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources() - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/03/30 16:02:25 UTC, 0 replies.
- Writing multiple streams to multiple kafka - posted by Deepak Jha <dk...@gmail.com> on 2016/03/30 20:19:51 UTC, 2 replies.
- cascading-flink 1.0 results - posted by Ken Krugler <kk...@transpac.com> on 2016/03/30 21:46:48 UTC, 0 replies.
- [jira] [Created] (FLINK-3684) CEP operator does not forward watermarks properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/31 11:37:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3685) Logical error in code for DateSerializer deserialize with reuse - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/03/31 12:13:25 UTC, 0 replies.
- Submission Problem - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/03/31 14:24:26 UTC, 9 replies.
- Performing consecutive Action operators - posted by Le Quoc Do <le...@gmail.com> on 2016/03/31 15:09:59 UTC, 1 replies.
- [VOTE] Release Apache Flink 1.0.1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/03/31 18:09:34 UTC, 0 replies.