commits@flink.apache.org, 2016-10

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

- buildbot success in on flink-docs-release-0.10 - posted by bu...@apache.org on 2016/10/01 03:15:13 UTC, 2 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #239 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/10/01 05:32:23 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4618] [kafka-connector] Incremented the commited offset by one to avoid duplicate read message. - posted by tz...@apache.org on 2016/10/01 10:10:56 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-4618] [kafka-connector] Minor improvements to comment and variable naming - posted by tz...@apache.org on 2016/10/01 10:10:57 UTC, 1 replies.
- flink git commit: [FLINK-4406] [cluster management] Implement job master registration at resource manager - posted by tr...@apache.org on 2016/10/02 20:56:12 UTC, 0 replies.
- flink git commit: [FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper - posted by tr...@apache.org on 2016/10/02 21:43:07 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's main thread [Forced Update!] - posted by tr...@apache.org on 2016/10/02 21:58:06 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4392] [rpc] Make RPC Service thread-safe - posted by tr...@apache.org on 2016/10/02 21:58:07 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Add tests for the TaskManager -> ResourceManager registration. - posted by tr...@apache.org on 2016/10/02 21:58:08 UTC, 1 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4434] [rpc] Add a testing RPC service. - posted by tr...@apache.org on 2016/10/02 21:58:09 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Implement TaskManager side of registration at ResourceManager. - posted by tr...@apache.org on 2016/10/02 21:58:10 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4414] [cluster] Add getAddress method to RpcGateway - posted by tr...@apache.org on 2016/10/02 21:58:11 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader. - posted by tr...@apache.org on 2016/10/02 21:58:12 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4363] Implement TaskManager basic startup of all components in java - posted by tr...@apache.org on 2016/10/02 21:58:13 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [hotfix] [clustermgnt] Set pending registration properly in TaskExecutorToResourceManagerConnection - posted by tr...@apache.org on 2016/10/02 21:58:14 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [hotfix] Remove RecoveryMode from JobMaster - posted by tr...@apache.org on 2016/10/02 21:58:15 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance - posted by tr...@apache.org on 2016/10/02 21:58:16 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters - posted by tr...@apache.org on 2016/10/02 21:58:17 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/02 21:58:18 UTC, 1 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/02 21:58:19 UTC, 1 replies.
- [15/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/02 21:58:20 UTC, 1 replies.
- [16/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/02 21:58:21 UTC, 1 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/02 21:58:22 UTC, 1 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/02 21:58:23 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4516] leader election of resourcemanager - posted by tr...@apache.org on 2016/10/02 21:58:24 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core - posted by tr...@apache.org on 2016/10/02 21:58:25 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as protected - posted by tr...@apache.org on 2016/10/02 21:58:26 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot - posted by tr...@apache.org on 2016/10/02 21:58:27 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by tr...@apache.org on 2016/10/02 21:58:28 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [hotfix] Add self rpc gateway registration to TestingSerialRpcService - posted by tr...@apache.org on 2016/10/02 21:58:29 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [hotfix] [taskmanager] Fixes TaskManager component creation at startup - posted by tr...@apache.org on 2016/10/02 21:58:30 UTC, 1 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/10/02 21:58:31 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/10/02 21:58:32 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/10/02 21:58:33 UTC, 1 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/10/02 21:58:34 UTC, 1 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4537] [cluster management] ResourceManager registration with JobManager - posted by tr...@apache.org on 2016/10/02 21:58:35 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4537] rebase and refine - posted by tr...@apache.org on 2016/10/02 21:58:36 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [hotfix] Add methods defined in the gateway to the ResourceManager and TaskExecutor - posted by tr...@apache.org on 2016/10/02 21:58:37 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor - posted by tr...@apache.org on 2016/10/02 21:58:38 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [FLINK-4535] rebase and refine - posted by tr...@apache.org on 2016/10/02 21:58:39 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [hotfix] fix ResourceManagerGateway - posted by tr...@apache.org on 2016/10/02 21:58:40 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails fast when endpoint is unreachable. - posted by tr...@apache.org on 2016/10/02 21:58:41 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor - posted by tr...@apache.org on 2016/10/02 21:58:42 UTC, 0 replies.
- [38/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/10/02 21:58:43 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Implement TaskManager component's startup - posted by tr...@apache.org on 2016/10/02 21:58:44 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by tr...@apache.org on 2016/10/02 21:58:45 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tr...@apache.org on 2016/10/02 21:58:46 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by tr...@apache.org on 2016/10/02 21:58:47 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/10/02 21:58:48 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/10/02 21:58:49 UTC, 1 replies.
- [45/50] [abbrv] flink git commit: [FLINK-4606] integrate features of old ResourceManager - posted by tr...@apache.org on 2016/10/02 21:58:50 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager - posted by tr...@apache.org on 2016/10/02 21:58:51 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses - posted by tr...@apache.org on 2016/10/02 21:58:52 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices - posted by tr...@apache.org on 2016/10/02 21:58:53 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-4406] [cluster management] Implement job master registration at resource manager - posted by tr...@apache.org on 2016/10/02 21:58:54 UTC, 1 replies.
- [50/50] [abbrv] flink git commit: [FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper - posted by tr...@apache.org on 2016/10/02 21:58:55 UTC, 0 replies.
- flink git commit: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by tr...@apache.org on 2016/10/02 22:00:24 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4624] [gelly] Support null values in Graph Summarization - posted by gr...@apache.org on 2016/10/03 14:55:06 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4643] [gelly] Average Clustering Coefficient - posted by gr...@apache.org on 2016/10/03 14:55:07 UTC, 0 replies.
- flink git commit: [FLINK-3656] [table] Convert expression tests to unit tests - posted by tw...@apache.org on 2016/10/04 10:00:32 UTC, 0 replies.
- flink git commit: [hotfix] Fix failing JobManagerRunnerMockTest - posted by tr...@apache.org on 2016/10/04 12:28:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4068] [table] Move constant computations out of code-generated - posted by tw...@apache.org on 2016/10/04 12:36:38 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4068] [table] Reduce expression also for filter/project - posted by tw...@apache.org on 2016/10/04 12:36:39 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [kafka] Fix NPE in Kafka09Fetcher - posted by fh...@apache.org on 2016/10/04 12:45:31 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4311] [hbase-connector] Fixed TableInputFormat to process multiple input splits. - posted by fh...@apache.org on 2016/10/04 12:45:32 UTC, 0 replies.
- flink git commit: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL - posted by tw...@apache.org on 2016/10/04 13:26:00 UTC, 0 replies.
- flink git commit: [hotfix] [kafka] Fix NPE in Kafka09Fetcher - posted by fh...@apache.org on 2016/10/04 13:46:06 UTC, 0 replies.
- flink git commit: [FLINK-4732] remove maven junction plugin - posted by mx...@apache.org on 2016/10/04 13:48:37 UTC, 1 replies.
- flink git commit: [hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should also be incremented by 1. - posted by tz...@apache.org on 2016/10/05 10:49:35 UTC, 1 replies.
- flink git commit: [FLINK-3874] Rewrite Kafka JSON Table sink tests - posted by tw...@apache.org on 2016/10/05 12:37:23 UTC, 0 replies.
- flink git commit: [FLINK-4677] fail if user jar contains no executions - posted by mx...@apache.org on 2016/10/05 14:09:01 UTC, 1 replies.
- flink git commit: [FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling - posted by mx...@apache.org on 2016/10/05 15:57:12 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4729] [gelly] Use optional VertexCentric CombineFunction - posted by gr...@apache.org on 2016/10/05 17:16:53 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4729] [gelly] Use optional VertexCentric CombineFunction - posted by gr...@apache.org on 2016/10/05 17:16:54 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4734] [gelly] Remove use of Tuple setField for fixed position - posted by gr...@apache.org on 2016/10/05 17:16:55 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4740] [tests] Upgrade testing libraries - posted by gr...@apache.org on 2016/10/05 17:16:56 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4744] [streaming api] Introduce usercode class loader to deserialize partitionable operator state - posted by se...@apache.org on 2016/10/05 20:28:59 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4744] [streaming api] Followup: Unify names for operator state access methods and comments. - posted by se...@apache.org on 2016/10/05 20:29:00 UTC, 0 replies.
- [01/17] flink git commit: [FLINK-4737] [core] Ensure that Flink and its Hadoop dependency pull the same version of 'commons-compress' - posted by se...@apache.org on 2016/10/05 22:16:51 UTC, 0 replies.
- [02/17] flink git commit: [hotfix] Various code cleanups around time service and asynchronous exceptions - posted by se...@apache.org on 2016/10/05 22:16:52 UTC, 0 replies.
- [03/17] flink git commit: [hotfix] [core] Minor code cleanup and correction of javadocs for filesystem input stream classes. - posted by se...@apache.org on 2016/10/05 22:16:53 UTC, 0 replies.
- [04/17] flink git commit: [FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper - posted by se...@apache.org on 2016/10/05 22:16:54 UTC, 0 replies.
- [05/17] flink git commit: [FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks Handling - posted by se...@apache.org on 2016/10/05 22:16:55 UTC, 0 replies.
- [06/17] flink git commit: [FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks Handling - posted by se...@apache.org on 2016/10/05 22:16:56 UTC, 0 replies.
- [07/17] flink git commit: [FLINK-4737] [core] Add support for bz2 and xy compression in flink-core. - posted by se...@apache.org on 2016/10/05 22:16:57 UTC, 0 replies.
- [08/17] flink git commit: [FLINK-4728] [core, optimizer] Replace reference equality with object equality - posted by se...@apache.org on 2016/10/05 22:16:58 UTC, 0 replies.
- [09/17] flink git commit: [FLINK-4748] [streaming api] Make timers in Ingestion Time source context properly cancelable. - posted by se...@apache.org on 2016/10/05 22:16:59 UTC, 0 replies.
- [10/17] flink git commit: [hotfix] [streaming api] Cleanup watermark initialization in window operator - posted by se...@apache.org on 2016/10/05 22:17:00 UTC, 0 replies.
- [11/17] flink git commit: [FLINK-4739] [elasticsearch connector] Adding packaging details for the Elasticsearch connector - posted by se...@apache.org on 2016/10/05 22:17:01 UTC, 0 replies.
- [12/17] flink git commit: [FLINK-4718] [docs] Fix figure about parallel watermarks. - posted by se...@apache.org on 2016/10/05 22:17:02 UTC, 0 replies.
- [13/17] flink git commit: [FLINK-4750] [runtime] Cleanly await end of all currently executing processing time timers when finite streams finish. - posted by se...@apache.org on 2016/10/05 22:17:03 UTC, 0 replies.
- [14/17] flink git commit: [hotfix] [streaming api] Remove obsolete and unused InputTypeSerializer from WindowOperator - posted by se...@apache.org on 2016/10/05 22:17:04 UTC, 0 replies.
- [15/17] flink git commit: [FLINK-4749] [streaming api] Remove redundant processing time timer sets from window operator - posted by se...@apache.org on 2016/10/05 22:17:05 UTC, 0 replies.
- [16/17] flink git commit: [FLINK-4700] [tests] Expand and harden TimeServiceProvider test - posted by se...@apache.org on 2016/10/05 22:17:06 UTC, 0 replies.
- [17/17] flink git commit: [hotfix] [tests] Remove leftover sysout logging code - posted by se...@apache.org on 2016/10/05 22:17:07 UTC, 0 replies.
- flink git commit: Commit for release 1.1.3 - posted by uc...@apache.org on 2016/10/06 08:22:11 UTC, 1 replies.
- flink git commit: [FLINK-4751] [futures] Add thenCombineAsync function to Flink's futures - posted by tr...@apache.org on 2016/10/06 11:35:24 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages [Forced Update!] - posted by tr...@apache.org on 2016/10/06 11:48:21 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters - posted by tr...@apache.org on 2016/10/06 11:48:22 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4414] [cluster] Add getAddress method to RpcGateway - posted by tr...@apache.org on 2016/10/06 11:48:24 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader. - posted by tr...@apache.org on 2016/10/06 11:48:25 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4434] [rpc] Add a testing RPC service. - posted by tr...@apache.org on 2016/10/06 11:48:26 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4363] Implement TaskManager basic startup of all components in java - posted by tr...@apache.org on 2016/10/06 11:48:27 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [hotfix] [clustermgnt] Set pending registration properly in TaskExecutorToResourceManagerConnection - posted by tr...@apache.org on 2016/10/06 11:48:28 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [hotfix] Remove RecoveryMode from JobMaster - posted by tr...@apache.org on 2016/10/06 11:48:29 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance - posted by tr...@apache.org on 2016/10/06 11:48:30 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-4516] leader election of resourcemanager - posted by tr...@apache.org on 2016/10/06 11:48:31 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/10/06 11:48:32 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as protected - posted by tr...@apache.org on 2016/10/06 11:48:38 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core - posted by tr...@apache.org on 2016/10/06 11:48:39 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot - posted by tr...@apache.org on 2016/10/06 11:48:40 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/10/06 11:48:41 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/10/06 11:48:42 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [hotfix] Add self rpc gateway registration to TestingSerialRpcService - posted by tr...@apache.org on 2016/10/06 11:48:43 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by tr...@apache.org on 2016/10/06 11:48:44 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4537] [cluster management] ResourceManager registration with JobManager - posted by tr...@apache.org on 2016/10/06 11:48:46 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [hotfix] Add methods defined in the gateway to the ResourceManager and TaskExecutor - posted by tr...@apache.org on 2016/10/06 11:48:47 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor - posted by tr...@apache.org on 2016/10/06 11:48:50 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails fast when endpoint is unreachable. - posted by tr...@apache.org on 2016/10/06 11:48:51 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [hotfix] fix ResourceManagerGateway - posted by tr...@apache.org on 2016/10/06 11:48:52 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-4537] rebase and refine - posted by tr...@apache.org on 2016/10/06 11:48:53 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor - posted by tr...@apache.org on 2016/10/06 11:48:54 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-4535] rebase and refine - posted by tr...@apache.org on 2016/10/06 11:48:55 UTC, 0 replies.
- [36/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/10/06 11:48:56 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tr...@apache.org on 2016/10/06 11:48:57 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by tr...@apache.org on 2016/10/06 11:48:58 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by tr...@apache.org on 2016/10/06 11:48:59 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [FLINK-4606] integrate features of old ResourceManager - posted by tr...@apache.org on 2016/10/06 11:49:00 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses - posted by tr...@apache.org on 2016/10/06 11:49:01 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Implement TaskManager component's startup - posted by tr...@apache.org on 2016/10/06 11:49:02 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager - posted by tr...@apache.org on 2016/10/06 11:49:03 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/10/06 11:49:05 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by tr...@apache.org on 2016/10/06 11:49:06 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices - posted by tr...@apache.org on 2016/10/06 11:49:07 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper - posted by tr...@apache.org on 2016/10/06 11:49:08 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [hotfix] Fix failing JobManagerRunnerMockTest - posted by tr...@apache.org on 2016/10/06 11:49:10 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] Minor cleanup in FlinkKafkaConsumerBase and Test - posted by uc...@apache.org on 2016/10/06 15:04:40 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] Make KeyGroupsStateHandle implement StreamStateHandle - posted by uc...@apache.org on 2016/10/06 15:04:41 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4730] Introducing CheckpointMetaData - posted by uc...@apache.org on 2016/10/06 15:04:42 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4730] Introducing CheckpointMetaData - posted by uc...@apache.org on 2016/10/06 15:04:43 UTC, 0 replies.
- flink git commit: [FLINK-4736] [core] Don't duplicate fields in Ordering - posted by gr...@apache.org on 2016/10/06 21:10:37 UTC, 0 replies.
- flink git commit: [hotfix] [streaming api] Re-register timers in open() instead of restore() - posted by se...@apache.org on 2016/10/07 09:02:42 UTC, 0 replies.
- buildbot success in on flink-docs-master - posted by bu...@apache.org on 2016/10/07 11:39:16 UTC, 3 replies.
- flink git commit: [FLINK-4731] Fix HeapKeyedStateBackend Scale-In - posted by uc...@apache.org on 2016/10/07 12:15:34 UTC, 0 replies.
- buildbot failure in on flink-docs-master - posted by bu...@apache.org on 2016/10/07 12:59:10 UTC, 3 replies.
- [1/2] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by mx...@apache.org on 2016/10/07 14:00:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by mx...@apache.org on 2016/10/07 14:00:43 UTC, 0 replies.
- flink git commit: [FLINK-4318][docs] change default version in config - posted by mx...@apache.org on 2016/10/07 14:04:55 UTC, 0 replies.
- [1/3] flink-web git commit: [FLINK-4318][docs] change default version in config - posted by mx...@apache.org on 2016/10/07 14:12:08 UTC, 0 replies.
- [2/3] flink-web git commit: update website - posted by mx...@apache.org on 2016/10/07 14:12:09 UTC, 0 replies.
- [3/3] flink-web git commit: update website - posted by mx...@apache.org on 2016/10/07 14:12:10 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.1 - posted by bu...@apache.org on 2016/10/07 14:22:53 UTC, 2 replies.
- buildbot failure in on flink-docs-release-0.10 - posted by bu...@apache.org on 2016/10/08 03:01:29 UTC, 2 replies.
- buildbot success in on flink-docs-release-0.9 - posted by bu...@apache.org on 2016/10/08 04:33:34 UTC, 2 replies.
- flink git commit: [FLINK-4777] catch IOException in ContinuousFileMonitoringFunction - posted by mx...@apache.org on 2016/10/10 08:48:21 UTC, 1 replies.
- flink git commit: [FLINK-4745] [table] Convert KafkaTableSource test to unit tests - posted by tw...@apache.org on 2016/10/10 09:25:12 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4776] [distributed coordination] Move ExecutionGraph initialization into the dedicated class ExecutionGraphBuilder - posted by se...@apache.org on 2016/10/10 10:25:58 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4786] [tests] Fix BarrierBufferTest validation of alignment time computation - posted by se...@apache.org on 2016/10/10 10:25:59 UTC, 0 replies.
- [3/5] flink git commit: [hotfix] [tests] Increase robustness of Fast Time Window Operator Tests - posted by se...@apache.org on 2016/10/10 10:26:00 UTC, 0 replies.
- [4/5] flink git commit: [hotfix] [tests] Remove leftover sysout logging from AccumulatingAlignedProcessingTimeWindowOperatorTest - posted by se...@apache.org on 2016/10/10 10:26:01 UTC, 0 replies.
- [5/5] flink git commit: [hotfix] [tests] Fix PowerMock warnings concerning log4j - posted by se...@apache.org on 2016/10/10 10:26:02 UTC, 0 replies.
- flink git commit: [FLINK-4788] [streaming api] Fix state backend classloading from configuration - posted by se...@apache.org on 2016/10/10 12:51:02 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-4764] [core] Introduce Config Options - posted by se...@apache.org on 2016/10/10 13:47:03 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4768] [core] Migrate high-availability configuration parameters to ConfigOptions - posted by se...@apache.org on 2016/10/10 13:47:04 UTC, 0 replies.
- flink git commit: [FLINK-4439] Validate 'bootstrap.servers' config in flink kafka consumer 0.8 - posted by rm...@apache.org on 2016/10/10 15:05:48 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4311] [hbase] Fix TableInputFormat to correctly process multiple input splits. - posted by fh...@apache.org on 2016/10/10 18:49:56 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2765] [hbase] Bump HBase versions and fix tests. - posted by fh...@apache.org on 2016/10/10 18:49:57 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-3656] [table] Add test base for logical unit testing. - posted by fh...@apache.org on 2016/10/10 18:49:58 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4778] [docs] Fix WordCount parameters in CLI examples. - posted by fh...@apache.org on 2016/10/10 18:49:59 UTC, 0 replies.
- flink git commit: [FLINK-4778] [docs] Fix WordCount parameters in CLI examples. - posted by fh...@apache.org on 2016/10/10 18:52:36 UTC, 0 replies.
- buildbot failure in on flink-docs-release-1.1 - posted by bu...@apache.org on 2016/10/11 01:01:32 UTC, 2 replies.
- [1/3] flink git commit: [FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9 connector - posted by rm...@apache.org on 2016/10/11 08:05:11 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9 connector - posted by rm...@apache.org on 2016/10/11 08:05:12 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4035] Add support for Kafka 0.10.x. - posted by rm...@apache.org on 2016/10/11 08:05:13 UTC, 0 replies.
- flink git commit: [FLINK-4694] [rpc] Add termination futures to RpcEndpoint and RpcService - posted by tr...@apache.org on 2016/10/11 13:49:10 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by tr...@apache.org on 2016/10/11 15:23:07 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by tr...@apache.org on 2016/10/11 15:23:08 UTC, 0 replies.
- buildbot failure in on flink-docs-release-0.9 - posted by bu...@apache.org on 2016/10/12 04:01:25 UTC, 2 replies.
- flink git commit: [FLINK-4793] [types] Improve lambda constructor reference handling - posted by tw...@apache.org on 2016/10/12 09:03:10 UTC, 0 replies.
- flink git commit: [FLINK-4746] Make TaskManagerRuntimeInfo an interface - posted by tr...@apache.org on 2016/10/12 09:05:11 UTC, 0 replies.
- flink git commit: [FLINK-3706] Fix YARN test instability - posted by rm...@apache.org on 2016/10/12 09:59:11 UTC, 1 replies.
- flink git commit: [FLINK-4799] re-add 'build-target' symlink on Unix systems - posted by mx...@apache.org on 2016/10/12 10:07:34 UTC, 0 replies.
- svn commit: r16483 - /release/flink/flink-1.1.3/ - posted by uc...@apache.org on 2016/10/12 16:58:56 UTC, 0 replies.
- [1/2] flink git commit: [hotfix][kafka] Undo DataGenerators changes (use inline kafka producer again - posted by rm...@apache.org on 2016/10/13 08:24:15 UTC, 0 replies.
- [2/2] flink git commit: [hotfix][kafka] Backport Kafka09FetcherTest for Kafka010 - posted by rm...@apache.org on 2016/10/13 08:24:16 UTC, 0 replies.
- [flink] Git Push Summary - posted by uc...@apache.org on 2016/10/13 09:44:47 UTC, 0 replies.
- flink git commit: [FLINK-4516] update leadership information in ResourceManager - posted by mx...@apache.org on 2016/10/13 14:19:10 UTC, 0 replies.
- flink git commit: [FLINK-4791] [table] Fix issues caused by expression reduction - posted by tw...@apache.org on 2016/10/13 14:29:20 UTC, 0 replies.
- [1/4] flink-web git commit: Add 1.1.3 release blog post - posted by uc...@apache.org on 2016/10/13 15:11:58 UTC, 0 replies.
- [2/4] flink-web git commit: Update quickstart versions - posted by uc...@apache.org on 2016/10/13 15:11:59 UTC, 0 replies.
- [3/4] flink-web git commit: Update Flink version to 1.1.3 - posted by uc...@apache.org on 2016/10/13 15:12:00 UTC, 0 replies.
- [4/4] flink-web git commit: Rebuild webpage - posted by uc...@apache.org on 2016/10/13 15:12:01 UTC, 0 replies.
- flink git commit: [docs] Set version to 1.1.3 - posted by uc...@apache.org on 2016/10/13 15:17:57 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by se...@apache.org on 2016/10/13 15:40:11 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by se...@apache.org on 2016/10/13 15:40:12 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by se...@apache.org on 2016/10/13 15:40:13 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-4768] [core] Migrate high-availability configuration parameters to ConfigOptions - posted by se...@apache.org on 2016/10/13 15:40:14 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-4735] [cluster management] Implements some job execution related RPC calls on the JobManager - posted by se...@apache.org on 2016/10/13 15:40:15 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-4776] [distributed coordination] Move ExecutionGraph initialization into the dedicated class ExecutionGraphBuilder - posted by se...@apache.org on 2016/10/13 15:40:16 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-4764] [core] Introduce Config Options - posted by se...@apache.org on 2016/10/13 15:40:17 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-4339] [cluster management] Implement Slot Pool core on JobManager side - posted by se...@apache.org on 2016/10/13 15:40:18 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:05:59 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:06:00 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:06:01 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:06:02 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:06:03 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:06:04 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-4512] [FLIP-10] Add option to persist periodic checkpoints - posted by uc...@apache.org on 2016/10/14 08:06:05 UTC, 0 replies.
- flink git commit: [FLINK-4717] Add CancelJobWithSavepoint - posted by uc...@apache.org on 2016/10/14 08:07:42 UTC, 0 replies.
- flink git commit: [FLINK-4373] [cluster management] Introduce AllocationID, ResourceProfile, and AllocatedSlot - posted by se...@apache.org on 2016/10/14 09:49:03 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4720] Implement archived ExecutionGraph - posted by ch...@apache.org on 2016/10/14 11:55:47 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4720] Implement archived ExecutionGraph - posted by ch...@apache.org on 2016/10/14 11:55:48 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4720] Implement archived ExecutionGraph - posted by ch...@apache.org on 2016/10/14 11:55:49 UTC, 0 replies.
- flink git commit: [FLINK-4774] [metrics] Fix scope concatenation in QueryScopeInfo - posted by ch...@apache.org on 2016/10/14 11:59:26 UTC, 0 replies.
- flink git commit: [FLINK-4827] [docs] Fix scala Streaming Table example - posted by ch...@apache.org on 2016/10/14 12:13:32 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-3660] Measure latency and exposes them via a metric - posted by rm...@apache.org on 2016/10/14 12:34:11 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3660] Measure latency and exposes them via a metric - posted by rm...@apache.org on 2016/10/14 12:34:12 UTC, 0 replies.
- flink git commit: [hotfix] Fix ArchivedExecutionGraphTest - posted by ch...@apache.org on 2016/10/14 12:54:54 UTC, 0 replies.
- flink git commit: [FLINK-3660][hotfix] Add missing default value in ConfigConstants - posted by rm...@apache.org on 2016/10/14 13:19:14 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core [Forced Update!] - posted by se...@apache.org on 2016/10/14 13:45:43 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by se...@apache.org on 2016/10/14 13:45:44 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by se...@apache.org on 2016/10/14 13:45:45 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by se...@apache.org on 2016/10/14 13:45:46 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by se...@apache.org on 2016/10/14 13:45:47 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by se...@apache.org on 2016/10/14 13:45:48 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by se...@apache.org on 2016/10/14 13:45:49 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4516] leader election of resourcemanager - posted by se...@apache.org on 2016/10/14 13:45:50 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor - posted by se...@apache.org on 2016/10/14 13:45:51 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by se...@apache.org on 2016/10/14 13:45:52 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by se...@apache.org on 2016/10/14 13:45:53 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [hotfix] Add methods defined in the gateway to the ResourceManager and TaskExecutor - posted by se...@apache.org on 2016/10/14 13:45:54 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-4537] [cluster management] ResourceManager registration with JobManager - posted by se...@apache.org on 2016/10/14 13:45:55 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4537] rebase and refine - posted by se...@apache.org on 2016/10/14 13:45:56 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot - posted by se...@apache.org on 2016/10/14 13:45:57 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by se...@apache.org on 2016/10/14 13:45:58 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by se...@apache.org on 2016/10/14 13:45:59 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [hotfix] [taskmanager] Fixes TaskManager component creation at startup - posted by se...@apache.org on 2016/10/14 13:46:00 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by se...@apache.org on 2016/10/14 13:46:01 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by se...@apache.org on 2016/10/14 13:46:02 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by se...@apache.org on 2016/10/14 13:46:03 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Implement TaskManager component's startup - posted by se...@apache.org on 2016/10/14 13:46:04 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4535] rebase and refine - posted by se...@apache.org on 2016/10/14 13:46:05 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor - posted by se...@apache.org on 2016/10/14 13:46:06 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [hotfix] fix ResourceManagerGateway - posted by se...@apache.org on 2016/10/14 13:46:07 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails fast when endpoint is unreachable. - posted by se...@apache.org on 2016/10/14 13:46:08 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job submission & setting up the ExecutionGraph - posted by se...@apache.org on 2016/10/14 13:46:09 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by se...@apache.org on 2016/10/14 13:46:10 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by se...@apache.org on 2016/10/14 13:46:11 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by se...@apache.org on 2016/10/14 13:46:12 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses - posted by se...@apache.org on 2016/10/14 13:46:13 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [FLINK-4606] integrate features of old ResourceManager - posted by se...@apache.org on 2016/10/14 13:46:14 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-4406] [cluster management] Implement job master registration at resource manager - posted by se...@apache.org on 2016/10/14 13:46:15 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices - posted by se...@apache.org on 2016/10/14 13:46:16 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper - posted by se...@apache.org on 2016/10/14 13:46:17 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by se...@apache.org on 2016/10/14 13:46:18 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [hotfix] Fix failing JobManagerRunnerMockTest - posted by se...@apache.org on 2016/10/14 13:46:19 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by se...@apache.org on 2016/10/14 13:46:20 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by se...@apache.org on 2016/10/14 13:46:21 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager - posted by se...@apache.org on 2016/10/14 13:46:22 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-4735] [cluster management] Implements some job execution related RPC calls on the JobManager - posted by se...@apache.org on 2016/10/14 13:46:23 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4694] [rpc] Add termination futures to RpcEndpoint and RpcService - posted by se...@apache.org on 2016/10/14 13:46:24 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by se...@apache.org on 2016/10/14 13:46:25 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by se...@apache.org on 2016/10/14 13:46:26 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-4746] Make TaskManagerRuntimeInfo an interface - posted by se...@apache.org on 2016/10/14 13:46:27 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [FLINK-4516] update leadership information in ResourceManager - posted by se...@apache.org on 2016/10/14 13:46:28 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by se...@apache.org on 2016/10/14 13:46:29 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by se...@apache.org on 2016/10/14 13:46:30 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods - posted by se...@apache.org on 2016/10/14 13:46:31 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-4339] [cluster management] Implement Slot Pool core on JobManager side - posted by se...@apache.org on 2016/10/14 13:46:32 UTC, 0 replies.
- flink git commit: [FLINK-4564] [metrics] Configurable delimiter per reporter - posted by ch...@apache.org on 2016/10/14 13:49:39 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4667] Fix for using correct ZK namespace in Yarn deployment - posted by mx...@apache.org on 2016/10/14 14:38:38 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3932] Added ZK ACL configuration for secure cluster setup - posted by mx...@apache.org on 2016/10/14 14:38:39 UTC, 0 replies.
- [1/2] flink-web git commit: [FLINK-4593] Fix PageRank algorithm example - posted by gr...@apache.org on 2016/10/14 18:34:53 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild website - posted by gr...@apache.org on 2016/10/14 18:34:54 UTC, 0 replies.
- flink git commit: [FLINK-4667] add import for config entry - posted by mx...@apache.org on 2016/10/14 23:27:26 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4506] [DataSet] Fix documentation of CsvOutputFormat about incorrect default of allowNullValues - posted by fh...@apache.org on 2016/10/15 07:47:04 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4108] [scala] Respect ResultTypeQueryable for InputFormats. - posted by fh...@apache.org on 2016/10/15 07:47:05 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4771] [avro] Add support for compression to AvroOutputFormat. - posted by fh...@apache.org on 2016/10/15 07:47:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4506] [DataSet] Fix documentation of CsvOutputFormat about incorrect default of allowNullValues - posted by fh...@apache.org on 2016/10/15 07:47:32 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4108] [scala] Respect ResultTypeQueryable for InputFormats. - posted by fh...@apache.org on 2016/10/15 07:47:33 UTC, 0 replies.
- flink git commit: [FLINK-4489] [tm] Add TaskSlotTable to manage slot allocations for multiple job managers - posted by tr...@apache.org on 2016/10/15 09:32:33 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4343] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/10/16 08:46:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4343] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/10/16 08:46:47 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic [Forced Update!] - posted by tr...@apache.org on 2016/10/16 08:48:13 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/10/16 08:48:14 UTC, 0 replies.
- flink git commit: [FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper - posted by se...@apache.org on 2016/10/16 17:13:26 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] [tests] Migrate some test tasks to Java - posted by se...@apache.org on 2016/10/16 21:38:42 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4835] [cluster management] Add embedded version of the high-availability services - posted by se...@apache.org on 2016/10/16 21:38:43 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4836] [cluster management] Add flink mini cluster (part 1) - posted by se...@apache.org on 2016/10/16 21:38:44 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4689] [cluster management] Implement a simple slot provider for the new job manager - posted by se...@apache.org on 2016/10/16 21:38:45 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4351] [cluster management] JobManager handle TaskManager's registration - posted by se...@apache.org on 2016/10/16 21:38:46 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-3931] Implement Transport Encryption (SSL/TLS) - posted by mx...@apache.org on 2016/10/17 09:49:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3931] Implement Transport Encryption (SSL/TLS) - posted by mx...@apache.org on 2016/10/17 09:49:47 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Treat taskManager's rpc address and location separately - posted by tr...@apache.org on 2016/10/17 13:38:02 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4839] [cluster management] JobManager handle TaskManager's slot offering - posted by tr...@apache.org on 2016/10/17 13:38:03 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] [cluster management] Remove scala dependencies from MiniCluster.java - posted by se...@apache.org on 2016/10/17 18:16:50 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] Add a DefaultSlotManager similar to the TestingSlotManager - posted by se...@apache.org on 2016/10/17 18:16:51 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager and TaskManager services in MiniCluster - posted by se...@apache.org on 2016/10/17 18:16:52 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager in MiniCluster - posted by se...@apache.org on 2016/10/17 18:16:53 UTC, 0 replies.
- flink git commit: [FLINK-4723] [kafka] Unify committed offsets to Kafka to be next record to process - posted by tz...@apache.org on 2016/10/18 03:45:50 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4829] snapshot accumulators on a best-effort basis - posted by mx...@apache.org on 2016/10/18 13:57:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4829] protect user accumulators against concurrent updates - posted by mx...@apache.org on 2016/10/18 13:57:42 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4829] protect user accumulators against concurrent updates - posted by mx...@apache.org on 2016/10/18 14:05:31 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4829] snapshot accumulators on a best-effort basis - posted by mx...@apache.org on 2016/10/18 14:05:32 UTC, 0 replies.
- flink git commit: [FLINK-4727] [kafka] Set missing initial offset states with starting KafkaConsumer position - posted by tz...@apache.org on 2016/10/19 01:54:14 UTC, 0 replies.
- flink git commit: [FLINK-4619] Answer with JobResultFailure if savepoint restore fails during submission - posted by uc...@apache.org on 2016/10/19 09:43:14 UTC, 1 replies.
- flink git commit: [FLINK-4510] [checkpoint] Always create CheckpointCoordinator - posted by uc...@apache.org on 2016/10/19 11:50:19 UTC, 1 replies.
- flink git commit: [hotfix] Fix JobSubmitTest - posted by uc...@apache.org on 2016/10/19 13:21:31 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4792] [docs] Update ML quickstart import - posted by gr...@apache.org on 2016/10/19 14:29:27 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4652] [streaming connectors] Automatically refresh AWS credentials - posted by gr...@apache.org on 2016/10/19 14:29:28 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4586] [core] Broken AverageAccumulator - posted by gr...@apache.org on 2016/10/19 14:29:29 UTC, 0 replies.
- flink git commit: [FLINK-4586] [core] Broken AverageAccumulator - posted by gr...@apache.org on 2016/10/19 15:19:42 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-4842] Introduce test to enforce order of operator / udf lifecycles - posted by al...@apache.org on 2016/10/20 14:15:19 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:20 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:21 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:22 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:23 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:24 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:25 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-4844] Partitionable Raw Keyed/Operator State - posted by al...@apache.org on 2016/10/20 14:15:26 UTC, 0 replies.
- flink git commit: [FLINK-4857] Remove throws clause from ZooKeeperUtils functions - posted by tr...@apache.org on 2016/10/20 17:44:19 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4804] [py] Fix first() failing when applied to groupings - posted by ch...@apache.org on 2016/10/21 09:03:45 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4805] [py] Fix implicit type conversion in CsvStringify - posted by ch...@apache.org on 2016/10/21 09:03:46 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4794] [py] Fix partition_by_hash() implicit key usage - posted by ch...@apache.org on 2016/10/21 09:03:47 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4795] [py] Fix CsvStringify for nested tuples - posted by ch...@apache.org on 2016/10/21 09:03:48 UTC, 0 replies.
- flink git commit: [FLINK-4784] Unique MetricQueryService actor names - posted by ch...@apache.org on 2016/10/21 10:04:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4129] [gelly] HITSAlgorithm should test for element-wise convergence - posted by va...@apache.org on 2016/10/21 10:34:15 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3888] allow registering a custom convergence criterion in delta iterations - posted by va...@apache.org on 2016/10/21 10:34:16 UTC, 0 replies.
- flink git commit: [FLINK-4780] Make GraphiteReporter protocol configurable - posted by ch...@apache.org on 2016/10/21 11:26:07 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4775] [metrics] Simplify MetricStore access - posted by ch...@apache.org on 2016/10/21 11:42:53 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4772] [metrics] Store metrics as strings in MetricStore - posted by ch...@apache.org on 2016/10/21 11:42:54 UTC, 0 replies.
- flink git commit: [FLINK-4833] properly log exceptions in CountMinHeavyHitter - posted by mx...@apache.org on 2016/10/21 11:57:38 UTC, 0 replies.
- flink git commit: [FLINK-4881][docker] remove shared volume for configuration - posted by mx...@apache.org on 2016/10/21 12:20:51 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction [Forced Update!] - posted by tr...@apache.org on 2016/10/21 12:21:41 UTC, 0 replies.
- flink git commit: [FLINK-4878][tests] Log test failure cause on INFO level - posted by rm...@apache.org on 2016/10/21 12:21:41 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/10/21 12:21:42 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [hotfix] Add methods defined in the gateway to the ResourceManager and TaskExecutor - posted by tr...@apache.org on 2016/10/21 12:21:43 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot - posted by tr...@apache.org on 2016/10/21 12:21:44 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [hotfix] fix ResourceManagerGateway - posted by tr...@apache.org on 2016/10/21 12:21:45 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4535] rebase and refine - posted by tr...@apache.org on 2016/10/21 12:21:46 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4537] rebase and refine - posted by tr...@apache.org on 2016/10/21 12:21:47 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor - posted by tr...@apache.org on 2016/10/21 12:21:48 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by tr...@apache.org on 2016/10/21 12:21:49 UTC, 0 replies.
- [10/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/10/21 12:21:50 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails fast when endpoint is unreachable. - posted by tr...@apache.org on 2016/10/21 12:21:51 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tr...@apache.org on 2016/10/21 12:21:52 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by tr...@apache.org on 2016/10/21 12:21:53 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Implement TaskManager component's startup - posted by tr...@apache.org on 2016/10/21 12:21:54 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/10/21 12:21:55 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/10/21 12:21:56 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4606] integrate features of old ResourceManager - posted by tr...@apache.org on 2016/10/21 12:21:57 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses - posted by tr...@apache.org on 2016/10/21 12:21:58 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager - posted by tr...@apache.org on 2016/10/21 12:21:59 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices - posted by tr...@apache.org on 2016/10/21 12:22:00 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4406] [cluster management] Implement job master registration at resource manager - posted by tr...@apache.org on 2016/10/21 12:22:01 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper - posted by tr...@apache.org on 2016/10/21 12:22:02 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4694] [rpc] Add termination futures to RpcEndpoint and RpcService - posted by tr...@apache.org on 2016/10/21 12:22:03 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by tr...@apache.org on 2016/10/21 12:22:04 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [hotfix] Fix failing JobManagerRunnerMockTest - posted by tr...@apache.org on 2016/10/21 12:22:05 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by tr...@apache.org on 2016/10/21 12:22:06 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager - posted by tr...@apache.org on 2016/10/21 12:22:07 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by tr...@apache.org on 2016/10/21 12:22:08 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager - posted by tr...@apache.org on 2016/10/21 12:22:09 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4746] Make TaskManagerRuntimeInfo an interface - posted by tr...@apache.org on 2016/10/21 12:22:10 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4516] update leadership information in ResourceManager - posted by tr...@apache.org on 2016/10/21 12:22:11 UTC, 0 replies.
- [32/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/10/21 12:22:12 UTC, 0 replies.
- [33/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/10/21 12:22:13 UTC, 0 replies.
- [34/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/10/21 12:22:14 UTC, 0 replies.
- [35/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/10/21 12:22:15 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-4339] [cluster management] Implement Slot Pool core on JobManager side - posted by tr...@apache.org on 2016/10/21 12:22:16 UTC, 0 replies.
- [37/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/10/21 12:22:17 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/10/21 12:22:18 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic - posted by tr...@apache.org on 2016/10/21 12:22:19 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [hotfix] [tests] Migrate some test tasks to Java - posted by tr...@apache.org on 2016/10/21 12:22:20 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-4835] [cluster management] Add embedded version of the high-availability services - posted by tr...@apache.org on 2016/10/21 12:22:21 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4836] [cluster management] Add flink mini cluster (part 1) - posted by tr...@apache.org on 2016/10/21 12:22:22 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4351] [cluster management] JobManager handle TaskManager's registration - posted by tr...@apache.org on 2016/10/21 12:22:23 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [hotfix] Treat taskManager's rpc address and location separately - posted by tr...@apache.org on 2016/10/21 12:22:24 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-4839] [cluster management] JobManager handle TaskManager's slot offering - posted by tr...@apache.org on 2016/10/21 12:22:25 UTC, 0 replies.
- [46/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/10/21 12:22:26 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [hotfix] Add a DefaultSlotManager similar to the TestingSlotManager - posted by tr...@apache.org on 2016/10/21 12:22:27 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [hotfix] [cluster management] Remove scala dependencies from MiniCluster.java - posted by tr...@apache.org on 2016/10/21 12:22:28 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager and TaskManager services in MiniCluster - posted by tr...@apache.org on 2016/10/21 12:22:29 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager in MiniCluster - posted by tr...@apache.org on 2016/10/21 12:22:30 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4836] [cluster management] Start ResourceManager in MiniCluster [Forced Update!] - posted by tr...@apache.org on 2016/10/21 12:46:56 UTC, 0 replies.
- [2/2] flink git commit: Rebasing fixes on latest master - posted by tr...@apache.org on 2016/10/21 12:46:57 UTC, 0 replies.
- flink git commit: [FLINK-4852] Remove Non-Multiplexing StreamRecordSerializer - posted by al...@apache.org on 2016/10/21 16:22:54 UTC, 0 replies.
- [01/11] flink git commit: [FLINK-4877] Use OperatorTestHarness and TestProcessingTimeService in Kafka Tests - posted by al...@apache.org on 2016/10/21 17:14:16 UTC, 0 replies.
- [02/11] flink git commit: [FLINK-4877] Refactor OperatorTestHarness to always use TestProcessingTimeService - posted by al...@apache.org on 2016/10/21 17:14:17 UTC, 0 replies.
- [03/11] flink git commit: [FLINK-4877] Refactor OperatorTestHarness to always use TestProcessingTimeService - posted by al...@apache.org on 2016/10/21 17:14:18 UTC, 0 replies.
- [04/11] flink git commit: [FLINK-4877] Rename TimeServiceProvider to ProcessingTimeService - posted by al...@apache.org on 2016/10/21 17:14:19 UTC, 0 replies.
- [05/11] flink git commit: [FLINK-4877] Rename TimeServiceProvider to ProcessingTimeService - posted by al...@apache.org on 2016/10/21 17:14:20 UTC, 0 replies.
- [06/11] flink git commit: [FLINK-3674] Add an interface for Time aware User Functions - posted by al...@apache.org on 2016/10/21 17:14:21 UTC, 0 replies.
- [07/11] flink git commit: [FLINK-3674] Add an interface for Time aware User Functions - posted by al...@apache.org on 2016/10/21 17:14:22 UTC, 0 replies.
- [08/11] flink git commit: [FLINK-3674] Add an interface for Time aware User Functions - posted by al...@apache.org on 2016/10/21 17:14:23 UTC, 0 replies.
- [09/11] flink git commit: [FLINK-4877] Rename Triggerable to ProcessingTimeCallback - posted by al...@apache.org on 2016/10/21 17:14:24 UTC, 0 replies.
- [10/11] flink git commit: [FLINK-4877] Rename ProcessingTimeCallback.trigger() to onProcessingTime() - posted by al...@apache.org on 2016/10/21 17:14:25 UTC, 0 replies.
- [11/11] flink git commit: [FLINK-4877] Refactor Operator TestHarnesses to use Common Base Class - posted by al...@apache.org on 2016/10/21 17:14:26 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4581] [table] Fix Table API throwing "No suitable driver found for jdbc:calcite" - posted by fh...@apache.org on 2016/10/22 08:10:31 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4838] [docs] Remove STREAM keyword in StreamSQLExample - posted by fh...@apache.org on 2016/10/22 08:10:32 UTC, 0 replies.
- flink git commit: [FLINK-4581] [table] Fix Table API throwing "No suitable driver found for jdbc:calcite" - posted by fh...@apache.org on 2016/10/22 08:25:20 UTC, 0 replies.
- flink git commit: [FLINK-4875] [metrics] Use correct operator name - posted by ch...@apache.org on 2016/10/22 09:13:51 UTC, 1 replies.
- flink git commit: [FLINK-4882] [flip-6] Remove exceptions from HighAvailabilityServices where not necessary - posted by tr...@apache.org on 2016/10/23 09:10:00 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4853] [rm] Clean up job manager registration at the resource manager - posted by tr...@apache.org on 2016/10/23 09:18:15 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4851] [rm] Introduce FatalErrorHandler and MetricRegistry to RM - posted by tr...@apache.org on 2016/10/23 09:18:16 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4851] [rm] Introduce FatalErrorHandler and MetricRegistry to RM - posted by tr...@apache.org on 2016/10/23 09:18:17 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4847] Let RpcEndpoint.start/shutDown throw exceptions - posted by tr...@apache.org on 2016/10/23 09:18:18 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4871] [mini cluster] Add memory calculation for TaskManagers to MiniCluster - posted by tr...@apache.org on 2016/10/23 09:18:19 UTC, 0 replies.
- flink git commit: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to Enforce Implementation - posted by al...@apache.org on 2016/10/24 07:12:38 UTC, 0 replies.
- flink git commit: [hotfix] Force Non-Parallel for Non-Keyed CEP Operators - posted by al...@apache.org on 2016/10/24 08:30:52 UTC, 0 replies.
- flink git commit: [FLINK-4891] Remove flink-contrib/flink-operator-stats module - posted by uc...@apache.org on 2016/10/24 09:08:51 UTC, 0 replies.
- flink git commit: [FLINK-4843] Test for FsCheckpointStateOutputStream::getPos() - posted by uc...@apache.org on 2016/10/24 09:12:22 UTC, 0 replies.
- flink git commit: [FLINK-4879] Make KafkaTableSource public - posted by rm...@apache.org on 2016/10/24 13:48:50 UTC, 0 replies.
- flink git commit: [FLINK-4862] fix Timer register in ContinuousEventTimeTrigger - posted by mx...@apache.org on 2016/10/24 13:49:41 UTC, 1 replies.
- flink git commit: [FLINK-4824] [client] CliFrontend shows misleading error message - posted by gr...@apache.org on 2016/10/24 15:18:42 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4204] [gelly] Clean up gelly-examples - posted by gr...@apache.org on 2016/10/24 16:32:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4204] [gelly] Clean up gelly-examples - posted by gr...@apache.org on 2016/10/24 16:32:47 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4773] [metrics] [refactor] Introduce OperatorIOMetricGroup - posted by ch...@apache.org on 2016/10/25 10:03:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4773] [metrics] [refactor] Rename IOMetricGroup to TaskIOMetricGroup - posted by ch...@apache.org on 2016/10/25 10:03:42 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4298] [storm compatibility] Add proper repository for Closure dependencies. - posted by se...@apache.org on 2016/10/25 12:39:56 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4218] [checkpoints] Do not fail checkpoints when state size cannot be determined - posted by se...@apache.org on 2016/10/25 12:39:57 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4639] [table] Introduce CalciteConfig to make Calcite features more pluggable. - posted by fh...@apache.org on 2016/10/25 14:15:36 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4762] [table] Use plural in time interval units - posted by fh...@apache.org on 2016/10/25 14:15:37 UTC, 0 replies.
- flink git commit: [hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 tests - posted by tz...@apache.org on 2016/10/26 07:47:59 UTC, 0 replies.
- flink git commit: [FLINK-3950] Implement MeterView - posted by ch...@apache.org on 2016/10/26 10:17:04 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [kafka consumer] Improve logging For Kafka Consumer 0.8 shutdown - posted by se...@apache.org on 2016/10/26 10:36:43 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] Fix unnecessary stream wrapping for Netty Error Message Frames - posted by se...@apache.org on 2016/10/26 10:36:44 UTC, 0 replies.
- flink git commit: [hotfix] [gelly] Driver usage and configuration - posted by gr...@apache.org on 2016/10/26 18:53:10 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4691] [table] Add group-windows for streaming tables to Table API. - posted by fh...@apache.org on 2016/10/26 21:11:23 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4691] [table] Add group-windows for streaming tables to Table API. - posted by fh...@apache.org on 2016/10/26 21:11:24 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4691] [table] Add group-windows for streaming tables to Table API. - posted by fh...@apache.org on 2016/10/26 21:11:25 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4691] [table] Add group-windows for streaming tables to Table API. - posted by fh...@apache.org on 2016/10/26 21:11:26 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4691] [table] Rework window property extraction. - posted by fh...@apache.org on 2016/10/26 21:11:27 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-4907] Add State Reshuffling in Operator Test Harness - posted by al...@apache.org on 2016/10/26 21:36:47 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-4907] Add Num-Subtasks/Subtask-Index Parameter to Operator Test Harnesses - posted by al...@apache.org on 2016/10/26 21:36:48 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-4892] Snapshot TimerService using Key-Grouped State - posted by al...@apache.org on 2016/10/26 21:36:49 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-4924] Simplify Operator Test Harness Constructors - posted by al...@apache.org on 2016/10/26 21:36:50 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-4892] Re-enable RescalingITCase - posted by al...@apache.org on 2016/10/26 21:36:51 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-4892] Add Key-Group Ranges Test in HeapInternalTimerServiceTest - posted by al...@apache.org on 2016/10/26 21:36:52 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-4892] Change TestHarness.snapshot() to return OperatorStateHandles - posted by al...@apache.org on 2016/10/26 21:36:53 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-4892] Parameterize HeapInternalTimerServiceTest - posted by al...@apache.org on 2016/10/26 21:36:54 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-4907] Add Test for Timers/State Provided by AbstractStreamOperator - posted by al...@apache.org on 2016/10/26 21:36:55 UTC, 0 replies.
- flink git commit: [FLINK-4283] Use new InfiniteDelayRestartStrategy instead of FixedDelayRestartStrategy to avoid blocking threads - posted by tr...@apache.org on 2016/10/26 22:46:53 UTC, 0 replies.
- flink git commit: [FLINK-4579] [RocksDB backend] Add StateBackendFactory and config shortcut for the RocksDB Backend - posted by se...@apache.org on 2016/10/27 09:06:17 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4913][yarn] include user jars in system class loader - posted by mx...@apache.org on 2016/10/27 12:22:23 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4800] Introduce the TimestampedFileInputSplit for Continuous File Processing - posted by mx...@apache.org on 2016/10/27 12:22:24 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4800] Introduce the TimestampedFileInputSplit for Continuous File Processing - posted by mx...@apache.org on 2016/10/27 12:22:25 UTC, 0 replies.
- flink git commit: [FLINK-4913][yarn] include user jars in system class loader - posted by mx...@apache.org on 2016/10/27 12:30:21 UTC, 0 replies.
- flink git commit: [FLINK-4903] [futures] Introduce synchronous future operations - posted by tr...@apache.org on 2016/10/27 13:42:09 UTC, 0 replies.
- flink git commit: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a quarantined actor system and JVM down - posted by tr...@apache.org on 2016/10/27 13:58:38 UTC, 0 replies.
- flink git commit: [FLINK-4894] [network] Don't request buffer after writing to partition - posted by uc...@apache.org on 2016/10/27 15:36:36 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-4715] Remove superfluous test - posted by uc...@apache.org on 2016/10/27 15:41:26 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4715] Fail TaskManager with fatal error if task cancellation is stuck - posted by uc...@apache.org on 2016/10/27 15:41:27 UTC, 0 replies.
- flink git commit: [FLINK-4715] Fail TaskManager with fatal error if task cancellation is stuck - posted by uc...@apache.org on 2016/10/27 15:41:58 UTC, 0 replies.
- flink git commit: [FLINK-4889] [InstanceManager] Remove ActorRef dependency from InstanceManager - posted by tr...@apache.org on 2016/10/27 16:52:24 UTC, 0 replies.
- flink git commit: Revert "[FLINK-4894] [network] Don't request buffer after writing to partition" - posted by se...@apache.org on 2016/10/27 18:16:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4378] Allow Setting Custom Configuration in BucketingSink - posted by al...@apache.org on 2016/10/28 08:59:00 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4378] Allow Setting Custom Configuration in RollingSink - posted by al...@apache.org on 2016/10/28 08:59:01 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4787] [runtime-web] Add JobCancellationWithSavepointHandlers - posted by uc...@apache.org on 2016/10/28 09:04:28 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4787] [runtime-web] Return generic HttpResponse in RequestHandler - posted by uc...@apache.org on 2016/10/28 09:04:29 UTC, 0 replies.
- flink git commit: [FLINK-4925] [metrics] Integrate meters into IOMetricGroups - posted by ch...@apache.org on 2016/10/28 09:11:24 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Add documentation for TaskManager's registration configuration parameters - posted by tr...@apache.org on 2016/10/28 10:23:05 UTC, 0 replies.
- flink git commit: [FLINK-4894] [network] Fix hasData() and correctly clear buffer state - posted by uc...@apache.org on 2016/10/28 10:52:46 UTC, 0 replies.
- flink git commit: [FLINK-4631] Prevent NPE in OneInputStreamTask - posted by ch...@apache.org on 2016/10/28 11:35:18 UTC, 0 replies.
- flink git commit: [FLINK-4544[ Refactor JM/TM metrics - posted by ch...@apache.org on 2016/10/28 11:42:22 UTC, 0 replies.
- flink git commit: [FLINK-4923] [metrics] Expose Task's input/output buffer queue lengths and bufferPool usage as a metrics - posted by se...@apache.org on 2016/10/30 16:44:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4245] JMXReporter exposes all defined variables - posted by ch...@apache.org on 2016/10/31 12:16:11 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [metrics] Make JmxMeter class static - posted by ch...@apache.org on 2016/10/31 12:16:12 UTC, 0 replies.
- flink git commit: [hotfix] Improved test stability of RescalingITCase - posted by uc...@apache.org on 2016/10/31 13:03:06 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4972] Fix CoordinatorShutdownTest - posted by ch...@apache.org on 2016/10/31 15:08:29 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4733] Reuse operator IO metrics for task - posted by ch...@apache.org on 2016/10/31 15:08:30 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4733] Port TaskManager metrics - posted by ch...@apache.org on 2016/10/31 15:08:31 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4733] Port Task IO metrics - posted by ch...@apache.org on 2016/10/31 15:08:32 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4733] Port Task IO metrics - posted by ch...@apache.org on 2016/10/31 15:08:33 UTC, 0 replies.
- flink git commit: [hotfix] Fixes the TimestampedInputSplit.EOS comparison. - posted by mx...@apache.org on 2016/10/31 18:08:52 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4933] [exec graph] Don't let the EG fail in case of a failing scheduleOrUpdateConsumers call - posted by se...@apache.org on 2016/10/31 18:17:09 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4894] [network] Don't request buffer after writing to partition - posted by se...@apache.org on 2016/10/31 18:17:10 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4659] [core] Closed the jassConfStream object to prevent resource leaks - posted by se...@apache.org on 2016/10/31 18:17:11 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4932] [distributed coordination] Failing in state RESTARTING only fails terminally if no more restarts are possible - posted by se...@apache.org on 2016/10/31 18:17:12 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4932] [distributed coordination] Failing in state RESTARTING only fails terminally if no more restarts are possible - posted by se...@apache.org on 2016/10/31 18:26:27 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4933] [exec graph] Don't let the EG fail in case of a failing scheduleOrUpdateConsumers call - posted by se...@apache.org on 2016/10/31 18:26:28 UTC, 0 replies.