You are viewing a plain text version of this content. The canonical link for it is here.
- [GitHub] incubator-flink pull request: Change TypeExtractor to support inte... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/01 20:23:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-1198) Store broadcast variables once per TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/01 20:35:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-553) Add getGroupKey() method to group-at-time operators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/01 20:46:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1040) Make type() call in projections optional (or remove it) - posted by "Chen Xu (JIRA)" <ji...@apache.org> on 2014/11/02 16:26:33 UTC, 37 replies.
- [jira] [Created] (FLINK-1201) Graph API for Flink - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/03 10:32:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Upgraded APIs: Flink (0.8) and HBase... - posted by fhueske <gi...@git.apache.org> on 2014/11/03 11:14:18 UTC, 72 replies.
- [GitHub] incubator-flink pull request: Flink 964 - posted by fhueske <gi...@git.apache.org> on 2014/11/03 11:37:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1202) Failed file outputs should remove partially complete files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 11:48:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1139] Fix for HadoopOF with D... - posted by fhueske <gi...@git.apache.org> on 2014/11/03 12:03:44 UTC, 8 replies.
- [jira] [Commented] (FLINK-1139) HadoopOutputFormat fails for DOP > 1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/03 12:04:33 UTC, 8 replies.
- [jira] [Created] (FLINK-1203) ClassCast exceptions in parallel tests (Surefire Bug?) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 12:24:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1203] Deactivate fork reuse i... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/03 12:33:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-1203) ClassCast exceptions in parallel tests (Surefire Bug?) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/03 12:33:33 UTC, 1 replies.
- [GitHub] incubator-flink pull request: [FLINK-1202] Remove partial files wh... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/03 12:35:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-1202) Failed file outputs should remove partially complete files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/03 12:35:34 UTC, 1 replies.
- [jira] [Created] (FLINK-1204) Fix streaming example builds to provide self-contained jars - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/03 16:54:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1203) ClassCast exceptions in parallel tests (Surefire Bug?) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 17:08:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1202) Failed file outputs should remove partially complete files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 17:08:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Add coarse-grained fault tolerance - posted by StephanEwen <gi...@git.apache.org> on 2014/11/03 17:09:01 UTC, 1 replies.
- [GitHub] incubator-flink pull request: Improved input type inference, bug f... - posted by twalthr <gi...@git.apache.org> on 2014/11/03 17:44:55 UTC, 2 replies.
- [GitHub] incubator-flink pull request: Improve error messages in case of in... - posted by asfgit <gi...@git.apache.org> on 2014/11/03 17:51:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1205) LibraryCacheManager should track execution IDs of library registrations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 19:41:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1206) Add option to the web client to specify default parallelism for a program - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 21:31:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1206) Add option to the web client to specify default parallelism for a program - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/03 21:36:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1207) Switch ContextEnvironment to Environment factory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/03 23:24:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1208) Skip comment lines in CSV input format. Allow user to specify comment character. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/04 11:06:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1209) Forgetting to close an iteration leads to a confusing error message - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/04 13:20:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1191] Add support for Scala C... - posted by aljoscha <gi...@git.apache.org> on 2014/11/04 15:11:12 UTC, 4 replies.
- [jira] [Commented] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/04 15:11:33 UTC, 4 replies.
- [jira] [Created] (FLINK-1210) Improve Error Message in Delta Iteratione when Next Workset does not Depend on Workset. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/04 15:15:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [Flink-1113] clean up JQuery depende... - posted by qmlmoon <gi...@git.apache.org> on 2014/11/04 15:16:36 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1210) Improve Error Message in Delta Iteratione when Next Workset does not Depend on Workset. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/04 16:44:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1205) LibraryCacheManager should track execution IDs of library registrations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/04 16:45:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1198) Store broadcast variables once per TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/04 16:46:34 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/05 09:30:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/05 09:31:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1211) EOL character of Windows Batch files should be CRLF - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 11:04:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1211] EOL character of Window... - posted by sarutak <gi...@git.apache.org> on 2014/11/05 11:04:55 UTC, 7 replies.
- [jira] [Commented] (FLINK-1211) EOL character of Windows Batch files should be CRLF - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/05 11:05:34 UTC, 7 replies.
- [GitHub] incubator-flink pull request: [FLINK-1113] clean up JQuery depende... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/05 11:16:31 UTC, 3 replies.
- [jira] [Created] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash" - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 11:16:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1113) Clean up JQuery Dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/05 11:16:34 UTC, 3 replies.
- [GitHub] incubator-flink pull request: [FLINK-1212] Interpreter directive i... - posted by sarutak <gi...@git.apache.org> on 2014/11/05 11:16:35 UTC, 5 replies.
- [jira] [Commented] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/05 11:17:33 UTC, 5 replies.
- [jira] [Created] (FLINK-1213) Add .gitattributes to normalize EOL character. - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 12:11:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1213] Add .gitattributes to n... - posted by sarutak <gi...@git.apache.org> on 2014/11/05 12:12:26 UTC, 5 replies.
- [jira] [Commented] (FLINK-1213) Add .gitattributes to normalize EOL character. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/05 12:12:33 UTC, 5 replies.
- [jira] [Closed] (FLINK-1049) Windows .bat files with UNIX line-end encoding - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/05 12:43:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1214) Prevent partitioning pushdown unless partitions fields match exactly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/05 12:45:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1215) FileSystem.initOutPathLocalFS can lead to race condition - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/05 13:52:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1214) Prevent partitioning pushdown unless partitions fields match exactly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/05 14:00:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1191) TypeAnalyzer MatchError when analyzing BitSet type with Scala API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/05 14:19:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1216) Quickstart projects should have flink dependencies in scope "provided" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/05 16:32:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1008) createProgramPlan() throws exception - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2014/11/05 17:26:35 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-1008) createProgramPlan() throws exception - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2014/11/05 17:47:33 UTC, 1 replies.
- [jira] [Created] (FLINK-1217) Keepalive option should be set to sockets in Client and Server - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 20:48:39 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1217] Keepalive option should... - posted by sarutak <gi...@git.apache.org> on 2014/11/05 20:49:55 UTC, 4 replies.
- [jira] [Updated] (FLINK-1217) Keepalive option should be set to sockets in Client and Server - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 20:50:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-1217) Keepalive option should be set to sockets in Client and Server - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/05 20:50:35 UTC, 4 replies.
- [jira] [Created] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead. - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 21:48:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1218] Don't use "new Integer"... - posted by sarutak <gi...@git.apache.org> on 2014/11/05 21:48:48 UTC, 5 replies.
- [jira] [Commented] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/05 21:49:34 UTC, 6 replies.
- [GitHub] incubator-flink pull request: [FLINK-1008] Fix createProgramPlan()... - posted by knub <gi...@git.apache.org> on 2014/11/05 22:42:37 UTC, 3 replies.
- [jira] [Updated] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash" - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/05 23:42:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1219) Add support for Apache Tez as execution engine - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/06 13:00:43 UTC, 0 replies.
- [jira] [Created] (FLINK-1220) Make INFO logging more verbose - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/06 13:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1221) Use program source line of invocation as the default function name - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/06 13:55:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1214) Prevent partitioning pushdown unless partitions fields match exactly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/06 14:02:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1220] Promote various log sta... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/06 14:11:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-1220) Make INFO logging more verbose - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/06 14:12:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-1142) Log IOManager temp path directories - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/06 14:19:33 UTC, 1 replies.
- [jira] [Created] (FLINK-1222) Let tasks finish as soon as their data is sent - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/06 15:14:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1223) Allow value escaping in CSV files - posted by "Johannes (JIRA)" <ji...@apache.org> on 2014/11/06 15:25:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1220) Make INFO logging more verbose - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/06 15:39:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1215] Fix spurious failures w... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/06 20:39:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-1215) FileSystem.initOutPathLocalFS can lead to race condition - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/06 20:39:36 UTC, 2 replies.
- [GitHub] incubator-flink pull request: [FLINK-1223] Allow value escaping in... - posted by jkirsch <gi...@git.apache.org> on 2014/11/06 21:53:38 UTC, 7 replies.
- [jira] [Commented] (FLINK-1223) Allow value escaping in CSV files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/06 21:54:34 UTC, 8 replies.
- [jira] [Commented] (FLINK-1112) Add GroupSorting with KeySelectors - posted by "Mingliang Qi (JIRA)" <ji...@apache.org> on 2014/11/07 10:17:33 UTC, 3 replies.
- [jira] [Commented] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats - posted by "Manu Kaul (JIRA)" <ji...@apache.org> on 2014/11/07 10:30:33 UTC, 13 replies.
- [jira] [Commented] (FLINK-1222) Let tasks finish as soon as their data is sent - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/07 11:16:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1215) FileSystem.initOutPathLocalFS can lead to race condition - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/07 11:16:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1222) Let tasks finish as soon as their data is sent - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/07 11:16:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [Flink-1142] Log information about I... - posted by NilsEngelbach <gi...@git.apache.org> on 2014/11/07 12:33:44 UTC, 17 replies.
- [jira] [Created] (FLINK-1224) Fix .getExecutionEnvironment of the StreamingExecutionEnvironment to return proper context - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/07 15:25:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1225) Quickstart does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/11/07 16:41:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1225) Quickstart does not work - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/07 17:12:33 UTC, 8 replies.
- [GitHub] incubator-flink pull request: [FLINK-1219] Add support for Apache ... - posted by ktzoumas <gi...@git.apache.org> on 2014/11/07 18:54:57 UTC, 7 replies.
- [jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/07 18:55:33 UTC, 7 replies.
- [jira] [Updated] (FLINK-1224) Fix .getExecutionEnvironment of the StreamingExecutionEnvironment to return proper context - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/07 23:04:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-1173) Add socket text stream as a data source for the streaming API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/09 13:29:33 UTC, 4 replies.
- [jira] [Updated] (FLINK-1081) Add HDFS file-stream source for streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/09 13:30:42 UTC, 0 replies.
- [jira] [Assigned] (FLINK-983) WebClient makes names of functions unreadable - posted by "Mingliang Qi (JIRA)" <ji...@apache.org> on 2014/11/09 15:03:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-983] Fix WebClient truncated ... - posted by qmlmoon <gi...@git.apache.org> on 2014/11/09 15:56:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-983) WebClient makes names of functions unreadable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/09 15:56:34 UTC, 3 replies.
- [GitHub] incubator-flink pull request: [FLINK-1095] Remove info option from... - posted by shivateja <gi...@git.apache.org> on 2014/11/09 20:05:38 UTC, 7 replies.
- [jira] [Commented] (FLINK-1095) ./flink info -d command is not working for the examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/09 20:06:33 UTC, 10 replies.
- [jira] [Closed] (FLINK-1224) Fix .getExecutionEnvironment of the StreamingExecutionEnvironment to return proper context - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/09 20:11:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-1223) Allow value escaping in CSV files - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/10 10:45:33 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1223) Allow value escaping in CSV files - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/10 10:46:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-1225) Quickstart does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/11/10 10:48:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/10 10:50:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1019] Implementation of akka ... - posted by rmetzger <gi...@git.apache.org> on 2014/11/10 10:52:30 UTC, 4 replies.
- [jira] [Commented] (FLINK-1019) Rework RPC service - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/10 10:52:34 UTC, 4 replies.
- [jira] [Created] (FLINK-1226) No way to give Configuration to DataSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/10 12:51:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1227) KeySelector can't implement ResultTypeQueryable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/10 14:12:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1227] KeySelector can now ext... - posted by zentol <gi...@git.apache.org> on 2014/11/10 14:14:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-1227) KeySelector can't implement ResultTypeQueryable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/10 14:14:35 UTC, 4 replies.
- [jira] [Created] (FLINK-1228) Add REST Interface to JobManager - posted by "Arvid Heise (JIRA)" <ji...@apache.org> on 2014/11/10 15:25:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/10 16:07:33 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1225) Quickstart does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/11/10 16:30:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1211) EOL character of Windows Batch files should be CRLF - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 16:32:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1213) Add .gitattributes to normalize EOL character. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 16:33:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 16:34:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1113) Clean up JQuery Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 16:35:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1229) Synchronize WebClient arguments with command line arguments - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/11/10 16:36:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1230) Add embedded collection execution to documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 16:37:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1192) Streaming source fault tolerance - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2014/11/10 16:50:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1195) Improvement of benchmarking infrastructure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/10 17:02:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1231) Add test for streaming remote execution - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/10 17:03:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1232) Allow I/O spill file writers to work with futures/callbacks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 17:19:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1323] implementation that use... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/10 17:22:25 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1040] Make type() call in pro... - posted by dukechain <gi...@git.apache.org> on 2014/11/10 17:30:58 UTC, 36 replies.
- [jira] [Commented] (FLINK-1228) Add REST Interface to JobManager - posted by "Markus Holzemer (JIRA)" <ji...@apache.org> on 2014/11/10 17:50:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [Flink-1186] Fix wrong flat key posi... - posted by rmetzger <gi...@git.apache.org> on 2014/11/10 17:58:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-1227) KeySelector can't implement ResultTypeQueryable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/10 18:12:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1233) Flaky Test AggregateITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/10 18:43:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1186) Join key selection for nested Tuples is broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 10:06:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 10:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1234) Make Hadoop2 profile default - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 10:10:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1323] Add an I/O writer imple... - posted by uce <gi...@git.apache.org> on 2014/11/11 11:38:55 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1232) Allow I/O spill file writers to work with futures/callbacks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/11 11:54:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-983) WebClient makes names of functions unreadable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/11 11:57:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1223) Allow value escaping in CSV files - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/11 12:06:34 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1230) Add embedded collection execution to documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:01:35 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1226) No way to give Configuration to DataSource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:02:34 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1221) Use program source line of invocation as the default function name - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:04:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1157) Document TaskManager Slots - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:06:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1217) Keepalive option should be set to sockets in Client and Server - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:08:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1209) Forgetting to close an iteration leads to a confusing error message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:08:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1201) Graph API for Flink - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/11 14:08:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/11 14:08:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 14:19:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1230) Add embedded collection execution to documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/11 15:17:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1230] Add documentation and a... - posted by rmetzger <gi...@git.apache.org> on 2014/11/11 15:51:32 UTC, 10 replies.
- [jira] [Commented] (FLINK-1230) Add embedded collection execution to documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/11 15:51:34 UTC, 10 replies.
- [GitHub] incubator-flink pull request: [FLINK-1226] Add API support for pas... - posted by rmetzger <gi...@git.apache.org> on 2014/11/11 15:55:31 UTC, 5 replies.
- [jira] [Commented] (FLINK-1226) No way to give Configuration to DataSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/11 15:55:34 UTC, 5 replies.
- [GitHub] incubator-flink pull request: [FLINK-1003] Added spread out schedu... - posted by fhueske <gi...@git.apache.org> on 2014/11/11 16:01:08 UTC, 2 replies.
- [jira] [Commented] (FLINK-1003) Spread out scheduling strategy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/11 16:01:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-456) Optional runtime statistics collection - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/12 09:43:33 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats - posted by "Manu Kaul (JIRA)" <ji...@apache.org> on 2014/11/12 09:47:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1235) Compiler rejectes non-nested iterations in constant path of an Iteration. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/12 16:12:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1221] Use the source line as ... - posted by rmetzger <gi...@git.apache.org> on 2014/11/12 16:37:51 UTC, 4 replies.
- [jira] [Commented] (FLINK-1221) Use program source line of invocation as the default function name - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/12 16:38:33 UTC, 10 replies.
- [jira] [Created] (FLINK-1236) Add support for localization of Hadoop Input Splits - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/12 17:11:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1236) Add support for localization of Hadoop Input Splits - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/12 17:15:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-933] Add primitive input form... - posted by fhueske <gi...@git.apache.org> on 2014/11/12 18:11:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-933) Add an input format to read primitive types directly (not through tuples) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/12 18:12:33 UTC, 1 replies.
- [jira] [Created] (FLINK-1237) Add custom partitioners for shuffle steps - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/12 18:18:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1235) Compiler rejectes non-nested iterations in constant path of an Iteration. - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2014/11/12 19:02:34 UTC, 6 replies.
- [jira] [Created] (FLINK-1238) Add a way to deactivate the "mutable object safe mode" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/12 19:36:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1238) Add a way to deactivate the "mutable object safe mode" - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/12 21:01:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-1238) Add a way to deactivate the "mutable object safe mode" - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/12 21:01:35 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1235] Compiler accepts iterat... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/12 21:50:53 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1235) Compiler rejectes non-nested iterations in constant path of an Iteration. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/12 23:39:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1239) Fix iteration example stucking with large input - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2014/11/12 23:49:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1239) Fix iteration example stucking with large input - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2014/11/12 23:54:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [scala] Self-contained build for sca... - posted by mbalassi <gi...@git.apache.org> on 2014/11/12 23:57:36 UTC, 13 replies.
- [jira] [Updated] (FLINK-1239) Fix iteration example getting stuck with large input - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2014/11/12 23:58:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-1239) Fix iteration example getting stuck with large input - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2014/11/13 03:36:16 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1226) No way to give Configuration to DataSource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/13 10:06:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1230) Add embedded collection execution to documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/13 10:09:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-1240) We cannot use sortGroup on a global reduce - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/13 10:31:34 UTC, 3 replies.
- [jira] [Created] (FLINK-1240) We cannot use sortGroup on a global reduce - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/13 10:31:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1221) Use program source line of invocation as the default function name - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/13 11:23:37 UTC, 1 replies.
- [GitHub] incubator-flink commit comment: 818ebda0f4d0070499446d2958532af5ad... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/13 12:19:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-1237) Add custom partitioners for shuffle steps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/13 12:57:33 UTC, 6 replies.
- [jira] [Resolved] (FLINK-1204) Fix streaming example builds to provide self-contained jars - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/13 16:09:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1241) Record processing counter for Dashboard - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2014/11/13 16:50:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1242) Streaming examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/13 18:19:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1242) Streaming examples project causes build error in Eclipse - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/13 18:20:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1154) YarnTaskManagerRunner does not shut down - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/13 18:36:33 UTC, 11 replies.
- [jira] [Created] (FLINK-1243) Remove JVM MaxPermSize parameter when we use Java 8 - posted by "Kousuke Saruta (JIRA)" <ji...@apache.org> on 2014/11/13 20:03:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1243] Remove JVM MaxPermSize ... - posted by sarutak <gi...@git.apache.org> on 2014/11/13 20:04:02 UTC, 6 replies.
- [jira] [Commented] (FLINK-1243) Remove JVM MaxPermSize parameter when we use Java 8 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/13 20:04:33 UTC, 6 replies.
- [jira] [Resolved] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/14 11:02:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: enable CSV Reader to ignore invalid ... - posted by FelixNeutatz <gi...@git.apache.org> on 2014/11/14 12:55:40 UTC, 56 replies.
- [jira] [Commented] (FLINK-1208) Skip comment lines in CSV input format. Allow user to specify comment character. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/14 12:56:33 UTC, 56 replies.
- [jira] [Updated] (FLINK-1208) Skip comment lines in CSV input format. Allow user to specify comment character. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/14 13:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1244) setCombinable() clunky to use - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/14 13:34:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-337] [FLINK-671] Generic Inte... - posted by zentol <gi...@git.apache.org> on 2014/11/14 15:34:09 UTC, 4 replies.
- [jira] [Commented] (FLINK-337) Fixed all JavaDoc warnings in pact-common. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/14 15:34:33 UTC, 4 replies.
- [GitHub] incubator-flink pull request: [FLINK-377] [FLINK-671] Generic Inte... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/14 18:23:30 UTC, 19 replies.
- [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/14 18:23:34 UTC, 19 replies.
- [jira] [Updated] (FLINK-1244) setCombinable() clunky to use - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/14 21:20:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-1244) setCombinable() clunky to use - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/14 21:20:34 UTC, 4 replies.
- [jira] [Created] (FLINK-1245) Introduce TypeHints for Java API operators - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/11/14 21:41:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1245] Introduce TypeHints for... - posted by twalthr <gi...@git.apache.org> on 2014/11/14 22:30:08 UTC, 9 replies.
- [jira] [Commented] (FLINK-1245) Introduce TypeHints for Java API operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/14 22:30:34 UTC, 9 replies.
- [jira] [Commented] (FLINK-1173) Add socket text stream as a data source for the streaming API - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2014/11/15 14:45:33 UTC, 15 replies.
- [jira] [Reopened] (FLINK-1221) Use program source line of invocation as the default function name - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/15 15:38:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1173] Add socket text stream ... - posted by chiwanpark <gi...@git.apache.org> on 2014/11/16 13:49:24 UTC, 10 replies.
- [jira] [Assigned] (FLINK-1112) Add GroupSorting with KeySelectors - posted by "Mingliang Qi (JIRA)" <ji...@apache.org> on 2014/11/16 16:08:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1244) setCombinable() clunky to use - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/16 16:29:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1244] setCombinable() returns... - posted by zentol <gi...@git.apache.org> on 2014/11/16 16:30:11 UTC, 3 replies.
- [jira] [Assigned] (FLINK-1172) Links to APIs inside Iterations guide broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/16 17:01:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1172] Fix broken links in doc... - posted by zentol <gi...@git.apache.org> on 2014/11/16 17:51:46 UTC, 3 replies.
- [jira] [Commented] (FLINK-1172) Links to APIs inside Iterations guide broken - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/16 17:52:33 UTC, 3 replies.
- [jira] [Assigned] (FLINK-1173) Add socket text stream as a data source for the streaming API - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2014/11/16 18:23:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1233) Flaky Test AggregateITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 01:38:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1237] Add support for custom ... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/17 01:38:43 UTC, 5 replies.
- [jira] [Assigned] (FLINK-1154) YarnTaskManagerRunner does not shut down - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/17 10:54:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1154] Quickfix to kill TaskMa... - posted by rmetzger <gi...@git.apache.org> on 2014/11/17 10:58:46 UTC, 10 replies.
- [jira] [Resolved] (FLINK-993) Inconsistent package naming of nightly builds and releases - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/17 13:21:33 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-993) Inconsistent package naming of nightly builds and releases - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/17 13:22:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1242) Streaming examples project causes build error in Eclipse - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 13:32:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1008) createProgramPlan() throws exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 14:22:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-890) [Examples Website] Replace "getInputData()" methods - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 15:36:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Modify documentation for POJO groupB... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/17 15:51:17 UTC, 5 replies.
- [GitHub] incubator-flink pull request: [FLINK-1112] Add KeySelector group s... - posted by qmlmoon <gi...@git.apache.org> on 2014/11/17 16:39:09 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1172) Links to APIs inside Iterations guide broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 17:09:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1244) setCombinable() clunky to use - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 17:10:36 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Implement the convenience methods co... - posted by mxm <gi...@git.apache.org> on 2014/11/17 19:04:34 UTC, 9 replies.
- [jira] [Created] (FLINK-1246) Flaky test RecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/17 19:12:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1169) Join Hint Specification in .join() Function is not Documented - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/17 21:51:34 UTC, 3 replies.
- [GitHub] incubator-flink pull request: [FLINK-1207] Context environments ar... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/17 22:18:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-1207) Switch ContextEnvironment to Environment factory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/17 22:18:34 UTC, 4 replies.
- [jira] [Created] (FLINK-1247) Links in documentation broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/18 00:04:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-1247) Links in documentation broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/18 00:05:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1247) Links in documentation broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/18 00:17:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1248) Manually built docu doesn't apply CSS/images - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/18 00:50:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1247) Links in documentation broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/18 01:22:34 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1207) Switch ContextEnvironment to Environment factory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 12:05:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1237) Add custom partitioners for shuffle steps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 12:24:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1246) Flaky test RecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 12:24:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1249) Add custom partitioner for CoGroup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 12:26:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 12:36:34 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1243) Remove JVM MaxPermSize parameter when we use Java 8 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/18 12:37:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-758] Add count operator to Da... - posted by uce <gi...@git.apache.org> on 2014/11/18 12:38:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-758) Add count method to DataSet and implement CountOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/18 12:38:33 UTC, 2 replies.
- [jira] [Created] (FLINK-1250) Wrong config key for taskmanager heartbeat timeout - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 14:11:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1209] & [FLINK-1250] Fixes fo... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/18 14:33:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-1209) Forgetting to close an iteration leads to a confusing error message - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/18 14:34:34 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1081) Add HDFS file-stream source for streaming - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2014/11/18 17:06:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1209) Forgetting to close an iteration leads to a confusing error message - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 17:29:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1250) Wrong config key for taskmanager heartbeat timeout - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/18 17:29:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1247] [docs] Fix more broken ... - posted by zentol <gi...@git.apache.org> on 2014/11/18 21:50:01 UTC, 3 replies.
- [jira] [Created] (FLINK-1251) CollectionInputFormat is not able to handle Enums - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/19 00:08:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1251) CollectionInputFormat is not able to handle Enums - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/19 00:11:33 UTC, 1 replies.
- [jira] [Created] (FLINK-1252) Add a serializer for Date - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/19 00:34:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Code cleanups - cleaned up IDEA warn... - posted by smarthi <gi...@git.apache.org> on 2014/11/19 05:21:12 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1247) Links in documentation broken - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/19 10:38:36 UTC, 0 replies.
- [GitHub] incubator-flink pull request: First part of rebase runtime support... - posted by uce <gi...@git.apache.org> on 2014/11/19 10:39:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 10:40:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1253) Tests occasionally die with GarbageCollectionOverhead exceeded - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/19 11:41:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1251) CollectionInputFormat is not able to handle Enums - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/19 11:43:40 UTC, 1 replies.
- [GitHub] incubator-flink pull request: hadoopcompatibility: Implementations... - posted by uce <gi...@git.apache.org> on 2014/11/19 11:47:23 UTC, 5 replies.
- [GitHub] incubator-flink pull request: Reworking of Iteration Synchronizati... - posted by uce <gi...@git.apache.org> on 2014/11/19 11:51:04 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1252] Add support for seriali... - posted by rmetzger <gi...@git.apache.org> on 2014/11/19 12:05:07 UTC, 15 replies.
- [jira] [Commented] (FLINK-1252) Add a serializer for Date - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 12:05:34 UTC, 15 replies.
- [jira] [Created] (FLINK-1254) Optimizer bug during pipeline breaker placement - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/19 12:27:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1027] ignore invalid commandl... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/19 14:02:14 UTC, 2 replies.
- [jira] [Commented] (FLINK-1027) CLI "run" command does not support flags - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 14:02:33 UTC, 2 replies.
- [GitHub] incubator-flink pull request: [FLINK-1254] Fix compiler bug for pi... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/19 14:02:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-1254) Optimizer bug during pipeline breaker placement - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 14:03:34 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1251) CollectionInputFormat is not able to handle Enums - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/19 14:04:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1253] Make sure tests do not ... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/19 14:06:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-1253) Tests occasionally die with GarbageCollectionOverhead exceeded - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 14:06:33 UTC, 2 replies.
- [GitHub] incubator-flink pull request: [FLINK-924] Add automatic dependency... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/19 14:17:24 UTC, 4 replies.
- [jira] [Commented] (FLINK-924) Extend JarFileCreator to automatically include dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 14:17:33 UTC, 4 replies.
- [jira] [Created] (FLINK-1255) Problems with generic types in Scala API - posted by "Sebastian Schelter (JIRA)" <ji...@apache.org> on 2014/11/19 15:24:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1255) Problems with generic types in Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/19 15:44:33 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1253) Tests occasionally die with GarbageCollectionOverhead exceeded - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/19 15:49:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1254) Optimizer bug during pipeline breaker placement - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/19 15:49:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1256) Use Kryo for user code object serialization - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/19 16:01:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1257) Binary input/output format which use the type serializer to read/write binary data - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/19 17:43:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1257] Added TypeSerializerInp... - posted by tillrohrmann <gi...@git.apache.org> on 2014/11/19 17:54:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-1257) Binary input/output format which use the type serializer to read/write binary data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/19 17:55:34 UTC, 3 replies.
- [jira] [Created] (FLINK-1258) Merge iterative and non-iterative tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/19 18:22:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1081) Add HDFS file-stream source for streaming - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2014/11/19 18:46:34 UTC, 28 replies.
- [jira] [Resolved] (FLINK-933) Add an input format to read primitive types directly (not through tuples) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/19 22:05:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1259) FilterFunction can modify data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/19 22:17:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1260) Add custom partitioning to documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/19 22:20:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1259) FilterFunction can modify data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/19 22:21:35 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Upgraded HBase addon to HBase 0.98.x... - posted by fpompermaier <gi...@git.apache.org> on 2014/11/20 00:14:27 UTC, 13 replies.
- [GitHub] incubator-flink pull request: Code cleanups, replaced for loops wi... - posted by smarthi <gi...@git.apache.org> on 2014/11/20 00:23:14 UTC, 4 replies.
- [jira] [Created] (FLINK-1261) Handling of full temporary directories at startup and runtime - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/20 12:12:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1142) Log IOManager temp path directories - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/20 12:13:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-838) GSoC Summer Project: Implement full Hadoop Compatibility Layer for Stratosphere - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/20 12:52:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1262) inconsistency between CsvReader.java and TupleGenerator.java - posted by "Chen Xu (JIRA)" <ji...@apache.org> on 2014/11/20 14:25:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [Flink-1262] inconsistency between C... - posted by dukechain <gi...@git.apache.org> on 2014/11/20 15:15:03 UTC, 2 replies.
- [jira] [Updated] (FLINK-1252) Add a serializer for Date - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/20 15:32:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1252) Add a serializer for Date - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/20 15:32:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1251) CollectionInputFormat is not able to handle Enums - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/20 15:33:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1263) Manual Partition operations are considered to keep data types constant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/20 15:51:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1264) Custom partitioners are not properly forwarded to teh runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/20 16:00:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-1263) Manual Partition operations are considered to keep data types constant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/20 16:06:34 UTC, 3 replies.
- [jira] [Closed] (FLINK-1257) Binary input/output format which use the type serializer to read/write binary data - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/20 16:15:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-1262) inconsistency between CsvReader.java and TupleGenerator.java - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/20 16:47:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-1264) Custom partitioners are not properly forwarded to the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/20 16:47:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1265) configure() not called with usercode classloader as context classloader - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/20 17:25:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1265) configure() not called with usercode classloader as context classloader - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/20 17:54:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1266) Generalize Flink's DistributedFileSystemClass to a Hadoop FileSystem wrapper - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/20 18:18:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1262) inconsistency between CsvReader.java and TupleGenerator.java - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/20 18:38:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-820) Support for unconnected data flows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/20 20:55:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1264) Custom partitioners are not properly forwarded to the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/20 20:56:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1263] [optimizer] Implement c... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/21 00:52:47 UTC, 2 replies.
- [jira] [Created] (FLINK-1267) Add crossGroup operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/21 10:10:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/21 11:26:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/21 12:00:34 UTC, 3 replies.
- [jira] [Commented] (FLINK-1267) Add crossGroup operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/21 12:05:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-938] Automatically configure ... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/21 12:20:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/21 12:20:34 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-827] KeySelector- Example - posted by StephanEwen <gi...@git.apache.org> on 2014/11/21 12:21:49 UTC, 7 replies.
- [jira] [Commented] (FLINK-827) Add Java example program with KeySelectors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/21 12:22:33 UTC, 7 replies.
- [jira] [Created] (FLINK-1269) Easy way to "group count" dataset - posted by "Sebastian Schelter (JIRA)" <ji...@apache.org> on 2014/11/21 14:15:34 UTC, 0 replies.
- [jira] [Assigned] (FLINK-710) Aggregate transformation works only with FieldPositionKeys - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2014/11/21 14:55:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1270) FileSystem.get() doesn't support relative paths - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/21 16:34:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1270] FS.get() supports relat... - posted by zentol <gi...@git.apache.org> on 2014/11/21 16:37:28 UTC, 6 replies.
- [jira] [Commented] (FLINK-1270) FileSystem.get() doesn't support relative paths - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/21 16:37:34 UTC, 6 replies.
- [jira] [Resolved] (FLINK-1263) Manual Partition operations are considered to keep data types constant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/21 16:58:33 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1269) Easy way to "group count" dataset - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2014/11/21 18:39:33 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Minor code cleanups - left from prev... - posted by smarthi <gi...@git.apache.org> on 2014/11/21 19:44:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-1269) Easy way to "group count" dataset - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/21 21:24:34 UTC, 12 replies.
- [jira] [Updated] (FLINK-1269) Easy way to "group count" dataset - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2014/11/21 21:37:34 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-1269) Easy way to "group count" dataset - posted by "Viktor Rosenfeld (JIRA)" <ji...@apache.org> on 2014/11/21 22:09:34 UTC, 2 replies.
- [jira] [Created] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2014/11/22 16:40:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1272) Add a "reduceWithKey" function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/22 18:06:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/22 21:04:12 UTC, 2 replies.
- [jira] [Created] (FLINK-1273) Add the "Void" type to the basic types. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/22 21:07:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/22 21:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2014/11/22 23:29:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1272) Add a "reduceWithKey" function - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/22 23:44:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1081] Add HDFS file-stream so... - posted by chiwanpark <gi...@git.apache.org> on 2014/11/23 18:08:38 UTC, 22 replies.
- [jira] [Closed] (FLINK-1169) Join Hint Specification in .join() Function is not Documented - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/23 20:37:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1275) Add support to compress network I/O - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/23 23:07:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1276) Misspelled class name SlotAvailabilityListener.java - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2014/11/23 23:56:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: FLINK-1276 - posted by smarthi <gi...@git.apache.org> on 2014/11/24 00:46:02 UTC, 10 replies.
- [jira] [Commented] (FLINK-1276) Misspelled class name SlotAvailabilityListener.java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/24 00:46:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1276) Misspelled class name SlotAvalablbilityListener.java - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2014/11/24 01:44:12 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1169) Join Hint Specification in .join() Function is not Documented - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/24 09:36:12 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-1169) Join Hint Specification in .join() Function is not Documented - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/24 09:36:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-1276) Misspelled class name SlotAvalablbilityListener.java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/24 14:16:12 UTC, 18 replies.
- [jira] [Assigned] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]] - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2014/11/24 15:17:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-867) Webinterface JobHistory does not work offline - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/24 16:20:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-867) Webinterface JobHistory does not work offline - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/24 16:20:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1277) Support sort order for coGroup inputs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2014/11/24 17:53:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1277) Support sort order for coGroup inputs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/24 17:58:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-939) Distribute required JAR files with seperate service - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2014/11/24 18:11:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1249) Add custom partitioner for CoGroup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/24 18:19:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1249) Add custom partitioner for CoGroup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/24 18:19:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1249) Add custom partitioner for CoGroup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/24 18:19:12 UTC, 3 replies.
- [jira] [Resolved] (FLINK-939) Distribute required JAR files with seperate service - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/24 20:56:13 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1249] [APIs] [compiler] Add c... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/25 00:44:39 UTC, 2 replies.
- [GitHub] incubator-flink pull request: Fixes FLINK-1276 - posted by smarthi <gi...@git.apache.org> on 2014/11/25 02:19:59 UTC, 6 replies.
- [GitHub] incubator-flink pull request: [FLINK-984] Extension of the API for... - posted by aljoscha <gi...@git.apache.org> on 2014/11/25 11:18:22 UTC, 4 replies.
- [jira] [Commented] (FLINK-984) Distinct operator for POJO DataSets without KeySelector and on UnsortedGrouping - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/25 11:19:12 UTC, 6 replies.
- [jira] [Assigned] (FLINK-984) Distinct operator for POJO DataSets without KeySelector and on UnsortedGrouping - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/25 11:26:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Small changes and tests for the newl... - posted by twalthr <gi...@git.apache.org> on 2014/11/25 11:53:45 UTC, 4 replies.
- [GitHub] incubator-flink pull request: [FLINK-1221] Use only method name an... - posted by rmetzger <gi...@git.apache.org> on 2014/11/25 12:11:03 UTC, 3 replies.
- [GitHub] incubator-flink pull request: [scala] Add ClosureCleaner for Scala... - posted by aljoscha <gi...@git.apache.org> on 2014/11/25 13:29:27 UTC, 5 replies.
- [GitHub] incubator-flink pull request: [FLINK-1234] Active hadoop2 profile ... - posted by rmetzger <gi...@git.apache.org> on 2014/11/25 15:29:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-1234) Make Hadoop2 profile default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/25 15:30:12 UTC, 8 replies.
- [jira] [Created] (FLINK-1278) Remove the Record special code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/25 15:44:13 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1234] Activate hadoop2 profil... - posted by uce <gi...@git.apache.org> on 2014/11/25 17:19:15 UTC, 6 replies.
- [jira] [Assigned] (FLINK-1278) Remove the Record special code paths - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/25 17:23:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1272) Add a "reduceWithKey" function - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2014/11/25 17:38:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-658] Group Sorting for CoGrou... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/25 18:59:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-658) Add Group Sorting to CoGroup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/25 19:00:16 UTC, 2 replies.
- [jira] [Resolved] (FLINK-827) Add Java example program with KeySelectors - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/25 19:56:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1276) Misspelled class name SlotAvalablbilityListener.java - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2014/11/25 20:25:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-1173) Add socket text stream as a data source for the streaming API - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2014/11/25 22:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1279) Change default partitioning setting for low parallelism stream sources from forward to distribute - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/26 01:03:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1280) Rework StreamInvokables to use the PactDriver interface for better future integration - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/26 01:09:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1281) Update website layout - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/26 11:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1282) Update layout of documentation - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/26 11:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1283) Update website layout and frontpage content - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/26 11:54:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1282] Update layout of docs - posted by ktzoumas <gi...@git.apache.org> on 2014/11/26 12:29:53 UTC, 6 replies.
- [jira] [Commented] (FLINK-1282) Update layout of documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/26 12:30:12 UTC, 6 replies.
- [jira] [Created] (FLINK-1284) Uniform random sampling operator over windows - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2014/11/26 12:49:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1285) Make execution mode configurable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/26 13:05:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Add support for Subclasses, Interfac... - posted by aljoscha <gi...@git.apache.org> on 2014/11/26 13:28:14 UTC, 15 replies.
- [jira] [Resolved] (FLINK-658) Add Group Sorting to CoGroup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/26 14:57:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1249) Add custom partitioner for CoGroup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/26 14:58:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1286) Failures and bad error message in CollectionInputFormat - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/26 15:44:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1287) Improve File Input Split assignment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/26 17:03:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-171) Meaningful names for operators generated by Scala API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/26 17:11:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-1259) FilterFunction can modify data - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/26 17:23:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1163) Scala DataSet cannot be used within iterations because it is not serializable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/26 17:26:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/26 17:27:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/26 17:30:15 UTC, 1 replies.
- [jira] [Created] (FLINK-1288) YARN ApplicationMaster sometimes fails to allocate the specified number of workers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/26 18:07:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1285) Make execution mode configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/26 18:12:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1286) Failures and bad error message in CollectionInputFormat - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/26 18:52:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1095] Remove '-d' option in i... - posted by shivateja <gi...@git.apache.org> on 2014/11/26 19:04:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-1248) Manually built docu doesn't apply CSS/images - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/26 19:16:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1248) Manually built docu doesn't apply CSS/images - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/26 19:19:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1289) Broken links to k-means examples in website - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2014/11/26 19:34:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1234) Make Hadoop2 profile default - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/26 20:33:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: canCreateInstance() method for type ... - posted by twalthr <gi...@git.apache.org> on 2014/11/26 21:10:12 UTC, 7 replies.
- [jira] [Assigned] (FLINK-1289) Broken links to k-means examples in website - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2014/11/26 22:09:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-1289) Broken links to k-means examples in website - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2014/11/26 23:04:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1279) Change default partitioning setting for low parallelism stream sources from forward to distribute - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/11/27 13:13:15 UTC, 0 replies.
- [jira] [Created] (FLINK-1290) Optimizer prunes all candidates when unable to reuse sort properties - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 13:22:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2014/11/27 15:05:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/27 15:16:12 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1285) Make execution mode configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/27 17:43:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1005) Add different mutable-object modes to runtime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/27 17:46:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1137) Add a way to switch between mutable object safe mode and efficient object reuse mode - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/27 17:46:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1238) Add a way to deactivate the "mutable object safe mode" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/27 17:46:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1163) Scala DataSet cannot be used within iterations because it is not serializable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/27 17:54:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1290) Optimizer prunes all candidates when unable to reuse sort properties - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 18:57:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1270) FileSystem.get() doesn't support relative paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 18:58:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1273) Add the "Void" type to the basic types. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 18:59:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1095) ./flink info -d command is not working for the examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 18:59:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1290) Optimizer prunes all candidates when unable to reuse sort properties - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 18:59:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1291) Remove GC options from JobManager and TaskManager scripts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 20:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1292) Allow for longer normalized keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2014/11/27 20:28:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1292) Allow for longer normalized keys - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2014/11/27 20:40:12 UTC, 1 replies.
- [GitHub] incubator-flink pull request: [FLINK-1291] Remove default GC optio... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/27 21:13:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-1291) Remove GC options from JobManager and TaskManager scripts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/27 21:14:12 UTC, 3 replies.
- [GitHub] incubator-flink pull request: [FLINK-1292] Allow for longer normal... - posted by StephanEwen <gi...@git.apache.org> on 2014/11/27 21:15:25 UTC, 0 replies.
- [GitHub] incubator-flink pull request: Just a typo in docs/index.md - posted by mborgmann <gi...@git.apache.org> on 2014/11/28 00:05:56 UTC, 2 replies.
- [jira] [Created] (FLINK-1293) Add support for out-of-place aggregations - posted by "Viktor Rosenfeld (JIRA)" <ji...@apache.org> on 2014/11/28 15:10:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-1293] Add support for out-of-... - posted by he-sk <gi...@git.apache.org> on 2014/11/28 15:46:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-1293) Add support for out-of-place aggregations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2014/11/28 15:47:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [Java API] [docs] Rephrase Javadoc o... - posted by uce <gi...@git.apache.org> on 2014/11/28 17:53:56 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1291) Remove GC options from JobManager and TaskManager scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2014/11/28 19:18:12 UTC, 0 replies.
- [GitHub] incubator-flink pull request: [FLINK-984] Compiler tests for disti... - posted by rmetzger <gi...@git.apache.org> on 2014/11/29 11:22:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1154) YarnTaskManagerRunner does not shut down - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2014/11/29 11:33:12 UTC, 0 replies.