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

---

- [GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1... - posted by EronWright <gi...@git.apache.org> on 2016/08/01 05:08:24 UTC, 132 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 05:09:20 UTC, 145 replies.
- [GitHub] flink issue #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1) - posted by EronWright <gi...@git.apache.org> on 2016/08/01 05:10:01 UTC, 11 replies.
- [jira] [Created] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/01 07:43:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/01 07:44:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 07:47:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/01 07:52:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 07:53:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4287) Unable to access secured HBase from a yarn-session. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/01 08:02:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 08:26:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4243) Change "Scope" to "Namespace" for Metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 08:31:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4243) Change "Scope" to "Namespace" for Metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 08:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4288) Make it possible to unregister tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 08:39:20 UTC, 0 replies.
- [GitHub] flink issue #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefault... - posted by zentol <gi...@git.apache.org> on 2016/08/01 08:48:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 08:48:20 UTC, 1 replies.
- [GitHub] flink issue #2308: [FLINK-4279] [py] Set flink dependencies to provided - posted by zentol <gi...@git.apache.org> on 2016/08/01 08:48:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4279) [py] Set flink dependencies to provided - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 08:49:20 UTC, 1 replies.
- [GitHub] flink pull request #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#test... - posted by asfgit <gi...@git.apache.org> on 2016/08/01 08:52:03 UTC, 0 replies.
- [GitHub] flink pull request #2308: [FLINK-4279] [py] Set flink dependencies to provid... - posted by asfgit <gi...@git.apache.org> on 2016/08/01 08:52:03 UTC, 0 replies.
- [jira] [Closed] (FLINK-4279) [py] Set flink dependencies to provided - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 08:53:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4277) TaskManagerConfigurationTest fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 08:53:20 UTC, 0 replies.
- [GitHub] flink issue #2281: RMQ Sink: Possibility to customize queue config [FLINK-42... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/01 08:54:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 08:55:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4289) Source files have executable flag set - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 09:10:20 UTC, 0 replies.
- [GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo... - posted by twalthr <gi...@git.apache.org> on 2016/08/01 09:12:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 09:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 09:13:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 09:15:20 UTC, 0 replies.
- [GitHub] flink pull request #2316: [FLINK-4289] Unset -x flag for .java files - posted by uce <gi...@git.apache.org> on 2016/08/01 09:16:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-4289) Source files have executable flag set - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 09:17:20 UTC, 3 replies.
- [GitHub] flink issue #2316: [FLINK-4289] Unset -x flag for .java files - posted by StephanEwen <gi...@git.apache.org> on 2016/08/01 09:18:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 09:21:20 UTC, 7 replies.
- [GitHub] flink issue #2309: [FLINK-4161] Add Quickstart exclusion for flink-dist depe... - posted by mxm <gi...@git.apache.org> on 2016/08/01 09:22:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 09:23:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4291) No log entry for unscheduled reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 09:31:20 UTC, 0 replies.
- [GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by StephanEwen <gi...@git.apache.org> on 2016/08/01 09:33:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-4265) Add a NoOpOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 09:33:20 UTC, 3 replies.
- [jira] [Closed] (FLINK-4289) Source files have executable flag set - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 09:59:20 UTC, 0 replies.
- [GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta... - posted by nielsbasjes <gi...@git.apache.org> on 2016/08/01 10:00:09 UTC, 23 replies.
- [jira] [Created] (FLINK-4292) HCatalog project incorrectly set up - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 10:00:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 10:00:25 UTC, 46 replies.
- [jira] [Created] (FLINK-4293) Malformatted Apache Haders - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 10:14:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4293) Malformatted Apache Haders - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 10:14:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2016/08/01 10:39:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4287) Unable to access secured HBase from a yarn-session. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/01 11:14:20 UTC, 8 replies.
- [GitHub] flink pull request #2317: [FLINK-4287] Ensure the yarn-session.sh classpath ... - posted by nielsbasjes <gi...@git.apache.org> on 2016/08/01 11:15:23 UTC, 4 replies.
- [GitHub] flink issue #2311: [FLINK-4284] [docu] Fix broken links - posted by zentol <gi...@git.apache.org> on 2016/08/01 11:32:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 11:32:20 UTC, 1 replies.
- [GitHub] flink pull request #2311: [FLINK-4284] [docu] Fix broken links - posted by asfgit <gi...@git.apache.org> on 2016/08/01 11:34:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 11:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4294) Allow access of composite type fields - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 11:49:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4294) Allow access of composite type fields - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 11:50:20 UTC, 0 replies.
- [GitHub] flink pull request #2318: [FLINK-4291] Add log entry for scheduled reporters - posted by zentol <gi...@git.apache.org> on 2016/08/01 11:59:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-4291) No log entry for unscheduled reporters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 12:00:24 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 12:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ... - posted by twalthr <gi...@git.apache.org> on 2016/08/01 12:20:51 UTC, 11 replies.
- [jira] [Updated] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 12:21:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-4294) Allow access of composite type fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 12:21:20 UTC, 12 replies.
- [jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/01 13:01:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4295) CoGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 13:05:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/01 13:05:21 UTC, 21 replies.
- [jira] [Created] (FLINK-4296) Scheduler accepts more tasks than it has task slots available - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 13:36:20 UTC, 0 replies.
- [GitHub] flink pull request #2320: [FLINK-4297][yarn] decode URL encoded fat jar path - posted by mxm <gi...@git.apache.org> on 2016/08/01 13:39:41 UTC, 2 replies.
- [jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 13:40:20 UTC, 8 replies.
- [jira] [Created] (FLINK-4298) Clean up Storm Compatibility Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 13:58:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4296) Scheduler accepts more tasks than it has task slots available - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 14:02:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4299) Show loss of job manager in Client - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 14:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4300) Improve error message for different Scala versions of JM and Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 15:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4301) Parameterize Flink version in Quickstart bash script - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 15:32:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4301) Parameterize Flink version in Quickstart bash script - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 15:33:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4302) Add JavaDocs to MetricConfig - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 15:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2237) Add hash-based Aggregation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 15:54:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 15:59:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 16:04:20 UTC, 41 replies.
- [jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/01 16:05:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-4299) Show loss of job manager in Client - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 16:06:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4299) Show loss of job manager in Client - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 16:06:20 UTC, 0 replies.
- [GitHub] flink pull request #2321: [FLINK-4296] Fixes failure reporting of consumer t... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/01 16:07:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-4293) Malformatted Apache Headers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/01 16:12:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/01 16:17:20 UTC, 0 replies.
- [GitHub] flink issue #2321: [FLINK-4296] Fixes failure reporting of consumer task sch... - posted by uce <gi...@git.apache.org> on 2016/08/01 16:18:05 UTC, 1 replies.
- [GitHub] flink pull request #2322: [FLINK-4299] show loss of job manager in Client - posted by mxm <gi...@git.apache.org> on 2016/08/01 16:25:32 UTC, 1 replies.
- [GitHub] flink issue #2322: [FLINK-4299] show loss of job manager in Client - posted by mxm <gi...@git.apache.org> on 2016/08/01 16:25:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4302) Add JavaDocs to MetricConfig - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 16:32:20 UTC, 1 replies.
- [GitHub] flink issue #2320: [FLINK-4297][yarn] decode URL encoded fat jar path - posted by uce <gi...@git.apache.org> on 2016/08/01 16:38:00 UTC, 5 replies.
- [jira] [Created] (FLINK-4303) Add CEP examples - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 16:39:20 UTC, 0 replies.
- [GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit... - posted by vijikarthi <gi...@git.apache.org> on 2016/08/01 16:51:08 UTC, 22 replies.
- [jira] [Closed] (FLINK-4296) Scheduler accepts more tasks than it has task slots available - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 17:00:24 UTC, 0 replies.
- [jira] [Closed] (FLINK-4299) Show loss of job manager in Client - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 17:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2281: RMQ Sink: Possibility to customize queue config [F... - posted by asfgit <gi...@git.apache.org> on 2016/08/01 18:03:55 UTC, 0 replies.
- [GitHub] flink pull request #913: [FLINK-2363] [docs] First part of internals - compl... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/01 18:13:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 18:13:20 UTC, 0 replies.
- [GitHub] flink pull request #2323: [FLINK-2090] toString of CollectionInputFormat tak... - posted by mushketyk <gi...@git.apache.org> on 2016/08/01 20:29:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/01 20:30:20 UTC, 8 replies.
- [GitHub] flink issue #2323: [FLINK-2090] toString of CollectionInputFormat takes long... - posted by mushketyk <gi...@git.apache.org> on 2016/08/01 20:30:58 UTC, 6 replies.
- [jira] [Commented] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/01 20:59:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/01 21:03:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/01 21:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3414) Add Scala API for CEP's pattern definition - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/01 21:08:20 UTC, 0 replies.
- [GitHub] flink pull request #2324: Bump version to 1.2-SNAPSHOT - posted by mbalassi <gi...@git.apache.org> on 2016/08/01 23:28:04 UTC, 1 replies.
- [GitHub] flink issue #2317: [FLINK-4287] Ensure the yarn-session.sh classpath contain... - posted by mxm <gi...@git.apache.org> on 2016/08/02 09:00:35 UTC, 2 replies.
- [jira] [Updated] (FLINK-4300) Improve error message for different Scala versions of JM and Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 09:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4303) Add CEP examples - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 09:15:20 UTC, 0 replies.
- [GitHub] flink pull request #2325: [cleanup] remove unused code - posted by mxm <gi...@git.apache.org> on 2016/08/02 09:17:47 UTC, 1 replies.
- [jira] [Created] (FLINK-4304) Jar names that contain whitespace cause problems in web client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 09:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4305) Build pull requests with Jenkins - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/02 09:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4305) Build pull requests with Jenkins - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 09:50:20 UTC, 4 replies.
- [GitHub] flink pull request #2326: [FLINK-4305] test Jenkins GitHub integration - posted by mxm <gi...@git.apache.org> on 2016/08/02 09:50:20 UTC, 1 replies.
- [GitHub] flink issue #2324: Bump version to 1.2-SNAPSHOT - posted by StephanEwen <gi...@git.apache.org> on 2016/08/02 10:05:31 UTC, 9 replies.
- [GitHub] flink issue #2326: [FLINK-4305] test Jenkins GitHub integration - posted by StephanEwen <gi...@git.apache.org> on 2016/08/02 10:23:41 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:45:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:47:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:48:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4298) Clean up Storm Compatibility Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:49:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4298) Clean up Storm Compatibility Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:50:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:51:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:51:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:52:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:52:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4292) HCatalog project incorrectly set up - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:56:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4292) HCatalog project incorrectly set up - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 10:56:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/02 10:59:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/02 11:36:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-4305) Build pull requests with Jenkins - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/02 11:42:20 UTC, 0 replies.
- [GitHub] flink issue #2149: [FLINK-4084] Add configDir parameter to CliFrontend and f... - posted by alkagin <gi...@git.apache.org> on 2016/08/02 11:44:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 11:44:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 12:19:20 UTC, 0 replies.
- [GitHub] flink pull request #2327: [FLINK-4304] [runtime-web] Jar names that contain ... - posted by twalthr <gi...@git.apache.org> on 2016/08/02 12:57:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-4304) Jar names that contain whitespace cause problems in web client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 12:58:20 UTC, 4 replies.
- [jira] [Updated] (FLINK-4304) Jar names that contain whitespace cause problems in web client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 13:00:23 UTC, 3 replies.
- [GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector - posted by StephanEwen <gi...@git.apache.org> on 2016/08/02 13:05:49 UTC, 21 replies.
- [jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 13:06:20 UTC, 53 replies.
- [GitHub] flink issue #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL and Strea... - posted by twalthr <gi...@git.apache.org> on 2016/08/02 13:07:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4180) Create a batch SQL example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 13:08:20 UTC, 1 replies.
- [GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc... - posted by mxm <gi...@git.apache.org> on 2016/08/02 14:11:24 UTC, 16 replies.
- [jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 14:12:20 UTC, 46 replies.
- [GitHub] flink pull request #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL an... - posted by asfgit <gi...@git.apache.org> on 2016/08/02 14:26:36 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4180) Create a batch SQL example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 14:29:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4181) Add a basic streaming Table API example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 14:30:20 UTC, 0 replies.
- [GitHub] flink issue #2293: [FLINK-4203] [table] [docs] Improve Table API documentati... - posted by twalthr <gi...@git.apache.org> on 2016/08/02 14:36:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-4203) Improve Table API documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 14:37:20 UTC, 1 replies.
- [GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex... - posted by mxm <gi...@git.apache.org> on 2016/08/02 14:37:20 UTC, 17 replies.
- [GitHub] flink issue #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() expects ... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/02 14:40:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 14:40:20 UTC, 2 replies.
- [GitHub] flink issue #2297: [FLINK-4081] [core] [table] FieldParsers should support e... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/02 14:41:50 UTC, 5 replies.
- [GitHub] flink pull request #2293: [FLINK-4203] [table] [docs] Improve Table API docu... - posted by asfgit <gi...@git.apache.org> on 2016/08/02 14:42:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-4081) FieldParsers should support empty strings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 14:42:20 UTC, 5 replies.
- [jira] [Resolved] (FLINK-4203) Improve Table API documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 14:44:20 UTC, 0 replies.
- [GitHub] flink pull request #2282: [FLINK-3940] [table] Add support for ORDER BY OFFS... - posted by twalthr <gi...@git.apache.org> on 2016/08/02 14:56:40 UTC, 15 replies.
- [jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 14:57:20 UTC, 17 replies.
- [GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/02 15:08:32 UTC, 28 replies.
- [jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 15:09:20 UTC, 29 replies.
- [jira] [Resolved] (FLINK-4246) Allow Specifying Multiple Metrics Reporters - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/02 15:12:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4224) Exception after successful execution os job submitted through the web interface. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/02 15:13:21 UTC, 1 replies.
- [GitHub] flink issue #2327: [FLINK-4304] [runtime-web] Jar names that contain whitesp... - posted by mxm <gi...@git.apache.org> on 2016/08/02 15:49:34 UTC, 2 replies.
- [jira] [Created] (FLINK-4307) Broken user-facing API for ListState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 16:18:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 16:34:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 16:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/02 17:57:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/02 17:59:21 UTC, 1 replies.
- [GitHub] flink issue #2051: [FLINK-3779] Add support for queryable state - posted by rehevkor5 <gi...@git.apache.org> on 2016/08/02 18:03:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-3779) Add support for queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/02 18:04:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-4307) Broken user-facing API for ListState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 19:48:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4307) Broken user-facing API for ListState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 19:48:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4262) Consider null handling during sorting - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/02 21:44:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4262) Consider null handling during sorting - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/02 21:44:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/02 21:58:20 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/02 21:58:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/03 01:17:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4224) Exception after successful execution os job submitted through the web interface. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/03 02:06: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/08/03 03:57:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/03 04:10:20 UTC, 7 replies.
- [jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/03 06:40:20 UTC, 17 replies.
- [jira] [Comment Edited] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/03 06:45:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/03 06:45:20 UTC, 12 replies.
- [jira] [Commented] (FLINK-3950) Add Meter Metric Type - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/03 07:17:20 UTC, 36 replies.
- [jira] [Commented] (FLINK-4256) Fine-grained recovery - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/03 07:17:20 UTC, 3 replies.
- [GitHub] flink pull request #2328: [hotfix] Fix TypeExtractor. - posted by chermenin <gi...@git.apache.org> on 2016/08/03 07:44:39 UTC, 1 replies.
- [GitHub] flink issue #2328: [hotfix] Fix TypeExtractor. - posted by twalthr <gi...@git.apache.org> on 2016/08/03 07:48:44 UTC, 1 replies.
- [jira] [Created] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/03 12:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4311) TableInputFormat fails when reused on next split - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/03 12:30:20 UTC, 0 replies.
- [GitHub] flink pull request #2329: [FLINK-3138] [types] Method References are not sup... - posted by twalthr <gi...@git.apache.org> on 2016/08/03 12:45:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-3138) Method References are not supported as lambda expressions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/03 12:45:20 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/03 12:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor... - posted by nielsbasjes <gi...@git.apache.org> on 2016/08/03 13:07:55 UTC, 4 replies.
- [jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/03 13:08:20 UTC, 17 replies.
- [GitHub] flink issue #2330: FLINK-4311 Fixed several problems in TableInputFormat - posted by nielsbasjes <gi...@git.apache.org> on 2016/08/03 13:13:20 UTC, 12 replies.
- [GitHub] flink issue #2290: [FLINK-4242] [table] Improve validation exception message... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/03 13:24:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-4242) Improve validation exception messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/03 13:24:20 UTC, 2 replies.
- [GitHub] flink pull request #2331: [FLINK-4282] [streaming] Added an offset parameter... - posted by aditivin <gi...@git.apache.org> on 2016/08/03 15:50:27 UTC, 1 replies.
- [GitHub] flink issue #2331: [FLINK-4282] [streaming] Added an offset parameter for pr... - posted by aljoscha <gi...@git.apache.org> on 2016/08/03 16:16:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/08/03 18:03:20 UTC, 25 replies.
- [jira] [Comment Edited] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/08/03 18:04:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/08/03 21:02:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/08/03 21:29:20 UTC, 9 replies.
- [jira] [Commented] (FLINK-4288) Make it possible to unregister tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/04 03:36:20 UTC, 0 replies.
- [GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink - posted by delding <gi...@git.apache.org> on 2016/08/04 08:37:03 UTC, 32 replies.
- [jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/04 08:37:21 UTC, 45 replies.
- [GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink - posted by delding <gi...@git.apache.org> on 2016/08/04 08:42:46 UTC, 13 replies.
- [GitHub] flink pull request #2309: [FLINK-4161] Add Quickstart exclusion for flink-di... - posted by asfgit <gi...@git.apache.org> on 2016/08/04 09:26:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 09:26:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 09:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2333: [FLINK-4282] [streaming] Add Offset Parameter to W... - posted by aditivin <gi...@git.apache.org> on 2016/08/04 10:59:03 UTC, 1 replies.
- [GitHub] flink issue #2288: Feature/s3 a fix - posted by StephanEwen <gi...@git.apache.org> on 2016/08/04 12:11:18 UTC, 6 replies.
- [jira] [Commented] (FLINK-2042) Increase font size for stack figure on website home - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 12:25:20 UTC, 0 replies.
- [GitHub] flink issue #2251: [FLINK-4212] [scripts] Lock PID file when starting daemon... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/04 12:31:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-4212) Lock PID file when starting daemons - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/04 12:32:20 UTC, 3 replies.
- [GitHub] flink issue #2253: [FLINK-4219] [scripts] Quote PDSH opts in start-cluster.s... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/04 12:32:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-4219) Quote PDSH opts in start-cluster.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/04 12:33:20 UTC, 1 replies.
- [GitHub] flink issue #2114: FLINK-3839 Added the extraction of jar files from a URL s... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/04 12:42:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/04 12:43:20 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/04 14:07:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/04 14:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4312) Remove Serializabiliy of ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 14:49:20 UTC, 0 replies.
- [GitHub] flink pull request #2334: [FLINK-4310] [build] Selectively run API compatibi... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/04 16:38:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/04 16:39:20 UTC, 5 replies.
- [GitHub] flink issue #2334: [FLINK-4310] [build] Selectively run API compatibility ch... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/04 16:48:43 UTC, 3 replies.
- [jira] [Created] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 17:09:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/04 21:06:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3703) Add sequence matching semantics to discard matched events - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/04 21:06:20 UTC, 0 replies.
- [GitHub] flink pull request #2335: [FLINK-4308] Allow uploaded jar directory to be co... - posted by zhenzhongxu <gi...@git.apache.org> on 2016/08/04 22:01:50 UTC, 1 replies.
- [GitHub] flink issue #2333: [FLINK-4282] [streaming] Add Offset Parameter to WindowAs... - posted by aljoscha <gi...@git.apache.org> on 2016/08/04 23:28:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-4312) Remove Serializabiliy of ExecutionGraph - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/04 23:29:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/04 23:35:20 UTC, 0 replies.
- [GitHub] flink issue #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to Kafka 0... - posted by tzulitai <gi...@git.apache.org> on 2016/08/05 05:54:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/05 05:54:20 UTC, 40 replies.
- [GitHub] flink pull request #2336: FLINK-4094 Off heap memory deallocation might not ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/05 05:57:12 UTC, 3 replies.
- [GitHub] flink pull request #2231: [FLINK-4035] Bump Kafka producer in Kafka sink to ... - posted by tzulitai <gi...@git.apache.org> on 2016/08/05 06:21:48 UTC, 4 replies.
- [GitHub] flink issue #2282: [FLINK-3940] [table] Add support for ORDER BY OFFSET FETC... - posted by gallenvara <gi...@git.apache.org> on 2016/08/05 06:40:53 UTC, 1 replies.
- [jira] [Closed] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:22:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3690) Create documentation on the new ResourceManager component - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:23:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4102) Test failure with checkpoint barriers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:23:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4094) Off heap memory deallocation might not properly work - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:23:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:25:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3828) flink-runtime - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:27:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3830) flink-scala - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:27:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:27:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3829) flink-java - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:27:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3827) Flink modules include unused dependencies - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:27:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3831) flink-streaming-java - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3833) flink-test-utils - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3832) flink-streaming-scala - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3834) flink-statebackend-rocksdb - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3950) Add Meter Metric Type - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:29:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4047) Fix documentation about determinism of KeySelectors - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:29:20 UTC, 0 replies.
- [GitHub] flink pull request #2253: [FLINK-4219] [scripts] Quote PDSH opts in start-cl... - posted by asfgit <gi...@git.apache.org> on 2016/08/05 08:32:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-4219) Quote PDSH opts in start-cluster.sh - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:35:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4257) Handle delegating algorithm change of class - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:35:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4104) Restructure Gelly docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:36:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:36:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4265) Add a NoOpOperator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:37:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 08:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4314) Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 09:34:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4314) Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 09:54:20 UTC, 0 replies.
- [GitHub] flink issue #2335: [FLINK-4308] Allow uploaded jar directory to be configura... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 09:59:37 UTC, 0 replies.
- [GitHub] flink issue #2336: FLINK-4094 Off heap memory deallocation might not properl... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 10:12:48 UTC, 1 replies.
- [jira] [Created] (FLINK-4315) Remove Hadoop Dependency from flink-java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 10:27:20 UTC, 0 replies.
- [GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ... - posted by twalthr <gi...@git.apache.org> on 2016/08/05 12:06:28 UTC, 3 replies.
- [jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/05 12:07:20 UTC, 8 replies.
- [jira] [Created] (FLINK-4316) Make flink-core independent of Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 12:22:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 12:26:20 UTC, 6 replies.
- [GitHub] flink pull request #2338: [FLINK-4316] [core] [hadoop compatibility] Make fl... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 12:31:53 UTC, 1 replies.
- [jira] [Created] (FLINK-4317) Restructure documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 12:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4318) Make master docs build target version-specific - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 13:10:20 UTC, 0 replies.
- [GitHub] flink issue #2338: [FLINK-4316] [core] [hadoop compatibility] Make flink-cor... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 13:20:30 UTC, 3 replies.
- [GitHub] flink issue #2312: [FLINK-4276] Fix TextInputFormatTest#testNestedFileRead - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 13:30:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/05 13:31:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability" - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/05 13:32:20 UTC, 28 replies.
- [jira] [Assigned] (FLINK-4253) Rename "recovery.mode" config key to "high-availability" - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/05 13:32:20 UTC, 0 replies.
- [GitHub] flink issue #2329: [FLINK-3138] [types] Method References are not supported ... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 13:46:52 UTC, 1 replies.
- [GitHub] flink issue #2318: [FLINK-4291] Add log entry for scheduled reporters - posted by StephanEwen <gi...@git.apache.org> on 2016/08/05 14:02:44 UTC, 1 replies.
- [jira] [Closed] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 14:06:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 14:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4319) Rework Cluster Management (FLIP-6) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 14:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4320) Fix misleading ScheduleMode names - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 15:47:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4318) Make master docs build target version-specific - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 16:00:22 UTC, 1 replies.
- [jira] [Created] (FLINK-4321) Initialize TaskExecutions directly with their starting state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 16:44:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 17:42:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/05 17:55:20 UTC, 19 replies.
- [jira] [Resolved] (FLINK-4312) Remove Serializabiliy of ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:01:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4312) Remove Serializabiliy of ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:01:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:05:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:11:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:16:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4324) Enable Akka SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/05 19:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4325) Implement Web UI HTTPS - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/05 19:10:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 19:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/06 00:02:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4266) Remote Storage Statebackend - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/08/06 04:14:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4266) Remote Database Statebackend - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/08/06 04:36:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1638) SimpleKafkaSource connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/06 04:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4266) Remote Database Statebackend - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/08/06 04:53:20 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3298) Streaming connector for ActiveMQ - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/06 05:36:20 UTC, 0 replies.
- [GitHub] flink pull request #2339: [FLINK-3318] Implement one or many and optional qu... - posted by mushketyk <gi...@git.apache.org> on 2016/08/06 18:33:15 UTC, 1 replies.
- [GitHub] flink issue #2339: [FLINK-3318] Implement one or many and optional quantifie... - posted by mushketyk <gi...@git.apache.org> on 2016/08/06 18:36:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/06 19:41:20 UTC, 0 replies.
- [GitHub] flink issue #2244: [FLINK-3874] Add a Kafka TableSink with JSON serializatio... - posted by mushketyk <gi...@git.apache.org> on 2016/08/06 19:43:22 UTC, 25 replies.
- [jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/06 19:44:20 UTC, 90 replies.
- [GitHub] flink pull request #2053: [FLINK-1707] Affinity Propagation - posted by joseprupi <gi...@git.apache.org> on 2016/08/06 21:32:56 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3026) Publish the flink docker container to the docker registry - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/08/07 10:53:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/08/07 10:55:20 UTC, 0 replies.
- [GitHub] flink pull request #2340: [FLINK-3155] Update docker flink container to the ... - posted by iemejia <gi...@git.apache.org> on 2016/08/07 11:02:35 UTC, 9 replies.
- [jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/07 11:03:20 UTC, 19 replies.
- [GitHub] flink issue #2340: [FLINK-3155] Update docker flink container to the latest ... - posted by iemejia <gi...@git.apache.org> on 2016/08/07 11:04:22 UTC, 9 replies.
- [jira] [Updated] (FLINK-3155) Update Flink docker version to latest stable Flink version - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/08/07 11:15:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4327) Error in link to downlad version for hadoop 2.7 and scala 2.11 - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/08/07 11:30:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-4327) Error in link to downlad version for hadoop 2.7 and scala 2.11 - posted by "Ahmad Ragab (JIRA)" <ji...@apache.org> on 2016/08/07 20:11:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4327) Error in link to downlad version for hadoop 2.7 and scala 2.11 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/07 20:22:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/08 08:15:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4328) Harden JobManagerHA*ITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/08 08:20:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4304) Jar names that contain whitespace cause problems in web client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/08 09:08:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3138) Method References are not supported as lambda expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/08 09:19:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/08 09:30:20 UTC, 15 replies.
- [GitHub] flink issue #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to let typ... - posted by twalthr <gi...@git.apache.org> on 2016/08/08 09:31:23 UTC, 4 replies.
- [jira] [Created] (FLINK-4329) Streaming File Source Must Correctly Handle Timestamps/Watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/08 12:00:25 UTC, 0 replies.
- [GitHub] flink issue #2261: [FLINK-4226] Typo: Define Keys using Field Expressions ex... - posted by rmetzger <gi...@git.apache.org> on 2016/08/08 12:51:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/08 12:52:20 UTC, 4 replies.
- [jira] [Closed] (FLINK-4226) Typo: Define Keys using Field Expressions example should use window and not reduce - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/08 12:54:20 UTC, 0 replies.
- [GitHub] flink pull request #2261: [FLINK-4226] Typo: Define Keys using Field Express... - posted by ASRagab <gi...@git.apache.org> on 2016/08/08 13:04:56 UTC, 0 replies.
- [jira] [Closed] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/08 13:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2312: [FLINK-4276] Fix TextInputFormatTest#testNestedFil... - posted by asfgit <gi...@git.apache.org> on 2016/08/08 13:12:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-4291) No log entry for unscheduled reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/08 13:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/08 13:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Pushpendra Jaiswal (JIRA)" <ji...@apache.org> on 2016/08/08 14:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 16:24:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4332) Savepoint Serializer mixed read()/readFully() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 17:16:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4333) Name mixup in Savepoint versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 17:18:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4333) Name mixup in Savepoint versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 17:18:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 18:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/08/08 20:22:21 UTC, 0 replies.
- [GitHub] flink pull request #2341: [FLINK-4334] [quickstarts] Correctly exclude hadoo... - posted by rehevkor5 <gi...@git.apache.org> on 2016/08/08 20:29:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/08 20:30:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4335) Add jar id, and job parameters information to job status rest call - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/08 23:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4336) Expose ability to take a savepoint from job manager rest api - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/08 23:31:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4335) Add jar id, and job parameters information to job status rest call - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/08 23:35:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4320) Fix misleading ScheduleMode names - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:29:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4332) Savepoint Serializer mixed read()/readFully() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:29:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4320) Fix misleading ScheduleMode names - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:29:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4332) Savepoint Serializer mixed read()/readFully() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:29:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4333) Name mixup in Savepoint versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:30:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4333) Name mixup in Savepoint versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:30:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4329) Streaming File Source Must Correctly Handle Timestamps/Watermarks - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/09 08:33:20 UTC, 0 replies.
- [GitHub] flink issue #2341: [FLINK-4334] [quickstarts] Correctly exclude hadoop1 in q... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/09 08:33:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:35:20 UTC, 0 replies.
- [GitHub] flink pull request #2342: FLINK-4253 - Rename "recovery.mode" config key to ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/09 09:21:38 UTC, 6 replies.
- [jira] [Created] (FLINK-4338) Implement Slot Pool - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 09:35:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4338) Implement Slot Pool - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 09:36:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4339) Implement Slot Pool Core - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 09:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/09 10:16:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/09 10:19:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 11:56:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 11:57:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 12:03:20 UTC, 0 replies.
- [GitHub] flink pull request #2343: [FLINK-4337] [build] Remove unnecessary Scala Suff... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/09 12:09:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/09 12:10:20 UTC, 1 replies.
- [GitHub] flink pull request #2344: [hotfix][build] Remove Scala suffix from Hadoop1 s... - posted by rmetzger <gi...@git.apache.org> on 2016/08/09 12:41:34 UTC, 1 replies.
- [jira] [Created] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/09 13:08:20 UTC, 0 replies.
- [GitHub] flink issue #2002: Support for bz2 compression in flink-core - posted by mtanski <gi...@git.apache.org> on 2016/08/09 13:16:31 UTC, 3 replies.
- [GitHub] flink pull request #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint ... - posted by aljoscha <gi...@git.apache.org> on 2016/08/09 13:18:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/09 13:19:20 UTC, 25 replies.
- [GitHub] flink issue #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint Mode - posted by aljoscha <gi...@git.apache.org> on 2016/08/09 13:19:51 UTC, 22 replies.
- [GitHub] flink pull request #2251: [FLINK-4212] [scripts] Lock PID file when starting... - posted by greghogan <gi...@git.apache.org> on 2016/08/09 13:32:52 UTC, 0 replies.
- [jira] [Closed] (FLINK-4212) Lock PID file when starting daemons - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/09 13:34:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 13:35:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 13:35:20 UTC, 0 replies.
- [GitHub] flink issue #2344: [hotfix][build] Remove Scala suffix from Hadoop1 shading ... - posted by uce <gi...@git.apache.org> on 2016/08/09 14:46:38 UTC, 1 replies.
- [GitHub] flink pull request #2051: [FLINK-3779] Add support for queryable state - posted by asfgit <gi...@git.apache.org> on 2016/08/09 14:48:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-3779) Add support for queryable state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/09 14:51:20 UTC, 0 replies.
- [GitHub] flink issue #2289: [FLINK-3866] StringArraySerializer type should be mutable - posted by mushketyk <gi...@git.apache.org> on 2016/08/09 15:22:20 UTC, 6 replies.
- [jira] [Commented] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/09 15:22:20 UTC, 7 replies.
- [jira] [Updated] (FLINK-4329) Fixes Streaming File Source Timestamps/Watermarks Handling - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/09 16:37:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 18:00:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 18:00:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/09 18:15:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-3623) Adjust MurmurHash algorithm - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/09 19:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/08/09 20:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4342) Fix dependencies of flink-connector-filesystem - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 20:50:20 UTC, 0 replies.
- [GitHub] flink pull request #2346: [FLINK-4342] [build] Fix dependencies of flink-con... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/09 20:53:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-4342) Fix dependencies of flink-connector-filesystem - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/09 20:53:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/08/09 21:55:20 UTC, 10 replies.
- [jira] [Created] (FLINK-4343) Implement new TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:04:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4319) Rework Cluster Management (FLIP-6) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:04:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:09:20 UTC, 6 replies.
- [jira] [Created] (FLINK-4344) Implement new JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4345) Implement new ResourceManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:33:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4346) Implement basic RPC abstraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4347) Implement SlotManager for new ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/10 03:12:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4347) Implement SlotManager for new ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/10 03:29:22 UTC, 0 replies.
- [GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/10 04:12:25 UTC, 20 replies.
- [jira] [Created] (FLINK-4348) implement communication from ResourceManager to TaskManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/10 08:31:20 UTC, 0 replies.
- [GitHub] flink issue #2346: [FLINK-4342] [build] Fix dependencies of flink-connector-... - posted by aljoscha <gi...@git.apache.org> on 2016/08/10 08:43:40 UTC, 0 replies.
- [jira] [Created] (FLINK-4349) ResourceManager interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 08:44:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4349) ResourceManager interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 08:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4350) ResourceManager interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 08:53:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/10 08:54:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4351) TaskExecutor interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:00:29 UTC, 0 replies.
- [jira] [Created] (FLINK-4352) JobClient interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4353) cluster components failure process - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4354) TaskManager to ResourceManager heartbeats - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4355) TaskManager registration at ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:20:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4354) TaskManager to ResourceManager heartbeats - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4356) JobMaster HA - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:24:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4350) interaction between new JobMaster and new ResourceManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:25:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4350) interaction between new JobManager and new ResourceManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:26:21 UTC, 1 replies.
- [jira] [Updated] (FLINK-4351) interaction between new JobManager and new TaskManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4352) interaction between new JobManager and JobClient - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:29:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4353) new JobManager handle cluster components failure - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:30:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4356) new JobManager HA - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4357) TaskManager responses slot allocation - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:37:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4354) TaskManager responses ResourceManager heartbeats - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:39:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4354) TaskManager responses heartbeats from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:41:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4357) TaskManager responses slot allocation from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:42:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4316) Make flink-core independent of Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 09:45:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4316) Make flink-core independent of Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 09:45:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4358) TaskManager deploys task into slot - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4359) Add INTERVAL type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/10 09:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4360) TaskManager slot registration at JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:00:25 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/10 10:04:20 UTC, 3 replies.
- [jira] [Resolved] (FLINK-4342) Fix dependencies of flink-connector-filesystem - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:05:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4342) Fix dependencies of flink-connector-filesystem - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:05:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4346) Implement basic RPC abstraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:08:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4361) Replace Scala Futures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4362) Auto generate message sender classes via Java Proxies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:09:20 UTC, 0 replies.
- [GitHub] flink pull request #2347: [FLINK-4236] fix error handling for jar files with... - posted by mxm <gi...@git.apache.org> on 2016/08/10 10:12:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 10:13:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4363) TaskManager basic startup of all components - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:15:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4355) TaskManager registration at ResourceManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:16:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4355) TaskManager registration at ResourceManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:19:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4363) TaskManager basic startup of all components - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:24:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4363) TaskManager basic startup of all components - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:24:20 UTC, 0 replies.
- [GitHub] flink issue #2347: [FLINK-4236] fix error handling for jar files with no mai... - posted by zentol <gi...@git.apache.org> on 2016/08/10 10:43:01 UTC, 3 replies.
- [jira] [Updated] (FLINK-4358) TaskManager deploys task into slot - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4364) TaskManage responses heartbeats from JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:54:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3445) make JDBCInputFormat implement ResultTypeQueryable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/10 10:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4365) [metrics] MetricConfig has no documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/10 11:43:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3690) Create documentation on the new ResourceManager component - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/10 11:45:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4318) Make master docs build target version-specific - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/10 11:51:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/10 12:06:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4359) Add INTERVAL type - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/10 12:37:20 UTC, 10 replies.
- [GitHub] flink pull request #2348: [FLINK-4359] [table] Add INTERVAL type - posted by twalthr <gi...@git.apache.org> on 2016/08/10 12:38:16 UTC, 1 replies.
- [GitHub] flink issue #2348: [FLINK-4359] [table] Add INTERVAL type - posted by twalthr <gi...@git.apache.org> on 2016/08/10 12:39:07 UTC, 4 replies.
- [jira] [Commented] (FLINK-4335) Add jar id, and job parameters information to job status rest call - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/10 13:09:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4336) Expose ability to take a savepoint from job manager rest api - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/10 13:19:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-4336) Expose ability to take a savepoint from job manager rest api - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/10 13:19:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/10 13:24:22 UTC, 0 replies.
- [GitHub] flink pull request #2349: [FLINK-4365] [metrics] Add documentation to Metric... - posted by zentol <gi...@git.apache.org> on 2016/08/10 14:24:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-4365) [metrics] MetricConfig has no documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 14:25:20 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Pushpendra Jaiswal (JIRA)" <ji...@apache.org> on 2016/08/10 14:36:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/10 14:49:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Pushpendra Jaiswal (JIRA)" <ji...@apache.org> on 2016/08/10 15:06:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Pushpendra Jaiswal (JIRA)" <ji...@apache.org> on 2016/08/10 15:18:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Pushpendra Jaiswal (JIRA)" <ji...@apache.org> on 2016/08/10 15:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4368) Eagerly initialize RrcProtocol members - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 16:27:20 UTC, 0 replies.
- [GitHub] flink pull request #2350: [FLINK-4329] Fix Streaming File Source Timestamps/... - posted by kl0u <gi...@git.apache.org> on 2016/08/10 16:31:33 UTC, 12 replies.
- [GitHub] flink pull request #2351: [FLINK-4368] [distributed runtime] Eagerly initial... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/10 16:31:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 16:32:20 UTC, 17 replies.
- [jira] [Commented] (FLINK-4368) Eagerly initialize RrcProtocol members - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 16:32:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4369) Evictingwindowoperator Must Actually Evict Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/10 17:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 17:22:20 UTC, 0 replies.
- [GitHub] flink pull request #2352: [FLINK-4370] Add an IntelliJ Inspections Profile - posted by StephanEwen <gi...@git.apache.org> on 2016/08/10 17:29:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 17:30:21 UTC, 10 replies.
- [jira] [Updated] (FLINK-4336) Expose ability to take a savepoint from job manager - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/10 18:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4371) Add ability to take savepoints from job manager RESTful API - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/10 18:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4372) Add ability to take savepoints from job manager web UI - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/10 18:14:20 UTC, 0 replies.
- [GitHub] flink issue #2351: [FLINK-4368] [distributed runtime] Eagerly initialize the... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/10 18:31:48 UTC, 3 replies.
- [GitHub] flink issue #2258: [FLINK-4104] [docs] Restructure Gelly docs - posted by vasia <gi...@git.apache.org> on 2016/08/10 19:48:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4104) Restructure Gelly docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 19:49:20 UTC, 1 replies.
- [GitHub] flink pull request #2353: [FLINK-4355] [cluster management] Implement TaskMa... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/10 21:59:25 UTC, 6 replies.
- [jira] [Commented] (FLINK-4355) TaskManager registration at ResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/10 22:00:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/11 01:41:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4354) TaskManager responses heartbeats from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:27:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4354) Implement TaskManager side of heartbeat from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4357) Implement TaskManager side slot allocation from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:38:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:39:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4355) Implement TaskManager side of registration at ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:40:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4358) Implement TaskManager deployment task into slot - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:42:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4360) Implement TaskManager offer slot to JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:45:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4360) Implement TaskManager registration slot at JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:49:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4363) Implement TaskManager basic startup of all components in java - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:50:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4364) Implement TaskManager side of heartbeats from JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:54:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4364) Implement TaskManager side of heartbeat from JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:55:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4360) Implement TaskManager registration slot at JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:56:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/11 03:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4373) Introduce SlotID & ResourceProfile - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/11 07:42:20 UTC, 0 replies.
- [GitHub] flink issue #2352: [FLINK-4370] Add an IntelliJ Inspections Profile - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/11 07:51:26 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4373) Introduce SlotID & ResourceProfile - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/11 08:00:34 UTC, 0 replies.
- [GitHub] flink issue #2306: [FLINK-4270] [table] fix 'as' in front of join does not w... - posted by wuchong <gi...@git.apache.org> on 2016/08/11 08:06:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-4270) 'as' in front of join does not work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/11 08:06:20 UTC, 2 replies.
- [GitHub] flink pull request #2354: [FLINK-4366] Enforce parallelism=1 For AllWindowed... - posted by wuchong <gi...@git.apache.org> on 2016/08/11 08:17:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/11 08:17:20 UTC, 10 replies.
- [jira] [Resolved] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/11 08:32:20 UTC, 0 replies.
- [GitHub] flink pull request #2244: [FLINK-3874] Add a Kafka TableSink with JSON seria... - posted by twalthr <gi...@git.apache.org> on 2016/08/11 08:46:35 UTC, 64 replies.
- [jira] [Updated] (FLINK-4344) Implement new JobManager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 09:08:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-1638) SimpleKafkaSource connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/11 09:13:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/11 09:29:20 UTC, 0 replies.
- [GitHub] flink pull request #2306: [FLINK-4270] [table] fix 'as' in front of join doe... - posted by asfgit <gi...@git.apache.org> on 2016/08/11 10:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4270) 'as' in front of join does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/11 10:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4374) GroupReduce Broken for null Date - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/11 10:35:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4374) GroupReduce Broken for null Date - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/11 10:36:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4374) GroupReduce Broken for null Date - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/11 10:36:20 UTC, 0 replies.
- [GitHub] flink issue #2354: [FLINK-4366] Enforce parallelism=1 For AllWindowedStream - posted by aljoscha <gi...@git.apache.org> on 2016/08/11 12:08:01 UTC, 8 replies.
- [jira] [Created] (FLINK-4375) defined rpc protocols provided by job manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 12:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4375) define rpc protocols provided by job manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 12:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4376) implement job manager init procedure - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 12:22:20 UTC, 0 replies.
- [GitHub] flink issue #2350: [FLINK-4329] Fix Streaming File Source Timestamps/Waterma... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/11 12:23:10 UTC, 4 replies.
- [GitHub] flink pull request #2290: [FLINK-4242] [table] Improve validation exception ... - posted by asfgit <gi...@git.apache.org> on 2016/08/11 12:23:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4242) Improve validation exception messages - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/11 12:24:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4359) Add INTERVAL type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/11 12:43:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4374) GroupReduce Broken for null Date - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 12:51:20 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-4374) GroupReduce Broken for null Date - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/11 12:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2355: [FLINK-4282]Add Offset Parameter to WindowAssigner... - posted by Renkai <gi...@git.apache.org> on 2016/08/11 12:56:44 UTC, 7 replies.
- [jira] [Created] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/08/11 13:00:24 UTC, 0 replies.
- [jira] [Created] (FLINK-4378) Enable RollingSink to custom HDFS client configuration - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 13:33:20 UTC, 0 replies.
- [GitHub] flink pull request #2356: [FLINK-4378]Enable RollingSink to custom HDFS clie... - posted by wenlong88 <gi...@git.apache.org> on 2016/08/11 13:36:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/11 13:36:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4379) Add Rescalable Non-Partitioned State - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/11 13:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/11 13:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4381) Refactor State to Prepare For Key-Group State Backends - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/11 14:03:20 UTC, 0 replies.
- [GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/11 14:15:12 UTC, 10 replies.
- [jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/11 14:15:21 UTC, 14 replies.
- [jira] [Updated] (FLINK-4368) Eagerly initialize RrcProtocol members - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 14:18:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4368) Eagerly initialize RrcProtocol members - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 14:18:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 14:37:20 UTC, 2 replies.
- [GitHub] flink issue #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via Java pr... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/11 15:01:18 UTC, 3 replies.
- [jira] [Created] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 15:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 15:21:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4368) Eagerly initialize RrcProtocol members - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 15:29:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 15:31:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 15:32:20 UTC, 0 replies.
- [GitHub] flink pull request #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoin... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/11 16:36:55 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 16:38:20 UTC, 0 replies.
- [GitHub] flink pull request #2359: [FLINK-4198] Replace org.apache.flink.streaming.ap... - posted by kishorekgarg <gi...@git.apache.org> on 2016/08/11 16:47:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/11 16:47:20 UTC, 4 replies.
- [GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/11 17:22:36 UTC, 6 replies.
- [jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/11 17:23:20 UTC, 9 replies.
- [GitHub] flink issue #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoint has b... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/11 17:28:43 UTC, 2 replies.
- [jira] [Created] (FLINK-4385) Union on Timestamp fields does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/11 17:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 18:01:20 UTC, 0 replies.
- [GitHub] flink issue #2359: [FLINK-4198] Replace org.apache.flink.streaming.api.windo... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/11 19:10:21 UTC, 2 replies.
- [GitHub] flink pull request #2361: [FLINK-3318][cep] Add support for quantifiers to C... - posted by mushketyk <gi...@git.apache.org> on 2016/08/11 21:12:22 UTC, 2 replies.
- [GitHub] flink issue #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa... - posted by mushketyk <gi...@git.apache.org> on 2016/08/11 21:15:28 UTC, 2 replies.
- [jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 02:15:21 UTC, 15 replies.
- [GitHub] flink issue #1963: [FLINK-3870][docs] Added IntelliJ code style - posted by wuchong <gi...@git.apache.org> on 2016/08/12 02:15:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3870) Add IntelliJ code style file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 02:16:20 UTC, 1 replies.
- [GitHub] flink pull request #1963: [FLINK-3870][docs] Added IntelliJ code style - posted by wuchong <gi...@git.apache.org> on 2016/08/12 03:29:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-4375) Introduce rpc protocols implemented by job manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/12 05:21:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4347) Implement SlotManager for new ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/12 05:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/12 06:58:20 UTC, 1 replies.
- [GitHub] flink issue #2313: [FLINK-4273] Modify JobClient to attach to running jobs - posted by mxm <gi...@git.apache.org> on 2016/08/12 07:50:48 UTC, 10 replies.
- [jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 07:51:20 UTC, 50 replies.
- [jira] [Created] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/12 08:27:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/12 08:27:20 UTC, 0 replies.
- [GitHub] flink issue #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEnd... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/12 09:20:39 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4385) Union on Timestamp fields does not work - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/12 09:30:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4336) Expose ability to take a savepoint from job manager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/12 09:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4388) Race condition during initialization of MemorySegmentFactory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/12 09:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2362: [FLINK-4385] [table] Union on Timestamp fields doe... - posted by wuchong <gi...@git.apache.org> on 2016/08/12 10:54:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-4385) Union on Timestamp fields does not work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 10:54:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4221) Show metrics in WebFrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 11:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4389) Expose metrics to Webfrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 11:38:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/12 11:40:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4362) Auto generate message sender classes via Java Proxies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/12 11:40:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/12 12:11:22 UTC, 4 replies.
- [jira] [Commented] (FLINK-4388) Race condition during initialization of MemorySegmentFactory - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/12 12:20:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/12 12:25:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/12 12:38:20 UTC, 3 replies.
- [GitHub] flink pull request #2363: [FLINK-4389] Expose metrics to WebFrontend - posted by zentol <gi...@git.apache.org> on 2016/08/12 12:43:24 UTC, 50 replies.
- [jira] [Commented] (FLINK-4389) Expose metrics to Webfrontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 12:44:20 UTC, 62 replies.
- [jira] [Assigned] (FLINK-4293) Malformatted Apache Headers - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 13:18:20 UTC, 0 replies.
- [GitHub] flink pull request #2364: [FLINK-4293] Fix malformatted license headers - posted by zentol <gi...@git.apache.org> on 2016/08/12 13:19:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-4293) Malformatted Apache Headers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 13:19:20 UTC, 3 replies.
- [jira] [Closed] (FLINK-4365) [metrics] MetricConfig has no documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 13:24:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4302) Add JavaDocs to MetricConfig - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 13:25:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 13:26:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 13:27:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 13:28:20 UTC, 0 replies.
- [GitHub] flink issue #2356: [FLINK-4378]Enable RollingSink to custom HDFS client conf... - posted by wenlong88 <gi...@git.apache.org> on 2016/08/12 13:36:00 UTC, 1 replies.
- [GitHub] flink pull request #2365: [FLINK-4383] [rpc] Eagerly serialize remote rpc in... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/12 13:47:52 UTC, 7 replies.
- [jira] [Commented] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/12 13:48:20 UTC, 10 replies.
- [jira] [Updated] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/12 13:49:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/12 13:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4390) Add throws clause verification to RpcCompletenessTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/12 13:52:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/12 14:55:20 UTC, 0 replies.
- [GitHub] flink pull request #2366: [FLINK-4322] Unify CheckpointCoordinator and Savep... - posted by uce <gi...@git.apache.org> on 2016/08/12 14:56:35 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4336) Expose ability to take a savepoint from job manager - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/12 18:16:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4335) Add jar id, and job parameters information to job status rest call - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/12 18:17:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/08/13 14:14:20 UTC, 0 replies.
- [GitHub] flink issue #2366: [FLINK-4322] Unify CheckpointCoordinator and SavepointCoo... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/13 14:35:01 UTC, 8 replies.
- [GitHub] flink issue #2364: [FLINK-4293] Fix malformatted license headers - posted by StephanEwen <gi...@git.apache.org> on 2016/08/13 14:35:57 UTC, 1 replies.
- [GitHub] flink issue #2349: [FLINK-4365] [metrics] Add documentation to MetricConfig - posted by StephanEwen <gi...@git.apache.org> on 2016/08/13 14:42:49 UTC, 1 replies.
- [GitHub] flink issue #2365: [FLINK-4383] [rpc] Eagerly serialize remote rpc invocatio... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/13 15:27:25 UTC, 2 replies.
- [jira] [Closed] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/13 16:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4392) Make RPC Service Thread Safe - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/13 16:33:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/13 21:13:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/13 21:13:20 UTC, 0 replies.
- [GitHub] flink pull request #2367: [FLINK-3703][cep] Add sequence matching semantics ... - posted by mushketyk <gi...@git.apache.org> on 2016/08/13 22:51:08 UTC, 10 replies.
- [GitHub] flink pull request #2368: [FLINK-3899] Document window processing with Reduc... - posted by danielblazevski <gi...@git.apache.org> on 2016/08/13 23:53:32 UTC, 15 replies.
- [jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "MaGuowei (JIRA)" <ji...@apache.org> on 2016/08/14 01:35:23 UTC, 2 replies.
- [GitHub] flink issue #2267: [FLINK-4205] Create a simple stratified sampling function... - posted by rmetzger <gi...@git.apache.org> on 2016/08/14 07:58:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-4205) Implement stratified sampling for DataSet - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/14 07:59:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4205) Implement stratified sampling for DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/14 07:59:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4392) Make RPC Service Thread Safe - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/14 13:45:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4392) Make RPC Service Thread Safe - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/14 13:45:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/14 13:46:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/14 13:46:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3950) Add Meter Metric Type - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/14 16:39:20 UTC, 0 replies.
- [GitHub] flink pull request #2369: [FLINK-4035] Add a streaming connector for Apache ... - posted by rmetzger <gi...@git.apache.org> on 2016/08/14 18:44:03 UTC, 16 replies.
- [jira] [Commented] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet() - posted by "Sunny T (JIRA)" <ji...@apache.org> on 2016/08/14 20:24:20 UTC, 16 replies.
- [jira] [Commented] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 01:04:20 UTC, 16 replies.
- [GitHub] flink pull request #2370: [FLINK-4373] [cluster management] Introduce SlotID... - posted by KurtYoung <gi...@git.apache.org> on 2016/08/15 01:04:20 UTC, 11 replies.
- [GitHub] flink pull request #2371: [FLINK-4309] Potential null pointer dereference in... - posted by tsunny <gi...@git.apache.org> on 2016/08/15 04:00:54 UTC, 10 replies.
- [GitHub] flink issue #2371: [FLINK-4309] Potential null pointer dereference in Delega... - posted by wuchong <gi...@git.apache.org> on 2016/08/15 04:42:33 UTC, 4 replies.
- [GitHub] flink pull request #2372: [FLINK-4281] [table] Wrap all Calcite Exceptions i... - posted by wuchong <gi...@git.apache.org> on 2016/08/15 06:04:04 UTC, 6 replies.
- [jira] [Commented] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 06:04:22 UTC, 8 replies.
- [jira] [Created] (FLINK-4393) Failed to serialize accumulators for task - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/08/15 06:24:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4393) Failed to serialize accumulators for task - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/08/15 06:25:20 UTC, 3 replies.
- [GitHub] flink issue #2362: [FLINK-4385] [table] Union on Timestamp fields does not w... - posted by twalthr <gi...@git.apache.org> on 2016/08/15 07:10:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4385) Union on Timestamp fields does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/15 07:29:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4348) implement communication from ResourceManager to TaskManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/15 07:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/08/15 07:46:20 UTC, 0 replies.
- [GitHub] flink pull request #2373: [FLINK-4394] RMQSource: QueueName accessible for s... - posted by theomega <gi...@git.apache.org> on 2016/08/15 07:47:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 07:47:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4395) Eager processing of late arrivals in CEP operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/15 07:59:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/15 09:08:20 UTC, 0 replies.
- [GitHub] flink issue #2373: [FLINK-4394] RMQSource: QueueName accessible for subclass... - posted by rmetzger <gi...@git.apache.org> on 2016/08/15 09:11:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 10:08:20 UTC, 0 replies.
- [GitHub] flink pull request #2288: Feature/s3 a fix - posted by uce <gi...@git.apache.org> on 2016/08/15 10:13:03 UTC, 13 replies.
- [jira] [Updated] (FLINK-4393) Failed to serialize accumulators for task - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/15 11:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4396) MetricRegistry class not found at startup of jobmanager - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/08/15 12:41:22 UTC, 0 replies.
- [GitHub] flink pull request #2313: [FLINK-4273] Modify JobClient to attach to running... - posted by rmetzger <gi...@git.apache.org> on 2016/08/15 12:48:54 UTC, 39 replies.
- [GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto... - posted by rmetzger <gi...@git.apache.org> on 2016/08/15 13:22:34 UTC, 24 replies.
- [GitHub] flink pull request #2141: [FLINK-4021] Problem of setting autoread for netty... - posted by uce <gi...@git.apache.org> on 2016/08/15 13:22:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 13:23:20 UTC, 7 replies.
- [GitHub] flink issue #2141: [FLINK-4021] Problem of setting autoread for netty channe... - posted by uce <gi...@git.apache.org> on 2016/08/15 13:30:39 UTC, 1 replies.
- [GitHub] flink issue #2075: [FLINK-3867] Provide Vagrant/Ansible based VMs to easily ... - posted by uce <gi...@git.apache.org> on 2016/08/15 13:38:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-3867) Provide virtualized Flink architecture for testing purposes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 13:39:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4055) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/15 14:05:22 UTC, 1 replies.
- [jira] [Closed] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/15 14:08:20 UTC, 0 replies.
- [GitHub] flink issue #2265: [FLINK-3097] [table] Add support for custom functions in ... - posted by twalthr <gi...@git.apache.org> on 2016/08/15 14:15:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-3097) Add support for custom functions in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 14:16:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/15 14:19:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/15 14:20:20 UTC, 2 replies.
- [GitHub] flink pull request #2265: [FLINK-3097] [table] Add support for custom functi... - posted by asfgit <gi...@git.apache.org> on 2016/08/15 14:20:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/15 14:21:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/15 14:21:21 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/15 14:22:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3097) Add support for custom functions in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/15 14:22:21 UTC, 0 replies.
- [GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp... - posted by twalthr <gi...@git.apache.org> on 2016/08/15 14:23:41 UTC, 7 replies.
- [jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/15 14:24:20 UTC, 56 replies.
- [jira] [Commented] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/15 14:30:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/08/15 14:48:20 UTC, 4 replies.
- [GitHub] flink issue #2370: [FLINK-4373] [cluster management] Introduce SlotID, Alloc... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/15 14:58:15 UTC, 4 replies.
- [jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/15 15:05:20 UTC, 3 replies.
- [GitHub] flink issue #2372: [FLINK-4281] [table] Wrap all Calcite Exceptions in Flink... - posted by wuchong <gi...@git.apache.org> on 2016/08/15 15:28:23 UTC, 1 replies.
- [jira] [Created] (FLINK-4399) Add support for oversized messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/15 16:02:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet() - posted by "Sunny T (JIRA)" <ji...@apache.org> on 2016/08/15 16:27:20 UTC, 0 replies.
- [GitHub] flink pull request #2374: [FLINK-3950] Add Meter Metric Type - posted by mushketyk <gi...@git.apache.org> on 2016/08/15 21:09:17 UTC, 16 replies.
- [jira] [Commented] (FLINK-4399) Add support for oversized messages - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2016/08/16 01:25:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "david.wang (JIRA)" <ji...@apache.org> on 2016/08/16 02:25:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "david.wang (JIRA)" <ji...@apache.org> on 2016/08/16 02:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2375: [FLINK-4375][cluster management]Introduce rpc prot... - posted by wenlong88 <gi...@git.apache.org> on 2016/08/16 03:49:17 UTC, 1 replies.
- [jira] [Commented] (FLINK-4375) Introduce rpc protocols implemented by job manager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/16 03:49:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4400) Leadership Election among JobManagers - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/16 06:22:20 UTC, 0 replies.
- [GitHub] flink issue #2353: [FLINK-4355] [cluster management] Implement TaskManager s... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/16 06:38:35 UTC, 3 replies.
- [GitHub] flink issue #2374: [FLINK-3950] Add Meter Metric Type - posted by zentol <gi...@git.apache.org> on 2016/08/16 07:42:00 UTC, 13 replies.
- [jira] [Resolved] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/16 08:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4401) Add docs about ordering in streams - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/16 08:42:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/16 10:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4402) Wrong metrics parameter names in documentation - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/08/16 13:36:22 UTC, 0 replies.
- [GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/16 14:36:33 UTC, 8 replies.
- [GitHub] flink pull request #2376: [FLINK-3755] Introduce key groups for key-value st... - posted by StefanRRichter <gi...@git.apache.org> on 2016/08/16 14:58:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/16 14:59:20 UTC, 5 replies.
- [GitHub] flink issue #2376: [FLINK-3755] Introduce key groups for key-value state to ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/08/16 15:37:16 UTC, 1 replies.
- [jira] [Closed] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/16 15:46:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 15:52:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 15:52:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4388) Race condition during initialization of MemorySegmentFactory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 15:53:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4388) Race condition during initialization of MemorySegmentFactory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 15:53:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4293) Malformatted Apache Headers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 16:15:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4293) Malformatted Apache Headers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 16:15:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4402) Wrong metrics parameter names in documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/16 19:11:20 UTC, 9 replies.
- [jira] [Created] (FLINK-4403) RPC proxy classloading should use Flink class' classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 19:16:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/16 20:15:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4381) Refactor State to Prepare For Key-Group State Backends - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/16 20:16:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/16 20:16:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3761) Introduce key group state backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/16 20:20:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3761) Refactor State Backends/Make Keyed State Key-Group Aware - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/16 20:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4404) Implement Data Transfer SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/17 05:22:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4405) Implement Blob Server SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/17 05:23:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4404) Implement Data Transfer SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/17 05:24:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4405) Implement Blob Server SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/17 05:24:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4406) Implement job master registration at resource manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/17 06:14:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4407) Implement the trigger DSL - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/17 07:04:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4407) Implement the trigger DSL - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/17 07:04:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4407) Implement the trigger DSL - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/17 07:07:20 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4355) Implement TaskManager side of registration at ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/17 07:35:20 UTC, 0 replies.
- [GitHub] flink pull request #2377: [Flink-4400][cluster management]Leadership Electio... - posted by shixiaogang <gi...@git.apache.org> on 2016/08/17 07:43:11 UTC, 13 replies.
- [jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/17 07:58:20 UTC, 64 replies.
- [jira] [Created] (FLINK-4408) JobSubmission - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/17 08:36:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4408) Submit Job and setup ExecutionGraph - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/17 08:38:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4404) Implement Data Transfer SSL - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/17 08:53:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4104) Restructure Gelly docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/17 09:24:20 UTC, 0 replies.
- [GitHub] flink pull request #2258: [FLINK-4104] [docs] Restructure Gelly docs - posted by asfgit <gi...@git.apache.org> on 2016/08/17 09:24:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/17 09:28:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/17 09:45:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 09:45:20 UTC, 6 replies.
- [jira] [Assigned] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 09:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/17 09:47:20 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/17 09:48:22 UTC, 11 replies.
- [GitHub] flink pull request #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop d... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/17 09:58:53 UTC, 1 replies.
- [GitHub] flink issue #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop dependen... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/17 09:59:13 UTC, 2 replies.
- [GitHub] flink issue #2216: [FLINK-4173] Use shade-plugin in flink-metrics - posted by StephanEwen <gi...@git.apache.org> on 2016/08/17 10:02:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/17 10:03:20 UTC, 1 replies.
- [GitHub] flink issue #2302: [hotfix] [metrics] Refactor constructors and tests - posted by StephanEwen <gi...@git.apache.org> on 2016/08/17 10:12:22 UTC, 1 replies.
- [jira] [Created] (FLINK-4411) [py] Chained dual input children are not properly propagated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 10:15:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4363) Implement TaskManager basic startup of all components in java - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/17 10:20:20 UTC, 0 replies.
- [GitHub] flink issue #2300: [FLINK-4245] [metrics] Expose all defined variables - posted by StephanEwen <gi...@git.apache.org> on 2016/08/17 10:26:05 UTC, 4 replies.
- [jira] [Commented] (FLINK-4245) Metric naming improvements - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/17 10:26:23 UTC, 32 replies.
- [jira] [Updated] (FLINK-4411) [py] Chained dual input children are not properly propagated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 11:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4412) [py] Chaining does not properly handle broadcast variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 11:46:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4412) [py] Chaining does not properly handle broadcast variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 11:56:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4411) [py] Chained dual input children are not properly propagated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 11:56:20 UTC, 0 replies.
- [GitHub] flink pull request #2302: [hotfix] [metrics] Refactor constructors and tests - posted by asfgit <gi...@git.apache.org> on 2016/08/17 12:00:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-4302) Add JavaDocs to MetricConfig - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 12:00:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-4302) Add JavaDocs to MetricConfig - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 12:04:20 UTC, 0 replies.
- [GitHub] flink pull request #2300: [FLINK-4245] [metrics] Expose all defined variable... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/17 12:21:39 UTC, 10 replies.
- [GitHub] flink pull request #2379: Add ManualSpeedTestITCase For Assessing State Perf... - posted by aljoscha <gi...@git.apache.org> on 2016/08/17 12:26:40 UTC, 3 replies.
- [jira] [Created] (FLINK-4413) Improve savepoint restore error messages - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/17 12:30:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4413) Improve savepoint restore error messages - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/17 12:39:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 14:36:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 14:36:22 UTC, 0 replies.
- [GitHub] flink pull request #2380: [FLINK-4189] [table] Introduce symbols for interna... - posted by twalthr <gi...@git.apache.org> on 2016/08/17 14:36:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-4189) Introduce symbols for internal use - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/17 14:37:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4414) Remove restriction on RpcService.getAddress - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/17 14:45:20 UTC, 0 replies.
- [GitHub] flink pull request #2381: [FLINK-4414][cluster management] Remove restrictio... - posted by wenlong88 <gi...@git.apache.org> on 2016/08/17 14:46:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/17 14:46:20 UTC, 16 replies.
- [jira] [Resolved] (FLINK-4281) Wrap all Calcite Exceptions in Flink Exceptions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/17 14:49:22 UTC, 0 replies.
- [GitHub] flink issue #2381: [FLINK-4414][cluster management] Remove restriction on Rp... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/17 14:57:21 UTC, 9 replies.
- [jira] [Created] (FLINK-4415) Enhance Trigger Interface with onFire() and onCleanup() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/17 15:29:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4415) Enhance Trigger Interface with onFire() and onCleanup() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/17 15:30:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4416) Provide a programmatic way to load a Yarn config - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/17 15:56:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 16:50:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 17:38:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 17:39:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4402) Wrong metrics parameter names in documentation - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/08/17 18:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2382: FLINK-4402: Wrong metrics parameter names in docum... - posted by nssalian <gi...@git.apache.org> on 2016/08/17 19:42:18 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/08/17 21:12:22 UTC, 5 replies.
- [jira] [Created] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/08/17 22:30:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/08/17 22:31:20 UTC, 1 replies.
- [GitHub] flink pull request #2383: [FLINK-4418] [client] Improve resilience when Inet... - posted by rehevkor5 <gi...@git.apache.org> on 2016/08/18 00:37:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 00:38:20 UTC, 9 replies.
- [jira] [Assigned] (FLINK-4406) Implement job master registration at resource manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/18 02:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4419) Batch improvement for supporting dfs as a ResultPartitionType - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/18 02:56:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4420) Introduce star(*) to select all of the columns in the table - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/18 05:08:22 UTC, 0 replies.
- [GitHub] flink pull request #2384: [FLINK-4420] [table] Introduce star(*) to select a... - posted by wuchong <gi...@git.apache.org> on 2016/08/18 05:17:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-4420) Introduce star(*) to select all of the columns in the table - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 05:18:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4347) Implement SlotManager core for new ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/18 07:30:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-4341) Kinesis connector does not emit maximum watermark properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 10:23:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/18 10:27:21 UTC, 15 replies.
- [jira] [Comment Edited] (FLINK-4341) Kinesis connector does not emit maximum watermark properly - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/18 10:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4421) Make clocks and time measurements monotonous - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 10:48:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4422) Convert all time interval measurements to System.nanoTime() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 10:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4423) Introduce a Clock utility for monotonous system timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 11:01:20 UTC, 0 replies.
- [GitHub] flink pull request #2385: FLINK-4322 (addendum)Issue with savepoint consider... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/18 12:00:57 UTC, 1 replies.
- [GitHub] flink issue #357: [FLINK-1458] Allow Interfaces and abstract types in TypeEx... - posted by pm-pushpendra-jaiswal <gi...@git.apache.org> on 2016/08/18 12:21:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-1458) Interfaces and abstract classes are not valid types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 12:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/18 12:33:20 UTC, 0 replies.
- [GitHub] flink issue #2355: [FLINK-4282]Add Offset Parameter to WindowAssigners - posted by aljoscha <gi...@git.apache.org> on 2016/08/18 13:25:08 UTC, 4 replies.
- [jira] [Created] (FLINK-4425) "Out Of Memory" during savepoint deserialization - posted by "Sergii Koshel (JIRA)" <ji...@apache.org> on 2016/08/18 14:03:21 UTC, 0 replies.
- [GitHub] flink issue #2363: [FLINK-4389] Expose metrics to WebFrontend - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/18 14:03:42 UTC, 11 replies.
- [GitHub] flink issue #2260: [FLINK-4222] Allow Kinesis configuration to get credentia... - posted by rmetzger <gi...@git.apache.org> on 2016/08/18 14:39:02 UTC, 3 replies.
- [jira] [Commented] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 14:39:23 UTC, 4 replies.
- [GitHub] flink pull request #2245: [hotfix] Fix Redis Sink to fail at opening if Redi... - posted by asfgit <gi...@git.apache.org> on 2016/08/18 14:43:30 UTC, 0 replies.
- [GitHub] flink issue #2377: [Flink-4400][cluster management]Leadership Election among... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/18 14:53:35 UTC, 1 replies.
- [GitHub] flink issue #2153: [FLINK-4110] Add testing skeleton to quickstart - posted by rmetzger <gi...@git.apache.org> on 2016/08/18 14:59:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-4110) Provide testing skeleton in quickstarts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 14:59:21 UTC, 0 replies.
- [GitHub] flink pull request #2272: [FLINK-4231] [java] Switch DistinctOperator from G... - posted by fhueske <gi...@git.apache.org> on 2016/08/18 15:40:52 UTC, 3 replies.
- [jira] [Commented] (FLINK-4231) Switch DistinctOperator from GroupReduce to Reduce - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 15:41:20 UTC, 5 replies.
- [jira] [Resolved] (FLINK-4189) Introduce symbols for internal use - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/18 15:47:20 UTC, 0 replies.
- [GitHub] flink issue #2383: [FLINK-4418] [client] Improve resilience when InetAddress... - posted by rehevkor5 <gi...@git.apache.org> on 2016/08/18 15:48:01 UTC, 5 replies.
- [jira] [Commented] (FLINK-4425) "Out Of Memory" during savepoint deserialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/18 16:01:21 UTC, 4 replies.
- [GitHub] flink issue #2272: [FLINK-4231] [java] Switch DistinctOperator from GroupRed... - posted by fhueske <gi...@git.apache.org> on 2016/08/18 16:16:02 UTC, 1 replies.
- [GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ... - posted by rmetzger <gi...@git.apache.org> on 2016/08/18 17:07:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 17:08:21 UTC, 5 replies.
- [GitHub] flink pull request #2387: [FLINK-4317, FLIP-3] [docs] Restructure docs - posted by uce <gi...@git.apache.org> on 2016/08/18 17:39:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4317) Restructure documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/18 17:39:21 UTC, 13 replies.
- [jira] [Closed] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/18 17:50:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4422) Convert all time interval measurements to System.nanoTime() - posted by "Sunny T (JIRA)" <ji...@apache.org> on 2016/08/18 18:20:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4422) Convert all time interval measurements to System.nanoTime() - posted by "Sunny T (JIRA)" <ji...@apache.org> on 2016/08/18 18:20:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-4303) Add CEP examples - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/18 20:11:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/18 20:23:20 UTC, 6 replies.
- [jira] [Commented] (FLINK-4395) Eager processing of late arrivals in CEP operator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/18 20:24:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4395) Eager processing of late arrivals in CEP operator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/18 20:24:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4371) Add ability to take savepoints from job manager RESTful API - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/18 21:19:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-305) Add Maven plugin to generate test coverage reports - posted by "Pavel Fadeev (JIRA)" <ji...@apache.org> on 2016/08/18 22:28:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4426) Unable to create proxy to the ResourceManager - posted by "Harpreet Sawhney (JIRA)" <ji...@apache.org> on 2016/08/18 23:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4426) Unable to create proxy to the ResourceManager - posted by "Harpreet Sawhney (JIRA)" <ji...@apache.org> on 2016/08/18 23:59:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4347) Implement SlotManager core - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 02:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4427) Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos) - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 03:45:20 UTC, 0 replies.
- [GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan... - posted by KurtYoung <gi...@git.apache.org> on 2016/08/19 03:58:38 UTC, 22 replies.
- [jira] [Commented] (FLINK-4347) Implement SlotManager core - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 03:59:20 UTC, 31 replies.
- [jira] [Created] (FLINK-4428) Method map/flatMapWithState may need a eviction policy - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/19 06:06:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/19 06:23:20 UTC, 5 replies.
- [GitHub] flink issue #2387: [FLINK-4317, FLIP-3] [docs] Restructure docs - posted by aljoscha <gi...@git.apache.org> on 2016/08/19 07:40:04 UTC, 11 replies.
- [jira] [Created] (FLINK-4429) Move Redis Sink from Flink to Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/19 08:25:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4427) Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos) - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 08:49:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4427) Add slot / Implement container releasing logic (Standalone / Yarn / Mesos) - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 08:58:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4430) prevent BLOCKING partition data lose when task is finished - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 09:00:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/19 09:30:20 UTC, 2 replies.
- [GitHub] flink issue #2385: FLINK-4322 (addendum)Issue with savepoint considering the... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/19 09:41:49 UTC, 1 replies.
- [GitHub] flink pull request #2389: Jira FLINK-4348 - posted by beyond1920 <gi...@git.apache.org> on 2016/08/19 09:52:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-4348) implement communication from ResourceManager to TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 09:53:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4348) Implement communication from ResourceManager to TaskManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/19 09:56:20 UTC, 0 replies.
- [GitHub] flink issue #2389: Jira FLINK-4348 - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/19 09:57:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 09:58:20 UTC, 69 replies.
- [jira] [Created] (FLINK-4431) Introduce a "VisibleForTesting" annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 10:06:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4430) prevent BLOCKING partition data lose when task is finished - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 10:06:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-4431) Introduce a "VisibleForTesting" annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 10:07:20 UTC, 0 replies.
- [GitHub] flink issue #2386: [FLINK-3660] Measure latency and exposes them via a metri... - posted by zentol <gi...@git.apache.org> on 2016/08/19 10:08:37 UTC, 4 replies.
- [GitHub] flink pull request #2390: [FLINK-4431] [core] Introduce a "VisibleForTesting... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/19 10:20:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-4431) Introduce a "VisibleForTesting" annotation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 10:20:20 UTC, 9 replies.
- [GitHub] flink pull request #2304: [FLINK-4268] [core] Add parsers for BigDecimal/Big... - posted by fhueske <gi...@git.apache.org> on 2016/08/19 10:22:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 10:23:20 UTC, 2 replies.
- [GitHub] flink issue #2304: [FLINK-4268] [core] Add parsers for BigDecimal/BigInteger - posted by fhueske <gi...@git.apache.org> on 2016/08/19 10:25:01 UTC, 0 replies.
- [GitHub] flink pull request #2391: [FLINK-3580] [table] Implement FLOOR/CEIL for time... - posted by twalthr <gi...@git.apache.org> on 2016/08/19 10:36:54 UTC, 3 replies.
- [jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 10:37:22 UTC, 9 replies.
- [jira] [Updated] (FLINK-4425) "Out Of Memory" during savepoint deserialization - posted by "Sergii Koshel (JIRA)" <ji...@apache.org> on 2016/08/19 11:25:20 UTC, 1 replies.
- [GitHub] flink pull request #2392: [FLINK-4414] [cluster] Add getAddress method to Rp... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/19 11:50:07 UTC, 1 replies.
- [GitHub] flink issue #2392: [FLINK-4414] [cluster] Add getAddress method to RpcGatewa... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/19 11:50:43 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4414) Remove restriction on RpcService.getAddress - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/19 11:53:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4414) Remove restriction on RpcService.getAddress - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/19 11:53:20 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/08/19 12:09:20 UTC, 0 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/08/19 12:22:20 UTC, 0 replies.
- [jira] [Closed] (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/08/19 12:23:20 UTC, 0 replies.
- [GitHub] flink issue #2390: [FLINK-4431] [core] Introduce a "VisibleForTesting" annot... - posted by uce <gi...@git.apache.org> on 2016/08/19 12:24:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-4426) Unable to create proxy to the ResourceManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/19 13:02:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-3279) Optionally disable DistinctOperator combiner - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/19 13:06:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4390) Add throws clause verification to RpcCompletenessTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/19 13:07:20 UTC, 0 replies.
- [GitHub] flink issue #2319: [FLINK-4294] [table] Allow access of composite type field... - posted by fhueske <gi...@git.apache.org> on 2016/08/19 13:21:47 UTC, 0 replies.
- [GitHub] flink issue #2382: [FLINK-4402]: Wrong metrics parameter names in documentat... - posted by rmetzger <gi...@git.apache.org> on 2016/08/19 13:44:05 UTC, 3 replies.
- [GitHub] flink issue #2379: Add ManualSpeedTestITCase For Assessing State Performance - posted by aljoscha <gi...@git.apache.org> on 2016/08/19 13:48:29 UTC, 1 replies.
- [GitHub] flink issue #2171: FLINK-3319 Added the or function to the CEP pattern - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/19 13:49:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 13:50:20 UTC, 1 replies.
- [GitHub] flink pull request #2171: FLINK-3319 Added the or function to the CEP patter... - posted by asfgit <gi...@git.apache.org> on 2016/08/19 13:50:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-3319) Add or operator to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/19 13:51:20 UTC, 0 replies.
- [GitHub] flink pull request #2382: [FLINK-4402]: Wrong metrics parameter names in doc... - posted by asfgit <gi...@git.apache.org> on 2016/08/19 14:37:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4402) Wrong metrics parameter names in documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/19 14:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4432) (YARN) JobManager web port is no longer available in configuration page in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/19 14:48:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4422) Convert all time interval measurements to System.nanoTime() - posted by "Sunny T (JIRA)" <ji...@apache.org> on 2016/08/19 16:25:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4282) Add Offset Parameter to WindowAssigners - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/19 16:25:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4433) Refactor the StreamSource. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/19 16:33:20 UTC, 0 replies.
- [GitHub] flink issue #2367: [FLINK-3703][cep] Add sequence matching semantics to disc... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/19 16:57:40 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/19 16:59:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/19 17:17:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4433) Refactor the StreamSource. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/19 17:30:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/19 17:45:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/19 18:10:20 UTC, 6 replies.
- [jira] [Commented] (FLINK-4433) Refactor the StreamSource. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 21:32:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4403) RPC proxy classloading should use Flink class' classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 21:35:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4403) RPC proxy classloading should use Flink class' classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 21:35:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4434) Add a testing RPC service - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 21:39:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4434) Add a testing RPC service - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 21:39:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4431) Introduce a "VisibleForTesting" annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 22:00:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-4431) Introduce a "VisibleForTesting" annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 22:01:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 22:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2393: [trivial] Fix typo in dosctring - posted by thvasilo <gi...@git.apache.org> on 2016/08/19 22:02:49 UTC, 1 replies.
- [GitHub] flink pull request #2394: [FLINK-4434] [rpc] Add a testing RPC service. - posted by StephanEwen <gi...@git.apache.org> on 2016/08/19 22:09:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-4434) Add a testing RPC service - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/19 22:10:20 UTC, 5 replies.
- [GitHub] flink pull request #2395: [FLINK-4355] [cluster management] Add tests for th... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/19 22:11:32 UTC, 1 replies.
- [jira] [Created] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/20 00:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/20 00:19:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/20 00:43:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/20 00:44:21 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/08/20 00:45:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/20 00:47:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/20 00:49:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/20 00:50:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/20 00:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4438) FlinkML Quickstart Guide implies incorrect type for test data - posted by "Ahmad Ragab (JIRA)" <ji...@apache.org> on 2016/08/21 07:36:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4438) FlinkML Quickstart Guide implies incorrect type for test data - posted by "Ahmad Ragab (JIRA)" <ji...@apache.org> on 2016/08/21 08:21:20 UTC, 0 replies.
- [GitHub] flink pull request #2396: [FLINK-4395][cep] Eager processing of late arrival... - posted by mushketyk <gi...@git.apache.org> on 2016/08/21 08:49:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/21 11:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid - posted by "Gheorghe Gheorghe (JIRA)" <ji...@apache.org> on 2016/08/21 13:59:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/21 14:09:20 UTC, 10 replies.
- [GitHub] flink pull request #2397: [FLINK-4439] Validate 'bootstrap.servers' config i... - posted by gheo21 <gi...@git.apache.org> on 2016/08/21 14:19:28 UTC, 0 replies.
- [GitHub] flink pull request #2398: [gelly] Add Vertex.create and Edge.create helper m... - posted by mushketyk <gi...@git.apache.org> on 2016/08/21 14:26:59 UTC, 0 replies.
- [GitHub] flink issue #2398: [gelly] Add Vertex.create and Edge.create helper methods - posted by mushketyk <gi...@git.apache.org> on 2016/08/21 14:29:14 UTC, 1 replies.
- [jira] [Updated] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse) - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/21 16:13:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/21 16:14:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/21 16:28:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/21 16:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4440) Make API for edge/vertex creation less verbose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/21 16:49:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/21 16:50:20 UTC, 13 replies.
- [GitHub] flink issue #2398: [FLINK-4440][gelly] Add Vertex.create and Edge.create hel... - posted by mushketyk <gi...@git.apache.org> on 2016/08/21 16:50:26 UTC, 1 replies.
- [jira] [Created] (FLINK-4441) RocksDB statebackend makes all operators appear stateful - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/21 19:56:20 UTC, 0 replies.
- [GitHub] flink pull request #2399: [FLINK-4441] Make RocksDB backend return null on e... - posted by gyfora <gi...@git.apache.org> on 2016/08/21 20:05:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-4441) RocksDB statebackend makes all operators appear stateful - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/21 20:05:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4427) Add slot / Implement container releasing logic (Standalone / Yarn / Mesos) - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/08/22 01:41:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4430) prevent BLOCKING partition data lose when task is finished - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/08/22 01:42:20 UTC, 0 replies.
- [GitHub] flink pull request #2400: [FLINK-4363] Implement TaskManager basic startup o... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/08/22 04:00:12 UTC, 47 replies.
- [jira] [Created] (FLINK-4442) Implement Standalone ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/22 04:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/22 05:48:20 UTC, 0 replies.
- [GitHub] flink pull request #2401: [FLInk-4443][rpc] Add support in RpcCompletenessTe... - posted by wenlong88 <gi...@git.apache.org> on 2016/08/22 06:08:56 UTC, 0 replies.
- [jira] [Created] (FLINK-4444) Add a DFSInputChannel and DFSSubPartition - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/22 06:47:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4352) Implement new JobClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/22 07:56:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2118) Table API fails on composite filter conditions - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/22 08:41:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4445) Ignore unmatched state when restoring from savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/22 08:46:20 UTC, 0 replies.
- [GitHub] flink issue #2399: [FLINK-4441] Make RocksDB backend return null on empty st... - posted by uce <gi...@git.apache.org> on 2016/08/22 08:46:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-4445) Ignore unmatched state when restoring from savepoint - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/22 08:51:20 UTC, 2 replies.
- [GitHub] flink issue #2393: [trivial] Fix typo in dosctring - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 08:53:31 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4444) Add a DFSInputChannel and DFSSubPartition - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/22 09:52:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4419) Batch improvement for supporting dfs as a ResultPartitionType - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/22 09:52:20 UTC, 0 replies.
- [GitHub] flink issue #2031: FLINK-3967 - Flink Sink for Rethink Db - posted by rmetzger <gi...@git.apache.org> on 2016/08/22 09:52:37 UTC, 2 replies.
- [jira] [Commented] (FLINK-3967) Provide RethinkDB Sink for Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/22 09:53:20 UTC, 2 replies.
- [GitHub] flink issue #2400: [FLINK-4363] Implement TaskManager basic startup of all c... - posted by mxm <gi...@git.apache.org> on 2016/08/22 09:55:02 UTC, 12 replies.
- [jira] [Commented] (FLINK-4428) Method map/flatMapWithState may need a eviction policy - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/22 10:05:20 UTC, 0 replies.
- [GitHub] flink issue #2394: [FLINK-4434] [rpc] Add a testing RPC service. - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 11:35:56 UTC, 2 replies.
- [GitHub] flink issue #2395: [FLINK-4355] [cluster management] Add tests for the TaskM... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 11:38:36 UTC, 1 replies.
- [GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 12:04:46 UTC, 66 replies.
- [GitHub] flink pull request #2260: [FLINK-4222] Allow Kinesis configuration to get cr... - posted by asfgit <gi...@git.apache.org> on 2016/08/22 13:00:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/22 13:00:24 UTC, 0 replies.
- [GitHub] flink pull request #2402: [FLINK-4436] Unclosed DataOutputBuffer in Utils#se... - posted by f7753 <gi...@git.apache.org> on 2016/08/22 13:13:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/22 13:14:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/22 13:31:21 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4355) Implement TaskManager side of registration at ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/22 14:15:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4434) Add a testing RPC service - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/22 14:16:21 UTC, 0 replies.
- [GitHub] flink issue #2389: [FLINK-4348] [cluster management] Implement communication... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 14:33:42 UTC, 1 replies.
- [GitHub] flink pull request #2401: [FLINK-4443][rpc] Add support in RpcCompletenessTe... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 14:41:36 UTC, 5 replies.
- [jira] [Commented] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/22 14:42:20 UTC, 8 replies.
- [jira] [Created] (FLINK-4446) Move Flume Sink from Flink to Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/22 14:42:20 UTC, 0 replies.
- [GitHub] flink issue #2401: [FLINK-4443][rpc] Add support in RpcCompletenessTest for ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/22 14:46:09 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4400) Leadership Election among JobManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/22 15:00:24 UTC, 0 replies.
- [GitHub] flink pull request #2403: [FLINK-4278]: Unclosed FSDataOutputStream in multi... - posted by nssalian <gi...@git.apache.org> on 2016/08/22 16:55:35 UTC, 1 replies.
- [jira] [Created] (FLINK-4447) Include NettyConfig options on Configurations page - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/22 19:00:22 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4440) Make API for edge/vertex creation less verbose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/22 20:54:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4445) Ignore unmatched state when restoring from savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/22 21:14:21 UTC, 0 replies.
- [GitHub] flink issue #2403: [FLINK-4278]: Unclosed FSDataOutputStream in multiple fil... - posted by nssalian <gi...@git.apache.org> on 2016/08/22 22:10:30 UTC, 3 replies.
- [GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co... - posted by KurtYoung <gi...@git.apache.org> on 2016/08/23 00:45:26 UTC, 8 replies.
- [jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/23 01:12:22 UTC, 3 replies.
- [jira] [Created] (FLINK-4448) Use Listeners to monitor execution status - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/23 01:43:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4376) Implement job master skeleton for managing single job - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/23 01:58:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/23 06:39:20 UTC, 0 replies.
- [GitHub] flink pull request #2404: [FLINK-4435] Replace Guava's VisibleForTesting ann... - posted by wuchong <gi...@git.apache.org> on 2016/08/23 06:44:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/23 06:45:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4449) Heartbeat Manager between ResourceManager and TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/23 07:45:21 UTC, 0 replies.
- [GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi... - posted by twalthr <gi...@git.apache.org> on 2016/08/23 09:01:26 UTC, 48 replies.
- [jira] [Closed] (FLINK-4425) "Out Of Memory" during savepoint deserialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/23 11:15:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4450) update storm version to 1.0.0 - posted by "yuzhongliu (JIRA)" <ji...@apache.org> on 2016/08/23 11:22:20 UTC, 0 replies.
- [GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink... - posted by gheo21 <gi...@git.apache.org> on 2016/08/23 11:55:18 UTC, 6 replies.
- [jira] [Closed] (FLINK-4426) Unable to create proxy to the ResourceManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/23 13:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4451) Throw exception when remote connection cannot be resolved - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 14:22:21 UTC, 0 replies.
- [GitHub] flink pull request #2289: [FLINK-3866] StringArraySerializer type should be ... - posted by asfgit <gi...@git.apache.org> on 2016/08/23 14:24:24 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 14:29:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/23 14:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4452) TaskManager network buffer guages - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/23 14:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4453) Scala code example in Window documentation shows Java - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/23 14:58:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4355) Implement TaskManager side of registration at ResourceManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/23 14:59:20 UTC, 0 replies.
- [GitHub] flink issue #2404: [FLINK-4435] Replace Guava's VisibleForTesting annotation... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/23 15:04:35 UTC, 1 replies.
- [GitHub] flink issue #2368: [FLINK-3899] Document window processing with Reduce/FoldF... - posted by fhueske <gi...@git.apache.org> on 2016/08/23 15:51:27 UTC, 5 replies.
- [jira] [Created] (FLINK-4454) Lookups for JobManager address in config - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/23 15:54:20 UTC, 0 replies.
- [GitHub] flink pull request #2405: [FLINK-4451] [rpc] Throw RpcConnectionException wh... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/23 16:02:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-4451) Throw exception when remote connection cannot be resolved - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/23 16:03:21 UTC, 10 replies.
- [GitHub] flink pull request #2406: [FLINK-4454] always retrieve JobManager address us... - posted by mxm <gi...@git.apache.org> on 2016/08/23 16:19:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-4454) Lookups for JobManager address in config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/23 16:20:20 UTC, 2 replies.
- [GitHub] flink pull request #2407: FLINK-4417 Checkpoints should be subsumed by Check... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/23 16:29:44 UTC, 1 replies.
- [jira] [Updated] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 16:39:20 UTC, 0 replies.
- [GitHub] flink issue #2405: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc ... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/23 16:50:27 UTC, 3 replies.
- [jira] [Created] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 16:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4456) Replace ActorGateway in RuntimeEnvironment by interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:04:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4456) Replace ActorGateway in Task by interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:10:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/23 17:13:20 UTC, 12 replies.
- [jira] [Resolved] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/23 17:17:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/23 17:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4457) Make the ExecutionGraph independent of Akka - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4458) Remove ForkableFlinkMiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:30:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4459) Introduce SlotProvider to Scheduler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:46:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4459) Introduce SlotProvider for Scheduler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:46:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4449) Heartbeat Manager between ResourceManager and TaskExecutor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 18:03:20 UTC, 34 replies.
- [jira] [Created] (FLINK-4460) Expose Late Arriving Events - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/08/23 18:28:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4408) Submit Job and setup ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/23 18:53:22 UTC, 2 replies.
- [jira] [Updated] (FLINK-4452) TaskManager network buffer gauges - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/23 19:02:20 UTC, 1 replies.
- [GitHub] flink pull request #2408: [FLINK-4452] TaskManager network buffer gauges - posted by greghogan <gi...@git.apache.org> on 2016/08/23 19:04:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-4452) TaskManager network buffer gauges - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/23 19:05:20 UTC, 2 replies.
- [GitHub] flink pull request #2409: FLINK-4437 Lock evasion around lastTriggeredCheckp... - posted by tedyu <gi...@git.apache.org> on 2016/08/23 19:12:16 UTC, 1 replies.
- [GitHub] flink issue #2240: [FLINK-4209] Fix issue on docker with multiple NICs and r... - posted by jagatfx <gi...@git.apache.org> on 2016/08/23 19:12:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/23 19:13:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3414) Add Scala API for CEP's pattern definition - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/23 20:34:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-2944) Collect, expose and display operator-specific stats - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/23 21:48:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/23 21:49:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3030) Enhance Dashboard to show Execution Attempts - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/23 21:49:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/08/23 21:57:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4100) RocksDBStateBackend#close() can throw NPE - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/08/24 00:24:21 UTC, 2 replies.
- [jira] [Closed] (FLINK-4448) Use Listeners to monitor execution status - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/24 01:58:20 UTC, 0 replies.
- [GitHub] flink pull request #2410: [FLINK-4449] [cluster management] Heartbeat Manage... - posted by beyond1920 <gi...@git.apache.org> on 2016/08/24 03:02:05 UTC, 27 replies.
- [jira] [Assigned] (FLINK-4453) Scala code example in Window documentation shows Java - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/24 03:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2411: [FLINK-4453] [docs] Scala code example in Window d... - posted by wuchong <gi...@git.apache.org> on 2016/08/24 03:06:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-4453) Scala code example in Window documentation shows Java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 03:06:20 UTC, 5 replies.
- [GitHub] flink issue #2409: FLINK-4437 Lock evasion around lastTriggeredCheckpoint ma... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/24 05:30:31 UTC, 8 replies.
- [jira] [Resolved] (FLINK-4441) RocksDB statebackend makes all operators appear stateful - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/24 07:10:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4461) Ensure all the classes are tagged with suitable annotations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/24 07:27:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4461) Ensure all the classes are tagged with suitable annotations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/24 07:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/24 07:29:20 UTC, 0 replies.
- [GitHub] flink issue #2411: [FLINK-4453] [docs] Scala code example in Window document... - posted by fhueske <gi...@git.apache.org> on 2016/08/24 07:36:14 UTC, 3 replies.
- [GitHub] flink pull request #2412: FLINK-4462 Add RUN_TIME retention policy for all t... - posted by ramkrish86 <gi...@git.apache.org> on 2016/08/24 07:39:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 07:40:20 UTC, 5 replies.
- [jira] [Closed] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:07:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-3343) Exception while using Kafka 0.9 connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:08:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:08:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:08:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3531) KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:09:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:12:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2049) KafkaSink sporadically fails to send message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:12:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 09:18:20 UTC, 0 replies.
- [GitHub] flink issue #2406: [FLINK-4454] always retrieve JobManager address using Lea... - posted by mxm <gi...@git.apache.org> on 2016/08/24 09:25:16 UTC, 0 replies.
- [jira] [Updated] (FLINK-4317) Restructure documentation layout - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:28:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4463) FLIP-3: Restructure Documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:30:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-4317) Restructure documentation layout - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:31:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4454) Lookups for JobManager address in config - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/24 09:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4464) Add docs about version upgrades - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:36:20 UTC, 0 replies.
- [GitHub] flink issue #2412: FLINK-4462 Add RUN_TIME retention policy for all the flin... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/24 09:39:14 UTC, 4 replies.
- [jira] [Created] (FLINK-4465) Add docs about system architecture - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:40:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4466) Add a metric availability test. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 09:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4467) Add docs about project structure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4468) Add documentation about processing semantics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:43:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4468) Add documentation about processing semantics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:47:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4468) Add docs about processing semantics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:48:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4465) Add docs about system architecture - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:48:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/24 09:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4470) Add docs about Failure and Recovery Model - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4472) Add docs about Security - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4471) Rocks backend fully async snapshot restore fails with custom serializers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/24 09:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4473) Add docs about end-to-end exactly once latency - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4474) Add docs about Testing & Test Utilities - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4475) Add docs about Debugging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:02:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4471) Rocks backend fully async snapshot restore fails with custom serializers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/24 10:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4476) Add docs about Tuning - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4477) Add and consolidate existing docs about data types - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:05:20 UTC, 0 replies.
- [GitHub] flink pull request #2413: [FLINK-4471] Use user code classloader to deserial... - posted by gyfora <gi...@git.apache.org> on 2016/08/24 10:05:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4471) Rocks backend fully async snapshot restore fails with custom serializers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 10:05:20 UTC, 7 replies.
- [jira] [Updated] (FLINK-4473) Add docs about end-to-end exactly once - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:05:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4253) Rename "recovery.mode" config key to "high-availability" - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:13:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/24 10:44:20 UTC, 1 replies.
- [GitHub] flink issue #2152: [FLINK-3920] Distributed Linear Algebra: block-based matr... - posted by chobeat <gi...@git.apache.org> on 2016/08/24 11:53:32 UTC, 2 replies.
- [jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 11:54:20 UTC, 15 replies.
- [GitHub] flink issue #2407: FLINK-4417 Checkpoints should be subsumed by CheckpointID... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/24 12:07:21 UTC, 0 replies.
- [GitHub] flink issue #2408: [FLINK-4452] TaskManager network buffer gauges - posted by StephanEwen <gi...@git.apache.org> on 2016/08/24 12:21:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4457) Make the ExecutionGraph independent of Akka - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 12:25:20 UTC, 0 replies.
- [GitHub] flink issue #2413: [FLINK-4471] Use user code classloader to deserialize sta... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/24 12:30:21 UTC, 5 replies.
- [GitHub] flink issue #2192: Flink 4034 Maven dependency convergence - posted by StephanEwen <gi...@git.apache.org> on 2016/08/24 12:40:39 UTC, 1 replies.
- [GitHub] flink issue #2086: [FLINK-3977] initialize FoldApplyWindowFunction properly - posted by StephanEwen <gi...@git.apache.org> on 2016/08/24 12:42:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 12:42:22 UTC, 2 replies.
- [jira] [Created] (FLINK-4478) Implement heartbeat logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/24 13:35:21 UTC, 0 replies.
- [GitHub] flink issue #2410: [FLINK-4449] [cluster management] Heartbeat Manager betwe... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/24 13:35:54 UTC, 3 replies.
- [jira] [Closed] (FLINK-4452) TaskManager network buffer gauges - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/24 13:58:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4231) Switch DistinctOperator from GroupReduce to Reduce - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/24 13:58:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4204) Clean up gelly-examples - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/24 14:11:20 UTC, 0 replies.
- [GitHub] flink pull request #2002: Support for bz2 compression in flink-core - posted by greghogan <gi...@git.apache.org> on 2016/08/24 14:20:35 UTC, 2 replies.
- [GitHub] flink pull request #2086: [FLINK-3977] initialize FoldApplyWindowFunction pr... - posted by rvdwenden <gi...@git.apache.org> on 2016/08/24 14:28:03 UTC, 0 replies.
- [GitHub] flink pull request #2295: [FLINK-4264] [gelly] New GraphMetrics driver - posted by asfgit <gi...@git.apache.org> on 2016/08/24 14:42:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4264) New GraphMetrics driver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 14:42:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4264) New GraphMetrics driver - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/24 14:44:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-3999) Rename the `running` flag in the drivers to `canceled` - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/08/24 14:44:22 UTC, 2 replies.
- [jira] [Reopened] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/24 14:44:22 UTC, 0 replies.
- [GitHub] flink issue #346: [FLINK-1460] fix typos - posted by coveralls <gi...@git.apache.org> on 2016/08/24 14:57:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-1460) Typo fixes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 14:58:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 15:05:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4451) Throw exception when remote connection cannot be resolved - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/24 15:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4480) Incorrect link to elastic.co in documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/24 15:35:20 UTC, 0 replies.
- [GitHub] flink pull request #2414: [FLINK-4341] Let idle consumer subtasks emit max v... - posted by tzulitai <gi...@git.apache.org> on 2016/08/24 17:12:20 UTC, 1 replies.
- [GitHub] flink pull request #2415: [FLINK-4407] Implement the trigger DSL - posted by kl0u <gi...@git.apache.org> on 2016/08/24 17:37:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-4407) Implement the trigger DSL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 17:38:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3999) Rename the `running` flag in the drivers to `canceled` - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/24 18:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4481) Maximum results for pairwise algorithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/24 19:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/24 20:56:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4457) Make the ExecutionGraph independent of Akka - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:14:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4480) Incorrect link to elastic.co in documentation - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/08/24 21:19:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4457) Make the ExecutionGraph independent of Akka - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:19:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:20:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:20:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:23:21 UTC, 2 replies.
- [jira] [Closed] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:23:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4453) Scala code example in Window documentation shows Java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:24:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4453) Scala code example in Window documentation shows Java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 21:25:20 UTC, 0 replies.
- [GitHub] flink pull request #2416: FLINK-4480: Incorrect link to elastic.co in docume... - posted by smarthi <gi...@git.apache.org> on 2016/08/24 22:08:33 UTC, 1 replies.
- [GitHub] flink issue #2416: FLINK-4480: Incorrect link to elastic.co in documentation - posted by smarthi <gi...@git.apache.org> on 2016/08/24 22:09:13 UTC, 3 replies.
- [jira] [Commented] (FLINK-4480) Incorrect link to elastic.co in documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/24 22:09:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/24 23:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4483) Complete test coverage integration - posted by "Pavel Fadeev (JIRA)" <ji...@apache.org> on 2016/08/24 23:18:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4483) Complete test coverage integration - posted by "Pavel Fadeev (JIRA)" <ji...@apache.org> on 2016/08/24 23:26:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4478) Implement heartbeat logic - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/25 02:46:20 UTC, 8 replies.
- [jira] [Assigned] (FLINK-4339) Implement Slot Pool Core - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/25 02:50:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4339) Implement Slot Pool Core - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/25 02:50:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/25 03:31:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/25 05:57:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4408) Submit Job and setup ExecutionGraph - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/25 07:31:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4483) Complete test coverage integration - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/25 07:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2417: [FLINK-4449] [cluster management] heartbeat receiv... - posted by beyond1920 <gi...@git.apache.org> on 2016/08/25 07:53:51 UTC, 1 replies.
- [jira] [Closed] (FLINK-4471) Rocks backend fully async snapshot restore fails with custom serializers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/25 08:53:21 UTC, 0 replies.
- [GitHub] flink issue #2391: [FLINK-3580] [table] Implement FLOOR/CEIL for time points - posted by twalthr <gi...@git.apache.org> on 2016/08/25 10:00:51 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/25 10:06:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/25 12:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4484) FLIP-10: Unify Savepoints and Checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/25 12:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:05:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/25 13:11:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:11:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/25 13:20:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/25 13:23:21 UTC, 1 replies.
- [GitHub] flink pull request #2418: [FLINK-4245] JMXReporter exposes all defined varia... - posted by zentol <gi...@git.apache.org> on 2016/08/25 13:28:02 UTC, 2 replies.
- [jira] [Created] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:31:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4478) Implement heartbeat logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 13:33:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4487) Need tools for managing the yarn-session better - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:36:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/25 13:41:20 UTC, 0 replies.
- [GitHub] flink pull request #2419: [FLINK-4488] only automatically shutdown clusters ... - posted by mxm <gi...@git.apache.org> on 2016/08/25 13:42:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/25 13:43:21 UTC, 3 replies.
- [jira] [Closed] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/25 14:01:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 14:04:21 UTC, 9 replies.
- [jira] [Commented] (FLINK-4354) Implement TaskManager side of heartbeat from ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:06:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4364) Implement TaskManager side of heartbeat from JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:12:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/25 14:12:20 UTC, 0 replies.
- [GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t... - posted by HungUnicorn <gi...@git.apache.org> on 2016/08/25 14:13:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/25 14:14:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4357) Implement TaskManager side of slot allocation from ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4489) Implement TaskManager's SlotManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:20:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4358) Implement TaskManager deployment task into slot - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:26:21 UTC, 0 replies.
- [GitHub] flink issue #2414: [FLINK-4341] Let idle consumer subtasks emit max value wa... - posted by rmetzger <gi...@git.apache.org> on 2016/08/25 14:27:52 UTC, 6 replies.
- [jira] [Commented] (FLINK-4343) Implement new TaskManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:28:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4490) Decouple Slot and Instance - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/25 14:34:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4343) Implement new TaskManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4492) Cleanup files from canceled snapshots - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/25 14:40:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4491) Handle index.number_of_shards in the ES connector - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/08/25 14:40:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4493) Unify the snapshot output format for keyed-state backends - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/25 14:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/25 15:13:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/25 15:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4495) Running multiple jobs on yarn (without yarn-session) - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 15:14:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/25 15:19:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4495) Running multiple jobs on yarn (without yarn-session) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/25 15:37:21 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/25 15:51:21 UTC, 1 replies.
- [GitHub] flink issue #2419: [FLINK-4488] only automatically shutdown clusters for det... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/25 15:52:12 UTC, 1 replies.
- [GitHub] flink issue #1988: [FLINK-3761] Introduction of key groups - posted by StephanEwen <gi...@git.apache.org> on 2016/08/25 15:53:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-3761) Refactor State Backends/Make Keyed State Key-Group Aware - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/25 15:54:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4433) Refactor the StreamSource. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/25 15:55:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/08/25 16:06:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 16:18:21 UTC, 0 replies.
- [GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables - posted by StephanEwen <gi...@git.apache.org> on 2016/08/25 16:36:33 UTC, 13 replies.
- [jira] [Commented] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/25 16:37:20 UTC, 0 replies.
- [GitHub] flink pull request #2420: [hotfix] Fix invalid elasticsearch url link in doc... - posted by haoch <gi...@git.apache.org> on 2016/08/25 16:41:19 UTC, 0 replies.
- [jira] [Created] (FLINK-4498) Better Cassandra sink documentation - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 16:46:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4498) Better Cassandra sink documentation - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 16:49:20 UTC, 1 replies.
- [GitHub] flink issue #2420: [hotfix] Fix invalid url link in documentation - posted by fhueske <gi...@git.apache.org> on 2016/08/25 16:56:41 UTC, 1 replies.
- [GitHub] flink pull request #2420: [hotfix] Fix invalid url link in documentation - posted by haoch <gi...@git.apache.org> on 2016/08/25 17:05:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/25 17:22:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4499) Introduce findbugs maven plugin - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/25 17:35:20 UTC, 0 replies.
- [GitHub] flink pull request #2421: FLINK-4482 numUnsuccessfulCheckpointsTriggers is a... - posted by tedyu <gi...@git.apache.org> on 2016/08/25 18:17:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-4490) Decouple Slot and Instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/25 18:54:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/25 18:57:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4459) Introduce SlotProvider for Scheduler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/25 18:59:20 UTC, 1 replies.
- [GitHub] flink pull request #2422: FLINK-4499: Introduce findbugs maven plugin - posted by smarthi <gi...@git.apache.org> on 2016/08/25 22:12:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/25 22:13:20 UTC, 8 replies.
- [GitHub] flink issue #2422: FLINK-4499: Introduce findbugs maven plugin - posted by smarthi <gi...@git.apache.org> on 2016/08/25 22:13:41 UTC, 2 replies.
- [jira] [Created] (FLINK-4500) Cassandra sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 22:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4501) Cassandra sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 22:53:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4501) Cassandra sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 22:54:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 23:42:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4478) Implement heartbeat logic - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/26 04:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4459) Introduce SlotProvider for Scheduler - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/26 05:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/26 06:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4504) Support user to decide whether the result of an operator is presistent - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/26 07:37:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4504) Support user to decide whether the result of an operator is presistent - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/26 07:38:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4489) Implement TaskManager's SlotManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/26 07:40:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/26 08:38:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-4487) Need tools for managing the yarn-session better - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/26 08:40:20 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/26 09:01:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/26 09:02:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/26 09:10:21 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/26 09:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4505) Implement abstract TaskManagerFactory to bring up TaskManager for different modes - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/26 09:39:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4505) Implement TaskManagerFactory to bring up TaskManager for different modes - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/26 09:40:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4505) Implement TaskManagerFactory to bring up TaskManager for different modes - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/26 09:40:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/26 10:09:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true - posted by "Michael Wong (JIRA)" <ji...@apache.org> on 2016/08/26 10:11:20 UTC, 0 replies.
- [GitHub] flink pull request #2423: [FLINK-4486] detached YarnSession: wait until clus... - posted by mxm <gi...@git.apache.org> on 2016/08/26 10:17:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/26 10:19:21 UTC, 0 replies.
- [GitHub] flink issue #2269: [FLINK-4190] Generalise RollingSink to work with arbitrar... - posted by joshfg <gi...@git.apache.org> on 2016/08/26 10:29:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/26 10:30:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4507) Deprecate savepoint backend config - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 12:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/26 14:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4509) Specify savepoint directory per savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4510) Always create CheckpointCoordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4511) Schedule periodic savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:39:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/26 14:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4512) Add option for persistent checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:49:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4440) Make API for edge/vertex creation less verbose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/26 14:59:22 UTC, 0 replies.
- [GitHub] flink pull request #2424: [FLINK-4459][Scheduler] Introduce SlotProvider for... - posted by KurtYoung <gi...@git.apache.org> on 2016/08/26 15:12:48 UTC, 0 replies.
- [jira] [Created] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/26 15:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/26 15:48:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4510) Always create CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/26 15:57:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4512) Add option for persistent checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/26 16:00:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-4509) Specify savepoint directory per savepoint - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/26 16:02:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4419) Batch improvement for supporting dfs as a ResultPartitionType - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/26 16:11:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/26 17:37:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/26 17:38:20 UTC, 1 replies.
- [GitHub] flink pull request #2425: FLINK-3930 Added shared secret based authorization... - posted by vijikarthi <gi...@git.apache.org> on 2016/08/26 19:14:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-3930) Implement Service-Level Authorization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/26 19:14:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4480) Incorrect link to elastic.co in documentation - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/08/26 19:22:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4480) Incorrect link to elastic.co in documentation - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/08/26 19:22:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-1379) add RSS feed for the blog - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/26 19:55:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/08/26 20:56:20 UTC, 0 replies.
- [GitHub] flink pull request #2426: [FLINK-3677] Remove Guava dependency from flink-co... - posted by mushketyk <gi...@git.apache.org> on 2016/08/26 21:00:45 UTC, 1 replies.
- [GitHub] flink issue #1985: [FLINK-1979] Add logistic loss, hinge loss and regulariza... - posted by skavulya <gi...@git.apache.org> on 2016/08/27 00:55:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-1979) Implement Loss Functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/27 00:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4516) ResourceManager leadership election - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/27 04:19:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4516) ResourceManager leadership election - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/27 04:20:20 UTC, 0 replies.
- [GitHub] flink pull request #2427: [FLINK-4516] [cluster management]leader election o... - posted by beyond1920 <gi...@git.apache.org> on 2016/08/27 06:26:51 UTC, 17 replies.
- [jira] [Commented] (FLINK-4516) ResourceManager leadership election - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/27 06:27:20 UTC, 22 replies.
- [jira] [Created] (FLINK-4517) scala code refactoring - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 09:15:22 UTC, 0 replies.
- [GitHub] flink pull request #2428: [FLINK-4517] scala code refactoring - posted by shijinkui <gi...@git.apache.org> on 2016/08/27 10:20:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-4517) scala code refactoring - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/27 10:21:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4518) maxLineLength change to 120 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 10:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4519) scala maxLineLength increased to 120 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 10:31:21 UTC, 0 replies.
- [GitHub] flink pull request #2429: [FLINK-4519] scala maxLineLength increased to 120 - posted by shijinkui <gi...@git.apache.org> on 2016/08/27 10:41:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/27 10:42:20 UTC, 6 replies.
- [jira] [Closed] (FLINK-4518) maxLineLength change to 120 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 10:43:20 UTC, 0 replies.
- [GitHub] flink pull request #2398: [FLINK-4440][gelly] Add Vertex.create and Edge.cre... - posted by mushketyk <gi...@git.apache.org> on 2016/08/27 22:28:20 UTC, 0 replies.
- [GitHub] flink pull request #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests - posted by mushketyk <gi...@git.apache.org> on 2016/08/27 22:30:33 UTC, 0 replies.
- [jira] [Created] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library - posted by "Hao Chen (JIRA)" <ji...@apache.org> on 2016/08/28 03:00:27 UTC, 0 replies.
- [jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/28 08:54:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4522) Gelly link broken in homepage - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/08/28 11:49:22 UTC, 0 replies.
- [GitHub] flink pull request #2431: [FLINK-4521] Fix "Submit new Job" panel in develop... - posted by mushketyk <gi...@git.apache.org> on 2016/08/28 12:05:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-4521) Fix "Submit new Job" panel in development mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/28 12:06:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 14:40:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 14:41:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 14:42:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 15:37:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 15:39:21 UTC, 0 replies.
- [GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl... - posted by vijikarthi <gi...@git.apache.org> on 2016/08/28 20:14:26 UTC, 0 replies.
- [GitHub] flink issue #2429: [FLINK-4519] scala maxLineLength increased to 120 - posted by shijinkui <gi...@git.apache.org> on 2016/08/29 00:37:53 UTC, 2 replies.
- [GitHub] flink issue #2375: [FLINK-4375][cluster management]Introduce rpc protocols i... - posted by wenlong88 <gi...@git.apache.org> on 2016/08/29 01:39:45 UTC, 0 replies.
- [GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas... - posted by chiwanpark <gi...@git.apache.org> on 2016/08/29 03:57:00 UTC, 12 replies.
- [GitHub] flink issue #2426: [FLINK-3677] Remove Guava dependency from flink-core - posted by mxm <gi...@git.apache.org> on 2016/08/29 08:36:55 UTC, 3 replies.
- [jira] [Created] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/29 09:03:20 UTC, 0 replies.
- [GitHub] flink issue #2428: [FLINK-4517] scala code refactoring - posted by StephanEwen <gi...@git.apache.org> on 2016/08/29 09:15:42 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4341) Kinesis connector does not emit maximum watermark properly - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/29 09:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4525) Drop the "eager split pre-assignment" code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 10:00:29 UTC, 0 replies.
- [GitHub] flink pull request #2432: [FLINK-4514][kinesis-connector] Handle unexpected ... - posted by tzulitai <gi...@git.apache.org> on 2016/08/29 10:04:50 UTC, 3 replies.
- [jira] [Commented] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/29 10:05:20 UTC, 12 replies.
- [jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/29 10:05:20 UTC, 1 replies.
- [GitHub] flink issue #2432: [FLINK-4514][kinesis-connector] Handle unexpected Expired... - posted by tzulitai <gi...@git.apache.org> on 2016/08/29 10:11:11 UTC, 7 replies.
- [GitHub] flink pull request #2433: docs: fixed timestamp extractor documentation Java... - posted by jpzk <gi...@git.apache.org> on 2016/08/29 10:11:11 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4478) Implement heartbeat logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 10:19:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4287) Unable to access secured HBase from a yarn-session. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/29 10:49:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4522) Gelly link broken in homepage - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/29 11:55:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/29 12:38:21 UTC, 2 replies.
- [GitHub] flink issue #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin - posted by StephanEwen <gi...@git.apache.org> on 2016/08/29 12:48:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/29 12:57:20 UTC, 0 replies.
- [GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t... - posted by kl0u <gi...@git.apache.org> on 2016/08/29 13:10:35 UTC, 4 replies.
- [jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/29 13:11:20 UTC, 6 replies.
- [jira] [Created] (FLINK-4526) ApplicationClient: remove redundant proxy messages - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/29 13:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/29 13:29:32 UTC, 4 replies.
- [jira] [Created] (FLINK-4527) Drop the "flinkAccumulators" from the Execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 13:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4528) Mark runAsync and scheduleAsync methods protected - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 13:48:20 UTC, 0 replies.
- [GitHub] flink issue #2384: [FLINK-4420] [table] Introduce star(*) to select all of t... - posted by twalthr <gi...@git.apache.org> on 2016/08/29 13:54:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4420) Introduce star(*) to select all of the columns in the table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/29 14:03:20 UTC, 0 replies.
- [GitHub] flink issue #2102: [FLINK-4068] [tableAPI] Move constant computations out of... - posted by twalthr <gi...@git.apache.org> on 2016/08/29 14:07:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/29 14:07:20 UTC, 1 replies.
- [GitHub] flink pull request #2436: [FLINK-4528] [rpc] Marks main thread execution met... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/29 14:07:42 UTC, 2 replies.
- [jira] [Commented] (FLINK-4528) Mark runAsync and scheduleAsync methods protected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/29 14:08:20 UTC, 6 replies.
- [GitHub] flink issue #2433: docs: fixed timestamp extractor documentation Java exampl... - posted by rmetzger <gi...@git.apache.org> on 2016/08/29 14:16:08 UTC, 0 replies.
- [GitHub] flink pull request #2437: [FLINK-4526][yarn] remove redundant proxy messages - posted by mxm <gi...@git.apache.org> on 2016/08/29 14:17:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-4526) ApplicationClient: remove redundant proxy messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/29 14:18:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 14:22:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4527) Drop the "flinkAccumulators" from the Execution - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/29 14:40:20 UTC, 0 replies.
- [GitHub] flink pull request #2438: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/29 14:40:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/29 14:41:21 UTC, 1 replies.
- [GitHub] flink issue #2434: [FLINK-4496] Refactor the TimeServiceProvider to take a T... - posted by aljoscha <gi...@git.apache.org> on 2016/08/29 15:18:01 UTC, 0 replies.
- [jira] [Created] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 15:38:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4525) Drop the "eager split pre-assignment" code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 16:12:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-4525) Drop the "eager split pre-assignment" code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 16:13:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/29 16:21:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/29 16:21:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4526) ApplicationClient: remove redundant proxy messages - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/29 16:22:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4495) Running multiple jobs on yarn (without yarn-session) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/29 16:25:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/29 16:31:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4361) Replace Scala Futures - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 16:45:20 UTC, 0 replies.
- [GitHub] flink issue #2436: [FLINK-4528] [rpc] Marks main thread execution methods in... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/29 16:57:15 UTC, 3 replies.
- [jira] [Created] (FLINK-4531) Thread.stop() is deprecated - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/29 17:26:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4531) Thread.stop() is deprecated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/29 18:04:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4531) Thread.stop() is deprecated - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 18:27:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2247) Improve the way memory is reported in the web frontend - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/08/29 23:59:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/08/30 00:01:38 UTC, 1 replies.
- [jira] [Closed] (FLINK-4375) Introduce rpc protocols implemented by job manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/30 02:30:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4484) FLIP-10: Unify Savepoints and Checkpoints - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/30 04:37:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/30 04:52:21 UTC, 0 replies.
- [GitHub] flink pull request #2439: update storm verion to 1.0.0 in flink-storm and fl... - posted by liuyuzhong <gi...@git.apache.org> on 2016/08/30 06:32:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4450) update storm version to 1.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/30 06:32:20 UTC, 7 replies.
- [jira] [Resolved] (FLINK-4190) Generalise RollingSink to work with arbitrary buckets - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/30 08:42:21 UTC, 0 replies.
- [GitHub] flink pull request #2269: [FLINK-4190] Generalise RollingSink to work with a... - posted by joshfg <gi...@git.apache.org> on 2016/08/30 08:58:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-4379) Add Rescalable Non-Partitioned State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/30 09:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4532) Allow independent metrics reporter for tasks - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/30 10:16:21 UTC, 0 replies.
- [GitHub] flink pull request #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStrea... - posted by asfgit <gi...@git.apache.org> on 2016/08/30 13:29:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/30 13:30:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/30 13:30:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/30 13:30:20 UTC, 0 replies.
- [GitHub] flink pull request #2440: Keyed backend refactor - posted by StefanRRichter <gi...@git.apache.org> on 2016/08/30 13:34:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4532) Allow independent metrics reporter for tasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/30 13:40:20 UTC, 4 replies.
- [jira] [Updated] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library - posted by "Hao Chen (JIRA)" <ji...@apache.org> on 2016/08/30 14:49:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library - posted by "Hao Chen (JIRA)" <ji...@apache.org> on 2016/08/30 14:50:20 UTC, 0 replies.
- [GitHub] flink pull request #2441: [FLINK-3580] [table] Add current time point functi... - posted by twalthr <gi...@git.apache.org> on 2016/08/30 15:41:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/30 16:04:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4533) Unprotected access to meters in StatsDReporter#report() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/30 17:30:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/30 17:33:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/30 17:35:21 UTC, 2 replies.
- [GitHub] flink issue #2427: [FLINK-4516] [cluster management]leader election of resou... - posted by beyond1920 <gi...@git.apache.org> on 2016/08/31 01:55:50 UTC, 4 replies.
- [jira] [Updated] (FLINK-4535) ResourceManager process registration from TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/31 02:55:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4535) ResourceManager process registration from TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/31 02:55:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4532) Allow independent metrics reporter for tasks - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/31 03:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4536) Possible thread leak in Task Manager - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/08/31 04:42:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/31 05:45:21 UTC, 3 replies.
- [GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a... - posted by liuyuzhong <gi...@git.apache.org> on 2016/08/31 06:56:22 UTC, 2 replies.
- [GitHub] flink issue #2441: [FLINK-3580] [table] Add current time point functions - posted by twalthr <gi...@git.apache.org> on 2016/08/31 07:20:34 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/08/31 08:19:21 UTC, 0 replies.
- [GitHub] flink issue #2438: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and Re... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 09:12:45 UTC, 0 replies.
- [GitHub] flink issue #2402: [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokens... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 09:19:50 UTC, 0 replies.
- [jira] [Created] (FLINK-4537) ResourceManager registration with JobManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 10:30:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4535) ResourceManager registration with TaskExecutor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 10:31:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4449) Heartbeat Manager integration with JobMaster / TaskExecutor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 11:46:20 UTC, 0 replies.
- [GitHub] flink issue #2421: FLINK-4482 numUnsuccessfulCheckpointsTriggers is accessed... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 11:48:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4348) Implement slot allocation protocol - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 11:49:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4348) Implement slot allocation protocol with TaskExecutor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 11:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4538) Implement slot allocation protocol with JobMaster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 11:50:20 UTC, 0 replies.
- [GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-... - posted by liuyuzhong <gi...@git.apache.org> on 2016/08/31 12:02:00 UTC, 3 replies.
- [jira] [Created] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 12:04:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4490) Decouple Slot and Instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 12:06:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4540) Detached job execution may prevent cluster shutdown - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 12:52:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4541) Support for SQL NOT IN operator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 13:16:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/31 13:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4542) Add support for MULTISET type and operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 13:59:20 UTC, 0 replies.
- [GitHub] flink pull request #2442: [FLINK-4148] incorrect calculation minDist distanc... - posted by xhumanoid <gi...@git.apache.org> on 2016/08/31 14:06:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 14:13:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 14:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 14:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 14:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2443: [FLINK-3950] Implement MeterView - posted by zentol <gi...@git.apache.org> on 2016/08/31 14:26:54 UTC, 0 replies.
- [jira] [Updated] (FLINK-4542) Add support for MULTISET type and operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 14:28:22 UTC, 2 replies.
- [GitHub] flink pull request #2444: [FLINK-4543] [network] Fix potential deadlock in S... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 14:31:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/31 14:31:21 UTC, 1 replies.
- [GitHub] flink issue #2444: [FLINK-4543] [network] Fix potential deadlock in SpilledS... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 14:31:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 14:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 15:17:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4363) Implement TaskManager basic startup of all components in java - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 15:21:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4347) Implement SlotManager core - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 15:22:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4516) ResourceManager leadership election - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 15:22:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/31 15:41:20 UTC, 0 replies.
- [GitHub] flink pull request #2445: [FLINK-4544] Refactor old CPU metric initializatio... - posted by zentol <gi...@git.apache.org> on 2016/08/31 15:50:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/31 15:50:22 UTC, 3 replies.
- [GitHub] flink pull request #2446: [hotfix] Fixes unstable ContinuousFileMonitoringTe... - posted by kl0u <gi...@git.apache.org> on 2016/08/31 15:57:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-3190) Retry rate limits for DataStream API - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/08/31 16:26:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/08/31 16:29:21 UTC, 0 replies.
- [GitHub] flink issue #2445: [FLINK-4544] Refactor old CPU metric initialization - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 16:32:59 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 17:04:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 17:04:20 UTC, 0 replies.
- [GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t... - posted by StephanEwen <gi...@git.apache.org> on 2016/08/31 17:17:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4456) Replace ActorGateway in Task by interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/31 18:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4545) Flink automatically manages TM network buffer - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/31 18:46:20 UTC, 0 replies.
- [GitHub] flink pull request #2448: [FLINK-4521] Enhance dashboard to show execution a... - posted by mushketyk <gi...@git.apache.org> on 2016/08/31 21:11:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/31 21:18:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/31 21:19:20 UTC, 0 replies.
- [GitHub] flink pull request #2440: [FLINK-3755] Introduce key groups for key-value st... - posted by StefanRRichter <gi...@git.apache.org> on 2016/08/31 22:02:18 UTC, 0 replies.
- [GitHub] flink pull request #2449: [FLINK-4455] [FLINK-4424] [networkenv] Make Networ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/31 23:48:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/08/31 23:48:20 UTC, 0 replies.
- [GitHub] flink pull request #2450: [Flink-4458] Replace ForkableFlinkMiniCluster by L... - posted by tillrohrmann <gi...@git.apache.org> on 2016/08/31 23:53:25 UTC, 0 replies.