You are viewing a plain text version of this content. The canonical link for it is here.

---

- [GitHub] flink pull request: Enhance Partitioned State and use it in Window... - posted by wenlonglwl <gi...@git.apache.org> on 2016/03/01 03:59:18 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3474] support partial aggregate - posted by ChengXiangLi <gi...@git.apache.org> on 2016/03/01 06:18:37 UTC, 45 replies.
- [jira] [Commented] (FLINK-3474) Partial aggregate interface design and sort-based implementation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 06:19:18 UTC, 45 replies.
- [GitHub] flink pull request: [FLINK-3422][streaming][api-breaking] Scramble... - posted by mbalassi <gi...@git.apache.org> on 2016/03/01 08:07:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-3422) Scramble HashPartitioner hashes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 08:08:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3537] Fix code gen for disjunctions. - posted by vasia <gi...@git.apache.org> on 2016/03/01 08:08:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-3537) Faulty code generation for disjunctions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 08:09:18 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3504] Fix join translation. Equality pr... - posted by vasia <gi...@git.apache.org> on 2016/03/01 08:09:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-3504) Join fails while have expression inside join condition. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 08:10:18 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3178] Don't Emit In-Flight Windows When... - posted by wenlonglwl <gi...@git.apache.org> on 2016/03/01 08:14:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 08:15:18 UTC, 2 replies.
- [GitHub] flink pull request: [docs] fix readme typos; use the same scala st... - posted by asfgit <gi...@git.apache.org> on 2016/03/01 08:16:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3504) Join fails while have expression inside join condition. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/01 09:06:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3537) Faulty code generation for disjunctions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/01 09:06:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2788] [apis] Add TypeHint class to allo... - posted by twalthr <gi...@git.apache.org> on 2016/03/01 10:19:23 UTC, 6 replies.
- [jira] [Commented] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 10:20:18 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3498] Implement TRIM, SUBSTRING as refe... - posted by twalthr <gi...@git.apache.org> on 2016/03/01 10:40:54 UTC, 10 replies.
- [jira] [Commented] (FLINK-3498) Implement TRIM, SUBSTRING as reference design for Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 10:41:18 UTC, 10 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] [Commented] (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:35:18 UTC, 19 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] [Updated] (FLINK-3555) Web interface does not render job information properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/01 11:39:18 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-3529 Add template for pull requests - posted by mxm <gi...@git.apache.org> on 2016/03/01 11:58:49 UTC, 13 replies.
- [jira] [Commented] (FLINK-3529) Add pull request template - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 11:59:18 UTC, 13 replies.
- [GitHub] flink pull request: [FLINK-3550] [FLINK-3552] Rework WindowJoin an... - posted by aljoscha <gi...@git.apache.org> on 2016/03/01 12:04:55 UTC, 4 replies.
- [jira] [Commented] (FLINK-3550) Rework stream join example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 12:05:18 UTC, 4 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] [Updated] (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-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.
- [GitHub] flink pull request: [FLINK-3557] [stream, scala] Introduce seconda... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/01 12:40:59 UTC, 6 replies.
- [jira] [Commented] (FLINK-3557) Scala DataStream fold method should take fold function in secondary parameter list - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 12:41:18 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3556] [runtime] Remove false check in H... - posted by uce <gi...@git.apache.org> on 2016/03/01 13:35:50 UTC, 6 replies.
- [jira] [Commented] (FLINK-3556) Unneeded check in HA blob store configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 13:36:18 UTC, 7 replies.
- [jira] [Updated] (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 14:29:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3554] [streaming] Emit a MAX Watermark ... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/01 14:34:04 UTC, 18 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] [Commented] (FLINK-2946) Add orderBy() to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/01 14:58:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3559] [dist] Don't print INFO if no act... - posted by uce <gi...@git.apache.org> on 2016/03/01 14:59:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-3559) Don't print pid file check if no active PID - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 14:59:18 UTC, 2 replies.
- [jira] [Closed] (FLINK-3556) Unneeded check in HA blob store configuration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:16:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3559) Don't print pid file check if no active PID - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:35:18 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:36:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:36:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:36:18 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:36:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:36:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/01 15:37:18 UTC, 0 replies.
- [jira] [Closed] (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 16:22:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/01 16:29:18 UTC, 3 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.
- [jira] [Closed] (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 17:23:18 UTC, 0 replies.
- [jira] [Resolved] (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 17:23:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3560] [examples] Remove unchecked outpu... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/01 17:30:43 UTC, 8 replies.
- [jira] [Commented] (FLINK-3560) Examples shouldn't always print usage statement - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/01 17:31:18 UTC, 8 replies.
- [jira] [Closed] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/01 20:29:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/01 20:29:18 UTC, 0 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.
- [GitHub] flink pull request: [build] Consolidate scala checkstyle usage and... - posted by mbalassi <gi...@git.apache.org> on 2016/03/02 11:17:04 UTC, 6 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] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/02 11:57:18 UTC, 5 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.
- [GitHub] flink pull request: [FLINK-3564] [table] Implement distinct() for ... - posted by twalthr <gi...@git.apache.org> on 2016/03/02 13:39:37 UTC, 11 replies.
- [jira] [Commented] (FLINK-3564) Implement distinct() for Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/02 13:40:18 UTC, 11 replies.
- [jira] [Commented] (FLINK-3152) Support all comparisons for Date type - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/03/02 14:13:18 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-3152) Support all comparisons for Date type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/02 14:22: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] [Assigned] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/02 14:40:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/02 14:49:18 UTC, 7 replies.
- [jira] [Commented] (FLINK-3561) ExecutionConfig's timestampsEnabled is unused - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/02 14:52:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/02 15:11:18 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/02 15:12: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.
- [jira] [Commented] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/02 16:20:18 UTC, 8 replies.
- [jira] [Resolved] (FLINK-3422) Scramble HashPartitioner hashes - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/02 17:33:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3565] add module to force execution of ... - posted by mxm <gi...@git.apache.org> on 2016/03/02 18:20:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/03/02 18:30:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3565) FlinkKafkaConsumer does not work with Scala 2.11 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/02 19:57:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3486] [tableAPI] Fix broken renaming of... - posted by fhueske <gi...@git.apache.org> on 2016/03/03 01:09:17 UTC, 2 replies.
- [jira] [Commented] (FLINK-3486) Use Project to rename all record fields would fail following Project. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 01:09:18 UTC, 2 replies.
- [GitHub] flink pull request: [docs] fix javascript exception caused by disq... - posted by wuchong <gi...@git.apache.org> on 2016/03/03 02:50:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/03/03 07:50:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3486) Use Project to rename all record fields would fail following Project. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/03 10:20:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3498) Implement TRIM, SUBSTRING as reference design for Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/03 10:21:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/03 11:08:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/03 11:35:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 11:37:18 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] [Closed] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/03 12:10:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3562) Update docs in the course of EventTimeSourceFunction removal - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/03 12:10: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.
- [GitHub] flink pull request: [FLINK-3569] set Maven Surefire working direct... - posted by mxm <gi...@git.apache.org> on 2016/03/03 12:53:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-3569) Test cases fail due to Maven Shade plugin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 12:54:18 UTC, 10 replies.
- [jira] [Commented] (FLINK-3568) Hadoop's Bzip decompression is not thread safe - posted by "Moritz Schubotz (JIRA)" <ji...@apache.org> on 2016/03/03 13:18:18 UTC, 11 replies.
- [jira] [Updated] (FLINK-3568) Hadoop's Bzip decompression is not thread safe - posted by "Sebastian Neef (JIRA)" <ji...@apache.org> on 2016/03/03 13:20:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 13:29:18 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/03/03 13:43:07 UTC, 17 replies.
- [jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 13:43:18 UTC, 29 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.
- [GitHub] flink pull request: [FLINK-3570] [runtime] Use InetAddress.getLoca... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 14:31:23 UTC, 3 replies.
- [jira] [Commented] (FLINK-3570) Replace random NIC selection heuristic by InetAddress.getLocalHost - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 14:32:18 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3429) Add histogram-based timestamp/watermark extractor - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/03/03 15:18:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/03/03 15:18: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.
- [GitHub] flink pull request: [FLINK-3496] Fix ML test discovery on Windows - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 15:49:12 UTC, 1 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] [Commented] (FLINK-3496) Flink-ml tests fail on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 15:49:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3496) Flink-ml tests fail on Windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/03 15:51:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 15:55:32 UTC, 33 replies.
- [jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 15:56:18 UTC, 32 replies.
- [GitHub] flink pull request: [FLINK-3566] [FLINK-3563] Input type validatio... - posted by twalthr <gi...@git.apache.org> on 2016/03/03 16:06:21 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3454] Add test dependencies on packaged... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 16:11:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-3454) Add test dependencies on packaged jars - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 16:12:18 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3571) SavepointITCase.testRestoreFailure fails on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/03 16:15:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3467] Remove superfluous objects from D... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 16:15:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 16:16:18 UTC, 2 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.
- [GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 16:22:59 UTC, 7 replies.
- [jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 16:23:18 UTC, 7 replies.
- [jira] [Assigned] (FLINK-3573) Implement more String functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 16:26:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3432] Fixed ZookeeperOffsethandlerTest ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/03 16:27:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 16:28:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/03 16:30:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3403) Create Section "Working with Time" in Streaming Guide - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/03 16:52: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.
- [GitHub] flink pull request: [FLINK-3575] Update Working With State Section... - posted by aljoscha <gi...@git.apache.org> on 2016/03/03 16:55:45 UTC, 3 replies.
- [jira] [Commented] (FLINK-3575) Update Working With State Section in Doc - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/03 16:56:18 UTC, 3 replies.
- [jira] [Updated] (FLINK-3574) Implement math functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/03 17:00:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3484) Add setSlotSharingGroup documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/03 17:12:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3507) PruneEmptyRules does not prune empty node as expected. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/03 17:25:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/03 17:26:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2757) DataSinkTaskTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/03 17:34:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2369) On Windows, in testFailingSortingDataSinkTask the temp file is not removed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/03 17:35:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/03 17:49:18 UTC, 0 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] [Assigned] (FLINK-3567) Rework selection when grouping in Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/04 09:50:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3567] Fix selection on grouping. Only g... - posted by fhueske <gi...@git.apache.org> on 2016/03/04 10:14:14 UTC, 6 replies.
- [jira] [Commented] (FLINK-3567) Rework selection when grouping in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 10:14:40 UTC, 6 replies.
- [jira] [Closed] (FLINK-3568) Hadoop's Bzip decompression is not thread safe - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/04 10:21:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3570) Replace random NIC selection heuristic by InetAddress.getLocalHost - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/04 10:37:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3396] [runtime] Suppress job restart if... - posted by uce <gi...@git.apache.org> on 2016/03/04 10:44:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-3396) Job submission Savepoint restore logic flawed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 10:44:40 UTC, 1 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] [Updated] (FLINK-3577) Display anchor links when hovering over headers. - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/03/04 10:48:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast... - posted by HungUnicorn <gi...@git.apache.org> on 2016/03/04 11:26:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 11:26:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3577] [docs] Display anchor links when ... - posted by wuchong <gi...@git.apache.org> on 2016/03/04 12:07:13 UTC, 3 replies.
- [jira] [Commented] (FLINK-3577) Display anchor links when hovering over headers. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 12:07:40 UTC, 3 replies.
- [GitHub] flink pull request: [docs] fix the active tab caption is not displ... - posted by wuchong <gi...@git.apache.org> on 2016/03/04 12:07:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 12:09:40 UTC, 13 replies.
- [GitHub] flink pull request: FLINK-3428: Adds a fixed time trailing waterma... - posted by kl0u <gi...@git.apache.org> on 2016/03/04 12:09:40 UTC, 13 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.
- [GitHub] flink pull request: [FLINK-3578] Support RichFunctions for Scala W... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/04 12:34:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-3578) Scala DataStream API does not support Rich Window Functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 12:34:40 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3573] [table] Implement more String fun... - posted by twalthr <gi...@git.apache.org> on 2016/03/04 12:55:19 UTC, 5 replies.
- [jira] [Commented] (FLINK-3573) Implement more String functions for Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 12:55:40 UTC, 5 replies.
- [jira] [Commented] (FLINK-3574) Implement math functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/04 12:57:40 UTC, 16 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.
- [GitHub] flink pull request: [FLINK-3569] fix test cases that expect a diff... - posted by mxm <gi...@git.apache.org> on 2016/03/04 13:59:14 UTC, 5 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.
- [GitHub] flink pull request: [FLINK-3495] Disable RocksDB tests on Windows - posted by StephanEwen <gi...@git.apache.org> on 2016/03/04 18:15:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 18:15:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3491] Prevent failure of HDFSCopyUtilit... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/04 18:15:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/04 18:16:40 UTC, 1 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.
- [jira] [Updated] (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:24:40 UTC, 5 replies.
- [jira] [Resolved] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:29:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:29:41 UTC, 0 replies.
- [jira] [Closed] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:30:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:30:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:31:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:33:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3575) Update Working With State Section in Doc - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:34:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3575) Update Working With State Section in Doc - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:34:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3578) Scala DataStream API does not support Rich Window Functions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:35:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3578) Scala DataStream API does not support Rich Window Functions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:35:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3550) Rework stream join example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:35:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3550) Rework stream join example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:36:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3552) Change socket WordCount to be properly windowed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:36:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3552) Change socket WordCount to be properly windowed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/05 00:36:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3583] User configuration visible in web... - posted by fijolekProjects <gi...@git.apache.org> on 2016/03/05 01:16:11 UTC, 10 replies.
- [jira] [Commented] (FLINK-3583) Configuration not visible in gui when job is running - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/05 01:16:40 UTC, 10 replies.
- [jira] [Closed] (FLINK-3569) Test cases fail due to Maven Shade plugin - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/05 14:50:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3322] MemoryManager creates too much GC... - posted by Xazax-hun <gi...@git.apache.org> on 2016/03/06 11:16:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/06 11:16:40 UTC, 6 replies.
- [jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/03/06 12:49:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/06 13:03:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/06 13:03:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/06 13:03:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/03/06 22:12:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/07 04:13:40 UTC, 2 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] [Commented] (FLINK-3584) WebInterface: Broken graphical display in Chrome - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/07 13:38:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3547] add support for streaming filter,... - posted by vasia <gi...@git.apache.org> on 2016/03/07 15:22:56 UTC, 23 replies.
- [jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/07 15:23:40 UTC, 23 replies.
- [GitHub] flink pull request: FLINK-3327: ExecutionConfig to JobGraph. - posted by kl0u <gi...@git.apache.org> on 2016/03/07 17:28:51 UTC, 6 replies.
- [jira] [Commented] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/07 17:29:40 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3564) Implement distinct() for Table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/07 17:31:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3567) Rework selection when grouping in Table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/07 17: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.
- [GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto... - posted by zentol <gi...@git.apache.org> on 2016/03/07 17:53:50 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-3332] Add Exactly-Once Cassandra connec... - posted by zentol <gi...@git.apache.org> on 2016/03/07 17:54:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/07 17:54:40 UTC, 11 replies.
- [jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/07 17:54:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav... - posted by asfgit <gi...@git.apache.org> on 2016/03/07 18:18:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/07 18:18:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-3585) Deploy scripts don't support spaces in paths - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/07 18:18:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3383) Separate Maven deployment from CI testing - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/07 18:19:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by chiwanpark <gi...@git.apache.org> on 2016/03/08 04:10:48 UTC, 9 replies.
- [jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 04:11:40 UTC, 9 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.
- [jira] [Closed] (FLINK-3474) Partial aggregate interface design and sort-based implementation - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/03/08 09:22:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3429) Add histogram-based timestamp/watermark extractor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/08 11:04:40 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-3309] [py] Resolve Maven warnings - posted by zentol <gi...@git.apache.org> on 2016/03/08 11:51:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-3309) [py] Resolve maven warnings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 11:51:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-3309) [py] Resolve maven warnings - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 11:54:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3331] TupleSerializer.getLength() can r... - posted by zentol <gi...@git.apache.org> on 2016/03/08 11:56:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 11:56:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 12:07:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3169] Remove Key class - posted by zentol <gi...@git.apache.org> on 2016/03/08 12:09:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 12:09:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3472] Better exception if jdbc field is... - posted by zentol <gi...@git.apache.org> on 2016/03/08 12:24:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 12:25:40 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/03/08 12:50:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/08 13:46:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 13:51: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] [Resolved] (FLINK-3573) Implement more String functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/08 14:11:40 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3574) Implement math functions for Table API - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/03/08 14:12: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.
- [GitHub] flink pull request: [FLINK-3590] Hide derby log in JDBC tests - posted by zentol <gi...@git.apache.org> on 2016/03/08 15:04:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-3590) JDBC Format tests don't hide derby logs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 15:04:40 UTC, 2 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.
- [GitHub] flink pull request: [FLINK-3591] Replace Quickstart K-Means Exampl... - posted by aljoscha <gi...@git.apache.org> on 2016/03/08 15:53:01 UTC, 27 replies.
- [jira] [Commented] (FLINK-3591) Replace Quickstart K-Means Example by Streaming Example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 15:53:40 UTC, 27 replies.
- [jira] [Commented] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 16:07:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 16:08:40 UTC, 0 replies.
- [GitHub] flink pull request: Improve TaskManagerTest#testRemotePartitionNot... - posted by zentol <gi...@git.apache.org> on 2016/03/08 16:10:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/03/08 16:12:40 UTC, 2 replies.
- [jira] [Updated] (FLINK-2444) Add tests for HadoopInputFormats - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 16:29:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 16:29:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 16:32:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/08 16:35:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3579) Improve String concatenation - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/08 17:03:40 UTC, 48 replies.
- [jira] [Resolved] (FLINK-3591) Replace Quickstart K-Means Example by Streaming Example - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/08 17:19:40 UTC, 0 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] [Closed] (FLINK-3592) Update setup quickstart - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/08 18:46: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.
- [jira] [Updated] (FLINK-3593) DistinctITCase is failing - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/08 20:01:41 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3593) DistinctITCase is failing - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/08 20:37:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3593) DistinctITCase is failing - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/08 20:37:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3574] Implement math functions for Tabl... - posted by dawidwys <gi...@git.apache.org> on 2016/03/08 20:50:46 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-3207] [gelly] adds the vertex-centric i... - posted by s1ck <gi...@git.apache.org> on 2016/03/08 22:11:55 UTC, 6 replies.
- [jira] [Commented] (FLINK-3207) Add a Pregel iteration abstraction to Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/08 22:12:40 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2997] Support range partition with user... - posted by gallenvara <gi...@git.apache.org> on 2016/03/09 03:24:58 UTC, 68 replies.
- [jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/09 03:25:40 UTC, 68 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.
- [jira] [Closed] (FLINK-3396) Job submission Savepoint restore logic flawed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/09 12:17:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3589) Allow setting Operator parallelism to default value - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/09 12:34:40 UTC, 4 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] [Updated] (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:35:40 UTC, 0 replies.
- [jira] [Commented] (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:35:40 UTC, 4 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.
- [GitHub] flink pull request: [FLINK-3596] DataSet RelNode refactoring - posted by vasia <gi...@git.apache.org> on 2016/03/09 15:46:51 UTC, 8 replies.
- [jira] [Commented] (FLINK-3596) DataSet RelNode refactoring - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/09 15:47:40 UTC, 8 replies.
- [jira] [Updated] (FLINK-3594) Unstable KafkaConsumerTestBase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/09 16:46:40 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.
- [GitHub] flink pull request: [FLINK-3589] Allow setting Operator parallelis... - posted by greghogan <gi...@git.apache.org> on 2016/03/09 21:24:52 UTC, 2 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:41 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Remove obsolete "Working with Time" S... - posted by aljoscha <gi...@git.apache.org> on 2016/03/10 10:27:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-3598) java.lang.NoSuchMethodError: org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfo - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 11:08:40 UTC, 1 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] [Closed] (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 11:37:40 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/10 14:24:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 14:26:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3561) ExecutionConfig's timestampsEnabled is unused - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/10 14:41:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3595] [runtime] Eagerly destroy buffer ... - posted by uce <gi...@git.apache.org> on 2016/03/10 14:58:29 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats - posted by mliesenberg <gi...@git.apache.org> on 2016/03/10 15:29:20 UTC, 18 replies.
- [jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/10 15:29:40 UTC, 18 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.
- [GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone... - posted by mxm <gi...@git.apache.org> on 2016/03/10 17:46:48 UTC, 151 replies.
- [jira] [Commented] (FLINK-3544) ResourceManager runtime components - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/10 17:47:40 UTC, 150 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.
- [GitHub] flink pull request: Netcat arguments for Mac OS X - posted by zitterbewegung <gi...@git.apache.org> on 2016/03/10 19:27:46 UTC, 4 replies.
- [GitHub] flink pull request: added support for Main-Class separated by / in... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/10 19:57:47 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3577) Display anchor links when hovering over headers. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 20:30:41 UTC, 0 replies.
- [jira] [Closed] (FLINK-3577) Display anchor links when hovering over headers. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 20:30:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-3594) StreamTask may fail when checkpoint is concurrent to regular termination - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 21:31:41 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3594) StreamTask may fail when checkpoint is concurrent to regular termination - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 21:32:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3594) StreamTask may fail when checkpoint is concurrent to regular termination - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/10 21:34:40 UTC, 1 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] [Commented] (FLINK-1932) Add L-BFGS to the optimization framework - posted by "Soila Kavulya (JIRA)" <ji...@apache.org> on 2016/03/11 03:40:40 UTC, 5 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.
- [jira] [Updated] (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:55:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3596) DataSet RelNode refactoring - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/11 09:02:55 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3604) Enable ignored Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 09:15:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3603) Re-enable Table API explain - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 09:17:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-3587) Bump Calcite version to 1.7.0-SNAPSHOT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 09:18:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/11 09:32:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-3489) Refactor Table API before merging into master - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/11 10:40:41 UTC, 8 replies.
- [jira] [Assigned] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/11 10:45:39 UTC, 0 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] [Commented] (FLINK-3608) ImmutableSettings error in ElasticsearchSink - posted by "Carlos Gonzalez de Zarate (JIRA)" <ji...@apache.org> on 2016/03/11 12:13:05 UTC, 3 replies.
- [GitHub] flink pull request: Enable and fix ignored Table API tests - posted by fhueske <gi...@git.apache.org> on 2016/03/11 12:36:58 UTC, 5 replies.
- [GitHub] flink pull request: Enable Table API explain and add descriptive o... - posted by fhueske <gi...@git.apache.org> on 2016/03/11 12:40:03 UTC, 9 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.
- [GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of... - posted by rmetzger <gi...@git.apache.org> on 2016/03/11 14:57:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/11 14:57:41 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3333] [Documentation][DataSet] Improve ... - posted by fhueske <gi...@git.apache.org> on 2016/03/11 15:18:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/11 15:19:53 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-1932) Add L-BFGS to the optimization framework - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/03/11 15:37:56 UTC, 0 replies.
- [GitHub] flink pull request: [streaming] Fast calculation of medians of win... - posted by uce <gi...@git.apache.org> on 2016/03/11 15:45:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-3607) Decrease default forkCount for tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/11 15:47:48 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos - posted by uce <gi...@git.apache.org> on 2016/03/11 15:51:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/11 15:52:54 UTC, 2 replies.
- [jira] [Commented] (FLINK-3602) Recursive Types are not supported / crash TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/11 16:42:19 UTC, 7 replies.
- [jira] [Assigned] (FLINK-3602) Recursive Types are not supported / crash TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/11 17:51:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/11 19:32:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/11 19:33:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3109]Join two streams with two differen... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/11 19:48:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3109) Join two streams with two different buffer time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/11 19:48:39 UTC, 1 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] [Assigned] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/13 05:33:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3610][api-breaking][streaming] Introduc... - posted by mbalassi <gi...@git.apache.org> on 2016/03/13 06:44:16 UTC, 2 replies.
- [jira] [Commented] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/13 06:44:33 UTC, 3 replies.
- [jira] [Updated] (FLINK-3576) Upgrade Snappy Java to 1.1.2.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/13 15:58:33 UTC, 2 replies.
- [jira] [Closed] (FLINK-3590) JDBC Format tests don't hide derby logs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/13 17:26:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3590) JDBC Format tests don't hide derby logs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/13 17:26:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/13 17:30:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/13 17:31:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/13 17:31:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/03/13 17:31:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3599) GSoC: Code Generation in Serializers - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/03/13 18:20:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/13 19:04:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3272] [Gelly] Generic value in Connecte... - posted by s1ck <gi...@git.apache.org> on 2016/03/13 20:58:24 UTC, 2 replies.
- [jira] [Commented] (FLINK-3272) Generalize vertex value type in ConnectedComponents - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/13 20:58:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Furkan KAMACI (JIRA)" <ji...@apache.org> on 2016/03/13 23:08:33 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-3611] [docs] corrected link in CONTRIBU... - posted by s1ck <gi...@git.apache.org> on 2016/03/14 00:09:06 UTC, 6 replies.
- [jira] [Commented] (FLINK-3611) Wrong link in CONTRIBUTING.md - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/14 00:09:33 UTC, 6 replies.
- [jira] [Commented] (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/14 02:43:33 UTC, 0 replies.
- [jira] [Comment Edited] (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/14 02:50:33 UTC, 0 replies.
- [jira] [Resolved] (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/14 02:52:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/14 09:58:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3489) Refactor Table API before merging into master - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 10:31:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/14 10:50:33 UTC, 35 replies.
- [jira] [Resolved] (FLINK-3333) Documentation about object reuse should be improved - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/14 10:58:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-2946) Add orderBy() to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/14 12:52:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3602] Recursive Types are not supported... - posted by twalthr <gi...@git.apache.org> on 2016/03/14 13:38:16 UTC, 4 replies.
- [GitHub] flink pull request: Flink 3579 Improve String concatenation - posted by ramkrish86 <gi...@git.apache.org> on 2016/03/14 13:43:13 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3563) .returns() doesn't compile when using .map() with a custom MapFunction - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/14 13:47:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3579) Improve String concatenation - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/14 13:47:33 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3579) Improve String concatenation - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/14 13:48:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3583) Configuration not visible in gui when job is running - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/14 14:02:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3597) Table API operator names should reflect relational expression - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 14:03:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3603) Re-enable Table API explain - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 14:04:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3604) Enable ignored Table API tests - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 14:21:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3609) Revisit selection of Calcite rules - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/14 14:31:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3489] TableAPI refactoring and cleanup - posted by vasia <gi...@git.apache.org> on 2016/03/14 14:43:41 UTC, 5 replies.
- [jira] [Closed] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/14 14:44:33 UTC, 0 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] [Updated] (FLINK-3612) Fix/adjust Table API examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 15:48:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3574) Implement math functions for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/14 16:00:39 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.
- [jira] [Commented] (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, 1 replies.
- [jira] [Commented] (FLINK-3612) Fix/adjust Table API examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 17:56:33 UTC, 8 replies.
- [jira] [Resolved] (FLINK-3272) Generalize vertex value type in ConnectedComponents - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 18:00:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard - posted by zentol <gi...@git.apache.org> on 2016/03/14 19:08:13 UTC, 71 replies.
- [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/14 19:08:33 UTC, 71 replies.
- [jira] [Updated] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/03/14 19:24:33 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3129] Add japicmp-maven-plugin to ensur... - posted by rmetzger <gi...@git.apache.org> on 2016/03/14 19:28:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-3129) Add tooling to ensure interface stability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/14 19:29:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/14 20:22:33 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3612) Fix/adjust Table API examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/14 20:33:33 UTC, 0 replies.
- [GitHub] flink pull request: [WIP] FLINK-3115: Update ElasticSearch connect... - posted by smarthi <gi...@git.apache.org> on 2016/03/15 09:34:53 UTC, 16 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.
- [jira] [Commented] (FLINK-3614) Remove Non-Keyed Window Operator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/15 11:14:33 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/15 12:02:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3612] Fix/adjust Table API examples - posted by vasia <gi...@git.apache.org> on 2016/03/15 12:05:30 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3492] Configurable interval between Che... - posted by zentol <gi...@git.apache.org> on 2016/03/15 13:14:44 UTC, 14 replies.
- [jira] [Commented] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/15 13:15:33 UTC, 14 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.
- [GitHub] flink pull request: Kafka-3375: Allows Watermark Generation in the... - posted by kl0u <gi...@git.apache.org> on 2016/03/15 15:25:45 UTC, 6 replies.
- [jira] [Assigned] (FLINK-3407) Extend TwitterSource with interface StoppableFunction - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/15 19:10:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1964] Reimplement TwitterSource - posted by rmetzger <gi...@git.apache.org> on 2016/03/15 19:11:47 UTC, 4 replies.
- [jira] [Commented] (FLINK-1964) Rework TwitterSource to use a Properties object instead of a file path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/15 19:12:33 UTC, 5 replies.
- [jira] [Resolved] (FLINK-3489) Refactor Table API before merging into master - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/15 19:16:33 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-3609] [tableAPI] Reorganize selection o... - posted by fhueske <gi...@git.apache.org> on 2016/03/15 23:03:42 UTC, 13 replies.
- [jira] [Commented] (FLINK-3609) Revisit selection of Calcite rules - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/15 23:04:33 UTC, 13 replies.
- [GitHub] flink pull request: [FLINK-3503] [tableAPI] Add cost model for Dat... - posted by fhueske <gi...@git.apache.org> on 2016/03/15 23:07:57 UTC, 5 replies.
- [jira] [Commented] (FLINK-3503) ProjectJoinTransposeRule fails to push down project. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/15 23:08:33 UTC, 5 replies.
- [GitHub] flink pull request: [hotFix] [tableAPI] Improve naming of DataSetR... - posted by fhueske <gi...@git.apache.org> on 2016/03/15 23:38:12 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3506) ReduceExpressionsRule does not remove duplicate expression in Filter - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/15 23:46: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.
- [jira] [Reopened] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/16 09:55:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/16 09:55:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/16 09:56:33 UTC, 0 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.
- [jira] [Commented] (FLINK-3616) Python API version inconsistencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/16 10:43:33 UTC, 1 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] [Assigned] (FLINK-3619) SavepointCoordinator test failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/16 11:33:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3619) SavepointCoordinator test failure - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/16 11:41:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3612) Fix/adjust Table API examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/16 12:01: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.
- [GitHub] flink pull request: [FLINK-3620] [streaming] Remove DbStateBackend - posted by gyfora <gi...@git.apache.org> on 2016/03/16 12:24:56 UTC, 3 replies.
- [jira] [Commented] (FLINK-3620) Remove DbStateBackend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/16 12:25:33 UTC, 3 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.
- [GitHub] flink pull request: [FLINK-3621] Improve documentation of memory c... - posted by fhueske <gi...@git.apache.org> on 2016/03/16 14:00:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-3621) Misleading documentation of memory configuration parameters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/16 14:00:36 UTC, 3 replies.
- [jira] [Closed] (FLINK-3621) Misleading documentation of memory configuration parameters - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 14:19:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3174] Add MergingWindowAssigner and Ses... - posted by aljoscha <gi...@git.apache.org> on 2016/03/16 15:06:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-3174) Add merging WindowAssigner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/16 15:07:33 UTC, 0 replies.
- [GitHub] flink pull request: [WIP] [streaming] OutOfCoreKvState added + maj... - posted by gyfora <gi...@git.apache.org> on 2016/03/16 15:12:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-3620) Remove DbStateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/03/16 15:13:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3503) ProjectJoinTransposeRule fails to push down project. - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/16 15:38:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3503) ProjectJoinTransposeRule fails to push down project. - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/16 15:38:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3609) Revisit selection of Calcite rules - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/16 15:39:34 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix][examples] Add zookeeper.connect to us... - posted by stefanobaghino <gi...@git.apache.org> on 2016/03/16 15:51:50 UTC, 5 replies.
- [jira] [Resolved] (FLINK-3505) JoinUnionTransposeRule fails to push Join past Union. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 16:11:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3487) FilterAggregateTransposeRule does not transform logical plan as desired. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 16:13:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3507) PruneEmptyRules does not prune empty node as expected. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 16:17:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3524) Provide a JSONSerialisationSchema in the kafka connector package - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/16 17:02:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3524) Provide a JSONSerialisationSchema in the kafka connector package - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/16 17:04:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3524) Provide a JSONDeserialisationSchema in the kafka connector package - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/16 17:04:33 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix][docs] fs.hdfs.hadoopconf typo - posted by stefanobaghino <gi...@git.apache.org> on 2016/03/16 17:08:35 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1964] Rework TwitterSource to use a Pro... - posted by asfgit <gi...@git.apache.org> on 2016/03/16 17:33:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1964) Rework TwitterSource to use a Properties object instead of a file path - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/16 17:33:34 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.
- [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] [Assigned] (FLINK-3622) Improve error messages for invalid joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/16 19:00:37 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] [Commented] (FLINK-3626) zipWithIndex in Python API - posted by "Shannon Quinn (JIRA)" <ji...@apache.org> on 2016/03/16 21:24:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3614] Remove Non-Keyed Window Operator - posted by aljoscha <gi...@git.apache.org> on 2016/03/16 21:44:00 UTC, 1 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] [Commented] (FLINK-3627) Task stuck on lock in StreamSource when cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/16 22:34:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3623] [runtime] Adjust MurmurHash Algor... - posted by greghogan <gi...@git.apache.org> on 2016/03/17 01:53:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-3623) Adjust MurmurHash algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/17 01:53:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2909] [Gelly] Graph generators - posted by greghogan <gi...@git.apache.org> on 2016/03/17 01:55:31 UTC, 4 replies.
- [jira] [Commented] (FLINK-2909) Gelly Graph Generators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/17 01:55:33 UTC, 4 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.
- [GitHub] flink pull request: [FLINK-3579] Improve String concatenation - posted by ramkrish86 <gi...@git.apache.org> on 2016/03/17 05:50:00 UTC, 6 replies.
- [jira] [Assigned] (FLINK-3475) DISTINCT aggregate function support - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/03/17 07:04:33 UTC, 0 replies.
- [jira] [Assigned] (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/17 07:06:33 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.
- [GitHub] flink pull request: [FLINK-3692] Fix quick start description for t... - posted by lifanxi <gi...@git.apache.org> on 2016/03/17 07:53:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/17 09:40:33 UTC, 2 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] [Assigned] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/17 10:52:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3034][Streaming Connectors] Redis Sink ... - posted by subhankarb <gi...@git.apache.org> on 2016/03/17 10:57:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-3034) Redis SInk Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/17 10:58:33 UTC, 37 replies.
- [jira] [Commented] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/17 11:09:33 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/17 11:10:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3628) ChainingOutput and CopyingChainingOutput setKeyContextElement1 is no use - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/17 11:11:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/17 11:31:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/17 11:59:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3630) Little mistake in documentation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/17 12:04:33 UTC, 2 replies.
- [GitHub] flink pull request: [docs] typo seperate - separate - posted by alkagin <gi...@git.apache.org> on 2016/03/17 12:06:11 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3630) Little mistake in documentation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/17 12:09:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-3630) Little mistake in documentation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/17 12:09:33 UTC, 1 replies.
- [GitHub] flink pull request: Updates the AssignerWithPunctuatedWatermarks a... - posted by kl0u <gi...@git.apache.org> on 2016/03/17 12:58:21 UTC, 2 replies.
- [GitHub] flink pull request: [hotfix] Fix typo 'JobManger' - posted by stefanobaghino <gi...@git.apache.org> on 2016/03/17 12:59:25 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3034] Redis Sink Connector - posted by subhankarb <gi...@git.apache.org> on 2016/03/17 13:14:16 UTC, 36 replies.
- [jira] [Resolved] (FLINK-3407) Extend TwitterSource with interface StoppableFunction - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/17 13:23:33 UTC, 0 replies.
- [jira] [Comment Edited] (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 13:34:33 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-3629] Fix quick start description for t... - posted by asfgit <gi...@git.apache.org> on 2016/03/17 14:10:42 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3629) In wikiedits Quick Start example, "The first call, .window()" should be "The first call, .timeWindow()" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/17 14:13: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] [Updated] (FLINK-3633) Job submission silently fails when using user code types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/17 14:55:33 UTC, 1 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.
- [GitHub] flink pull request: [hotfix] Update python.md - posted by zentol <gi...@git.apache.org> on 2016/03/17 15:07:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/17 18:40:33 UTC, 10 replies.
- [GitHub] flink pull request: [hotfix] [docs] Flink hotfix windows docs - posted by smarthi <gi...@git.apache.org> on 2016/03/17 22:14:54 UTC, 2 replies.
- [GitHub] flink pull request: [hotfix] [docs] Fix broken link in Windows doc... - posted by smarthi <gi...@git.apache.org> on 2016/03/17 22:18:28 UTC, 3 replies.
- [GitHub] flink pull request: FLINK-3115: Update ElasticSearch connector to ... - posted by smarthi <gi...@git.apache.org> on 2016/03/17 23:33:08 UTC, 17 replies.
- [jira] [Commented] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/03/17 23:57:33 UTC, 5 replies.
- [jira] [Updated] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/03/18 01:04:33 UTC, 0 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] [Commented] (FLINK-3636) NoClassDefFoundError while running WindowJoin example - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/18 11:59:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-3636) NoClassDefFoundError while running WindowJoin example - posted by "Zoltán Zvara (JIRA)" <ji...@apache.org> on 2016/03/18 12:05: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.
- [jira] [Updated] (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, 1 replies.
- [jira] [Resolved] (FLINK-3622) Improve error messages for invalid joins - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 14:54:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3632) Clean up Table API exceptions - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 14:55:33 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3632) Clean up Table API exceptions - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 14:55:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3225) Optimize logical Table API plans in Calcite - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 14:56:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3223) Translate Table API query into logical relational plans for Apache Calcite - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 14:57:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 14:58:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3221) Move Table API on top of Apache Calcite - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/18 15:02:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ... - posted by fhueske <gi...@git.apache.org> on 2016/03/18 16:20:44 UTC, 5 replies.
- [jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/18 16:21:33 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3633) Job submission silently fails when using user code types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/18 16:22:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3634] [docs] Fix documentation for Data... - posted by greghogan <gi...@git.apache.org> on 2016/03/18 16:29:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-3634) Fix documentation for DataSetUtils.zipWithUniqueId() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/18 16:30:33 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/18 16:31:53 UTC, 16 replies.
- [jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/18 16:32:33 UTC, 19 replies.
- [jira] [Comment Edited] (FLINK-3633) Job submission silently fails when using user code types - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/03/18 16:33:33 UTC, 0 replies.
- [GitHub] flink pull request: Flink-3429: adds a histogram-based watermark e... - posted by kl0u <gi...@git.apache.org> on 2016/03/18 19:41:51 UTC, 9 replies.
- [jira] [Resolved] (FLINK-3636) NoClassDefFoundError while running WindowJoin example - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/03/20 22:07:33 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3579 Improve String concatenation (Ram) - posted by ramkrish86 <gi...@git.apache.org> on 2016/03/21 08:27:47 UTC, 24 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.
- [GitHub] flink pull request: FLINK-3179 - Adding just a log message - posted by ramkrish86 <gi...@git.apache.org> on 2016/03/21 12:36:01 UTC, 7 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] [Assigned] (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:22: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] [Assigned] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/03/21 15:21:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Roy Ben-Alta (JIRA)" <ji...@apache.org> on 2016/03/21 15:25:25 UTC, 8 replies.
- [jira] [Assigned] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/21 17:27:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3631] CodeGenerator does not check type... - posted by ramkrish86 <gi...@git.apache.org> on 2016/03/21 17:36:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/21 17:36:25 UTC, 3 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.
- [jira] [Commented] (FLINK-3399) Count with timeout trigger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/21 17:40:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3399) Count with timeout trigger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/21 17:40:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3640) Add support for SQL queries in DataSet programs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/21 18:33:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3207) Add a Pregel iteration abstraction to Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/21 19:13:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3587) Bump Calcite version to 1.7.0 - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/21 21:25:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3587) Bump Calcite version to 1.7.0 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/21 21:29:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1579) Create a Flink History Server - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/03/21 22:24:25 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-3644] WebRuntimMonitor set java.io.tmpd... - posted by Astralidea <gi...@git.apache.org> on 2016/03/22 05:25:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-3644) WebRuntimMonitor set java.io.tmpdir does not work for change upload dir. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 05:26:25 UTC, 2 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.
- [GitHub] flink pull request: [FLINK-3645] [tests] HDFSCopyUtilitiesTest fai... - posted by chiwanpark <gi...@git.apache.org> on 2016/03/22 09:47:05 UTC, 3 replies.
- [jira] [Commented] (FLINK-3645) HDFSCopyUtilitiesTest fails in a Hadoop cluster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 09:47:25 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/22 11:43:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2444] add tests for HadoopInputFormats - posted by fhueske <gi...@git.apache.org> on 2016/03/22 11:51:57 UTC, 8 replies.
- [jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 11:52:25 UTC, 8 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.
- [GitHub] flink pull request: Refactor rolling sink writer - posted by dalegaard <gi...@git.apache.org> on 2016/03/22 12:04:48 UTC, 3 replies.
- [jira] [Commented] (FLINK-3637) Change RollingSink Writer interface to allow wider range of outputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 12:05: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] [Updated] (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] [Closed] (FLINK-3645) HDFSCopyUtilitiesTest fails in a Hadoop cluster - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/03/22 12:46:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2935] [scala-shell] Allow Scala shell t... - posted by chiwanpark <gi...@git.apache.org> on 2016/03/22 13:51:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 13:51:25 UTC, 4 replies.
- [jira] [Closed] (FLINK-3631) CodeGenerator does not check type compatibility for equality expressions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/22 14:00:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-3611) Wrong link in CONTRIBUTING.md - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/22 14:00:28 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3602) Recursive Types are not supported / crash TypeExtractor - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/22 14:46:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/22 14:47:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3311] Add a connector for streaming dat... - posted by alkagin <gi...@git.apache.org> on 2016/03/22 14:58:54 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.
- [GitHub] flink pull request: [FLINK-3150] Make the YARN container start inv... - posted by rmetzger <gi...@git.apache.org> on 2016/03/22 16:10:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-3150) Make YARN container invocation configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 16:10:25 UTC, 1 replies.
- [jira] [Closed] (FLINK-3066) Kafka producer fails on leader change - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/22 16:21: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.
- [jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/22 16:25:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3639] add methods for registering datas... - posted by vasia <gi...@git.apache.org> on 2016/03/22 16:26:09 UTC, 26 replies.
- [jira] [Resolved] (FLINK-2256) Handling Broker failures on the KafkaSink side - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/22 16:26:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3639) Add methods and utilities to register DataSets and Tables in the TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 16:26:25 UTC, 26 replies.
- [jira] [Resolved] (FLINK-2101) Scheme Inference doesn't work for Tuple5 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/22 16:29:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3288) KafkaConsumer (0.8) fails with UnknownException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/22 16:31:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/22 16:34:25 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-3653] recovery.zookeeper.storageDir is ... - posted by stefanobaghino <gi...@git.apache.org> on 2016/03/22 17:24:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-3653) recovery.zookeeper.storageDir is not documented on the configuration page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/22 17:24:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/03/22 17:52:25 UTC, 1 replies.
- [jira] [Updated] (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-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.
- [jira] [Updated] (FLINK-3655) Allow comma-separated directories to be specified for FileInputFormat - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/03/22 19:44:25 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/03/22 20:03:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/03/22 20:53:25 UTC, 2 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.
- [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.
- [GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun... - posted by smarthi <gi...@git.apache.org> on 2016/03/23 07:31:42 UTC, 11 replies.
- [jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/23 07:32:25 UTC, 11 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] [Updated] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 10:23:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/23 10:33:25 UTC, 3 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.
- [GitHub] flink pull request: [FLINK-3651] Fix faulty RollingSink Restore - posted by aljoscha <gi...@git.apache.org> on 2016/03/23 11:02:20 UTC, 6 replies.
- [jira] [Commented] (FLINK-3651) Fix faulty RollingSink Restore - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/23 11:02:25 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3659] Allow ConnectedStreams to Be Keye... - posted by aljoscha <gi...@git.apache.org> on 2016/03/23 11:02:32 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-3658][Kafka] Allow producing into multi... - posted by rmetzger <gi...@git.apache.org> on 2016/03/23 11:02:50 UTC, 2 replies.
- [jira] [Commented] (FLINK-3659) Allow ConnectedStreams to Be Keyed on Only One Side - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/23 11:03:25 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-2609] [streaming] auto-register types - posted by zentol <gi...@git.apache.org> on 2016/03/23 11:13:55 UTC, 5 replies.
- [jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/23 11:14:25 UTC, 5 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] [Resolved] (FLINK-3652) Enable UnusedImports check for Scala checkstyle - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/23 11:22:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3524] [kafka] Add JSONDeserializationSc... - posted by zentol <gi...@git.apache.org> on 2016/03/23 13:29:34 UTC, 5 replies.
- [jira] [Commented] (FLINK-3524) Provide a JSONDeserialisationSchema in the kafka connector package - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/23 13:30:25 UTC, 5 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.
- [jira] [Resolved] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 14:22:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3608) ImmutableSettings error in ElasticsearchSink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 14:25:25 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 15:19:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 15:19:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/23 15:20:25 UTC, 0 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.
- [GitHub] flink pull request: FLINK-3663: FlinkKafkaConsumerBase.logPartitio... - posted by NielsZeilemaker <gi...@git.apache.org> on 2016/03/23 16:40:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/23 16:41:25 UTC, 3 replies.
- [jira] [Closed] (FLINK-2444) Add tests for HadoopInputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/23 17:38:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/23 17:39:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2997) Support range partition with user customized data distribution. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/23 17:41:25 UTC, 0 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.
- [jira] [Commented] (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, 4 replies.
- [jira] [Updated] (FLINK-3664) Create a method to easily Summarize a DataSet - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/03/23 18:53:25 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/03/23 22:24:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3653) recovery.zookeeper.storageDir is not documented on the configuration page - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/24 11:56:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3663) FlinkKafkaConsumerBase.logPartitionInfo is missing a log marker - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/24 12:00:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/24 12:06:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3658) Allow the FlinkKafkaProducer to send data to multiple topics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/24 12:16:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/24 12:35:25 UTC, 0 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] [Closed] (FLINK-2935) Allow scala shell to read yarn properties - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/03/24 13:47:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3257] Add Exactly-Once Processing Guara... - posted by uce <gi...@git.apache.org> on 2016/03/24 15:00:03 UTC, 5 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/24 15:00:29 UTC, 5 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.
- [jira] [Resolved] (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/24 17:56:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3667) Generalize client<->cluster communication - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/24 18:20:25 UTC, 2 replies.
- [GitHub] flink pull request: [hotfix][docs] Fix a couple of typos in YARN d... - posted by stefanobaghino <gi...@git.apache.org> on 2016/03/25 15:27:09 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.
- [jira] [Comment Edited] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits() - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/25 18:09:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits() - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/03/25 18:09:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/25 18:28:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/25 22:47:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Konstantin Boudnik (JIRA)" <ji...@apache.org> on 2016/03/26 01:03:25 UTC, 0 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.
- [jira] [Closed] (FLINK-3616) Python API version inconsistencies - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/03/27 18:14:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/28 04:30:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/03/28 04:31:25 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3643) Improve Window Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/28 15:40:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3643) Improve Window Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/28 15:42:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/03/28 23:51:25 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.
- [jira] [Closed] (FLINK-3544) ResourceManager runtime components - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 12:54:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3545) ResourceManager: YARN integration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 12:55:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3547) Add support for streaming projection, selection, and union - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/03/29 13:08:25 UTC, 0 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] [Closed] (FLINK-3676) WebClient hasn't been removed from the docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 15:49: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] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/03/29 18:29: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.
- [jira] [Closed] (FLINK-3651) Fix faulty RollingSink Restore - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/29 19:16:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3678] Make Flink logs directory configu... - posted by stefanobaghino <gi...@git.apache.org> on 2016/03/29 19:28:02 UTC, 6 replies.
- [jira] [Commented] (FLINK-3678) Make Flink logs directory configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/29 19:28:25 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2157] [ml] Create evaluation framework ... - posted by rawkintrevo <gi...@git.apache.org> on 2016/03/29 21:40:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-2157) Create evaluation framework for ML library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/29 21:40:25 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] [Commented] (FLINK-3673) Annotations for code generation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/03/30 00:35:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/03/30 01:57:25 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/03/30 01:58:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2998] Support range partition compariso... - posted by gallenvara <gi...@git.apache.org> on 2016/03/30 04:54:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-2998) Support range partition comparison for multi input nodes. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/30 04:55:26 UTC, 3 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.
- [jira] [Updated] (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:19:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3669) WindowOperator registers a log of timers at StreamTask - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/03/30 09:50:25 UTC, 0 replies.
- [GitHub] flink pull request: Adds watermark emission to the Kafka source by... - posted by kl0u <gi...@git.apache.org> on 2016/03/30 11:45:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/30 11:54:25 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3138) Method References are not supported as lambda expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/03/30 12:40:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Dongwon Kim (JIRA)" <ji...@apache.org> on 2016/03/30 14:10:25 UTC, 0 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] [Updated] (FLINK-3673) Annotations for code generation - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/03/30 15:07:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3681] [cep, typeextractor] Generalize T... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/30 15:11:28 UTC, 7 replies.
- [jira] [Commented] (FLINK-3681) CEP library does not support Java 8 lambdas as select function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/30 15:12:25 UTC, 7 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.
- [GitHub] flink pull request: [FLINK-3682] [cep] Assign processing timestamp... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/30 15:32:33 UTC, 5 replies.
- [jira] [Commented] (FLINK-3682) CEP operator does not set the processing timestamp correctly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/30 15:33:25 UTC, 5 replies.
- [jira] [Updated] (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:33: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.
- [jira] [Updated] (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:04:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/30 16:16:25 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/03/30 16:19:25 UTC, 0 replies.
- [GitHub] flink pull request: - posted by uce <gi...@git.apache.org> on 2016/03/30 17:20:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-3681) CEP library does not support Java 8 lambdas as select function - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/31 10:34:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-3682) CEP operator does not set the processing timestamp correctly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/31 10:34:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/03/31 11:17:25 UTC, 0 replies.
- [jira] [Updated] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/31 11:31:25 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.
- [GitHub] flink pull request: [FLINK-3684] [cep] Add proper watermark emissi... - posted by tillrohrmann <gi...@git.apache.org> on 2016/03/31 11:38:07 UTC, 3 replies.
- [jira] [Commented] (FLINK-3684) CEP operator does not forward watermarks properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/31 11:38:25 UTC, 3 replies.
- [jira] [Closed] (FLINK-3684) CEP operator does not forward watermarks properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/03/31 11:41: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.
- [jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/31 15:10:25 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala... - posted by rawkintrevo <gi...@git.apache.org> on 2016/03/31 16:02:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/03/31 16:03:25 UTC, 2 replies.
- [GitHub] flink pull request: [docs] Add first version of "Concepts" documen... - posted by StephanEwen <gi...@git.apache.org> on 2016/03/31 19:35:39 UTC, 0 replies.