You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 00:55:21 UTC, 16 replies.
- [GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/01 00:59:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4347) Implement SlotManager core - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 00:59:21 UTC, 0 replies.
- [GitHub] flink issue #2427: [FLINK-4516] [cluster management]leader election of resou... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/01 00:59:50 UTC, 0 replies.
- [GitHub] flink pull request #2427: [FLINK-4516] [cluster management]leader election o... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/01 00:59:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-4516) ResourceManager leadership election - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 01:00:39 UTC, 1 replies.
- [GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/01 01:24:02 UTC, 13 replies.
- [jira] [Commented] (FLINK-4490) Decouple Slot and Instance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 01:24:22 UTC, 17 replies.
- [GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a... - posted by liuyuzhong <gi...@git.apache.org> on 2016/09/01 01:47:08 UTC, 2 replies.
- [jira] [Commented] (FLINK-4450) update storm version to 1.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 01:47:20 UTC, 6 replies.
- [GitHub] flink pull request #2400: [FLINK-4363] Implement TaskManager basic startup o... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/09/01 02:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 02:06:20 UTC, 0 replies.
- [GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-... - posted by liuyuzhong <gi...@git.apache.org> on 2016/09/01 05:03:29 UTC, 3 replies.
- [jira] [Created] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/01 05:04:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/01 05:05:21 UTC, 0 replies.
- [GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/01 06:25:12 UTC, 11 replies.
- [jira] [Created] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 06:55:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 06:57:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4537) ResourceManager registration with JobManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 07:02:20 UTC, 0 replies.
- [GitHub] flink pull request #2452: Flink-4450 add a new module "flink-apache-storm" t... - posted by liuyuzhong <gi...@git.apache.org> on 2016/09/01 07:25:31 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 07:59:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4381) Refactor State to Prepare For Key-Group State Backends - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:00:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3761) Refactor State Backends/Make Keyed State Key-Group Aware - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:00:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:00:38 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:01:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:09:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 08:09:20 UTC, 0 replies.
- [GitHub] flink issue #2446: [hotfix] Fixes unstable ContinuousFileMonitoringTest. - posted by aljoscha <gi...@git.apache.org> on 2016/09/01 08:10:34 UTC, 1 replies.
- [GitHub] flink pull request #2446: [hotfix] Fixes unstable ContinuousFileMonitoringTe... - posted by asfgit <gi...@git.apache.org> on 2016/09/01 08:11:34 UTC, 0 replies.
- [GitHub] flink pull request #2453: [FLINK-4510] [checkpoint] Always create Checkpoint... - posted by wuchong <gi...@git.apache.org> on 2016/09/01 08:22:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 08:22:22 UTC, 4 replies.
- [GitHub] flink pull request #2454: [FLINK-4546] [table] Remove STREAM keyword in Stre... - posted by wuchong <gi...@git.apache.org> on 2016/09/01 08:36:02 UTC, 3 replies.
- [jira] [Commented] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 08:36:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4546) Remove STREAM keyword in Stream SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/01 08:36:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4348) Implement slot allocation protocol with TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 08:49:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4449) Heartbeat Manager integration with JobMaster / TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 08:53:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 08:53:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4549) Test and document implicitly supported SQL functions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 08:55:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4549) Test and document implicitly supported SQL functions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 08:55:21 UTC, 1 replies.
- [GitHub] flink pull request #2455: [FLINK-4547] [cluster management] Return same obje... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/01 08:59:07 UTC, 3 replies.
- [jira] [Commented] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 08:59:20 UTC, 6 replies.
- [jira] [Created] (FLINK-4550) Clearly define SQL operator table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:04:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4449) Heartbeat Manager integration with TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 09:05:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4551) Heartbeat Manager integration with JobMaster - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 09:05:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4458) Remove ForkableFlinkMiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/01 09:08:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/01 09:11:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/01 09:13:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4552) Refactor WindowOperator/Trigger Tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 09:20:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4542) Add support for MULTISET type and operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:22:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/01 09:42:20 UTC, 5 replies.
- [jira] [Updated] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/01 09:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4553) Add support for table sampling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:44:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4554) Add support for array types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 09:49:20 UTC, 0 replies.
- [GitHub] flink pull request #1988: [FLINK-3761] Introduction of key groups - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 09:50:30 UTC, 0 replies.
- [GitHub] flink issue #1988: [FLINK-3761] Introduction of key groups - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 09:50:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-3761) Refactor State Backends/Make Keyed State Key-Group Aware - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 09:51:21 UTC, 1 replies.
- [GitHub] flink issue #2438: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and Re... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 09:52:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 09:53:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/01 10:05:20 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-4536) Possible thread leak in Task Manager - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/01 10:07:21 UTC, 6 replies.
- [GitHub] flink pull request #2438: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 10:15:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/01 10:16:20 UTC, 0 replies.
- [GitHub] flink issue #2452: Flink-4450 add a new module "flink-apache-storm" to suppo... - posted by liuyuzhong <gi...@git.apache.org> on 2016/09/01 10:23:07 UTC, 1 replies.
- [GitHub] flink issue #2436: [FLINK-4528] [rpc] Marks main thread execution methods in... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 10:29:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-4528) Mark runAsync and scheduleAsync methods protected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 10:29:20 UTC, 1 replies.
- [GitHub] flink pull request #2436: [FLINK-4528] [rpc] Marks main thread execution met... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 10:31:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-4528) Mark runAsync and scheduleAsync methods protected - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/01 10:31:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/09/01 11:00:30 UTC, 1 replies.
- [jira] [Created] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/01 11:02:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4537) ResourceManager registration with JobManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/01 11:15:21 UTC, 1 replies.
- [GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/01 11:27:24 UTC, 25 replies.
- [jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 11:28:20 UTC, 38 replies.
- [GitHub] flink issue #2455: [FLINK-4547] [cluster management] Return same object when... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 11:51:59 UTC, 1 replies.
- [GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 11:55:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-4245) Metric naming improvements - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 11:55:20 UTC, 2 replies.
- [GitHub] flink pull request #2421: FLINK-4482 numUnsuccessfulCheckpointsTriggers is a... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 11:55:31 UTC, 3 replies.
- [jira] [Commented] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 11:56:20 UTC, 6 replies.
- [GitHub] flink issue #2421: FLINK-4482 numUnsuccessfulCheckpointsTriggers is accessed... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 12:06:26 UTC, 1 replies.
- [GitHub] flink issue #2428: [FLINK-4517] scala code refactoring - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 12:11:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4517) scala code refactoring - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 12:11:20 UTC, 0 replies.
- [GitHub] flink pull request #2448: [FLINK-3030][web frontend] Enhance dashboard to sh... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 12:18:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 12:19:20 UTC, 7 replies.
- [GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 12:21:07 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4538) Implement slot allocation protocol with JobMaster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/01 12:29:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4348) Implement slot allocation protocol with TaskExecutor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/01 12:32:20 UTC, 9 replies.
- [jira] [Updated] (FLINK-3930) Implement Service-Level Authorization - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/01 12:45:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 12:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/01 12:53:20 UTC, 0 replies.
- [GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl... - posted by rmetzger <gi...@git.apache.org> on 2016/09/01 12:57:21 UTC, 13 replies.
- [jira] [Commented] (FLINK-3930) Implement Service-Level Authorization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 12:58:20 UTC, 37 replies.
- [GitHub] flink pull request #2425: FLINK-3930 Added shared secret based authorization... - posted by rmetzger <gi...@git.apache.org> on 2016/09/01 13:07:04 UTC, 23 replies.
- [GitHub] flink pull request #2449: [FLINK-4455] [FLINK-4424] [networkenv] Make Networ... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 13:32:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 13:33:20 UTC, 12 replies.
- [GitHub] flink issue #2449: [FLINK-4455] [FLINK-4424] [networkenv] Make NetworkEnviro... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 13:43:52 UTC, 5 replies.
- [jira] [Created] (FLINK-4557) Table API Stream Aggregations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 13:55:20 UTC, 0 replies.
- [GitHub] flink issue #2453: [FLINK-4510] [checkpoint] Always create CheckpointCoordin... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 14:04:05 UTC, 3 replies.
- [GitHub] flink pull request #2450: [FLINK-4458] Replace ForkableFlinkMiniCluster by L... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 14:10:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-4458) Remove ForkableFlinkMiniCluster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 14:11:20 UTC, 11 replies.
- [GitHub] flink issue #2450: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFli... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 14:19:24 UTC, 8 replies.
- [GitHub] flink pull request #2456: [FLINK-4456] Replace ActorGateway in Task and Runt... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/01 14:55:58 UTC, 7 replies.
- [jira] [Commented] (FLINK-4456) Replace ActorGateway in Task by interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 14:56:21 UTC, 10 replies.
- [GitHub] flink issue #2424: [FLINK-4459][Scheduler] Introduce SlotProvider for Schedu... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/01 15:05:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-4459) Introduce SlotProvider for Scheduler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 15:06:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/09/01 15:23:21 UTC, 13 replies.
- [jira] [Assigned] (FLINK-4549) Test and document implicitly supported SQL functions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/01 15:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4558) Add support for synchronizing streams - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/09/01 16:24:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4461) Ensure all the classes are tagged with suitable annotations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/09/01 16:32:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4558) Add support for synchronizing streams - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/09/01 16:47:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/01 17:08:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/01 17:08:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/09/01 17:11:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/09/01 17:21:20 UTC, 36 replies.
- [jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/01 18:12:20 UTC, 0 replies.
- [GitHub] flink pull request #2457: [FLINK-3680] Remove "(not set)" text in the Job Pl... - posted by mushketyk <gi...@git.apache.org> on 2016/09/01 19:35:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/01 19:35:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/01 20:11:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/01 20:11:20 UTC, 9 replies.
- [jira] [Created] (FLINK-4560) enforcer java version as 1.7 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 02:38:20 UTC, 0 replies.
- [GitHub] flink pull request #2458: [FLINK-4560] enforcer java version as 1.7 - posted by shijinkui <gi...@git.apache.org> on 2016/09/02 02:49:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-4560) enforcer java version as 1.7 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 02:50:21 UTC, 9 replies.
- [jira] [Created] (FLINK-4561) replace all the scala version as a property - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 03:12:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4561) replace all the scala version as a `scala.binary.version` property - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 03:13:20 UTC, 0 replies.
- [GitHub] flink pull request #2459: [FLINK-4561] replace all the scala version as a `s... - posted by shijinkui <gi...@git.apache.org> on 2016/09/02 03:17:19 UTC, 1 replies.
- [jira] [Commented] (FLINK-4561) replace all the scala version as a `scala.binary.version` property - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 03:17:20 UTC, 9 replies.
- [jira] [Updated] (FLINK-4562) table examples make an divided module in flink-examples - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 06:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4562) table example make an divided module in flink-examples - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/02 06:50:20 UTC, 0 replies.
- [GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink... - posted by gheo21 <gi...@git.apache.org> on 2016/09/02 06:59:03 UTC, 6 replies.
- [jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 06:59:20 UTC, 6 replies.
- [GitHub] flink pull request #2460: [FLINK-4562] table examples make an divided module... - posted by shijinkui <gi...@git.apache.org> on 2016/09/02 07:01:19 UTC, 4 replies.
- [jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 07:01:20 UTC, 9 replies.
- [GitHub] flink issue #2459: [FLINK-4561] replace all the scala version as a `scala.bi... - posted by chiwanpark <gi...@git.apache.org> on 2016/09/02 07:08:58 UTC, 7 replies.
- [jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/02 07:20:20 UTC, 7 replies.
- [GitHub] flink issue #2447: [FLINK-4490] [distributed coordination] Decouple the JobM... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/02 07:23:02 UTC, 3 replies.
- [GitHub] flink pull request #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint ... - posted by aljoscha <gi...@git.apache.org> on 2016/09/02 08:28:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 08:29:20 UTC, 0 replies.
- [GitHub] flink issue #2445: [FLINK-4544] Refactor old CPU metric initialization - posted by zentol <gi...@git.apache.org> on 2016/09/02 08:51:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 08:52:20 UTC, 3 replies.
- [GitHub] flink issue #2152: [FLINK-3920] Distributed Linear Algebra: block-based matr... - posted by chobeat <gi...@git.apache.org> on 2016/09/02 08:56:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 08:56:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/02 09:03:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/02 09:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4564) [metrics] Delimiter should be configured per reporter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/02 09:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4565) Support for SQL IN operator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/02 09:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 09:49:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 09:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4568) Replace ActorGateway in WebRuntimeMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/02 09:50:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4348) Implement slot allocation protocol with TaskExecutor - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 09:56:20 UTC, 0 replies.
- [GitHub] flink pull request #2461: [FLINK-4505][Cluster Management] Implement TaskMan... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/09/02 10:07:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-4505) Implement TaskManagerFactory to bring up TaskManager for different modes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 10:08:21 UTC, 11 replies.
- [jira] [Created] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/02 10:21:21 UTC, 0 replies.
- [GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta... - posted by mxm <gi...@git.apache.org> on 2016/09/02 10:21:56 UTC, 22 replies.
- [jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 10:22:20 UTC, 46 replies.
- [jira] [Commented] (FLINK-2312) Random Splits - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/02 10:28:20 UTC, 1 replies.
- [GitHub] flink issue #2461: [FLINK-4505][Cluster Management] Implement TaskManagerFac... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/09/02 10:48:09 UTC, 11 replies.
- [GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup... - posted by mxm <gi...@git.apache.org> on 2016/09/02 12:18:22 UTC, 14 replies.
- [GitHub] flink issue #2451: [FLINK-4535] [cluster management] resourceManager process... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/02 12:43:39 UTC, 3 replies.
- [jira] [Created] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 12:44:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 12:47:21 UTC, 5 replies.
- [GitHub] flink pull request #2462: [FLINK-4570] revert Scalastyle version to 0.5.0 - posted by mxm <gi...@git.apache.org> on 2016/09/02 12:55:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 12:58:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 12:58:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/02 13:06:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/02 13:07:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4489) Implement TaskManager's SlotAllocationTable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/02 13:27:20 UTC, 1 replies.
- [GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo... - posted by mxm <gi...@git.apache.org> on 2016/09/02 14:30:31 UTC, 28 replies.
- [jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 14:31:21 UTC, 32 replies.
- [GitHub] flink issue #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allocation ... - posted by mxm <gi...@git.apache.org> on 2016/09/02 14:32:51 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4522) Gelly link broken in homepage - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/02 14:42:20 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 14:55:20 UTC, 1 replies.
- [GitHub] flink pull request #2464: [FLINK-4522] [docs] Gelly link broken in homepage - posted by greghogan <gi...@git.apache.org> on 2016/09/02 14:55:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-4522) Gelly link broken in homepage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 14:56:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4536) Possible thread leak in Task Manager - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/09/02 14:57:20 UTC, 0 replies.
- [GitHub] flink issue #2441: [FLINK-3580] [table] Add current time point functions - posted by twalthr <gi...@git.apache.org> on 2016/09/02 15:12:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 15:13:20 UTC, 10 replies.
- [GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on... - posted by greghogan <gi...@git.apache.org> on 2016/09/02 15:14:34 UTC, 7 replies.
- [jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 15:15:21 UTC, 10 replies.
- [jira] [Closed] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:37:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:37:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4490) Decouple Slot and Instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:38:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4490) Decouple Slot and Instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:38:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:41:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:43:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/02 15:43:20 UTC, 0 replies.
- [GitHub] flink pull request #2441: [FLINK-3580] [table] Add current time point functi... - posted by asfgit <gi...@git.apache.org> on 2016/09/02 15:46:07 UTC, 0 replies.
- [jira] [Created] (FLINK-4571) Configurable little parallelism in Gelly drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/02 15:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4572) Convert to negative in LongValueToIntValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/02 16:00:21 UTC, 0 replies.
- [GitHub] flink pull request #2466: [FLINK-4570] remove conflicting Unicode character - posted by mxm <gi...@git.apache.org> on 2016/09/02 16:03:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-4570) Scalastyle Maven plugin fails undeterministically - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/02 16:08:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4546) Remove STREAM keyword in Stream SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 16:13:20 UTC, 7 replies.
- [GitHub] flink issue #2454: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL - posted by twalthr <gi...@git.apache.org> on 2016/09/02 16:13:21 UTC, 4 replies.
- [GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by greghogan <gi...@git.apache.org> on 2016/09/02 16:26:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-4265) Add a NoOpOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 16:26:20 UTC, 2 replies.
- [GitHub] flink issue #2066: Updated ssh configuration in base Dockerfile - posted by greghogan <gi...@git.apache.org> on 2016/09/02 16:39:15 UTC, 0 replies.
- [GitHub] flink issue #2060: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/09/02 17:02:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/02 17:03:20 UTC, 9 replies.
- [jira] [Created] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler# - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/02 17:51:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/02 17:55:21 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/02 21:25:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/02 21:25:20 UTC, 6 replies.
- [jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/02 21:27:20 UTC, 0 replies.
- [GitHub] flink pull request #2467: [FLINK-3719][web frontend] Moving the barrier betw... - posted by mushketyk <gi...@git.apache.org> on 2016/09/02 22:59:13 UTC, 0 replies.
- [GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function - posted by twalthr <gi...@git.apache.org> on 2016/09/03 07:27:52 UTC, 8 replies.
- [GitHub] flink pull request #2469: [FLINK-4572] [gelly] Convert to negative in LongVa... - posted by greghogan <gi...@git.apache.org> on 2016/09/03 13:42:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-4572) Convert to negative in LongValueToIntValue - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/03 13:42:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/03 14:37:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/03 14:38:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/03 15:45:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/03 18:46:21 UTC, 0 replies.
- [GitHub] flink pull request #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCre... - posted by tzulitai <gi...@git.apache.org> on 2016/09/03 18:55:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/03 18:56:21 UTC, 5 replies.
- [GitHub] flink issue #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredential... - posted by greghogan <gi...@git.apache.org> on 2016/09/03 20:33:29 UTC, 2 replies.
- [GitHub] flink pull request #2471: Broken links on website - posted by apivovarov <gi...@git.apache.org> on 2016/09/03 21:15:07 UTC, 1 replies.
- [GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp... - posted by rmetzger <gi...@git.apache.org> on 2016/09/04 15:39:54 UTC, 4 replies.
- [jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/04 15:40:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4575) DataSet aggregate methods should support POJOs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 16:25:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/04 17:01:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/04 17:12:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4577) Re-enable transparent reshard handling in Kinesis Consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/04 17:20:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4575) DataSet aggregate methods should support POJOs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 18:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4578) AggregateOperator incorrectly sets ForwardedField with nested composite types - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 19:06:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4575) DataSet aggregate methods should support POJOs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 19:08:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 19:11:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4578) AggregateOperator incorrectly sets ForwardedField with nested composite types - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/09/04 19:12:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/04 19:36:20 UTC, 22 replies.
- [jira] [Updated] (FLINK-4361) Introduce Flink's own future abstraction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/04 21:09:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4361) Introduce Flink's own future abstraction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/04 21:09:20 UTC, 0 replies.
- [GitHub] flink pull request #2424: [FLINK-4459][Scheduler] Introduce SlotProvider for... - posted by asfgit <gi...@git.apache.org> on 2016/09/04 21:11:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4459) Introduce SlotProvider for Scheduler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/04 21:13:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4459) Introduce SlotProvider for Scheduler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/04 21:13:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4406) Implement job master registration at resource manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/09/05 05:50:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4579) Add StateBackendFactory for RocksDB Backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/05 08:06:21 UTC, 0 replies.
- [GitHub] flink pull request #2472: [FLINK-4361] Introduce Flink's own future abstract... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/05 08:07:25 UTC, 10 replies.
- [jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/05 08:08:20 UTC, 17 replies.
- [jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2016/09/05 08:51:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2016/09/05 08:54:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4580) Check that the RpcEndpoint supports the specified RpcGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/05 08:59:21 UTC, 0 replies.
- [GitHub] flink issue #2456: [FLINK-4456] Replace ActorGateway in Task and RuntimeEnvi... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/05 09:10:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-4451) Throw exception when remote connection cannot be resolved - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/05 09:16:20 UTC, 0 replies.
- [GitHub] flink issue #2471: Broken links on website - posted by zentol <gi...@git.apache.org> on 2016/09/05 09:32:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/05 09:50:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/05 09:50:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/05 09:50:21 UTC, 0 replies.
- [GitHub] flink pull request #2452: [Flink-4450] add a new module "flink-apache-storm"... - posted by liuyuzhong <gi...@git.apache.org> on 2016/09/05 10:19:29 UTC, 1 replies.
- [GitHub] flink pull request #2473: [FLINK-4580] [rpc] Verify that the rpc endpoint su... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/05 10:19:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-4580) Check that the RpcEndpoint supports the specified RpcGateway - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/05 10:20:21 UTC, 8 replies.
- [jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/05 11:53:20 UTC, 6 replies.
- [GitHub] flink pull request #2363: [FLINK-4389] Expose metrics to WebFrontend - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/05 14:10:54 UTC, 11 replies.
- [jira] [Commented] (FLINK-4389) Expose metrics to Webfrontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/05 14:11:20 UTC, 13 replies.
- [jira] [Resolved] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/05 14:23:20 UTC, 0 replies.
- [GitHub] flink issue #2363: [FLINK-4389] Expose metrics to WebFrontend - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/05 14:24:55 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/05 14:50:22 UTC, 0 replies.
- [GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/05 17:45:25 UTC, 12 replies.
- [jira] [Comment Edited] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/06 00:24:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/06 00:25:21 UTC, 3 replies.
- [jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/06 00:25:21 UTC, 3 replies.
- [jira] [Updated] (FLINK-4533) Unprotected access to meters in StatsDReporter#report() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/06 00:25:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/09/06 03:02:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/06 06:48:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-616) Change of java version without effect. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/06 08:30:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4565) Support for SQL IN operator - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/06 09:58:20 UTC, 22 replies.
- [jira] [Comment Edited] (FLINK-4565) Support for SQL IN operator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/06 10:23:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO" - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/06 12:22:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/06 12:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite" - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/06 12:26:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/06 13:07:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/06 13:38:20 UTC, 0 replies.
- [GitHub] flink pull request #2294: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by asfgit <gi...@git.apache.org> on 2016/09/06 14:17:41 UTC, 0 replies.
- [jira] [Closed] (FLINK-4265) Add a NoOpOperator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/06 14:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4583) NullPointerException in CliFrontend - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/06 15:08:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4257) Handle delegating algorithm change of class - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/06 16:37:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4554) Add support for array types - posted by "Konstantin Boudnik (JIRA)" <ji...@apache.org> on 2016/09/06 16:58:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java - posted by "Konstantin Boudnik (JIRA)" <ji...@apache.org> on 2016/09/06 17:00:28 UTC, 10 replies.
- [jira] [Created] (FLINK-4584) Fix broken links on flink.apache.org - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/06 19:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4585) Fix broken links on flink.apache.org - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/06 19:57:20 UTC, 0 replies.
- [GitHub] flink pull request #2474: [FLINK-4257] [gelly] Handle delegating algorithm c... - posted by greghogan <gi...@git.apache.org> on 2016/09/06 20:02:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4257) Handle delegating algorithm change of class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/06 20:02:21 UTC, 1 replies.
- [GitHub] flink pull request #2475: [FLINK-4571] [gelly] Configurable little paralleli... - posted by greghogan <gi...@git.apache.org> on 2016/09/06 20:03:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-4571) Configurable little parallelism in Gelly drivers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/06 20:04:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4585) Fix broken links on flink.apache.org - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/06 20:06:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4585) Fix broken links on flink.apache.org - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/06 20:09:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4585) Fix broken links in index.md - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/06 20:33:20 UTC, 2 replies.
- [GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ... - posted by greghogan <gi...@git.apache.org> on 2016/09/06 20:43:23 UTC, 6 replies.
- [jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/06 20:44:20 UTC, 7 replies.
- [jira] [Commented] (FLINK-3709) [streaming] Graph event rates over time - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/06 21:04:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue - posted by "Johannes (JIRA)" <ji...@apache.org> on 2016/09/06 21:21:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue - posted by "Johannes (JIRA)" <ji...@apache.org> on 2016/09/06 21:38:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/06 21:45:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue - posted by "Johannes (JIRA)" <ji...@apache.org> on 2016/09/06 21:48:20 UTC, 0 replies.
- [GitHub] flink pull request #2455: [FLINK-4547] [cluster management] when call connec... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/07 03:07:15 UTC, 1 replies.
- [jira] [Updated] (FLINK-4547) when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/07 03:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/07 04:31:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/07 04:33:20 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/07 05:17:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4565) Support for SQL IN operator - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/07 07:24:21 UTC, 0 replies.
- [GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten... - posted by chobeat <gi...@git.apache.org> on 2016/09/07 08:13:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 08:13:21 UTC, 3 replies.
- [GitHub] flink issue #2455: [FLINK-4547] [cluster management] when call connect metho... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/07 08:28:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-4547) when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 08:29:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4579) Add StateBackendFactory for RocksDB Backend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/07 09:26:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4588) Fix Merging of Covering Window in MergingWindowSet - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/07 11:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/07 11:43:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/07 11:46:22 UTC, 0 replies.
- [GitHub] flink pull request #2476: [FLINK-4589] Fix Merging of Covering Window in Mer... - posted by aljoscha <gi...@git.apache.org> on 2016/09/07 11:53:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 11:54:20 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true - posted by "Kirill Morozov (JIRA)" <ji...@apache.org> on 2016/09/07 12:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4591) Select star does not work with grouping - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/07 12:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2477: [FLINK-4506] CsvOutputFormat defaults allowNullVal... - posted by kirill-morozov-epam <gi...@git.apache.org> on 2016/09/07 12:32:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 12:33:21 UTC, 8 replies.
- [GitHub] flink pull request #2443: [FLINK-3950] Implement MeterView - posted by rmetzger <gi...@git.apache.org> on 2016/09/07 12:50:06 UTC, 4 replies.
- [jira] [Commented] (FLINK-3950) Add Meter Metric Type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 12:50:20 UTC, 5 replies.
- [GitHub] flink issue #2443: [FLINK-3950] Implement MeterView - posted by rmetzger <gi...@git.apache.org> on 2016/09/07 13:01:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/07 15:31:22 UTC, 0 replies.
- [GitHub] flink pull request #2440: [FLINK-3755] Introduce key groups for key-value st... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/07 16:23:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 16:24:20 UTC, 3 replies.
- [GitHub] flink issue #2440: [FLINK-3755] Introduce key groups for key-value state to ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/07 17:39:49 UTC, 0 replies.
- [jira] [Created] (FLINK-4593) Fix PageRank algorithm example - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/07 18:20:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4593) Fix PageRank algorithm example - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/07 18:23:21 UTC, 1 replies.
- [GitHub] flink issue #2469: [FLINK-4572] [gelly] Convert to negative in LongValueToIn... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/07 18:50:33 UTC, 2 replies.
- [jira] [Created] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/07 19:32:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4585) Fix broken links in index.md - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/07 20:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4595) Close FileOutputStream in ParameterTool - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/07 21:10:22 UTC, 0 replies.
- [GitHub] flink pull request #2478: [FLINK-4595] Close FileOutputStream in ParameterTo... - posted by apivovarov <gi...@git.apache.org> on 2016/09/07 21:13:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-4595) Close FileOutputStream in ParameterTool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/07 21:13:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4596) Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/09/08 01:35:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4591) Select star does not work with grouping - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 01:44:20 UTC, 9 replies.
- [GitHub] flink pull request #2479: [FLINK-4537] [cluster management] ResourceManager ... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/08 02:48:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-4537) ResourceManager registration with JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 02:49:20 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4551) Heartbeat Manager integration with JobMaster - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/08 02:51:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4427) Implement container releasing logic (Standalone / Yarn / Mesos) - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/08 02:54:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "Olga Golovneva (JIRA)" <ji...@apache.org> on 2016/09/08 03:19:20 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/09/08 03:49:20 UTC, 0 replies.
- [GitHub] flink pull request #2480: [FLINK-4408][JobManager] Introduce JobMasterRunner... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/08 04:21:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-4408) Submit Job and setup ExecutionGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 04:22:21 UTC, 2 replies.
- [jira] [Closed] (FLINK-4376) Implement job master skeleton for managing single job - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/08 05:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4597) Improve Scalar Function section in Table API documentation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 06:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4598) Support NULLIF in Table API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 06:46:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4597) Improve Scalar Function section in Table API documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 07:52:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4598) Support NULLIF in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 07:59:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 08:01:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4597) Improve Scalar Function section in Table API documentation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 08:12:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4442) Implement Standalone ResourceManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/08 08:50:20 UTC, 0 replies.
- [GitHub] flink issue #2102: [FLINK-4068] [tableAPI] Move constant computations out of... - posted by wuchong <gi...@git.apache.org> on 2016/09/08 09:01:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 09:02:20 UTC, 13 replies.
- [jira] [Created] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 09:40:21 UTC, 0 replies.
- [GitHub] flink issue #2478: [FLINK-4595] Close FileOutputStream in ParameterTool - posted by zentol <gi...@git.apache.org> on 2016/09/08 09:43:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals - posted by "miaoever (JIRA)" <ji...@apache.org> on 2016/09/08 09:48:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals - posted by "miaoever (JIRA)" <ji...@apache.org> on 2016/09/08 09:48:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Leo Deng (JIRA)" <ji...@apache.org> on 2016/09/08 09:53:20 UTC, 0 replies.
- [GitHub] flink issue #2402: [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokens... - posted by zentol <gi...@git.apache.org> on 2016/09/08 10:01:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 10:02:20 UTC, 1 replies.
- [GitHub] flink pull request #2402: [FLINK-4436] Unclosed DataOutputBuffer in Utils#se... - posted by asfgit <gi...@git.apache.org> on 2016/09/08 10:06:37 UTC, 0 replies.
- [jira] [Closed] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/08 10:07:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4595) Close FileOutputStream in ParameterTool - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/08 10:07:21 UTC, 0 replies.
- [GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ... - posted by ggevay <gi...@git.apache.org> on 2016/09/08 10:43:14 UTC, 47 replies.
- [jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 10:43:20 UTC, 49 replies.
- [GitHub] flink issue #2386: [FLINK-3660] Measure latency and exposes them via a metri... - posted by rmetzger <gi...@git.apache.org> on 2016/09/08 12:03:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 12:04:20 UTC, 12 replies.
- [GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ... - posted by zentol <gi...@git.apache.org> on 2016/09/08 12:32:32 UTC, 11 replies.
- [jira] [Assigned] (FLINK-4579) Add StateBackendFactory for RocksDB Backend - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/08 13:10:20 UTC, 0 replies.
- [GitHub] flink pull request #2481: [FLINK-4594] [core] Validate lower bound in MathUt... - posted by greghogan <gi...@git.apache.org> on 2016/09/08 14:37:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/08 14:38:22 UTC, 2 replies.
- [jira] [Closed] (FLINK-4458) Remove ForkableFlinkMiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/08 15:19:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4456) Replace ActorGateway in Task by interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/08 15:25:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 16:28:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 16:29:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3656) Rework Table API tests - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 16:30:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4550) Clearly define SQL operator table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/08 16:30:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4585) Fix broken links in index.md - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/08 16:59:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4522) Gelly link broken in homepage - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/08 21:14:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4257) Handle delegating algorithm change of class - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/08 21:15:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4522) Gelly link broken in homepage - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/08 21:15:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4571) Configurable little parallelism in Gelly drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/08 21:16:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4571) Configurable little parallelism in Gelly drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/08 21:16:21 UTC, 0 replies.
- [GitHub] flink pull request #2482: [FLINK-4579] [StateBackend] Add StateBackendFactor... - posted by wuchong <gi...@git.apache.org> on 2016/09/09 06:07:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4591) Select star does not work with grouping - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/09 06:19:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4591) Select star does not work with grouping - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/09 06:26:20 UTC, 0 replies.
- [GitHub] flink issue #2412: FLINK-4462 Add RUN_TIME retention policy for all the flin... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/09 06:57:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/09 06:58:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4601) Check for empty string properly - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/09 06:58:21 UTC, 0 replies.
- [GitHub] flink pull request #2483: [FLINK-4601] Check for empty string properly - posted by apivovarov <gi...@git.apache.org> on 2016/09/09 07:00:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-4601) Check for empty string properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/09 07:00:31 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-4591) Select star does not work with grouping - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/09 07:15:22 UTC, 0 replies.
- [GitHub] flink issue #2211: [WIP][FLINK-3599] Code generation for PojoSerializer and ... - posted by mbalassi <gi...@git.apache.org> on 2016/09/09 07:28:55 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/09 08:15:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/09 08:21:20 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/09 09:12:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4588) Fix Merging of Covering Window in MergingWindowSet - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/09 09:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4602) Move RocksDB backed to proper package - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/09 09:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4603) KeyedStateBackend cannot restore user code classes - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/09 10:04:21 UTC, 0 replies.
- [GitHub] flink issue #2483: [FLINK-4601] Check for empty string properly - posted by twalthr <gi...@git.apache.org> on 2016/09/09 10:13:55 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4601) Check for empty string properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 10:19:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 10:30:20 UTC, 0 replies.
- [GitHub] flink pull request #2484: [FLINK-4177] Harden CassandraConnectorTest - posted by zentol <gi...@git.apache.org> on 2016/09/09 11:03:28 UTC, 8 replies.
- [jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/09 11:04:20 UTC, 8 replies.
- [jira] [Updated] (FLINK-4505) Implement TaskManagerRunner to construct related components for TaskManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/09/09 11:06:21 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 11:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4604) Add support for standard deviation/variance - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 11:48:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/09 11:51:20 UTC, 13 replies.
- [GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable... - posted by chobeat <gi...@git.apache.org> on 2016/09/09 12:32:40 UTC, 5 replies.
- [jira] [Created] (FLINK-4605) Add an expression that returns the return type of an expression - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/09 15:06:20 UTC, 0 replies.
- [GitHub] flink issue #2485: [Flink 4599] - Add 'explain()' also to StreamTableEnviron... - posted by twalthr <gi...@git.apache.org> on 2016/09/09 15:09:22 UTC, 2 replies.
- [GitHub] flink pull request #2060: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/09/09 15:25:35 UTC, 5 replies.
- [GitHub] flink pull request #2486: FLINK-4520 Integrate Siddhi as a light-weight Stre... - posted by haoch <gi...@git.apache.org> on 2016/09/09 18:49:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/09 18:49:22 UTC, 23 replies.
- [jira] [Updated] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library - posted by "Hao Chen (JIRA)" <ji...@apache.org> on 2016/09/09 18:58:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/09/09 19:09:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2144) Incremental count, average, and variance for windows - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2016/09/09 20:50:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-710) Aggregate transformation works only with FieldPositionKeys - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/09 23:03:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/09 23:04:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/09 23:04:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-2859) Add links to docs and JIRA issues in FlinkML roadmap - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/09 23:06:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3457) Link to Apache Flink meetups from the 'Community' section of the website - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/09 23:46:20 UTC, 0 replies.
- [GitHub] flink issue #2442: [FLINK-4148] incorrect calculation minDist distance in Qu... - posted by nssalian <gi...@git.apache.org> on 2016/09/10 00:15:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/10 00:16:20 UTC, 1 replies.
- [GitHub] flink issue #2465: [FLINK-4447] [docs] Include NettyConfig options on Config... - posted by nssalian <gi...@git.apache.org> on 2016/09/10 00:21:12 UTC, 2 replies.
- [GitHub] flink pull request #2486: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l... - posted by haoch <gi...@git.apache.org> on 2016/09/10 02:08:52 UTC, 0 replies.
- [GitHub] flink pull request #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l... - posted by haoch <gi...@git.apache.org> on 2016/09/10 02:29:49 UTC, 11 replies.
- [GitHub] flink issue #2486: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we... - posted by haoch <gi...@git.apache.org> on 2016/09/10 02:31:04 UTC, 0 replies.
- [jira] [Created] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/10 03:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4607) Close FileInputStream in ParameterTool and other - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 03:31:20 UTC, 0 replies.
- [GitHub] flink pull request #2488: [FLINK-4607] Close FileInputStream in ParameterToo... - posted by apivovarov <gi...@git.apache.org> on 2016/09/10 03:39:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-4607) Close FileInputStream in ParameterTool and other - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/10 03:40:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 04:51:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 04:52:20 UTC, 2 replies.
- [GitHub] flink pull request #2489: [FLINK-4608] Use short-circuit AND in Max/Min Aggr... - posted by apivovarov <gi...@git.apache.org> on 2016/09/10 04:53:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/10 04:54:21 UTC, 4 replies.
- [jira] [Created] (FLINK-4609) Remove redundant check for null in CrossOperator - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 05:24:21 UTC, 0 replies.
- [GitHub] flink pull request #2490: [FLINK-4609] Remove redundant check for null in Cr... - posted by apivovarov <gi...@git.apache.org> on 2016/09/10 05:25:40 UTC, 11 replies.
- [jira] [Commented] (FLINK-4609) Remove redundant check for null in CrossOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/10 05:26:20 UTC, 17 replies.
- [GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we... - posted by haoch <gi...@git.apache.org> on 2016/09/10 06:01:43 UTC, 7 replies.
- [jira] [Created] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 06:09:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/10 06:10:20 UTC, 0 replies.
- [GitHub] flink pull request #2491: [FLINK-4610] Replace keySet/getValue with entrySet... - posted by apivovarov <gi...@git.apache.org> on 2016/09/10 06:11:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/10 06:11:20 UTC, 2 replies.
- [GitHub] flink issue #2488: [FLINK-4607] Close FileInputStream in ParameterTool and o... - posted by zentol <gi...@git.apache.org> on 2016/09/10 07:28:16 UTC, 2 replies.
- [GitHub] flink issue #2489: [FLINK-4608] Use short-circuit AND in Max/Min Aggregation... - posted by zentol <gi...@git.apache.org> on 2016/09/10 07:28:58 UTC, 2 replies.
- [GitHub] flink issue #2491: [FLINK-4610] Replace keySet/getValue with entrySet in Udf... - posted by apivovarov <gi...@git.apache.org> on 2016/09/10 21:09:06 UTC, 1 replies.
- [GitHub] flink issue #2490: [FLINK-4609] Remove redundant check for null in CrossOper... - posted by apivovarov <gi...@git.apache.org> on 2016/09/10 23:01:07 UTC, 6 replies.
- [jira] [Commented] (FLINK-4602) Move RocksDB backed to proper package - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/11 04:45:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/11 04:54:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/11 04:57:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4325) Implement Web UI HTTPS - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/09/11 10:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4405) Implement Blob Server SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/09/11 10:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4324) Enable Akka SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/09/11 10:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4404) Implement Data Transfer SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/09/11 10:04:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3931) Implement Transport Encryption (SSL/TLS) - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/09/11 10:05:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4517) scala code refactoring - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/12 00:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4612) Close FileWriter using try with resources - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/12 05:45:20 UTC, 0 replies.
- [GitHub] flink pull request #2492: [FLINK-4612] Close FileWriter using try with resou... - posted by apivovarov <gi...@git.apache.org> on 2016/09/12 05:54:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-4612) Close FileWriter using try with resources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/12 05:55:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4613) Extend ALS to handle implicit feedback datasets - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2016/09/12 07:50:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/12 14:33:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-2014) Add LASSO regression - posted by "Victor Chen (JIRA)" <ji...@apache.org> on 2016/09/12 16:53:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2014) Add LASSO regression - posted by "Victor Chen (JIRA)" <ji...@apache.org> on 2016/09/12 20:56:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3370) Add an aligned version of the window operator - posted by "Adam J Heller (JIRA)" <ji...@apache.org> on 2016/09/12 20:59:21 UTC, 1 replies.
- [GitHub] flink pull request #2493: [FLINK-4513] [Docs]: Kafka connector documentation... - posted by nssalian <gi...@git.apache.org> on 2016/09/12 21:38:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4614) CLONE - Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/12 21:45:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4614) CLONE - Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/12 21:45:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/12 21:56:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/12 21:56:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/12 21:57:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-4614) CLONE - Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/12 22:20:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4614) Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/12 22:37:21 UTC, 1 replies.
- [GitHub] flink pull request #2494: [FLINK-4614][Docs]: Changed the version from 1.2-S... - posted by nssalian <gi...@git.apache.org> on 2016/09/12 22:55:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-4614) Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/12 22:55:20 UTC, 4 replies.
- [GitHub] flink issue #2494: [FLINK-4614][Docs]: Changed the version from 1.2-SNAPSHOT... - posted by nssalian <gi...@git.apache.org> on 2016/09/13 04:24:43 UTC, 2 replies.
- [GitHub] flink issue #2493: [FLINK-4513] [Docs]: Kafka connector documentation refers... - posted by nssalian <gi...@git.apache.org> on 2016/09/13 04:25:24 UTC, 2 replies.
- [GitHub] flink pull request #2495: FLINK-3322 - Make sorters to reuse the memory page... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/13 06:40:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4615) Reusing the memory allocated for the drivers and iterators - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/09/13 13:38:20 UTC, 0 replies.
- [GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/13 13:42:44 UTC, 11 replies.
- [jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/13 13:43:20 UTC, 14 replies.
- [jira] [Created] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state - posted by "Yuri Makhno (JIRA)" <ji...@apache.org> on 2016/09/13 14:14:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/09/13 15:25:21 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/09/13 16:21:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4617) Kafka & Flink duplicate messages on restart - posted by "Matthew Barlocker (JIRA)" <ji...@apache.org> on 2016/09/13 20:08:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4617) Kafka & Flink duplicate messages on restart - posted by "Matthew Barlocker (JIRA)" <ji...@apache.org> on 2016/09/13 22:10:20 UTC, 0 replies.
- [GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/14 06:34:19 UTC, 9 replies.
- [GitHub] flink pull request #2497: [FLINK-4339][cluster management] Implement Slot Po... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/14 07:42:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4339) Implement Slot Pool Core - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/14 07:42:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/14 08:26:20 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/14 08:37:21 UTC, 10 replies.
- [jira] [Created] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/14 09:02:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/14 09:03:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/14 09:15:20 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/14 09:17:20 UTC, 3 replies.
- [GitHub] flink issue #2496: FLINK-4615 Reusing the memory allocated for the drivers a... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/14 09:27:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-4617) Kafka & Flink duplicate messages on restart - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/14 09:32:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-4603) KeyedStateBackend cannot restore user code classes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/14 09:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4620) Automatically creating savepoints - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/09/14 12:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails - posted by "Maciej Prochniak (JIRA)" <ji...@apache.org> on 2016/09/14 12:22:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/14 12:25:22 UTC, 5 replies.
- [jira] [Updated] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/14 12:45:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/14 13:59:20 UTC, 0 replies.
- [GitHub] flink pull request #2498: [FLINK-4619] - JobManager does not answer to clien... - posted by mproch <gi...@git.apache.org> on 2016/09/14 21:26:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/15 01:17:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/15 01:17:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4617) Kafka & Flink duplicate messages on restart - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 06:25:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4617) Kafka & Flink duplicate messages on restart - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 06:25:20 UTC, 0 replies.
- [GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t... - posted by tzulitai <gi...@git.apache.org> on 2016/09/15 06:46:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/15 06:47:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/15 06:57:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 08:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4621) Improve decimal literals of SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 09:50:20 UTC, 0 replies.
- [GitHub] flink pull request #2499: [FLINK-4485] close and remove user class loader af... - posted by mxm <gi...@git.apache.org> on 2016/09/15 11:04:17 UTC, 1 replies.
- [GitHub] flink pull request #2500: [FLINK-4549] [table] Test and document implicitly ... - posted by twalthr <gi...@git.apache.org> on 2016/09/15 12:57:30 UTC, 4 replies.
- [jira] [Commented] (FLINK-4549) Test and document implicitly supported SQL functions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/15 12:58:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4550) Clearly define SQL operator table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 13:07:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4620) Automatically creating savepoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/15 14:02:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-3442) Expose savepoint button on web ui - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/09/15 14:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4622) CLI help message should include 'savepoint' action - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/09/15 14:40:20 UTC, 0 replies.
- [GitHub] flink pull request #2501: [FLINK-4622] CLI help message should include 'save... - posted by skidder <gi...@git.apache.org> on 2016/09/15 14:50:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-4622) CLI help message should include 'savepoint' action - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/15 14:51:20 UTC, 3 replies.
- [GitHub] flink pull request #2502: [FLINK-4550] [table] Clearly define SQL operator t... - posted by twalthr <gi...@git.apache.org> on 2016/09/15 15:03:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-4550) Clearly define SQL operator table - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/15 15:04:20 UTC, 3 replies.
- [jira] [Resolved] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 15:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4623) Create Physical Execution Plan of a DataStream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 16:00:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-4623) Create Physical Execution Plan of a DataStream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 16:00:23 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/15 16:20:20 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4618) Last kafka message gets consumed twice when restarting job - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 16:49:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record when startup from Kafka offsets - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 16:51:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record on startup from offsets in Kafka - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 16:52:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record on startup from Kafka offsets - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 16:52:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 16:53:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 16:58:20 UTC, 11 replies.
- [jira] [Created] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/15 17:03:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/15 17:05:20 UTC, 3 replies.
- [GitHub] flink issue #2476: [FLINK-4589] Fix Merging of Covering Window in MergingWin... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/15 17:16:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-4389) Expose metrics to Webfrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/15 17:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4625) Guard Flink processes against blocking shutdown hooks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/15 17:27:20 UTC, 0 replies.
- [GitHub] flink issue #2501: [FLINK-4622] CLI help message should include 'savepoint' ... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/15 17:38:04 UTC, 1 replies.
- [GitHub] flink issue #2499: [FLINK-4485] close and remove user class loader after job... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/15 17:39:32 UTC, 6 replies.
- [GitHub] flink issue #2498: [FLINK-4619] - JobManager does not answer to client when ... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/15 17:57:29 UTC, 1 replies.
- [GitHub] flink pull request #2503: [FLINK-4625] [core] Add a safety net to forcibly t... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/15 18:07:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-4625) Guard Flink processes against blocking shutdown hooks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/15 18:08:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/15 19:16:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4626) Missing break in MetricStore#add() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/15 22:19:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/16 03:47:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/16 03:48:20 UTC, 0 replies.
- [GitHub] flink pull request #2504: [FLINK-4590] [table] Some Table API tests are fail... - posted by twalthr <gi...@git.apache.org> on 2016/09/16 09:01:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/16 09:02:20 UTC, 5 replies.
- [jira] [Assigned] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite" - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/16 09:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4628) User class loader unavailable during input split assignment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/16 10:16:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4628) User class loader unavailable during input split assignment - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/09/16 10:24:20 UTC, 4 replies.
- [GitHub] flink pull request #2505: [FLINK-4628] provide user class loader during inpu... - posted by mxm <gi...@git.apache.org> on 2016/09/16 10:26:26 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4626) Missing break in MetricStore#add() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:27:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-4626) Missing break in MetricStore#add() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:27:22 UTC, 1 replies.
- [GitHub] flink issue #2492: [FLINK-4612] Close FileWriter using try with resources - posted by zentol <gi...@git.apache.org> on 2016/09/16 10:30:31 UTC, 0 replies.
- [jira] [Closed] (FLINK-4626) Missing break in MetricStore#add() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:36:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:37:22 UTC, 1 replies.
- [jira] [Closed] (FLINK-4612) Close FileWriter using try with resources - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:37:22 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:38:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:38:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4607) Close FileInputStream in ParameterTool and other - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 10:38:20 UTC, 0 replies.
- [GitHub] flink pull request #2506: [FLINK-4581] [table] Table API throws "No suitable... - posted by twalthr <gi...@git.apache.org> on 2016/09/16 10:51:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-4581) Table API throws "No suitable driver found for jdbc:calcite" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/16 10:52:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4252) Table program cannot be compiled - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/16 11:04:21 UTC, 0 replies.
- [GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit... - posted by mxm <gi...@git.apache.org> on 2016/09/16 12:11:39 UTC, 23 replies.
- [jira] [Closed] (FLINK-4622) CLI help message should include 'savepoint' action - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/16 12:17:20 UTC, 0 replies.
- [GitHub] flink pull request #2507: [FLINK-4252] [table] Validate input and output cla... - posted by twalthr <gi...@git.apache.org> on 2016/09/16 12:35:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-4252) Table program cannot be compiled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/16 12:35:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4393) Failed to serialize accumulators for task - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/16 12:39:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4288) Make it possible to unregister tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/16 12:40:20 UTC, 0 replies.
- [GitHub] flink issue #2297: [FLINK-4081] [core] [table] FieldParsers should support e... - posted by twalthr <gi...@git.apache.org> on 2016/09/16 13:31:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-4081) FieldParsers should support empty strings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/16 13:32:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4629) Kafka v 0.10 Support - posted by "Mariano Gonzalez (JIRA)" <ji...@apache.org> on 2016/09/16 19:25:20 UTC, 0 replies.
- [GitHub] flink pull request #2508: [FLINK-2662] [dataSet] Translate union with multip... - posted by fhueske <gi...@git.apache.org> on 2016/09/16 22:19:38 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/16 22:21:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/17 07:58:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4629) Kafka v 0.10 Support - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/17 12:42:20 UTC, 4 replies.
- [GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit... - posted by tzulitai <gi...@git.apache.org> on 2016/09/17 14:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/17 14:36:20 UTC, 5 replies.
- [jira] [Updated] (FLINK-4499) Introduce findbugs maven plugin - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/17 15:34:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4557) Table API Stream Aggregations - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/18 02:43:20 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4557) Table API Stream Aggregations - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/18 02:52:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4598) Support NULLIF in Table API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/18 03:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4630) add netty tcp source support - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/18 08:04:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/18 11:11:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4630) add netty tcp source support - posted by "Kanstantsin Kamkou (JIRA)" <ji...@apache.org> on 2016/09/18 12:30:20 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4630) add netty tcp source support - posted by "Kanstantsin Kamkou (JIRA)" <ji...@apache.org> on 2016/09/18 12:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4631) NullPointerException during stream task cleanup - posted by "Avihai Berkovitz (JIRA)" <ji...@apache.org> on 2016/09/18 14:51:20 UTC, 0 replies.
- [GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0... - posted by nemccarthy <gi...@git.apache.org> on 2016/09/19 00:48:16 UTC, 7 replies.
- [jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 00:48:20 UTC, 13 replies.
- [jira] [Created] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/09/19 01:12:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4633) Implement new Client - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/19 01:54:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/19 03:07:21 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/09/19 06:51:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/09/19 07:03:20 UTC, 23 replies.
- [jira] [Resolved] (FLINK-4629) Kafka v 0.10 Support - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/19 07:10:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4629) Kafka v 0.10 Support - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/09/19 07:10:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4633) Implement new Client - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/19 07:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4634) TaskStopTest.testStopExecution() times out - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/09/19 07:53:20 UTC, 0 replies.
- [jira] [Deleted] (FLINK-4633) Implement new Client - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/19 09:09:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/19 09:19:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4415) Enhance Trigger Interface with onFire() - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/19 09:49:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/19 09:56:20 UTC, 9 replies.
- [jira] [Assigned] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/19 10:10:20 UTC, 0 replies.
- [GitHub] flink pull request #2510: FLINK-3322 Allow drivers and iterators to reuse th... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/19 10:31:56 UTC, 11 replies.
- [jira] [Closed] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/19 11:12:22 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/19 11:13:20 UTC, 0 replies.
- [GitHub] flink pull request #2511: [FLINK-4288] [table] Make it possible to unregiste... - posted by twalthr <gi...@git.apache.org> on 2016/09/19 12:31:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-4288) Make it possible to unregister tables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 12:32:21 UTC, 0 replies.
- [GitHub] flink pull request #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests - posted by fhueske <gi...@git.apache.org> on 2016/09/19 13:30:52 UTC, 3 replies.
- [jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 13:31:21 UTC, 7 replies.
- [GitHub] flink issue #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests - posted by fhueske <gi...@git.apache.org> on 2016/09/19 13:31:43 UTC, 3 replies.
- [GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t... - posted by kl0u <gi...@git.apache.org> on 2016/09/19 13:32:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 13:33:21 UTC, 9 replies.
- [GitHub] flink pull request #2512: Partitionable op state - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/19 13:58:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-4379) Add Rescalable Non-Partitioned State - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 13:58:20 UTC, 8 replies.
- [GitHub] flink issue #2512: [FLINK-4379] Rescalable non-partitioned state - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/19 14:04:43 UTC, 6 replies.
- [jira] [Updated] (FLINK-4565) Support for SQL IN operator - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/19 14:22:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4081) FieldParsers should support empty strings - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/19 14:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2297: [FLINK-4081] [core] [table] FieldParsers should su... - posted by asfgit <gi...@git.apache.org> on 2016/09/19 14:26:26 UTC, 0 replies.
- [GitHub] flink pull request #2513: [hotfix] RescalingITCase - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/19 15:57:06 UTC, 4 replies.
- [GitHub] flink issue #2508: [FLINK-2662] [dataSet] Translate union with multiple outp... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 16:24:35 UTC, 3 replies.
- [GitHub] flink issue #2304: [FLINK-4268] [core] Add parsers for BigDecimal/BigInteger - posted by twalthr <gi...@git.apache.org> on 2016/09/19 16:26:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 16:27:20 UTC, 5 replies.
- [GitHub] flink issue #2505: [FLINK-4628] provide user class loader during input split... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 16:35:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/19 16:47:20 UTC, 3 replies.
- [GitHub] flink pull request #2514: [FLINK-4555] add test case to test Yarn cluster sh... - posted by mxm <gi...@git.apache.org> on 2016/09/19 16:53:45 UTC, 1 replies.
- [jira] [Closed] (FLINK-1151) CollectionDataSource does not provide statistics - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/19 17:29:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4614) Kafka connector documentation refers to Flink 1.2-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/19 18:18:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/19 18:18:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/19 18:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4636) AbstractCEPPatternOperator fails to restore state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/19 18:30:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/19 18:39:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/19 18:56:20 UTC, 0 replies.
- [GitHub] flink issue #2481: [FLINK-4594] [core] Validate lower bound in MathUtils.che... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 19:35:30 UTC, 0 replies.
- [GitHub] flink issue #2482: [FLINK-4579] [StateBackend] Add StateBackendFactory for R... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 19:37:11 UTC, 3 replies.
- [GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 19:50:28 UTC, 7 replies.
- [GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7 - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 20:06:06 UTC, 7 replies.
- [GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor... - posted by fhueske <gi...@git.apache.org> on 2016/09/19 20:16:38 UTC, 16 replies.
- [jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/19 20:17:20 UTC, 17 replies.
- [GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/19 20:18:20 UTC, 4 replies.
- [jira] [Resolved] (FLINK-4625) Guard Flink processes against blocking shutdown hooks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/19 20:34:21 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/09/20 01:27:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4638) Fix exception message for MemorySegment - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 06:33:20 UTC, 0 replies.
- [GitHub] flink pull request #2515: [FLINK-4638] Fix exception message for MemorySegme... - posted by lw-lin <gi...@git.apache.org> on 2016/09/20 06:37:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-4638) Fix exception message for MemorySegment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 06:38:20 UTC, 3 replies.
- [GitHub] flink issue #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() expects ... - posted by fhueske <gi...@git.apache.org> on 2016/09/20 07:42:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 07:43:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4639) Make Calcite features more pluggable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/20 07:49:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 08:34:20 UTC, 8 replies.
- [jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 08:34:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 08:34:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 08:34:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4533) Unprotected access to meters in StatsDReporter#report() - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/20 08:37:20 UTC, 3 replies.
- [GitHub] flink issue #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to let typ... - posted by twalthr <gi...@git.apache.org> on 2016/09/20 08:40:32 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4639) Make Calcite features more pluggable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/20 08:50:20 UTC, 0 replies.
- [GitHub] flink issue #2472: [FLINK-4361] Introduce Flink's own future abstraction - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/20 09:10:49 UTC, 2 replies.
- [jira] [Created] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/20 09:16:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/20 09:21:20 UTC, 2 replies.
- [GitHub] flink pull request #2516: [FLINK-4563] [metrics] Delimiter should be configu... - posted by ex00 <gi...@git.apache.org> on 2016/09/20 09:43:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 09:44:20 UTC, 9 replies.
- [GitHub] flink pull request #2304: [FLINK-4268] [core] Add parsers for BigDecimal/Big... - posted by fhueske <gi...@git.apache.org> on 2016/09/20 09:50:08 UTC, 3 replies.
- [GitHub] flink issue #2516: [FLINK-4564] [metrics] Delimiter should be configured per... - posted by ex00 <gi...@git.apache.org> on 2016/09/20 10:02:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 10:03:21 UTC, 46 replies.
- [GitHub] flink pull request #2516: [FLINK-4564] [metrics] Delimiter should be configu... - posted by ex00 <gi...@git.apache.org> on 2016/09/20 10:10:06 UTC, 0 replies.
- [GitHub] flink pull request #2517: [FLINK-4564] [metrics] Delimiter should be configu... - posted by ex00 <gi...@git.apache.org> on 2016/09/20 10:16:45 UTC, 36 replies.
- [GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no... - posted by fhueske <gi...@git.apache.org> on 2016/09/20 10:38:02 UTC, 22 replies.
- [GitHub] flink pull request #2519: [docs] Small improvements to the docs. - posted by alpinegizmo <gi...@git.apache.org> on 2016/09/20 12:58:48 UTC, 4 replies.
- [GitHub] flink pull request #640: [scheduling] implement backtracking of intermediate... - posted by mxm <gi...@git.apache.org> on 2016/09/20 13:01:06 UTC, 0 replies.
- [GitHub] flink issue #640: [scheduling] implement backtracking of intermediate result... - posted by mxm <gi...@git.apache.org> on 2016/09/20 13:01:06 UTC, 0 replies.
- [GitHub] flink issue #2517: [FLINK-4564] [metrics] Delimiter should be configured per... - posted by ex00 <gi...@git.apache.org> on 2016/09/20 13:01:16 UTC, 7 replies.
- [jira] [Created] (FLINK-4641) Support branching CEP patterns - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/20 13:02:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4641) Support branching CEP patterns - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/20 13:02:20 UTC, 2 replies.
- [GitHub] flink issue #2434: [FLINK-4496] Refactor the TimeServiceProvider to take a T... - posted by kl0u <gi...@git.apache.org> on 2016/09/20 13:08:38 UTC, 2 replies.
- [GitHub] flink issue #2515: [FLINK-4638] [core] Fix exception message for MemorySegme... - posted by greghogan <gi...@git.apache.org> on 2016/09/20 13:11:53 UTC, 0 replies.
- [GitHub] flink issue #2514: [FLINK-4555] add test case to test Yarn cluster shutdown - posted by mxm <gi...@git.apache.org> on 2016/09/20 13:46:32 UTC, 0 replies.
- [GitHub] flink pull request #2520: Jira 4530 - posted by zhuhaifengleon <gi...@git.apache.org> on 2016/09/20 13:50:55 UTC, 0 replies.
- [GitHub] flink pull request #2521: [FLINK-4639] [table] Make Calcite features more pl... - posted by twalthr <gi...@git.apache.org> on 2016/09/20 13:55:37 UTC, 0 replies.
- [jira] [Commented] (FLINK-4639) Make Calcite features more pluggable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 13:56:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4301) Parameterize Flink version in Quickstart bash script - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/09/20 14:06:21 UTC, 0 replies.
- [GitHub] flink pull request #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() e... - posted by asfgit <gi...@git.apache.org> on 2016/09/20 14:09:15 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/20 14:10:21 UTC, 0 replies.
- [GitHub] flink pull request #2515: [FLINK-4638] [core] Fix exception message for Memo... - posted by asfgit <gi...@git.apache.org> on 2016/09/20 14:13:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:14:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:14:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4572) Convert to negative in LongValueToIntValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:15:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4572) Convert to negative in LongValueToIntValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:15:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4609) Remove redundant check for null in CrossOperator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:16:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4609) Remove redundant check for null in CrossOperator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:17:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4638) Fix exception message for MemorySegment - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:17:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4638) Fix exception message for MemorySegment - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 14:18:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/09/20 14:36:20 UTC, 0 replies.
- [GitHub] flink pull request #2522: Parameterize Flink version in Quickstart bash scri... - posted by chobeat <gi...@git.apache.org> on 2016/09/20 14:37:26 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4268) Add a parsers for BigDecimal/BigInteger - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/20 14:47:20 UTC, 0 replies.
- [GitHub] flink pull request #2523: [FLINK-4556] Make Queryable State Key-Group Aware - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/20 14:52:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 14:52:20 UTC, 3 replies.
- [GitHub] flink issue #2522: Parameterize Flink version in Quickstart bash script - posted by StephanEwen <gi...@git.apache.org> on 2016/09/20 14:53:21 UTC, 0 replies.
- [GitHub] flink issue #2513: [hotfix] RescalingITCase - posted by StephanEwen <gi...@git.apache.org> on 2016/09/20 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/20 14:58:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/20 15:01:20 UTC, 24 replies.
- [jira] [Created] (FLINK-4643) Average Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 15:57:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4533) Unprotected access to meters in StatsDReporter#report() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/20 16:29:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/20 16:50:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/20 16:52:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-3987) Add data stream connector to DistributedLog - posted by "John Lonergan (JIRA)" <ji...@apache.org> on 2016/09/20 17:48:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/20 17:48:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3988) Add data set connector to DistributedLog - posted by "John Lonergan (JIRA)" <ji...@apache.org> on 2016/09/20 17:50:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4645) Hard to register Kryo Serializers due to generics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/20 18:01:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/20 19:40:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/20 19:58:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/20 20:15:20 UTC, 0 replies.
- [GitHub] flink pull request #934: Framesize fix - posted by kl0u <gi...@git.apache.org> on 2016/09/20 20:18:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/20 20:29:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/20 20:30:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3670) Kerberos: Improving long-running streaming jobs - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/20 20:31:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4406) Implement job master registration at resource manager - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/09/21 01:59:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4641) Support branching CEP patterns - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:37:21 UTC, 2 replies.
- [jira] [Created] (FLINK-4646) Add BipartiteGraph class - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:41:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4646) Add BipartiteGraph class - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4647) Implement BipartiteGraph reader - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4648) Implement bipartite graph generators - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4649) Implement bipartite graph metrics - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:53:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4649) Implement bipartite graph metrics - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/21 06:54:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4596) RESTART_STRATEGY is not really pluggable - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/09/21 07:18:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4564) [metrics] Delimiter should be configured per reporter - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/09/21 07:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4650) Frequent task manager disconnects from JobManager - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/09/21 07:31:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4361) Introduce Flink's own future abstraction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 08:11:20 UTC, 0 replies.
- [GitHub] flink issue #2477: [FLINK-4506] CsvOutputFormat defaults allowNullValues to ... - posted by zentol <gi...@git.apache.org> on 2016/09/21 08:12:08 UTC, 1 replies.
- [jira] [Created] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/21 08:32:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/21 08:33:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4652) Don't pass credentials explicitly to AmazonClient - use credentials provider instead - posted by "Kristian Frøhlich Hansen (JIRA)" <ji...@apache.org> on 2016/09/21 08:38:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/21 08:55:20 UTC, 4 replies.
- [GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo... - posted by twalthr <gi...@git.apache.org> on 2016/09/21 08:56:48 UTC, 2 replies.
- [jira] [Created] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/21 09:33:20 UTC, 0 replies.
- [GitHub] flink pull request #2524: [FLINK-4653] [Client] Refactor JobClientActor to a... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/21 09:40:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 09:41:21 UTC, 4 replies.
- [jira] [Created] (FLINK-4654) clean up docs - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/09/21 09:55:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4241) Cryptic expression parser exceptions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/21 09:57:20 UTC, 0 replies.
- [GitHub] flink issue #2524: [FLINK-4653] [Client] Refactor JobClientActor to adapt to... - posted by mxm <gi...@git.apache.org> on 2016/09/21 10:01:59 UTC, 2 replies.
- [GitHub] flink pull request #2525: [FLINK-4654] Small improvements to the docs. - posted by alpinegizmo <gi...@git.apache.org> on 2016/09/21 10:24:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-4654) clean up docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 10:25:20 UTC, 4 replies.
- [GitHub] flink issue #2435: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/21 10:40:21 UTC, 3 replies.
- [jira] [Commented] (FLINK-4478) Implement heartbeat logic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 10:41:22 UTC, 10 replies.
- [jira] [Commented] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/09/21 10:41:22 UTC, 0 replies.
- [GitHub] flink issue #2473: [FLINK-4580] [rpc] Verify that the rpc endpoint supports ... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/21 11:19:23 UTC, 1 replies.
- [GitHub] flink issue #2480: [FLINK-4408][JobManager] Introduce JobMasterRunner and im... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/21 11:21:15 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/21 12:15:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/21 12:16:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/21 13:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4655) Add tests for validation of Expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/21 13:17:20 UTC, 0 replies.
- [GitHub] flink pull request #2526: [FLINK-4580] [rpc] Report rpc invocation exception... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/21 13:26:52 UTC, 1 replies.
- [jira] [Created] (FLINK-4656) Port existing code to use Flink's future abstraction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 13:29:20 UTC, 0 replies.
- [GitHub] flink pull request #2527: [FLINK-4624] Allow for null values in Graph Summar... - posted by s1ck <gi...@git.apache.org> on 2016/09/21 14:11:23 UTC, 4 replies.
- [jira] [Updated] (FLINK-4654) clean up docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/21 14:41:20 UTC, 0 replies.
- [GitHub] flink issue #2525: [FLINK-4654] Small improvements to the docs. - posted by greghogan <gi...@git.apache.org> on 2016/09/21 14:41:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4654) clean up docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/21 14:43:20 UTC, 0 replies.
- [GitHub] flink pull request #2528: [FLINK-4643] [gelly] Average Clustering Coefficien... - posted by greghogan <gi...@git.apache.org> on 2016/09/21 14:52:15 UTC, 0 replies.
- [jira] [Created] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/21 14:52:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4643) Average Clustering Coefficient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 14:52:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/21 14:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2529: [FLINK-4241] [table] Cryptic expression parser exc... - posted by twalthr <gi...@git.apache.org> on 2016/09/21 15:16:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-4241) Cryptic expression parser exceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 15:17:20 UTC, 2 replies.
- [GitHub] flink pull request #2530: [FLINK-4656] [rpc] Port the existing code to Flink... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/21 15:30:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-4656) Port existing code to use Flink's future abstraction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 15:31:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/21 15:37:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/21 15:55:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/21 15:55:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4645) Hard to register Kryo Serializers due to generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/21 15:56:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4645) Hard to register Kryo Serializers due to generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/21 15:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 16:01:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4564) [metrics] Delimiter should be configured per reporter - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/09/21 16:10:20 UTC, 0 replies.
- [GitHub] flink pull request #2531: [FLINK-4658] [rpc] Allow RpcService to execute Run... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/21 16:19:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 16:19:20 UTC, 3 replies.
- [GitHub] flink issue #2530: [FLINK-4656] [rpc] Port the existing code to Flink's own ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/21 16:20:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-4656) Port existing code to use Flink's future abstraction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 16:22:20 UTC, 0 replies.
- [GitHub] flink issue #2531: [FLINK-4658] [rpc] Allow RpcService to execute Runnables ... - posted by mxm <gi...@git.apache.org> on 2016/09/21 16:26:02 UTC, 1 replies.
- [jira] [Closed] (FLINK-4658) Allow RpcService to execute Callables in the RpcService executor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/21 16:33:20 UTC, 0 replies.
- [GitHub] flink issue #2479: [FLINK-4537] [cluster management] ResourceManager registr... - posted by mxm <gi...@git.apache.org> on 2016/09/21 17:55:42 UTC, 1 replies.
- [jira] [Created] (FLINK-4659) Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/21 18:12:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/09/21 19:45:21 UTC, 9 replies.
- [jira] [Created] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/09/21 19:45:21 UTC, 0 replies.
- [GitHub] flink pull request #2532: [FLINK-4494] Expose the TimeServiceProvider from t... - posted by kl0u <gi...@git.apache.org> on 2016/09/21 22:27:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/21 22:28:20 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (FLINK-4564) [metrics] Delimiter should be configured per reporter - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/09/22 06:33:20 UTC, 0 replies.
- [GitHub] flink pull request #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot resto... - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/22 08:02:49 UTC, 3 replies.
- [GitHub] flink issue #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot restore user... - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/22 08:03:30 UTC, 4 replies.
- [GitHub] flink issue #2330: FLINK-4311 Fixed several problems in TableInputFormat - posted by fhueske <gi...@git.apache.org> on 2016/09/22 08:27:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/22 09:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/22 09:35:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/22 09:37:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4646) Add BipartiteGraph class - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 10:05:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4662) Bump Calcite version up to 1.9 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/22 10:07:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 10:09:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-2170) Add OrcTableSource - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/09/22 10:21:20 UTC, 1 replies.
- [GitHub] flink issue #2526: [FLINK-4580] [rpc] Report rpc invocation exceptions to th... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/22 10:42:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Swapnil Chougule (JIRA)" <ji...@apache.org> on 2016/09/22 10:48:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Swapnil Chougule (JIRA)" <ji...@apache.org> on 2016/09/22 11:05:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Swapnil Chougule (JIRA)" <ji...@apache.org> on 2016/09/22 11:06:20 UTC, 4 replies.
- [jira] [Assigned] (FLINK-4662) Bump Calcite version up to 1.9 - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/22 12:04:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 12:55:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 12:59:20 UTC, 11 replies.
- [GitHub] flink pull request #2534: [FLINK-4663] Flink JDBCOutputFormat logs wrong WAR... - posted by swapnil-chougule <gi...@git.apache.org> on 2016/09/22 13:01:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Swapnil Chougule (JIRA)" <ji...@apache.org> on 2016/09/22 13:05:20 UTC, 1 replies.
- [jira] [Reopened] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/22 13:08:20 UTC, 0 replies.
- [GitHub] flink issue #2534: [FLINK-4663] Flink JDBCOutputFormat logs wrong WARN messa... - posted by zentol <gi...@git.apache.org> on 2016/09/22 13:09:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/22 13:28:21 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4554) Add support for array types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/22 13:35:20 UTC, 0 replies.
- [GitHub] flink issue #2523: [FLINK-4556] Make Queryable State Key-Group Aware - posted by StefanRRichter <gi...@git.apache.org> on 2016/09/22 13:43:15 UTC, 1 replies.
- [jira] [Closed] (FLINK-4603) KeyedStateBackend cannot restore user code classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 13:54:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4603) KeyedStateBackend cannot restore user code classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 13:54:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4628) User class loader unavailable during input split assignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 13:55:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4628) User class loader unavailable during input split assignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/22 13:55:20 UTC, 0 replies.
- [GitHub] flink pull request #2535: [FLINK-4662] Bump Calcite version up to 1.9 - posted by wuchong <gi...@git.apache.org> on 2016/09/22 14:20:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-4662) Bump Calcite version up to 1.9 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/22 14:21:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-4596) RESTART_STRATEGY is not really pluggable - posted by "Monal Daxini (JIRA)" <ji...@apache.org> on 2016/09/22 16:24:20 UTC, 2 replies.
- [GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization - posted by greghogan <gi...@git.apache.org> on 2016/09/22 17:43:52 UTC, 7 replies.
- [jira] [Created] (FLINK-4664) Add translator to NullValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/22 20:47:20 UTC, 0 replies.
- [GitHub] flink pull request #2536: [FLINK-4664] [gelly] Add translator to NullValue - posted by greghogan <gi...@git.apache.org> on 2016/09/22 20:58:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-4664) Add translator to NullValue - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/22 20:59:20 UTC, 3 replies.
- [jira] [Closed] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/23 01:06:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4630) add netty tcp source support - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/23 02:55:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4535) ResourceManager registration with TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/23 03:15:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4537) ResourceManager registration with JobManager - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/23 03:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4665) Remove boxing/unboxing to parse a primitive - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 03:26:20 UTC, 0 replies.
- [GitHub] flink pull request #2537: [FLINK-4665] Remove boxing/unboxing to parse a pri... - posted by apivovarov <gi...@git.apache.org> on 2016/09/23 03:36:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-4665) Remove boxing/unboxing to parse a primitive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 03:37:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4666) Make constants final in ParameterTool - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 05:53:20 UTC, 0 replies.
- [GitHub] flink pull request #2538: [FLINK-4666] Make constants to be final in Paramet... - posted by apivovarov <gi...@git.apache.org> on 2016/09/23 05:55:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-4666) Make constants to be final in ParameterTool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 05:55:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-4666) Make constants to be final in ParameterTool - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 05:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/09/23 06:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4668) Fix positive random int generation - posted by "Alexander Pivovarov (JIRA)" <ji...@apache.org> on 2016/09/23 06:23:20 UTC, 0 replies.
- [GitHub] flink pull request #2539: [FLINK-4668] Fix positive random int generation - posted by apivovarov <gi...@git.apache.org> on 2016/09/23 06:27:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-4668) Fix positive random int generation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 06:28:20 UTC, 7 replies.
- [GitHub] flink pull request #2540: [FLINK-4606] [Client] Integrate the new ResourceMa... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/23 07:33:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 07:34:20 UTC, 12 replies.
- [jira] [Commented] (FLINK-4605) Add an expression that returns the return type of an expression - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/23 07:45:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4621) Improve decimal literals of SQL API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/23 08:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/23 09:38:20 UTC, 0 replies.
- [GitHub] flink pull request #2541: [FLINK-4669] scala api createLocalEnvironment() fu... - posted by shijinkui <gi...@git.apache.org> on 2016/09/23 09:51:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 09:51:20 UTC, 5 replies.
- [jira] [Updated] (FLINK-4315) Remove Hadoop Dependency from flink-java - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/23 10:13:21 UTC, 0 replies.
- [GitHub] flink issue #2536: [FLINK-4664] [gelly] Add translator to NullValue - posted by StephanEwen <gi...@git.apache.org> on 2016/09/23 10:27:18 UTC, 1 replies.
- [GitHub] flink issue #2537: [FLINK-4665] Remove boxing/unboxing to parse a primitive - posted by StephanEwen <gi...@git.apache.org> on 2016/09/23 10:32:48 UTC, 0 replies.
- [GitHub] flink issue #2538: [FLINK-4666] Make constants to be final in ParameterTool - posted by StephanEwen <gi...@git.apache.org> on 2016/09/23 10:34:24 UTC, 0 replies.
- [GitHub] flink issue #2539: [FLINK-4668] Fix positive random int generation - posted by StephanEwen <gi...@git.apache.org> on 2016/09/23 10:36:42 UTC, 5 replies.
- [GitHub] flink pull request #2542: [FLINK-4613] Extend ALS to handle implicit feedbac... - posted by gaborhermann <gi...@git.apache.org> on 2016/09/23 11:11:24 UTC, 10 replies.
- [jira] [Commented] (FLINK-4613) Extend ALS to handle implicit feedback datasets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 11:12:20 UTC, 26 replies.
- [jira] [Created] (FLINK-4670) Add watch mechanism on current RPC framework - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/23 11:19:20 UTC, 0 replies.
- [GitHub] flink pull request #2543: [FLINK-4606] [cluster management] Add watch mechan... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/23 11:31:44 UTC, 0 replies.
- [GitHub] flink issue #2543: [FLINK-4606] [cluster management] Add watch mechanism on ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/23 11:47:29 UTC, 0 replies.
- [GitHub] flink issue #2543: [FLINK-4670] [cluster management] Add watch mechanism on ... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/23 12:13:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-4670) Add watch mechanism on current RPC framework - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/23 12:13:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4666) Make constants to be final in ParameterTool - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:14:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4666) Make constants to be final in ParameterTool - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:14:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4665) Remove boxing/unboxing to parse a primitive - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:15:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4665) Remove boxing/unboxing to parse a primitive - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:15:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:17:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:18:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4556) Make Queryable State Key-Group Aware - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 12:18:20 UTC, 0 replies.
- [GitHub] flink issue #2502: [FLINK-4550] [table] Clearly define SQL operator table - posted by fhueske <gi...@git.apache.org> on 2016/09/23 12:30:12 UTC, 1 replies.
- [GitHub] flink issue #2532: [FLINK-4494] Expose the TimeServiceProvider from the Task... - posted by aljoscha <gi...@git.apache.org> on 2016/09/23 13:14:32 UTC, 1 replies.
- [GitHub] flink pull request #2544: [FLINK-4218] [checkpoints] Do not rely on FileSyst... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/23 13:24:16 UTC, 5 replies.
- [GitHub] flink issue #2544: [FLINK-4218] [checkpoints] Do not rely on FileSystem to d... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/23 13:25:21 UTC, 1 replies.
- [jira] [Closed] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/23 13:29:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/23 13:29:20 UTC, 0 replies.
- [GitHub] flink issue #2542: [FLINK-4613] Extend ALS to handle implicit feedback datas... - posted by mbalassi <gi...@git.apache.org> on 2016/09/23 13:54:14 UTC, 2 replies.
- [GitHub] flink issue #2507: [FLINK-4252] [table] Validate input and output classes of... - posted by fhueske <gi...@git.apache.org> on 2016/09/23 14:27:09 UTC, 0 replies.
- [GitHub] flink issue #2529: [FLINK-4241] [table] Cryptic expression parser exceptions - posted by fhueske <gi...@git.apache.org> on 2016/09/23 14:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4511) Schedule periodic savepoints - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/09/23 14:49:20 UTC, 0 replies.
- [GitHub] flink issue #2504: [FLINK-4590] [table] Some Table API tests are failing whe... - posted by fhueske <gi...@git.apache.org> on 2016/09/23 14:49:43 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4550) Clearly define SQL operator table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/23 15:04:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4549) Test and document implicitly supported SQL functions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/23 15:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4671) Table API can not be built - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/23 15:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4672) TaskManager accidentally decorates Kill messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 16:43:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 17:17:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/23 17:17:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4668) Fix positive random int generation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/23 18:51:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4668) Fix positive random int generation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/23 18:51:20 UTC, 1 replies.
- [jira] [Closed] (FLINK-4664) Add translator to NullValue - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/23 18:51:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4673) TypeInfoFactory for Either type - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/23 18:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4673) TypeFactory for Either type - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/23 18:59:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4671) Table API can not be built - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/24 06:10:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4674) File Descriptors not being released after Completion of Flink Job Run via Flink Web Portal - posted by "Abey Sam Alex (JIRA)" <ji...@apache.org> on 2016/09/24 10:26:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/24 11:59:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/24 12:00:24 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/24 12:23:20 UTC, 0 replies.
- [GitHub] flink pull request #2545: [FLINK-4673] [core] TypeInfoFactory for Either typ... - posted by greghogan <gi...@git.apache.org> on 2016/09/24 12:27:16 UTC, 3 replies.
- [jira] [Commented] (FLINK-4673) TypeInfoFactory for Either type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/24 12:27:20 UTC, 4 replies.
- [jira] [Created] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/24 12:54:20 UTC, 0 replies.
- [GitHub] flink pull request #2546: [FLINK-4329] Fix Streaming File Source Timestamps/... - posted by kl0u <gi...@git.apache.org> on 2016/09/25 15:30:11 UTC, 13 replies.
- [jira] [Commented] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/25 15:30:20 UTC, 21 replies.
- [GitHub] flink pull request #2547: [FLINK-4552] Refactor WindowOperator/Trigger Tests - posted by aljoscha <gi...@git.apache.org> on 2016/09/25 16:55:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/25 16:56:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/09/25 23:57:21 UTC, 0 replies.
- [GitHub] flink issue #2510: FLINK-3322 Allow drivers and iterators to reuse the memor... - posted by ramkrish86 <gi...@git.apache.org> on 2016/09/26 05:09:48 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4489) Implement TaskManager's SlotAllocationTable - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/09/26 07:56:20 UTC, 0 replies.
- [GitHub] flink issue #2545: [FLINK-4673] [core] TypeInfoFactory for Either type - posted by twalthr <gi...@git.apache.org> on 2016/09/26 08:00:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-4632) when yarn nodemanager lost, flink hung - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 08:09:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3674) Add an interface for EventTime aware User Function - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/26 08:56:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3674) Add an interface for Time aware User Function - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/26 08:57:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-3674) Add an interface for Time aware User Functions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/26 08:58:20 UTC, 0 replies.
- [GitHub] flink issue #2547: [FLINK-4552] Refactor WindowOperator/Trigger Tests - posted by zentol <gi...@git.apache.org> on 2016/09/26 09:29:32 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4671) Table API can not be built - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 09:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4676) Merge flink-batch-con - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 11:49:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 11:50:20 UTC, 6 replies.
- [jira] [Assigned] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/09/26 12:12:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4672) TaskManager accidentally decorates Kill messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 12:26:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4672) TaskManager accidentally decorates Kill messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 12:26:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 12:27:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4580) Check that the RpcEndpoint supports the specified RpcGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/26 12:28:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 12:30:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 12:40:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4630) add netty tcp/restful pushed source support - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/26 12:53:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4509) Specify savepoint directory per savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/09/26 12:56:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4511) Schedule periodic savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/09/26 12:57:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4512) Add option for persistent checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/09/26 12:57:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/26 13:00:22 UTC, 0 replies.
- [GitHub] flink pull request #2548: [FLINK-4677] fail if user jar contains no executio... - posted by mxm <gi...@git.apache.org> on 2016/09/26 13:03:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/26 13:04:20 UTC, 3 replies.
- [GitHub] flink pull request #2549: [FLINK-4671] [table] Table API can not be built - posted by twalthr <gi...@git.apache.org> on 2016/09/26 13:12:19 UTC, 3 replies.
- [GitHub] flink issue #2549: [FLINK-4671] [table] Table API can not be built - posted by mxm <gi...@git.apache.org> on 2016/09/26 13:21:55 UTC, 0 replies.
- [GitHub] flink pull request #2540: [FLINK-4606] [cluster management] Integrate the ne... - posted by mxm <gi...@git.apache.org> on 2016/09/26 13:27:55 UTC, 6 replies.
- [jira] [Created] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:29:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4679) Add TumbleRow row-windows for streaming tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4680) Add SlidingRow row-windows for streaming tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4682) Add TumbleRow row-windows for batch tables. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4681) Add SessionRow row-windows for batch tables. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4683) Add SlideRow row-windows for batch tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 13:35:20 UTC, 0 replies.
- [GitHub] flink issue #2540: [FLINK-4606] [cluster management] Integrate the new Resou... - posted by mxm <gi...@git.apache.org> on 2016/09/26 13:48:29 UTC, 2 replies.
- [GitHub] flink issue #2535: [FLINK-4662] Bump Calcite version up to 1.9 - posted by twalthr <gi...@git.apache.org> on 2016/09/26 13:50:09 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4662) Bump Calcite version up to 1.9 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 14:05:20 UTC, 0 replies.
- [GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con... - posted by gyfora <gi...@git.apache.org> on 2016/09/26 14:20:29 UTC, 4 replies.
- [GitHub] flink pull request #2369: [FLINK-4035] Add a streaming connector for Apache ... - posted by rmetzger <gi...@git.apache.org> on 2016/09/26 14:46:05 UTC, 4 replies.
- [jira] [Created] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 15:10:21 UTC, 0 replies.
- [GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ... - posted by twalthr <gi...@git.apache.org> on 2016/09/26 15:22:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4294) Allow access of composite type fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/26 15:23:20 UTC, 0 replies.
- [GitHub] flink pull request #2550: [Flink-4657] Implement HighAvailabilityServices ba... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/26 15:41:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-4410) Report more information about operator checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 15:57:20 UTC, 5 replies.
- [jira] [Created] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/26 16:00:23 UTC, 0 replies.
- [jira] [Created] (FLINK-4686) Add possibility to get column names - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 16:20:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4686) Add possibility to get column names - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 16:20:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 16:56:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4252) Table program cannot be compiled - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 17:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4687) Add getAddress method to RpcService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/26 17:06:20 UTC, 0 replies.
- [GitHub] flink pull request #2551: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/26 17:09:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-4687) Add getAddress method to RpcService - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/26 17:10:20 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4241) Cryptic expression parser exceptions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/26 17:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 18:21:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/26 18:24:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-598) Add support for globalOrdering in DataSet API - posted by "Neelesh Srinivas Salian (JIRA)" <ji...@apache.org> on 2016/09/26 20:01:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4408) Submit Job and setup ExecutionGraph - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/27 01:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4689) Implement a simple slot provider for the new job manager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/27 02:00:26 UTC, 0 replies.
- [jira] [Created] (FLINK-4690) Replace SlotAllocationFuture with flink's own future - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/27 03:59:20 UTC, 0 replies.
- [GitHub] flink pull request #2552: [FLINK-4690] Replace SlotAllocationFuture with fli... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/27 04:12:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-4690) Replace SlotAllocationFuture with flink's own future - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/27 04:13:20 UTC, 3 replies.
- [GitHub] flink issue #2497: [FLINK-4339][cluster management] Implement Slot Pool core... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/27 06:06:43 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators - posted by "MaGuowei (JIRA)" <ji...@apache.org> on 2016/09/27 07:58:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4630) add netty tcp/restful pushed source support - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 08:28:22 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4686) Add possibility to get column names - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/27 08:30:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4671) Table API can not be built - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4691) Add group-windows for streaming tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:39:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4692) Add tumbling and sliding group-windows for batch tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4693) Add session group-windows for batch tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 08:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4694) Add wait for termination function to RpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 08:47:20 UTC, 0 replies.
- [GitHub] flink pull request #2553: [FLINK-4686] [table] Add possibility to get column... - posted by wuchong <gi...@git.apache.org> on 2016/09/27 09:08:45 UTC, 9 replies.
- [jira] [Commented] (FLINK-4686) Add possibility to get column names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/27 09:09:20 UTC, 10 replies.
- [jira] [Commented] (FLINK-3674) Add an interface for Time aware User Functions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/27 09:11:21 UTC, 4 replies.
- [jira] [Commented] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 10:17:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/27 10:28:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/09/27 10:31:21 UTC, 2 replies.
- [GitHub] flink issue #2551: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/27 11:45:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4687) Add getAddress method to RpcService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 11:47:20 UTC, 0 replies.
- [GitHub] flink pull request #2554: [FLINK-4361] Introduce Flink's own future abstract... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/27 11:52:29 UTC, 1 replies.
- [jira] [Created] (FLINK-4695) Separate configuration parsing from MetricRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 12:41:20 UTC, 0 replies.
- [GitHub] flink pull request #2555: [FLINK-4695] Introduce MetricRegistryConfiguration... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/27 12:44:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/27 12:45:21 UTC, 6 replies.
- [jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 12:49:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 12:50:20 UTC, 0 replies.
- [GitHub] flink issue #2552: [FLINK-4690] Replace SlotAllocationFuture with flink's ow... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/27 12:53:02 UTC, 1 replies.
- [jira] [Created] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 12:53:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/09/27 12:54:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 12:57:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 13:03:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 13:03:20 UTC, 0 replies.
- [GitHub] flink issue #2555: [FLINK-4695] Introduce MetricRegistryConfiguration to enc... - posted by zentol <gi...@git.apache.org> on 2016/09/27 13:19:31 UTC, 2 replies.
- [GitHub] flink issue #2554: [FLINK-4361] Introduce Flink's own future abstraction - posted by StephanEwen <gi...@git.apache.org> on 2016/09/27 13:28:13 UTC, 0 replies.
- [GitHub] flink pull request #2102: [FLINK-4068] [tableAPI] Move constant computations... - posted by wuchong <gi...@git.apache.org> on 2016/09/27 13:45:35 UTC, 0 replies.
- [GitHub] flink pull request #2556: [FLINK-4573] Fix potential resource leak due to un... - posted by lw-lin <gi...@git.apache.org> on 2016/09/27 14:17:07 UTC, 4 replies.
- [GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat... - posted by lw-lin <gi...@git.apache.org> on 2016/09/27 14:18:23 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:19:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:20:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:20:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4698) Visualize additional checkpoint information - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 15:44:20 UTC, 0 replies.
- [GitHub] flink issue #2548: [FLINK-4677] fail if user jar contains no executions - posted by StephanEwen <gi...@git.apache.org> on 2016/09/27 15:48:19 UTC, 2 replies.
- [jira] [Created] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/27 15:51:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4700) Harden the TimeProvider test - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/27 16:07:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4583) NullPointerException in CliFrontend - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/27 16:10:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4690) Replace SlotAllocationFuture with flink's own future - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 16:43:21 UTC, 0 replies.
- [GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/27 17:02:32 UTC, 12 replies.
- [jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/27 17:03:20 UTC, 14 replies.
- [jira] [Closed] (FLINK-4695) Separate configuration parsing from MetricRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/27 17:20:22 UTC, 0 replies.
- [GitHub] flink pull request #2444: [FLINK-4543] [network] Fix potential deadlock in S... - posted by asfgit <gi...@git.apache.org> on 2016/09/27 17:48:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4560) enforcer java version as 1.7 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 17:48:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/27 17:48:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4560) enforcer java version as 1.7 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 17:48:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 17:49:21 UTC, 0 replies.
- [jira] [Closed] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 17:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4701) Unprotected access to cancelables in StreamTask - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/09/27 18:04:20 UTC, 0 replies.
- [GitHub] flink issue #2550: [FLINK-4657] Implement HighAvailabilityServices based on ... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/27 18:04:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/27 18:22:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 19:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4702) Kafka consumer must commit offsets asynchronously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/27 19:08:20 UTC, 0 replies.
- [GitHub] flink pull request #2559: [FLINK-4702] [kafka connector] Commit offets to Ka... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/27 19:12:50 UTC, 7 replies.
- [jira] [Commented] (FLINK-4702) Kafka consumer must commit offsets asynchronously - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/27 19:13:21 UTC, 31 replies.
- [jira] [Assigned] (FLINK-4646) Add BipartiteGraph class - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/09/27 22:14:20 UTC, 0 replies.
- [GitHub] flink pull request #2560: [FLINK-4068] [table] Move constant computations ou... - posted by wuchong <gi...@git.apache.org> on 2016/09/28 02:33:40 UTC, 6 replies.
- [jira] [Assigned] (FLINK-4679) Add TumbleRow row-windows for streaming tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/09/28 03:03:20 UTC, 0 replies.
- [GitHub] flink pull request #2543: [FLINK-4670] [cluster management] Add watch mechan... - posted by beyond1920 <gi...@git.apache.org> on 2016/09/28 03:12:57 UTC, 0 replies.
- [GitHub] flink issue #2560: [FLINK-4068] [table] Move constant computations out of co... - posted by twalthr <gi...@git.apache.org> on 2016/09/28 08:59:06 UTC, 4 replies.
- [jira] [Resolved] (FLINK-4505) Implement TaskManagerRunner to construct related components for TaskManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/28 09:16:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4505) Implement TaskManagerRunner to construct related components for TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/28 09:16:20 UTC, 2 replies.
- [jira] [Closed] (FLINK-4505) Implement TaskManagerRunner to construct related components for TaskManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/09/28 09:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasss - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/28 10:38:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/28 10:41:20 UTC, 2 replies.
- [GitHub] flink pull request #2561: [FLINK-4703] RpcCompletenessTest: Add support for ... - posted by mxm <gi...@git.apache.org> on 2016/09/28 10:44:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/28 10:45:21 UTC, 2 replies.
- [GitHub] flink issue #2559: [FLINK-4702] [kafka connector] Commit offets to Kafka asy... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/28 12:02:40 UTC, 9 replies.
- [GitHub] flink pull request #2562: [FLINK-4691] [table] Add group-windows for streami... - posted by twalthr <gi...@git.apache.org> on 2016/09/28 12:15:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-4691) Add group-windows for streaming tables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/28 12:16:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/28 12:33:20 UTC, 2 replies.
- [jira] [Resolved] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/28 12:34:20 UTC, 0 replies.
- [GitHub] flink issue #2546: [FLINK-4329] Fix Streaming File Source Timestamps/Waterma... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/28 13:06:45 UTC, 7 replies.
- [jira] [Commented] (FLINK-4701) Unprotected access to cancelables in StreamTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/28 13:20:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/28 13:26:20 UTC, 0 replies.
- [GitHub] flink issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for I... - posted by senorcarbone <gi...@git.apache.org> on 2016/09/28 13:53:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/28 13:54:21 UTC, 0 replies.
- [GitHub] flink issue #2561: [FLINK-4703] RpcCompletenessTest: Add support for type ar... - posted by mxm <gi...@git.apache.org> on 2016/09/28 16:00:49 UTC, 0 replies.
- [GitHub] flink pull request #2563: [FLINK-3656] [table] Reduce number of ITCases - posted by twalthr <gi...@git.apache.org> on 2016/09/28 16:08:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/28 16:09:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-3656) Rework Table API tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/28 16:09:20 UTC, 4 replies.
- [jira] [Reopened] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/09/28 16:10:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4650) Frequent task manager disconnects from JobManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/09/28 16:28:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-3409) Integrate STOP with Savepoints - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/09/28 16:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4705) Instrument FixedLengthRecordSorter - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/09/28 18:24:20 UTC, 0 replies.
- [GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class - posted by mushketyk <gi...@git.apache.org> on 2016/09/28 21:59:53 UTC, 10 replies.
- [jira] [Created] (FLINK-4706) Is there a way to load user classes first? - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/09/29 02:43:20 UTC, 0 replies.
- [GitHub] flink pull request #2565: [FLINK-4406] [cluster management] Implement job ma... - posted by KurtYoung <gi...@git.apache.org> on 2016/09/29 04:00:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-4406) Implement job master registration at resource manager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/29 04:00:24 UTC, 7 replies.
- [jira] [Updated] (FLINK-4344) Implement new JobManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/09/29 04:11:20 UTC, 0 replies.
- [GitHub] flink issue #2553: [FLINK-4686] [table] Add possibility to get column names - posted by wuchong <gi...@git.apache.org> on 2016/09/29 05:15:47 UTC, 0 replies.
- [jira] [Created] (FLINK-4707) Including flink-connector-filesystem as dependency fails build - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/29 05:58:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-4707) Including flink-connector-filesystem as dependency fails build - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/09/29 06:02:20 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4707) Including flink-connector-filesystem as dependency fails build - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/29 08:14:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4706) Is there a way to load user classes first? - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/29 08:15:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-4704) Move Table API to org.apache.flink.table - posted by "Liwei Lin (JIRA)" <ji...@apache.org> on 2016/09/29 08:38:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-4707) Including flink-connector-filesystem as dependency fails build - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 08:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 08:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream - posted by "Holger Frydrych (JIRA)" <ji...@apache.org> on 2016/09/29 09:01:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 09:02:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4710) Remove transitive Guice dependency from Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 09:04:20 UTC, 0 replies.
- [GitHub] flink issue #2520: [FLINK-4530] [Distributed Coordination] Generalize TaskEx... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/29 09:31:54 UTC, 0 replies.
- [GitHub] flink pull request #2566: [FLINK-3656] [table] Consolidate ITCases - posted by twalthr <gi...@git.apache.org> on 2016/09/29 09:51:18 UTC, 1 replies.
- [GitHub] flink pull request #2520: [FLINK-4530] [Distributed Coordination] Generalize... - posted by zhuhaifengleon <gi...@git.apache.org> on 2016/09/29 09:53:10 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/09/29 09:55:20 UTC, 0 replies.
- [GitHub] flink issue #2542: [FLINK-4613] [ml] Extend ALS to handle implicit feedback ... - posted by gaborhermann <gi...@git.apache.org> on 2016/09/29 10:26:24 UTC, 4 replies.
- [GitHub] flink pull request #2542: [FLINK-4613] [ml] Extend ALS to handle implicit fe... - posted by gaborhermann <gi...@git.apache.org> on 2016/09/29 11:04:08 UTC, 7 replies.
- [GitHub] flink issue #2565: [FLINK-4406] [cluster management] Implement job master re... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/29 12:15:46 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 12:47:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4708) Scope Mini Kerberos Cluster dependencies as test dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 12:47:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4710) Remove transitive Guice dependency from Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 12:47:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4710) Remove transitive Guice dependency from Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/29 12:48:21 UTC, 0 replies.
- [GitHub] flink issue #2557: [FLINK-3734] Close stream state handles after state resto... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/29 13:03:20 UTC, 0 replies.
- [GitHub] flink issue #2556: [FLINK-4573] Fix potential resource leak due to unclosed ... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/29 13:04:20 UTC, 1 replies.
- [GitHub] flink pull request #2567: [FLINK-3656] [table] Convert expression tests to u... - posted by twalthr <gi...@git.apache.org> on 2016/09/29 14:08:57 UTC, 0 replies.
- [GitHub] flink pull request #2568: [FLINK-4636] Add boundary check for priorityqueue ... - posted by jaxbihani <gi...@git.apache.org> on 2016/09/29 14:30:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-4636) AbstractCEPPatternOperator fails to restore state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/29 14:31:20 UTC, 3 replies.
- [jira] [Created] (FLINK-4711) TaskManager can crash due to failing onPartitionStateUpdate call - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 14:35:20 UTC, 0 replies.
- [GitHub] flink pull request #2569: [FLINK-4711] Let the Task trigger partition state ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/29 14:42:28 UTC, 7 replies.
- [jira] [Commented] (FLINK-4711) TaskManager can crash due to failing onPartitionStateUpdate call - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/29 14:43:20 UTC, 9 replies.
- [jira] [Updated] (FLINK-4636) AbstractCEPPatternOperator fails to restore state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/09/29 15:03:20 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4678) Add SessionRow row-windows for streaming tables (FLIP-11) - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/29 15:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4712) Implementing ranking predictions for ALS - posted by "Domokos Miklós Kelen (JIRA)" <ji...@apache.org> on 2016/09/29 15:16:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-4712) Implementing ranking predictions for ALS - posted by "Domokos Miklós Kelen (JIRA)" <ji...@apache.org> on 2016/09/29 15:17:20 UTC, 2 replies.
- [GitHub] flink pull request #2570: [FLINK-3674] Add an interface for Time aware User ... - posted by aljoscha <gi...@git.apache.org> on 2016/09/29 15:21:28 UTC, 0 replies.
- [jira] [Created] (FLINK-4713) Implementing ranking evaluation scores for recommender systems - posted by "Domokos Miklós Kelen (JIRA)" <ji...@apache.org> on 2016/09/29 15:22:20 UTC, 0 replies.
- [GitHub] flink pull request #2571: [FLINK-4348] Simplify logic of SlotManager - posted by mxm <gi...@git.apache.org> on 2016/09/29 15:37:54 UTC, 0 replies.
- [GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests - posted by aljoscha <gi...@git.apache.org> on 2016/09/29 15:51:52 UTC, 0 replies.
- [GitHub] flink pull request #2573: Refactor StreamOperator Hierachy to make Keys Expl... - posted by aljoscha <gi...@git.apache.org> on 2016/09/29 15:53:43 UTC, 0 replies.
- [GitHub] flink issue #2571: [FLINK-4348] Simplify logic of SlotManager - posted by mxm <gi...@git.apache.org> on 2016/09/29 16:11:29 UTC, 7 replies.
- [GitHub] flink pull request #2574: [FLINK-4702] [kafka connector] Commit offsets to K... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/29 16:11:37 UTC, 10 replies.
- [GitHub] flink issue #2569: [FLINK-4711] Let the Task trigger partition state request... - posted by tillrohrmann <gi...@git.apache.org> on 2016/09/29 16:13:49 UTC, 1 replies.
- [GitHub] flink issue #2574: [FLINK-4702] [kafka connector] Commit offsets to Kafka as... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/29 16:13:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-4700) Harden the TimeProvider test - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/09/29 16:35:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4714) Set task state to RUNNING after state has been restored - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 17:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4715) TaskManager should commit suicide after cancellation failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 17:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4716) Add trigger full recovery button to web UI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 17:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4717) Naive version of atomic stop signal with savepoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/29 18:07:20 UTC, 0 replies.
- [GitHub] flink issue #2528: [FLINK-4643] [gelly] Average Clustering Coefficient - posted by StephanEwen <gi...@git.apache.org> on 2016/09/29 18:12:01 UTC, 0 replies.
- [GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class - posted by mushketyk <gi...@git.apache.org> on 2016/09/29 22:16:13 UTC, 5 replies.
- [jira] [Commented] (FLINK-4715) TaskManager should commit suicide after cancellation failure - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/09/30 02:31:20 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4715) TaskManager should commit suicide after cancellation failure - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/09/30 02:32:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4718) Confusing label in Parallel Streams Diagram - posted by "Neil Derraugh (JIRA)" <ji...@apache.org> on 2016/09/30 02:32:21 UTC, 0 replies.
- [GitHub] flink pull request #2575: 'Id' is the key of the stream and not the id of th... - posted by nderraugh <gi...@git.apache.org> on 2016/09/30 02:40:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-4718) Confusing label in Parallel Streams Diagram - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/30 02:40:21 UTC, 2 replies.
- [jira] [Closed] (FLINK-4711) TaskManager can crash due to failing onPartitionStateUpdate call - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/09/30 07:09:20 UTC, 0 replies.
- [GitHub] flink issue #2575: 'Id' is the key of the stream and not the id of the event... - posted by StephanEwen <gi...@git.apache.org> on 2016/09/30 09:25:18 UTC, 3 replies.
- [jira] [Created] (FLINK-4719) KryoSerializer random exception - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/09/30 09:27:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4719) KryoSerializer random exception - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/09/30 09:29:20 UTC, 0 replies.
- [GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager - posted by mxm <gi...@git.apache.org> on 2016/09/30 10:20:02 UTC, 6 replies.
- [jira] [Created] (FLINK-4720) Implement an archived version of the execution graph - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/09/30 10:29:21 UTC, 0 replies.
- [GitHub] flink pull request #2576: [FLINK-4315] Remove Hadoop Dependency from flink-j... - posted by kenmy <gi...@git.apache.org> on 2016/09/30 10:50:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-4604) Add support for standard deviation/variance - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/09/30 11:09:20 UTC, 2 replies.
- [jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2016/09/30 11:15:20 UTC, 3 replies.
- [GitHub] flink pull request #2577: [FLINK-4720] Implement archived version of the Exe... - posted by zentol <gi...@git.apache.org> on 2016/09/30 12:36:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/30 12:37:20 UTC, 1 replies.
- [GitHub] flink pull request #2512: [FLINK-4379] Rescalable non-partitioned state - posted by asfgit <gi...@git.apache.org> on 2016/09/30 12:49:01 UTC, 0 replies.
- [GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG... - posted by zentol <gi...@git.apache.org> on 2016/09/30 12:54:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-4604) Add support for standard deviation/variance - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/09/30 13:05:20 UTC, 0 replies.
- [GitHub] flink pull request #2578: Event B should be unique. - posted by nderraugh <gi...@git.apache.org> on 2016/09/30 13:16:55 UTC, 0 replies.
- [GitHub] flink issue #2578: Event B should be unique. - posted by nderraugh <gi...@git.apache.org> on 2016/09/30 13:32:22 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4702) Kafka consumer must commit offsets asynchronously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/30 14:49:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/30 14:50:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/30 14:50:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4379) Add Rescalable Non-Partitioned State - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/30 14:51:20 UTC, 0 replies.
- [jira] [Closed] (FLINK-4379) Add Rescalable Non-Partitioned State - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/09/30 14:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation - posted by "Ashish Walia (JIRA)" <ji...@apache.org> on 2016/09/30 19:52:20 UTC, 0 replies.
- [GitHub] flink pull request #2579: [FLINK-4618] FlinkKafkaConsumer09 should start fro... - posted by static-max <gi...@git.apache.org> on 2016/09/30 21:07:52 UTC, 0 replies.
- [GitHub] flink pull request #757: [FLINK-2131][ml]: Initialization schemes for k-mean... - posted by skonto <gi...@git.apache.org> on 2016/09/30 22:31:49 UTC, 8 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/09/30 22:32:20 UTC, 9 replies.
- [GitHub] flink issue #757: [FLINK-2131][ml]: Initialization schemes for k-means clust... - posted by skonto <gi...@git.apache.org> on 2016/09/30 22:34:17 UTC, 0 replies.