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

---

- [GitHub] flink pull request: [FLINK-3854] Support Avro key-value rolling si... - posted by IgorBerman <gi...@git.apache.org> on 2016/05/01 11:49:06 UTC, 13 replies.
- [jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 11:49:12 UTC, 13 replies.
- [GitHub] flink pull request: [FLINK-3845] [gelly] Gelly allows duplicate ve... - posted by vasia <gi...@git.apache.org> on 2016/05/01 12:50:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 12:51:12 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3853] [gelly] Reduce object creation in... - posted by vasia <gi...@git.apache.org> on 2016/05/01 12:52:02 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3846] [gelly] Graph.removeEdges also re... - posted by vasia <gi...@git.apache.org> on 2016/05/01 12:52:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3846) Graph.removeEdges also removes duplicate edges - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 12:52:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-3853) Reduce object creation in Gelly utility mappers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 12:52:12 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3853) Reduce object creation in Gelly utility mappers - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/01 13:51:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3846) Graph.removeEdges also removes duplicate edges - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/01 13:51:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3847] Restructure flink-table test pack... - posted by vasia <gi...@git.apache.org> on 2016/05/01 14:17:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-3847) Reorganize package structure of flink-table - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 14:18:12 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3847) Reorganize package structure of flink-table - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/01 14:49:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G... - posted by vasia <gi...@git.apache.org> on 2016/05/01 15:25:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-3771) Methods for translating Graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 15:26:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/05/01 16:40:12 UTC, 77 replies.
- [jira] [Assigned] (FLINK-3190) Retry rate limits for DataStream API - posted by "Michał Fijołek (JIRA)" <ji...@apache.org> on 2016/05/01 19:47:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3190] failure rate restart strategy - posted by fijolekProjects <gi...@git.apache.org> on 2016/05/01 19:50:33 UTC, 4 replies.
- [jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/01 19:51:12 UTC, 5 replies.
- [jira] [Commented] (FLINK-3855) Upgrade Jackson version - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/02 08:10:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/02 09:56:12 UTC, 5 replies.
- [jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/02 09:59:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3786] [core] [api-extending] Add BigDec... - posted by twalthr <gi...@git.apache.org> on 2016/05/02 10:50:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-3786) Add BigDecimal and BigInteger as Basic types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 10:50:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 11:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 11:14:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3786) Add BigDecimal and BigInteger as Basic types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 11:16:12 UTC, 0 replies.
- [GitHub] flink pull request: Jackson version upgrade: default from 2.4.2 to... - posted by aljoscha <gi...@git.apache.org> on 2016/05/02 11:18:15 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S... - posted by vasia <gi...@git.apache.org> on 2016/05/02 12:03:38 UTC, 12 replies.
- [jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 12:04:12 UTC, 12 replies.
- [jira] [Created] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/02 12:12:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H... - posted by gallenvara <gi...@git.apache.org> on 2016/05/02 12:21:49 UTC, 87 replies.
- [jira] [Commented] (FLINK-2099) Add a SQL API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/02 13:47:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3581] [FLINK-3582] State Iterator and A... - posted by aljoscha <gi...@git.apache.org> on 2016/05/02 14:03:39 UTC, 7 replies.
- [jira] [Commented] (FLINK-3581) Add Special Aligned Event-Time WindowOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 14:04:12 UTC, 7 replies.
- [jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/02 14:30:13 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3837] [table] Create FLOOR/CEIL functio... - posted by fhueske <gi...@git.apache.org> on 2016/05/02 14:36:54 UTC, 2 replies.
- [jira] [Commented] (FLINK-3837) Create FLOOR/CEIL function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 14:37:12 UTC, 2 replies.
- [jira] [Closed] (FLINK-2099) Add a SQL API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/02 14:44:13 UTC, 0 replies.
- [GitHub] flink pull request: Flink 3750 fixed - posted by fhueske <gi...@git.apache.org> on 2016/05/02 15:07:15 UTC, 69 replies.
- [jira] [Created] (FLINK-3858) Date is wrongly serialized - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 15:48:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2259][ml] Add Train-Testing Splitters - posted by rawkintrevo <gi...@git.apache.org> on 2016/05/02 15:53:58 UTC, 15 replies.
- [jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 15:54:12 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-3821] Reduce Guava usage in flink-java - posted by zentol <gi...@git.apache.org> on 2016/05/02 16:00:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-3821) Reduce Guava usage in flink-java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 16:01:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 16:45:12 UTC, 22 replies.
- [jira] [Resolved] (FLINK-3837) Create FLOOR/CEIL function - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 17:01:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3859) Add BigDecimal/BigInteger support to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 17:11:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1991) Return Table as DataSet - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/02 17:15:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo... - posted by yjshen <gi...@git.apache.org> on 2016/05/02 17:34:08 UTC, 71 replies.
- [jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 17:34:13 UTC, 66 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/05/02 17:54:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/02 18:02:13 UTC, 3 replies.
- [jira] [Updated] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/02 18:03:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/02 18:03:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/02 18:03:13 UTC, 2 replies.
- [jira] [Closed] (FLINK-3771) Methods for translating Graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/02 18:15:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/02 19:11:12 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3650 Add maxBy/minBy to Scala DataSet AP... - posted by ramkrish86 <gi...@git.apache.org> on 2016/05/02 19:18:57 UTC, 15 replies.
- [jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/02 19:19:12 UTC, 16 replies.
- [jira] [Commented] (FLINK-3772) Graph algorithms for vertex and edge degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/02 20:09:12 UTC, 13 replies.
- [jira] [Assigned] (FLINK-1996) Add output methods to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/02 22:04:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/02 23:40:12 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s... - posted by fhueske <gi...@git.apache.org> on 2016/05/02 23:41:14 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass... - posted by fhueske <gi...@git.apache.org> on 2016/05/02 23:59:28 UTC, 2 replies.
- [jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/03 00:00:14 UTC, 2 replies.
- [GitHub] flink pull request: [Flink-3691] extend avroinputformat to support... - posted by fhueske <gi...@git.apache.org> on 2016/05/03 00:59:22 UTC, 6 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/03 10:52:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1827] and small fixes in some tests - posted by fhueske <gi...@git.apache.org> on 2016/05/03 11:08:22 UTC, 8 replies.
- [jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/03 11:09:12 UTC, 16 replies.
- [jira] [Resolved] (FLINK-3793) Re-organize the Table API and SQL docs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/03 11:15:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/03 11:52:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/03 12:18:12 UTC, 7 replies.
- [jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/05/03 12:58:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql.... - posted by twalthr <gi...@git.apache.org> on 2016/05/03 13:00:06 UTC, 17 replies.
- [GitHub] flink pull request: FLINK-3808: Refactor the whole file monitoring... - posted by zentol <gi...@git.apache.org> on 2016/05/03 13:43:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/03 13:44:12 UTC, 4 replies.
- [jira] [Commented] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/03 14:01:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/03 14:20:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3825] Documentation for CEP Scala API. - posted by StefanRRichter <gi...@git.apache.org> on 2016/05/03 14:22:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-3825) Update CEP documentation to include Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/03 14:23:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/03 14:25:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1996] [tableApi] Add TableSink interfac... - posted by fhueske <gi...@git.apache.org> on 2016/05/03 14:26:08 UTC, 5 replies.
- [jira] [Commented] (FLINK-1996) Add output methods to Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/03 14:26:12 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ... - posted by rmetzger <gi...@git.apache.org> on 2016/05/03 14:28:40 UTC, 4 replies.
- [jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/03 14:29:12 UTC, 4 replies.
- [jira] [Closed] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction - posted by "Sergio Ramírez (JIRA)" <ji...@apache.org> on 2016/05/03 15:02:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/03 15:26:13 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/03 15:28:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3661) Make Scala 2.11.x the default Scala version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/03 15:28:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/03 15:29:12 UTC, 0 replies.
- [GitHub] flink pull request: Timer coalescing across keys and cleanup of un... - posted by aljoscha <gi...@git.apache.org> on 2016/05/03 15:56:16 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/03 15:57:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3862) Restructure community website - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/03 17:37:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3862) Restructure community slide - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/03 17:37:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3862) Restructure community website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/03 17:45:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/03 18:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3864) Yarn tests don't check for prohibited strings in log output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/03 19:12:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/05/03 20:53:12 UTC, 15 replies.
- [jira] [Assigned] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/05/03 20:53:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/05/03 21:11:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3865) ExecutionConfig NullPointerException with second execution - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/03 21:58:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/05/04 01:36:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/05/04 01:38:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3857][Streaming Connectors]Add reconnec... - posted by sbcd90 <gi...@git.apache.org> on 2016/05/04 04:27:31 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-3701] reuse serializer lists in Executi... - posted by mxm <gi...@git.apache.org> on 2016/05/04 10:24:21 UTC, 12 replies.
- [jira] [Commented] (FLINK-3701) Cant call execute after first execution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/04 10:25:12 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/04 10:30:13 UTC, 1 replies.
- [GitHub] flink pull request: [docs] Added IntelliJ code style - posted by dawidwys <gi...@git.apache.org> on 2016/05/04 08:42:59 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3860] [connector-wikiedits] Add retry l... - posted by uce <gi...@git.apache.org> on 2016/05/04 08:43:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-3864) Yarn per-job cluster sets parallelism to 1 instead of #taskmanagers * #slots - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/04 08:45:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/04 08:55:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/04 09:06:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3865) ExecutionConfig NullPointerException with second execution - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/04 09:14:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/04 11:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3867) Provide virtualized Flink architecture for testing purposes - posted by "Andreas Kempa-Liehr (JIRA)" <ji...@apache.org> on 2016/05/04 11:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3868) Specialized CopyableValue serializers and comparators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/04 13:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/04 14:04:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3825) Update CEP documentation to include Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/04 15:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3870) Add IntelliJ code style file - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/05/04 15:40:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3865) ExecutionConfig NullPointerException with second execution - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/04 16:02:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3875) Add a TableSink for Elasticsearch - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 16:42:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/05/04 16:53:12 UTC, 6 replies.
- [jira] [Created] (FLINK-3876) Improve documentation of Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/04 17:50:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3876) Improve documentation of Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/04 18:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3876) Improve documentation of Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/04 18:14:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 19:27:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 19:28:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-1996) Add output methods to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 19:28:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/04 19:29:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/05/04 19:47:13 UTC, 3 replies.
- [jira] [Created] (FLINK-3877) Create TranslateFunction interface for Graph translators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/04 20:17:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ... - posted by chobeat <gi...@git.apache.org> on 2016/05/05 07:33:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/05 07:34:12 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto... - posted by alkagin <gi...@git.apache.org> on 2016/05/05 13:49:34 UTC, 19 replies.
- [jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/05 13:50:12 UTC, 19 replies.
- [jira] [Commented] (FLINK-2971) Add outer joins to the Table API - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/05/05 16:00:15 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System - posted by rmetzger <gi...@git.apache.org> on 2016/05/05 17:10:09 UTC, 25 replies.
- [jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/05 17:10:13 UTC, 24 replies.
- [jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/05/05 18:47:12 UTC, 10 replies.
- [jira] [Created] (FLINK-3878) File cache doesn't support multiple duplicate temp directories - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/05/05 23:27:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3878) File cache doesn't support multiple duplicate temp directories - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/05/05 23:31:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3878) File cache doesn't support multiple duplicate temp directories - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/05/06 02:56:12 UTC, 2 replies.
- [GitHub] flink pull request: FLINK-3878: File cache doesn't support multipl... - posted by kkrugler <gi...@git.apache.org> on 2016/05/06 03:35:49 UTC, 3 replies.
- [jira] [Commented] (FLINK-1873) Distributed matrix implementation - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/05/06 07:51:12 UTC, 22 replies.
- [GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert... - posted by vasia <gi...@git.apache.org> on 2016/05/06 10:00:34 UTC, 11 replies.
- [jira] [Updated] (FLINK-1873) Distributed matrix implementation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/06 10:07:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/06 13:22:12 UTC, 13 replies.
- [jira] [Created] (FLINK-3879) Native implementation of HITS algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/06 15:11:13 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-3836] Add LongHistogram accumulator - posted by mbode <gi...@git.apache.org> on 2016/05/06 15:13:22 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3879] [gelly] Native implementation of ... - posted by greghogan <gi...@git.apache.org> on 2016/05/06 15:38:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/06 15:39:12 UTC, 17 replies.
- [jira] [Created] (FLINK-3880) Use ConcurrentHashMap for Accumulators - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/05/06 15:41:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3879) Native implementation of HITS algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/06 15:58:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3880) Use ConcurrentHashMap for Accumulators - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/06 16:21:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3880) Use ConcurrentHashMap for Accumulators - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/06 16:21:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3877] [gelly] Create TranslateFunction ... - posted by greghogan <gi...@git.apache.org> on 2016/05/06 16:42:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-3877) Create TranslateFunction interface for Graph translators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/06 16:43:12 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/06 17:55:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/06 22:57:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/06 22:57:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-3618) Rename abstract UDF classes in Scatter-Gather implementation - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/05/07 10:06:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3155] - posted by tonybaines <gi...@git.apache.org> on 2016/05/07 14:20:10 UTC, 1 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/05/07 14:20:12 UTC, 3 replies.
- [jira] [Created] (FLINK-3881) Error in Java 8 Documentation Sample - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/07 16:23:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3881) Error in Java 8 Documentation Sample - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/07 16:24:12 UTC, 5 replies.
- [jira] [Updated] (FLINK-3881) Error in Java 8 Documentation Sample - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/07 16:51:12 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3881] [docs] Java 8 Documetation Sample... - posted by mans2singh <gi...@git.apache.org> on 2016/05/07 19:15:25 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-3881) Error in Java 8 Documentation Sample - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/07 19:24:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3882) Errors in sample Java code for the Elasticsearch 2.x sink - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/08 20:31:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3882][docs] Fix errors in sample Java c... - posted by markreddy <gi...@git.apache.org> on 2016/05/08 20:49:52 UTC, 3 replies.
- [jira] [Commented] (FLINK-3882) Errors in sample Java code for the Elasticsearch 2.x sink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/08 20:50:12 UTC, 3 replies.
- [jira] [Created] (FLINK-3883) Rename flink clients for inclusion on system path - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/08 23:26:12 UTC, 0 replies.
- [GitHub] flink pull request: Build a flink-connector-kafka-0.9 test-jar - posted by scosenza <gi...@git.apache.org> on 2016/05/08 23:57:33 UTC, 5 replies.
- [jira] [Updated] (FLINK-3883) Rename flink clients for inclusion on system path - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/09 02:47:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/09 08:43:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3869] Relax window fold generic paramet... - posted by aljoscha <gi...@git.apache.org> on 2016/05/09 08:44:40 UTC, 3 replies.
- [jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/09 08:45:13 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3881) Error in Java 8 Documentation Sample - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/09 08:51:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3883) Rename flink clients for inclusion on system path - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/09 08:57:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3884) Snapshot quickstart projects don't include snapshot repository - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/09 09:49:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3885) Revisit parallelism logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/09 10:22:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3842] [table] Fix handling null record/... - posted by twalthr <gi...@git.apache.org> on 2016/05/09 10:58:51 UTC, 4 replies.
- [jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/05/09 11:55:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2184] Cannot get last element with maxB... - posted by gallenvara <gi...@git.apache.org> on 2016/05/09 11:58:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-3880) Improve performance of Accumulator map - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/09 12:07:13 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/09 13:30:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3772) Graph algorithms for vertex and edge degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/09 13:46:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3886) Give a better error when the application Main class is not public. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/05/09 14:40:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3886) Give a better error when the application Main class is not public. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/05/09 14:45:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3880] remove mutex for user accumulator... - posted by mxm <gi...@git.apache.org> on 2016/05/09 14:56:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3880) Improve performance of Accumulator map - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/09 14:56:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/05/09 15:00:15 UTC, 0 replies.
- [jira] [Created] (FLINK-3887) Improve dependency management for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/09 15:09:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3886) Give a better error when the application Main class is not public. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/05/09 15:23:12 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3877) Create TranslateFunction interface for Graph translators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/09 16:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/05/09 18:54:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/05/10 07:47:12 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/10 09:07:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3880) Improve performance of Accumulator map - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 10:24:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3155] Update the versions in docker-con... - posted by mxm <gi...@git.apache.org> on 2016/05/10 10:28:56 UTC, 1 replies.
- [jira] [Created] (FLINK-3889) Make File Monitoring Function checkpointable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/10 11:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 12:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3891) Add a class containing all supported Table API types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/10 12:19:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3892) ConnectionUtils may die with NullPointerException - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 13:34:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3826) Broken test: StreamCheckpointingITCase - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/10 13:42:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3826] Broken test: StreamCheckpointingI... - posted by kl0u <gi...@git.apache.org> on 2016/05/10 14:03:57 UTC, 6 replies.
- [jira] [Commented] (FLINK-3826) Broken test: StreamCheckpointingITCase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/10 14:04:12 UTC, 5 replies.
- [jira] [Created] (FLINK-3893) LeaderChangeStateCleanupTest times out - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 14:22:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3894) Remove Program Packaging via Plans - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/10 14:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3895) Remove Focs for Program Packaging via Plans - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/10 14:37:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3895) Remove Focs for Program Packaging via Plans - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/05/10 15:02:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3893) LeaderChangeStateCleanupTest times out - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/10 15:11:12 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3768] [gelly] Clustering Coefficient - posted by greghogan <gi...@git.apache.org> on 2016/05/10 15:30:49 UTC, 7 replies.
- [jira] [Updated] (FLINK-3895) Remove Docs for Program Packaging via Plans - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/10 15:31:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3768) Clustering Coefficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/10 15:31:12 UTC, 4 replies.
- [jira] [Created] (FLINK-3896) Allow a StreamTask to be Externally Cancelled. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/10 16:08:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3896) Allow a StreamTask to be Externally Cancelled. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/10 16:12:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3667] refactor client communication - posted by mxm <gi...@git.apache.org> on 2016/05/10 17:20:47 UTC, 21 replies.
- [jira] [Commented] (FLINK-3667) Generalize client<->cluster communication - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/10 17:21:12 UTC, 20 replies.
- [jira] [Closed] (FLINK-3842) Fix handling null record/row in generated code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/10 20:38:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3821) Reduce Guava usage in flink-java - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/10 20:39:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3882) Errors in sample Java code for the Elasticsearch 2.x sink - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/10 20:40:12 UTC, 0 replies.
- [GitHub] flink pull request: [Flink 3758] Add possibility to register accum... - posted by knaufk <gi...@git.apache.org> on 2016/05/10 21:41:23 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3758] Add possibility to register accum... - posted by knaufk <gi...@git.apache.org> on 2016/05/10 21:49:09 UTC, 11 replies.
- [jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/10 22:58:12 UTC, 16 replies.
- [jira] [Issue Comment Deleted] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/05/11 02:27:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3891) Add a class containing all supported Table API types - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/11 03:28:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/11 03:56:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/11 04:01:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3780] [gelly] Jaccard Similarity - posted by greghogan <gi...@git.apache.org> on 2016/05/11 04:17:47 UTC, 37 replies.
- [jira] [Commented] (FLINK-3780) Jaccard Similarity - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/11 04:18:12 UTC, 37 replies.
- [GitHub] flink pull request: [Flink-2971][table] Add outer joins to the Tab... - posted by dawidwys <gi...@git.apache.org> on 2016/05/11 06:23:04 UTC, 51 replies.
- [GitHub] flink pull request: [FLINK-1979] Lossfunctions - posted by skavulya <gi...@git.apache.org> on 2016/05/11 07:17:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-1979) Implement Loss Functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/11 07:18:12 UTC, 19 replies.
- [jira] [Commented] (FLINK-2169) Add ParquetTableSource - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/05/11 08:13:13 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3852] update the quickstart module to i... - posted by markreddy <gi...@git.apache.org> on 2016/05/11 09:03:43 UTC, 14 replies.
- [jira] [Updated] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/11 10:21:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/11 10:22:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/11 10:22:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/11 10:23:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/11 11:39:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3898) Adamic-Adar Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/11 14:03:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3780) Jaccard Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/11 14:04:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/11 14:22:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3776] Flink Scala shell does not allow ... - posted by mxm <gi...@git.apache.org> on 2016/05/11 14:25:11 UTC, 8 replies.
- [jira] [Commented] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/11 14:25:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-3898) Adamic-Adar Similarity - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/11 15:09:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/11 15:10:14 UTC, 0 replies.
- [jira] [Closed] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/11 15:13:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/11 15:23:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3836] Add LongHistogram accumulator - posted by mbode <gi...@git.apache.org> on 2016/05/11 16:12:34 UTC, 9 replies.
- [jira] [Commented] (FLINK-3836) Change Histogram to enable Long counters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/11 16:13:12 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3868] [core] Specialized CopyableValue ... - posted by greghogan <gi...@git.apache.org> on 2016/05/11 17:39:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-3868) Specialized CopyableValue serializers and comparators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/11 17:40:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-3868) Specialized CopyableValue serializers and comparators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/11 17:40:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/11 22:26:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3889] Make File Monitoring Function che... - posted by kl0u <gi...@git.apache.org> on 2016/05/12 01:04:35 UTC, 21 replies.
- [GitHub] flink pull request: [FLINK-1979] Add logistic loss, hinge loss and... - posted by skavulya <gi...@git.apache.org> on 2016/05/12 03:43:14 UTC, 17 replies.
- [jira] [Commented] (FLINK-3889) Make File Monitoring Function checkpointable. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/12 09:10:12 UTC, 25 replies.
- [jira] [Commented] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/12 09:18:12 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/12 09:55:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/12 12:02:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3648) Introduce Trigger Test Harness - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/12 12:03:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/12 12:03:12 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/12 13:55:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/12 14:15:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3900) Set nullCheck=true as default in TableConfig - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/12 16:27:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3900) Set nullCheck=true as default in TableConfig - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/12 16:30:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3900) Set nullCheck=true as default in TableConfig - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/12 16:30:14 UTC, 6 replies.
- [jira] [Created] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/12 16:33:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3902) Discarded FileSystem checkpoints are lingering around - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/12 16:38:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3901) Create a RowCsvInputFormat to use as default CSV IF in Table API - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/12 16:39:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3903) Homebrew Installation - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/12 18:03:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3655] multiple directories (Paths) for ... - posted by gna-phetsarath <gi...@git.apache.org> on 2016/05/12 20:53:56 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3655] Multiple File Paths for InputFile... - posted by gna-phetsarath <gi...@git.apache.org> on 2016/05/13 00:22:15 UTC, 6 replies.
- [jira] [Closed] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/13 07:15:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3855) Upgrade Jackson version - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/13 07:16:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3878) File cache doesn't support multiple duplicate temp directories - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/13 07:20:12 UTC, 0 replies.
- [GitHub] flink pull request: Refactor StreamSourceContext - posted by zentol <gi...@git.apache.org> on 2016/05/13 08:18:36 UTC, 0 replies.
- [GitHub] flink pull request: Refactor MockStreamSourceContext - posted by zentol <gi...@git.apache.org> on 2016/05/13 08:18:41 UTC, 0 replies.
- [jira] [Updated] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/13 08:48:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/13 08:56:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/13 08:59:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3887) Improve dependency management for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/13 09:17:12 UTC, 6 replies.
- [jira] [Created] (FLINK-3905) Add KafkaOutputFormat (DataSet API) - posted by "Maximilian Bode (JIRA)" <ji...@apache.org> on 2016/05/13 09:21:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3447) Package Gelly algorithms by framework - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 12:42:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3906) Global Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 13:45:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/13 14:21:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3761] Introduction of key groups - posted by tillrohrmann <gi...@git.apache.org> on 2016/05/13 14:23:11 UTC, 11 replies.
- [jira] [Created] (FLINK-3907) Directed Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 14:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/13 15:18:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/13 15:21:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/13 16:12:12 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3901 - Added CsvRowInputFormat - posted by fpompermaier <gi...@git.apache.org> on 2016/05/13 16:21:29 UTC, 0 replies.
- [jira] [Created] (FLINK-3910) New self-join operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/13 18:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3911) Sort operation before a group reduce doesn't seem to be implemented on 1.0.2 - posted by "Patrice Freydiere (JIRA)" <ji...@apache.org> on 2016/05/13 20:33:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3911) Sort operation before a group reduce doesn't seem to be implemented on 1.0.2 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/13 20:57:12 UTC, 8 replies.
- [jira] [Created] (FLINK-3912) Typos in Batch Scala API Documentation - posted by "Ignacio N. Lucero Ascencio (JIRA)" <ji...@apache.org> on 2016/05/13 21:38:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3912] [docs] Fix errors in Batch Scala ... - posted by houcros <gi...@git.apache.org> on 2016/05/13 21:42:40 UTC, 3 replies.
- [jira] [Closed] (FLINK-3912) Typos in Batch Scala API Documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/13 22:28:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by chiwanpark <gi...@git.apache.org> on 2016/05/14 06:29:43 UTC, 41 replies.
- [jira] [Resolved] (FLINK-3701) Cant call execute after first execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/14 13:28:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3788) Programs extending App trait cause problems because of DelayedInit - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/14 15:27:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3882) Errors in sample Java code for the Elasticsearch 2.x sink - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/15 14:11:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2147) Approximate calculation of frequencies in data streams - posted by "Stavros Kontopoulos (JIRA)" <ji...@apache.org> on 2016/05/15 20:48:12 UTC, 17 replies.
- [jira] [Created] (FLINK-3913) Clean up documentation typos - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/15 23:51:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3913] [docs] clean up spelling mistakes - posted by markreddy <gi...@git.apache.org> on 2016/05/15 23:58:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3914) BlobServer.createTemporaryFilename() has concurrency safety problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/16 03:55:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3911) Sort operation before a group reduce doesn't seem to be implemented on 1.0.2 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/16 09:21:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-2147) Approximate calculation of frequencies in data streams - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 11:42:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2148] [contrib] Exact and approximate c... - posted by ggevay <gi...@git.apache.org> on 2016/05/16 11:49:49 UTC, 1 replies.
- [jira] [Updated] (FLINK-2148) Approximately calculate the number of distinct elements of a stream - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 11:53:12 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2146) Fast calculation of min/max with arbitrary eviction and triggers - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 12:10:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2145) Median calculation for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 12:35:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2142) GSoC project: Exact and Approximate Statistics for Data Streams and Windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 12:40:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-2144) Implement count, average, and variance for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 13:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2144) Implement count, average, and variance for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 13:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2144) Implement incremental count, average, and variance for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 13:15:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-2144) Incremental count, average, and variance for windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/16 13:17:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3768) Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/16 18:54:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2829] Confusing error message when Flin... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/16 21:14:29 UTC, 7 replies.
- [jira] [Commented] (FLINK-2829) Confusing error message when Flink cannot create enough task threads - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/16 21:15:13 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3900] Set nullCheck=true as default in ... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/16 21:23:38 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3782] ByteArrayOutputStream and ObjectO... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/16 22:19:26 UTC, 4 replies.
- [jira] [Commented] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/16 22:20:12 UTC, 5 replies.
- [jira] [Created] (FLINK-3915) Updating a Dataset in Flink using Flink's Table API - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/05/17 06:56:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3915) Updating a Dataset in Flink using Flink's Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/17 07:05:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3749) Improve decimal handling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/17 08:42:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3749) Improve decimal handling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/17 08:43:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3916) Allow generic types passing the Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/17 08:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3917) Remove mouse focus from plan visualizer - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/17 09:20:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3918) Not configuring any time characteristic leads to a ClassCastException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/17 10:14:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Rohit (JIRA)" <ji...@apache.org> on 2016/05/17 10:46:12 UTC, 4 replies.
- [jira] [Commented] (FLINK-3915) Updating a Dataset in Flink using Flink's Table API - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/05/17 12:06:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 12:28:12 UTC, 44 replies.
- [jira] [Created] (FLINK-3919) Distributed Linear Algebra: row-based matrix - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/05/17 12:34:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3920) Distributed Linear Algebra: block-based matrix - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/05/17 12:35:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3919) Distributed Linear Algebra: row-based matrix - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/05/17 12:38:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/17 12:52:12 UTC, 24 replies.
- [GitHub] flink pull request: [FLINK-3919][flink-ml] Distributed Linear Alge... - posted by chobeat <gi...@git.apache.org> on 2016/05/17 13:05:04 UTC, 25 replies.
- [jira] [Commented] (FLINK-3919) Distributed Linear Algebra: row-based matrix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 13:05:12 UTC, 25 replies.
- [jira] [Assigned] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/17 13:33:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3918) Not configuring any time characteristic leads to a ClassCastException - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/17 13:34:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/17 14:17:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3906] [gelly] Global Clustering Coeffic... - posted by greghogan <gi...@git.apache.org> on 2016/05/17 15:53:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-3906) Global Clustering Coefficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 15:54:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3906) Global Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/17 15:55:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3913) Clean up documentation typos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 17:29:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3488] Kafka08ITCase.testBigRecordJob fa... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/17 18:00:31 UTC, 3 replies.
- [jira] [Commented] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 18:01:12 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3805] BloomFilter initialized with no m... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/17 19:18:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-3805) BloomFilter initialized with no memory available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 19:19:12 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3914) BlobServer.createTemporaryFilename() has concurrency safety problem - posted by "Mark Reddy (JIRA)" <ji...@apache.org> on 2016/05/17 19:35:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3914] [runtime] fixed race when attempt... - posted by markreddy <gi...@git.apache.org> on 2016/05/17 19:50:28 UTC, 4 replies.
- [jira] [Commented] (FLINK-3914) BlobServer.createTemporaryFilename() has concurrency safety problem - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/17 19:51:12 UTC, 4 replies.
- [jira] [Created] (FLINK-3921) StringParser not specifying encoding to use - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/05/17 20:13:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3921) StringParser not specifying encoding to use - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/05/17 20:17:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3807) FastFailuresITCase deadlocks on Travis - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/17 21:06:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/17 21:20:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3900) Set nullCheck=true as default in TableConfig - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/17 21:21:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/17 21:21:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2829) Confusing error message when Flink cannot create enough task threads - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/17 21:22:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3805) BloomFilter initialized with no memory available - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/17 21:23:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3826) Broken test: StreamCheckpointingITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:46:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3826) Broken test: StreamCheckpointingITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:46:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:47:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:47:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:47:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:48:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:48:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/17 21:48:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3900) Set nullCheck=true as default in TableConfig - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/17 23:00:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-3913) Clean up documentation typos - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/17 23:00:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/17 23:02:12 UTC, 0 replies.
- [GitHub] flink pull request: [script] Simple fix of typo from JobManager to... - posted by hsaputra <gi...@git.apache.org> on 2016/05/18 01:17:07 UTC, 4 replies.
- [jira] [Closed] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/18 03:43:12 UTC, 0 replies.
- [GitHub] flink pull request: Support for bz2 compression in flink-core - posted by mtanski <gi...@git.apache.org> on 2016/05/18 04:09:25 UTC, 6 replies.
- [jira] [Commented] (FLINK-3910) New self-join operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 08:53:12 UTC, 4 replies.
- [jira] [Updated] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/18 10:03:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/18 10:03:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3661) Make Scala 2.11.x the default Scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/18 10:03:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/18 10:18:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/18 10:20:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-3761) Introduce key group state backend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/18 11:30:13 UTC, 7 replies.
- [jira] [Commented] (FLINK-3632) Clean up Table API exceptions - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/18 12:30:13 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3632) Clean up Table API exceptions - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/18 12:32:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/18 13:07:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/18 13:13:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3924) Remove protobuf shading from Kinesis connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/18 13:22:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3909] update Maven Failsafe version - posted by mxm <gi...@git.apache.org> on 2016/05/18 13:40:14 UTC, 22 replies.
- [jira] [Commented] (FLINK-3141) Design of NULL values handling in operation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 13:44:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3141) Design of NULL values handling in operation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 13:44:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3139) NULL values handling in Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 13:45:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3656) Rework Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 13:53:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-3656) Rework TableAPI tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 13:53:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3546) Streaming Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 14:00:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3507) PruneEmptyRules does not prune empty node as expected. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 14:08:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3507) PruneEmptyRules does not prune empty node as expected. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 14:08:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3728) Find a way to exclude unsupported SQL features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 14:10:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2100) Add ITCases for all Table API examples - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 14:12:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2100) Add ITCases for all Table API examples - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 14:12:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3925) GraphAlgorithm to filter by maximum degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 15:28:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/18 15:34:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/18 15:35:12 UTC, 5 replies.
- [GitHub] flink pull request: [Flink-3926][TypeSystem]Incorrect implementati... - posted by yjshen <gi...@git.apache.org> on 2016/05/18 15:41:35 UTC, 1 replies.
- [jira] [Created] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/18 15:52:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 15:59:12 UTC, 9 replies.
- [jira] [Assigned] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/18 16:07:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/05/18 16:08:12 UTC, 8 replies.
- [jira] [Created] (FLINK-3928) Potential overflow due to 32-bit int arithmetic - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/18 16:08:13 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/18 16:10:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3916) Allow generic types passing the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 16:14:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3728) Throw meaningful exceptions for unsupported SQL features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 16:16:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3772) Graph algorithms for vertex and edge degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 16:42:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3926][TypeSystem]Incorrect implementati... - posted by fhueske <gi...@git.apache.org> on 2016/05/18 16:42:48 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3928) Potential overflow due to 32-bit int arithmetic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 18:06:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3928) Potential overflow due to 32-bit int arithmetic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 18:30:13 UTC, 4 replies.
- [jira] [Created] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 19:07:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 19:14:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 19:15:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3925] GraphAlgorithm to filter by maxim... - posted by greghogan <gi...@git.apache.org> on 2016/05/18 19:20:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-3925) GraphAlgorithm to filter by maximum degree - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/18 19:21:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3925) GraphAlgorithm to filter by maximum degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 19:21:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3928] [gelly] Potential overflow due to... - posted by greghogan <gi...@git.apache.org> on 2016/05/18 19:21:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-3928) Potential overflow due to 32-bit int arithmetic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/18 19:22:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3930) Implement Service-Level Authorization - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 20:42:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3930) Implement Service-Level Authorization - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 20:45:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 20:45:13 UTC, 1 replies.
- [jira] [Created] (FLINK-3931) Implement Transport Encryption (SSL/TLS) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 21:01:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3931) Implement Transport Encryption (SSL/TLS) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 21:03:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3932) Implement State Backend Security - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 21:13:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-3699) Allow per-job Kerberos authentication - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/18 21:28:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 22:24:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3914) BlobServer.createTemporaryFilename() has concurrency safety problem - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 22:25:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3750) Make JDBCInputFormat a parallel source - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/18 22:25:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/19 08:20:12 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-3908] Fixed Parser's error state reset - posted by fpompermaier <gi...@git.apache.org> on 2016/05/19 09:42:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/19 09:51:12 UTC, 5 replies.
- [jira] [Issue Comment Deleted] (FLINK-3908) FieldParsers error state is not reset correctly to NONE - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/05/19 09:52:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3892] return null when hostname unresol... - posted by mxm <gi...@git.apache.org> on 2016/05/19 10:06:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-3892) ConnectionUtils may die with NullPointerException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/19 10:07:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3893] improve LeaderChangeStateCleanupT... - posted by mxm <gi...@git.apache.org> on 2016/05/19 10:08:09 UTC, 3 replies.
- [jira] [Commented] (FLINK-3543) Introduce ResourceManager component - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/19 10:10:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3543) Introduce ResourceManager component - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/19 10:26:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/19 10:32:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3933) Add an auto-type-extracting DeserializationSchema - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/19 10:35:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3933] [streaming API] Add AbstractDeser... - posted by StephanEwen <gi...@git.apache.org> on 2016/05/19 10:40:54 UTC, 6 replies.
- [jira] [Commented] (FLINK-3933) Add an auto-type-extracting DeserializationSchema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/19 10:41:12 UTC, 6 replies.
- [jira] [Created] (FLINK-3934) Prevent translation of non-equi joins in DataSetJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 12:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3935) Invalid check of key and ordering fields in PartitionNode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 12:11:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 13:12:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/05/19 14:31:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/05/19 14:50:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/05/19 14:52:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3922] [types] Infinite recursion on Typ... - posted by twalthr <gi...@git.apache.org> on 2016/05/19 15:08:42 UTC, 4 replies.
- [jira] [Created] (FLINK-3938) Yarn tests don't run on the current master - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/19 15:36:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3932) Implement State Backend Security - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/05/19 15:58:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3938] re-enable Yarn tests - posted by mxm <gi...@git.apache.org> on 2016/05/19 16:02:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-3938) Yarn tests don't run on the current master - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/19 16:03:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3927][yarn] make container id consisten... - posted by mxm <gi...@git.apache.org> on 2016/05/19 16:45:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/19 16:46:13 UTC, 2 replies.
- [jira] [Closed] (FLINK-3934) Prevent translation of non-equi joins in DataSetJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 20:27:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3935) Invalid check of key and ordering fields in PartitionNode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 20:28:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/19 22:53:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3939] [tableAPI] Prevent translation of... - posted by fhueske <gi...@git.apache.org> on 2016/05/20 08:59:19 UTC, 4 replies.
- [jira] [Commented] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/20 09:00:23 UTC, 4 replies.
- [jira] [Commented] (FLINK-3475) DISTINCT aggregate function support - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:16:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:22:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3940) Add support for ORDER BY OFFSET FETCH - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:23:12 UTC, 3 replies.
- [jira] [Created] (FLINK-3941) Add support for UNION (with duplicate elimination) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:27:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3942) Add support for INTERSECT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:31:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3943) Add support for EXCEPT (set minus) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 09:35:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/20 12:59:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/20 15:42:12 UTC, 4 replies.
- [jira] [Closed] (FLINK-3892) ConnectionUtils may die with NullPointerException - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/20 15:44:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3909) Maven Failsafe plugin may report SUCCESS on failed tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/20 15:44:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3892] ConnectionUtils may die with Null... - posted by asfgit <gi...@git.apache.org> on 2016/05/20 15:44:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3893) LeaderChangeStateCleanupTest times out - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/20 15:45:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3938) Yarn tests don't run on the current master - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/20 15:45:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3945) Degree annotation for directed graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/20 16:52:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3928) Potential overflow due to 32-bit int arithmetic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/20 20:31:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3780) Jaccard Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/20 20:31:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3946) State API Should Support Data Expiration - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/20 20:44:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3947) Provide low level access to RocksDB state backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/20 21:32:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 06:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 06:40:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 06:43:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3946) State API Should Support Data Expiration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 06:56:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 07:04:12 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 07:04:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/21 07:08:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3632][TableAPI]Clean up Table API excep... - posted by yjshen <gi...@git.apache.org> on 2016/05/21 08:09:34 UTC, 3 replies.
- [jira] [Updated] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/21 11:18:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu... - posted by aozturk <gi...@git.apache.org> on 2016/05/21 14:44:39 UTC, 23 replies.
- [jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/21 14:45:12 UTC, 23 replies.
- [jira] [Updated] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/21 14:56:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "Rami (JIRA)" <ji...@apache.org> on 2016/05/22 10:29:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2673] [type system] Add a comparator fo... - posted by chiwanpark <gi...@git.apache.org> on 2016/05/22 11:50:53 UTC, 4 replies.
- [jira] [Commented] (FLINK-2673) Scala API does not support Option type as key - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/22 11:51:13 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3728) Throw meaningful exceptions for unsupported SQL features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/22 12:14:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/22 13:49:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/22 14:54:12 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/22 14:54:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3728] [tableAPI] Improve error message ... - posted by fhueske <gi...@git.apache.org> on 2016/05/22 15:53:02 UTC, 5 replies.
- [jira] [Commented] (FLINK-3728) Throw meaningful exceptions for unsupported SQL features - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/22 15:53:12 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/22 16:28:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:23:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:23:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3949) Collect Metrics in Runtime Operators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:24:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3950) Add Meter Metric Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3951) Add Histogram Metric Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:26:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/22 19:27:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3952) Bump Netty to 4.1 - posted by "rektide de la fey (JIRA)" <ji...@apache.org> on 2016/05/22 22:53:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3952) Bump Netty to 4.1 - posted by "rektide de la fey (JIRA)" <ji...@apache.org> on 2016/05/22 22:53:12 UTC, 0 replies.
- [GitHub] flink pull request: - posted by zentol <gi...@git.apache.org> on 2016/05/23 05:18:44 UTC, 5 replies.
- [jira] [Commented] (FLINK-3953) Surefire plugin executes unit tests twice - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 10:04:12 UTC, 3 replies.
- [jira] [Created] (FLINK-3953) Surefire plugin executes unit tests twice - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 10:04:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3953] rename unit-tests execution to de... - posted by mxm <gi...@git.apache.org> on 2016/05/23 10:10:54 UTC, 2 replies.
- [jira] [Closed] (FLINK-3953) Surefire plugin executes unit tests twice - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 10:39:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 10:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3954) Installing Flink on EMR using EMR bootstrap action - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/05/23 11:31:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi... - posted by kl0u <gi...@git.apache.org> on 2016/05/23 13:08:05 UTC, 9 replies.
- [jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/23 13:08:12 UTC, 16 replies.
- [jira] [Created] (FLINK-3955) Change Table.toSink() to Table.writeToSink() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/23 13:13:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3896) Allow a StreamTask to be Externally Cancelled. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/23 13:18:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3955) Change Table.toSink() to Table.writeToSink() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/05/23 13:24:13 UTC, 6 replies.
- [jira] [Created] (FLINK-3956) Make FileInputFormats in Streaming independent from the Configuration object - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/23 13:25:12 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3955) Change Table.toSink() to Table.writeToSink() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/05/23 13:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3957) Breaking API changes for Flink 2.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/23 14:07:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/23 14:14:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3959) Remove implicit sinks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/23 14:29:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/23 14:32:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3632) Clean up Table API exceptions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/23 14:33:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3952) Bump Netty to 4.1 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/23 14:47:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-3956) Make FileInputFormats independent from Configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/23 14:56:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3956) Make FileInputFormats independent from Configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/23 14:56:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-3959) Remove implicit sinks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/23 15:00:15 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3941) Add support for UNION (with duplicate elimination) - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/23 16:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3960) EventTimeCheckpointingITCase fails with a segmentation fault - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 16:29:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/23 16:30:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3945] [gelly] Degree annotation for dir... - posted by greghogan <gi...@git.apache.org> on 2016/05/23 16:51:22 UTC, 4 replies.
- [jira] [Commented] (FLINK-3945) Degree annotation for directed graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/23 16:52:12 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3960] ignore EventTimeWindowCheckpointi... - posted by mxm <gi...@git.apache.org> on 2016/05/23 17:17:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/23 17:18:12 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3955] [tableAPI] Rename Table.toSink() ... - posted by fhueske <gi...@git.apache.org> on 2016/05/23 17:45:18 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3586] Fix potential overflow of Long AV... - posted by fhueske <gi...@git.apache.org> on 2016/05/23 17:50:17 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3941][TableAPI]Add support for UNION (w... - posted by yjshen <gi...@git.apache.org> on 2016/05/24 05:00:31 UTC, 24 replies.
- [jira] [Commented] (FLINK-3941) Add support for UNION (with duplicate elimination) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/24 05:01:13 UTC, 23 replies.
- [jira] [Created] (FLINK-3961) Possibility to write output to multiple locations based on partitions - posted by "Kirsti Laurila (JIRA)" <ji...@apache.org> on 2016/05/24 05:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3699) Allow per-job Kerberos authentication - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/05/24 08:10:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3728) Throw meaningful exceptions for unsupported SQL features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/24 09:38:14 UTC, 0 replies.
- [jira] [Closed] (FLINK-3955) Change Table.toSink() to Table.writeToSink() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/24 09:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 09:52:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 09:55:12 UTC, 5 replies.
- [jira] [Created] (FLINK-3963) AbstractReporter uses shaded dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 10:39:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3963) AbstractReporter uses shaded dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 10:39:13 UTC, 1 replies.
- [jira] [Created] (FLINK-3964) Job submission times out with recursive.file.enumeration - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2016/05/24 11:04:14 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Removed shaded import - posted by kl0u <gi...@git.apache.org> on 2016/05/24 11:57:11 UTC, 5 replies.
- [jira] [Reopened] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 12:21:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/24 12:22:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3963) AbstractReporter uses shaded dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 12:22:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 12:23:12 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3963) AbstractReporter uses shaded dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/24 14:04:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/05/24 15:23:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3965) Delegating GraphAlgorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/24 17:42:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/24 18:11:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2915] Fix for JobManagerProcessFailureB... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/24 18:17:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/24 18:18:13 UTC, 4 replies.
- [jira] [Created] (FLINK-3966) AvroTypeInfo does not work with readonly avro specific records - posted by "Matthew Burghoffer (JIRA)" <ji...@apache.org> on 2016/05/24 18:37:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/24 18:43:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2771] Fix for IterateTest.testSimpleIte... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/24 18:44:06 UTC, 2 replies.
- [jira] [Commented] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/24 18:44:12 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode - posted by "Rekha Joshi (JIRA)" <ji...@apache.org> on 2016/05/24 19:11:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2814] Fix for DualInputPlanNode cannot ... - posted by rekhajoshm <gi...@git.apache.org> on 2016/05/24 19:12:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/24 19:12:13 UTC, 1 replies.
- [jira] [Created] (FLINK-3967) Provide RethinkDB Sink for Flink - posted by "Mans Singh (JIRA)" <ji...@apache.org> on 2016/05/25 00:53:12 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3967 - Flink Streaming Sink for Rethink ... - posted by mans4singh <gi...@git.apache.org> on 2016/05/25 01:23:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-3967) Provide RethinkDB Sink for Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 01:24:12 UTC, 12 replies.
- [GitHub] flink pull request: FLINK-3967 - Flink Sink for Rethink Db - posted by mans2singh <gi...@git.apache.org> on 2016/05/25 01:32:25 UTC, 10 replies.
- [jira] [Created] (FLINK-3968) Cancel button on a running job not available on smaller screens - posted by "Lokesh Ravindranathan (JIRA)" <ji...@apache.org> on 2016/05/25 04:16:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3968) Cancel button on a running job not available on smaller screens - posted by "Lokesh Ravindranathan (JIRA)" <ji...@apache.org> on 2016/05/25 04:17:12 UTC, 1 replies.
- [jira] [Closed] (FLINK-3968) Cancel button on a running job not available on smaller screens - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/25 05:59:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3961) Possibility to write output to multiple locations based on partitions - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2016/05/25 06:42:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-2672) Add partitioned output format to HDFS RollingSink - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2016/05/25 06:46:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3969) Log Exceptions Thrown by Invokable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/25 09:52:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3969) Log Exceptions Thrown by Invokable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/25 09:53:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3970) How to deal with "resouce isolation" problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/25 11:22:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3970) How to deal with "resouce isolation" problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/25 11:24:12 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-3970) How to deal with "resouce isolation" problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/25 11:24:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3965] [gelly] Delegating GraphAlgorithm - posted by greghogan <gi...@git.apache.org> on 2016/05/25 11:55:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-3965) Delegating GraphAlgorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 11:56:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3887] improve dependency management for... - posted by mxm <gi...@git.apache.org> on 2016/05/25 12:33:37 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3937] Implemented -yid option to Flink ... - posted by packet23 <gi...@git.apache.org> on 2016/05/25 12:38:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 12:38:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-1673) Colocate Flink Kafka consumer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/25 13:10:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/25 13:16:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/25 13:30:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2715) Benchmark Triangle Count methods - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/25 13:34:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:17:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3589] Allow setting Operator parallelis... - posted by StephanEwen <gi...@git.apache.org> on 2016/05/25 14:17:45 UTC, 3 replies.
- [jira] [Commented] (FLINK-3589) Allow setting Operator parallelism to default value - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 14:18:12 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3936] [tableAPI] Add MIN/MAX aggregatio... - posted by fhueske <gi...@git.apache.org> on 2016/05/25 14:25:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 14:26:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:41:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3859) Add BigDecimal/BigInteger support to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:41:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3152) Support all comparisons for Date type - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:42:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:42:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:43:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3971) Aggregates handle null values incorrectly. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:51:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2971) Add outer joins to the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 14:53:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/25 15:11:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3972) Subclasses of ResourceID may not to be serializable - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/25 15:18:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-1673) Colocate Flink Kafka consumer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/25 15:48:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/25 15:55:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3973) Table API documentation is "hidden" in Programming Guide menu list - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/25 16:25:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "B Wyatt (JIRA)" <ji...@apache.org> on 2016/05/25 16:28:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2044) Implementation of Gelly HITS Algorithm - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/05/25 16:58:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ... - posted by greghogan <gi...@git.apache.org> on 2016/05/25 17:15:38 UTC, 29 replies.
- [jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 17:16:12 UTC, 40 replies.
- [jira] [Issue Comment Deleted] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "B Wyatt (JIRA)" <ji...@apache.org> on 2016/05/25 18:52:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "B Wyatt (JIRA)" <ji...@apache.org> on 2016/05/25 18:52:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-3974) enableObjectReuse fails when an operator chains to multiple downstream operators - posted by "B Wyatt (JIRA)" <ji...@apache.org> on 2016/05/25 18:52:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3806] [gelly] Revert use of DataSet.cou... - posted by greghogan <gi...@git.apache.org> on 2016/05/25 19:21:44 UTC, 8 replies.
- [jira] [Commented] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/25 19:22:12 UTC, 9 replies.
- [jira] [Created] (FLINK-3975) docs build script isn't serving the preview on the correct base url - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/05/25 19:33:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3975) docs build script isn't serving the preview on the correct base url - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/05/25 19:42:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/26 03:11:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/26 03:11:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/26 07:12:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/05/26 07:18:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-3971) Aggregates handle null values incorrectly. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/26 07:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/26 07:47:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3972] subclasses of ResourceID may not ... - posted by mxm <gi...@git.apache.org> on 2016/05/26 10:19:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-3972) Subclasses of ResourceID may not to be serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/26 10:20:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/26 10:21:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/26 12:31:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/26 12:31:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3908] Fixed Parser's error state reset - posted by StephanEwen <gi...@git.apache.org> on 2016/05/26 12:35:26 UTC, 3 replies.
- [jira] [Created] (FLINK-3978) Add contains methods to RuntimeContext - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 13:50:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3978) Add contains methods to RuntimeContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/26 14:02:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/26 14:07:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-3978) Add contains methods to RuntimeContext - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 14:17:12 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-3717 - Be able to re-start reading from ... - posted by kl0u <gi...@git.apache.org> on 2016/05/26 14:57:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-3717) Add functionality to be a able to restore from specific point in a FileInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/26 14:57:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3979) [documentation]add missed import classes in run_example_quickstart - posted by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/26 15:15:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3941) Add support for UNION (with duplicate elimination) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/26 15:17:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3936) Add MIN / MAX aggregations function for BOOLEAN types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/26 15:18:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/26 15:18:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3034] Redis Sink Connector - posted by rphillips <gi...@git.apache.org> on 2016/05/26 15:38:07 UTC, 4 replies.
- [jira] [Commented] (FLINK-3034) Redis SInk Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/26 15:38:12 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3979] documentation - add missed import... - posted by jiazhai <gi...@git.apache.org> on 2016/05/26 15:38:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-3979) [documentation]add missed import classes in run_example_quickstart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/26 15:39:12 UTC, 2 replies.
- [jira] [Updated] (FLINK-3978) Add containsBroadcastVariable methods to RuntimeContext - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 16:19:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3978) Add containsBroadcastVariable method to RuntimeContext - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 16:19:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3978) Add containsBroadcastVariable method to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/26 17:14:13 UTC, 1 replies.
- [jira] [Updated] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 18:46:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 19:19:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3978] [core] Add hasBroadcastVariable m... - posted by greghogan <gi...@git.apache.org> on 2016/05/26 20:16:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/26 20:17:12 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-3910) New self-join operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/26 20:24:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3975] [docs] Override baseurl when serv... - posted by dyanarose <gi...@git.apache.org> on 2016/05/26 20:52:47 UTC, 5 replies.
- [jira] [Commented] (FLINK-3975) docs build script isn't serving the preview on the correct base url - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/26 20:53:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3975) Override baseurl when serving docs locally - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/05/26 20:54:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3970) How to deal with "resouce isolation" problem - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/05/27 02:12:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3317) Add timeout handler to CEP operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/05/27 09:52:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3317] [cep] Introduce timeout handler t... - posted by tillrohrmann <gi...@git.apache.org> on 2016/05/27 10:16:37 UTC, 0 replies.
- [jira] [Commented] (FLINK-3317) Add timeout handler to CEP operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/27 10:17:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead - posted by "Pawel Szczur (JIRA)" <ji...@apache.org> on 2016/05/27 10:23:12 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3129] Add japicmp-maven-plugin to ensur... - posted by rmetzger <gi...@git.apache.org> on 2016/05/27 10:28:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-3129) Add tooling to ensure interface stability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/27 10:29:13 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-3129] Add tooling to ensure interface s... - posted by rmetzger <gi...@git.apache.org> on 2016/05/27 10:31:48 UTC, 9 replies.
- [jira] [Updated] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/27 10:59:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/27 11:07:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/27 11:46:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3886] Give a better error when the appl... - posted by nielsbasjes <gi...@git.apache.org> on 2016/05/27 11:52:52 UTC, 2 replies.
- [jira] [Reopened] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 12:16:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3960) Disable, fix and re-enable EventTimeWindowCheckpointingITCase - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 12:17:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3944] [tableAPI] Add rewrite rules to r... - posted by fhueske <gi...@git.apache.org> on 2016/05/27 12:24:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-3944) Add optimization rules to reorder Cartesian products and joins - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/27 12:25:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2971) Add outer joins to the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/05/27 15:26:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK1919] add HCatOutputFormat - posted by fpompermaier <gi...@git.apache.org> on 2016/05/27 15:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3129) Add tooling to ensure interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/27 15:58:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3972) Subclasses of ResourceID may not to be serializable - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 16:44:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3981) Don't log duplicate TaskManager registrations as exceptions - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 19:10:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3982) Multiple ResourceManagers register at JobManager in standalone HA mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/27 19:49:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3981] don't log duplicate TaskManager r... - posted by mxm <gi...@git.apache.org> on 2016/05/27 20:38:46 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/27 20:39:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3981) Don't log duplicate TaskManager registrations as exceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/27 20:39:13 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/27 20:39:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3982] let only ResourceManager of leadi... - posted by mxm <gi...@git.apache.org> on 2016/05/27 20:43:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-3982) Multiple ResourceManagers register at JobManager in standalone HA mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/27 20:44:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/27 21:10:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/28 01:33:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3984) Event time of stream transformations is undocumented - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/05/28 01:53:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/28 07:03:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/28 07:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3985) A metric with the name * was already registered - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/28 07:10:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3985) A metric with the name * was already registered - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/28 07:10:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-3985) A metric with the name * was already registered - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/28 07:12:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3984) Event time of stream transformations is undocumented - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/28 08:12:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/28 10:56:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3986) Rename the readFileStream(String filePath, long intervalMillis, WatchType watchType) from the StreamExecutionEnvironment - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/05/28 10:56:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/28 20:09:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3987) Add data stream connector to DistributedLog - posted by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/29 03:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3988) Add data set connector to DistributedLog - posted by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/29 03:05:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3987) Add data stream connector to DistributedLog - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/29 03:56:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3988) Add data set connector to DistributedLog - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/05/29 03:57:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3989) Add guide to write a custom streaming source / sink in DataStream API documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/05/29 05:09:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3989) Add guide to write a custom streaming connector in DataStream API documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/05/29 05:24:12 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-3405: Extend NiFiSource with interface S... - posted by smarthi <gi...@git.apache.org> on 2016/05/29 06:16:56 UTC, 8 replies.
- [jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/29 06:17:12 UTC, 8 replies.
- [jira] [Reopened] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/05/29 06:22:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/05/29 06:22:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3323) Nifi connector not documented - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/05/29 17:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/29 18:00:15 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3985) A metric with the name * was already registered - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/29 19:58:12 UTC, 0 replies.
- [GitHub] flink pull request: [Flink 1934] Add approximative k-nearest-neigh... - posted by danielblazevski <gi...@git.apache.org> on 2016/05/30 00:10:46 UTC, 7 replies.
- [jira] [Updated] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/30 03:32:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3452) Procuring more Travis CI build capacity for Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/30 10:29:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3982) Multiple ResourceManagers register at JobManager in standalone HA mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/30 10:31:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3981) Don't log duplicate TaskManager registrations as exceptions - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/30 10:31:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3971] [tableAPI] Aggregates handle null... - posted by gallenvara <gi...@git.apache.org> on 2016/05/30 10:42:46 UTC, 1 replies.
- [jira] [Closed] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/05/30 11:17:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/05/30 12:38:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3989) Add guide to write a custom streaming connector in DataStream API documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/30 12:44:12 UTC, 2 replies.
- [GitHub] flink pull request: [Flink-1934] Add approximative k-nearest-neigh... - posted by danielblazevski <gi...@git.apache.org> on 2016/05/30 13:08:58 UTC, 4 replies.
- [jira] [Created] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/05/30 13:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3992) Remove Key interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/30 13:27:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/30 13:29:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-2693) Refactor InvalidTypesException to be checked - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/05/30 13:31:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2016/05/30 13:45:13 UTC, 14 replies.
- [jira] [Issue Comment Deleted] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2016/05/30 13:49:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3870][docs] Added IntelliJ code style - posted by danielblazevski <gi...@git.apache.org> on 2016/05/30 14:45:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-3870) Add IntelliJ code style file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/30 14:46:13 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3779] Add support for queryable state - posted by uce <gi...@git.apache.org> on 2016/05/30 16:11:52 UTC, 7 replies.
- [jira] [Commented] (FLINK-3779) Add support for queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/30 16:12:12 UTC, 7 replies.
- [GitHub] flink pull request: Added addition, subtraction and multiply by sc... - posted by danielblazevski <gi...@git.apache.org> on 2016/05/30 17:18:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-3975) Override baseurl when serving docs locally - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/30 18:03:12 UTC, 4 replies.
- [jira] [Closed] (FLINK-2829) Confusing error message when Flink cannot create enough task threads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/30 21:08:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2829) Confusing error message when Flink cannot create enough task threads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/30 21:08:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3872) Add Kafka TableSource with JSON serialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/30 23:23:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2673) Scala API does not support Option type as key - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/05/31 02:07:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3054] Remove R (return) type variable f... - posted by gyk <gi...@git.apache.org> on 2016/05/31 03:34:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3054) Remove R (return) type variable from SerializationSchema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/31 03:35:12 UTC, 1 replies.
- [GitHub] flink pull request: Affinity Propagation - posted by joseprupi <gi...@git.apache.org> on 2016/05/31 04:10:49 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k... - posted by chiwanpark <gi...@git.apache.org> on 2016/05/31 06:04:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/31 06:05:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-3954) Installing Flink on EMR using EMR bootstrap action - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/05/31 07:55:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3993) [py] Add generateSequence() support to Python AP - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/05/31 08:16:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3993) [py] Add generateSequence() support to Python API - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/05/31 08:20:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-3887) Improve dependency management for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/31 09:29:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3994) Instable KNNITSuite - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/05/31 09:42:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3975) Override baseurl when serving docs locally - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/31 10:10:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3994) Instable KNNITSuite - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/05/31 10:16:12 UTC, 9 replies.
- [jira] [Assigned] (FLINK-3994) Instable KNNITSuite - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/05/31 10:18:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3995) Properly Structure Test Utils and Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 10:29:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3995) Properly Structure Test Utils and Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 10:32:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-3887) Improve dependency management for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/31 10:37:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3763] RabbitMQ Source/Sink standardize ... - posted by subhankarb <gi...@git.apache.org> on 2016/05/31 10:42:19 UTC, 0 replies.
- [jira] [Created] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/05/31 10:57:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3996] Add addition, subtraction and multiply by s... - posted by danielblazevski <gi...@git.apache.org> on 2016/05/31 10:59:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/31 11:00:17 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3993] [py] Add generateSequence() support to Pyth... - posted by omaralvarez <gi...@git.apache.org> on 2016/05/31 11:29:25 UTC, 3 replies.
- [jira] [Commented] (FLINK-3993) [py] Add generateSequence() support to Python API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/05/31 11:30:13 UTC, 3 replies.
- [jira] [Updated] (FLINK-3994) Instable KNNITSuite - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/31 11:44:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/31 11:48:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/31 12:38:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3994] [ml, tests] Fix flaky KNN integration tests - posted by chiwanpark <gi...@git.apache.org> on 2016/05/31 13:03:14 UTC, 6 replies.
- [jira] [Closed] (FLINK-3607) Decrease default forkCount for tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/05/31 13:21:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3997) PRNG Skip-ahead - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/05/31 14:02:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3607) Decrease default forkCount for tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 14:34:12 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3979] documentation - add missed import classes i... - posted by asfgit <gi...@git.apache.org> on 2016/05/31 14:42:09 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3886] Give a better error when the application Ma... - posted by asfgit <gi...@git.apache.org> on 2016/05/31 14:42:09 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persistent - posted by aljoscha <gi...@git.apache.org> on 2016/05/31 15:36:58 UTC, 7 replies.
- [jira] [Resolved] (FLINK-3979) [documentation]add missed import classes in run_example_quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 15:51:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 15:51:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3979) [documentation]add missed import classes in run_example_quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 15:51:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3886) Give a better error when the application Main class is not public. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 15:52:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 15:52:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3886) Give a better error when the application Main class is not public. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/05/31 15:52:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine strategy f... - posted by ggevay <gi...@git.apache.org> on 2016/05/31 16:26:14 UTC, 10 replies.
- [jira] [Created] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/05/31 16:28:12 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Fix JSONDeserializationSchema for Kafka; Parame... - posted by rmetzger <gi...@git.apache.org> on 2016/05/31 17:28:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3806] [gelly] Revert use of DataSet.count() - posted by greghogan <gi...@git.apache.org> on 2016/05/31 17:30:55 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1979] Add logistic loss, hinge loss and regulariz... - posted by skavulya <gi...@git.apache.org> on 2016/05/31 17:42:09 UTC, 0 replies.
- [jira] [Created] (FLINK-3999) Rename the `running` flag in the drivers to `canceled` - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/05/31 17:54:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3763] RabbitMQ Source/Sink standardize connection... - posted by rmetzger <gi...@git.apache.org> on 2016/05/31 19:52:52 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3054] Remove R (return) type variable from Serial... - posted by rmetzger <gi...@git.apache.org> on 2016/05/31 20:11:50 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3758] Add possibility to register accumulators in... - posted by rmetzger <gi...@git.apache.org> on 2016/05/31 20:39:44 UTC, 0 replies.