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

---

- [jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/01 11:49:04 UTC, 12 replies.
- [jira] [Comment Edited] (FLINK-1523) Vertex-centric iteration extensions - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/01 11:56:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat - posted by rmetzger <gi...@git.apache.org> on 2015/03/01 12:51:55 UTC, 29 replies.
- [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/01 12:52:04 UTC, 30 replies.
- [jira] [Commented] (FLINK-1370) Build website automatically - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/01 13:20:04 UTC, 4 replies.
- [GitHub] flink pull request: Fix typos in iterations.md file - posted by rmetzger <gi...@git.apache.org> on 2015/03/01 16:40:58 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1591] Removed unnecessary merge before ... - posted by gyfora <gi...@git.apache.org> on 2015/03/01 22:15:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-1591) Remove window merge before flatten as an optimization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/01 22:15:04 UTC, 3 replies.
- [jira] [Created] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/01 22:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1618) Add parallel time discretisation for time-window transformations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/02 10:01:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1619) Add pre-aggregator for time windows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/02 10:14:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1620) Add pre-aggregator for count windows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/02 10:15:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1591) Remove window merge before flatten as an optimization - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/02 10:19:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1621) Create a generalized combine function - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/02 10:39:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1622) Add ReducePartial and GroupReducePartial Operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 10:58:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1622) Add ReducePartial and GroupReducePartial Operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 12:12:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-1622) Add ReducePartial and GroupReducePartial Operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 12:13:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1622) Add GroupReducePartial Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 12:13:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/02 12:20:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/03/02 12:59:04 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1555] Add serializer hierarchy debug ut... - posted by aljoscha <gi...@git.apache.org> on 2015/03/02 14:18:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-1555) Add utility to log the serializers of composite types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/02 14:18:05 UTC, 1 replies.
- [jira] [Created] (FLINK-1623) Rename Expression API and Operation Representation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 15:48:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1623) Rename Expression API and Operation Representation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 15:48:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-1623) Rename Expression API and Operation Representation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 15:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1624) Build of old sources fails due to git-commit-id plugin - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/02 15:58:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1593) Improve exception handling int Streaming runtime - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/02 15:58:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1624) Build of old sources fails due to git-commit-id plugin - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/02 15:59:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1624] fix failing build due to maven gi... - posted by mxm <gi...@git.apache.org> on 2015/03/02 16:03:05 UTC, 6 replies.
- [jira] [Commented] (FLINK-1624) Build of old sources fails due to git-commit-id plugin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/02 16:03:05 UTC, 6 replies.
- [jira] [Commented] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/02 16:43:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA... - posted by aljoscha <gi...@git.apache.org> on 2015/03/02 17:01:30 UTC, 9 replies.
- [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/02 17:02:04 UTC, 9 replies.
- [jira] [Created] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/02 17:32:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1569) Object reuse mode is not working with KeySelector functions. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/02 17:35:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1626) Spurious failure in MatchTask cancelling test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/02 17:41:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1627) Netty channel connect deadlock - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/02 18:28:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1628) Strange behavior of "where" function during a join - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/03/02 18:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1629) Add option to start Flink on YARN in a detached mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/02 19:10:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1630) Add option to YARN client to re-allocate failed containers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/02 19:12:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1624) Build of old sources fails due to git-commit-id plugin - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/02 19:18:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/02 19:34:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1626) Spurious failure in MatchTask cancelling test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/02 19:45:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/02 19:45:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1628) Strange behavior of "where" function during a join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/02 20:05:04 UTC, 6 replies.
- [jira] [Issue Comment Deleted] (FLINK-1370) Build website automatically - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/02 20:22:07 UTC, 0 replies.
- [jira] [Created] (FLINK-1631) Port collisions in ProcessReaping tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/02 20:28:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/02 22:07:04 UTC, 1 replies.
- [jira] [Created] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/02 22:07:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1633) Add getTriplets() Gelly method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/02 22:52:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1634) Fix "Could not build up connection to JobManager" issue on some systems - posted by "Dulaj Viduranga (JIRA)" <ji...@apache.org> on 2015/03/03 08:34:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for... - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/03 10:36:03 UTC, 12 replies.
- [jira] [Created] (FLINK-1635) Remove Apache Thrift dependency from Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/03 10:36:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/03 10:36:06 UTC, 12 replies.
- [jira] [Commented] (FLINK-1627) Netty channel connect deadlock - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/03 10:43:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-1635) Remove Apache Thrift dependency from Flink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/03 10:50:04 UTC, 2 replies.
- [jira] [Created] (FLINK-1636) Misleading exception during concurrent partition release and remote request - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/03 10:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1637) Flink uberjar does not work with Java 6 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/03 11:38:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/03 11:52:05 UTC, 10 replies.
- [jira] [Created] (FLINK-1638) SimpleKafkaSource connector - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/03 14:13:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1577) Misleading error messages when cancelling tasks - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/03 15:55:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-999] Configurability of LocalExecutor - posted by jkirsch <gi...@git.apache.org> on 2015/03/03 16:30:06 UTC, 2 replies.
- [jira] [Commented] (FLINK-999) Configurability of LocalExecutor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/03 16:31:06 UTC, 2 replies.
- [GitHub] flink pull request: Streaming cancellation + exception handling re... - posted by gyfora <gi...@git.apache.org> on 2015/03/03 16:41:13 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1350][FLINK-1359][Distributed runtime] ... - posted by uce <gi...@git.apache.org> on 2015/03/03 16:57:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-1350) Add blocking intermediate result partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/03 16:58:04 UTC, 10 replies.
- [GitHub] flink pull request: Add auto-parallelism to Jobs (0.8 branch) - posted by rmetzger <gi...@git.apache.org> on 2015/03/03 17:03:40 UTC, 11 replies.
- [jira] [Resolved] (FLINK-1555) Add utility to log the serializers of composite types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/03 17:11:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1577) Misleading error messages when cancelling tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/03 17:20:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1637] Reduce number of files in uberjar... - posted by rmetzger <gi...@git.apache.org> on 2015/03/03 18:51:53 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-1522][FLINK-1576] Updated LabelPropagat... - posted by balidani <gi...@git.apache.org> on 2015/03/03 19:00:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-1522) Add tests for the library methods and examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/03 19:01:04 UTC, 6 replies.
- [jira] [Updated] (FLINK-1637) Flink uberjar does not work with Java 6 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/03 19:01:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1616) Action "list -r" gives IOException when there are running jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/03 19:34:05 UTC, 13 replies.
- [jira] [Created] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/03 20:37:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1633) Add getTriplets() Gelly method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/03 20:59:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/03 21:02:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/03 21:02:04 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/03 21:05:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1631) Port collisions in ProcessReaping tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/03 23:02:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client. - posted by StephanEwen <gi...@git.apache.org> on 2015/03/03 23:05:40 UTC, 12 replies.
- [jira] [Created] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/' - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/03 23:06:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method... - posted by andralungu <gi...@git.apache.org> on 2015/03/03 23:06:22 UTC, 27 replies.
- [jira] [Assigned] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/' - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/03 23:07:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1633) Add getTriplets() Gelly method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/03 23:07:05 UTC, 27 replies.
- [jira] [Assigned] (FLINK-1612) Add guidelines to avoid duplicate class names and more JavaDoc for new addition - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 01:51:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1641) Make projection operator chainable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/04 10:02:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO... - posted by chiwanpark <gi...@git.apache.org> on 2015/03/04 10:09:44 UTC, 53 replies.
- [jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/04 10:10:05 UTC, 54 replies.
- [jira] [Assigned] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/04 10:53:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/04 10:53:05 UTC, 2 replies.
- [jira] [Created] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/04 10:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1643) Detect tumbling policies where trigger and eviction match - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/04 12:07:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1644) WebClient dies when no ExecutionEnvironment in main method - posted by "Jonathan Hasenburg (JIRA)" <ji...@apache.org> on 2015/03/04 12:49:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1628) Strange behavior of "where" function during a join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/04 13:40:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1628) Strange behavior of "where" function during a join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/04 13:40:05 UTC, 2 replies.
- [jira] [Created] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/04 13:57:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1162) Cannot serialize Scala classes with Avro serializer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/04 14:48:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/04 14:51:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-839) Add GroupReduceFunction and CoGroupFunction with separate Key - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/04 15:18:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1577) Misleading error messages when cancelling tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/04 15:20:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1522][gelly] Added test for SSSP Exampl... - posted by vasia <gi...@git.apache.org> on 2015/03/04 15:30:27 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1640] Remove tailing slash from paths. - posted by fhueske <gi...@git.apache.org> on 2015/03/04 15:38:18 UTC, 7 replies.
- [jira] [Commented] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/04 15:39:04 UTC, 7 replies.
- [jira] [Created] (FLINK-1647) Push master documentation (latest) to Flink website - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 16:54:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-1647) Push master documentation (latest) to Flink website - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/04 17:00:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-1647) Push master documentation (latest) to Flink website - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 17:08:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1627) Netty channel connect deadlock - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/04 18:03:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/04 18:14:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/04 18:37:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1616) Action "list -r" gives IOException when there are running jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/04 18:41:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/04 18:43:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1388) POJO support for writeAsCsv - posted by "Adnan Khan (JIRA)" <ji...@apache.org> on 2015/03/04 18:51:05 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-1605] Bundle all hadoop dependencies an... - posted by rmetzger <gi...@git.apache.org> on 2015/03/04 18:57:46 UTC, 24 replies.
- [jira] [Commented] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/04 18:58:06 UTC, 24 replies.
- [jira] [Commented] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 19:13:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1602) Remove 0.6-incubating from Flink website SVN - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 19:26:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 19:27:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1602) Remove 0.6-incubating from Flink website SVN - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/04 19:33:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1602) Remove 0.6-incubating from Flink website SVN - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/03/04 19:34:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1649) Give a good error message when a user program emits a null record - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/04 20:37:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/04 20:42:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/04 20:49:38 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-1650] [logging] Suppress wrong netty wa... - posted by StephanEwen <gi...@git.apache.org> on 2015/03/04 20:56:38 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1649] [runtime] Give a good error messa... - posted by StephanEwen <gi...@git.apache.org> on 2015/03/04 20:57:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-1649) Give a good error message when a user program emits a null record - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/04 20:58:38 UTC, 4 replies.
- [jira] [Created] (FLINK-1651) Running mvn test got stuck - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/04 21:46:38 UTC, 0 replies.
- [GitHub] flink pull request: Some simple cleanups and doc updates while loo... - posted by hsaputra <gi...@git.apache.org> on 2015/03/04 22:21:47 UTC, 4 replies.
- [jira] [Created] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/04 23:07:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/04 23:10:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1593) Improve exception handling int Streaming runtime - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/04 23:33:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1653) Setting up Apache Jenkins CI for continuous tests - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/05 00:02:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1572) Output directories are created before input paths are checked - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/05 01:17:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-1651) Running mvn test got stuck - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/05 02:07:38 UTC, 6 replies.
- [jira] [Created] (FLINK-1654) Wrong scala example of POJO type in documentation - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/03/05 03:36:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1654) Wrong scala example of POJO type in documentation - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/05 03:42:38 UTC, 14 replies.
- [jira] [Comment Edited] (FLINK-1654) Wrong scala example of POJO type in documentation - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/05 03:46:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1651) Running mvn test got stuck - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/05 06:19:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/05 10:23:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite... - posted by andralungu <gi...@git.apache.org> on 2015/03/05 11:15:49 UTC, 19 replies.
- [jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/05 11:16:38 UTC, 19 replies.
- [jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/05 11:45:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1595) Add a complex integration test for Streaming API - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/05 14:04:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/05 14:09:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/05 14:09:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1649) Give a good error message when a user program emits a null record - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/05 14:10:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/05 14:11:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1642) Flakey YARNSessionCapacitySchedulerITCase - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/05 14:11:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1429) Add documentation for streaming scala api - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/05 14:22:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/05 15:30:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/' - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/05 18:55:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1655) Rename StreamInvokable to StreamOperator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/05 22:12:38 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1651) Running mvn test got stuck - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/06 00:11:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1628] Fix partitioning properties for J... - posted by fhueske <gi...@git.apache.org> on 2015/03/06 01:01:00 UTC, 2 replies.
- [jira] [Created] (FLINK-1656) Fix ForwardedField documentation for operators with iterator input - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/06 11:29:38 UTC, 0 replies.
- [GitHub] flink pull request: [streaming] [wip] Fault tolerance prototype (f... - posted by mbalassi <gi...@git.apache.org> on 2015/03/06 11:33:26 UTC, 19 replies.
- [jira] [Created] (FLINK-1657) Make count windows local automatically - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/06 12:45:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1656) Fix ForwardedField documentation for operators with iterator input - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/06 12:57:38 UTC, 1 replies.
- [jira] [Created] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/06 16:24:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1648) Add a mode where the system automatically sets the parallelism to the available task slots - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/06 16:24:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/06 16:31:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1536) GSoC project: Graph partitioning operators for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/06 17:40:38 UTC, 7 replies.
- [jira] [Commented] (FLINK-1629) Add option to start Flink on YARN in a detached mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/06 22:31:39 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1651] Fix test case at JobManagerStartu... - posted by hsaputra <gi...@git.apache.org> on 2015/03/07 00:06:38 UTC, 3 replies.
- [jira] [Assigned] (FLINK-1651) Running mvn test got stuck - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/07 01:24:38 UTC, 0 replies.
- [GitHub] flink pull request: Fix checking null for ternary operator check o... - posted by hsaputra <gi...@git.apache.org> on 2015/03/07 02:55:06 UTC, 3 replies.
- [jira] [Created] (FLINK-1659) Rename classes and packages that contains Pact - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/07 03:21:38 UTC, 0 replies.
- [GitHub] flink pull request: Mesos integration of Apache Flink - posted by omnisis <gi...@git.apache.org> on 2015/03/07 04:41:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/07 09:10:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe... - posted by vasia <gi...@git.apache.org> on 2015/03/07 13:29:28 UTC, 3 replies.
- [jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/07 13:29:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/03/07 15:04:38 UTC, 15 replies.
- [jira] [Issue Comment Deleted] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/03/07 15:34:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1632][gelly] Deleted GraphUtils - posted by andralungu <gi...@git.apache.org> on 2015/03/07 17:28:52 UTC, 6 replies.
- [jira] [Commented] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/07 17:29:38 UTC, 6 replies.
- [jira] [Assigned] (FLINK-1547) Disable automated ApplicationMaster restart - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/07 18:23:38 UTC, 0 replies.
- [GitHub] flink pull request: Fixed simple typos - posted by akshaydixi <gi...@git.apache.org> on 2015/03/07 19:05:05 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/07 20:37:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming - posted by "Akshay Dixit (JIRA)" <ji...@apache.org> on 2015/03/07 20:53:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api - posted by "Akshay Dixit (JIRA)" <ji...@apache.org> on 2015/03/07 21:25:38 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-1472] Fixed Web frontend config overvie... - posted by qmlmoon <gi...@git.apache.org> on 2015/03/08 09:44:51 UTC, 3 replies.
- [jira] [Commented] (FLINK-1472) Web frontend config overview shows wrong value - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/08 09:45:38 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1429) Add documentation for streaming scala api - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/08 22:38:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/08 23:48:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1654) Wrong scala example of POJO type in documentation - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/03/09 04:54:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1637) Flink uberjar does not work with Java 6 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/09 09:48:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1660) MultiTriggerPolicyTest timeout during test - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/09 10:46:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1661) No Documentation for the isWeaklyConnected() Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/09 11:37:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1660) MultiTriggerPolicyTest timeout during test - posted by "Jonas Traub (JIRA)" <ji...@apache.org> on 2015/03/09 11:41:38 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1652] fixes superstep increment in Coll... - posted by vasia <gi...@git.apache.org> on 2015/03/09 12:15:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/09 12:16:38 UTC, 4 replies.
- [jira] [Assigned] (FLINK-1560) Add ITCases for streaming examples - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/09 13:36:38 UTC, 0 replies.
- [GitHub] flink pull request: Windowing features / fixes - posted by gyfora <gi...@git.apache.org> on 2015/03/09 14:39:15 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/09 15:15:38 UTC, 3 replies.
- [jira] [Updated] (FLINK-1641) Make projection operator chainable - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/09 15:25:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming - posted by "Wepngong Ngeh Benaiah (JIRA)" <ji...@apache.org> on 2015/03/09 15:37:38 UTC, 4 replies.
- [jira] [Created] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/09 17:06:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1651) Running mvn test got stuck - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/09 17:23:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1576) Change the Gelly examples to be consistent with the other Flink examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/09 17:30:38 UTC, 5 replies.
- [jira] [Assigned] (FLINK-1576) Change the Gelly examples to be consistent with the other Flink examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/09 17:30:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1622][java-api][scala-api] add a partia... - posted by mxm <gi...@git.apache.org> on 2015/03/09 17:38:04 UTC, 19 replies.
- [jira] [Commented] (FLINK-1622) Add GroupReducePartial Operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/09 17:38:38 UTC, 27 replies.
- [jira] [Created] (FLINK-1663) Add a FIFO job scheduler to the JobManager - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/09 18:00:44 UTC, 0 replies.
- [jira] [Created] (FLINK-1664) Fix sorting on POJO fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/09 18:07:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/09 18:11:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1664) Forbid sorting on POJOs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/09 18:12:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1664) Forbid sorting on POJOs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/09 18:12:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1666) Clean-up Field Expression Code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/09 18:19:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1667) Add tests for recovery with distributed process failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/09 18:22:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1667] [runtime] Add test for recovery a... - posted by StephanEwen <gi...@git.apache.org> on 2015/03/09 18:27:42 UTC, 3 replies.
- [jira] [Commented] (FLINK-1667) Add tests for recovery with distributed process failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/09 18:28:38 UTC, 3 replies.
- [jira] [Created] (FLINK-1668) Add a config option to specify delays between restarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/09 18:37:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1663) Add a FIFO job scheduler to the JobManager - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/03/09 18:38:38 UTC, 2 replies.
- [jira] [Created] (FLINK-1669) Streaming tests for recovery with distributed process failure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/09 18:54:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1669) Streaming tests for recovery with distributed process failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/09 19:24:38 UTC, 7 replies.
- [jira] [Commented] (FLINK-1644) WebClient dies when no ExecutionEnvironment in main method - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/09 20:31:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1629][FLINK-1630][FLINK-1547] Rework Fl... - posted by rmetzger <gi...@git.apache.org> on 2015/03/09 20:54:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-1106) Deprecate old Record API - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/09 22:32:38 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1628) Strange behavior of "where" function during a join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 01:52:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1567] [gelly] improvements to the gelly... - posted by vasia <gi...@git.apache.org> on 2015/03/10 09:22:14 UTC, 4 replies.
- [jira] [Commented] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/10 09:22:38 UTC, 7 replies.
- [jira] [Issue Comment Deleted] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/10 09:26:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1576] [gelly] improvements to the gelly... - posted by vasia <gi...@git.apache.org> on 2015/03/10 09:32:16 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1667) Add tests for recovery with distributed process failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/10 09:45:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1668) Add a config option to specify delays between restarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/10 09:45:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1567] Add switch to use the AvroSeriali... - posted by StephanEwen <gi...@git.apache.org> on 2015/03/10 10:05:30 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1219] Add support for Apache Tez as exe... - posted by rmetzger <gi...@git.apache.org> on 2015/03/10 10:39:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/10 10:39:39 UTC, 1 replies.
- [jira] [Created] (FLINK-1670) Collect method for streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/10 10:57:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1350] [runtime] Add blocking result par... - posted by uce <gi...@git.apache.org> on 2015/03/10 11:15:21 UTC, 9 replies.
- [jira] [Created] (FLINK-1671) Add execution modes for programs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/10 11:29:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1368) Change memory management settings for Streaming programs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/10 11:55:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1672) Refactor task registration/unregistration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/10 11:57:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1673) Colocate Flink Kafka consumer - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/10 13:33:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1671) Add execution modes for programs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/10 13:41:38 UTC, 2 replies.
- [jira] [Created] (FLINK-1674) Add test with nested avro type - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/10 14:09:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1544) Extend streaming aggregation tests to include POJOs - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/10 15:18:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1675) Rework Accumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/10 15:56:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1676) enableForceKryo() is not working as expected - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/10 16:12:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1594] [streaming] [wip] DataStream supp... - posted by gaborhermann <gi...@git.apache.org> on 2015/03/10 16:21:44 UTC, 5 replies.
- [jira] [Commented] (FLINK-1594) DataStreams don't support self-join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/10 16:22:38 UTC, 5 replies.
- [jira] [Commented] (FLINK-1664) Forbid sorting on POJOs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/10 16:22:39 UTC, 1 replies.
- [jira] [Created] (FLINK-1677) Properly Suppress Sysout Printing for the Degrees with exception test suite - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/10 16:42:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs - posted by "Wepngong Ngeh Benaiah (JIRA)" <ji...@apache.org> on 2015/03/10 16:54:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/10 17:34:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1676] Rework ExecutionConfig.enableForc... - posted by rmetzger <gi...@git.apache.org> on 2015/03/10 18:03:16 UTC, 3 replies.
- [jira] [Commented] (FLINK-1676) enableForceKryo() is not working as expected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/10 18:03:39 UTC, 3 replies.
- [GitHub] flink pull request: Cleanup of low level Kafka consumer (Persisten... - posted by gaborhermann <gi...@git.apache.org> on 2015/03/10 18:51:39 UTC, 8 replies.
- [jira] [Created] (FLINK-1678) Extend internals documentation: program flow, optimizer, ... - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/10 19:21:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/10 19:32:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1680) Upgrade Flink dependencies for Tachyon to 0.6.0 - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/10 19:42:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1681) Remove the old Record API - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/10 20:41:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1682) Port Record-API based optimizer tests to new Java API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 20:51:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1682) Port Record-API based optimizer tests to new Java API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 20:52:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1683) Scheduling preferences for non-unary tasks are not correctly computed - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 21:03:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1272) Add a "reduceWithKey" function - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 21:07:38 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1272) Add a "reduceWithKey" function - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 21:28:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1677][gelly] Suppresed Sysout Printing - posted by andralungu <gi...@git.apache.org> on 2015/03/10 22:30:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-1677) Properly Suppress Sysout Printing for the Degrees with exception test suite - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/10 22:30:39 UTC, 4 replies.
- [jira] [Updated] (FLINK-1343) Branching Join Program Deadlocks - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/10 22:57:38 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1683] [jobmanager]� Fix scheduling pref... - posted by fhueske <gi...@git.apache.org> on 2015/03/11 00:37:28 UTC, 3 replies.
- [jira] [Commented] (FLINK-1683) Scheduling preferences for non-unary tasks are not correctly computed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/11 00:37:39 UTC, 3 replies.
- [GitHub] flink pull request: Add support for building Flink with Scala 2.11 - posted by aalexandrov <gi...@git.apache.org> on 2015/03/11 00:41:16 UTC, 38 replies.
- [GitHub] flink pull request: [FLINK-1654] Wrong scala example of POJO type ... - posted by chiwanpark <gi...@git.apache.org> on 2015/03/11 02:43:49 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-1525) Provide utils to pass -D parameters to UDFs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/11 10:01:38 UTC, 1 replies.
- [jira] [Created] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/11 10:27:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1685) Document how to read gzip/compressed files with Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/11 11:55:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/11 12:03:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1685) Document how to read gzip/compressed files with Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/11 12:27:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1686) Streaming iteration heads cannot be instantiated - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/03/11 12:39:39 UTC, 0 replies.
- [GitHub] flink pull request: Kick off of Flink's machine learning library - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/11 12:42:33 UTC, 25 replies.
- [jira] [Created] (FLINK-1687) Streaming file source API is not in sync with the batch API - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/11 14:42:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/11 15:04:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/11 15:45:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1684) Make Kafka connectors read/write a partition the worker is on - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/11 15:45:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1688) Add socket sink - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/11 16:20:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/11 16:21:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1688) Add socket sink - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/11 16:21:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/11 16:23:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/11 16:23:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/11 16:27:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1691) Inprove CountCollectITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/11 16:46:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/11 16:53:38 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1654) Wrong scala example of POJO type in documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/11 18:10:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1388) POJO support for writeAsCsv - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/11 18:21:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1525) Provide utils to pass -D parameters to UDFs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/12 09:45:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1525) Provide utils to pass -D parameters to UDFs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/12 09:45:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/12 09:58:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/12 09:58:38 UTC, 19 replies.
- [jira] [Created] (FLINK-1692) Add option to Flink YARN client to stop a detached YARN session. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/12 10:00:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1547) Disable automated ApplicationMaster restart - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/12 11:35:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1630) Add option to YARN client to re-allocate failed containers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/12 11:35:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1629) Add option to start Flink on YARN in a detached mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/12 11:35:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1688) Add socket sink - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/12 11:36:38 UTC, 13 replies.
- [jira] [Created] (FLINK-1693) Deprecate the Spargel API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/12 12:24:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1694) Change the split between create/run of a vertex-centric iteration - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/12 12:38:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-1694) Change the split between create/run of a vertex-centric iteration - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/12 12:38:42 UTC, 0 replies.
- [GitHub] flink pull request: IntelliJ Setup Guide - posted by nltran <gi...@git.apache.org> on 2015/03/12 16:17:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1450] Added fold operator for the Strea... - posted by akshaydixi <gi...@git.apache.org> on 2015/03/12 18:51:48 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-1677][gelly] Suppressed Sysout Printing... - posted by andralungu <gi...@git.apache.org> on 2015/03/12 22:19:34 UTC, 1 replies.
- [GitHub] flink pull request: Remove -j and -a parameters which seemed no lo... - posted by hsaputra <gi...@git.apache.org> on 2015/03/13 00:21:42 UTC, 9 replies.
- [jira] [Created] (FLINK-1695) Create machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/13 01:11:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1696) Add multiple linear regression to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/13 01:12:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1697) Add alternating least squares algorithm to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/13 01:12:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1697) Add alternating least squares algorithm for matrix factorization to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/13 01:13:38 UTC, 2 replies.
- [jira] [Created] (FLINK-1698) Add polynomial base feature mapper to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/13 01:14:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1695] Kick off of Flink's machine learn... - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/13 01:17:11 UTC, 23 replies.
- [jira] [Commented] (FLINK-1695) Create machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/13 01:17:38 UTC, 23 replies.
- [jira] [Created] (FLINK-1699) Co-task sometimes returns null - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/13 09:57:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1699) Co-task sometimes returns null - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/13 10:03:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/13 11:27:38 UTC, 5 replies.
- [jira] [Updated] (FLINK-441) Renaming in pact-compiler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/13 11:35:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-1659) Rename classes and packages that contains Pact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/13 11:37:38 UTC, 2 replies.
- [jira] [Updated] (FLINK-82) (Hash) Aggregators (fold style) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/13 11:48:38 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/13 12:00:42 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1615) Introduces a new InputFormat for Tweets - posted by "mustafa elbehery (JIRA)" <ji...@apache.org> on 2015/03/13 12:05:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1700) Include Google Analytics in Javadocs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/13 12:20:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/13 13:28:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1701) Serialization problems with TestStreamEnvironment - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/13 14:00:44 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1683) Scheduling preferences for non-unary tasks are not correctly computed - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/13 14:34:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1702) Authenticate via Kerberos from the client only - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/13 17:46:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1703) option to balance load according to CPU available rather than slots available - posted by "Emmanuel Leroy (JIRA)" <ji...@apache.org> on 2015/03/13 18:27:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1622][java-api][scala-api] add a GroupC... - posted by hsaputra <gi...@git.apache.org> on 2015/03/13 18:53:25 UTC, 7 replies.
- [jira] [Created] (FLINK-1704) Change AbstractFlinkYarnClient from abstract to interface - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/13 19:19:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1704) Change AbstractFlinkYarnClient and AbstractFlinkYarnCluster from abstract to interface - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/13 22:10:38 UTC, 2 replies.
- [GitHub] flink pull request: IntelliJ file ignored - posted by miguel0afd <gi...@git.apache.org> on 2015/03/14 12:24:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-1356) Add a warning during startup if config files cannot be found - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/14 17:22:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1356) Add a warning during startup if config files cannot be found - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/14 17:23:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1705) InstanceConnectionInfo returns wrong hostname when no DNS entry exists - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/14 18:20:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1688] Socket client sink added - posted by miguel0afd <gi...@git.apache.org> on 2015/03/14 23:58:00 UTC, 12 replies.
- [jira] [Resolved] (FLINK-1450) Add Fold operator to the Streaming api - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 11:07:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1705) InstanceConnectionInfo returns wrong hostname when no DNS entry exists - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/15 17:09:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1677) Properly Suppress Sysout Printing for the Degrees with exception test suite - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/15 17:10:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1461) Add sortPartition operator - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:39:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1450) Add Fold operator to the Streaming api - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:44:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-1654) Wrong scala example of POJO type in documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:44:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:44:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/' - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:46:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:46:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1569) Object reuse mode is not working with KeySelector functions. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:48:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1646) Add name of required configuration value into the "Insufficient number of network buffers" exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:48:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1591) Remove window merge before flatten as an optimization - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:48:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1625) Add cancel method to user defined sources and sinks and call them on task cancellation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:48:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1593) Improve exception handling int Streaming runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 17:49:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1657) Make count windows local automatically - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 18:04:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1657) Make count windows local automatically - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 18:04:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1620) Add pre-aggregator for count windows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 18:04:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1643) Detect tumbling policies where trigger and eviction match - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 18:04:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1619) Add pre-aggregator for time windows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 18:05:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1660) MultiTriggerPolicyTest timeout during test - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/15 18:05:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 18:11:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 18:12:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-1609) FileSystem doesn't expose current user's home directory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 18:14:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1519) Web frontend task state mismatch when cancelling - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 18:14:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/15 18:16:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/16 10:24:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1691) Inprove CountCollectITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/16 10:51:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1699) Co-task sometimes returns null - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/16 10:53:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1618] [streaming] Parallel time reduce - posted by gyfora <gi...@git.apache.org> on 2015/03/16 11:28:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-1618) Add parallel time discretisation for time-window transformations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/16 11:29:38 UTC, 1 replies.
- [jira] [Created] (FLINK-1706) Add disk spilling to BarrierBuffer - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/16 11:33:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1699) Co-task sometimes returns null - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/16 11:43:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1342] Fix filtering of usercode from qu... - posted by rmetzger <gi...@git.apache.org> on 2015/03/16 14:52:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-1342) Quickstart's assembly can possibly filter out user's code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/16 14:53:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/16 15:34:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/16 15:57:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "joey (JIRA)" <ji...@apache.org> on 2015/03/16 15:59:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/16 17:11:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1708) KafkaSink not working from Usercode classloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/16 17:19:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1709) Add support for programs with higher-than-slot parallelism - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/16 17:46:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1710) Expression API Tests take very long - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/16 17:48:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1671] Add different execution modes to ... - posted by StephanEwen <gi...@git.apache.org> on 2015/03/16 18:17:24 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1679] rename degree of parallelism to p... - posted by mxm <gi...@git.apache.org> on 2015/03/16 18:29:42 UTC, 16 replies.
- [jira] [Resolved] (FLINK-1370) Build website automatically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/16 18:36:38 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1615) Introduces a new InputFormat for Tweets - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/16 19:42:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1641] Make projection operator chainabl... - posted by ggevay <gi...@git.apache.org> on 2015/03/17 03:51:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-1641) Make projection operator chainable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/17 03:51:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-1701) Serialization problems with TestStreamEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 10:04:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1671) Add execution modes for programs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 10:38:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1711) Replace all usages off commons.Validate with guava.check - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 10:41:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1671) Add execution modes for programs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 10:41:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-1711) Replace all usages off commons.Validate with guava.check - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 10:41:42 UTC, 1 replies.
- [jira] [Created] (FLINK-1712) Restructure Maven Projects - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 10:46:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1712) Restructure Maven Projects - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/17 10:50:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1713) Add support for blocking data exchange in closed loop iterations - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/17 11:23:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1340) Project restructure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/17 11:31:38 UTC, 0 replies.
- [GitHub] flink pull request: modify the getlogger of the class - posted by matadorhong <gi...@git.apache.org> on 2015/03/17 11:51:49 UTC, 1 replies.
- [jira] [Created] (FLINK-1714) Fix the bug of logger class loader - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/17 14:43:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1576) Change the Gelly examples to be consistent with the other Flink examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/17 15:37:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/17 15:37:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1593) Improve exception handling int Streaming runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/17 15:43:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1593) Improve exception handling in the Streaming runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/17 15:44:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1593) Improve exception handling in the Streaming runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/17 16:00:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-1695) Create machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 16:23:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1696) Add multiple linear regression to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 16:23:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-1698) Add polynomial base feature mapper to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 16:24:39 UTC, 0 replies.
- [GitHub] flink pull request: Fix issue where Windows paths were not recogni... - posted by balidani <gi...@git.apache.org> on 2015/03/17 17:00:47 UTC, 16 replies.
- [jira] [Closed] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/17 17:34:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API - posted by "Tushar Tiwari (JIRA)" <ji...@apache.org> on 2015/03/17 17:41:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1507) Allow to configure produced intermediate result type via ExecutionConfig - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/17 18:04:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1568) Add failure-case tests for data exchange - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/17 18:06:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1570) Add failure-case tests for pipelined data exchange - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/17 18:06:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1571) Add failure-case tests for blocking data exchange - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/17 18:06:40 UTC, 0 replies.
- [jira] [Created] (FLINK-1715) Remove print statements in MultiEvictionPolicy and GroupedDataStream - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/17 18:12:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ... - posted by StephanEwen <gi...@git.apache.org> on 2015/03/17 19:58:31 UTC, 12 replies.
- [jira] [Commented] (FLINK-441) Renaming in pact-compiler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/17 19:58:38 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-1706] Spilling BarrierBuffer added + ba... - posted by gyfora <gi...@git.apache.org> on 2015/03/17 20:11:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-1706) Add disk spilling to BarrierBuffer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/17 20:11:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1714]Fix the bug of logger class loader - posted by StephanEwen <gi...@git.apache.org> on 2015/03/17 20:30:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-1714) Fix the bug of logger class loader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/17 20:30:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:06:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1714) Fix the bug of logger class loader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:07:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1682) Port Record-API based optimizer tests to new Java API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:08:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1584) Spurious failure of TaskManagerFailsITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:12:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-1535) Use usercode class loader to serialize/deserialize accumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:16:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:23:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:24:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:25:41 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1459) Collect DataSet to client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:28:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1467) Job deployment fails with NPE on JobManager, if TMs did not start properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:35:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1467) Job deployment fails with NPE on JobManager, if TMs did not start properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/17 21:36:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1713) Add support for blocking data exchange in closed loop iterations - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/17 22:41:38 UTC, 1 replies.
- [jira] [Closed] (FLINK-1695) Create machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 23:50:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1696) Add multiple linear regression to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 23:50:43 UTC, 0 replies.
- [jira] [Closed] (FLINK-1697) Add alternating least squares algorithm for matrix factorization to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 23:51:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1698) Add polynomial base feature mapper to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/17 23:51:39 UTC, 0 replies.
- [GitHub] flink pull request: Add final modifier to PollingThread#lock objec... - posted by hsaputra <gi...@git.apache.org> on 2015/03/18 00:18:27 UTC, 2 replies.
- [GitHub] flink pull request: Merge pull request #1 from apache/master - posted by matadorhong <gi...@git.apache.org> on 2015/03/18 02:33:11 UTC, 1 replies.
- [jira] [Reopened] (FLINK-1695) Create machine learning library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:26:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1695) Create machine learning library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:26:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1696) Add multiple linear regression to ML library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:36:38 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1696) Add multiple linear regression to ML library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:36:38 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1697) Add alternating least squares algorithm for matrix factorization to ML library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:36:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1697) Add alternating least squares algorithm for matrix factorization to ML library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:36:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1698) Add polynomial base feature mapper to ML library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:36:39 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1698) Add polynomial base feature mapper to ML library - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 09:36:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1716) Add CoCoA algorithm to flink-ml - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 09:45:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1717) Add support to read libSVM and SVMLight input files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 09:55:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 09:59:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 10:12:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 10:12:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-1486) Add a string to the print method to identify output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/18 10:40:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/18 10:41:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/18 10:45:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1669] [wip] Test for streaming recovery... - posted by mbalassi <gi...@git.apache.org> on 2015/03/18 11:18:04 UTC, 6 replies.
- [jira] [Created] (FLINK-1721) Flakey Yarn Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/18 11:20:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1721) Flakey Yarn Tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 11:23:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-1710) Expression API Tests take very long - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/18 11:28:38 UTC, 9 replies.
- [jira] [Updated] (FLINK-1721) Flakey Yarn Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/18 11:35:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1722) Streaming not respecting FinalizeOnMaster for output formats - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/18 11:45:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1723) Add cross validation for parameter selection and validation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 12:02:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1724) TestingCluster uses local communication with multiple task managers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/18 12:04:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1712) Restructure Maven Projects - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/18 12:57:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1725) New Partitioner for better load balancing for skewed data - posted by "Anis Nasir (JIRA)" <ji...@apache.org> on 2015/03/18 13:19:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data - posted by "Anis Nasir (JIRA)" <ji...@apache.org> on 2015/03/18 13:20:38 UTC, 2 replies.
- [jira] [Created] (FLINK-1726) Add Community Detection Library and Example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/18 14:16:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1727) Add decision tree to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 14:40:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1724) TestingCluster uses local communication with multiple task managers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/18 14:46:38 UTC, 1 replies.
- [jira] [Reopened] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:51:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1632) Use DataSet's count() and collect() to simplify Gelly methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:52:38 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:52:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1728) Add random forest ensemble method to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 14:52:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:52:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1652) Wrong superstep number in VertexCentricIteration in Collection mode - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:53:38 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1576) Change the Gelly examples to be consistent with the other Flink examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:53:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1576) Change the Gelly examples to be consistent with the other Flink examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:53:40 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1576) Change the Gelly examples to be consistent with the other Flink examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/18 14:53:41 UTC, 0 replies.
- [jira] [Created] (FLINK-1729) Assess performance of classification algorithms - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 15:12:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/18 15:17:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 15:19:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1732) Add Gaussian mixture model to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 15:29:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1733) Add PCA to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 15:37:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1734) Insufficient memory allocation in Gelly - posted by "Robert Waury (JIRA)" <ji...@apache.org> on 2015/03/18 15:39:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1735) Add FeatureHasher to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 15:54:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1720] Integrate ScalaDoc into JavaDoc - posted by aljoscha <gi...@git.apache.org> on 2015/03/18 16:03:21 UTC, 4 replies.
- [jira] [Commented] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/18 16:03:40 UTC, 4 replies.
- [jira] [Created] (FLINK-1736) Add CountVectorizer to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 16:07:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 16:19:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1738) Add mean centering transformation to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 16:36:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1196) Interfaces wrapping the persistence layer for source fault tolerance - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/18 16:52:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1184) Streaming stateful computation support - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/18 16:54:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1192) Streaming source fault tolerance - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/18 16:55:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1641) Make projection operator chainable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/18 16:56:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1709) Add support for programs with slot count exceeding parallelism - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/18 17:31:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1732) Add Gaussian mixture model to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 17:48:38 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1709] [wip] Add SlotCountExceedingParal... - posted by uce <gi...@git.apache.org> on 2015/03/18 17:52:56 UTC, 5 replies.
- [jira] [Commented] (FLINK-1709) Add support for programs with slot count exceeding parallelism - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/18 17:53:38 UTC, 5 replies.
- [jira] [Created] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check. - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/18 18:15:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task... - posted by matadorhong <gi...@git.apache.org> on 2015/03/18 18:16:42 UTC, 9 replies.
- [jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/18 18:17:38 UTC, 9 replies.
- [jira] [Created] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/18 18:23:41 UTC, 0 replies.
- [GitHub] flink pull request: Improvements to Kafka Source/Sink & some bugfi... - posted by rmetzger <gi...@git.apache.org> on 2015/03/18 18:26:22 UTC, 11 replies.
- [jira] [Assigned] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/03/18 18:45:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1622) Add GroupReducePartial Operator - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/18 18:47:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1622) Add GroupReducePartial Operator - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/18 18:48:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1621) Create a generalized combine function - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/18 18:51:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/03/18 18:52:38 UTC, 14 replies.
- [jira] [Created] (FLINK-1741) Add Jaccard Similarity Metric Example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/18 19:27:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1729) Assess performance of classification algorithms - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-1717) Add support to read libSVM and SVMLight input files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1736) Add CountVectorizer to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1733) Add PCA to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1735) Add FeatureHasher to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1738) Add mean centering transformation to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1728) Add random forest ensemble method to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-1716) Add CoCoA algorithm to flink-ml - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1723) Add cross validation for parameter selection and validation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-1727) Add decision tree to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:35:40 UTC, 0 replies.
- [jira] [Created] (FLINK-1742) Sample data points for MultipleLinearRegression to support proper SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:41:43 UTC, 0 replies.
- [jira] [Created] (FLINK-1743) Add multinomial logistic regression to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/18 19:59:39 UTC, 0 replies.
- [GitHub] flink pull request: Flink 1740 - posted by senorcarbone <gi...@git.apache.org> on 2015/03/18 20:00:54 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1701) Serialization problems with TestStreamEnvironment - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/18 21:29:38 UTC, 0 replies.
- [jira] [Closed] (FLINK-1701) Serialization problems with TestStreamEnvironment - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/18 21:33:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-1740 - posted by hsaputra <gi...@git.apache.org> on 2015/03/18 21:39:53 UTC, 9 replies.
- [jira] [Commented] (FLINK-1741) Add Jaccard Similarity Metric Example - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/03/18 21:49:38 UTC, 13 replies.
- [jira] [Created] (FLINK-1744) Change the reference of slaves to workers to match the description of the system - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/18 23:45:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/18 23:47:38 UTC, 4 replies.
- [jira] [Closed] (FLINK-1734) Insufficient memory allocation in Gelly - posted by "Robert Waury (JIRA)" <ji...@apache.org> on 2015/03/19 00:15:38 UTC, 0 replies.
- [GitHub] flink pull request: Remove redundant codes which never been execut... - posted by matadorhong <gi...@git.apache.org> on 2015/03/19 10:05:23 UTC, 1 replies.
- [jira] [Created] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/19 11:16:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1350) Add blocking intermediate result partitions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 11:26:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1746) Add linear discriminant analysis to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/19 11:29:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-1746) Add linear discriminant analysis to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/19 11:29:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 11:33:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1343) Branching Join Program Deadlocks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 11:34:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 11:35:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1359) Make IntermediateResultPartitionManager aware of consumed partitions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 11:36:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1332) Possible deadlock with two broadcast sets - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 11:40:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1748) Integrate PageRank implementation into machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/19 11:42:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/19 12:23:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/19 12:47:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1751) Update CLI documentation page - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/19 15:38:50 UTC, 0 replies.
- [jira] [Updated] (FLINK-1751) Update CLI documentation page - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 15:49:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1752) Add test to Kafka streaming connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 15:56:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1753) Add more tests for Kafka Connectors - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 16:36:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 16:50:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1751) Update CLI documentation page - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/19 17:04:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/19 17:53:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/19 17:54:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1709) Add support for programs with slot count exceeding parallelism - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/19 17:57:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1752] Improvements to Kafka Source/Sink... - posted by rmetzger <gi...@git.apache.org> on 2015/03/19 18:41:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-1752) Add test to Kafka streaming connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/19 18:41:38 UTC, 2 replies.
- [jira] [Closed] (FLINK-1708) KafkaSink not working from Usercode classloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 18:44:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1754) Deadlock in job execution - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/03/19 18:59:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1754) Deadlock in job execution - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/03/19 19:01:38 UTC, 10 replies.
- [jira] [Updated] (FLINK-1754) Deadlock in job execution - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/03/19 19:02:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1754) Deadlock in job execution - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 19:09:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 19:19:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1342) Quickstart's assembly can possibly filter out user's code - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 20:32:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 20:32:39 UTC, 2 replies.
- [GitHub] flink pull request: Make Expression API available to Java, Rename ... - posted by aljoscha <gi...@git.apache.org> on 2015/03/19 20:49:12 UTC, 16 replies.
- [jira] [Resolved] (FLINK-1752) Add test to Kafka streaming connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/19 20:59:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 10:05:38 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1721) Flakey Yarn Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 10:40:40 UTC, 0 replies.
- [jira] [Created] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 10:46:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-441) Renaming in pact-compiler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:08:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-67) Add HBase Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:14:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-336) Job-Preview (web) should not require getPlan() to work with empty args - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:15:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-819) OutOfMemoryError from TaskManager is causing hard to understand exceptions and blocking JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:16:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-947) Add support for "Named Datasets" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:18:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-952) TypeExtractor requires the argument types of the UDF to be identical to the parameter types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:19:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1018) Logistic Regression deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:20:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1090) Join deadlocks when used inside Delta iteration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:21:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1088) Iteration head deadlock - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:22:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-972) Run Flink on Tez - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 11:23:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1706) Add disk spilling to BarrierBuffer - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 13:45:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1618) Add parallel time discretisation for time-window transformations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 13:45:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/20 13:45:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1594) DataStreams don't support self-join - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 13:46:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1715) Remove print statements in MultiEvictionPolicy and GroupedDataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 13:47:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 14:08:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1758) Extend Gelly's neighborhood methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/20 14:13:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1759) Execution statistics for vertex-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/20 14:26:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1759) Execution statistics for vertex-centric iterations - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/20 14:41:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/20 14:44:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1759) Execution statistics for vertex-centric iterations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 14:53:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1760) Add support for building Flink with Scala 2.11 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 14:54:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1740] Pass config param for numberOfExe... - posted by asfgit <gi...@git.apache.org> on 2015/03/20 14:57:02 UTC, 2 replies.
- [jira] [Updated] (FLINK-1759) Execution statistics for vertex-centric iterations - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/20 14:57:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 14:57:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 14:58:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/20 15:37:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/20 15:38:38 UTC, 11 replies.
- [jira] [Created] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/20 15:49:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1760) Add support for building Flink with Scala 2.11 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 15:50:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-974) TaskManager startup script does not respect JAVA_HOME - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 16:28:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1761] Fix IndexOutOfBoundsException whe... - posted by uce <gi...@git.apache.org> on 2015/03/20 16:30:28 UTC, 2 replies.
- [jira] [Commented] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/20 16:30:38 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1726][gelly] Added Community Detection ... - posted by andralungu <gi...@git.apache.org> on 2015/03/20 16:47:47 UTC, 12 replies.
- [jira] [Commented] (FLINK-1726) Add Community Detection Library and Example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/20 16:48:38 UTC, 12 replies.
- [jira] [Created] (FLINK-1762) Make Statefulness of a Streaming Function explicit - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 16:51:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1763) Remove "cancel" from streaming SinkFunction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 17:55:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1764) Rework record copying logic in streaming API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 18:16:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 18:20:38 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-1764) Rework record copying logic in streaming API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 18:31:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1765) Reducer grouping is skippted when parallelism is one - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/20 18:32:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1756] [streaming] Rename Stream Monitor... - posted by mbalassi <gi...@git.apache.org> on 2015/03/20 18:38:21 UTC, 10 replies.
- [jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 18:50:38 UTC, 3 replies.
- [jira] [Assigned] (FLINK-1765) Reducer grouping is skippted when parallelism is one - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 19:12:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-1763) Remove "cancel" from streaming SinkFunction - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 21:19:38 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1765) Reducer grouping is skippted when parallelism is one - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/20 21:25:38 UTC, 0 replies.
- [GitHub] flink pull request: Add the class member variables with 'this' - posted by matadorhong <gi...@git.apache.org> on 2015/03/21 04:05:24 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin... - posted by bhatsachin <gi...@git.apache.org> on 2015/03/21 09:40:11 UTC, 12 replies.
- [jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/21 09:40:38 UTC, 12 replies.
- [jira] [Assigned] (FLINK-1655) Rename StreamInvokable to StreamOperator - posted by "Akshay Dixit (JIRA)" <ji...@apache.org> on 2015/03/21 11:56:38 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1763) Remove "cancel" from streaming SinkFunction - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/21 12:40:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1655] Renamed StreamInvokable to Stream... - posted by akshaydixi <gi...@git.apache.org> on 2015/03/21 12:45:26 UTC, 2 replies.
- [jira] [Commented] (FLINK-1655) Rename StreamInvokable to StreamOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/21 12:45:38 UTC, 2 replies.
- [jira] [Created] (FLINK-1766) Fix the bug of equals function of FSKey - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/21 13:55:38 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1766]Fix the bug of equals function of ... - posted by matadorhong <gi...@git.apache.org> on 2015/03/21 13:55:41 UTC, 10 replies.
- [jira] [Commented] (FLINK-1766) Fix the bug of equals function of FSKey - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/21 13:56:38 UTC, 10 replies.
- [GitHub] flink pull request: Adds akka interal docs and configuration descr... - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/21 17:34:45 UTC, 6 replies.
- [jira] [Resolved] (FLINK-1611) Rename classes and packages that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/22 04:42:10 UTC, 0 replies.
- [jira] [Created] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/22 08:37:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1763] [streaming] Remove cancel from Si... - posted by gyfora <gi...@git.apache.org> on 2015/03/22 13:47:12 UTC, 1 replies.
- [jira] [Created] (FLINK-1768) Fix the bug of BlobServerConnection's LOG. - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/22 17:21:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1768]Fix the bug of BlobServerConnectio... - posted by matadorhong <gi...@git.apache.org> on 2015/03/22 17:21:41 UTC, 2 replies.
- [jira] [Commented] (FLINK-1768) Fix the bug of BlobServerConnection's LOG. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/22 17:22:10 UTC, 2 replies.
- [GitHub] flink pull request: Rename the variable 'contentAdressable' to 'co... - posted by matadorhong <gi...@git.apache.org> on 2015/03/22 17:54:41 UTC, 0 replies.
- [jira] [Closed] (FLINK-1763) Remove "cancel" from streaming SinkFunction - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/22 19:01:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1756) Rename Stream Monitoring to Stream Checkpointing - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/22 19:03:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1688) Add socket sink - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/22 19:06:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-1693) Deprecate the Spargel API - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/22 21:17:10 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/03/22 22:15:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1767] [streaming] Make StreamExecutionE... - posted by ggevay <gi...@git.apache.org> on 2015/03/22 22:35:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/22 22:36:10 UTC, 6 replies.
- [jira] [Resolved] (FLINK-1679) Document how "degree of parallelism" / "parallelism" / "slots" are connected to each other - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/23 09:14:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 09:57:10 UTC, 0 replies.
- [jira] [Created] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 11:09:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 11:10:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 11:10:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1656) Filtered Semantic Properties for Operators with Iterators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/23 11:11:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1656) Filtered Semantic Properties for Operators with Iterators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/23 11:16:10 UTC, 6 replies.
- [jira] [Created] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable' - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/23 12:09:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable' - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/23 12:10:10 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1373) Add documentation for intermediate results and network stack to internals - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/23 12:39:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1544] [streaming] POJO types added to A... - posted by szape <gi...@git.apache.org> on 2015/03/23 14:43:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-1544) Extend streaming aggregation tests to include POJOs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 14:44:10 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1650] Configure Netty (akka) to use Slf... - posted by rmetzger <gi...@git.apache.org> on 2015/03/23 14:57:28 UTC, 8 replies.
- [GitHub] flink pull request: FLINK-1560 - Add ITCases for streaming example... - posted by szape <gi...@git.apache.org> on 2015/03/23 15:03:47 UTC, 9 replies.
- [jira] [Commented] (FLINK-1560) Add ITCases for streaming examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 15:04:10 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-1595] [streaming] Complex integration t... - posted by szape <gi...@git.apache.org> on 2015/03/23 15:12:55 UTC, 4 replies.
- [jira] [Commented] (FLINK-1595) Add a complex integration test for Streaming API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 15:13:10 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1687] [streaming] Syncing streaming sou... - posted by szape <gi...@git.apache.org> on 2015/03/23 15:21:17 UTC, 7 replies.
- [jira] [Commented] (FLINK-1687) Streaming file source/sink API is not in sync with the batch API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 15:22:11 UTC, 7 replies.
- [jira] [Commented] (FLINK-1319) Add static code analysis for UDFs - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/03/23 15:22:12 UTC, 9 replies.
- [jira] [Updated] (FLINK-1744) Change the reference of slaves to workers to match the description of the system - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 15:37:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1771) Add tests for setting the processing slots for the YARN client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 15:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1771) Add tests for setting the processing slots for the YARN client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 15:49:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1744) Change the reference of slaves to workers to match the description of the system - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 16:05:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1772) Chain of split/select does not work - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/03/23 16:28:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-1772) Chain of split/select does not work - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/23 16:37:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/23 17:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1774) Remove the redundant code in try{} block - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/23 17:23:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1774) Remove the redundant code in try{} block - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/23 17:24:11 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1774]Remove the redundant code in try{}... - posted by matadorhong <gi...@git.apache.org> on 2015/03/23 17:25:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-1774) Remove the redundant code in try{} block - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 17:26:10 UTC, 3 replies.
- [GitHub] flink pull request: Introduced CentralActiveTrigger with GroupedAc... - posted by gyfora <gi...@git.apache.org> on 2015/03/23 17:43:46 UTC, 8 replies.
- [jira] [Created] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/23 17:48:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/23 17:48:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1776) APIs provide invalid Semantic Properties for Operators with SelectorFunction keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/23 17:54:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/23 17:55:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1693) Deprecate the Spargel API - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 18:10:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1611) Rename classes and packages that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 18:15:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-1611) Rename classes and packages that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 18:15:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1659) Rename classes and packages that contains Pact - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 18:15:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1659) Rename classes and packages that contains Pact - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/23 18:16:10 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-1686] Streaming Iterations Slot Sharing... - posted by senorcarbone <gi...@git.apache.org> on 2015/03/23 18:42:01 UTC, 4 replies.
- [jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/23 19:45:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 19:47:52 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1770]Rename the variable 'contentAdress... - posted by rmetzger <gi...@git.apache.org> on 2015/03/23 21:03:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/23 21:03:53 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1656] Filter ForwardedField properties ... - posted by fhueske <gi...@git.apache.org> on 2015/03/23 23:25:55 UTC, 5 replies.
- [jira] [Updated] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/23 23:29:52 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1775] BarrierBuffer fix to avoid end of... - posted by gyfora <gi...@git.apache.org> on 2015/03/24 00:02:41 UTC, 11 replies.
- [jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/24 00:02:53 UTC, 11 replies.
- [GitHub] flink pull request: Adds akka configuration description - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/24 00:34:18 UTC, 4 replies.
- [jira] [Commented] (FLINK-1611) Rename classes and packages that contains Nephele - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/24 00:36:53 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check. - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 01:47:53 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1766) Fix the bug of equals function of FSKey - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 07:12:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1768) Fix the bug of BlobServerConnection's LOG. - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 07:12:53 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable' - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 07:13:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-1768) Fix the bug of BlobServerConnection's LOG. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/24 12:24:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1714) Fix the bug of logger class loader - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 12:33:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-1776) APIs provide invalid Semantic Properties for Operators with SelectorFunction keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/24 13:49:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/24 13:51:53 UTC, 6 replies.
- [jira] [Resolved] (FLINK-1761) IndexOutOfBoundsException when receiving empty buffer at remote channel - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/24 13:53:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1777) Update Java 8 Lambdas with Eclipse documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/03/24 15:28:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1777] [docs] Update Java 8 Lambdas with... - posted by twalthr <gi...@git.apache.org> on 2015/03/24 15:32:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-1777) Update Java 8 Lambdas with Eclipse documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/24 15:32:55 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1717) Add support to read libSVM and SVMLight input files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/24 15:33:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1778) Improve normalized keys in composite key case - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/24 16:20:52 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1660) MultiTriggerPolicyTest timeout during test - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/24 16:30:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1779) Rename the function name from "getCurrentyActiveConnections" to "getCurrentActiveConnections" in org.apache.flink.runtime.blob - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 17:04:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1779]Rename the function getCurrentyAct... - posted by matadorhong <gi...@git.apache.org> on 2015/03/24 17:08:19 UTC, 3 replies.
- [jira] [Commented] (FLINK-1779) Rename the function name from "getCurrentyActiveConnections" to "getCurrentActiveConnections" in org.apache.flink.runtime.blob - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/24 17:08:53 UTC, 3 replies.
- [jira] [Updated] (FLINK-1779) Rename the function name from "getCurrentyActiveConnections" to "getCurrentActiveConnections" in org.apache.flink.runtime.blob - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/24 17:34:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1780) Rename FlatCombineFunction to GroupCombineFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/24 17:45:54 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1780) Rename FlatCombineFunction to GroupCombineFunction - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/03/24 20:15:53 UTC, 0 replies.
- [GitHub] flink pull request: Flink-1780: Rename FlatCombineFunction to Grou... - posted by smarthi <gi...@git.apache.org> on 2015/03/24 21:20:42 UTC, 17 replies.
- [GitHub] flink pull request: [FLINK-1776] Add offsets to field indexes of s... - posted by fhueske <gi...@git.apache.org> on 2015/03/24 23:56:23 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1770) Rename the variable 'contentAdressable' to 'contentAddressable' - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/25 00:00:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1781) Quickstarts broken due to Scala Version Variables - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/25 01:48:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1782) Change Quickstart Java version to 1.7 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/25 01:50:54 UTC, 0 replies.
- [jira] [Created] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/25 02:50:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/25 03:10:52 UTC, 3 replies.
- [GitHub] flink pull request: Flink dev cluster on Docker with Docker Compos... - posted by streamnsight <gi...@git.apache.org> on 2015/03/25 05:07:19 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1544) Extend streaming aggregation tests to include POJOs - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/03/25 10:25:52 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-1319) Add static code analysis for UDFs - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/03/25 13:02:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/25 13:36:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1782) Change Quickstart Java version to 1.7 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/25 14:35:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-1781) Quickstarts broken due to Scala Version Variables - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/25 14:36:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1781) Quickstarts broken due to Scala Version Variables - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/25 14:36:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1769] Fix deploy bug caused by ScalaDoc... - posted by aljoscha <gi...@git.apache.org> on 2015/03/25 14:52:26 UTC, 4 replies.
- [jira] [Updated] (FLINK-1766) Fix the bug of equals function of FSKey - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/25 15:25:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-1780) Rename FlatCombineFunction to GroupCombineFunction - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/25 17:26:54 UTC, 0 replies.
- [jira] [Created] (FLINK-1784) KafkaITCase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/25 17:46:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1784) KafkaITCase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/25 17:48:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1512) Add CsvReader for reading into POJOs. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/03/25 20:48:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-703) Use complete element as join key. - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/03/26 03:07:52 UTC, 1 replies.
- [jira] [Created] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/26 07:30:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/26 07:45:52 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1785] [test] Master tests in flink-tach... - posted by hsaputra <gi...@git.apache.org> on 2015/03/26 08:29:52 UTC, 4 replies.
- [jira] [Commented] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/26 08:29:55 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e... - posted by andralungu <gi...@git.apache.org> on 2015/03/26 09:20:45 UTC, 10 replies.
- [jira] [Created] (FLINK-1786) Add support for pipelined programs with slot count exceeding parallelism - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/26 10:33:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/26 10:49:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/26 10:49:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls. - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/03/26 10:57:52 UTC, 1 replies.
- [jira] [Closed] (FLINK-1787) Remove commons Validate calls with Guava checkArgument() calls. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/26 11:02:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/26 13:41:53 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1788) Extend Table API to allow logical plan optimisations - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/26 13:51:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1788) Extend Table API to allow logical plan optimisations - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/26 13:51:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/03/26 16:05:55 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/26 16:07:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/26 16:08:52 UTC, 2 replies.
- [jira] [Closed] (FLINK-1772) Chain of split/select does not work - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/26 16:56:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/26 16:57:52 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK]Remove the redunant import code - posted by matadorhong <gi...@git.apache.org> on 2015/03/26 17:00:24 UTC, 0 replies.
- [jira] [Created] (FLINK-1790) Remove the redunant import code - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/26 17:00:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1790) Remove the redundant import code - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/26 17:02:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1790) d - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/26 17:02:53 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/26 17:08:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1791) Change nightly Javadoc build to use correct profile - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/26 17:09:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-1791) Change nightly Javadoc build to use correct profile - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/26 17:09:53 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/26 17:48:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-1791) Change nightly Javadoc build to use correct profile - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/26 17:53:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1718] Adds sparse matrix and sparse vec... - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/26 17:59:07 UTC, 9 replies.
- [jira] [Commented] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/26 17:59:53 UTC, 9 replies.
- [jira] [Resolved] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/26 19:12:52 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1790]Remove the redundant import code - posted by hsaputra <gi...@git.apache.org> on 2015/03/26 22:03:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-1790) Remove the redundant import code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/26 22:03:53 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1726) Add Community Detection Library and Example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/26 23:41:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1758) Extend Gelly's neighborhood methods - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/03/27 00:17:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 11:40:54 UTC, 0 replies.
- [jira] [Created] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 11:44:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1793) Streaming jobs can't be canceled - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/03/27 11:56:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 13:14:53 UTC, 0 replies.
- [GitHub] flink pull request: - posted by mbalassi <gi...@git.apache.org> on 2015/03/27 13:33:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-1793) Streaming jobs can't be canceled - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 14:39:52 UTC, 2 replies.
- [jira] [Updated] (FLINK-1781) Quickstarts broken due to Scala Version Variables - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 14:48:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1771) Add support for submitting single jobs detached YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 15:18:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-1771) Add support for submitting single jobs to a detached YARN session - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/27 15:20:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1589] Add option to pass configuration ... - posted by rmetzger <gi...@git.apache.org> on 2015/03/27 16:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/27 16:41:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1782) Change Quickstart Java version to 1.7 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 19:02:54 UTC, 0 replies.
- [jira] [Created] (FLINK-1794) Add test base for scalatest and adapt flink-ml test cases - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/27 19:22:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1790) Remove the redundant import code - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/27 19:38:55 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1794] [test-utils] Adds test base for s... - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/27 19:49:10 UTC, 5 replies.
- [jira] [Commented] (FLINK-1794) Add test base for scalatest and adapt flink-ml test cases - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/27 19:49:52 UTC, 5 replies.
- [jira] [Created] (FLINK-1795) Solution set allows duplicates upon construction. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 20:13:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1783) Quickstart shading should not created shaded jar and dependency reduced pom - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 20:16:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1781) Quickstarts broken due to Scala Version Variables - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 20:17:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1796) Local mode TaskManager should have a process reaper - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 20:25:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-1795) Solution set allows duplicates upon construction. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 20:25:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-1796) Local mode TaskManager should have a process reaper - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/27 20:26:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1664] Adds checks if selected sort key ... - posted by fhueske <gi...@git.apache.org> on 2015/03/28 00:41:57 UTC, 0 replies.
- [jira] [Created] (FLINK-1797) Add jumping pre-reducer for Count and Time windows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/28 16:48:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-1797) Add jumping pre-reducer for Count and Time windows - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/28 16:54:53 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1771] Add support for submitting single... - posted by rmetzger <gi...@git.apache.org> on 2015/03/28 17:57:46 UTC, 19 replies.
- [jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/28 17:57:53 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-1717] Adds support for libSVM/SVMLight ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/28 18:53:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-1717) Add support to read libSVM and SVMLight input files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/28 18:53:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1797) Add jumping pre-reducer for Count and Time windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/03/29 04:38:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check - posted by "Mathusuthan Kannan (JIRA)" <ji...@apache.org> on 2015/03/29 13:47:53 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1623) Rename Expression API and Operation Representation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/03/29 13:53:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1796) Local mode TaskManager should have a process reaper - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/29 18:37:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1795) Solution set allows duplicates upon construction. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/29 18:38:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1694) Change the split between create/run of a vertex-centric iteration - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/29 21:30:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1669) Streaming tests for recovery with distributed process failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/29 21:47:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/30 10:07:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/30 10:08:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/30 11:13:53 UTC, 3 replies.
- [jira] [Closed] (FLINK-1686) Streaming iteration heads cannot be instantiated - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/03/30 11:26:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2015/03/30 11:38:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-1699) Co-task sometimes returns null - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/30 11:47:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1633) Add getTriplets() Gelly method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/30 11:55:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1799) Scala API does not support generic arrays - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/30 12:53:54 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1348) Move Stream Connector Jars from "lib" to Client JARs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 13:08:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1800) Add a "Beta" badge in the documentation to components in flink-staging - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/30 13:12:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/30 14:06:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1779) Rename the function name from "getCurrentyActiveConnections" to "getCurrentActiveConnections" in org.apache.flink.runtime.blob - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 14:16:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1774) Remove the redundant code in try{} block - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 14:16:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1754) Deadlock in job execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 14:25:54 UTC, 0 replies.
- [jira] [Created] (FLINK-1801) NetworkEnvironment should start without JobManager association - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 14:31:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1802) BlobManager directories should be checked before TaskManager startup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 14:33:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1803) Add type hints to the streaming api - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/03/30 14:39:56 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1741][gelly] Adds Jaccard Similarity Me... - posted by andralungu <gi...@git.apache.org> on 2015/03/30 15:02:33 UTC, 11 replies.
- [jira] [Created] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/30 15:36:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/03/30 16:52:56 UTC, 0 replies.
- [GitHub] flink pull request: The class IOManagerAsync should use its own Lo... - posted by matadorhong <gi...@git.apache.org> on 2015/03/30 17:02:35 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1716] Adds CoCoA algorithm - posted by tillrohrmann <gi...@git.apache.org> on 2015/03/30 17:02:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-1716) Add CoCoA algorithm to flink-ml - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/30 17:02:53 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1694] [gelly] added IterationConfigurat... - posted by vasia <gi...@git.apache.org> on 2015/03/30 17:23:24 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1522) Add tests for the library methods and examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/03/30 17:37:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1435) TaskManager does not log missing memory error on start up - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 18:38:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1435) TaskManager does not log missing memory error on start up - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 18:38:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1465) GlobalBufferPool reports negative memory allocation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 18:52:52 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1805]The class IOManagerAsync should us... - posted by hsaputra <gi...@git.apache.org> on 2015/03/30 19:10:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/30 19:10:53 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1801) NetworkEnvironment should start without JobManager association - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 20:08:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1465) GlobalBufferPool reports negative memory allocation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/03/30 20:08:53 UTC, 0 replies.
- [GitHub] flink pull request: Add --abbrev-ref to get the right branch name ... - posted by hsaputra <gi...@git.apache.org> on 2015/03/31 02:07:31 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1797] Add jumping pre-reducer for Count... - posted by ggevay <gi...@git.apache.org> on 2015/03/31 05:45:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1771) Add support for submitting single jobs to a detached YARN session - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/31 10:50:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1806) Improve S3 file system error message when no access/secret key provided - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/31 11:26:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1806) Improve S3 file system error message when no access/secret key provided - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/03/31 11:37:52 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1788] [table] Make logical plans transf... - posted by aljoscha <gi...@git.apache.org> on 2015/03/31 11:48:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1788) Extend Table API to allow logical plan optimisations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/31 11:48:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1807) Stochastic gradient descent optimizer for ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/31 13:39:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/03/31 13:48:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/03/31 13:56:52 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1808] Send barrier requests only when t... - posted by senorcarbone <gi...@git.apache.org> on 2015/03/31 14:20:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/03/31 14:21:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only - posted by "Sachin Bhat (JIRA)" <ji...@apache.org> on 2015/03/31 14:23:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1794) Add test base for scalatest and adapt flink-ml test cases - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/31 15:38:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/03/31 16:40:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1809) Add standard scaler to ML library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/03/31 17:44:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/31 19:38:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1766) Fix the bug of equals function of FSKey - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/03/31 19:57:52 UTC, 0 replies.