commits@flink.apache.org, 2017-09

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

- flink git commit: [FLINK-7299][AVRO] Write GenericRecord using AvroOutputFormat - posted by al...@apache.org on 2017/09/01 08:50:42 UTC, 0 replies.
- flink git commit: [FLINK-7422] Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis - posted by al...@apache.org on 2017/09/01 09:00:01 UTC, 0 replies.
- flink-web git commit: Add Shaoxuan Wang to committer list & reordered the list by last name - posted by sh...@apache.org on 2017/09/01 09:57:16 UTC, 0 replies.
- flink git commit: [FLINK-7169][CEP] Support AFTER MATCH SKIP function in CEP - posted by dw...@apache.org on 2017/09/01 12:31:58 UTC, 0 replies.
- [1/2] flink-web git commit: [FLINK-6860] Update apache beam info (remove incubating) - posted by ch...@apache.org on 2017/09/01 14:05:32 UTC, 0 replies.
- [2/2] flink-web git commit: rebuild flink-web - posted by ch...@apache.org on 2017/09/01 14:05:33 UTC, 0 replies.
- flink git commit: [FLINK-7457] Make Dispatcher highly available - posted by tr...@apache.org on 2017/09/03 21:01:37 UTC, 0 replies.
- flink git commit: [FLINK-7489] Remove startJobExecution and suspendExecution from JobMasterGateway - posted by tr...@apache.org on 2017/09/03 21:05:38 UTC, 0 replies.
- flink git commit: [FLINK-7501] Generalize RegisteredRpcConnection to support generic leader ids - posted by tr...@apache.org on 2017/09/03 21:10:36 UTC, 0 replies.
- flink git commit: [FLINK-7522] Add termination future to ClusterEntrypoint - posted by tr...@apache.org on 2017/09/03 21:12:45 UTC, 0 replies.
- flink git commit: [FLINK-7519] Add HttpResponseStatus to RestClientException - posted by tr...@apache.org on 2017/09/03 21:17:04 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7078] [rpc] Introduce FencedRpcEndpoint - posted by tr...@apache.org on 2017/09/03 21:37:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7078] [rpc] Introduce FencedRpcEndpoint - posted by tr...@apache.org on 2017/09/03 21:37:43 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7409] [web] Make WebRuntimeMonitor reactive - posted by tr...@apache.org on 2017/09/03 22:00:17 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7409] [web] Make WebRuntimeMonitor reactive - posted by tr...@apache.org on 2017/09/03 22:00:18 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7409] [web] Make WebRuntimeMonitor reactive - posted by tr...@apache.org on 2017/09/03 22:00:19 UTC, 0 replies.
- flink git commit: [FLINK-7444] [rpc] Make external calls non-blocking - posted by tr...@apache.org on 2017/09/03 22:17:49 UTC, 0 replies.
- flink git commit: [FLINK-7500] Set JobMaster leader session id in main thread - posted by tr...@apache.org on 2017/09/04 06:36:57 UTC, 0 replies.
- flink git commit: [FLINK-7526] [TaskExecutor] Filter out duplicate JobManager gained leadership messages - posted by tr...@apache.org on 2017/09/04 06:41:00 UTC, 0 replies.
- flink git commit: [FLINK-7507] [dispatcher] Fence Dispatcher - posted by tr...@apache.org on 2017/09/04 06:49:02 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7504] Fence the ResourceManager - posted by tr...@apache.org on 2017/09/04 11:44:26 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7504] Fence the ResourceManager - posted by tr...@apache.org on 2017/09/04 11:44:27 UTC, 0 replies.
- flink-web git commit: [FLINK-7560] Add reset button for plan visualizer page - posted by ch...@apache.org on 2017/09/05 09:36:02 UTC, 0 replies.
- flink-web git commit: [FLINK-7570] Fix broken/missing links on FAQ page - posted by ch...@apache.org on 2017/09/05 09:44:31 UTC, 0 replies.
- flink git commit: [FLINK-7523] Add proper resource shutdown to ResourceManager/JobManagerRunner - posted by tr...@apache.org on 2017/09/05 10:38:26 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7506] Fence JobMaster - posted by tr...@apache.org on 2017/09/05 10:44:56 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7506] Fence JobMaster - posted by tr...@apache.org on 2017/09/05 10:44:57 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-7404] [table] Generate code for non-equi join conditions only. - posted by fh...@apache.org on 2017/09/05 12:22:40 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7572] [table] Improve TableSchema and FlinkTable validation exception messages. - posted by fh...@apache.org on 2017/09/05 12:22:41 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-6751] [docs] Add documentation for user-defined AggregateFunction. - posted by fh...@apache.org on 2017/09/05 12:22:42 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7564] [table] Fix watermark semantics in rowtime unbounded OVER window. - posted by fh...@apache.org on 2017/09/05 12:22:43 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7227] [table] Fix push-down of disjunctive predicates with more than two terms. - posted by fh...@apache.org on 2017/09/05 12:22:44 UTC, 1 replies.
- [1/5] flink git commit: [FLINK-6751] [docs] Add documentation for user-defined AggregateFunction. - posted by fh...@apache.org on 2017/09/05 14:06:44 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7564] [table] Fix watermark semantics in rowtime unbounded OVER window. - posted by fh...@apache.org on 2017/09/05 14:06:45 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-7572] [table] Improve TableSchema and FlinkTable validation exception messages. - posted by fh...@apache.org on 2017/09/05 14:06:46 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7404] [table] Generate code for non-equi join conditions only. - posted by fh...@apache.org on 2017/09/05 14:06:47 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-7568] Add section about consecutive windows to window doc - posted by al...@apache.org on 2017/09/05 16:07:21 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7568] Add note about 'key' parameter to window doc - posted by al...@apache.org on 2017/09/05 16:07:22 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-7568] Change role of ProcessWindowFunction and WindowFunction in doc - posted by al...@apache.org on 2017/09/05 16:07:23 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7568] Add note about start/end timestamps in window doc - posted by al...@apache.org on 2017/09/05 16:07:24 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7568] Update ProcessFunction.Context in window documentation - posted by al...@apache.org on 2017/09/05 16:07:25 UTC, 0 replies.
- flink git commit: [FLINK-7576] [futures] Add FutureUtils.retryWithDelay - posted by tr...@apache.org on 2017/09/06 08:19:17 UTC, 0 replies.
- flink git commit: [FLINK-7430] Set StreamTask.isRunning to false after closing StreamOperators - posted by tr...@apache.org on 2017/09/06 14:11:54 UTC, 0 replies.
- flink git commit: [hotfix][kafka][docs] Add warning regarding data losses when writing to Kafka - posted by al...@apache.org on 2017/09/06 14:14:52 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-7407] [kafka] Adapt AbstractPartitionDiscoverer to handle non-contiguous partition metadata - posted by tz...@apache.org on 2017/09/07 06:19:25 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] [kafka] Remove unused shouldAssignToThisSubtask method in AbstractPartitionDiscoverer - posted by tz...@apache.org on 2017/09/07 06:19:26 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-7440] [kinesis] Eagerly check serializability of deserialization schema in FlinkKinesisConsumer - posted by tz...@apache.org on 2017/09/07 06:19:27 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-7440] [kinesis] Eagerly check that provided schema and partitioner is serializable in FlinkKinesisProducer - posted by tz...@apache.org on 2017/09/07 06:19:28 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-7367] [kinesis] Generalize configuration for FlinkKinesisProducer properties - posted by tz...@apache.org on 2017/09/07 06:19:29 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-7363] [kinesis] Clean up deprecation of ProducerConfigConstants - posted by tz...@apache.org on 2017/09/07 06:19:30 UTC, 0 replies.
- flink git commit: [FLINK-7294] [mesos] Set mesos.resourcemanager.framework.role for resources - posted by tr...@apache.org on 2017/09/14 11:30:50 UTC, 1 replies.
- flink git commit: [FLINK-7617] [runtime] Remove string format in BitSet to improve the performance of BuildSideOuterjoin - posted by ku...@apache.org on 2017/09/14 13:21:16 UTC, 1 replies.
- [1/4] flink git commit: [FLINK-7273] [gelly] Gelly tests with empty graphs - posted by gr...@apache.org on 2017/09/15 13:58:32 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7273] [gelly] Gelly tests with empty graphs - posted by gr...@apache.org on 2017/09/15 13:58:33 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-7273] [gelly] Gelly tests with empty graphs - posted by gr...@apache.org on 2017/09/15 13:58:34 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7199] [gelly] Graph simplification does not set parallelism - posted by gr...@apache.org on 2017/09/15 13:58:35 UTC, 0 replies.
- [1/2] flink-web git commit: Added Tink as third party project - posted by rm...@apache.org on 2017/09/15 19:24:06 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild site - posted by rm...@apache.org on 2017/09/15 19:24:07 UTC, 0 replies.
- [1/2] flink-web git commit: update training website link - posted by rm...@apache.org on 2017/09/15 19:25:58 UTC, 0 replies.
- [2/2] flink-web git commit: Add bahir-flink repo links - posted by rm...@apache.org on 2017/09/15 19:25:59 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] [docs] Fix log file name in quick start guide - posted by gr...@apache.org on 2017/09/15 20:43:15 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7494] [build] Add license header to '.travis.yml' file - posted by gr...@apache.org on 2017/09/15 20:43:16 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-7625] [docs] Fix metric name - posted by gr...@apache.org on 2017/09/15 20:43:17 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7402] [runtime] Fix null check in NettyMessage#write - posted by gr...@apache.org on 2017/09/15 20:43:18 UTC, 0 replies.
- flink git commit: [FLINK-7625] [docs] Fix metric name - posted by gr...@apache.org on 2017/09/16 19:51:01 UTC, 0 replies.
- flink git commit: [FLINK-7563] [cep] Fix watermark semantics in cep and related tests. - posted by dw...@apache.org on 2017/09/17 16:15:24 UTC, 1 replies.
- flink git commit: [hotfix] [cep] Fix afterMatchStrategy parameter missing issue - posted by dw...@apache.org on 2017/09/17 16:37:38 UTC, 0 replies.
- flink git commit: [FLINK-7458] Generalize GatewayRetriever for WebRuntimeMonitor - posted by tr...@apache.org on 2017/09/18 20:59:40 UTC, 0 replies.
- flink git commit: [FLINK-7459] Generalize Flink's redirection logic - posted by tr...@apache.org on 2017/09/18 21:00:52 UTC, 0 replies.
- flink git commit: [FLINK-7533] Let LeaderGatewayRetriever retry failed gateway retrievals - posted by tr...@apache.org on 2017/09/18 21:09:56 UTC, 0 replies.
- flink git commit: [FLINK-7580] Automatically retry failed gateway retrievals - posted by tr...@apache.org on 2017/09/18 21:12:16 UTC, 0 replies.
- flink git commit: [FLINK-7639] [tests] Harden TaskExecutorITCase - posted by tr...@apache.org on 2017/09/18 21:26:08 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-7609][examples] Adjust WindowWordCount default window configuration values - posted by ch...@apache.org on 2017/09/19 09:08:16 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-6549] [datastream] Improve error message for type mismatches with side outputs - posted by ch...@apache.org on 2017/09/19 09:08:17 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-7581] [REST] Name netty threads - posted by ch...@apache.org on 2017/09/19 09:08:18 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-7583] [REST] Use static constant for CONTENT_TYPE header - posted by ch...@apache.org on 2017/09/19 09:08:19 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-7626] [docs][metrics] Add some checkpoints metric description in docs - posted by ch...@apache.org on 2017/09/19 09:08:20 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-7598][travis] fix ineffective shaded artifacts checks - posted by ch...@apache.org on 2017/09/19 09:08:21 UTC, 0 replies.
- flink git commit: [FLINK-7630] Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() - posted by al...@apache.org on 2017/09/19 14:24:50 UTC, 1 replies.
- flink git commit: [FLINK-7527] [rest] Let AbstractRestHandler extend RedirectHandler - posted by tr...@apache.org on 2017/09/19 22:26:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7528] Create DispatcherRestEndpoint and integrate with Dispatcher - posted by tr...@apache.org on 2017/09/19 22:34:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7528] Create DispatcherRestEndpoint and integrate with Dispatcher - posted by tr...@apache.org on 2017/09/19 22:34:42 UTC, 0 replies.
- flink git commit: [FLINK-7529] Retrieve complete REST address from gateway - posted by tr...@apache.org on 2017/09/19 22:38:45 UTC, 0 replies.
- [01/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:11 UTC, 0 replies.
- [02/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:12 UTC, 0 replies.
- [03/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:13 UTC, 0 replies.
- [04/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:14 UTC, 0 replies.
- [05/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:15 UTC, 0 replies.
- [06/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:16 UTC, 0 replies.
- [07/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:17 UTC, 0 replies.
- [08/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:18 UTC, 0 replies.
- [09/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:19 UTC, 0 replies.
- [10/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:20 UTC, 0 replies.
- [11/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:21 UTC, 0 replies.
- [12/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:22 UTC, 0 replies.
- [13/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:23 UTC, 0 replies.
- [14/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:24 UTC, 0 replies.
- [15/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:25 UTC, 0 replies.
- [16/16] flink git commit: [FLINK-7531] Move Flink legacy rest handler to flink-runtime - posted by tr...@apache.org on 2017/09/19 22:44:26 UTC, 0 replies.
- flink git commit: [hotfix] Test properly default JobMasterId in JobMaster#suspendExecution - posted by tr...@apache.org on 2017/09/19 22:49:02 UTC, 0 replies.
- flink git commit: [FLINK-6733] Remove commented out AvgAggregationFunction.java - posted by ku...@apache.org on 2017/09/20 01:23:06 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-6442] [table] Add registration for TableSinks and INSERT INTO support for SQL and Table API. - posted by fh...@apache.org on 2017/09/20 08:13:16 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-6442] [table] Add registration for TableSinks and INSERT INTO support for SQL and Table API. - posted by fh...@apache.org on 2017/09/20 08:13:17 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-6442] [table] Add registration for TableSinks and INSERT INTO support for SQL and Table API. - posted by fh...@apache.org on 2017/09/20 08:13:18 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7357] [table] Fix translation of group window queries with window props and HAVING. - posted by fh...@apache.org on 2017/09/20 08:13:19 UTC, 0 replies.
- flink git commit: [FLINK-7532] Add web content handler to DispatcherRestEndpoint - posted by tr...@apache.org on 2017/09/20 08:35:41 UTC, 0 replies.
- flink git commit: [FLINK-7357] [table] Fix translation of group window queries with window props and HAVING. - posted by fh...@apache.org on 2017/09/20 14:29:43 UTC, 0 replies.
- flink git commit: [FLINK-7534] Create LegacyRestHandlerAdapter for old REST handlers - posted by tr...@apache.org on 2017/09/20 15:51:36 UTC, 0 replies.
- flink git commit: [FLINK-7535] Port DashboardConfigHandler to new REST endpoint - posted by tr...@apache.org on 2017/09/21 07:31:15 UTC, 0 replies.
- flink git commit: [FLINK-7651] [flip-6] Delay RetryingRegistration in case of connection error - posted by tr...@apache.org on 2017/09/21 07:32:45 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7552] Extend SinkFunction interface with SinkContext - posted by al...@apache.org on 2017/09/21 11:47:00 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7553] Use new SinkFunction interface in FlinkKafkaProducer010 - posted by al...@apache.org on 2017/09/21 11:47:01 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7571] [table] Fix translation of TableSource with time indicators. - posted by fh...@apache.org on 2017/09/21 12:16:45 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7644] [runtime] Remove double semicolon. - posted by fh...@apache.org on 2017/09/21 12:16:46 UTC, 0 replies.
- flink git commit: [FLINK-7442] Add option for using a child-first classloader for loading user code - posted by al...@apache.org on 2017/09/21 13:02:08 UTC, 0 replies.
- flink git commit: [FLINK-7571] Add test for TableSource with time indicators. - posted by fh...@apache.org on 2017/09/21 13:08:50 UTC, 0 replies.
- flink git commit: [FLINK-7655] [flip6] Set fencing token to null if not leader - posted by tr...@apache.org on 2017/09/21 22:59:34 UTC, 0 replies.
- flink git commit: [FLINK-7567] [scala] Remove keepPartitioning parameter from DataStream.iterate() - posted by al...@apache.org on 2017/09/22 09:17:11 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] Fix typo in Debugging Classloading documentation - posted by tz...@apache.org on 2017/09/22 09:45:04 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7600] [kinesis] Shorten credential update delay to avoid updateCredentials Exception - posted by tz...@apache.org on 2017/09/22 09:45:05 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7508] [kinesis] Switch to POOLED ThreadingMode in FlinkKinesisProducer - posted by tz...@apache.org on 2017/09/22 09:45:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7600] [kinesis] Shorten credential update delay to avoid updateCredentials Exception - posted by tz...@apache.org on 2017/09/22 12:32:36 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] Fix typo in Debugging Classloading documentation - posted by tz...@apache.org on 2017/09/22 12:32:37 UTC, 0 replies.
- flink git commit: [FLINK-7656] [runtime] Switch to user classloader before calling initializeOnMaster and finalizeOnMaster. - posted by fh...@apache.org on 2017/09/22 21:56:35 UTC, 1 replies.
- flink git commit: [hotfix] Add ProcessOperator tests that verify side outputs work - posted by al...@apache.org on 2017/09/25 08:54:24 UTC, 0 replies.
- flink git commit: [hotfix] Fix typos and other small things - posted by al...@apache.org on 2017/09/25 08:57:31 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] Remove leftover KeyedTimePanes - posted by al...@apache.org on 2017/09/25 13:50:29 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7635] Support side output in ProcessWindowFunction - posted by al...@apache.org on 2017/09/25 13:50:30 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7635] Add side-output test in WindowOperatorContractTest - posted by al...@apache.org on 2017/09/25 13:50:31 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7524] Remove potentially blocking behaviour from AbstractCloseableRegistry. - posted by sr...@apache.org on 2017/09/25 15:47:50 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7619] Improved abstraction of AbstractAsyncIOCallable to better fit the current usage pattern. - posted by sr...@apache.org on 2017/09/25 15:47:51 UTC, 0 replies.
- [1/2] flink git commit: [hotfix][runtime] Checkstyle changes in TaskStateSnapshot - posted by sr...@apache.org on 2017/09/25 16:14:05 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7541][runtime] Refactor StateAssignmentOperation and use OperatorID - posted by sr...@apache.org on 2017/09/25 16:14:06 UTC, 0 replies.
- flink git commit: [FLINK-7638] [flip6] Port CurrentJobsOverviewHandler to new REST endpoint - posted by tr...@apache.org on 2017/09/25 21:47:25 UTC, 0 replies.
- flink git commit: Revert "[FLINK-7541][runtime] Refactor StateAssignmentOperation and use OperatorID" - posted by tr...@apache.org on 2017/09/26 07:09:08 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7439] [table] Add possiblity to replace TypeExtractor call - posted by tw...@apache.org on 2017/09/26 08:50:38 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7439] [table] Support variable arguments for UDTF in SQL - posted by tw...@apache.org on 2017/09/26 08:50:39 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7664] Replace FlinkFutureException by java.util.concurrent.CompletionException - posted by tr...@apache.org on 2017/09/26 09:25:51 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7664] Replace FlinkFutureException by java.util.concurrent.CompletionException - posted by tr...@apache.org on 2017/09/26 09:25:52 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Simplify and fix Table UDF docs - posted by tw...@apache.org on 2017/09/26 11:55:54 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7596] [table] Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType) - posted by tw...@apache.org on 2017/09/26 14:50:33 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-7596] [table] Restrict equality and improve tests - posted by tw...@apache.org on 2017/09/26 14:50:34 UTC, 1 replies.
- [1/9] flink git commit: [FLINK-4047] [docs] Fix documentation about determinism of KeySelectors - posted by tz...@apache.org on 2017/09/26 16:04:43 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-7654] [rabbitmq] Update RabbitMQ Java client version to 4.2.0 - posted by tz...@apache.org on 2017/09/26 16:04:44 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] [doc] Fix incorrect javaStream access on Scala DataStream API in docs - posted by tz...@apache.org on 2017/09/26 16:04:45 UTC, 0 replies.
- [4/9] flink git commit: [hotfix] [docs] Method name for PatternFlatSelectFunction should be flatSelect - posted by tz...@apache.org on 2017/09/26 16:04:46 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-7647] [flip6] Port JobManagerConfigHandler to new REST endpoint - posted by tz...@apache.org on 2017/09/26 16:04:47 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-7393] [kinesis] Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest - posted by tz...@apache.org on 2017/09/26 16:04:48 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-7647] [flip6] Rename JobManagerConfigHandler to ClusterConfigHandler - posted by tz...@apache.org on 2017/09/26 16:04:49 UTC, 0 replies.
- [8/9] flink git commit: hotfix] [docs] Fix incorrect doc for s3a configuration for AWS deployment - posted by tz...@apache.org on 2017/09/26 16:04:50 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-7647] [flip6] Introduce test base for REST response marshalling - posted by tz...@apache.org on 2017/09/26 16:04:51 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] [docs] Method name for PatternFlatSelectFunction should be flatSelect - posted by tz...@apache.org on 2017/09/26 16:11:51 UTC, 0 replies.
- [2/5] flink git commit: [hotfix] [doc] Fix incorrect javaStream access on Scala DataStream API in docs - posted by tz...@apache.org on 2017/09/26 16:11:52 UTC, 0 replies.
- [3/5] flink git commit: hotfix] [docs] Fix incorrect doc for s3a configuration for AWS deployment - posted by tz...@apache.org on 2017/09/26 16:11:53 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4047] [docs] Fix documentation about determinism of KeySelectors - posted by tz...@apache.org on 2017/09/26 16:11:54 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7670][doc] fix typo in docs runtime section - posted by tz...@apache.org on 2017/09/26 16:11:55 UTC, 0 replies.
- [01/20] flink git commit: [hotfix] Java 8-ify HadoopSecurityContext - posted by al...@apache.org on 2017/09/27 11:09:06 UTC, 0 replies.
- [02/20] flink git commit: [hotfix] Fix containerized.master.env.* config options - posted by al...@apache.org on 2017/09/27 11:09:07 UTC, 0 replies.
- [03/20] flink git commit: [FLINK-2268] Remove Writable support from Scala TypeInformation Macro - posted by al...@apache.org on 2017/09/27 11:09:08 UTC, 0 replies.
- [04/20] flink git commit: [FLINK-2268] Remove Hadoop-related Akka Serializers from runtime - posted by al...@apache.org on 2017/09/27 11:09:09 UTC, 0 replies.
- [05/20] flink git commit: [FLINK-4048] Remove Hadoop from DataSet API - posted by al...@apache.org on 2017/09/27 11:09:10 UTC, 0 replies.
- [06/20] flink git commit: [FLINK-4048] Remove Hadoop from DataSet API - posted by al...@apache.org on 2017/09/27 11:09:11 UTC, 0 replies.
- [07/20] flink git commit: [FLINK-4048] Remove Hadoop from DataSet API - posted by al...@apache.org on 2017/09/27 11:09:12 UTC, 0 replies.
- [08/20] flink git commit: [FLINK-4048] Remove Hadoop from DataSet API - posted by al...@apache.org on 2017/09/27 11:09:13 UTC, 0 replies.
- [09/20] flink git commit: [FLINK-2268] Remove unused HDFS copy-utils from flink-streaming-java - posted by al...@apache.org on 2017/09/27 11:09:14 UTC, 0 replies.
- [10/20] flink git commit: [FLINK-4048] Remove Hadoop GenericOptionsParser from ParameterTool - posted by al...@apache.org on 2017/09/27 11:09:15 UTC, 0 replies.
- [11/20] flink git commit: [FLINK-2268] Don't use Hadoop Writable in JoinOperatorTest - posted by al...@apache.org on 2017/09/27 11:09:16 UTC, 0 replies.
- [12/20] flink git commit: [FLINK-2268] Don't use commons-io ByteArrayOutputStream in NFATest - posted by al...@apache.org on 2017/09/27 11:09:17 UTC, 0 replies.
- [13/20] flink git commit: [FLINK-2268] Don't use Hadoop FileSystem in RocksDB tests - posted by al...@apache.org on 2017/09/27 11:09:18 UTC, 0 replies.
- [14/20] flink git commit: [FLINK-2268] Don't use jets3t in MesosArtifactServer - posted by al...@apache.org on 2017/09/27 11:09:19 UTC, 0 replies.
- [15/20] flink git commit: [FLINK-2268] Only print Hadoop env info if Hadoop is in the classpath - posted by al...@apache.org on 2017/09/27 11:09:20 UTC, 0 replies.
- [16/20] flink git commit: [FLINK-2268] Dynamically load Hadoop security module when available - posted by al...@apache.org on 2017/09/27 11:09:21 UTC, 0 replies.
- [17/20] flink git commit: [FLINK-2268] Close Hadoop FS reflectively in TestBaseUtils - posted by al...@apache.org on 2017/09/27 11:09:22 UTC, 0 replies.
- [18/20] flink git commit: [FLINK-2268] Don't include Hadoop deps in flink-core/flink-java - posted by al...@apache.org on 2017/09/27 11:09:23 UTC, 0 replies.
- [19/20] flink git commit: [hotfix] Make SecurityUtils.SecurityConfiguration a toplevel class - posted by al...@apache.org on 2017/09/27 11:09:24 UTC, 0 replies.
- [20/20] flink git commit: [FLINK-2268] Allow not including the Hadoop uber jar - posted by al...@apache.org on 2017/09/27 11:09:25 UTC, 0 replies.
- flink git commit: [FLINK-7663] [flip6] Return BAD_REQUEST if HandlerRequest cannot be created - posted by tr...@apache.org on 2017/09/27 16:13:57 UTC, 0 replies.
- flink git commit: [FLINK-7723] [tests] Harden DispatcherTest - posted by tr...@apache.org on 2017/09/27 23:04:30 UTC, 0 replies.
- flink git commit: [FLINK-7650] [flip6] Port JobCancellationHandler to new REST endpoint - posted by tr...@apache.org on 2017/09/27 23:06:54 UTC, 0 replies.
- flink git commit: [FLINK-7649] [flip6] Extend JobTerminationHandler to support stop - posted by tr...@apache.org on 2017/09/27 23:08:08 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-7513][tests] remove TestBufferFactory#MOCK_BUFFER - posted by tr...@apache.org on 2017/09/28 08:59:47 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7487][tests] fix ClassLoaderITCase#testDisposeSavepointWithCustomKvState not self-contained - posted by tr...@apache.org on 2017/09/28 08:59:48 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-7514][tests] fix BackPressureStatsTrackerITCase releasing buffers twice - posted by tr...@apache.org on 2017/09/28 08:59:49 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7411][network] minor (performance) improvements in NettyMessage - posted by tr...@apache.org on 2017/09/28 08:59:50 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-7645] [docs][metrics] Add system-metrics subsections to ToC - posted by ch...@apache.org on 2017/09/28 11:00:59 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-7675] [metrics] LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by ch...@apache.org on 2017/09/28 11:01:00 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-7724] [metrics] Add extra metrics to MetricStoreTest.setupStore - posted by ch...@apache.org on 2017/09/28 11:01:01 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-4664] [webUI] Show uploaded-jars descending by upload time - posted by ch...@apache.org on 2017/09/28 11:01:02 UTC, 0 replies.
- [5/7] flink git commit: [hotfix] [REST] Add note about placement of FileServerHandler - posted by ch...@apache.org on 2017/09/28 11:01:03 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-7725] [REST] Add testbase for requests / allow exceptions - posted by ch...@apache.org on 2017/09/28 11:01:04 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-7659] Fix unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by ch...@apache.org on 2017/09/28 11:01:05 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-7675] [metrics] LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by ch...@apache.org on 2017/09/28 11:11:36 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7659] Fix unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by ch...@apache.org on 2017/09/28 11:11:37 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-7626] [docs][metrics] Add some checkpoints metric description in docs - posted by ch...@apache.org on 2017/09/28 11:11:38 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-6549] [datastream] Improve error message for type mismatches with side outputs - posted by ch...@apache.org on 2017/09/28 11:11:39 UTC, 0 replies.
- flink git commit: [FLINK-7438] [scala] Remove unused import - posted by ch...@apache.org on 2017/09/28 12:44:04 UTC, 0 replies.
- flink git commit: [FLINK-7674] Fix NullPointerException in ContinuousFileMonitoringFunction#close - posted by ch...@apache.org on 2017/09/28 12:56:56 UTC, 0 replies.
- flink git commit: [FLINK-7541][runtime] Refactor StateAssignmentOperation and use OperatorID - posted by sr...@apache.org on 2017/09/28 14:30:00 UTC, 0 replies.
- flink git commit: [FLINK-7683][state backends] Introduce iterator for keys in KeyedStateBackend. This closes #4722. - posted by sr...@apache.org on 2017/09/28 14:37:38 UTC, 0 replies.
- [1/8] flink git commit: [hotfix] Add checkstyle suppressions for StateBackendTestBase - posted by al...@apache.org on 2017/09/28 15:09:06 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-5619] Add numStateEntries() method for all keyed backends - posted by al...@apache.org on 2017/09/28 15:09:07 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-7700] Fix RocksDB ReducingState merging - posted by al...@apache.org on 2017/09/28 15:09:08 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-7700] Fix RocksDB ListState merging - posted by al...@apache.org on 2017/09/28 15:09:09 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-5619] Consolidate ListState Tests in StateBackendTestBase - posted by al...@apache.org on 2017/09/28 15:09:10 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-5619] Consolidate ReducingState Tests in StateBackendTestBase - posted by al...@apache.org on 2017/09/28 15:09:11 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-7700] Fix RocksDB ReducingState merging - posted by al...@apache.org on 2017/09/28 15:09:12 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-5619] Consolidate AggregatingState Tests in StateBackendTestBase - posted by al...@apache.org on 2017/09/28 15:09:13 UTC, 0 replies.
- flink git commit: [FLINK-7547] Make AsyncFunction.scala extends Function - posted by al...@apache.org on 2017/09/28 15:32:24 UTC, 0 replies.
- flink git commit: [FLINK-7734] [tests] Harden ResourceManagerTest#testHeartbeatTimeoutWithTaskExecutor - posted by tr...@apache.org on 2017/09/28 16:55:22 UTC, 0 replies.
- flink git commit: [FLINK-7667] [flip6] Use ArchivedExecutionGraph as serializable AccessExecutionGraph - posted by tr...@apache.org on 2017/09/29 08:34:06 UTC, 0 replies.
- flink git commit: [hotfix] [REST] Extend empty request/parameters support - posted by tr...@apache.org on 2017/09/29 13:22:50 UTC, 0 replies.