You are viewing a plain text version of this content. The canonical link for it is here.
- [1/4] flink git commit: [FLINK-4887] [execution graph] Introduce TaskManagerGateway to encapsulate communcation logic - posted by tr...@apache.org on 2016/11/01 08:37:36 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4887] [execution graph] Introduce TaskManagerGateway to encapsulate communcation logic - posted by tr...@apache.org on 2016/11/01 08:37:37 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4887] [execution graph] Introduce TaskManagerGateway to encapsulate communcation logic - posted by tr...@apache.org on 2016/11/01 08:37:38 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4887] [execution graph] Introduce TaskManagerGateway to encapsulate communcation logic - posted by tr...@apache.org on 2016/11/01 08:37:39 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4537] rebase and refine [Forced Update!] - posted by tr...@apache.org on 2016/11/01 08:40:28 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Implement TaskManager component's startup - posted by tr...@apache.org on 2016/11/01 08:40:29 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by tr...@apache.org on 2016/11/01 08:40:30 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tr...@apache.org on 2016/11/01 08:40:31 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by tr...@apache.org on 2016/11/01 08:40:32 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job submission & setting up the ExecutionGraph - posted by tr...@apache.org on 2016/11/01 08:40:33 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices - posted by tr...@apache.org on 2016/11/01 08:40:34 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4606] integrate features of old ResourceManager - posted by tr...@apache.org on 2016/11/01 08:40:35 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses - posted by tr...@apache.org on 2016/11/01 08:40:36 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager - posted by tr...@apache.org on 2016/11/01 08:40:37 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/11/01 08:40:38 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/11/01 08:40:39 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by tr...@apache.org on 2016/11/01 08:40:40 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper - posted by tr...@apache.org on 2016/11/01 08:40:41 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [hotfix] Fix failing JobManagerRunnerMockTest - posted by tr...@apache.org on 2016/11/01 08:40:42 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by tr...@apache.org on 2016/11/01 08:40:43 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by tr...@apache.org on 2016/11/01 08:40:44 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4406] [cluster management] Implement job master registration at resource manager - posted by tr...@apache.org on 2016/11/01 08:40:45 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4516] update leadership information in ResourceManager - posted by tr...@apache.org on 2016/11/01 08:40:46 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-4746] Make TaskManagerRuntimeInfo an interface - posted by tr...@apache.org on 2016/11/01 08:40:47 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4694] [rpc] Add termination futures to RpcEndpoint and RpcService - posted by tr...@apache.org on 2016/11/01 08:40:48 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by tr...@apache.org on 2016/11/01 08:40:49 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by tr...@apache.org on 2016/11/01 08:40:50 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/11/01 08:40:51 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/11/01 08:40:52 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4735] [cluster management] Implements some job execution related RPC calls on the JobManager - posted by tr...@apache.org on 2016/11/01 08:40:53 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by tr...@apache.org on 2016/11/01 08:40:54 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by tr...@apache.org on 2016/11/01 08:40:55 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by tr...@apache.org on 2016/11/01 08:40:56 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4339] [cluster management] Implement Slot Pool core on JobManager side - posted by tr...@apache.org on 2016/11/01 08:40:57 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4489] [tm] Add TaskSlotTable to manage slot allocations for multiple job managers - posted by tr...@apache.org on 2016/11/01 08:40:58 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [FLINK-4689] [cluster management] Implement a simple slot provider for the new job manager - posted by tr...@apache.org on 2016/11/01 08:40:59 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-4351] [cluster management] JobManager handle TaskManager's registration - posted by tr...@apache.org on 2016/11/01 08:41:00 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [hotfix] [tests] Migrate some test tasks to Java - posted by tr...@apache.org on 2016/11/01 08:41:01 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-4835] [cluster management] Add embedded version of the high-availability services - posted by tr...@apache.org on 2016/11/01 08:41:02 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-4836] [cluster management] Add flink mini cluster (part 1) - posted by tr...@apache.org on 2016/11/01 08:41:03 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-4839] [cluster management] JobManager handle TaskManager's slot offering - posted by tr...@apache.org on 2016/11/01 08:41:04 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager and TaskManager services in MiniCluster - posted by tr...@apache.org on 2016/11/01 08:41:05 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [hotfix] Treat taskManager's rpc address and location separately - posted by tr...@apache.org on 2016/11/01 08:41:06 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [hotfix] [cluster management] Remove scala dependencies from MiniCluster.java - posted by tr...@apache.org on 2016/11/01 08:41:07 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [hotfix] Add a DefaultSlotManager similar to the TestingSlotManager - posted by tr...@apache.org on 2016/11/01 08:41:08 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4882] [flip-6] Remove exceptions from HighAvailabilityServices where not necessary - posted by tr...@apache.org on 2016/11/01 08:41:09 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4847] Let RpcEndpoint.start/shutDown throw exceptions - posted by tr...@apache.org on 2016/11/01 08:41:10 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager in MiniCluster - posted by tr...@apache.org on 2016/11/01 08:41:11 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: Rebasing fixes on latest master - posted by tr...@apache.org on 2016/11/01 08:41:12 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: Rebase fixes - posted by tr...@apache.org on 2016/11/01 08:41:13 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-4851] [rm] Introduce FatalErrorHandler and MetricRegistry to RM - posted by tr...@apache.org on 2016/11/01 08:41:14 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-4851] [rm] Introduce FatalErrorHandler and MetricRegistry to RM - posted by tr...@apache.org on 2016/11/01 08:41:15 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-4853] [rm] Clean up job manager registration at the resource manager - posted by tr...@apache.org on 2016/11/01 08:41:16 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-4871] [mini cluster] Add memory calculation for TaskManagers to MiniCluster - posted by tr...@apache.org on 2016/11/01 08:41:17 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-4834] [cluster management] Add LeaderIdMismatchException at a common way to report RPC calls rejected due to outdated leader status. - posted by tr...@apache.org on 2016/11/01 08:42:05 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-4958] [tm] Send slot report to RM when registering - posted by tr...@apache.org on 2016/11/01 08:42:06 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-4986] Improvements to the JobMaster - posted by tr...@apache.org on 2016/11/01 08:42:07 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-4987] Harden SlotPool on JobMaster - posted by tr...@apache.org on 2016/11/01 08:42:08 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-4987] Harden SlotPool on JobMaster - posted by tr...@apache.org on 2016/11/01 08:42:09 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-4987] Add RpcTaskManagerGateway implementation; Port AllocatedSlotsTest, AvailableSlotsTest and SlotPoolTest - posted by tr...@apache.org on 2016/11/01 08:42:10 UTC, 0 replies.
- flink git commit: [FLINK-4884] Eagerly Store MergingWindowSet in State in WindowOperator - posted by al...@apache.org on 2016/11/01 16:49:25 UTC, 0 replies.
- flink git commit: [FLINK-4447] [docs] Include NettyConfig options on Configurations page - posted by gr...@apache.org on 2016/11/01 20:12:53 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4445] [client] Add allowNonRestoredState flag to CLI - posted by uc...@apache.org on 2016/11/02 06:34:55 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-4445] [checkpointing] Add option to allow non restored checkpoint state - posted by uc...@apache.org on 2016/11/02 06:34:56 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4935] [webfrontend] Submit job with savepoint - posted by uc...@apache.org on 2016/11/02 07:07:00 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4935] [webfrontend] Submit job with savepoint - posted by uc...@apache.org on 2016/11/02 07:07:01 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4935] [webfrontend] Submit job with savepoint - posted by uc...@apache.org on 2016/11/02 07:07:02 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4935] [webfrontend] Submit job with savepoint - posted by uc...@apache.org on 2016/11/02 07:07:03 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4935] [webfrontend] Submit job with savepoint - posted by uc...@apache.org on 2016/11/02 07:07:04 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4445] [checkpointing] Add option to allow non restored savepoint state - posted by uc...@apache.org on 2016/11/02 07:10:23 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4923] [metrics] Initializes all task's gauges in TaskIOMetricGroup and extract the used buffers interface for BufferPool - posted by ch...@apache.org on 2016/11/02 09:48:36 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4845] [runtime-web] Fix Job Exception page - posted by ch...@apache.org on 2016/11/02 09:48:37 UTC, 0 replies.
- flink git commit: [FLINK-4398] [query] Improve logging and error message in failing KvStateServerHandlerTest - posted by uc...@apache.org on 2016/11/02 10:22:06 UTC, 0 replies.
- flink git commit: [FLINK-4398] [query] Fix race in KvStateServerHandlerTest - posted by uc...@apache.org on 2016/11/02 10:31:38 UTC, 0 replies.
- [1/8] flink-web git commit: Add FLIP to Community Menu and How-To-Contribute - posted by gr...@apache.org on 2016/11/02 13:37:05 UTC, 0 replies.
- [2/8] flink-web git commit: FF16 announcement for community - posted by gr...@apache.org on 2016/11/02 13:37:06 UTC, 0 replies.
- [3/8] flink-web git commit: fix JIRA link on community page - posted by gr...@apache.org on 2016/11/02 13:37:07 UTC, 0 replies.
- [4/8] flink-web git commit: Update slides.md - posted by gr...@apache.org on 2016/11/02 13:37:08 UTC, 0 replies.
- [5/8] flink-web git commit: Include support for Docker - posted by gr...@apache.org on 2016/11/02 13:37:09 UTC, 0 replies.
- [6/8] flink-web git commit: Use latest stack image and small textual fixes - posted by gr...@apache.org on 2016/11/02 13:37:10 UTC, 0 replies.
- [7/8] flink-web git commit: Rebuild website - posted by gr...@apache.org on 2016/11/02 13:37:11 UTC, 0 replies.
- [8/8] flink-web git commit: Rebuild website - posted by gr...@apache.org on 2016/11/02 13:37:12 UTC, 0 replies.
- flink git commit: [FLINK-4945] FlinkKafkaConsumer logs wrong warning about confirmation for unknown checkpoint - posted by rm...@apache.org on 2016/11/02 14:21:42 UTC, 0 replies.
- flink git commit: [FLINK-4991] [taskmanager] Fix too aggressive timeout and improve logging in TaskTest - posted by uc...@apache.org on 2016/11/02 14:25:04 UTC, 1 replies.
- flink git commit: [FLINK-4850] [ml] FlinkML - SVM predict Operation for Vector and not LaveledVector - posted by tr...@apache.org on 2016/11/02 17:13:14 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4996] [core] Make CrossHint @Public - posted by fh...@apache.org on 2016/11/02 20:46:39 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4943] Fix typo ConfigConstants JavaDocs: YYARN -> YARN - posted by fh...@apache.org on 2016/11/02 20:46:40 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4623] [table] Add physical execution plan to StreamTableEnvironment explain(). - posted by fh...@apache.org on 2016/11/02 20:46:41 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4743] [table] Add support for power(DOUBLE, DECIMAL) function. - posted by fh...@apache.org on 2016/11/02 20:46:42 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4315] [dataSet] [hadoopCompat] Annotate Hadoop-related methods in ExecutionEnvironment as @Deprecated. - posted by fh...@apache.org on 2016/11/02 20:46:43 UTC, 0 replies.
- flink git commit: [FLINK-4996] [core] Make CrossHint @Public - posted by fh...@apache.org on 2016/11/02 20:48:32 UTC, 0 replies.
- flink git commit: [yarn] fix debug string displayed for failed applications - posted by mx...@apache.org on 2016/11/03 10:14:14 UTC, 1 replies.
- flink git commit: [hotfix] [checkpointing] Fix error message in SavepointLoader - posted by uc...@apache.org on 2016/11/03 12:25:00 UTC, 0 replies.
- flink git commit: [FLINK-4960] Add AbstractStreamOperatorTestHarness.repackageState() - posted by al...@apache.org on 2016/11/04 09:24:55 UTC, 0 replies.
- flink git commit: [hotfix] Don't Swallow Exception in RocksDBAsyncSnapshotTest - posted by al...@apache.org on 2016/11/04 10:41:47 UTC, 0 replies.
- flink git commit: [hotfix] [tests] Simplify mocking of the ResultPartitionWriter - posted by se...@apache.org on 2016/11/04 11:04:47 UTC, 0 replies.
- flink git commit: [FLINK-4977] [core] Fix enum serializer to use proper access to enum constants - posted by se...@apache.org on 2016/11/04 13:49:54 UTC, 1 replies.
- flink git commit: [FLINK-4596] Fallback restart strategy config to let jobs choose restart configuration set at cluster level - posted by tr...@apache.org on 2016/11/04 13:57:41 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4998][yarn] fail if too many task slots are configured - posted by mx...@apache.org on 2016/11/04 19:09:09 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3813][yarn] wait for CLI to complete before checking output - posted by mx...@apache.org on 2016/11/04 19:09:10 UTC, 0 replies.
- flink git commit: [FLINK-3813][yarn] wait for CLI to complete before checking output - posted by mx...@apache.org on 2016/11/04 19:10:49 UTC, 0 replies.
- flink git commit: [FLINK-4998][yarn] fail if too many task slots are configured - posted by mx...@apache.org on 2016/11/04 19:15:37 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4221] Show metrics in WebFrontend + general improvements - posted by rm...@apache.org on 2016/11/04 20:58:29 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4221] Show metrics in WebFrontend + general improvements - posted by rm...@apache.org on 2016/11/04 20:58:30 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4221] Show metrics in WebFrontend + general improvements - posted by rm...@apache.org on 2016/11/04 20:58:31 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4221] Show metrics in WebFrontend + general improvements - posted by rm...@apache.org on 2016/11/04 20:58:32 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4221] Show metrics in WebFrontend + general improvements - posted by rm...@apache.org on 2016/11/04 20:58:33 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Remove unnecessary ConfigOptions#key() calls - posted by uc...@apache.org on 2016/11/07 10:19:03 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5004] [runtime] Add option to disable queryable state - posted by uc...@apache.org on 2016/11/07 10:19:04 UTC, 0 replies.
- flink git commit: [hotfix] Remove noisy log message in TaskCancelerWatchDog - posted by uc...@apache.org on 2016/11/07 10:29:16 UTC, 0 replies.
- flink git commit: [FLINK-4876] [webfrontend] Allow to bind to a specific interface - posted by uc...@apache.org on 2016/11/07 14:22:51 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-4957] Provide API for TimelyCoFlatMapFunction - posted by al...@apache.org on 2016/11/07 15:26:29 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-4955] Add Translations Tests for KeyedStream.flatMap(TimelyFlatMapFunction) - posted by al...@apache.org on 2016/11/07 15:26:30 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] Add Check for Keyed Operator in getInternalTimerService() - posted by al...@apache.org on 2016/11/07 15:26:31 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-4951] Fix Javadoc of KeyedStream.flatMap(TimelyFlatMapFunction) - posted by al...@apache.org on 2016/11/07 15:26:32 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-4957] Remove Key Serializer Parameter getInternalTimerService() - posted by al...@apache.org on 2016/11/07 15:26:33 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-4952] [scala] Add KeyedStream.flatMap(TimelyFlatMapFunction) - posted by al...@apache.org on 2016/11/07 15:26:34 UTC, 0 replies.
- flink git commit: [FLINK-5028] [streaming] StreamTask skips clean shutdown logic upon cancellation - posted by se...@apache.org on 2016/11/07 18:23:18 UTC, 1 replies.
- flink git commit: [FLINK-5032] Fix CsvOutputFormatTest on Windows OS - posted by ch...@apache.org on 2016/11/08 13:01:16 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] [tests] Clean up (mostly redundant) PowerMock runners, preparations, and exclusions - posted by se...@apache.org on 2016/11/08 14:27:30 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5014] [RocksDB backend] Add toString for RocksDBStateBackend - posted by se...@apache.org on 2016/11/08 14:27:31 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] [RocksDB backend] Minor cleanups to constructors and comments in RocksDBStateBackend - posted by se...@apache.org on 2016/11/08 14:27:32 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5022] Suppress RejectedExecutionExceptions if the ExecutorService has been shut down - posted by se...@apache.org on 2016/11/08 14:27:33 UTC, 0 replies.
- flink git commit: [FLINK-4963] [gelly] Tabulate edge direction for directed VertexMetrics - posted by gr...@apache.org on 2016/11/08 15:54:42 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4984] [checkpointing] Add Cancellation Barriers as a way to signal aborted checkpoints - posted by se...@apache.org on 2016/11/08 20:25:07 UTC, 1 replies.
- [2/4] flink git commit: [FLINK-4984] [checkpointing] Add Cancellation Barriers as a way to signal aborted checkpoints - posted by se...@apache.org on 2016/11/08 20:25:08 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4985] [checkpointing] Report canceled / declined checkpoints to the Checkpoint Coordinator - posted by se...@apache.org on 2016/11/08 20:25:09 UTC, 1 replies.
- [4/4] flink git commit: [FLINK-4975] [checkpointing] Add a limit for how much data may be buffered in alignment. - posted by se...@apache.org on 2016/11/08 20:25:10 UTC, 1 replies.
- [2/4] flink git commit: [FLINK-4985] [checkpointing] Report canceled / declined checkpoints to the Checkpoint Coordinator - posted by se...@apache.org on 2016/11/08 23:11:06 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Properly Await Termination in SavepointITCase - posted by al...@apache.org on 2016/11/09 10:17:37 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5019] Proper isRestored result for tasks that did not write state - posted by al...@apache.org on 2016/11/09 10:17:38 UTC, 0 replies.
- flink git commit: [hotfix] Move logging of JobStatus changes into the ExecutionGraph - posted by tr...@apache.org on 2016/11/09 13:57:03 UTC, 1 replies.
- flink git commit: [FLINK-5037] Fixed instability in AbstractUdfStreamOperatorLifecycleTest - posted by al...@apache.org on 2016/11/09 14:48:15 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5038] [streaming runtime] Make sure Canceleables are canceled even them "cancelTask" throws an exception - posted by se...@apache.org on 2016/11/09 19:24:47 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [web frontend] Reduce log level to DEBUG for requests againt unavailable jobs - posted by se...@apache.org on 2016/11/09 19:24:48 UTC, 0 replies.
- flink git commit: [FLINK-5038] [streaming runtime] Make sure Canceleables are canceled even them "cancelTask" throws an exception - posted by se...@apache.org on 2016/11/09 20:28:24 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5033] [cep] Advance time with incoming watermarks at CEP operator - posted by tr...@apache.org on 2016/11/10 13:21:16 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5027] FileSource finishes successfully with a wrong path - posted by tr...@apache.org on 2016/11/10 13:21:17 UTC, 0 replies.
- flink git commit: [FLINK-5033] [cep] Advance time with incoming watermarks at CEP operator - posted by tr...@apache.org on 2016/11/10 13:44:29 UTC, 0 replies.
- flink git commit: [FLINK-4954] [rpc] Discard messages when AkkaRpcActor is in state Processing.STOP - posted by tr...@apache.org on 2016/11/10 13:48:02 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] [tests] Fix wrong argument order of assertNotNull in ClassLoaderITCase. - posted by fh...@apache.org on 2016/11/10 14:34:55 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] [tests] Fix boxed Integer comparison with != in PartitionerITCase. - posted by fh...@apache.org on 2016/11/10 14:34:56 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] Fix duplicate "ms" time unit in RestartStrategy. - posted by fh...@apache.org on 2016/11/10 14:34:57 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] [docs] [tableAPI] Fix typos in Table API documentation. - posted by fh...@apache.org on 2016/11/10 14:34:58 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4946] [scripts] Load jar files from subdirectories of lib - posted by gr...@apache.org on 2016/11/10 17:14:10 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4970] [gelly] Parameterize vertex value for SSSP - posted by gr...@apache.org on 2016/11/10 17:14:11 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] [gelly] Flip ordering of TriangleListing bitmask - posted by gr...@apache.org on 2016/11/10 17:14:12 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4934] [gelly] Triadic Census - posted by gr...@apache.org on 2016/11/10 17:14:13 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5046] [tdd] Preserialize TaskDeploymentDescriptor information - posted by tr...@apache.org on 2016/11/10 17:47:29 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-5046] [tdd] Preserialize TaskDeploymentDescriptor information - posted by tr...@apache.org on 2016/11/10 17:47:30 UTC, 1 replies.
- [1/3] flink git commit: [FLINK-5040] [jobmanager] Set correct input channel types with eager scheduling - posted by uc...@apache.org on 2016/11/10 20:53:40 UTC, 0 replies.
- [2/3] flink git commit: Revert "[FLINK-3232] [runtime] Add option to eagerly deploy channels" - posted by uc...@apache.org on 2016/11/10 20:53:41 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5040] [taskmanager] Adjust partition request backoffs - posted by uc...@apache.org on 2016/11/10 20:53:42 UTC, 1 replies.
- flink git commit: [hotfix] Fix ExecutionVertexDeploymentTest compilation - posted by uc...@apache.org on 2016/11/10 21:20:12 UTC, 0 replies.
- [1/3] flink git commit: Revert "[FLINK-3232] [runtime] Add option to eagerly deploy channels" - posted by uc...@apache.org on 2016/11/11 08:45:00 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5040] [jobmanager] Set correct input channel types with eager scheduling - posted by uc...@apache.org on 2016/11/11 08:45:01 UTC, 0 replies.
- flink git commit: Commit for release 1.1.4 - posted by uc...@apache.org on 2016/11/11 09:04:08 UTC, 0 replies.
- flink git commit: [FLINK-5012] Expose Timestamp in Timely FlatMap Functions - posted by al...@apache.org on 2016/11/11 09:18:38 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5021] Make the ContinuousFileReaderOperator rescalable. - posted by al...@apache.org on 2016/11/11 13:09:10 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5021] Guarantee PROCESS_ONCE works correctly after recovering. - posted by al...@apache.org on 2016/11/11 13:09:11 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5021] Remove the special EOS TimestampedFileInputSplit. - posted by al...@apache.org on 2016/11/11 13:09:12 UTC, 0 replies.
- flink git commit: [FLINK-4939] WriteAheadSink: Decouple creation and commit of a pending checkpoint - posted by ch...@apache.org on 2016/11/14 12:41:43 UTC, 0 replies.
- flink git commit: [FLINK-4177] Harden CassandraConnectorITCase - posted by ch...@apache.org on 2016/11/14 13:38:52 UTC, 0 replies.
- flink git commit: [hotfix] [cassandra] Fix CassandraSinkBase serialization issue - posted by ch...@apache.org on 2016/11/14 13:45:28 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [metrics] Supply name to view/reporter thread - posted by ch...@apache.org on 2016/11/14 15:23:45 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [metrics] Prevent concurrency issues in MeterView - posted by ch...@apache.org on 2016/11/14 15:23:46 UTC, 0 replies.
- flink git commit: [FLINK-4174] Enhance evictor functionality - posted by al...@apache.org on 2016/11/15 09:07:28 UTC, 0 replies.
- flink git commit: [hotfix] [cassandra] [tests] Show error log messages - posted by ch...@apache.org on 2016/11/15 13:28:39 UTC, 0 replies.
- flink git commit: [FLINK-4174] Add accessor for current watermark in Evictor Context - posted by al...@apache.org on 2016/11/15 13:53:02 UTC, 0 replies.
- flink git commit: [FLINK-4801] [types] Input type inference is faulty with custom Tuples and RichFunctions - posted by tw...@apache.org on 2016/11/15 13:57:59 UTC, 0 replies.
- flink git commit: [hotfix] Remove unused ProcessingTimeService from Evictor - posted by tr...@apache.org on 2016/11/15 14:40:57 UTC, 0 replies.
- flink git commit: [FLINK-5013] [kinesis] Shade AWS dependencies to work with older EMR versions - posted by tz...@apache.org on 2016/11/16 06:27:03 UTC, 1 replies.
- flink git commit: [hotfix] [metrics] MetricRegistry threadNumber starts at 1 - posted by ch...@apache.org on 2016/11/16 14:05:19 UTC, 0 replies.
- [1/5] flink git commit: Revert "[FLINK-4177] Harden CassandraConnectorITCase" - posted by se...@apache.org on 2016/11/16 18:09:51 UTC, 0 replies.
- [2/5] flink git commit: Revert "[hotfix] [cassandra] [tests] Show error log messages" - posted by se...@apache.org on 2016/11/16 18:09:52 UTC, 0 replies.
- [3/5] flink git commit: [hotfix] [Kafka Consumer] Clean up some code confusion and style in the Fetchers for Kafka 0.9/0.10 - posted by se...@apache.org on 2016/11/16 18:09:53 UTC, 0 replies.
- [4/5] flink git commit: Revert "[hotfix] [cassandra] Fix CassandraSinkBase serialization issue" - posted by se...@apache.org on 2016/11/16 18:09:54 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-5048] [kafka consumer] Change thread model of FlinkKafkaConsumer to better handel shutdown/interrupt situations - posted by se...@apache.org on 2016/11/16 18:09:55 UTC, 0 replies.
- flink git commit: [hotfix] [tests] Corrected log4j files. - posted by gr...@apache.org on 2016/11/16 19:26:09 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5006] [streaming] Remove assumption of order in SystemProcessingTimeServiceTest - posted by se...@apache.org on 2016/11/16 23:35:32 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5063] [checkpointing] Discard state handles of declined or expired state handles - posted by se...@apache.org on 2016/11/16 23:35:33 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5057] [taskmanager] Read cancellation timeout from task manager config - posted by se...@apache.org on 2016/11/16 23:35:34 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5057] [taskmanager] Read cancellation timeout from task manager config - posted by se...@apache.org on 2016/11/16 23:36:43 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5063] [checkpointing] Discard state handles of declined or expired state handles - posted by se...@apache.org on 2016/11/16 23:36:44 UTC, 0 replies.
- flink git commit: [FLINK-4263] [table] SQL's VALUES does not work properly - posted by tw...@apache.org on 2016/11/17 13:45:31 UTC, 0 replies.
- flink git commit: [hotfix] [checkpoints] Enhance debug logging in exactly-once and at-least-once checkpoint stream aligners - posted by se...@apache.org on 2016/11/17 16:42:30 UTC, 1 replies.
- [1/2] flink git commit: [hotfix] [docs] Fix incorrect URL. - posted by fh...@apache.org on 2016/11/17 22:46:32 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-5058] [scala-shell] Set correct value for TaskManager memory parameter. - posted by fh...@apache.org on 2016/11/17 22:46:33 UTC, 1 replies.
- flink git commit: [FLINK-5054] [FLINK-5056] Make the BucketingSink rescalable. - posted by ch...@apache.org on 2016/11/18 10:51:13 UTC, 0 replies.
- flink git commit: [FLINK-5071][yarn] adjust vcore validation check - posted by mx...@apache.org on 2016/11/21 16:49:48 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [streamExamples] Fix typo in comment. - posted by fh...@apache.org on 2016/11/21 20:45:26 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [docs] Fix broken links, figures, and code examples. - posted by fh...@apache.org on 2016/11/21 20:45:27 UTC, 0 replies.
- flink git commit: [FLINK-4294] [table] Allow access of composite type fields - posted by tw...@apache.org on 2016/11/22 08:19:21 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5082] Pull ExecutorService lifecycle management out of the JobManager - posted by tr...@apache.org on 2016/11/22 08:48:45 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5073] Use Executor to run ZooKeeper callbacks in ZooKeeperStateHandleStore - posted by tr...@apache.org on 2016/11/22 08:48:46 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-5085] Execute CheckpointCoordinator's state discard calls asynchronously - posted by tr...@apache.org on 2016/11/22 08:48:47 UTC, 1 replies.
- [4/4] flink git commit: [FLINK-5085] Execute CheckpointCoordinator's state discard calls asynchronously - posted by tr...@apache.org on 2016/11/22 08:48:48 UTC, 1 replies.
- flink git commit: [FLINK-5123] [docs] Add description how to build a properly shaded build with different Maven versions - posted by se...@apache.org on 2016/11/22 11:51:55 UTC, 1 replies.
- flink git commit: [FLINK-4155] [kafka] Move partition list fetching to open() for Kafka producers - posted by tz...@apache.org on 2016/11/22 15:51:44 UTC, 0 replies.
- flink git commit: [FLINK-3869] Replace WindowedStream.apply() by reduce()/fold() - posted by al...@apache.org on 2016/11/22 16:43:17 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5073] Use Executor to run ZooKeeper callbacks in ZooKeeperStateHandleStore - posted by tr...@apache.org on 2016/11/22 22:09:40 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5082] Pull ExecutorService lifecycle management out of the JobManager - posted by tr...@apache.org on 2016/11/22 22:09:41 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4910] Introduce safety net for closing file system streams - posted by tr...@apache.org on 2016/11/22 23:25:53 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5107] Introduced limit for prior execution attempt history - posted by tr...@apache.org on 2016/11/22 23:25:54 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5107] Handle evicted execution attempts in request handlers - posted by tr...@apache.org on 2016/11/22 23:25:55 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5107] Introduced limit for prior execution attempt history - posted by tr...@apache.org on 2016/11/23 08:13:50 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5107] Handle evicted execution attempts in request handlers - posted by tr...@apache.org on 2016/11/23 08:13:51 UTC, 0 replies.
- flink git commit: [FLINK-5124] [table] Support more temporal arithmetic - posted by tw...@apache.org on 2016/11/23 09:06:59 UTC, 0 replies.
- flink git commit: [FLINK-2608] Updated Twitter Chill version. - posted by mx...@apache.org on 2016/11/23 09:39:15 UTC, 0 replies.
- flink git commit: [FLINK-5010] [akka] Introduce default configuration values for Akka's deathwatch - posted by tr...@apache.org on 2016/11/23 13:09:40 UTC, 0 replies.
- flink git commit: [FLINK-5000] Rename Methods in ManagedInitializationContext - posted by al...@apache.org on 2016/11/23 15:13:53 UTC, 0 replies.
- flink git commit: [FLINK-4900] flink-master: Allow to deploy TM with container - posted by mx...@apache.org on 2016/11/23 16:43:50 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] [streaming] Fix type extraction for joined streams. - posted by fh...@apache.org on 2016/11/23 20:03:08 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4937] [table] Add incremental group window aggregation for streaming Table API. - posted by fh...@apache.org on 2016/11/23 20:03:09 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2662] [optimizer] Fix computation of global properties of union operator. - posted by fh...@apache.org on 2016/11/23 20:03:10 UTC, 0 replies.
- [4/5] flink git commit: [hotfix][docs] Stream joins don't support tuple position keys - posted by fh...@apache.org on 2016/11/23 20:03:11 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-5143] [table] Add EXISTS to list of supported SQL operators. - posted by fh...@apache.org on 2016/11/23 20:03:12 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2662] [optimizer] Fix computation of global properties of union operator. - posted by fh...@apache.org on 2016/11/23 20:15:33 UTC, 0 replies.
- [2/3] flink git commit: [hotfix][docs] Stream joins don't support tuple position keys - posted by fh...@apache.org on 2016/11/23 20:15:34 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [streaming] Fix type extraction for joined streams. - posted by fh...@apache.org on 2016/11/23 20:15:35 UTC, 0 replies.
- flink git commit: [FLINK-5149] let ContinuousEventTimeTrigger fire at the end of the window - posted by mx...@apache.org on 2016/11/24 10:33:52 UTC, 1 replies.
- flink git commit: [FLINK-5075] [kinesis] Make connector fail-proof to incorrect Kinesalite API behaviour - posted by tz...@apache.org on 2016/11/24 10:52:31 UTC, 1 replies.
- flink git commit: [FLINK-2608] remove expensive integration tests previously introduced - posted by mx...@apache.org on 2016/11/24 17:28:56 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-3702] Make FieldAccessors support nested field expressions. - posted by mb...@apache.org on 2016/11/24 21:23:14 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-3702] Make FieldAccessors support nested field expressions. - posted by mb...@apache.org on 2016/11/24 21:23:15 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-3702] FieldAccessor refactor to static factory - posted by mb...@apache.org on 2016/11/24 21:23:16 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-3702] FieldAccessor refactor to static factory - posted by mb...@apache.org on 2016/11/24 21:23:17 UTC, 0 replies.
- flink git commit: [FLINK-5055][security] skip Hadoop UGI login if unsecured - posted by mx...@apache.org on 2016/11/25 13:59:29 UTC, 0 replies.
- flink git commit: Revert "[FLINK-4913][yarn] include user jars in system class loader" - posted by rm...@apache.org on 2016/11/25 15:16:20 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] Fix condition in CoGroupRawDescriptor - posted by ch...@apache.org on 2016/11/27 11:51:32 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5112] [ExecutionGraph] Remove unused accumulator aggregation code from ArchivedExecutionJobVertex - posted by ch...@apache.org on 2016/11/27 11:51:33 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4741] Proper shutdown the ServerBootstrap WebRuntimeMonitor - posted by ch...@apache.org on 2016/11/27 11:51:34 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5096] Make the RollingSink rescalable. - posted by ch...@apache.org on 2016/11/27 11:51:35 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5172] [RockDB backend] Set dependencies to 'flink-core' and 'flink-streaming-java' as 'provided' - posted by se...@apache.org on 2016/11/28 10:57:08 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5173] [RocksDB backend] Upgrade RocksDB version to 4.11.2 - posted by se...@apache.org on 2016/11/28 10:57:09 UTC, 0 replies.
- flink git commit: [FLINK-4993] Don't Allow Trigger.onMerge() to return TriggerResult - posted by al...@apache.org on 2016/11/28 12:08:43 UTC, 0 replies.
- flink git commit: [FLINK-4993] Remove Unused Import in TriggerResult - posted by al...@apache.org on 2016/11/28 12:52:44 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5168] Scaladoc annotation link use [[]] instead of {@link} - posted by se...@apache.org on 2016/11/28 13:32:18 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] [tests] Harden timeout logic for TaskManager registration in AbstractTaskManagerProcessFailureRecoveryTest - posted by se...@apache.org on 2016/11/28 13:32:19 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] Flush in CsvOutputFormat before closing, to increase CI stability - posted by se...@apache.org on 2016/11/28 13:32:20 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5050] [build] Remove transitive JSON.org dependency - posted by se...@apache.org on 2016/11/28 13:32:21 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Add a rouch description about internal types of states and state backends - posted by se...@apache.org on 2016/11/28 13:57:47 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-5171] [runtime] fix wrong use of Preconditions.checkState in TaskManagerRunner - posted by tr...@apache.org on 2016/11/28 16:22:13 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-5170] [akka] Fix hostname usage in AkkaUtils.getConfig - posted by tr...@apache.org on 2016/11/28 16:22:14 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-5076] Shutting down TM when shutting down mini cluster. - posted by tr...@apache.org on 2016/11/28 16:22:15 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-5170] [akka] Extend AkkaUtils.getAkkaConfig methods to properly work with Java - posted by tr...@apache.org on 2016/11/28 16:22:16 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-5093] Fix bug about throwing ConcurrentModificationException when stopping TimerService. - posted by tr...@apache.org on 2016/11/28 16:22:17 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-5093] Add proper shutdown of scheduled executor service in TimerService - posted by tr...@apache.org on 2016/11/28 16:22:18 UTC, 0 replies.
- flink git commit: [FLINK-5181] Add Tests in StateBackendTestBase that verify Default-Value Behaviour - posted by al...@apache.org on 2016/11/28 16:59:40 UTC, 0 replies.
- flink git commit: [FLINK-4872] [types] Type erasure problem exclusively on cluster execution - posted by tw...@apache.org on 2016/11/28 17:28:52 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5050] [build] Remove transitive JSON.org dependency - posted by se...@apache.org on 2016/11/28 17:31:44 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5142] [checkpoints] Fix timer resource leak in CheckpointCoordinator - posted by se...@apache.org on 2016/11/28 17:31:45 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5026] Rename TimelyFlatMap to Process - posted by al...@apache.org on 2016/11/28 17:45:10 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5026] Rename TimelyFlatMap to Process - posted by al...@apache.org on 2016/11/28 17:45:11 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-5169] [network] Add tests for channel consumption - posted by uc...@apache.org on 2016/11/28 20:06:08 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-5169] [network] Adjust tests to new consumer logic - posted by uc...@apache.org on 2016/11/28 20:06:09 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-5169] [network] Adjust tests to new consumer logic - posted by uc...@apache.org on 2016/11/28 20:06:10 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-5169] [network] Make consumption of InputChannels fair - posted by uc...@apache.org on 2016/11/28 20:06:11 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-5169] [network] Make consumption of InputChannels fair - posted by uc...@apache.org on 2016/11/28 20:06:12 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4825] [table] Implement a RexExecutor that uses Flink's code generation. - posted by fh...@apache.org on 2016/11/29 14:42:55 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5184] [table] Fix compareSerialized() of RowComparator. - posted by fh...@apache.org on 2016/11/29 14:42:56 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4832] [table] Fix global aggregation of empty tables (Count/Sum = 0). - posted by fh...@apache.org on 2016/11/29 14:42:57 UTC, 0 replies.
- flink git commit: [FLINK-5184] [table] Fix compareSerialized() of RowComparator. - posted by fh...@apache.org on 2016/11/29 14:51:02 UTC, 0 replies.
- flink git commit: [FLINK-4260] [table] Allow SQL's LIKE ESCAPE - posted by tw...@apache.org on 2016/11/29 15:01:51 UTC, 0 replies.
- flink git commit: [FLINK-4921] Upgrade to Mesos 1.0.1 - posted by mx...@apache.org on 2016/11/29 17:49:10 UTC, 0 replies.
- flink git commit: [FLINK-5197] [jm] Ignore outdated JobStatusChanged messages - posted by tr...@apache.org on 2016/11/30 12:41:44 UTC, 1 replies.
- flink git commit: [FLINK-4895] Drop Hadoop1 support and remove related build infrastructure - posted by rm...@apache.org on 2016/11/30 14:43:50 UTC, 0 replies.
- flink git commit: [FLINK-5123] [task] Add missing @Override to Task#failExternally - posted by uc...@apache.org on 2016/11/30 15:18:29 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-5192] [logging] Improve log config templates - posted by uc...@apache.org on 2016/11/30 15:22:22 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-5199] [logging] Improve logging in ZooKeeperSubmittedJobGraphStore - posted by uc...@apache.org on 2016/11/30 15:22:23 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-5201] [logging] Log loaded config properties on INFO level - posted by uc...@apache.org on 2016/11/30 15:22:24 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-5194] [logging] Log heartbeats on TRACE level - posted by uc...@apache.org on 2016/11/30 15:22:25 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-5196] [logging] Don't log InputChannelDeploymentDescriptor - posted by uc...@apache.org on 2016/11/30 15:22:26 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-5207] [logging] Decrease HadoopFileSystem logging - posted by uc...@apache.org on 2016/11/30 15:22:27 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-5198] [logging] Improve TaskState toString - posted by uc...@apache.org on 2016/11/30 15:22:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4826] add keytab support to mesos container - posted by mx...@apache.org on 2016/11/30 17:31:06 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4918] add SSL handler to artifact server - posted by mx...@apache.org on 2016/11/30 17:31:07 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:18 UTC, 0 replies.
- [2/5] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:19 UTC, 0 replies.
- [3/5] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:20 UTC, 0 replies.
- [4/5] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:21 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-3680] [web frontend] Remove "(not set)" text in the Job Plan UI - posted by gr...@apache.org on 2016/11/30 21:49:22 UTC, 0 replies.
- [01/10] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:46 UTC, 0 replies.
- [02/10] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:47 UTC, 0 replies.
- [03/10] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:48 UTC, 0 replies.
- [04/10] flink git commit: [hotfix] [webfrontend] Rebuild - posted by gr...@apache.org on 2016/11/30 21:49:49 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-3680] [web frontend] Remove "(not set)" text in the Job Plan UI - posted by gr...@apache.org on 2016/11/30 21:49:50 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-3719][web frontend] Moving the barrier between graph and stats - posted by gr...@apache.org on 2016/11/30 21:49:51 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-3719][web frontend] Moving the barrier between graph and stats - posted by gr...@apache.org on 2016/11/30 21:49:52 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-3719][web frontend] Moving the barrier between graph and stats - posted by gr...@apache.org on 2016/11/30 21:49:53 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-3719][web frontend] Moving the barrier between graph and stats - posted by gr...@apache.org on 2016/11/30 21:49:54 UTC, 0 replies.
- [10/10] flink git commit: [hotfix] [webfrontend] Organize job pane tabs - posted by gr...@apache.org on 2016/11/30 21:49:55 UTC, 0 replies.