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

---

- [GitHub] flink pull request: [FLINK-3994] [ml, tests] Fix flaky KNN integration tests - posted by chiwanpark <gi...@git.apache.org> on 2016/06/01 01:23:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-3994) Instable KNNITSuite - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 01:23:13 UTC, 2 replies.
- [jira] [Closed] (FLINK-3994) Instable KNNITSuite - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/06/01 01:28:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1979] Add logistic loss, hinge loss and regulariz... - posted by chiwanpark <gi...@git.apache.org> on 2016/06/01 01:44:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-1979) Implement Loss Functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 01:44:12 UTC, 11 replies.
- [jira] [Created] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Aride Chettali (JIRA)" <ji...@apache.org> on 2016/06/01 05:12:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3763] RabbitMQ Source/Sink standardize connection... - posted by subhankarb <gi...@git.apache.org> on 2016/06/01 05:27:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 05:28:13 UTC, 12 replies.
- [GitHub] flink pull request: Not able to create flink-streaming-connectors jar - posted by mrakshay <gi...@git.apache.org> on 2016/06/01 06:35:29 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3919][flink-ml] Distributed Linear Algebra: row-b... - posted by chiwanpark <gi...@git.apache.org> on 2016/06/01 06:43:52 UTC, 11 replies.
- [jira] [Commented] (FLINK-3919) Distributed Linear Algebra: row-based matrix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 06:44:13 UTC, 16 replies.
- [GitHub] flink pull request: [FLINK-3993] [py] Add generateSequence() support to Pyth... - posted by omaralvarez <gi...@git.apache.org> on 2016/06/01 08:21:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-3993) [py] Add generateSequence() support to Python API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 08:21:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-1873) Distributed matrix implementation - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/06/01 09:03:59 UTC, 5 replies.
- [GitHub] flink pull request: - posted by zentol <gi...@git.apache.org> on 2016/06/01 09:19:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 09:26:59 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3758] Add possibility to register accumulators in... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/01 09:29:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/01 09:29:59 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine strategy f... - posted by ggevay <gi...@git.apache.org> on 2016/06/01 09:44:18 UTC, 6 replies.
- [jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 09:44:59 UTC, 18 replies.
- [jira] [Updated] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 10:06:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-3854) Support Avro key-value rolling sink writer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 10:06:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-2672) Add partitioned output format to HDFS RollingSink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 10:07:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4001) Add event time support to filesystem connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 10:09:59 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3806] [gelly] Revert use of DataSet.count() - posted by vasia <gi...@git.apache.org> on 2016/06/01 11:37:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 11:37:59 UTC, 4 replies.
- [jira] [Created] (FLINK-4002) [py] Improve testing infraestructure - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/06/01 11:58:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4002) [py] Improve testing infraestructure - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/06/01 11:59:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Christophe S (JIRA)" <ji...@apache.org> on 2016/06/01 12:01:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persistent - posted by aljoscha <gi...@git.apache.org> on 2016/06/01 12:03:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 12:03:59 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3667] refactor client communication - posted by mxm <gi...@git.apache.org> on 2016/06/01 12:19:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-3667) Generalize client<->cluster communication - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 12:19:59 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3908] Fixed Parser's error state reset - posted by fpompermaier <gi...@git.apache.org> on 2016/06/01 12:34:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 12:34:59 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3945] [gelly] Degree annotation for directed grap... - posted by greghogan <gi...@git.apache.org> on 2016/06/01 12:50:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-3945) Degree annotation for directed graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 12:50:59 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Aride Chettali (JIRA)" <ji...@apache.org> on 2016/06/01 12:57:59 UTC, 1 replies.
- [jira] [Closed] (FLINK-3993) [py] Add generateSequence() support to Python API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/01 14:12:59 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Fix JSONDeserializationSchema for Kafka; Parame... - posted by zentol <gi...@git.apache.org> on 2016/06/01 14:17:15 UTC, 0 replies.
- [GitHub] flink pull request #1517: [FLINK-3477] [runtime] Add hash-based combine stra... - posted by ggevay <gi...@git.apache.org> on 2016/06/01 14:51:34 UTC, 8 replies.
- [GitHub] flink issue #2007: [FLINK-3908] Fixed Parser's error state reset - posted by fpompermaier <gi...@git.apache.org> on 2016/06/01 15:33:56 UTC, 5 replies.
- [GitHub] flink issue #1517: [FLINK-3477] [runtime] Add hash-based combine strategy fo... - posted by ggevay <gi...@git.apache.org> on 2016/06/01 15:55:01 UTC, 3 replies.
- [jira] [Created] (FLINK-4003) Use intrinsics for MathUtils logarithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/01 16:28:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/06/01 17:12:59 UTC, 1 replies.
- [GitHub] flink issue #2049: [FLINK-3971] [tableAPI] Aggregates handle null values inc... - posted by fhueske <gi...@git.apache.org> on 2016/06/01 17:34:17 UTC, 9 replies.
- [jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 17:34:59 UTC, 17 replies.
- [jira] [Created] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 18:11:59 UTC, 0 replies.
- [GitHub] flink pull request #2059: [FLINK-4003] Use intrinsics for MathUtils logarith... - posted by greghogan <gi...@git.apache.org> on 2016/06/01 18:32:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4003) Use intrinsics for MathUtils logarithms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 18:32:59 UTC, 2 replies.
- [GitHub] flink issue #2058: Not able to create flink-streaming-connectors jar - posted by StephanEwen <gi...@git.apache.org> on 2016/06/01 19:08:19 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3921) StringParser not specifying encoding to use - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/01 20:21:59 UTC, 0 replies.
- [GitHub] flink pull request #2060: [FLINK-3921] StringParser encoding - posted by rekhajoshm <gi...@git.apache.org> on 2016/06/01 20:23:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/01 20:23:59 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/01 20:51:59 UTC, 0 replies.
- [GitHub] flink pull request #2061: [FLINK-4000] Checkpoint dictionaries null after ta... - posted by rekhajoshm <gi...@git.apache.org> on 2016/06/01 20:54:18 UTC, 1 replies.
- [GitHub] flink issue #2061: [FLINK-4000] Checkpoint dictionaries null after taskmgr f... - posted by asavartsov <gi...@git.apache.org> on 2016/06/01 21:29:16 UTC, 5 replies.
- [jira] [Created] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/01 22:28:59 UTC, 0 replies.
- [GitHub] flink issue #1985: [FLINK-1979] Add logistic loss, hinge loss and regulariza... - posted by skavulya <gi...@git.apache.org> on 2016/06/01 22:58:18 UTC, 5 replies.
- [GitHub] flink pull request #2062: [FLINK-4000] Fix for checkpoint state restore at M... - posted by asavartsov <gi...@git.apache.org> on 2016/06/01 23:31:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/06/02 00:06:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/02 03:54:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/02 03:56:59 UTC, 1 replies.
- [jira] [Created] (FLINK-4007) Flink Kafka Consumer throws Null Pointer Exception when using DataStream keyBy - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/02 06:33:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/02 06:34:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/02 07:40:59 UTC, 4 replies.
- [GitHub] flink pull request #2063: [FLINK-4002] [py] Improve testing infraestructure - posted by omaralvarez <gi...@git.apache.org> on 2016/06/02 09:18:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/02 09:18:59 UTC, 18 replies.
- [GitHub] flink issue #2063: [FLINK-4002] [py] Improve testing infraestructure - posted by zentol <gi...@git.apache.org> on 2016/06/02 09:50:52 UTC, 16 replies.
- [jira] [Comment Edited] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/02 10:03:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4009) Scala Shell fails to find library for inclusion in test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 12:20:59 UTC, 0 replies.
- [GitHub] flink pull request #2064: [FLINK-3980] [core] Remove ExecutionConfig.PARALLE... - posted by greghogan <gi...@git.apache.org> on 2016/06/02 12:22:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/02 12:22:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-4009) Scala Shell fails to find library for inclusion in test - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/02 12:38:59 UTC, 8 replies.
- [jira] [Closed] (FLINK-4009) Scala Shell fails to find library for inclusion in test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 12:57:59 UTC, 1 replies.
- [jira] [Created] (FLINK-4010) Scala Shell tests may fail because of a locked STDIN - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 13:02:59 UTC, 0 replies.
- [GitHub] flink issue #2036: [FLINK-3806] [gelly] Revert use of DataSet.count() - posted by greghogan <gi...@git.apache.org> on 2016/06/02 13:10:33 UTC, 0 replies.
- [jira] [Created] (FLINK-4011) Unable to access completed job in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/02 13:28:59 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4009) Scala Shell fails to find library for inclusion in test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 13:30:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4009) Scala Shell fails to find library for inclusion in test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 13:34:59 UTC, 3 replies.
- [GitHub] flink pull request #2065: [FLINK-4011] Keep UserCodeClassLoader in archived ... - posted by rmetzger <gi...@git.apache.org> on 2016/06/02 14:17:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4011) Unable to access completed job in web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/02 14:17:59 UTC, 4 replies.
- [jira] [Created] (FLINK-4012) Docs: Links to "Iterations" are broken (404) - posted by "Bernd Louis (JIRA)" <ji...@apache.org> on 2016/06/02 14:26:59 UTC, 0 replies.
- [GitHub] flink pull request #2036: [FLINK-3806] [gelly] Revert use of DataSet.count() - posted by asfgit <gi...@git.apache.org> on 2016/06/02 14:28:36 UTC, 0 replies.
- [GitHub] flink pull request #2021: [FLINK-3945] [gelly] Degree annotation for directe... - posted by asfgit <gi...@git.apache.org> on 2016/06/02 14:28:36 UTC, 0 replies.
- [jira] [Closed] (FLINK-3945) Degree annotation for directed graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/02 14:34:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/02 14:34:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4010) Scala Shell tests may fail because of a locked STDIN - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 14:50:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4007) Flink Kafka Consumer throws Null Pointer Exception when using DataStream keyBy - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/02 15:50:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/02 15:52:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/02 19:37:59 UTC, 0 replies.
- [GitHub] flink pull request #1996: [FLINK-3919][flink-ml] Distributed Linear Algebra:... - posted by chiwanpark <gi...@git.apache.org> on 2016/06/03 05:07:13 UTC, 5 replies.
- [GitHub] flink issue #2034: [FLINK-3937] Implemented -yid option to Flink cli list, s... - posted by mxm <gi...@git.apache.org> on 2016/06/03 09:17:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 09:17:59 UTC, 45 replies.
- [jira] [Updated] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and LocalBuffer - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/03 10:18:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and LocalBufferPool has some problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/03 10:18:59 UTC, 3 replies.
- [jira] [Created] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and Local、 - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/03 10:18:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and LocalBufferPool has some problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/03 10:21:59 UTC, 0 replies.
- [GitHub] flink pull request #2066: Updated ssh configuration in base Dockerfile - posted by techmaniack <gi...@git.apache.org> on 2016/06/03 10:22:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/03 10:23:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/06/03 11:10:59 UTC, 113 replies.
- [GitHub] flink issue #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API - posted by zentol <gi...@git.apache.org> on 2016/06/03 11:19:22 UTC, 18 replies.
- [jira] [Created] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/06/03 11:57:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/03 12:08:59 UTC, 5 replies.
- [jira] [Updated] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set. - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/06/03 12:37:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/03 13:05:59 UTC, 3 replies.
- [GitHub] flink issue #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector - posted by rmetzger <gi...@git.apache.org> on 2016/06/03 13:10:35 UTC, 6 replies.
- [jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 13:10:59 UTC, 7 replies.
- [GitHub] flink issue #2054: [FLINK-3763] RabbitMQ Source/Sink standardize connection ... - posted by subhankarb <gi...@git.apache.org> on 2016/06/03 13:22:39 UTC, 1 replies.
- [GitHub] flink pull request #2067: [FLINK-4013] [gelly] GraphAlgorithms to simplify d... - posted by greghogan <gi...@git.apache.org> on 2016/06/03 13:54:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 13:54:59 UTC, 1 replies.
- [GitHub] flink pull request #2068: [hotfix] [core] Fix scope format keys - posted by zentol <gi...@git.apache.org> on 2016/06/03 14:08:52 UTC, 1 replies.
- [GitHub] flink issue #2060: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/06/03 14:18:13 UTC, 3 replies.
- [GitHub] flink issue #2002: Support for bz2 compression in flink-core - posted by greghogan <gi...@git.apache.org> on 2016/06/03 14:44:13 UTC, 0 replies.
- [jira] [Created] (FLINK-4016) FoldApplyWindowFunction is not properly initialized - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/06/03 14:50:59 UTC, 0 replies.
- [GitHub] flink pull request #2069: [FLINK-3872] [table, connector-kafka] Add KafkaJso... - posted by uce <gi...@git.apache.org> on 2016/06/03 14:55:20 UTC, 12 replies.
- [jira] [Commented] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 14:55:59 UTC, 18 replies.
- [jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/03 15:32:59 UTC, 0 replies.
- [GitHub] flink pull request #2070: [FLINK-4016] initialize FoldApplyWindowFunction pr... - posted by rvdwenden <gi...@git.apache.org> on 2016/06/03 16:06:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4016) FoldApplyWindowFunction is not properly initialized - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/03 16:06:59 UTC, 7 replies.
- [jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/06/03 19:17:59 UTC, 0 replies.
- [GitHub] flink issue #2069: [FLINK-3872] [table, connector-kafka] Add KafkaJsonTableS... - posted by rmetzger <gi...@git.apache.org> on 2016/06/03 19:34:00 UTC, 5 replies.
- [jira] [Created] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 02:59:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 03:15:59 UTC, 5 replies.
- [GitHub] flink pull request #2071: [FLINK-4018](streaming-connectors) Configurable id... - posted by tzulitai <gi...@git.apache.org> on 2016/06/04 04:49:49 UTC, 0 replies.
- [jira] [Created] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 09:14:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 09:40:59 UTC, 0 replies.
- [GitHub] flink pull request #2072: [FLINK-3948] Protect RocksDB cleanup by cleanup lo... - posted by aljoscha <gi...@git.apache.org> on 2016/06/04 12:03:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/04 12:03:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 12:28:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 12:37:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 13:04:59 UTC, 63 replies.
- [jira] [Comment Edited] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 13:04:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/06/04 16:45:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/05 07:38:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/05 07:46:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/05 08:52:59 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/05 14:33:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Michal Harish (JIRA)" <ji...@apache.org> on 2016/06/05 15:22:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Michal Harish (JIRA)" <ji...@apache.org> on 2016/06/05 15:24:59 UTC, 2 replies.
- [jira] [Created] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/05 17:36:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/05 17:40:59 UTC, 0 replies.
- [GitHub] flink issue #2072: [FLINK-3948] Protect RocksDB cleanup by cleanup lock - posted by StephanEwen <gi...@git.apache.org> on 2016/06/05 21:14:15 UTC, 0 replies.
- [GitHub] flink issue #2065: [FLINK-4011] Keep UserCodeClassLoader in archived Executi... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/05 21:20:50 UTC, 2 replies.
- [jira] [Created] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/06/05 21:28:59 UTC, 0 replies.
- [GitHub] flink pull request #2073: [FLINK-4025] Add possiblity for the RMQ Streaming ... - posted by theomega <gi...@git.apache.org> on 2016/06/05 21:29:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/05 21:29:59 UTC, 5 replies.
- [jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/05 21:40:59 UTC, 6 replies.
- [GitHub] flink issue #2064: [FLINK-3980] [core] Remove ExecutionConfig.PARALLELISM_UN... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/05 21:44:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/05 22:08:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/06/06 06:49:01 UTC, 3 replies.
- [jira] [Closed] (FLINK-4016) FoldApplyWindowFunction is not properly initialized - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/06 07:44:56 UTC, 0 replies.
- [GitHub] flink issue #2070: [FLINK-4016] initialize FoldApplyWindowFunction properly - posted by aljoscha <gi...@git.apache.org> on 2016/06/06 07:46:10 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/06/06 08:43:10 UTC, 1 replies.
- [GitHub] flink pull request #2074: [FLINK-2985] [Table API] Allow different field nam... - posted by gallenvara <gi...@git.apache.org> on 2016/06/06 09:04:45 UTC, 1 replies.
- [GitHub] flink issue #2074: [FLINK-2985] [Table API] Allow different field names for ... - posted by gallenvara <gi...@git.apache.org> on 2016/06/06 09:08:57 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/06 11:52:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/06 13:47:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3960) Disable, fix and re-enable EventTimeWindowCheckpointingITCase - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/06 13:48:21 UTC, 0 replies.
- [GitHub] flink pull request #2020: [FLINK-2314] Make Streaming File Sources Persisten... - posted by kl0u <gi...@git.apache.org> on 2016/06/06 14:12:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/06 14:20:21 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/06 14:21:21 UTC, 0 replies.
- [GitHub] flink pull request #2076: [FLINK-2832] [tests] Hardens RandomSamplerTest - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/06 14:22:16 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/06 14:33:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/06 14:33:21 UTC, 6 replies.
- [jira] [Created] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/06/06 15:18:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/06/06 15:19:21 UTC, 4 replies.
- [GitHub] flink pull request #2077: [FLINK-4026] Fix code, grammar, and link issues in... - posted by dyanarose <gi...@git.apache.org> on 2016/06/06 15:27:29 UTC, 1 replies.
- [jira] [Updated] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/06/06 15:39:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/06 19:39:21 UTC, 31 replies.
- [jira] [Updated] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/06 19:42:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/06 19:42:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/06 19:43:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/06 19:43:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/06 19:43:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/06/06 21:08:20 UTC, 0 replies.
- [GitHub] flink issue #2031: FLINK-3967 - Flink Sink for Rethink Db - posted by mans2singh <gi...@git.apache.org> on 2016/06/06 23:16:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-3967) Provide RethinkDB Sink for Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/06 23:17:20 UTC, 1 replies.
- [GitHub] flink issue #2076: [FLINK-2832] [tests] Hardens RandomSamplerTest - posted by chiwanpark <gi...@git.apache.org> on 2016/06/07 02:05:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 02:05:21 UTC, 6 replies.
- [GitHub] flink pull request #2078: [FLINK-2985] Allow different field names for union... - posted by gallenvara <gi...@git.apache.org> on 2016/06/07 02:07:22 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/06/07 02:13:20 UTC, 0 replies.
- [GitHub] flink issue #2078: [FLINK-2985] Allow different field names for unionAll() i... - posted by gallenvara <gi...@git.apache.org> on 2016/06/07 02:14:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/07 05:07:20 UTC, 2 replies.
- [GitHub] flink issue #2077: [FLINK-4026] Fix code, grammar, and link issues in the St... - posted by aljoscha <gi...@git.apache.org> on 2016/06/07 08:44:52 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/07 08:46:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/07 08:53:21 UTC, 7 replies.
- [GitHub] flink pull request #2039: [FLINK-3978] [core] Add hasBroadcastVariable metho... - posted by greghogan <gi...@git.apache.org> on 2016/06/07 12:40:34 UTC, 0 replies.
- [GitHub] flink issue #2039: [FLINK-3978] [core] Add hasBroadcastVariable method to Ru... - posted by greghogan <gi...@git.apache.org> on 2016/06/07 12:40:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 12:41:21 UTC, 1 replies.
- [GitHub] flink issue #2032: [FLINK-3965] [gelly] Delegating GraphAlgorithm - posted by greghogan <gi...@git.apache.org> on 2016/06/07 13:36:28 UTC, 4 replies.
- [jira] [Commented] (FLINK-3965) Delegating GraphAlgorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 13:37:21 UTC, 6 replies.
- [jira] [Updated] (FLINK-1736) Add CountVectorizer to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/07 13:56:21 UTC, 0 replies.
- [GitHub] flink issue #1983: [FLINK-3868] [core] Specialized CopyableValue serializers... - posted by greghogan <gi...@git.apache.org> on 2016/06/07 14:39:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-3868) Specialized CopyableValue serializers and comparators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 14:40:21 UTC, 3 replies.
- [GitHub] flink pull request #2005: [FLINK-3925] GraphAlgorithm to filter by maximum d... - posted by asfgit <gi...@git.apache.org> on 2016/06/07 14:59:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-3925) GraphAlgorithm to filter by maximum degree - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 14:59:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/07 15:00:24 UTC, 0 replies.
- [jira] [Closed] (FLINK-3925) GraphAlgorithm to filter by maximum degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/07 15:00:24 UTC, 0 replies.
- [jira] [Closed] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/07 15:01:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/07 15:02:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/07 15:02:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/07 15:28:20 UTC, 11 replies.
- [jira] [Created] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/07 15:45:21 UTC, 0 replies.
- [GitHub] flink issue #2062: [FLINK-4000] Fix for checkpoint state restore at MessageA... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 16:16:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/07 16:17:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-3907) Directed Clustering Coefficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 16:22:21 UTC, 1 replies.
- [GitHub] flink pull request #2079: [FLINK-3907] [gelly] Directed Clustering Coefficie... - posted by greghogan <gi...@git.apache.org> on 2016/06/07 16:22:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-3907) Directed Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/07 16:23:20 UTC, 0 replies.
- [GitHub] flink pull request #2080: [FLINK-3530] Fix Kafka08 instability: Avoid restar... - posted by rmetzger <gi...@git.apache.org> on 2016/06/07 16:23:54 UTC, 1 replies.
- [GitHub] flink issue #2059: [FLINK-4003] Use intrinsics for MathUtils logarithms - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 17:12:04 UTC, 0 replies.
- [GitHub] flink issue #2047: FLINK-3405: Extend NiFiSource with interface StoppableFun... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 17:14:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 17:15:22 UTC, 1 replies.
- [GitHub] flink issue #2011: [FLINK-3922] [types] Infinite recursion on TypeExtractor - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 17:27:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 17:28:20 UTC, 1 replies.
- [GitHub] flink issue #1999: [FLINK-3805] BloomFilter initialized with no memory avail... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 17:35:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-3805) BloomFilter initialized with no memory available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 17:36:21 UTC, 0 replies.
- [GitHub] flink issue #1973: [FLINK-3869] Relax window fold generic parameters - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 17:39:53 UTC, 3 replies.
- [jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 17:40:20 UTC, 4 replies.
- [GitHub] flink issue #2073: [FLINK-4025] Add possiblity for the RMQ Streaming Source ... - posted by rmetzger <gi...@git.apache.org> on 2016/06/07 17:40:55 UTC, 0 replies.
- [GitHub] flink pull request #1997: [FLINK-3906] [gelly] Global Clustering Coefficient - posted by asfgit <gi...@git.apache.org> on 2016/06/07 17:48:57 UTC, 0 replies.
- [GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 17:49:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-3906) Global Clustering Coefficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 17:49:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/07 17:49:21 UTC, 15 replies.
- [jira] [Closed] (FLINK-3906) Global Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/07 17:51:21 UTC, 0 replies.
- [GitHub] flink issue #2080: [FLINK-3530] Fix Kafka08 instability: Avoid restarts from... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/07 18:25:51 UTC, 1 replies.
- [jira] [Closed] (FLINK-4003) Use intrinsics for MathUtils logarithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/07 18:40:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/08 06:59:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/08 07:00:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-3867) Provide virtualized Flink architecture for testing purposes - posted by "Julius Neuffer (JIRA)" <ji...@apache.org> on 2016/06/08 09:20:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/08 09:36:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4011) Unable to access completed job in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/08 09:38:21 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by uce <gi...@git.apache.org> on 2016/06/08 10:05:45 UTC, 2 replies.
- [jira] [Created] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Rami (JIRA)" <ji...@apache.org> on 2016/06/08 11:11:20 UTC, 0 replies.
- [GitHub] flink pull request #2081: [FLINK-4020][streaming-connectors] Move shard list... - posted by tzulitai <gi...@git.apache.org> on 2016/06/08 11:14:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/08 11:15:21 UTC, 5 replies.
- [jira] [Created] (FLINK-4030) ScalaShellITCase - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/08 13:05:21 UTC, 0 replies.
- [GitHub] flink pull request #1973: [FLINK-3869] Relax window fold generic parameters - posted by aljoscha <gi...@git.apache.org> on 2016/06/08 13:12:03 UTC, 0 replies.
- [GitHub] flink pull request #2011: [FLINK-3922] [types] Infinite recursion on TypeExt... - posted by asfgit <gi...@git.apache.org> on 2016/06/08 13:18:33 UTC, 0 replies.
- [GitHub] flink pull request #2047: FLINK-3405: Extend NiFiSource with interface Stopp... - posted by asfgit <gi...@git.apache.org> on 2016/06/08 13:18:33 UTC, 0 replies.
- [jira] [Closed] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:21:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:21:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:23:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:23:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:25:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:25:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:26:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/08 13:26:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4031) Nightly Jenkins job doesn't deploy sources - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/08 13:27:20 UTC, 0 replies.
- [GitHub] flink pull request #2082: [FLINK-4031] include sources in Maven snapshot dep... - posted by mxm <gi...@git.apache.org> on 2016/06/08 13:32:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-4031) Nightly Jenkins job doesn't deploy sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/08 13:33:21 UTC, 2 replies.
- [GitHub] flink pull request #2083: [FLINK-3713] [clients, runtime] Use user code clas... - posted by uce <gi...@git.apache.org> on 2016/06/08 14:45:12 UTC, 10 replies.
- [jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/08 14:45:21 UTC, 14 replies.
- [GitHub] flink issue #2082: [FLINK-4031] include sources in Maven snapshot deployment - posted by rmetzger <gi...@git.apache.org> on 2016/06/08 14:47:06 UTC, 0 replies.
- [jira] [Created] (FLINK-4032) Replace all usage of Guava Preconditions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/08 15:10:22 UTC, 0 replies.
- [GitHub] flink pull request #2084: [FLINK-4032] Replace all usages Guava precondition... - posted by zentol <gi...@git.apache.org> on 2016/06/08 15:12:20 UTC, 8 replies.
- [jira] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/08 15:12:20 UTC, 17 replies.
- [jira] [Closed] (FLINK-4031) Nightly Jenkins job doesn't deploy sources - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/08 16:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/08 16:48:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/08 17:52:21 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3553) Don't include watermarks in record count - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/08 18:01:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/08 18:03:20 UTC, 0 replies.
- [GitHub] flink pull request #2085: [FLINK-3937] programmatic resuming of clusters - posted by mxm <gi...@git.apache.org> on 2016/06/08 18:20:12 UTC, 33 replies.
- [jira] [Created] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo - posted by "Vladislav Pernin (JIRA)" <ji...@apache.org> on 2016/06/08 18:47:21 UTC, 0 replies.
- [GitHub] flink pull request #2086: [FLINK-3977] initialize FoldApplyWindowFunction pr... - posted by rvdwenden <gi...@git.apache.org> on 2016/06/08 19:00:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/08 19:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/06/08 21:02:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3725) Exception in thread "main" scala.MatchError: ... (of class scala.Tuple4) - posted by "Ankit Chaudhary (JIRA)" <ji...@apache.org> on 2016/06/09 00:15:21 UTC, 0 replies.
- [GitHub] flink pull request #1962: [FLINK-3857][Streaming Connectors]Add reconnect at... - posted by tzulitai <gi...@git.apache.org> on 2016/06/09 05:45:20 UTC, 9 replies.
- [GitHub] flink issue #2084: [FLINK-4032] Replace all usages Guava preconditions - posted by tzulitai <gi...@git.apache.org> on 2016/06/09 07:48:10 UTC, 8 replies.
- [jira] [Created] (FLINK-4036) Potential deadlock in StreamIterationSink - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/09 08:41:21 UTC, 0 replies.
- [GitHub] flink issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer - posted by rmetzger <gi...@git.apache.org> on 2016/06/09 08:49:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/09 08:49:20 UTC, 5 replies.
- [GitHub] flink issue #2057: [hotfix] Fix JSONDeserializationSchema for Kafka; Paramet... - posted by rmetzger <gi...@git.apache.org> on 2016/06/09 08:57:39 UTC, 0 replies.
- [GitHub] flink pull request #2057: [hotfix] Fix JSONDeserializationSchema for Kafka; ... - posted by asfgit <gi...@git.apache.org> on 2016/06/09 08:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 09:09:20 UTC, 0 replies.
- [GitHub] flink issue #2081: [FLINK-4020][streaming-connectors] Move shard list queryi... - posted by rmetzger <gi...@git.apache.org> on 2016/06/09 09:14:02 UTC, 3 replies.
- [jira] [Created] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:41:20 UTC, 0 replies.
- [GitHub] flink pull request #2087: [hotfix] [streaming-java] Harden IterateTest - posted by uce <gi...@git.apache.org> on 2016/06/09 09:42:37 UTC, 1 replies.
- [jira] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:45:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:49:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:49:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 10:46:21 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 10:52:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4042) TwitterStream example does not work - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/09 11:23:20 UTC, 0 replies.
- [GitHub] flink pull request #1953: [FLINK-3854] Support Avro key-value rolling sink w... - posted by asfgit <gi...@git.apache.org> on 2016/06/09 11:35:44 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3854) Support Avro key-value rolling sink writer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 11:36:21 UTC, 0 replies.
- [GitHub] flink issue #2087: [hotfix] [streaming-java] Harden IterateTest - posted by uce <gi...@git.apache.org> on 2016/06/09 11:54:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-4030) ScalaShellITCase gets stuck - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/09 12:09:20 UTC, 0 replies.
- [GitHub] flink issue #2086: [FLINK-3977] initialize FoldApplyWindowFunction properly - posted by aljoscha <gi...@git.apache.org> on 2016/06/09 12:22:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/09 12:23:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4044) Rename RabbitMQ connector to AMQP connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:41:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:43:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4045) Test AMQP connector using Apache ActiveMQ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:43:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:57:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 13:01:20 UTC, 3 replies.
- [GitHub] flink pull request #2054: [FLINK-3763] RabbitMQ Source/Sink standardize conn... - posted by asfgit <gi...@git.apache.org> on 2016/06/09 13:17:41 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 13:18:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 13:19:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/09 13:39:20 UTC, 29 replies.
- [jira] [Assigned] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/09 13:48:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/09 13:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4047) Fix documentation about determinism of KeySelectors - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/09 14:07:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 14:07:21 UTC, 3 replies.
- [GitHub] flink pull request #2088: [FLINK-3859] [table] Add BigDecimal/BigInteger sup... - posted by twalthr <gi...@git.apache.org> on 2016/06/09 14:15:50 UTC, 7 replies.
- [jira] [Commented] (FLINK-3859) Add BigDecimal/BigInteger support to Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/09 14:16:21 UTC, 20 replies.
- [jira] [Created] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 14:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 14:43:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4050) FlinkKafkaProducer API Refactor - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/06/09 15:37:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4051) RabbitMQ Source might not react to cancel signal - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 16:07:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4051) RabbitMQ Source might not react to cancel signal - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/06/09 16:25:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/09 18:39:21 UTC, 7 replies.
- [jira] [Created] (FLINK-4052) Unstable test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/09 19:33:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4053) Return value from Connection should be checked against null - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/09 19:41:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-2170) Add OrcTableSource - posted by "Owen O'Malley (JIRA)" <ji...@apache.org> on 2016/06/09 20:29:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-4014) Job blocked on read/write buffer requests - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/09 20:52:21 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/09 20:52:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-2170) Add OrcTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/09 21:03:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-4052) Unstable test ConnectionUtilsTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/09 22:19:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4052) Unstable test ConnectionUtilsTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/09 22:30:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4052) Unstable test ConnectionUtilsTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/09 22:30:21 UTC, 0 replies.
- [GitHub] flink issue #2044: [FLINK-3944] [tableAPI] Add rewrite rules to reorder Cart... - posted by fhueske <gi...@git.apache.org> on 2016/06/10 07:47:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/10 07:47:20 UTC, 5 replies.
- [jira] [Assigned] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 11:33:20 UTC, 0 replies.
- [GitHub] flink pull request #2089: [FLINK-4049] Mark (open/close)IF() @PublicEvolving - posted by zentol <gi...@git.apache.org> on 2016/06/10 11:34:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/10 11:35:21 UTC, 3 replies.
- [GitHub] flink issue #2089: [FLINK-4049] Mark (open/close)IF() @PublicEvolving - posted by rmetzger <gi...@git.apache.org> on 2016/06/10 12:04:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-4002) [py] Improve testing infraestructure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 12:09:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4054) Inconsistent Reporter synchronization within report() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 12:17:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 12:19:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4055) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/10 12:36:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/10 12:41:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/10 12:44:21 UTC, 0 replies.
- [GitHub] flink pull request #2090: Expose several new Metrics - posted by zentol <gi...@git.apache.org> on 2016/06/10 12:52:40 UTC, 9 replies.
- [jira] [Closed] (FLINK-4054) Inconsistent Reporter synchronization within report() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 13:06:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 13:08:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4057) Expose JobManager Metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 13:44:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4057) Expose JobManager Metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 13:46:21 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1550) Show JVM Metrics for JobManager - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 13:46:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3969) Log Exceptions Thrown by Invokable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 14:44:22 UTC, 0 replies.
- [GitHub] flink pull request #2091: [FLINK-3969] Log Exceptions by Invokable - posted by zentol <gi...@git.apache.org> on 2016/06/10 14:44:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-3969) Log Exceptions Thrown by Invokable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/10 14:45:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-3297) Streaming connector for ZeroMQ - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/06/10 15:16:21 UTC, 7 replies.
- [GitHub] flink issue #2091: [FLINK-3969] Log Exceptions by Invokable - posted by StephanEwen <gi...@git.apache.org> on 2016/06/10 15:27:53 UTC, 0 replies.
- [GitHub] flink pull request #2049: [FLINK-3971] [tableAPI] Aggregates handle null val... - posted by fhueske <gi...@git.apache.org> on 2016/06/10 15:59:40 UTC, 9 replies.
- [GitHub] flink issue #2085: [FLINK-3937] programmatic resuming of clusters - posted by rmetzger <gi...@git.apache.org> on 2016/06/10 16:47:18 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-3839) Support wildcards in classpath parameters - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/10 17:35:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/10 17:35:21 UTC, 5 replies.
- [GitHub] flink pull request #2044: [FLINK-3944] [tableAPI] Add rewrite rules to reord... - posted by asfgit <gi...@git.apache.org> on 2016/06/10 17:52:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/10 17:55:20 UTC, 1 replies.
- [GitHub] flink issue #1881: [FLINK-3749] [table] Improve decimal handling - posted by fhueske <gi...@git.apache.org> on 2016/06/10 18:00:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-3749) Improve decimal handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/10 18:01:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-3839) Support wildcards in classpath parameters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/10 20:10:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4058) Error uploading JAR with dependencies using flink.bat on a Windows stand-alone instance - posted by "Mark Nadelson (JIRA)" <ji...@apache.org> on 2016/06/10 21:52:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4058) Error uploading JAR with dependencies using flink.bat on a Windows stand-alone instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/10 22:08:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/10 22:21:20 UTC, 1 replies.
- [GitHub] flink issue #2083: [FLINK-3713] [clients, runtime] Use user code class loade... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/10 22:26:48 UTC, 3 replies.
- [jira] [Closed] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/06/10 22:51:21 UTC, 0 replies.
- [GitHub] flink pull request #2092: [FLINK-3395] [build] Make test utils properly avai... - posted by StephanEwen <gi...@git.apache.org> on 2016/06/11 00:49:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-3395) Polishing the web UI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/11 00:49:20 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Tester (JIRA)" <ji...@apache.org> on 2016/06/11 04:44:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/11 07:59:20 UTC, 0 replies.
- [GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness" - posted by kl0u <gi...@git.apache.org> on 2016/06/11 21:52:09 UTC, 16 replies.
- [jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/11 21:52:20 UTC, 23 replies.
- [jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/12 17:23:20 UTC, 19 replies.
- [jira] [Comment Edited] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/12 17:27:20 UTC, 0 replies.
- [GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi... - posted by ggevay <gi...@git.apache.org> on 2016/06/12 18:35:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/12 18:35:21 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4051) RabbitMQ Source might not react to cancel signal - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/06/13 04:31:21 UTC, 3 replies.
- [jira] [Created] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/13 07:03:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/13 08:59:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/13 09:20:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :( - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/13 09:39:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/13 09:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/13 09:42:20 UTC, 0 replies.
- [GitHub] flink pull request #2095: [FLINK-4046] [runtime] Add direct state transition... - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/13 09:44:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 09:44:21 UTC, 5 replies.
- [jira] [Created] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug - posted by "dengchangfu (JIRA)" <ji...@apache.org> on 2016/06/13 09:45:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 09:51:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 09:52:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/06/13 09:59:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4062) Update Window Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 10:10:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :( - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/13 10:10:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/13 10:10:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4062) Update Windowing Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 10:11:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/13 10:23:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4063) Add Metrics Support for Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 12:17:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4063) Add Metrics Support for Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 12:20:20 UTC, 6 replies.
- [jira] Akshay Shingote shared "FLINK-4059: Requirement of Streaming layer for Complex Event Processing" with you - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/13 12:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4064) Allow calling MetricGroup methods multiple times - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 12:39:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4064) Allow calling MetricGroup methods multiple times - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 12:40:21 UTC, 4 replies.
- [jira] [Created] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/13 12:57:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/13 12:58:20 UTC, 0 replies.
- [GitHub] flink pull request #2096: [FLINK-3800] [runtime] Introduce SUSPENDED job sta... - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/13 13:34:24 UTC, 8 replies.
- [jira] [Commented] (FLINK-3800) ExecutionGraphs can become orphans - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 13:35:21 UTC, 12 replies.
- [jira] [Created] (FLINK-4066) RabbitMQ source, customize queue arguments - posted by "Kanstantsin Kamkou (JIRA)" <ji...@apache.org> on 2016/06/13 13:36:21 UTC, 0 replies.
- [GitHub] flink issue #2093: [FLINK-3714] Add Support for "Allowed Lateness" - posted by aljoscha <gi...@git.apache.org> on 2016/06/13 13:47:54 UTC, 6 replies.
- [GitHub] flink issue #2088: [FLINK-3859] [table] Add BigDecimal/BigInteger support to... - posted by fhueske <gi...@git.apache.org> on 2016/06/13 15:04:28 UTC, 12 replies.
- [jira] [Commented] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/13 15:14:21 UTC, 1 replies.
- [jira] [Closed] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/13 15:14:21 UTC, 0 replies.
- [GitHub] flink pull request #1881: [FLINK-3749] [table] Improve decimal handling - posted by twalthr <gi...@git.apache.org> on 2016/06/13 15:14:51 UTC, 0 replies.
- [jira] [Created] (FLINK-4067) Add version header to savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/13 15:16:21 UTC, 0 replies.
- [GitHub] flink pull request #2097: [FLINK-4028] Create correct TimeWindow in Abstract... - posted by aljoscha <gi...@git.apache.org> on 2016/06/13 15:19:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 15:20:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-4066) RabbitMQ source, customize queue arguments - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/13 15:20:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4066) RabbitMQ source, customize queue arguments - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/13 15:20:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4066) RabbitMQ source, customize queue arguments - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/13 15:20:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/13 15:34:20 UTC, 0 replies.
- [GitHub] flink issue #1626: [FLINK-3340] [runtime] Fix object juggling in drivers - posted by xhumanoid <gi...@git.apache.org> on 2016/06/13 16:08:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-3340) Fix object juggling in drivers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 16:09:21 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/13 16:15:21 UTC, 0 replies.
- [GitHub] flink pull request #2098: [revert] [FLINK-3944] [tableAPI] Reverts "Add rewr... - posted by fhueske <gi...@git.apache.org> on 2016/06/13 16:26:32 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker - posted by "Subhankar Biswas (JIRA)" <ji...@apache.org> on 2016/06/13 17:06:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4066) RabbitMQ source, customize queue arguments - posted by "Kanstantsin Kamkou (JIRA)" <ji...@apache.org> on 2016/06/13 18:01:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3323) Add documentation for NiFi connector - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/06/13 18:44:30 UTC, 0 replies.
- [GitHub] flink pull request #2099: Flink 3323: Add documentation for NiFi connector - posted by smarthi <gi...@git.apache.org> on 2016/06/13 18:56:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-3323) Add documentation for NiFi connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/13 18:57:30 UTC, 1 replies.
- [jira] [Created] (FLINK-4069) Kafka Consumer should not initialize on construction - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/06/13 20:48:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/14 02:43:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-4069) Kafka Consumer should not initialize on construction - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/14 02:48:57 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4069) Kafka Consumer should not initialize on construction - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/14 02:50:57 UTC, 1 replies.
- [GitHub] flink issue #2099: Flink 3323: Add documentation for NiFi connector - posted by rmetzger <gi...@git.apache.org> on 2016/06/14 06:26:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-4050) FlinkKafkaProducer API Refactor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/14 09:41:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/14 10:13:01 UTC, 13 replies.
- [jira] [Commented] (FLINK-3153) Support all comparisons for String type - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/14 11:43:01 UTC, 0 replies.
- [GitHub] flink issue #2041: [FLINK-3317] [cep] Introduce timeout handler to CEP opera... - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/14 12:30:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-3317) Add timeout handler to CEP operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/14 12:31:01 UTC, 2 replies.
- [GitHub] flink issue #2098: [revert] [FLINK-3944] [tableAPI] Reverts "Add rewrite rul... - posted by fhueske <gi...@git.apache.org> on 2016/06/14 13:09:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/14 14:51:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/14 14:51:01 UTC, 13 replies.
- [jira] [Updated] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/14 14:51:01 UTC, 0 replies.
- [GitHub] flink pull request #2100: [FLINK-4024] FileSourceFunction not adjusted to ne... - posted by kl0u <gi...@git.apache.org> on 2016/06/14 15:00:13 UTC, 19 replies.
- [jira] [Closed] (FLINK-3971) Aggregates handle null values incorrectly. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/14 16:27:57 UTC, 0 replies.
- [GitHub] flink issue #2100: [FLINK-4024] FileSourceFunction not adjusted to new IF li... - posted by fhueske <gi...@git.apache.org> on 2016/06/14 16:36:31 UTC, 9 replies.
- [GitHub] flink issue #2090: Expose several new Metrics - posted by fhueske <gi...@git.apache.org> on 2016/06/14 17:01:51 UTC, 2 replies.
- [jira] [Closed] (FLINK-3889) Make File Monitoring Function checkpointable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/14 17:48:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-3717) Add functionality to be a able to restore from specific point in a FileInputFormat - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/14 17:48:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/14 17:49:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-3896) Allow a StreamTask to be Externally Cancelled. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/14 17:50:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/14 17:51:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/14 17:51:27 UTC, 0 replies.
- [GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API - posted by fhueske <gi...@git.apache.org> on 2016/06/14 20:22:15 UTC, 92 replies.
- [jira] [Closed] (FLINK-3323) Add documentation for NiFi connector - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/14 21:54:30 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3649) Document stable API methods maxBy/minBy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/14 23:02:30 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3641) Document registerCachedFile API call - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/14 23:02:30 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/14 23:03:30 UTC, 0 replies.
- [jira] [Closed] (FLINK-4069) Kafka Consumer should not initialize on construction - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/06/14 23:10:30 UTC, 0 replies.
- [jira] [Created] (FLINK-4070) Support literals on left side of binary expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/15 07:44:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-4070) Support literals on left side of binary expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/15 07:48:09 UTC, 1 replies.
- [jira] [Created] (FLINK-4071) JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:17:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:19:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:21:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:22:09 UTC, 0 replies.
- [GitHub] flink pull request #2101: [FLINK-4030] Revert Surefire version to 2.18.1 - posted by mxm <gi...@git.apache.org> on 2016/06/15 09:04:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-4030) ScalaShellITCase gets stuck - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/15 09:05:09 UTC, 2 replies.
- [GitHub] flink issue #2101: [FLINK-4030] Revert Surefire version to 2.18.1 - posted by mxm <gi...@git.apache.org> on 2016/06/15 09:05:53 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4030) ScalaShellITCase gets stuck - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/15 09:07:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4070) Support literals on left side of binary expressions - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/15 09:18:09 UTC, 3 replies.
- [GitHub] flink pull request #2102: [FLINK-4068] [tableAPI] Move constant computations... - posted by wuchong <gi...@git.apache.org> on 2016/06/15 09:31:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions. - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/15 09:32:09 UTC, 7 replies.
- [GitHub] flink pull request #2103: [FLINK-2733] Harden ZooKeeperLeaderElectionTest - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/15 09:43:09 UTC, 1 replies.
- [GitHub] flink issue #2102: [FLINK-4068] [tableAPI] Move constant computations out of... - posted by fhueske <gi...@git.apache.org> on 2016/06/15 09:54:34 UTC, 4 replies.
- [jira] [Created] (FLINK-4074) Reporter can block TaskManager shutdown - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 10:08:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-3916) Allow generic types passing the Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/15 10:16:09 UTC, 1 replies.
- [GitHub] flink pull request #2104: [FLINK-3649] [docs] Add documentation for DataSet ... - posted by fhueske <gi...@git.apache.org> on 2016/06/15 10:17:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-3649) Document stable API methods maxBy/minBy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/15 10:18:09 UTC, 2 replies.
- [jira] [Updated] (FLINK-1550) Show JVM Metrics for JobManager - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 10:49:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-3553) Don't include watermarks in record count - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 10:50:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-456) Integrate runtime metrics / statistics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 10:51:09 UTC, 0 replies.
- [GitHub] flink issue #2020: [FLINK-2314] Make Streaming File Sources Persistent - posted by fhueske <gi...@git.apache.org> on 2016/06/15 11:05:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-4036) Potential deadlock in StreamIterationSink - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 11:37:09 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4071) JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 11:43:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 11:45:09 UTC, 0 replies.
- [jira] [Closed] (FLINK-3969) Log Exceptions Thrown by Invokable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 11:48:09 UTC, 0 replies.
- [GitHub] flink pull request #2105: [FLINK-4074] Make metric reporters less blocking - posted by zentol <gi...@git.apache.org> on 2016/06/15 11:51:56 UTC, 14 replies.
- [jira] [Commented] (FLINK-4074) Reporter can block TaskManager shutdown - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/15 11:52:09 UTC, 18 replies.
- [jira] [Updated] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 11:55:09 UTC, 1 replies.
- [jira] [Closed] (FLINK-4032) Replace all usage of Guava Preconditions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 12:06:09 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/15 12:07:09 UTC, 0 replies.
- [jira] [Closed] (FLINK-4064) Allow calling MetricGroup methods multiple times - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/15 12:07:09 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/15 12:07:09 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4063) Add Metrics Support for Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/15 12:20:09 UTC, 0 replies.
- [GitHub] flink pull request #2106: [FLINK-4063] Add Metrics Support for Triggers - posted by aljoscha <gi...@git.apache.org> on 2016/06/15 12:31:15 UTC, 1 replies.
- [jira] [Closed] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/15 12:35:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4076) BoltWrapper#dispose() should call AbstractStreamOperator#dispose() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/15 13:50:09 UTC, 0 replies.
- [GitHub] flink issue #2106: [FLINK-4063] Add Metrics Support for Triggers - posted by zentol <gi...@git.apache.org> on 2016/06/15 13:58:23 UTC, 3 replies.
- [jira] [Commented] (FLINK-4076) BoltWrapper#dispose() should call AbstractStreamOperator#dispose() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/15 14:35:09 UTC, 3 replies.
- [jira] [Created] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/15 15:06:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4078) Use ClosureCleaner for CoGroup where - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 15:31:09 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/15 15:55:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 15:55:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/15 16:10:09 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/15 16:10:09 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/15 16:12:09 UTC, 3 replies.
- [jira] [Commented] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 16:19:09 UTC, 9 replies.
- [GitHub] flink pull request #2107: [FLINK-4077] Register Pojo DataSet/DataStream as T... - posted by fhueske <gi...@git.apache.org> on 2016/06/15 16:28:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/15 16:29:09 UTC, 2 replies.
- [jira] [Created] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/15 16:47:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/15 16:48:09 UTC, 1 replies.
- [jira] [Reopened] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/15 17:02:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/15 17:02:09 UTC, 1 replies.
- [jira] [Updated] (FLINK-4078) Use ClosureCleaner for CoGroup where - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 17:26:09 UTC, 0 replies.
- [GitHub] flink pull request #2108: [FLINK-4027] Flush FlinkKafkaProducer on checkpoin... - posted by rmetzger <gi...@git.apache.org> on 2016/06/15 20:08:10 UTC, 23 replies.
- [jira] [Assigned] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/15 20:26:09 UTC, 0 replies.
- [GitHub] flink pull request #1989: FLINK-3901 - Added CsvRowInputFormat - posted by fhueske <gi...@git.apache.org> on 2016/06/15 21:51:50 UTC, 17 replies.
- [jira] [Commented] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/15 21:52:10 UTC, 18 replies.
- [GitHub] flink issue #1989: FLINK-3901 - Added CsvRowInputFormat - posted by fhueske <gi...@git.apache.org> on 2016/06/15 22:32:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-4053) Return value from Connection should be checked against null - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/16 02:18:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/06/16 05:44:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions. - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/16 06:19:05 UTC, 0 replies.
- [GitHub] flink issue #1979: [FLINK-3758] Add possibility to register accumulators in ... - posted by aljoscha <gi...@git.apache.org> on 2016/06/16 06:21:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/06/16 07:05:05 UTC, 1 replies.
- [GitHub] flink pull request #2007: [FLINK-3908] Fixed Parser's error state reset - posted by asfgit <gi...@git.apache.org> on 2016/06/16 07:41:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/16 07:44:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/16 07:44:06 UTC, 0 replies.
- [GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc... - posted by mushketyk <gi...@git.apache.org> on 2016/06/16 07:50:21 UTC, 5 replies.
- [jira] [Commented] (FLINK-4053) Return value from Connection should be checked against null - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/16 08:09:05 UTC, 9 replies.
- [jira] [Assigned] (FLINK-4053) Return value from Connection should be checked against null - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/16 08:09:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3943) Add support for EXCEPT (set minus) - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/16 08:13:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3943) Add support for EXCEPT (set minus) - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/16 08:13:05 UTC, 20 replies.
- [jira] [Commented] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 09:12:05 UTC, 0 replies.
- [GitHub] flink pull request #2110: [FLINK-3974] Fix object reuse with multi-chaining - posted by aljoscha <gi...@git.apache.org> on 2016/06/16 09:12:46 UTC, 6 replies.
- [jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 09:13:05 UTC, 14 replies.
- [jira] [Commented] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 09:14:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 09:19:05 UTC, 8 replies.
- [GitHub] flink pull request #2111: [FLINK-4076] BoltWrapper#dispose() should call Abs... - posted by f7753 <gi...@git.apache.org> on 2016/06/16 09:22:37 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/16 09:26:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/16 09:28:05 UTC, 3 replies.
- [jira] [Created] (FLINK-4081) FieldParsers should support empty strings - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/06/16 09:29:05 UTC, 0 replies.
- [GitHub] flink issue #2111: [FLINK-4076] BoltWrapper#dispose() should call AbstractSt... - posted by zentol <gi...@git.apache.org> on 2016/06/16 09:49:45 UTC, 0 replies.
- [GitHub] flink issue #2108: [FLINK-4027] Flush FlinkKafkaProducer on checkpoints - posted by rmetzger <gi...@git.apache.org> on 2016/06/16 09:53:44 UTC, 4 replies.
- [GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex... - posted by zentol <gi...@git.apache.org> on 2016/06/16 10:10:32 UTC, 11 replies.
- [jira] [Assigned] (FLINK-3951) Add Histogram Metric Type - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 10:14:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4063) Add Metrics Support for Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/16 10:16:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3949) Collect Metrics in Runtime Operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/16 10:24:05 UTC, 0 replies.
- [GitHub] flink pull request #2112: [FLINK-3951] Add histogram metric type - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/16 10:28:50 UTC, 32 replies.
- [jira] [Commented] (FLINK-3951) Add Histogram Metric Type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/16 10:29:05 UTC, 39 replies.
- [jira] [Closed] (FLINK-3949) Collect Metrics in Runtime Operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/16 10:36:05 UTC, 0 replies.
- [GitHub] flink issue #2112: [FLINK-3951] Add histogram metric type - posted by zentol <gi...@git.apache.org> on 2016/06/16 11:11:19 UTC, 6 replies.
- [jira] [Updated] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/16 12:10:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/16 12:11:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/16 12:11:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/16 12:13:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:17:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:26:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:27:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:27:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3588) Add a streaming (exactly-once) JDBC connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:28:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:28:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:29:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3674) Add an interface for EventTime aware User Function - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:29:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3661) Make Scala 2.11.x the default Scala version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:29:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3720) Add warm starts for models - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:30:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3827) Flink modules include unused dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:32:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:33:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3864) Yarn tests don't check for prohibited strings in log output - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:34:05 UTC, 3 replies.
- [jira] [Updated] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/16 12:35:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3894) Remove Program Packaging via Plans - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:35:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:35:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3895) Remove Docs for Program Packaging via Plans - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:36:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4082) Add Setting for LargeRecordHandler - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/16 12:36:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3933) Add an auto-type-extracting DeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:37:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3933) Add an auto-type-extracting DeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:37:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3950) Add Meter Metric Type - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:38:05 UTC, 1 replies.
- [GitHub] flink pull request #2113: [FLINK-4082] Add Setting for enabling/disabling La... - posted by aljoscha <gi...@git.apache.org> on 2016/06/16 12:42:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-3995) Properly Structure Test Utils and Dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:43:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-4082) Add Setting for LargeRecordHandler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/16 12:43:05 UTC, 5 replies.
- [jira] [Updated] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:48:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:48:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3875) Add a TableSink for Elasticsearch - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:48:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:50:05 UTC, 0 replies.
- [GitHub] flink pull request #2114: FLINT-3839 Added the extraction of jar files from ... - posted by thormanrd <gi...@git.apache.org> on 2016/06/16 12:51:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-3967) Provide RethinkDB Sink for Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 12:55:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 13:12:05 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 13:13:05 UTC, 0 replies.
- [GitHub] flink pull request #2115: [FLINK-4017] [py] Add Aggregation support to Pytho... - posted by GEOFBOT <gi...@git.apache.org> on 2016/06/16 13:16:58 UTC, 5 replies.
- [jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/16 13:18:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4083) Use ClosureCleaner for Join where and equalTo - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/16 13:19:05 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-4083) Use ClosureCleaner for Join where and equalTo - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/16 13:19:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4083) Use ClosureCleaner for Join where and equalTo - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/16 13:20:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 13:23:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 13:23:05 UTC, 0 replies.
- [GitHub] flink issue #2114: FLINT-3839 Added the extraction of jar files from a URL s... - posted by rmetzger <gi...@git.apache.org> on 2016/06/16 13:36:01 UTC, 0 replies.
- [GitHub] flink pull request #2116: [FLINK-4078] [java, DataSet] Introduce missing cal... - posted by StefanRRichter <gi...@git.apache.org> on 2016/06/16 13:38:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-4078) Use ClosureCleaner for CoGroup where - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/16 13:39:05 UTC, 5 replies.
- [jira] [Assigned] (FLINK-4067) Add version header to savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/16 13:45:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/16 14:13:05 UTC, 0 replies.
- [GitHub] flink pull request #2117: [FLINK-4083] [java,DataSet] Introduce closure clea... - posted by StefanRRichter <gi...@git.apache.org> on 2016/06/16 14:17:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-3317) Add timeout handler to CEP operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 14:50:05 UTC, 0 replies.
- [GitHub] flink pull request #2041: [FLINK-3317] [cep] Introduce timeout handler to CE... - posted by asfgit <gi...@git.apache.org> on 2016/06/16 14:50:15 UTC, 0 replies.
- [GitHub] flink pull request #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector - posted by asfgit <gi...@git.apache.org> on 2016/06/16 14:59:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 15:00:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3332) Provide an exactly-once Cassandra connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/16 15:00:10 UTC, 0 replies.
- [GitHub] flink issue #2114: FLINK-3839 Added the extraction of jar files from a URL s... - posted by thormanrd <gi...@git.apache.org> on 2016/06/16 15:28:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3942) Add support for INTERSECT - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/16 15:53:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3942) Add support for INTERSECT - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/16 15:53:05 UTC, 21 replies.
- [jira] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 16:05:05 UTC, 0 replies.
- [GitHub] flink pull request #2118: [FLINK-3977] InternalWindowFunctions implement Out... - posted by fhueske <gi...@git.apache.org> on 2016/06/16 16:12:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/16 19:30:05 UTC, 7 replies.
- [jira] [Assigned] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/16 22:29:05 UTC, 0 replies.
- [GitHub] flink pull request #2119: [FLINK-3949] Add numSplitsProcessed (Streaming) - posted by zentol <gi...@git.apache.org> on 2016/06/17 07:42:21 UTC, 4 replies.
- [jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 07:43:05 UTC, 6 replies.
- [GitHub] flink pull request #2120: [FLINK-4070] [tableApi] Support literals on left s... - posted by wuchong <gi...@git.apache.org> on 2016/06/17 08:21:19 UTC, 0 replies.
- [GitHub] flink issue #2104: [FLINK-3649] [docs] Add documentation for DataSet minBy /... - posted by fhueske <gi...@git.apache.org> on 2016/06/17 08:35:50 UTC, 0 replies.
- [GitHub] flink issue #2107: [FLINK-4077] Register Pojo DataSet/DataStream as Table wi... - posted by fhueske <gi...@git.apache.org> on 2016/06/17 08:35:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 08:41:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 08:42:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3649) Document stable API methods maxBy/minBy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 08:42:05 UTC, 0 replies.
- [GitHub] flink pull request #2034: [FLINK-3937] Implemented -yid option to Flink cli ... - posted by asfgit <gi...@git.apache.org> on 2016/06/17 08:45:59 UTC, 0 replies.
- [GitHub] flink pull request #1978: [FLINK-3667] refactor client communication - posted by asfgit <gi...@git.apache.org> on 2016/06/17 08:45:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/17 08:51:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/17 08:52:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/17 08:53:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3667) Generalize client<->cluster communication - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/17 08:56:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3667) Generalize client<->cluster communication - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/17 08:58:05 UTC, 0 replies.
- [GitHub] flink issue #2118: [FLINK-3977] InternalWindowFunctions implement OutputType... - posted by aljoscha <gi...@git.apache.org> on 2016/06/17 09:19:40 UTC, 1 replies.
- [GitHub] flink issue #2079: [FLINK-3907] [gelly] Directed Clustering Coefficient - posted by zentol <gi...@git.apache.org> on 2016/06/17 09:34:22 UTC, 0 replies.
- [GitHub] flink pull request #2121: [FLINK-4075] ContinuousFileProcessingCheckpointITC... - posted by kl0u <gi...@git.apache.org> on 2016/06/17 09:45:09 UTC, 1 replies.
- [GitHub] flink issue #2119: [FLINK-3949] Add numSplitsProcessed (Streaming) - posted by fhueske <gi...@git.apache.org> on 2016/06/17 09:45:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/17 09:59:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo - posted by "Vladislav Pernin (JIRA)" <ji...@apache.org> on 2016/06/17 10:17:05 UTC, 0 replies.
- [GitHub] flink pull request #2122: [FLINK-3641] Add documentation for DataSet distrib... - posted by fhueske <gi...@git.apache.org> on 2016/06/17 10:27:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-3641) Document registerCachedFile API call - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 10:27:05 UTC, 3 replies.
- [GitHub] flink pull request #2123: [FLINK-3904] GlobalConfiguration doesn't ensure co... - posted by mxm <gi...@git.apache.org> on 2016/06/17 10:44:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 10:45:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/17 11:15:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/17 11:38:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4085) Set Kinesis Consumer Agent to Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/17 11:39:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/17 11:42:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/17 11:44:05 UTC, 0 replies.
- [GitHub] flink pull request #2124: [FLINK-3647] Change StreamSource to use Processing... - posted by kl0u <gi...@git.apache.org> on 2016/06/17 12:26:53 UTC, 4 replies.
- [jira] [Commented] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 12:27:05 UTC, 7 replies.
- [jira] [Commented] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/17 12:28:05 UTC, 0 replies.
- [GitHub] flink pull request #2125: [FLINK-3864] Yarn tests don't check for prohibited... - posted by mxm <gi...@git.apache.org> on 2016/06/17 12:30:29 UTC, 1 replies.
- [GitHub] flink issue #2103: [FLINK-2733] Harden ZooKeeperLeaderElectionTest - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/17 12:48:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/17 12:51:05 UTC, 0 replies.
- [GitHub] flink pull request #1954: [FLINK-3190] failure rate restart strategy - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/17 12:56:03 UTC, 7 replies.
- [jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 12:56:05 UTC, 9 replies.
- [jira] [Created] (FLINK-4086) Hide internal Expression methods from Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 13:24:05 UTC, 0 replies.
- [GitHub] flink pull request #2126: [FLINK-4086] [tableAPI] Hide internal methods of E... - posted by fhueske <gi...@git.apache.org> on 2016/06/17 13:31:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-4086) Hide internal Expression methods from Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 13:32:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4087) JMXReporter can't handle port conflicts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/17 13:47:05 UTC, 0 replies.
- [GitHub] flink pull request #2127: [FLINK-4087] [metrics] Improved JMX port handling - posted by zentol <gi...@git.apache.org> on 2016/06/17 13:57:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-4087) JMXReporter can't handle port conflicts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 13:58:05 UTC, 24 replies.
- [GitHub] flink issue #1954: [FLINK-3190] failure rate restart strategy - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/17 13:59:16 UTC, 1 replies.
- [GitHub] flink issue #2116: [FLINK-4078] [java, DataSet] Introduce missing calls to c... - posted by uce <gi...@git.apache.org> on 2016/06/17 14:05:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 14:10:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 14:10:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2988) Cannot load DataSet[Row] from CSV file - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 14:16:05 UTC, 0 replies.
- [GitHub] flink issue #1898: [FLINK-2259][ml] Add Train-Testing Splitters - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/17 14:54:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/17 14:55:05 UTC, 2 replies.
- [GitHub] flink issue #2125: [FLINK-3864] Yarn tests don't check for prohibited string... - posted by zentol <gi...@git.apache.org> on 2016/06/17 14:55:54 UTC, 1 replies.
- [jira] [Created] (FLINK-4088) Add interface to save and load TableSources - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 14:57:05 UTC, 0 replies.
- [GitHub] flink pull request #1898: [FLINK-2259][ml] Add Train-Testing Splitters - posted by asfgit <gi...@git.apache.org> on 2016/06/17 14:59:50 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/17 15:00:09 UTC, 0 replies.
- [GitHub] flink issue #2122: [FLINK-3641] Add documentation for DataSet distributed ca... - posted by zentol <gi...@git.apache.org> on 2016/06/17 15:38:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-4088) Add interface to save and load TableSources - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/06/17 15:58:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/17 17:08:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/17 17:10:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/06/17 20:36:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/06/17 20:39:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/17 21:12:05 UTC, 13 replies.
- [jira] [Comment Edited] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/06/17 21:25:05 UTC, 0 replies.
- [GitHub] flink pull request #2128: [FLINK-4053] Return value from Connection should b... - posted by mushketyk <gi...@git.apache.org> on 2016/06/17 21:28:22 UTC, 5 replies.
- [jira] [Assigned] (FLINK-1003) Spread out scheduling strategy - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/18 10:30:05 UTC, 0 replies.
- [GitHub] flink pull request #2129: [FLINK-1003] [WIP] Spread out scheduling of tasks - posted by gyfora <gi...@git.apache.org> on 2016/06/18 10:40:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-1003) Spread out scheduling strategy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/18 10:41:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2618) ExternalSortITCase failure - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/18 21:10:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-3641) Document registerCachedFile API call - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/18 21:48:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/18 21:49:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4092) Stringify map function's type conversion problem is breaking running provided example in documents - posted by "Shahin Azad (JIRA)" <ji...@apache.org> on 2016/06/19 08:49:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4092) Stringify map function's type conversion problem is breaking running provided example in documents - posted by "Shahin Azad (JIRA)" <ji...@apache.org> on 2016/06/19 08:54:05 UTC, 1 replies.
- [GitHub] flink pull request #2130: [FLINK-4092] Python API Stringify map function's t... - posted by shahinism <gi...@git.apache.org> on 2016/06/19 10:09:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-4092) Stringify map function's type conversion problem is breaking running provided example in documents - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/19 10:10:05 UTC, 3 replies.
- [GitHub] flink issue #2130: [FLINK-4092] Python API Stringify map function's type con... - posted by zentol <gi...@git.apache.org> on 2016/06/19 10:18:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/19 15:59:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/19 16:01:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/19 16:02:05 UTC, 8 replies.
- [jira] [Updated] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/19 16:03:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/19 16:06:05 UTC, 4 replies.
- [jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/19 16:07:05 UTC, 5 replies.
- [GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon... - posted by tzulitai <gi...@git.apache.org> on 2016/06/19 17:15:31 UTC, 45 replies.
- [GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector - posted by mjsax <gi...@git.apache.org> on 2016/06/19 17:25:54 UTC, 112 replies.
- [jira] [Commented] (FLINK-3034) Redis SInk Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/19 17:26:05 UTC, 117 replies.
- [GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector - posted by mjsax <gi...@git.apache.org> on 2016/06/19 19:50:04 UTC, 18 replies.
- [GitHub] flink pull request #2132: [FLINK-4090] Close of OutputStream should be in fi... - posted by f7753 <gi...@git.apache.org> on 2016/06/20 02:03:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 02:04:05 UTC, 4 replies.
- [jira] [Created] (FLINK-4093) Expose metric interfaces - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/20 09:14:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/20 09:15:05 UTC, 0 replies.
- [GitHub] flink pull request #2133: [FLINK-4091] Fix Guava shading in Cassandra connec... - posted by zentol <gi...@git.apache.org> on 2016/06/20 09:17:00 UTC, 1 replies.
- [GitHub] flink pull request #2134: [FLINK-4093] Expose metric interfaces - posted by zentol <gi...@git.apache.org> on 2016/06/20 09:19:28 UTC, 6 replies.
- [jira] [Commented] (FLINK-4093) Expose metric interfaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 09:20:05 UTC, 8 replies.
- [GitHub] flink issue #2132: [FLINK-4090] Close of OutputStream should be in finally c... - posted by zentol <gi...@git.apache.org> on 2016/06/20 09:20:20 UTC, 2 replies.
- [GitHub] flink issue #2133: [FLINK-4091] Fix Guava shading in Cassandra connector - posted by theomega <gi...@git.apache.org> on 2016/06/20 09:22:46 UTC, 4 replies.
- [jira] [Commented] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:26:05 UTC, 6 replies.
- [jira] [Resolved] (FLINK-3765) ScalaShellITCase deadlocks spuriously - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:28:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3787) Yarn client does not report unfulfillable container constraints - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:29:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3820) ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:32:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-3838) CLI parameter parser is munging application params - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:35:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-3838) CLI parameter parser is munging application params - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:36:05 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3838) CLI parameter parser is munging application params - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 09:36:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4058) Error uploading JAR with dependencies using flink.bat on a Windows stand-alone instance - posted by "miaoever (JIRA)" <ji...@apache.org> on 2016/06/20 09:44:05 UTC, 0 replies.
- [GitHub] flink pull request #2135: [hotfix] [metrics] Prevent log flooding from colli... - posted by zentol <gi...@git.apache.org> on 2016/06/20 09:58:02 UTC, 0 replies.
- [jira] [Created] (FLINK-4094) Off heap memory deallocation might not work properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/20 10:31:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/20 10:32:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/06/20 10:51:05 UTC, 2 replies.
- [GitHub] flink issue #2127: [FLINK-4087] [metrics] Improved JMX port handling - posted by zentol <gi...@git.apache.org> on 2016/06/20 11:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-4095) Add configDir argument to shell scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/20 12:23:05 UTC, 0 replies.
- [GitHub] flink issue #2092: [FLINK-3395] [build] Make test utils properly available a... - posted by rmetzger <gi...@git.apache.org> on 2016/06/20 13:34:29 UTC, 0 replies.
- [jira] [Closed] (FLINK-4083) Use ClosureCleaner for Join where and equalTo - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/20 13:38:05 UTC, 0 replies.
- [GitHub] flink pull request #2136: [FLINK-3626] [py] zipWithIndex in Python API - posted by GEOFBOT <gi...@git.apache.org> on 2016/06/20 13:38:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-3626) zipWithIndex in Python API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/20 13:39:05 UTC, 7 replies.
- [jira] [Closed] (FLINK-4078) Use ClosureCleaner for CoGroup where - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/20 13:39:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 14:12:05 UTC, 7 replies.
- [jira] [Assigned] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/20 14:42:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4041) Failure while asking ResourceManager for RegisterResource - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 14:47:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/20 14:47:05 UTC, 8 replies.
- [jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/06/20 14:49:05 UTC, 38 replies.
- [GitHub] flink pull request #2137: [FLINK-4041] reduce log level for JobManager->Reso... - posted by mxm <gi...@git.apache.org> on 2016/06/20 14:53:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4041) Failure while asking ResourceManager for RegisterResource - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 14:54:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:02:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:09:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:13:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:13:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:22:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:22:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:23:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-4095) Add configDir argument to shell scripts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:28:05 UTC, 1 replies.
- [jira] [Reopened] (FLINK-4095) Add configDir argument to shell scripts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:28:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:37:05 UTC, 0 replies.
- [GitHub] flink pull request #2138: [FLINK-3757] clarify JavaDoc for addAccumulator me... - posted by mxm <gi...@git.apache.org> on 2016/06/20 15:45:59 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:49:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/20 15:50:05 UTC, 0 replies.
- [GitHub] flink issue #2138: [FLINK-3757] clarify JavaDoc for addAccumulator method - posted by knaufk <gi...@git.apache.org> on 2016/06/20 15:57:44 UTC, 1 replies.
- [GitHub] flink pull request #2139: [FLINK-3838] Upgrade commons-cli to fix parsing of... - posted by mxm <gi...@git.apache.org> on 2016/06/20 16:00:07 UTC, 1 replies.
- [GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r... - posted by tzulitai <gi...@git.apache.org> on 2016/06/20 16:09:47 UTC, 15 replies.
- [GitHub] flink issue #2136: [FLINK-3626] [py] zipWithIndex in Python API - posted by zentol <gi...@git.apache.org> on 2016/06/20 16:28:06 UTC, 1 replies.
- [GitHub] flink issue #2075: [FLINK-3867] Provide Vagrant/Ansible based VMs to easily ... - posted by rmetzger <gi...@git.apache.org> on 2016/06/20 17:56:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/20 18:50:57 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/20 18:50:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3320) Add not operator to CEP's pattern API - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/20 18:57:57 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3319) Add or operator to CEP's pattern API - posted by "Robert Thorman (JIRA)" <ji...@apache.org> on 2016/06/20 19:39:58 UTC, 0 replies.
- [GitHub] flink issue #2115: [FLINK-4017] [py] Add Aggregation support to Python API - posted by zentol <gi...@git.apache.org> on 2016/06/20 19:56:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/20 23:32:57 UTC, 0 replies.
- [GitHub] flink pull request #2140: [FLINK-4079] do not load Yarn properties file for ... - posted by mxm <gi...@git.apache.org> on 2016/06/21 09:08:55 UTC, 1 replies.
- [GitHub] flink pull request #2141: [flink-4021] Problem of setting autoread for netty... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/06/21 09:17:07 UTC, 0 replies.
- [GitHub] flink pull request #2142: [FLINK-3752] Add Per-Kafka-Partition Watermark Gen... - posted by kl0u <gi...@git.apache.org> on 2016/06/21 09:21:36 UTC, 3 replies.
- [jira] [Updated] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 09:46:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3332) Provide an exactly-once Cassandra connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 09:46:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 09:50:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-1337) Create an Amazon EMR Bootstrap Action - posted by "Stephan Brosinski (JIRA)" <ji...@apache.org> on 2016/06/21 10:12:57 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-1337) Create an Amazon EMR Bootstrap Action - posted by "Stephan Brosinski (JIRA)" <ji...@apache.org> on 2016/06/21 10:14:58 UTC, 0 replies.
- [GitHub] flink issue #2113: [FLINK-4082] Add Setting for enabling/disabling LargeReco... - posted by uce <gi...@git.apache.org> on 2016/06/21 10:16:01 UTC, 3 replies.
- [jira] [Updated] (FLINK-3964) Job submission times out with recursive.file.enumeration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 10:17:57 UTC, 1 replies.
- [jira] [Closed] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/21 10:27:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-4012) Docs: Links to "Iterations" are broken (404) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/21 10:34:57 UTC, 0 replies.
- [GitHub] flink issue #2141: [FLINK-4021] Problem of setting autoread for netty channe... - posted by uce <gi...@git.apache.org> on 2016/06/21 12:10:31 UTC, 0 replies.
- [GitHub] flink issue #2140: [FLINK-4079] do not load Yarn properties file for per-job... - posted by mxm <gi...@git.apache.org> on 2016/06/21 12:18:35 UTC, 1 replies.
- [jira] [Closed] (FLINK-3973) Table API documentation is "hidden" in Programming Guide menu list - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/21 12:21:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/21 12:23:57 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/21 12:56:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/21 13:07:57 UTC, 2 replies.
- [jira] [Closed] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/21 13:09:57 UTC, 0 replies.
- [GitHub] flink issue #2053: [FLINK-1707] Affinity Propagation - posted by vasia <gi...@git.apache.org> on 2016/06/21 13:25:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/21 13:25:57 UTC, 19 replies.
- [GitHub] flink pull request #2053: [FLINK-1707] Affinity Propagation - posted by vasia <gi...@git.apache.org> on 2016/06/21 13:37:28 UTC, 14 replies.
- [jira] [Assigned] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/21 15:03:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/21 15:18:58 UTC, 0 replies.
- [GitHub] flink pull request #2143: [FLINK-4040] [dist] Allow JobManager/TaskManager-s... - posted by uce <gi...@git.apache.org> on 2016/06/21 15:38:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/06/21 15:38:58 UTC, 9 replies.
- [jira] [Commented] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/21 15:38:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/21 15:46:58 UTC, 0 replies.
- [GitHub] flink issue #2143: [FLINK-4040] [dist] Allow JobManager/TaskManager-specific... - posted by gyfora <gi...@git.apache.org> on 2016/06/21 15:48:44 UTC, 1 replies.
- [GitHub] flink issue #2124: [FLINK-3647] Change StreamSource to use Processing-Time C... - posted by aljoscha <gi...@git.apache.org> on 2016/06/21 16:07:27 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/06/21 16:10:57 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4082) Add Setting for LargeRecordHandler - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/21 17:12:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3675) YARN ship folder incosistent behavior - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 21:29:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 21:40:58 UTC, 1 replies.
- [GitHub] flink pull request #1946: [FLINK-3834] POM Cleanup statebackend-rocksdb - posted by zentol <gi...@git.apache.org> on 2016/06/22 08:25:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-3834) flink-statebackend-rocksdb - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/22 08:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/22 08:57:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 09:45:58 UTC, 0 replies.
- [GitHub] flink pull request #2144: [FLINK-4097] Cassandra Sink throws NPE on closing ... - posted by alkagin <gi...@git.apache.org> on 2016/06/22 09:52:52 UTC, 2 replies.
- [jira] [Closed] (FLINK-4092) Stringify map function's type conversion problem is breaking running provided example in documents - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 09:59:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-3626) zipWithIndex in Python API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 10:06:58 UTC, 0 replies.
- [GitHub] flink issue #2144: [FLINK-4097] Cassandra Sink throws NPE on closing if serv... - posted by zentol <gi...@git.apache.org> on 2016/06/22 10:07:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-4076) BoltWrapper#dispose() should call AbstractStreamOperator#dispose() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 10:13:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 10:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4100) RocksDBStateBackend#close() can throw NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 10:48:57 UTC, 0 replies.
- [GitHub] flink pull request #2145: [FLINK-4087] [metrics] Improved JMX port handling - posted by zentol <gi...@git.apache.org> on 2016/06/22 11:03:11 UTC, 17 replies.
- [GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics - posted by zentol <gi...@git.apache.org> on 2016/06/22 11:04:51 UTC, 62 replies.
- [jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/22 11:04:57 UTC, 79 replies.
- [jira] [Updated] (FLINK-4100) RocksDBStateBackend#close() can throw NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 11:24:58 UTC, 0 replies.
- [GitHub] flink issue #2105: [FLINK-4074] Make metric reporters less blocking - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/22 11:38:00 UTC, 3 replies.
- [GitHub] flink issue #2095: [FLINK-4046] [runtime] Add direct state transition from R... - posted by uce <gi...@git.apache.org> on 2016/06/22 11:49:52 UTC, 3 replies.
- [GitHub] flink issue #2145: [FLINK-4087] [metrics] Improved JMX port handling - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/22 12:38:58 UTC, 3 replies.
- [GitHub] flink issue #1996: [FLINK-3919][flink-ml] Distributed Linear Algebra: row-ba... - posted by chiwanpark <gi...@git.apache.org> on 2016/06/22 12:45:26 UTC, 0 replies.
- [jira] [Created] (FLINK-4101) Calculating average in Flink DataStream on window time - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/22 14:10:57 UTC, 0 replies.
- [GitHub] flink issue #2142: [FLINK-3752] Add Per-Kafka-Partition Watermark Generation... - posted by rmetzger <gi...@git.apache.org> on 2016/06/22 14:20:59 UTC, 3 replies.
- [GitHub] flink issue #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/22 14:32:18 UTC, 18 replies.
- [GitHub] flink pull request #2147: [FLINK-1946] reduce verbosity of Yarn cluster setu... - posted by mxm <gi...@git.apache.org> on 2016/06/22 14:37:01 UTC, 2 replies.
- [jira] [Commented] (FLINK-1946) Make yarn tests logging less verbose - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/22 14:37:57 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/22 14:39:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method - posted by "Michael Allman (JIRA)" <ji...@apache.org> on 2016/06/22 14:47:57 UTC, 1 replies.
- [jira] [Created] (FLINK-4102) Test failure with checkpoint barriers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 15:10:59 UTC, 0 replies.
- [GitHub] flink issue #2110: [FLINK-3974] Fix object reuse with multi-chaining - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/22 15:43:49 UTC, 5 replies.
- [GitHub] flink pull request #2148: [FLINK-3995] [build] Make test utils properly avai... - posted by rmetzger <gi...@git.apache.org> on 2016/06/22 15:45:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/22 15:48:57 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/22 15:49:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/22 15:50:57 UTC, 0 replies.
- [GitHub] flink issue #2096: [FLINK-3800] [runtime] Introduce SUSPENDED job status - posted by uce <gi...@git.apache.org> on 2016/06/22 16:06:26 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 16:28:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/22 16:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/06/22 16:34:57 UTC, 0 replies.
- [GitHub] flink pull request #1983: [FLINK-3868] [core] Specialized CopyableValue seri... - posted by asfgit <gi...@git.apache.org> on 2016/06/22 17:26:36 UTC, 0 replies.
- [jira] [Closed] (FLINK-3868) Specialized CopyableValue serializers and comparators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 17:29:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-3789) Overload methods which trigger program execution to allow naming job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 18:29:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4104) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-4105) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:08:56 UTC, 0 replies.
- [jira] [Created] (FLINK-4106) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:08:56 UTC, 0 replies.
- [jira] [Created] (FLINK-4107) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:09:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-4105) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:18:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-4106) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:20:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-4107) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:20:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4108) NPE in Row.productArity - posted by "Martin Scholl (JIRA)" <ji...@apache.org> on 2016/06/22 22:20:16 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3919) Distributed Linear Algebra: row-based matrix - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/06/23 02:10:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?' - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/23 02:18:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/06/23 05:56:16 UTC, 4 replies.
- [jira] [Created] (FLINK-4110) Provide testing skeleton in quickstarts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/23 06:53:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/23 08:17:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/23 08:18:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?' - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/23 08:45:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?' - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/23 08:45:16 UTC, 3 replies.
- [jira] [Resolved] (FLINK-4051) RabbitMQ Source might not react to cancel signal - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/23 08:54:16 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3859) Add BigDecimal/BigInteger support to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/23 09:13:16 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/23 09:28:16 UTC, 0 replies.
- [GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten... - posted by alkagin <gi...@git.apache.org> on 2016/06/23 09:56:17 UTC, 29 replies.
- [GitHub] flink pull request #2150: [FLINK-3580] [table] Reintroduce Date/Time and imp... - posted by twalthr <gi...@git.apache.org> on 2016/06/23 10:03:53 UTC, 7 replies.
- [jira] [Closed] (FLINK-4101) Calculating average in Flink DataStream on window time - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/23 10:04:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-4101) Calculating average in Flink DataStream on window time - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/23 10:04:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-3656) Rework Table API tests - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/23 10:08:16 UTC, 0 replies.
- [GitHub] flink pull request #2151: [hotfix][docs] Add warning to Cassandra documentat... - posted by rmetzger <gi...@git.apache.org> on 2016/06/23 11:49:19 UTC, 1 replies.
- [jira] [Closed] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/23 12:00:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/23 12:00:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4111) Flink Table & SQL doesn't work in very simple example - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/23 12:11:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/23 13:09:16 UTC, 0 replies.
- [GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas... - posted by chobeat <gi...@git.apache.org> on 2016/06/23 13:36:54 UTC, 4 replies.
- [jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/23 13:37:17 UTC, 6 replies.
- [GitHub] flink pull request #2153: [FLINK-4110] Add testing skeleton to quickstart - posted by rmetzger <gi...@git.apache.org> on 2016/06/23 13:53:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-4110) Provide testing skeleton in quickstarts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/23 13:54:16 UTC, 5 replies.
- [GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation - posted by aljoscha <gi...@git.apache.org> on 2016/06/23 13:57:21 UTC, 37 replies.
- [jira] [Commented] (FLINK-4062) Update Windowing Documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/23 13:58:16 UTC, 40 replies.
- [GitHub] flink issue #2134: [FLINK-4093] Expose metric interfaces - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/23 14:48:50 UTC, 1 replies.
- [GitHub] flink pull request #2155: [FLINK-3319] Added Or function for where clause in... - posted by thormanrd <gi...@git.apache.org> on 2016/06/23 15:13:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/23 15:48:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/23 15:49:16 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/23 16:03:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-3800) ExecutionGraphs can become orphans - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/23 16:12:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4113) Always copy first value in ChainedAllReduceDriver - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/23 16:37:16 UTC, 0 replies.
- [GitHub] flink issue #2151: [hotfix][docs] Add warning to Cassandra documentation - posted by zentol <gi...@git.apache.org> on 2016/06/23 16:40:51 UTC, 3 replies.
- [GitHub] flink issue #2147: [FLINK-1946] reduce verbosity of Yarn cluster setup - posted by zentol <gi...@git.apache.org> on 2016/06/23 16:50:58 UTC, 0 replies.
- [GitHub] flink issue #2153: [FLINK-4110] Add testing skeleton to quickstart - posted by tzulitai <gi...@git.apache.org> on 2016/06/23 17:21:10 UTC, 2 replies.
- [GitHub] flink pull request #2156: [FLINK-4113] [runtime] Always copy first value in ... - posted by greghogan <gi...@git.apache.org> on 2016/06/23 19:25:26 UTC, 4 replies.
- [jira] [Commented] (FLINK-4113) Always copy first value in ChainedAllReduceDriver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/23 19:26:16 UTC, 9 replies.
- [jira] [Created] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner - posted by "Chris Hogue (JIRA)" <ji...@apache.org> on 2016/06/23 19:44:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/06/23 20:08:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/06/23 20:12:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-3898) Adamic-Adar Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/23 20:52:16 UTC, 0 replies.
- [GitHub] flink pull request #2157: [FLINK-4115] FsStateBackend filesystem verificatio... - posted by jfg9 <gi...@git.apache.org> on 2016/06/23 23:03:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/23 23:04:16 UTC, 1 replies.
- [GitHub] flink issue #2152: [FLINK-3920] Distributed Linear Algebra: block-based matr... - posted by chiwanpark <gi...@git.apache.org> on 2016/06/24 07:20:35 UTC, 1 replies.
- [jira] [Created] (FLINK-4116) Document metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/24 09:59:16 UTC, 0 replies.
- [GitHub] flink pull request #2158: [FLINK-4116] Metrics documentation - posted by zentol <gi...@git.apache.org> on 2016/06/24 10:02:35 UTC, 71 replies.
- [jira] [Commented] (FLINK-4116) Document metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/24 10:03:16 UTC, 76 replies.
- [jira] [Updated] (FLINK-3834) flink-statebackend-rocksdb - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/24 10:08:16 UTC, 0 replies.
- [GitHub] flink pull request #2071: [FLINK-4018][streaming-connectors] Configurable id... - posted by rmetzger <gi...@git.apache.org> on 2016/06/24 11:43:08 UTC, 1 replies.
- [GitHub] flink pull request #2159: [FLINK-3942] [tableAPI] Add support for INTERSECT - posted by wuchong <gi...@git.apache.org> on 2016/06/24 12:44:35 UTC, 15 replies.
- [GitHub] flink issue #2159: [FLINK-3942] [tableAPI] Add support for INTERSECT - posted by mushketyk <gi...@git.apache.org> on 2016/06/24 13:08:07 UTC, 4 replies.
- [jira] [Reopened] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/24 13:50:16 UTC, 0 replies.
- [GitHub] flink issue #2128: [FLINK-4053] Return value from Connection should be check... - posted by mushketyk <gi...@git.apache.org> on 2016/06/24 14:34:06 UTC, 3 replies.
- [jira] [Created] (FLINK-4117) Wait for CuratorFramework connection to be established - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/24 14:44:16 UTC, 0 replies.
- [GitHub] flink issue #2071: [FLINK-4018][streaming-connectors] Configurable idle time... - posted by tzulitai <gi...@git.apache.org> on 2016/06/24 16:04:33 UTC, 1 replies.
- [jira] [Closed] (FLINK-3907) Directed Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/24 20:56:16 UTC, 0 replies.
- [GitHub] flink pull request #2160: [FLINK-3898] [gelly] Adamic-Adar Similarity - posted by greghogan <gi...@git.apache.org> on 2016/06/24 21:38:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-3898) Adamic-Adar Similarity - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/24 21:39:16 UTC, 0 replies.
- [GitHub] flink issue #2150: [FLINK-3580] [table] Reintroduce Date/Time and implement ... - posted by fhueske <gi...@git.apache.org> on 2016/06/24 23:32:20 UTC, 2 replies.
- [GitHub] flink pull request #2161: FLINK-4301: Modify CsvTableSource to implement Str... - posted by smarthi <gi...@git.apache.org> on 2016/06/25 03:13:24 UTC, 1 replies.
- [GitHub] flink issue #2161: FLINK-4301: Modify CsvTableSource to implement StreamTabl... - posted by smarthi <gi...@git.apache.org> on 2016/06/25 03:23:26 UTC, 0 replies.
- [GitHub] flink pull request #2162: FLINK-4103: Modify CsvTableSource to implement Str... - posted by smarthi <gi...@git.apache.org> on 2016/06/25 03:57:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/25 03:58:16 UTC, 2 replies.
- [jira] [Created] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/06/25 06:19:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/06/25 06:20:16 UTC, 13 replies.
- [jira] [Created] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/06/25 14:02:37 UTC, 0 replies.
- [GitHub] flink pull request #2163: [FLINK-4119] Null checks in close() for Cassandra ... - posted by alkagin <gi...@git.apache.org> on 2016/06/25 14:09:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/25 14:09:37 UTC, 3 replies.
- [jira] [Closed] (FLINK-3864) Yarn tests don't check for prohibited strings in log output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/25 15:34:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/25 15:36:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3838) CLI parameter parser is munging application params - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/25 15:40:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4041) Failure while asking ResourceManager for RegisterResource - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/25 15:44:37 UTC, 0 replies.
- [GitHub] flink pull request #2164: [FLINK-4118] The docker-flink image is outdated (1... - posted by iemejia <gi...@git.apache.org> on 2016/06/25 21:05:14 UTC, 1 replies.
- [GitHub] flink issue #2164: [FLINK-4118] The docker-flink image is outdated (1.0.2) a... - posted by iemejia <gi...@git.apache.org> on 2016/06/25 21:07:55 UTC, 0 replies.
- [jira] [Created] (FLINK-4120) Lightweight fault tolerance through recomputing lost state - posted by "Dénes Vadász (JIRA)" <ji...@apache.org> on 2016/06/26 22:27:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/06/27 04:07:52 UTC, 2 replies.
- [GitHub] flink issue #2163: [FLINK-4119] Null checks in close() for Cassandra Input/O... - posted by rmetzger <gi...@git.apache.org> on 2016/06/27 07:41:58 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2144) Incremental count, average, and variance for windows - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/06/27 07:57:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-4120) Lightweight fault tolerance through recomputing lost state - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/27 08:10:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-4120) Lightweight fault tolerance through recomputing lost state - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/27 08:18:52 UTC, 1 replies.
- [GitHub] flink issue #2157: [FLINK-4115] FsStateBackend filesystem verification can c... - posted by aljoscha <gi...@git.apache.org> on 2016/06/27 09:10:13 UTC, 0 replies.
- [jira] [Created] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks - posted by "Jonas Traub (JIRA)" <ji...@apache.org> on 2016/06/27 09:18:52 UTC, 0 replies.
- [GitHub] flink pull request #2165: [FLINK-4121] Add timeunit (ms) to docs for timesta... - posted by powibol <gi...@git.apache.org> on 2016/06/27 09:28:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 09:28:52 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/27 09:37:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/27 09:38:51 UTC, 0 replies.
- [GitHub] flink issue #2165: [FLINK-4121] Add timeunit (ms) to docs for timestamps and... - posted by aljoscha <gi...@git.apache.org> on 2016/06/27 09:51:32 UTC, 0 replies.
- [GitHub] flink pull request #2166: [FLINK-4099] Fix CliFrontendYarnAddressConfigurati... - posted by rmetzger <gi...@git.apache.org> on 2016/06/27 09:53:28 UTC, 2 replies.
- [jira] [Commented] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 09:53:52 UTC, 4 replies.
- [GitHub] flink issue #2149: [FLINK-4084] Add configDir parameter to CliFrontend and f... - posted by mxm <gi...@git.apache.org> on 2016/06/27 10:04:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/27 10:12:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 10:22:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4122) Cassandra jar contains 2 guava versions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 10:23:52 UTC, 0 replies.
- [GitHub] flink pull request #2167: [FLINK-4122] Disable root shading in Cassandra jar - posted by zentol <gi...@git.apache.org> on 2016/06/27 10:25:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4122) Cassandra jar contains 2 guava versions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/27 10:25:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 10:28:52 UTC, 0 replies.
- [GitHub] flink pull request #2168: [FLINK-3964] add hint to job submission timeout ex... - posted by mxm <gi...@git.apache.org> on 2016/06/27 10:30:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/27 10:50:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/27 10:52:52 UTC, 1 replies.
- [jira] [Closed] (FLINK-4074) Reporter can block TaskManager shutdown - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 11:09:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-4087) JMXReporter can't handle port conflicts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 11:18:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3675) YARN ship folder incosistent behavior - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/27 11:22:52 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3297) Streaming connector for ZeroMQ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/27 11:22:52 UTC, 0 replies.
- [GitHub] flink issue #2156: [FLINK-4113] [runtime] Always copy first value in Chained... - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/27 11:23:52 UTC, 2 replies.
- [GitHub] flink issue #2158: [FLINK-4116] Metrics documentation - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/27 12:04:56 UTC, 4 replies.
- [jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/27 13:03:52 UTC, 11 replies.
- [jira] [Comment Edited] (FLINK-3675) YARN ship folder incosistent behavior - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/27 13:04:52 UTC, 2 replies.
- [GitHub] flink issue #2168: [FLINK-3964] add hint to job submission timeout exception... - posted by gyfora <gi...@git.apache.org> on 2016/06/27 13:15:06 UTC, 1 replies.
- [GitHub] flink issue #2166: [FLINK-4099] Fix CliFrontendYarnAddressConfigurationTest ... - posted by mxm <gi...@git.apache.org> on 2016/06/27 13:40:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-4093) Expose metric interfaces - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 14:00:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-3951) Add Histogram Metric Type - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 14:00:57 UTC, 0 replies.
- [GitHub] flink issue #2155: [FLINK-3319] Added Or function for where clause in CEP Pa... - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/27 14:22:16 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/27 15:02:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/27 15:02:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/27 17:15:52 UTC, 0 replies.
- [GitHub] flink pull request #2169: [FLINK-3943] Add support for EXCEPT operator - posted by mushketyk <gi...@git.apache.org> on 2016/06/27 19:47:10 UTC, 21 replies.
- [GitHub] flink issue #2169: [FLINK-3943] Add support for EXCEPT operator - posted by mushketyk <gi...@git.apache.org> on 2016/06/27 19:52:40 UTC, 3 replies.
- [GitHub] flink pull request #2170: Merge pull request #1 from apache/master - posted by thormanrd <gi...@git.apache.org> on 2016/06/27 19:59:47 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4120) Lightweight fault tolerance through recomputing lost state - posted by "Dénes Vadász (JIRA)" <ji...@apache.org> on 2016/06/27 20:24:52 UTC, 0 replies.
- [GitHub] flink pull request #2171: FLINK-3319 Added the or function to the CEP patter... - posted by thormanrd <gi...@git.apache.org> on 2016/06/27 20:37:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/27 20:59:17 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/27 20:59:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/27 21:07:17 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/27 21:07:17 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/27 21:19:17 UTC, 1 replies.
- [jira] [Created] (FLINK-4124) Unstable test WrapperSetupHelperTest.testCreateTopologyContext - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/27 21:27:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-4124) Unstable test WrapperSetupHelperTest.testCreateTopologyContext - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/27 21:28:16 UTC, 1 replies.
- [GitHub] flink pull request #2172: [FLINK-4096] Ensure JarOutputStream is always clos... - posted by mushketyk <gi...@git.apache.org> on 2016/06/27 21:35:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/27 21:36:57 UTC, 2 replies.
- [jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/27 21:46:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count - posted by "Chris Hogue (JIRA)" <ji...@apache.org> on 2016/06/27 21:47:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/28 06:49:57 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4113) Always copy first value in ChainedAllReduceDriver - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/28 08:46:57 UTC, 0 replies.
- [GitHub] flink issue #2171: FLINK-3319 Added the or function to the CEP pattern - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/28 08:55:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 08:55:57 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4110) Provide testing skeleton in quickstarts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 09:30:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 09:31:57 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4085) Set Kinesis Consumer Agent to Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 10:01:00 UTC, 0 replies.
- [GitHub] flink pull request #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITC... - posted by kl0u <gi...@git.apache.org> on 2016/06/28 11:37:55 UTC, 7 replies.
- [GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen... - posted by rmetzger <gi...@git.apache.org> on 2016/06/28 11:55:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-4085) Set Kinesis Consumer Agent to Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/28 11:55:57 UTC, 7 replies.
- [jira] [Created] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 12:06:57 UTC, 0 replies.
- [GitHub] flink issue #2174: [FLINK-4075] ContinuousFileProcessingCheckpointITCase fai... - posted by aljoscha <gi...@git.apache.org> on 2016/06/28 12:08:18 UTC, 1 replies.
- [jira] [Closed] (FLINK-3898) Adamic-Adar Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 12:11:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 12:15:57 UTC, 2 replies.
- [GitHub] flink issue #2154: [FLINK-4062] Update Windowing Documentation - posted by kl0u <gi...@git.apache.org> on 2016/06/28 12:41:52 UTC, 2 replies.
- [GitHub] flink pull request #2176: Flink 4118 - posted by iemejia <gi...@git.apache.org> on 2016/06/28 13:05:41 UTC, 0 replies.
- [GitHub] flink issue #2176: Flink 4118 - posted by iemejia <gi...@git.apache.org> on 2016/06/28 13:06:02 UTC, 0 replies.
- [GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a... - posted by iemejia <gi...@git.apache.org> on 2016/06/28 13:17:54 UTC, 5 replies.
- [GitHub] flink issue #2175: [FLINK-4085][Kinesis] Set Flink-specific user agent - posted by rmetzger <gi...@git.apache.org> on 2016/06/28 13:36:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 13:45:57 UTC, 0 replies.
- [GitHub] flink pull request #2177: [FLINK-4127] Check API compatbility for 1.1 in fli... - posted by rmetzger <gi...@git.apache.org> on 2016/06/28 14:00:59 UTC, 19 replies.
- [jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/28 14:01:04 UTC, 21 replies.
- [jira] [Commented] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner - posted by "Chris Hogue (JIRA)" <ji...@apache.org> on 2016/06/28 14:11:57 UTC, 1 replies.
- [GitHub] flink pull request #2178: [Flink-1815] Add methods to read and write a Graph... - posted by fobeligi <gi...@git.apache.org> on 2016/06/28 16:24:08 UTC, 6 replies.
- [jira] [Created] (FLINK-4128) compile error about git-commit-id-plugin - posted by "Mao, Wei (JIRA)" <ji...@apache.org> on 2016/06/28 17:12:57 UTC, 0 replies.
- [GitHub] flink pull request #2179: [Flink-4128]fix flink-runtime compile error about ... - posted by mwws <gi...@git.apache.org> on 2016/06/28 17:13:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-3674) Add an interface for EventTime aware User Function - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/06/28 17:38:57 UTC, 2 replies.
- [jira] [Commented] (FLINK-4128) compile error about git-commit-id-plugin - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 18:05:57 UTC, 14 replies.
- [GitHub] flink issue #2179: [Flink-4128] fix flink-runtime compile error about git-co... - posted by greghogan <gi...@git.apache.org> on 2016/06/28 18:51:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4129) HITSAlgorithm should test for element-wise convergence - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 19:27:57 UTC, 0 replies.
- [GitHub] flink pull request #1671: [FLINK-3277] Use Value types in Gelly API - posted by asfgit <gi...@git.apache.org> on 2016/06/28 19:46:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3277) Use Value types in Gelly API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/28 19:46:57 UTC, 0 replies.
- [jira] [Closed] (FLINK-3277) Use Value types in Gelly API - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 19:48:57 UTC, 0 replies.
- [GitHub] flink pull request #1967: [FLINK-3879] [gelly] Native implementation of HITS... - posted by asfgit <gi...@git.apache.org> on 2016/06/28 20:23:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-3879) Native implementation of HITS algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 20:23:57 UTC, 0 replies.
- [GitHub] flink issue #1967: [FLINK-3879] [gelly] Native implementation of HITS algori... - posted by vasia <gi...@git.apache.org> on 2016/06/28 20:48:04 UTC, 0 replies.
- [GitHub] flink issue #2179: [FLINK-4128] compile error about git-commit-id-plugin - posted by mwws <gi...@git.apache.org> on 2016/06/29 02:06:53 UTC, 11 replies.
- [jira] [Assigned] (FLINK-3152) Support all comparisons for Date type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/29 07:55:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3152) Support all comparisons for Date type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/29 08:02:55 UTC, 0 replies.
- [jira] [Created] (FLINK-4130) CallGenerator could generate illegal code when taking no operands - posted by "Cody (JIRA)" <ji...@apache.org> on 2016/06/29 08:17:36 UTC, 0 replies.
- [GitHub] flink pull request #2180: [FLINK-4080][kinesis-connector] Guarantee exactly-... - posted by tzulitai <gi...@git.apache.org> on 2016/06/29 08:22:03 UTC, 5 replies.
- [jira] [Commented] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/29 08:24:18 UTC, 7 replies.
- [GitHub] flink issue #2180: [FLINK-4080][kinesis-connector] Guarantee exactly-once fo... - posted by rmetzger <gi...@git.apache.org> on 2016/06/29 08:24:19 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/29 08:27:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/29 08:32:45 UTC, 0 replies.
- [GitHub] flink issue #2177: [FLINK-4127] Check API compatbility for 1.1 in flink-core - posted by mxm <gi...@git.apache.org> on 2016/06/29 08:40:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/29 08:45:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/29 08:45:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/29 08:45:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets() - posted by "Jens Kat (JIRA)" <ji...@apache.org> on 2016/06/29 10:16:37 UTC, 3 replies.
- [GitHub] flink pull request #2181: [FLINK-4033][docs, kinesis-connector] Polish up Ki... - posted by tzulitai <gi...@git.apache.org> on 2016/06/29 11:08:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/29 11:08:37 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/29 11:38:37 UTC, 0 replies.
- [GitHub] flink issue #2181: [FLINK-4033][docs, kinesis-connector] Polish up Kinesis c... - posted by rmetzger <gi...@git.apache.org> on 2016/06/29 11:40:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/29 11:42:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4085) Set Kinesis Consumer Agent to Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/29 11:44:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4131) Confusing error for out dated RequestPartitionState - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/29 11:47:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4132) Fix boxed comparison in CommunityDetection algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/29 13:03:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4133) Reflect streaming file source changes in documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/29 13:13:37 UTC, 0 replies.
- [GitHub] flink pull request #2182: [Flink 4130] CallGenerator could generate illegal ... - posted by unsleepy22 <gi...@git.apache.org> on 2016/06/29 13:28:01 UTC, 0 replies.
- [GitHub] flink pull request #2183: [FLINK-4123] Cassandra sink checks for exceptions ... - posted by zentol <gi...@git.apache.org> on 2016/06/29 14:26:30 UTC, 4 replies.
- [jira] [Commented] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/29 14:27:17 UTC, 4 replies.
- [GitHub] flink pull request #2184: [FLINK-3618] [gelly] Rename abstract UDF classes i... - posted by greghogan <gi...@git.apache.org> on 2016/06/29 14:36:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/29 14:39:17 UTC, 0 replies.
- [GitHub] flink pull request #2185: [FLINK-4132] [gelly] Fix boxed comparison in Commu... - posted by greghogan <gi...@git.apache.org> on 2016/06/29 14:45:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-4132) Fix boxed comparison in CommunityDetection algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/29 14:45:17 UTC, 2 replies.
- [GitHub] flink pull request #2182: [Flink-4130] CallGenerator could generate illegal ... - posted by wuchong <gi...@git.apache.org> on 2016/06/29 15:32:13 UTC, 2 replies.
- [GitHub] flink pull request #2186: [licenses] Remove not included dependency from LIC... - posted by tillrohrmann <gi...@git.apache.org> on 2016/06/29 15:35:04 UTC, 0 replies.
- [GitHub] flink pull request #2187: [FLINK-3675][yarn] improvements to library shippin... - posted by mxm <gi...@git.apache.org> on 2016/06/29 18:30:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-1759) Execution statistics for vertex-centric iterations - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/29 19:31:05 UTC, 1 replies.
- [GitHub] flink issue #2184: [FLINK-3618] [gelly] Rename abstract UDF classes in Scatt... - posted by vasia <gi...@git.apache.org> on 2016/06/29 19:36:38 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/06/29 21:35:10 UTC, 0 replies.
- [GitHub] flink issue #2162: FLINK-4103: Modify CsvTableSource to implement StreamTabl... - posted by fhueske <gi...@git.apache.org> on 2016/06/29 22:50:15 UTC, 1 replies.
- [GitHub] flink issue #2182: [Flink-4130] CallGenerator could generate illegal code wh... - posted by unsleepy22 <gi...@git.apache.org> on 2016/06/30 03:12:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-4130) CallGenerator could generate illegal code when taking no operands - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/06/30 05:17:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-3792) RowTypeInfo equality should not depend on field names - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/30 05:37:10 UTC, 0 replies.
- [GitHub] flink issue #2187: [FLINK-3675][yarn] improvements to library shipping - posted by stefanobaghino <gi...@git.apache.org> on 2016/06/30 06:59:00 UTC, 3 replies.
- [GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1... - posted by aljoscha <gi...@git.apache.org> on 2016/06/30 09:36:03 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4124) Unstable test WrapperSetupHelperTest.testCreateTopologyContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/30 09:49:10 UTC, 1 replies.
- [GitHub] flink issue #2186: [licenses] Remove not included dependency from LICENSE - posted by greghogan <gi...@git.apache.org> on 2016/06/30 12:20:21 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/30 12:48:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/30 12:48:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 12:55:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3822) Document checksum functions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 12:56:10 UTC, 0 replies.
- [GitHub] flink pull request #2188: [FLINK-4135] [gelly] Replace ChecksumHashCode as G... - posted by greghogan <gi...@git.apache.org> on 2016/06/30 13:11:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/06/30 13:11:10 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4124) Unstable test WrapperSetupHelperTest.testCreateTopologyContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/30 13:34:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/30 13:35:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4136) Add a JobHistory Server service - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/06/30 14:25:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/30 15:21:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 16:09:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/06/30 16:39:10 UTC, 0 replies.
- [GitHub] flink issue #2185: [FLINK-4132] [gelly] Fix boxed comparison in CommunityDet... - posted by uce <gi...@git.apache.org> on 2016/06/30 16:46:14 UTC, 0 replies.
- [GitHub] flink pull request #2189: [FLINK-3667] delay connection to JobManager until ... - posted by mxm <gi...@git.apache.org> on 2016/06/30 16:51:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-4132) Fix boxed comparison in CommunityDetection algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 19:02:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 19:02:10 UTC, 0 replies.
- [GitHub] flink pull request #2179: [FLINK-4128] compile error about git-commit-id-plu... - posted by asfgit <gi...@git.apache.org> on 2016/06/30 19:51:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4128) compile error about git-commit-id-plugin - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 19:52:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4138) error with Kinesis connector - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2016/06/30 20:20:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-4138) error with Kinesis connector - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2016/06/30 20:44:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/30 21:34:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/30 21:34:10 UTC, 0 replies.
- [GitHub] flink issue #2188: [FLINK-4135] [gelly] Replace ChecksumHashCode as GraphAna... - posted by vasia <gi...@git.apache.org> on 2016/06/30 22:08:39 UTC, 0 replies.