issues@flink.apache.org, 2016-11

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

- [GitHub] flink pull request #2727: [FLINK-4923] [Metrics] Initializes patch for Expos... - posted by zhuhaifengleon <gi...@git.apache.org> on 2016/11/01 03:01:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 03:01:59 UTC, 2 replies.
- [jira] [Closed] (FLINK-4885) Improve the Elasticsearch configuration flexibility - posted by "Mike Dias (JIRA)" <ji...@apache.org> on 2016/11/01 03:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4988) Elasticsearch 5.x support - posted by "Mike Dias (JIRA)" <ji...@apache.org> on 2016/11/01 03:21:58 UTC, 0 replies.
- [GitHub] flink pull request #2736: [FLINK-4174] Enhance evictor functionality - posted by soniclavier <gi...@git.apache.org> on 2016/11/01 03:43:44 UTC, 17 replies.
- [jira] [Commented] (FLINK-4174) Enhance Window Evictor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 03:43:58 UTC, 25 replies.
- [GitHub] flink issue #2686: [FLINK-4743] The sqrt/power function not accept the real ... - posted by tonycox <gi...@git.apache.org> on 2016/11/01 08:06:24 UTC, 5 replies.
- [jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 08:06:58 UTC, 17 replies.
- [jira] [Commented] (FLINK-4193) Task manager JVM crashes while deploying cancelling jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/01 08:33:58 UTC, 0 replies.
- [GitHub] flink issue #2699: [FLINK-4887] [execution graph] Introduce TaskManagerGatew... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 08:36:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 08:36:59 UTC, 1 replies.
- [GitHub] flink pull request #2699: [FLINK-4887] [execution graph] Introduce TaskManag... - posted by asfgit <gi...@git.apache.org> on 2016/11/01 08:38:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/01 08:38:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4987) Harden slot pool logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/01 08:42:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4986) Harden JobMaster logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/01 08:43:58 UTC, 0 replies.
- [GitHub] flink issue #2721: [FLINK-4958] [tm] Send slot report to RM when registering - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 08:44:31 UTC, 0 replies.
- [GitHub] flink pull request #2721: [FLINK-4958] [tm] Send slot report to RM when regi... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 08:44:31 UTC, 0 replies.
- [jira] [Closed] (FLINK-4958) Send slot report to RM when registering - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/01 08:44:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4958) Send slot report to RM when registering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 08:44:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4940) Add Support for Broadcast/Global State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/01 09:57:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3659) Add ConnectWithBroadcast Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/01 10:01:10 UTC, 6 replies.
- [jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/01 10:11:59 UTC, 6 replies.
- [GitHub] flink issue #2732: [FLINK-4272] Create a JobClient for job control and monit... - posted by mxm <gi...@git.apache.org> on 2016/11/01 11:06:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-4272) Create a JobClient for job control and monitoring - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 11:06:58 UTC, 62 replies.
- [jira] [Comment Edited] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "Lim Chee Hau (JIRA)" <ji...@apache.org> on 2016/11/01 12:21:58 UTC, 0 replies.
- [GitHub] flink pull request #2701: [backport] [FLINK-4933] [exec graph] Don't let the... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 13:08:08 UTC, 0 replies.
- [GitHub] flink issue #2701: [backport] [FLINK-4933] [exec graph] Don't let the EG fai... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 13:08:08 UTC, 0 replies.
- [GitHub] flink pull request #2711: [backport] [FLINK-4932] [exec graph] Failing in st... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 13:08:26 UTC, 0 replies.
- [GitHub] flink issue #2711: [backport] [FLINK-4932] [exec graph] Failing in state RES... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/01 13:08:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-4932) Don't let ExecutionGraph fail when in state Restarting - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 13:08:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 13:08:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4832) Count/Sum 0 elements - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/01 13:34:58 UTC, 30 replies.
- [jira] [Closed] (FLINK-4889) Make InstanceManager independent of ActorRef - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/01 14:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2737: [FLINK-4983] Web UI: Add favicon - posted by siliconcat <gi...@git.apache.org> on 2016/11/01 14:28:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-4983) Web UI: Add favicon - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 14:28:58 UTC, 11 replies.
- [jira] [Commented] (FLINK-4982) quickstart example: Can't see the output - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/11/01 14:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4989) Completed job -> Properties: Misleading label - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/11/01 15:01:58 UTC, 0 replies.
- [GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon - posted by Makman2 <gi...@git.apache.org> on 2016/11/01 15:03:33 UTC, 9 replies.
- [jira] [Updated] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/01 15:48:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4977) Enum serialization does not work properly - posted by "Sean Winard (JIRA)" <ji...@apache.org> on 2016/11/01 16:04:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4977) Enum serialization does not work in all cases - posted by "Sean Winard (JIRA)" <ji...@apache.org> on 2016/11/01 16:06:58 UTC, 0 replies.
- [GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts - posted by greghogan <gi...@git.apache.org> on 2016/11/01 16:39:45 UTC, 8 replies.
- [jira] [Commented] (FLINK-4861) Package optional project artifacts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 16:39:58 UTC, 8 replies.
- [GitHub] flink pull request #2685: [FLINK-4884] Eagerly Store MergingWindowSet in Sta... - posted by aljoscha <gi...@git.apache.org> on 2016/11/01 16:49:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 16:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/01 16:51:58 UTC, 0 replies.
- [GitHub] flink issue #2723: [FLINK-3617] Simple fix for OptionSerializer. - posted by StephanEwen <gi...@git.apache.org> on 2016/11/01 19:12:30 UTC, 5 replies.
- [jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 19:12:58 UTC, 9 replies.
- [jira] [Commented] (FLINK-4977) Enum serialization does not work in all cases - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/01 19:33:59 UTC, 1 replies.
- [GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on... - posted by asfgit <gi...@git.apache.org> on 2016/11/01 20:14:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/01 20:14:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4447) Include NettyConfig options on Configurations page - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/01 20:14:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/01 20:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4990) Remove JAR option from savepoint disposal - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/01 20:29:58 UTC, 0 replies.
- [GitHub] flink issue #2734: Keytab & TLS support for Flink on Mesos Setup - posted by vijikarthi <gi...@git.apache.org> on 2016/11/01 22:25:17 UTC, 2 replies.
- [GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th... - posted by wuchong <gi...@git.apache.org> on 2016/11/02 01:55:41 UTC, 11 replies.
- [GitHub] flink pull request #2712: [FLINK-4445] Add option to ignore unmapped checkpo... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 06:36:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-4445) Ignore unmatched state when restoring from savepoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 06:36:58 UTC, 1 replies.
- [GitHub] flink pull request #2714: [FLINK-4935] [webfrontend] Submit job with savepoi... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 07:08:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-4935) Submit job with savepoint via REST API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 07:08:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4935) Submit job with savepoint via REST API - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 07:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4445) Ignore unmatched state when restoring from savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 07:17:58 UTC, 0 replies.
- [GitHub] flink pull request #2713: [backport] [FLINK-4445] Add option to ignore unmap... - posted by uce <gi...@git.apache.org> on 2016/11/02 07:18:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 07:20:58 UTC, 1 replies.
- [jira] [Created] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 07:22:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4832) Count/Sum 0 elements - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/02 08:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/02 08:47:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 09:11:58 UTC, 2 replies.
- [GitHub] flink issue #2727: [FLINK-4923] [Metrics] Initializes patch for Expose input... - posted by zentol <gi...@git.apache.org> on 2016/11/02 09:25:25 UTC, 0 replies.
- [GitHub] flink pull request #2738: [FLINK-4991] [taskmanager] Fix too aggressive time... - posted by uce <gi...@git.apache.org> on 2016/11/02 09:30:27 UTC, 1 replies.
- [GitHub] flink issue #2722: [FLINK-4845] [runtime-web] Fix Job Exception page - posted by zentol <gi...@git.apache.org> on 2016/11/02 09:30:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-4845) Fix Job Exceptions page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 09:30:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 09:30:58 UTC, 5 replies.
- [GitHub] flink pull request #2739: [FLINK-4991] [taskmanager] Fix too aggressive time... - posted by uce <gi...@git.apache.org> on 2016/11/02 09:31:34 UTC, 1 replies.
- [GitHub] flink pull request #2722: [FLINK-4845] [runtime-web] Fix Job Exception page - posted by asfgit <gi...@git.apache.org> on 2016/11/02 09:49:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-4845) Fix Job Exceptions page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/02 09:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/02 09:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 09:51:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 10:32:59 UTC, 0 replies.
- [GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c... - posted by zentol <gi...@git.apache.org> on 2016/11/02 10:35:02 UTC, 24 replies.
- [jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 10:35:58 UTC, 29 replies.
- [GitHub] flink issue #2706: [FLINK-4945] KafkaConsumer logs wrong warning about confi... - posted by rmetzger <gi...@git.apache.org> on 2016/11/02 11:02:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 11:02:58 UTC, 1 replies.
- [GitHub] flink pull request #2683: [FLINK-4888][metrics] instantiated job manager met... - posted by rmetzger <gi...@git.apache.org> on 2016/11/02 11:21:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 11:21:58 UTC, 0 replies.
- [GitHub] flink issue #2633: [FLINK-4497] CassadraSink support for scala tuples/case c... - posted by zentol <gi...@git.apache.org> on 2016/11/02 11:22:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 11:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2740: Implement StringIndexer - posted by tfournier314 <gi...@git.apache.org> on 2016/11/02 13:05:31 UTC, 0 replies.
- [GitHub] flink issue #2740: Implement StringIndexer - posted by tfournier314 <gi...@git.apache.org> on 2016/11/02 13:09:21 UTC, 1 replies.
- [jira] [Created] (FLINK-4994) Don't Clear Trigger State and Merging Window Set When Purging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 13:23:00 UTC, 0 replies.
- [GitHub] flink issue #2738: [FLINK-4991] [taskmanager] Fix too aggressive timeout and... - posted by uce <gi...@git.apache.org> on 2016/11/02 13:59:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/02 14:02:58 UTC, 10 replies.
- [GitHub] flink issue #2484: [FLINK-4177] Harden CassandraConnectorTest - posted by zentol <gi...@git.apache.org> on 2016/11/02 14:11:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 14:11:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/11/02 14:12:58 UTC, 7 replies.
- [jira] [Commented] (FLINK-4713) Implementing ranking evaluation scores for recommender systems - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2016/11/02 14:20:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/02 14:22:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/02 14:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2706: [FLINK-4945] KafkaConsumer logs wrong warning abou... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 14:23:02 UTC, 0 replies.
- [jira] [Created] (FLINK-4995) YarnFlinkResourceManagerTest JobManager Lost Leadership test failed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 14:23:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 14:27:58 UTC, 0 replies.
- [GitHub] flink issue #2720: [FLINK-4623] Create Physical Execution Plan of a DataStre... - posted by fhueske <gi...@git.apache.org> on 2016/11/02 14:29:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-4623) Create Physical Execution Plan of a DataStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 14:29:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 14:31:58 UTC, 16 replies.
- [jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 14:35:58 UTC, 1 replies.
- [GitHub] flink issue #2637: [FLINK-4315] Deprecate Hadoop dependent methods in flink-... - posted by kenmy <gi...@git.apache.org> on 2016/11/02 14:56:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 14:56:58 UTC, 3 replies.
- [jira] [Created] (FLINK-4996) Make CrossHint @Public - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/02 15:02:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4997) Extending Window Function Metadata - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2016/11/02 15:04:58 UTC, 1 replies.
- [jira] [Created] (FLINK-4997) Extending Window Function Metadata - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2016/11/02 15:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/02 15:42:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/02 15:43:58 UTC, 3 replies.
- [GitHub] flink pull request #2741: [FLINK-4998][yarn] fail if too many task slots are... - posted by mxm <gi...@git.apache.org> on 2016/11/02 15:48:37 UTC, 1 replies.
- [GitHub] flink pull request #2742: [FLINK-4944] Replace Akka's death watch with own h... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/02 15:59:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 15:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/02 16:01:02 UTC, 0 replies.
- [GitHub] flink pull request #2743: [FLINK-4996] [core] Make CrossHint @Public - posted by greghogan <gi...@git.apache.org> on 2016/11/02 16:41:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-4996) Make CrossHint @Public - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 16:41:58 UTC, 2 replies.
- [GitHub] flink issue #2741: [FLINK-4998][yarn] fail if too many task slots are config... - posted by mxm <gi...@git.apache.org> on 2016/11/02 16:47:48 UTC, 0 replies.
- [GitHub] flink issue #2684: Add EvaluateDataSet Operation for LabeledVector - This cl... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/02 17:07:00 UTC, 1 replies.
- [GitHub] flink issue #2658: [FLINK-4850] [ml] FlinkML - SVM predict Operation for Vec... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/02 17:10:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 17:10:59 UTC, 1 replies.
- [GitHub] flink issue #2743: [FLINK-4996] [core] Make CrossHint @Public - posted by fhueske <gi...@git.apache.org> on 2016/11/02 17:13:20 UTC, 0 replies.
- [GitHub] flink pull request #2658: [FLINK-4850] [ml] FlinkML - SVM predict Operation ... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 17:14:17 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/02 17:14:58 UTC, 0 replies.
- [GitHub] flink issue #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN - posted by fhueske <gi...@git.apache.org> on 2016/11/02 17:16:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 17:16:59 UTC, 1 replies.
- [jira] [Created] (FLINK-5000) Rename Methods in ManagedInitializationContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 17:32:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5000) Rename Methods in ManagedInitializationContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 17:32:58 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/02 17:47:58 UTC, 8 replies.
- [jira] [Created] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/02 20:18:58 UTC, 0 replies.
- [GitHub] flink pull request #2637: [FLINK-4315] Deprecate Hadoop dependent methods in... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 20:47:42 UTC, 0 replies.
- [GitHub] flink pull request #2720: [FLINK-4623] Create Physical Execution Plan of a D... - posted by asfgit <gi...@git.apache.org> on 2016/11/02 20:47:42 UTC, 0 replies.
- [GitHub] flink pull request #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN - posted by asfgit <gi...@git.apache.org> on 2016/11/02 20:47:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-4996) Make CrossHint @Public - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/02 20:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/02 20:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4623) Create Physical Execution Plan of a DataStream - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/02 20:53:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4743) The sqrt/power function not accept the real data types. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/02 20:54:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/02 20:55:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/02 21:39:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/02 21:40:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4990) Remove JAR option from savepoint disposal - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/02 21:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/02 22:06:58 UTC, 0 replies.
- [GitHub] flink issue #2740: [FLINK-4964] [ml] - posted by tfournier314 <gi...@git.apache.org> on 2016/11/02 22:21:01 UTC, 11 replies.
- [jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/02 22:21:58 UTC, 20 replies.
- [GitHub] flink issue #2510: FLINK-3322 Allow drivers and iterators to reuse the memor... - posted by ramkrish86 <gi...@git.apache.org> on 2016/11/03 04:57:37 UTC, 1 replies.
- [GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc... - posted by ramkrish86 <gi...@git.apache.org> on 2016/11/03 04:57:37 UTC, 0 replies.
- [jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 04:57:58 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/11/03 07:10:58 UTC, 13 replies.
- [GitHub] flink pull request #2744: [FLINK-4928] [yarn] Implement FLIP-6 YARN Applicat... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/03 08:48:35 UTC, 22 replies.
- [jira] [Commented] (FLINK-4928) Implement FLIP-6 YARN Application Master Runner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 08:48:58 UTC, 25 replies.
- [jira] [Created] (FLINK-5003) Provide Access to State Stores in Operator Snapshot Context - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/03 09:23:58 UTC, 0 replies.
- [GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f... - posted by wuchong <gi...@git.apache.org> on 2016/11/03 09:50:18 UTC, 14 replies.
- [jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 09:50:58 UTC, 113 replies.
- [jira] [Updated] (FLINK-4840) Measure latency of record processing and expose it as a metric - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/03 10:01:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/03 10:06:58 UTC, 1 replies.
- [GitHub] flink pull request #2745: [yarn] fix debug string displayed for failed appli... - posted by mxm <gi...@git.apache.org> on 2016/11/03 10:07:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/03 10:34:58 UTC, 11 replies.
- [GitHub] flink pull request #2746: [hotfix] SubtaskState::hasState ignores raw operat... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/03 10:36:41 UTC, 0 replies.
- [GitHub] flink issue #2746: [hotfix] SubtaskState::hasState ignores raw operator stat... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/03 10:36:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/03 10:59:58 UTC, 1 replies.
- [GitHub] flink pull request #2747: [FLINK-4960] Allow the AbstractStreamOperatorTestH... - posted by kl0u <gi...@git.apache.org> on 2016/11/03 11:09:10 UTC, 3 replies.
- [jira] [Commented] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 11:09:58 UTC, 7 replies.
- [GitHub] flink issue #2747: [FLINK-4960] Allow the AbstractStreamOperatorTestHarness ... - posted by kl0u <gi...@git.apache.org> on 2016/11/03 11:10:51 UTC, 3 replies.
- [jira] [Assigned] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/03 11:10:58 UTC, 0 replies.
- [GitHub] flink pull request #2425: FLINK-3930 Added shared secret based authorization... - posted by mxm <gi...@git.apache.org> on 2016/11/03 11:32:53 UTC, 22 replies.
- [jira] [Commented] (FLINK-3930) Implement Service-Level Authorization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 11:32:59 UTC, 28 replies.
- [jira] [Created] (FLINK-5004) Add task manager option to disable queryable state server - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 12:26:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4545) Flink automatically manages TM network buffer - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/11/03 12:37:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-3089) OperatorState timeout - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/03 12:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5005) Publish Scala 2.12 artifacts - posted by "Andrew Roberts (JIRA)" <ji...@apache.org> on 2016/11/03 13:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 13:23:59 UTC, 0 replies.
- [GitHub] flink pull request #2748: [FLINK-5004] [runtime] Add option to disable query... - posted by uce <gi...@git.apache.org> on 2016/11/03 13:26:03 UTC, 3 replies.
- [jira] [Commented] (FLINK-5004) Add task manager option to disable queryable state server - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 13:26:59 UTC, 4 replies.
- [jira] [Commented] (FLINK-5005) Publish Scala 2.12 artifacts - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/03 13:35:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/03 14:12:58 UTC, 2 replies.
- [GitHub] flink pull request #2749: [FLINK-3813][yarn] wait for CLI to complete before... - posted by mxm <gi...@git.apache.org> on 2016/11/03 14:14:02 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/03 14:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5007) Retain externalized checkpoint on suspension - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 14:46:59 UTC, 0 replies.
- [GitHub] flink pull request #2750: [FLINK-5007] [checkpointing] Retain externalized c... - posted by uce <gi...@git.apache.org> on 2016/11/03 14:54:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-5007) Retain externalized checkpoint on suspension - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 14:54:58 UTC, 1 replies.
- [GitHub] flink issue #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the creating... - posted by kl0u <gi...@git.apache.org> on 2016/11/03 15:02:25 UTC, 4 replies.
- [GitHub] flink pull request #2751: Window operator changes - posted by aljoscha <gi...@git.apache.org> on 2016/11/03 15:09:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 15:09:58 UTC, 5 replies.
- [jira] [Created] (FLINK-5008) Update IDE setup documentation - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/03 15:10:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5008) Update IDE setup documentation - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/03 15:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi... - posted by mbalassi <gi...@git.apache.org> on 2016/11/03 15:14:14 UTC, 18 replies.
- [jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 15:14:58 UTC, 22 replies.
- [GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp... - posted by mbalassi <gi...@git.apache.org> on 2016/11/03 15:28:36 UTC, 3 replies.
- [GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/03 15:30:56 UTC, 176 replies.
- [jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 15:31:01 UTC, 189 replies.
- [jira] [Created] (FLINK-5009) FS checkpoints leave empty directory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 15:31:01 UTC, 0 replies.
- [GitHub] flink pull request #2752: [FLINK-4814] [checkpointing] Use checkpoint direct... - posted by uce <gi...@git.apache.org> on 2016/11/03 16:03:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 16:03:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/03 16:07:58 UTC, 0 replies.
- [GitHub] flink pull request #2740: [FLINK-4964] [ml] - posted by greghogan <gi...@git.apache.org> on 2016/11/03 17:01:52 UTC, 8 replies.
- [jira] [Created] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/11/03 17:02:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/11/03 17:05:58 UTC, 3 replies.
- [GitHub] flink issue #2735: [FLINK-2094] implements Word2Vec for FlinkML - posted by thvasilo <gi...@git.apache.org> on 2016/11/03 17:11:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-2094) Implement Word2Vec - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 17:11:58 UTC, 1 replies.
- [GitHub] flink pull request #2680: [FLINK-4876] Allow web interface to be bound to a ... - posted by uce <gi...@git.apache.org> on 2016/11/03 17:15:14 UTC, 5 replies.
- [jira] [Commented] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 17:15:59 UTC, 9 replies.
- [jira] [Commented] (FLINK-4865) FlinkML - Add EvaluateDataSet operation for LabeledVector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/03 17:41:58 UTC, 0 replies.
- [GitHub] flink issue #2684: [FLINK-4865] [ml] Add EvaluateDataSet operation for Label... - posted by tfournier314 <gi...@git.apache.org> on 2016/11/03 17:41:58 UTC, 0 replies.
- [GitHub] flink issue #2680: [FLINK-4876] Allow web interface to be bound to a specifi... - posted by attachmentgenie <gi...@git.apache.org> on 2016/11/03 21:05:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/11/03 22:06:59 UTC, 0 replies.
- [GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl... - posted by vijikarthi <gi...@git.apache.org> on 2016/11/03 22:30:08 UTC, 5 replies.
- [GitHub] flink issue #2736: [FLINK-4174] Enhance evictor functionality - posted by soniclavier <gi...@git.apache.org> on 2016/11/03 23:05:33 UTC, 7 replies.
- [GitHub] flink issue #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML - posted by kalmanchapman <gi...@git.apache.org> on 2016/11/04 00:16:54 UTC, 0 replies.
- [GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ... - posted by bjlovegithub <gi...@git.apache.org> on 2016/11/04 02:48:17 UTC, 12 replies.
- [GitHub] flink pull request #2753: [FLINK-4840] [metrics] Measure latency of record p... - posted by zhuhaifengleon <gi...@git.apache.org> on 2016/11/04 07:30:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-4840) Measure latency of record processing and expose it as a metric - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 07:30:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-4960) Allow the AbstractStreamOperatorTestHarness to test scaling down - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 09:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/04 09:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/04 09:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5014) RocksDBStateBackend misses good toString - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/04 10:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/04 10:11:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/04 10:21:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/04 10:22:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/04 10:41:58 UTC, 2 replies.
- [GitHub] flink pull request #2724: [FLINK-4221] Show metrics in WebFrontend + general... - posted by uce <gi...@git.apache.org> on 2016/11/04 11:25:03 UTC, 10 replies.
- [jira] [Commented] (FLINK-4221) Show metrics in WebFrontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 11:25:58 UTC, 15 replies.
- [GitHub] flink pull request #2754: [FLINK-4975] [checkpointing] Add a limit for how m... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/04 12:18:28 UTC, 17 replies.
- [jira] [Commented] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 12:18:58 UTC, 23 replies.
- [jira] [Created] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/04 12:28:58 UTC, 0 replies.
- [GitHub] flink issue #2753: [FLINK-4840] [metrics] Measure latency of record processi... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/04 12:30:29 UTC, 0 replies.
- [jira] [Created] (FLINK-5018) User configurable source idle timeout to work with WatermarkStatus emitting - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/04 12:43:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/04 12:44:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/11/04 12:59:58 UTC, 9 replies.
- [GitHub] flink pull request #2592: FLINK-4596: Fallback restart strategy config to le... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/04 13:16:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-4596) RESTART_STRATEGY is not really pluggable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 13:16:58 UTC, 2 replies.
- [GitHub] flink issue #2592: FLINK-4596: Fallback restart strategy config to let jobs ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/04 13:17:33 UTC, 0 replies.
- [jira] [Updated] (FLINK-5008) Update quickstart documentation - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/04 13:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5019) Proper isRestored result for tasks that did not write state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/04 13:17:58 UTC, 0 replies.
- [GitHub] flink pull request #2708: [FLINK-4946] [scripts] Load jar files from subdire... - posted by uce <gi...@git.apache.org> on 2016/11/04 13:19:22 UTC, 3 replies.
- [jira] [Commented] (FLINK-4946) Load jar files from subdirectories of lib - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 13:19:58 UTC, 7 replies.
- [GitHub] flink issue #2748: [FLINK-5004] [runtime] Add option to disable queryable st... - posted by uce <gi...@git.apache.org> on 2016/11/04 13:35:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/04 13:40:58 UTC, 13 replies.
- [GitHub] flink issue #2724: [FLINK-4221] Show metrics in WebFrontend + general improv... - posted by rmetzger <gi...@git.apache.org> on 2016/11/04 13:44:47 UTC, 4 replies.
- [GitHub] flink pull request #2746: [FLINK-5019] Proper isRestored result for tasks th... - posted by aljoscha <gi...@git.apache.org> on 2016/11/04 13:54:33 UTC, 5 replies.
- [jira] [Commented] (FLINK-5019) Proper isRestored result for tasks that did not write state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 13:54:58 UTC, 6 replies.
- [jira] [Resolved] (FLINK-4596) RESTART_STRATEGY is not really pluggable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/04 13:59:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4977) Enum serialization does not work in all cases - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/04 13:59:58 UTC, 0 replies.
- [GitHub] flink issue #2746: [FLINK-5019] Proper isRestored result for tasks that did ... - posted by aljoscha <gi...@git.apache.org> on 2016/11/04 14:00:13 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/11/04 14:05:58 UTC, 0 replies.
- [GitHub] flink issue #2703: [FLINK-4900] flink-master: Allow to deploy TM with contai... - posted by mxm <gi...@git.apache.org> on 2016/11/04 14:08:01 UTC, 4 replies.
- [jira] [Commented] (FLINK-4900) Implement Docker image support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 14:08:59 UTC, 9 replies.
- [jira] [Closed] (FLINK-4977) Enum serialization does not work in all cases - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/04 14:11:58 UTC, 0 replies.
- [GitHub] flink pull request #2755: [hotfix][docs] Stream joins don't support tuple po... - posted by rmetzger <gi...@git.apache.org> on 2016/11/04 14:41:41 UTC, 1 replies.
- [jira] [Created] (FLINK-5020) Make the GenericWriteAheadSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ... - posted by sunjincheng121 <gi...@git.apache.org> on 2016/11/04 15:17:55 UTC, 98 replies.
- [jira] [Closed] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:22:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4433) Refactor the StreamSource. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:23:58 UTC, 0 replies.
- [GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata - posted by VenturaDelMonte <gi...@git.apache.org> on 2016/11/04 15:24:17 UTC, 8 replies.
- [jira] [Commented] (FLINK-4997) Extending Window Function Metadata - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 15:24:58 UTC, 14 replies.
- [jira] [Created] (FLINK-5021) Make the ContinuousFileReaderOperator rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:25:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5020) Make the GenericWriteAheadSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/04 15:27:58 UTC, 0 replies.
- [GitHub] flink pull request #2757: [FLINK-5022] Suppress RejectedExecutionExceptions ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/04 15:29:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 15:29:58 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/04 15:47:58 UTC, 7 replies.
- [GitHub] flink pull request #2758: support specifying an ESCAPE character in LIKE and... - posted by miaoever <gi...@git.apache.org> on 2016/11/04 16:01:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Leo Deng (JIRA)" <ji...@apache.org> on 2016/11/04 16:02:58 UTC, 0 replies.
- [GitHub] flink issue #2758: support specifying an ESCAPE character in LIKE and SIMILA... - posted by miaoever <gi...@git.apache.org> on 2016/11/04 16:11:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-3767) Show timeline also for running tasks, not only for finished ones - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/04 16:30:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-3395) Polishing the web UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/04 16:31:58 UTC, 0 replies.
- [GitHub] flink pull request #2759: [FLINK-5020] Make the GenericWriteAheadSink rescal... - posted by kl0u <gi...@git.apache.org> on 2016/11/04 18:13:44 UTC, 7 replies.
- [jira] [Commented] (FLINK-5020) Make the GenericWriteAheadSink rescalable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/04 18:13:58 UTC, 9 replies.
- [GitHub] flink issue #2757: [FLINK-5022] Suppress RejectedExecutionExceptions if the ... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/04 18:46:02 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/04 19:11:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/04 19:16:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4221) Show metrics in WebFrontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/04 20:59:59 UTC, 0 replies.
- [GitHub] flink pull request #2355: [FLINK-4282]Add Offset Parameter to WindowAssigner... - posted by soniclavier <gi...@git.apache.org> on 2016/11/05 02:59:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 02:59:59 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4938) Unnecessary update() call for Views to be removed in ViewUpdater#run() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/05 04:40:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/05 04:41:59 UTC, 2 replies.
- [GitHub] flink pull request #2758: [FLINK-4260] Support specifying ESCAPE character i... - posted by wuchong <gi...@git.apache.org> on 2016/11/05 09:40:50 UTC, 8 replies.
- [jira] [Commented] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 09:40:59 UTC, 15 replies.
- [GitHub] flink pull request #2760: [FLINK-5014] [RocksDB backend] add toString for Ro... - posted by melentye <gi...@git.apache.org> on 2016/11/05 11:16:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-5014) RocksDBStateBackend misses good toString - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 11:16:58 UTC, 2 replies.
- [GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaiming Exam... - posted by ch33hau <gi...@git.apache.org> on 2016/11/05 17:12:31 UTC, 9 replies.
- [jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 17:12:58 UTC, 11 replies.
- [GitHub] flink issue #2730: [FLINK-4970] [gelly] Parameterize vertex value for SSSP - posted by vasia <gi...@git.apache.org> on 2016/11/05 18:00:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-4970) Parameterize vertex value for SSSP - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 18:01:02 UTC, 3 replies.
- [GitHub] flink issue #2733: [FLINK-4896] [gelly] PageRank algorithm for directed grap... - posted by vasia <gi...@git.apache.org> on 2016/11/05 18:40:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-4896) PageRank algorithm for directed graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 18:40:58 UTC, 0 replies.
- [GitHub] flink pull request #2762: [FLINK-3873] Implement Kafka TableSink with Avro s... - posted by mushketyk <gi...@git.apache.org> on 2016/11/05 23:31:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-3873) Add a Kafka TableSink with Avro serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/05 23:31:58 UTC, 4 replies.
- [jira] [Updated] (FLINK-5021) Makes the ContinuousFileReaderOperator rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/05 23:46:58 UTC, 0 replies.
- [GitHub] flink issue #2731: [FLINK-4934] [gelly] Triadic Census - posted by vasia <gi...@git.apache.org> on 2016/11/06 14:39:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-4934) Triadic Census - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/06 14:39:58 UTC, 3 replies.
- [GitHub] flink issue #2431: [FLINK-4521][web frontend] Fix "Submit new Job" panel in ... - posted by mushketyk <gi...@git.apache.org> on 2016/11/06 16:51:07 UTC, 5 replies.
- [jira] [Commented] (FLINK-4521) Fix "Submit new Job" panel in development mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/06 16:51:58 UTC, 5 replies.
- [GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class - posted by mushketyk <gi...@git.apache.org> on 2016/11/06 19:31:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/06 19:31:59 UTC, 11 replies.
- [GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class - posted by mushketyk <gi...@git.apache.org> on 2016/11/06 21:39:05 UTC, 5 replies.
- [GitHub] flink pull request #2448: [FLINK-3030][web frontend] Enhance dashboard to sh... - posted by mushketyk <gi...@git.apache.org> on 2016/11/06 21:40:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/06 21:40:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5023) Add get() method in State interface - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/07 02:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/07 02:24:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4856) Add MapState for keyed streams - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/07 02:27:58 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4856) Add MapState for keyed streams - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/07 02:29:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5018) User configurable source idle timeout to work with WatermarkStatus emitting - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/07 09:27:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-4937) Add incremental group window aggregation for streaming Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/07 09:28:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5018) User configurable source idle timeout to work with WatermarkStatus emitting - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/07 09:28:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4354) Implement TaskManager side of heartbeat from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/07 09:38:59 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4354) Implement TaskManager side of heartbeat from ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/07 09:41:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-5023) Add get() method in State interface - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 10:13:59 UTC, 23 replies.
- [jira] [Created] (FLINK-5025) Job fails because of Optimizer bug - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/11/07 10:19:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5025) Job fails because of Optimizer bug - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/11/07 10:23:59 UTC, 3 replies.
- [jira] [Closed] (FLINK-5025) Job fails because of Optimizer bug - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/07 10:27:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/07 10:27:59 UTC, 7 replies.
- [jira] [Closed] (FLINK-5004) Add task manager option to disable queryable state server - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/07 10:27:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 10:30:58 UTC, 5 replies.
- [GitHub] flink pull request #2763: [FLINK-5021] Makes the ContinuousFileReaderOperato... - posted by kl0u <gi...@git.apache.org> on 2016/11/07 10:33:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-5021) Makes the ContinuousFileReaderOperator rescalable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 10:34:00 UTC, 2 replies.
- [GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation - posted by NicoK <gi...@git.apache.org> on 2016/11/07 10:52:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-5008) Update quickstart documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 10:52:58 UTC, 8 replies.
- [jira] [Commented] (FLINK-4492) Cleanup files from canceled snapshots - posted by "Nikolay Vasilishin (JIRA)" <ji...@apache.org> on 2016/11/07 12:08:58 UTC, 0 replies.
- [GitHub] flink issue #2759: [FLINK-5020] Make the GenericWriteAheadSink rescalable. - posted by zentol <gi...@git.apache.org> on 2016/11/07 12:21:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 13:08:58 UTC, 7 replies.
- [jira] [Created] (FLINK-5026) Rename TimelyFlatMap to Process - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 13:24:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5026) Rename TimelyFlatMap to Process - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 13:26:58 UTC, 24 replies.
- [GitHub] flink issue #2762: [FLINK-3873] Implement Kafka TableSink with Avro serializ... - posted by fhueske <gi...@git.apache.org> on 2016/11/07 13:43:29 UTC, 3 replies.
- [GitHub] flink issue #2764: [FLINK-5008] Update quickstart documentation - posted by greghogan <gi...@git.apache.org> on 2016/11/07 13:57:23 UTC, 7 replies.
- [jira] [Closed] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/07 14:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5027) FileSource finishes successfully with a wrong path - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/07 15:15:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4890) FileInputFormatTest#testExcludeFiles fails on Windows OS - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/07 15:18:59 UTC, 1 replies.
- [GitHub] flink pull request #2715: Fix timely flatmap issues - posted by aljoscha <gi...@git.apache.org> on 2016/11/07 15:26:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-4955) Add Translations Tests for KeyedStream.flatMap(TimelyFlatMapFunction) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 15:28:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4951) Better Javadocs for KeyedStream.flatMap(TimelyFlatMapFunction) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 15:28:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4952) Add Scala API for KeyedStream.flatMap(TimelyFlatMapFunction) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 15:28:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4957) Provide API for TimelyCoFlatMapFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 15:30:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 15:35:59 UTC, 6 replies.
- [jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 15:36:58 UTC, 20 replies.
- [jira] [Updated] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 15:36:58 UTC, 1 replies.
- [GitHub] flink pull request #2765: [FLINK-5027] FileSource finishes successfully with... - posted by kl0u <gi...@git.apache.org> on 2016/11/07 15:38:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-5027) FileSource finishes successfully with a wrong path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 15:38:58 UTC, 5 replies.
- [jira] [Created] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 15:57:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4698) Visualize additional checkpoint information - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/07 16:48:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/07 16:48:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4410) Report more information about operator checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/07 16:48:58 UTC, 0 replies.
- [GitHub] flink issue #2765: [FLINK-5027] FileSource finishes successfully with a wron... - posted by kl0u <gi...@git.apache.org> on 2016/11/07 16:52:38 UTC, 2 replies.
- [GitHub] flink issue #2760: [FLINK-5014] [RocksDB backend] add toString for RocksDBSt... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/07 17:26:10 UTC, 0 replies.
- [jira] [Created] (FLINK-5029) Implement KvState SSL - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/07 19:18:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 19:23:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 19:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5030) Support hostname verification - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/07 19:42:58 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3931) Implement Transport Encryption (SSL/TLS) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/07 19:43:58 UTC, 0 replies.
- [GitHub] flink pull request #2766: [FLINK-4898] Refactor HTTP handlers and Netty serv... - posted by EronWright <gi...@git.apache.org> on 2016/11/07 19:46:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 19:46:58 UTC, 4 replies.
- [GitHub] flink pull request #2767: [FLINK-4988] Elasticsearch 5.x support - posted by mikedias <gi...@git.apache.org> on 2016/11/07 20:33:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-4988) Elasticsearch 5.x support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 20:33:58 UTC, 5 replies.
- [GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio... - posted by mushketyk <gi...@git.apache.org> on 2016/11/07 20:38:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 20:38:58 UTC, 8 replies.
- [jira] [Created] (FLINK-5031) Consecutive DataStream.split() ignored - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/07 22:35:58 UTC, 0 replies.
- [GitHub] flink issue #534: [FLINK-1775] BarrierBuffer fix to avoid end of stream dead... - posted by coveralls <gi...@git.apache.org> on 2016/11/07 22:40:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/07 22:40:58 UTC, 0 replies.
- [GitHub] flink pull request #2768: [FLINK-5023 & FLINK-5024] Add SimpleStateDescripto... - posted by shixiaogang <gi...@git.apache.org> on 2016/11/08 02:58:31 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5023) Add get() method in State interface - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/08 03:14:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/08 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5032) CsvOutputFormatTest fails on Windows OS - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/08 06:30:59 UTC, 0 replies.
- [GitHub] flink pull request #2769: [FLINK-5032] CsvOutputFormatTest fails on Windows ... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/08 09:03:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-5032) CsvOutputFormatTest fails on Windows OS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 09:03:58 UTC, 3 replies.
- [GitHub] flink issue #2769: [FLINK-5032] CsvOutputFormatTest fails on Windows OS - posted by fhueske <gi...@git.apache.org> on 2016/11/08 09:14:17 UTC, 1 replies.
- [GitHub] flink pull request #2770: [FLINK-4354]Implement TaskManager side of heartbea... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/11/08 10:46:08 UTC, 0 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/11/08 12:29:32 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/11/08 12:29:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 13:01:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5032) CsvOutputFormatTest fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/08 13:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5033) CEP operators don't properly advance time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/08 13:17:58 UTC, 0 replies.
- [GitHub] flink pull request #2768: [FLINK-5023][FLINK-5024] Add SimpleStateDescriptor... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/08 13:31:27 UTC, 9 replies.
- [jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/08 13:39:58 UTC, 56 replies.
- [GitHub] flink issue #2542: [FLINK-4613] [ml] Extend ALS to handle implicit feedback ... - posted by jfeher <gi...@git.apache.org> on 2016/11/08 13:57:21 UTC, 14 replies.
- [jira] [Commented] (FLINK-4613) Extend ALS to handle implicit feedback datasets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 13:57:58 UTC, 27 replies.
- [GitHub] flink pull request #2771: [FLINK-5033] [cep] Advance time with incoming wate... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/08 14:20:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-5033) CEP operators don't properly advance time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 14:20:59 UTC, 2 replies.
- [jira] [Resolved] (FLINK-5014) RocksDBStateBackend misses good toString - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 14:29:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5014) RocksDBStateBackend misses good toString - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 14:29:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 14:30:58 UTC, 0 replies.
- [GitHub] flink issue #2754: [FLINK-4975] [checkpointing] Add a limit for how much dat... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/08 14:31:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 14:32:58 UTC, 0 replies.
- [GitHub] flink issue #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests - posted by aljoscha <gi...@git.apache.org> on 2016/11/08 14:44:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 14:44:58 UTC, 1 replies.
- [GitHub] flink pull request #2772: [FLINK-5012] Expose Timestamp in Timely FlatMap Fu... - posted by aljoscha <gi...@git.apache.org> on 2016/11/08 15:54:42 UTC, 1 replies.
- [GitHub] flink pull request #2725: [FLINK-4963] [gelly] Tabulate edge direction for d... - posted by asfgit <gi...@git.apache.org> on 2016/11/08 15:55:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4963) Tabulate edge direction for directed VertexMetrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 15:55:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-4963) Tabulate edge direction for directed VertexMetrics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/08 15:56:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 16:16:58 UTC, 3 replies.
- [jira] [Created] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 16:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 16:20:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 16:20:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4565) Support for SQL IN operator - posted by "Nikolay Vasilishin (JIRA)" <ji...@apache.org> on 2016/11/08 17:10:58 UTC, 15 replies.
- [jira] [Comment Edited] (FLINK-4565) Support for SQL IN operator - posted by "Nikolay Vasilishin (JIRA)" <ji...@apache.org> on 2016/11/08 17:11:59 UTC, 2 replies.
- [GitHub] flink issue #2725: [FLINK-4963] [gelly] Tabulate edge direction for directed... - posted by vasia <gi...@git.apache.org> on 2016/11/08 17:48:05 UTC, 0 replies.
- [GitHub] flink pull request #2773: [backport] [FLINK-4975] [checkpointing] Add a limi... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/08 18:01:12 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/08 20:47:58 UTC, 0 replies.
- [GitHub] flink issue #2708: [FLINK-4946] [scripts] Load jar files from subdirectories... - posted by greghogan <gi...@git.apache.org> on 2016/11/08 20:51:14 UTC, 3 replies.
- [GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra... - posted by mushketyk <gi...@git.apache.org> on 2016/11/08 21:05:29 UTC, 4 replies.
- [jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/08 21:05:59 UTC, 7 replies.
- [jira] [Resolved] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:12:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:12:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4976) Add a way to abort in flight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:13:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:13:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:13:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4976) Add a way to abort in flight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:13:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:14:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 23:15:59 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5023) Add get() method in State interface - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/09 02:45:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5036) Perform the grouping of keys in restoring instead of checkpointing - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/09 03:27:58 UTC, 0 replies.
- [GitHub] flink pull request #2774: [hotfix] PartitionerITCase replace comparing Integ... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/09 06:23:33 UTC, 1 replies.
- [GitHub] flink pull request #2775: [hotfix] Fix wrong arguments order in assert - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/09 06:25:15 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/09 07:07:59 UTC, 3 replies.
- [GitHub] flink pull request #2776: [docs] Fix typos in Table API documentation - posted by wuchong <gi...@git.apache.org> on 2016/11/09 07:22:37 UTC, 1 replies.
- [GitHub] flink issue #2650: [FLINK-4563] [metrics] scope caching not adjusted for mul... - posted by ex00 <gi...@git.apache.org> on 2016/11/09 07:48:46 UTC, 5 replies.
- [jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/09 07:48:59 UTC, 13 replies.
- [jira] [Created] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/09 08:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/09 08:27:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-5036) Perform the grouping of keys in restoring instead of checkpointing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/09 08:45:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-4692) Add tumbling and sliding group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/09 08:58:58 UTC, 2 replies.
- [GitHub] flink pull request #2777: [FLINK-5037] Fixed instability in AbstractUdfStrea... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/09 10:21:56 UTC, 1 replies.
- [jira] [Closed] (FLINK-5019) Proper isRestored result for tasks that did not write state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 10:23:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4364) Implement TaskManager side of heartbeat from JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/09 10:30:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/09 12:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5039) Avro GenericRecord support is broken - posted by "Bruno Dumon (JIRA)" <ji...@apache.org> on 2016/11/09 13:43:58 UTC, 0 replies.
- [GitHub] flink pull request #2732: [FLINK-4272] Create a JobClient for job control an... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/09 13:49:35 UTC, 59 replies.
- [GitHub] flink pull request #2729: [FLINK-4883]Prevent UDFs implementations through S... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/09 14:32:38 UTC, 5 replies.
- [jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/09 14:32:58 UTC, 6 replies.
- [GitHub] flink issue #2777: [FLINK-5037] Fixed instability in AbstractUdfStreamOperat... - posted by aljoscha <gi...@git.apache.org> on 2016/11/09 14:48:39 UTC, 0 replies.
- [GitHub] flink pull request #2542: [FLINK-4613] [ml] Extend ALS to handle implicit fe... - posted by thvasilo <gi...@git.apache.org> on 2016/11/09 14:57:58 UTC, 12 replies.
- [jira] [Closed] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 15:01:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/09 15:15:58 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/09 15:38:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5040) Set correct input channel types with eager scheduling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/09 17:24:59 UTC, 0 replies.
- [GitHub] flink pull request #2778: [hotfix] fix duplicate "ms" time unit - posted by NicoK <gi...@git.apache.org> on 2016/11/09 17:32:38 UTC, 1 replies.
- [jira] [Created] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 19:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5042) Convert old savepoints to new savepoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 20:01:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 20:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 20:08:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/09 20:29:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/09 20:29:58 UTC, 0 replies.
- [GitHub] flink issue #2776: [docs] Fix typos in Table API documentation - posted by fhueske <gi...@git.apache.org> on 2016/11/09 20:42:52 UTC, 1 replies.
- [GitHub] flink issue #2288: Feature/s3 a fix - posted by cresny <gi...@git.apache.org> on 2016/11/09 20:55:20 UTC, 0 replies.
- [GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec... - posted by mushketyk <gi...@git.apache.org> on 2016/11/09 21:56:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5045) Latency markers emitted after output buffer pool destroyed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/09 21:59:58 UTC, 0 replies.
- [GitHub] flink issue #2775: [hotfix] Fix wrong arguments order in assert - posted by fhueske <gi...@git.apache.org> on 2016/11/09 22:17:42 UTC, 1 replies.
- [GitHub] flink issue #2774: [hotfix] PartitionerITCase replace comparing Integers by ... - posted by fhueske <gi...@git.apache.org> on 2016/11/09 22:25:20 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4648) Implement bipartite graph generators - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/09 22:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/10 00:46:58 UTC, 0 replies.
- [GitHub] flink pull request #2779: [FLINK-5046] [tdd] Preserialize TaskDeploymentDesc... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/10 00:52:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/10 00:52:58 UTC, 4 replies.
- [jira] [Created] (FLINK-5047) Add tumbling group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:18:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4692) Add tumbling and sliding group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:19:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5047) Add Sliding group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:19:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5047) Add sliding group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:19:58 UTC, 2 replies.
- [jira] [Updated] (FLINK-4692) Add tumbling group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:20:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:25:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-5045) Latency markers emitted after output buffer pool destroyed - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/10 09:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5047) Add sliding group-windows for batch tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/10 09:34:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-4929) Implement FLIP-6 YARN TaskManager Runner - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/10 09:57:00 UTC, 0 replies.
- [GitHub] flink issue #2778: [hotfix] fix duplicate "ms" time unit - posted by fhueske <gi...@git.apache.org> on 2016/11/10 10:20:24 UTC, 1 replies.
- [jira] [Created] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/10 10:30:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4692) Add tumbling group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 11:55:58 UTC, 0 replies.
- [GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the... - posted by mushketyk <gi...@git.apache.org> on 2016/11/10 13:07:57 UTC, 8 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/11/10 13:07:59 UTC, 12 replies.
- [GitHub] flink pull request #2780: [backport] [FLINK-5046] [tdd] Preserialize TaskDep... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/10 13:16:14 UTC, 1 replies.
- [GitHub] flink issue #2771: [FLINK-5033] [cep] Advance time with incoming watermarks ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/10 13:17:44 UTC, 0 replies.
- [jira] [Closed] (FLINK-5027) FileSource finishes successfully with a wrong path - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/10 13:21:58 UTC, 0 replies.
- [GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/10 13:34:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/10 13:35:00 UTC, 1 replies.
- [GitHub] flink issue #2781: [FLINK-5041] Savepoint backwards compatibility 1.1 -> 1.2 - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/10 13:35:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-5033) CEP operators don't properly advance time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/10 13:45:58 UTC, 0 replies.
- [GitHub] flink issue #2719: [FLINK-4954] [rpc] Discard messages when AkkaRpcActor is ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/10 13:47:47 UTC, 0 replies.
- [GitHub] flink pull request #2719: [FLINK-4954] [rpc] Discard messages when AkkaRpcAc... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/10 13:47:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-4954) Remove stashing from AkkaRpcActor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/10 13:47:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-4954) Remove stashing from AkkaRpcActor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/10 13:48:58 UTC, 0 replies.
- [GitHub] flink pull request #2782: [hotfix] Prevent possible NPE in FlumeSink. - posted by chermenin <gi...@git.apache.org> on 2016/11/10 15:00:53 UTC, 1 replies.
- [GitHub] flink pull request #2783: [FLINK-5040] [jobmanager] Set correct input channe... - posted by uce <gi...@git.apache.org> on 2016/11/10 16:33:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-5040) Set correct input channel types with eager scheduling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/10 16:33:58 UTC, 3 replies.
- [GitHub] flink pull request #2784: [backport] [FLINK-5040] [jobmanager] Set correct i... - posted by uce <gi...@git.apache.org> on 2016/11/10 16:36:03 UTC, 1 replies.
- [GitHub] flink issue #2782: [hotfix] Prevent possible NPE in FlumeSink. - posted by greghogan <gi...@git.apache.org> on 2016/11/10 17:11:36 UTC, 2 replies.
- [GitHub] flink pull request #2457: [FLINK-3680][web frontend] Remove "(not set)" text... - posted by greghogan <gi...@git.apache.org> on 2016/11/10 17:13:22 UTC, 3 replies.
- [GitHub] flink pull request #2730: [FLINK-4970] [gelly] Parameterize vertex value for... - posted by asfgit <gi...@git.apache.org> on 2016/11/10 17:15:25 UTC, 0 replies.
- [GitHub] flink pull request #2731: [FLINK-4934] [gelly] Triadic Census - posted by asfgit <gi...@git.apache.org> on 2016/11/10 17:15:25 UTC, 0 replies.
- [jira] [Closed] (FLINK-4934) Triadic Census - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/10 17:16:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4970) Parameterize vertex value for SSSP - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/10 17:17:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4946) Load jar files from subdirectories of lib - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/10 17:17:58 UTC, 0 replies.
- [GitHub] flink pull request #2785: [FLINK-5006] SystemProcessingTimeServiceTest.testT... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/10 17:26:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/10 17:27:58 UTC, 10 replies.
- [GitHub] flink issue #2779: [FLINK-5046] [tdd] Preserialize TaskDeploymentDescriptor ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/10 17:32:46 UTC, 0 replies.
- [GitHub] flink issue #2785: [FLINK-5006] SystemProcessingTimeServiceTest.testTimerSor... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/10 17:37:42 UTC, 8 replies.
- [jira] [Closed] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/10 18:36:58 UTC, 0 replies.
- [GitHub] flink issue #2772: [FLINK-5012] Expose Timestamp in Timely FlatMap Functions - posted by jgrier <gi...@git.apache.org> on 2016/11/10 18:47:54 UTC, 1 replies.
- [jira] [Created] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/10 21:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5050) JSON.org license is CatX - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/10 23:44:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4918) Add SSL support to Mesos artifact server - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/11 01:29:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/11 02:47:59 UTC, 0 replies.
- [GitHub] flink pull request #2786: [FLINK-5016] [ci] Increase no output timeout to 10... - posted by uce <gi...@git.apache.org> on 2016/11/11 08:57:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-4648) Implement bipartite graph generators - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/11 08:58:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/11 09:00:01 UTC, 3 replies.
- [jira] [Closed] (FLINK-5040) Set correct input channel types with eager scheduling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/11 09:01:15 UTC, 0 replies.
- [GitHub] flink pull request #2787: [FLINK-5013] [kinesis] Shade AWS dependencies to w... - posted by tzulitai <gi...@git.apache.org> on 2016/11/11 09:09:35 UTC, 1 replies.
- [GitHub] flink issue #2786: [FLINK-5016] [ci] Increase no output timeout to 10 mins - posted by aljoscha <gi...@git.apache.org> on 2016/11/11 09:15:15 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/11 09:19:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/11 09:20:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 09:24:58 UTC, 7 replies.
- [jira] [Created] (FLINK-5051) Backwards compatibility for serializers in backend state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/11 09:53:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/11 10:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5053) Incremental / lightweight snapshots for checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/11 10:59:58 UTC, 0 replies.
- [GitHub] flink pull request #2788: [FLINK-5026] Rename TimelyFlatMap to Process - posted by aljoscha <gi...@git.apache.org> on 2016/11/11 11:03:03 UTC, 18 replies.
- [jira] [Reopened] (FLINK-4631) NullPointerException during stream task cleanup - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/11 11:13:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/11/11 11:27:59 UTC, 30 replies.
- [jira] [Commented] (FLINK-5050) JSON.org license is CatX - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/11 11:57:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/11 12:07:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/11 12:08:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5054) Make the BucketingSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/11 12:59:58 UTC, 0 replies.
- [GitHub] flink issue #2763: [FLINK-5021] Makes the ContinuousFileReaderOperator resca... - posted by aljoscha <gi...@git.apache.org> on 2016/11/11 13:11:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-5021) Makes the ContinuousFileReaderOperator rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/11 13:19:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5054) Make the BucketingSink rescalable. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/11 13:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/11 13:51:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/11/11 14:23:59 UTC, 3 replies.
- [GitHub] flink pull request #2789: [FLINK-5048] [Kafka Consumer] Change thread model ... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/11 14:38:53 UTC, 28 replies.
- [jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 14:38:58 UTC, 33 replies.
- [jira] [Commented] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2016/11/11 14:51:00 UTC, 2 replies.
- [jira] [Created] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/11 15:24:59 UTC, 0 replies.
- [GitHub] flink pull request #2790: [FLINK-4491] Handle index.number_of_shards in the ... - posted by ddolzan <gi...@git.apache.org> on 2016/11/11 16:02:03 UTC, 5 replies.
- [jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/11 16:02:58 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/11 18:18:58 UTC, 1 replies.
- [GitHub] flink issue #2787: [FLINK-5013] [kinesis] Shade AWS dependencies to work wit... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/11 18:23:06 UTC, 4 replies.
- [GitHub] flink pull request #2467: [FLINK-3719][web frontend] Moving the barrier betw... - posted by iampeter <gi...@git.apache.org> on 2016/11/11 21:06:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-4460) Side Outputs in Flink - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/11/11 22:26:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4647) Implement BipartiteGraph reader - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/11 22:30:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-1275) Add support to compress network I/O - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/11/11 22:47:58 UTC, 0 replies.
- [GitHub] flink pull request #2703: [FLINK-4900] flink-master: Allow to deploy TM with... - posted by EronWright <gi...@git.apache.org> on 2016/11/11 23:28:07 UTC, 4 replies.
- [GitHub] flink pull request #2524: [FLINK-4653] [Client] Refactor JobClientActor to a... - posted by beyond1920 <gi...@git.apache.org> on 2016/11/12 02:45:40 UTC, 0 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/11/12 02:45:58 UTC, 0 replies.
- [GitHub] flink pull request #2791: [FLINK-4449] [cluster management] add Heartbeat ma... - posted by beyond1920 <gi...@git.apache.org> on 2016/11/12 02:56:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-4449) Heartbeat Manager integration with TaskExecutor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/12 02:56:58 UTC, 0 replies.
- [GitHub] flink pull request #2792: Flink 4937 pr - posted by sunjincheng121 <gi...@git.apache.org> on 2016/11/12 13:29:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/12 13:29:58 UTC, 73 replies.
- [jira] [Commented] (FLINK-4647) Implement BipartiteGraph reader - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/12 17:24:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4649) Implement bipartite graph metrics - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/12 17:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5057) Cancellation timeouts are picked from wrong config - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/12 19:15:58 UTC, 0 replies.
- [GitHub] flink pull request #2793: [FLINK-5057] [task] Pick cancellation timeout from... - posted by uce <gi...@git.apache.org> on 2016/11/12 19:33:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-5057) Cancellation timeouts are picked from wrong config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/12 19:33:58 UTC, 4 replies.
- [GitHub] flink pull request #2794: [backport] [FLINK-5057] [task] Pick cancellation t... - posted by uce <gi...@git.apache.org> on 2016/11/12 19:35:40 UTC, 1 replies.
- [GitHub] flink pull request #2795: Revert "[FLINK-4913][yarn] include user jars in sy... - posted by uce <gi...@git.apache.org> on 2016/11/12 19:55:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/12 19:55:58 UTC, 11 replies.
- [GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ... - posted by wuchong <gi...@git.apache.org> on 2016/11/13 09:14:52 UTC, 61 replies.
- [GitHub] flink issue #2792: [FLINK-4937] [Table] Add incremental group window aggrega... - posted by sunjincheng121 <gi...@git.apache.org> on 2016/11/13 11:55:28 UTC, 4 replies.
- [GitHub] flink pull request #2796: [FLINK-4873] Configurable ship path for YARN clust... - posted by gyfora <gi...@git.apache.org> on 2016/11/13 18:22:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-4873) Add config option to specify "home directory" for YARN client resource sharing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/13 18:22:58 UTC, 1 replies.
- [GitHub] flink issue #2796: [FLINK-4873] Configurable ship path for YARN cluster reso... - posted by gyfora <gi...@git.apache.org> on 2016/11/13 18:23:38 UTC, 0 replies.
- [GitHub] flink issue #2756: [FLINK-4997] Extending Window Function Metadata - posted by manuzhang <gi...@git.apache.org> on 2016/11/14 02:30:53 UTC, 5 replies.
- [jira] [Commented] (FLINK-5053) Incremental / lightweight snapshots for checkpoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/14 08:38:59 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-4937) Add incremental group window aggregation for streaming Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/14 09:35:58 UTC, 0 replies.
- [GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable. - posted by kl0u <gi...@git.apache.org> on 2016/11/14 09:39:04 UTC, 36 replies.
- [jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 09:39:58 UTC, 45 replies.
- [jira] [Commented] (FLINK-5054) Make the BucketingSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/14 09:42:58 UTC, 0 replies.
- [GitHub] flink pull request #2798: [FLINK-4364]Implement TaskManager side of heartbea... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/11/14 10:04:23 UTC, 0 replies.
- [jira] [Created] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell - posted by "yangping wu (JIRA)" <ji...@apache.org> on 2016/11/14 10:04:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5058) slots attribute set wrong value in FlinkShell - posted by "yangping wu (JIRA)" <ji...@apache.org> on 2016/11/14 11:06:58 UTC, 2 replies.
- [GitHub] flink pull request #2799: [FLINK-5058]taskManagerMemory attribute set wrong ... - posted by 397090770 <gi...@git.apache.org> on 2016/11/14 11:12:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-5058) slots attribute set wrong value in FlinkShell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 11:12:58 UTC, 0 replies.
- [GitHub] flink pull request #2800: Update README.md - posted by bitchelov <gi...@git.apache.org> on 2016/11/14 11:15:06 UTC, 1 replies.
- [jira] [Updated] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell - posted by "yangping wu (JIRA)" <ji...@apache.org> on 2016/11/14 11:18:58 UTC, 1 replies.
- [GitHub] flink pull request #2650: [FLINK-4563] [metrics] scope caching not adjusted ... - posted by zentol <gi...@git.apache.org> on 2016/11/14 11:20:51 UTC, 7 replies.
- [GitHub] flink pull request #2801: [FLINK-5017] [streaming] Introduce StreamStatus to... - posted by tzulitai <gi...@git.apache.org> on 2016/11/14 11:44:35 UTC, 0 replies.
- [GitHub] flink issue #2801: [FLINK-5017] [streaming] Introduce StreamStatus to facili... - posted by tzulitai <gi...@git.apache.org> on 2016/11/14 11:46:38 UTC, 2 replies.
- [jira] [Closed] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 12:43:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/14 13:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/14 13:26:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 13:26:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 13:39:58 UTC, 0 replies.
- [GitHub] flink pull request #2484: [FLINK-4177] Harden CassandraConnectorTest - posted by asfgit <gi...@git.apache.org> on 2016/11/14 13:39:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 13:40:58 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 13:40:58 UTC, 0 replies.
- [GitHub] flink issue #2729: [FLINK-4883]Prevent UDFs implementations through Scala si... - posted by Renkai <gi...@git.apache.org> on 2016/11/14 13:41:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 13:41:58 UTC, 0 replies.
- [GitHub] flink pull request #2802: Minor fixes - posted by bitchelov <gi...@git.apache.org> on 2016/11/14 14:16:07 UTC, 2 replies.
- [jira] [Created] (FLINK-5061) Remove ContinuousEventTimeTrigger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/14 14:25:58 UTC, 0 replies.
- [GitHub] flink pull request #2803: [FLINK-5061] Remove ContinuousEventTimeTrigger - posted by aljoscha <gi...@git.apache.org> on 2016/11/14 14:27:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 14:27:58 UTC, 9 replies.
- [jira] [Commented] (FLINK-4920) Add a Scala Function Gauge - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 15:13:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4527) Drop the "flinkAccumulators" from the Execution - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 15:18:59 UTC, 0 replies.
- [GitHub] flink issue #2800: Update README.md - posted by greghogan <gi...@git.apache.org> on 2016/11/14 15:27:47 UTC, 3 replies.
- [jira] [Updated] (FLINK-5062) Ensure that all created threads have a proper name - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 15:32:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5062) Ensure that all create threads have a proper name - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 15:32:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4812) Export currentLowWatermark metric also for sources - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 15:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 15:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5064) Checkpoint messages are not scoped to the leader session ID - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 17:43:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5065) Resource leaks in case of lost checkpoint messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 17:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/14 18:33:59 UTC, 0 replies.
- [GitHub] flink issue #2795: Revert "[FLINK-4913][yarn] include user jars in system cl... - posted by mxm <gi...@git.apache.org> on 2016/11/14 19:17:17 UTC, 9 replies.
- [jira] [Updated] (FLINK-5051) Backwards compatibility for serializers in backend state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/14 19:37:59 UTC, 1 replies.
- [jira] [Created] (FLINK-5067) Make Flink compile with 1.8 Java compiler - posted by "Andrey Melentyev (JIRA)" <ji...@apache.org> on 2016/11/14 20:44:58 UTC, 0 replies.
- [GitHub] flink pull request #2804: [FLINK-5067] Make Flink compile with 1.8 Java comp... - posted by melentye <gi...@git.apache.org> on 2016/11/14 20:49:14 UTC, 6 replies.
- [jira] [Commented] (FLINK-5067) Make Flink compile with 1.8 Java compiler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 20:49:59 UTC, 9 replies.
- [GitHub] flink pull request #2805: Flink 5059 - posted by NicoK <gi...@git.apache.org> on 2016/11/14 21:05:31 UTC, 1 replies.
- [GitHub] flink pull request #2806: [FLINK-5066] Prevent LocalInputChannel#getNextBuff... - posted by NicoK <gi...@git.apache.org> on 2016/11/14 21:16:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 21:16:58 UTC, 0 replies.
- [GitHub] flink issue #2805: Flink 5059 - posted by zentol <gi...@git.apache.org> on 2016/11/14 21:45:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/14 21:45:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-5031) Consecutive DataStream.split() ignored - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/11/15 04:18:58 UTC, 3 replies.
- [jira] [Assigned] (FLINK-5031) Consecutive DataStream.split() ignored - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/11/15 04:18:58 UTC, 0 replies.
- [GitHub] flink pull request #2805: [FLINK-5059] only serialise events once in RecordW... - posted by NicoK <gi...@git.apache.org> on 2016/11/15 08:15:53 UTC, 2 replies.
- [jira] [Created] (FLINK-5068) YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/15 08:34:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5068) YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/15 09:20:59 UTC, 0 replies.
- [GitHub] flink issue #2802: Minor fixes - posted by bitchelov <gi...@git.apache.org> on 2016/11/15 09:23:34 UTC, 1 replies.
- [jira] [Created] (FLINK-5069) Pending checkpoint statistics gauge - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/15 09:26:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5069) Pending checkpoint statistics gauge - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/15 09:27:59 UTC, 0 replies.
- [GitHub] flink pull request #2807: [FLINK-4631] Prevent some possible NPEs. - posted by chermenin <gi...@git.apache.org> on 2016/11/15 09:34:09 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4693) Add session group-windows for batch tables - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/15 09:37:58 UTC, 0 replies.
- [GitHub] flink pull request #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource M... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/15 09:50:04 UTC, 16 replies.
- [jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 09:50:58 UTC, 16 replies.
- [GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti... - posted by zhuhaifengleon <gi...@git.apache.org> on 2016/11/15 09:53:11 UTC, 6 replies.
- [jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 09:53:59 UTC, 7 replies.
- [GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ... - posted by tonycox <gi...@git.apache.org> on 2016/11/15 10:05:47 UTC, 42 replies.
- [GitHub] flink issue #2367: [FLINK-3703][cep] Add sequence matching semantics to disc... - posted by LordFB <gi...@git.apache.org> on 2016/11/15 10:11:59 UTC, 2 replies.
- [jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 10:13:01 UTC, 2 replies.
- [jira] [Commented] (FLINK-4498) Better Cassandra sink documentation - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2016/11/15 10:14:58 UTC, 0 replies.
- [GitHub] flink pull request #2811: [Flink-4541] Support for SQL NOT IN operator - posted by AlexanderShoshin <gi...@git.apache.org> on 2016/11/15 10:29:22 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4263) SQL's VALUES does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/15 10:29:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4604) Add support for standard deviation/variance - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/15 11:14:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5070) Unable to use Scala's BeanProperty with classes - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2016/11/15 11:39:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2186) Rework CSV import to support very wide files - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/15 12:09:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/15 12:23:58 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/15 12:24:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/15 12:42:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/11/15 13:34:59 UTC, 0 replies.
- [GitHub] flink issue #2625: [FLINK-4801] [types] Input type inference is faulty with ... - posted by twalthr <gi...@git.apache.org> on 2016/11/15 13:38:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 13:38:58 UTC, 1 replies.
- [GitHub] flink pull request #2625: [FLINK-4801] [types] Input type inference is fault... - posted by asfgit <gi...@git.apache.org> on 2016/11/15 13:59:37 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/15 13:59:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/15 14:01:58 UTC, 12 replies.
- [jira] [Created] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/15 14:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures. - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/15 14:27:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2016/11/15 14:38:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2016/11/15 14:38:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-4174) Enhance Window Evictor - posted by "vishnu viswanath (JIRA)" <ji...@apache.org> on 2016/11/15 14:39:58 UTC, 1 replies.
- [GitHub] flink pull request #2812: [FLINK-5063] Discard state handles of declined or ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/15 14:43:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 14:43:58 UTC, 6 replies.
- [GitHub] flink pull request #2813: [backport] [FLINK-5063] Discard state handles of d... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/15 14:45:07 UTC, 1 replies.
- [jira] [Created] (FLINK-5072) MetricFetcher Ask Timeout - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/15 15:06:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5072) MetricFetcher Ask Timeout - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/15 15:23:58 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4174) Enhance Window Evictor - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/15 15:37:58 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/15 15:38:58 UTC, 0 replies.
- [GitHub] flink issue #2797: [FLINK-5056] Makes the BucketingSink rescalable. - posted by zentol <gi...@git.apache.org> on 2016/11/15 15:56:00 UTC, 8 replies.
- [GitHub] flink pull request #2814: Corrected log4j files. - posted by bitchelov <gi...@git.apache.org> on 2016/11/15 17:00:57 UTC, 1 replies.
- [GitHub] flink issue #2814: Corrected log4j files. - posted by greghogan <gi...@git.apache.org> on 2016/11/15 17:05:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4900) Implement Docker image support - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/11/15 19:50:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-4900) Implement Docker image support - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/11/15 19:54:59 UTC, 3 replies.
- [jira] [Created] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/15 19:59:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4499) Introduce findbugs maven plugin - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/15 22:55:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4164) Use only one rocksdb column family to store all states in an operator - posted by "LiuBiao (JIRA)" <ji...@apache.org> on 2016/11/16 03:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/16 03:55:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/16 03:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/16 06:15:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/16 06:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5076) Shutting down TM when shutting down new mini cluster - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/16 07:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5077) testStreamTableSink falls unstable - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/16 07:49:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5077) testStreamTableSink fails unstable - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/16 07:51:58 UTC, 0 replies.
- [GitHub] flink pull request #2815: [FLINK-5073] Use Executor to run ZooKeeper callbac... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/16 08:06:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 08:06:59 UTC, 6 replies.
- [GitHub] flink pull request #2816: [backport] [FLINK-5073] Use Executor to run ZooKee... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/16 08:07:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/16 10:02:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/16 10:03:58 UTC, 0 replies.
- [GitHub] flink pull request #2817: [FLINK-5076] Shutting down TM when shutting down m... - posted by ifndef-SleePy <gi...@git.apache.org> on 2016/11/16 10:23:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-5076) Shutting down TM when shutting down new mini cluster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 10:23:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/16 10:27:59 UTC, 9 replies.
- [jira] [Created] (FLINK-5078) Introduce annotations for classes copied from Calcite - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/16 11:03:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5079) Failed to submit job to YARN cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/16 11:14:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5078) Introduce annotations for classes copied from Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/16 11:18:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/16 11:34:59 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-4872) Type erasure problem exclusively on cluster execution - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/11/16 11:44:58 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 13:20:43 UTC, 7 replies.
- [jira] [Created] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2016/11/16 13:59:58 UTC, 0 replies.
- [GitHub] flink issue #2789: [FLINK-5048] [Kafka Consumer] Change thread model of Flin... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 14:11:14 UTC, 3 replies.
- [GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaiming Examples - posted by thvasilo <gi...@git.apache.org> on 2016/11/16 14:13:34 UTC, 1 replies.
- [GitHub] flink issue #2807: [FLINK-4631] Prevent some possible NPEs. - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 14:15:20 UTC, 0 replies.
- [GitHub] flink pull request #2818: [FLINK-4263] [table] SQL's VALUES does not work pr... - posted by twalthr <gi...@git.apache.org> on 2016/11/16 14:15:50 UTC, 2 replies.
- [jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 14:15:59 UTC, 4 replies.
- [GitHub] flink issue #2812: [FLINK-5063] Discard state handles of declined or expired... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 14:17:51 UTC, 0 replies.
- [GitHub] flink issue #2813: [backport] [FLINK-5063] Discard state handles of declined... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 14:18:17 UTC, 1 replies.
- [GitHub] flink pull request #2819: [FLINK-4961] [ml] SGD for Matrix Factorization (WI... - posted by gaborhermann <gi...@git.apache.org> on 2016/11/16 15:00:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4961) SGD for Matrix Factorization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 15:01:10 UTC, 3 replies.
- [GitHub] flink issue #2819: [FLINK-4961] [ml] SGD for Matrix Factorization (WIP) - posted by gaborhermann <gi...@git.apache.org> on 2016/11/16 15:11:47 UTC, 2 replies.
- [jira] [Created] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/16 15:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/16 17:33:58 UTC, 0 replies.
- [GitHub] flink issue #1033: Add Scala version of GraphAlgorithm - posted by greghogan <gi...@git.apache.org> on 2016/11/16 17:37:43 UTC, 0 replies.
- [GitHub] flink issue #2066: Updated ssh configuration in base Dockerfile - posted by greghogan <gi...@git.apache.org> on 2016/11/16 17:45:48 UTC, 0 replies.
- [GitHub] flink pull request #2820: [FLINK-5082] Pull ExecutorService lifecycle manage... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/16 17:53:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 17:53:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/16 19:52:58 UTC, 1 replies.
- [GitHub] flink issue #2060: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/11/16 19:53:01 UTC, 2 replies.
- [jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/16 19:53:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/16 20:01:03 UTC, 0 replies.
- [GitHub] flink issue #2803: [FLINK-5061] Remove ContinuousEventTimeTrigger - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 20:03:55 UTC, 2 replies.
- [jira] [Created] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2016/11/16 20:18:58 UTC, 0 replies.
- [GitHub] flink issue #2794: [backport] [FLINK-5057] [task] Pick cancellation timeout ... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/16 20:23:43 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2016/11/16 21:05:58 UTC, 2 replies.
- [GitHub] flink issue #2804: [FLINK-5067] Make Flink compile with 1.8 Java compiler - posted by melentye <gi...@git.apache.org> on 2016/11/16 21:14:09 UTC, 2 replies.
- [jira] [Commented] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/16 22:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5084) Replace Java Table API integration tests by unit tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/16 23:07:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5057) Cancellation timeouts are picked from wrong config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/16 23:53:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5057) Cancellation timeouts are picked from wrong config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/16 23:53:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/16 23:54:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/16 23:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/17 00:25:58 UTC, 0 replies.
- [GitHub] flink pull request #2821: [MINOR][DOC] Fix incorrect URL - posted by mindprince <gi...@git.apache.org> on 2016/11/17 00:50:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/17 07:20:58 UTC, 12 replies.
- [jira] [Issue Comment Deleted] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/17 07:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-... - posted by tzulitai <gi...@git.apache.org> on 2016/11/17 07:33:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 07:33:58 UTC, 8 replies.
- [GitHub] flink issue #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-proof t... - posted by tzulitai <gi...@git.apache.org> on 2016/11/17 07:37:32 UTC, 3 replies.
- [jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/17 08:27:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/17 08:57:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/17 09:12:59 UTC, 0 replies.
- [GitHub] flink issue #2821: [MINOR][DOC] Fix incorrect URL - posted by fhueske <gi...@git.apache.org> on 2016/11/17 09:33:18 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-5053) Incremental / lightweight snapshots for checkpoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/17 09:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/17 10:01:58 UTC, 0 replies.
- [GitHub] flink issue #2818: [FLINK-4263] [table] SQL's VALUES does not work properly - posted by fhueske <gi...@git.apache.org> on 2016/11/17 10:11:03 UTC, 1 replies.
- [GitHub] flink issue #2790: [FLINK-4491] Handle index.number_of_shards in the ES conn... - posted by fpompermaier <gi...@git.apache.org> on 2016/11/17 10:33:48 UTC, 4 replies.
- [jira] [Created] (FLINK-5087) Additional steps needed for the Java quickstart guide - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/11/17 10:59:59 UTC, 0 replies.
- [GitHub] flink issue #2811: [FLINK-4541] Support for SQL NOT IN operator - posted by fhueske <gi...@git.apache.org> on 2016/11/17 11:35:10 UTC, 6 replies.
- [GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator - posted by fhueske <gi...@git.apache.org> on 2016/11/17 11:35:35 UTC, 22 replies.
- [jira] [Comment Edited] (FLINK-4832) Count/Sum 0 elements - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/17 12:45:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5050) JSON.org license is CatX - posted by "Sergey Sokur (JIRA)" <ji...@apache.org> on 2016/11/17 12:54:58 UTC, 0 replies.
- [GitHub] flink pull request #2823: [FLINK-4872] [types] Type erasure problem exclusiv... - posted by twalthr <gi...@git.apache.org> on 2016/11/17 13:23:59 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4872) Type erasure problem exclusively on cluster execution - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/17 13:24:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/17 13:25:58 UTC, 3 replies.
- [jira] [Resolved] (FLINK-4263) SQL's VALUES does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/17 13:47:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4886) Example in Machine Learning Quickstart Guide causes error - posted by "Lim Chee Hau (JIRA)" <ji...@apache.org> on 2016/11/17 14:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5088) Add option to limit subpartition queue length - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/17 14:09:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5089) Introduce Loop functions and Enforce Nesting on Data Streams - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/11/17 14:24:59 UTC, 0 replies.
- [GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria... - posted by fhueske <gi...@git.apache.org> on 2016/11/17 15:05:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/11/17 15:47:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/17 16:15:58 UTC, 1 replies.
- [GitHub] flink pull request #2824: [FLINK-5050] JSON.org license is CatX - posted by bitchelov <gi...@git.apache.org> on 2016/11/17 16:42:19 UTC, 1 replies.
- [GitHub] flink pull request #2825: [FLINK-5085] Execute CheckpointCoordinator's state... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/17 16:44:03 UTC, 1 replies.
- [GitHub] flink pull request #2826: [FLINK-5085] Execute CheckpointCoordinator's state... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/17 16:45:56 UTC, 0 replies.
- [GitHub] flink issue #2799: [FLINK-5058]taskManagerMemory attribute set wrong value - posted by fhueske <gi...@git.apache.org> on 2016/11/17 16:50:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 16:50:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5090) Expose optionally detailed metrics about network queue lengths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/17 18:43:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5079) Failed to submit job to YARN cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/17 18:49:58 UTC, 0 replies.
- [GitHub] flink pull request #2827: [FLINK-4921] Upgrade to Mesos 1.0.1 - posted by EronWright <gi...@git.apache.org> on 2016/11/17 19:35:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-4921) Upgrade to Mesos 1.0.1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/17 19:35:58 UTC, 5 replies.
- [GitHub] flink issue #2766: [FLINK-4898] Refactor HTTP handlers and Netty server/clie... - posted by EronWright <gi...@git.apache.org> on 2016/11/17 19:38:31 UTC, 3 replies.
- [jira] [Commented] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/17 19:48:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5091) Formalize the AppMaster environment for docker compability - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/17 20:05:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/17 21:39:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/17 21:43:59 UTC, 3 replies.
- [jira] [Closed] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/17 22:50:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5090) Expose optionally detailed metrics about network queue lengths - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/18 01:31:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5092) Add maven profile with code coverage - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/18 07:36:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5092) Add maven profile with code coverage report generation - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/18 07:44:59 UTC, 1 replies.
- [jira] [Created] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/18 08:49:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5076) Shutting down TM when shutting down new mini cluster - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/18 08:50:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5076) Shutting down TM when shutting down new mini cluster - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/18 08:50:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/18 09:03:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/18 09:08:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5092) Add integration with Sonarqube - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/18 09:10:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-5092) Add integration with Sonarqube and code coverage - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/18 09:13:58 UTC, 3 replies.
- [GitHub] flink pull request #2828: [FLINK-5093] java.util.ConcurrentModificationExcep... - posted by ifndef-SleePy <gi...@git.apache.org> on 2016/11/18 10:45:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 10:45:58 UTC, 3 replies.
- [jira] [Closed] (FLINK-5054) Make the BucketingSink rescalable. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/18 10:52:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/18 10:52:59 UTC, 0 replies.
- [GitHub] flink pull request #1833: [FLINK-2609] [streaming] auto-register types - posted by zentol <gi...@git.apache.org> on 2016/11/18 10:59:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 10:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/18 11:27:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/18 11:27:58 UTC, 1 replies.
- [GitHub] flink pull request #2829: Hotfix 2016 11 18 - posted by NicoK <gi...@git.apache.org> on 2016/11/18 12:29:55 UTC, 2 replies.
- [GitHub] flink issue #2829: Hotfix 2016 11 18 - posted by fpompermaier <gi...@git.apache.org> on 2016/11/18 12:41:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-4719) KryoSerializer random exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 12:41:58 UTC, 1 replies.
- [GitHub] flink issue #2829: [hotfix] prevent RecordWriter#flush() to clear the serial... - posted by NicoK <gi...@git.apache.org> on 2016/11/18 12:57:43 UTC, 0 replies.
- [jira] [Updated] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/18 13:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/18 13:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5096) Make the RollingSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/18 13:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/18 13:23:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4679) Add TumbleRow row-windows for streaming tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/18 13:26:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5098) Detect network problems to eagerly time out ask operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/18 13:46:58 UTC, 0 replies.
- [GitHub] flink pull request #2830: [FLINK-5098] [akka] Detect unreachable remote acto... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/18 13:52:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/18 13:52:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-5098) Detect network problems to eagerly time out ask operations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 13:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4591) Select star does not work with grouping - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/18 13:58:58 UTC, 0 replies.
- [GitHub] flink pull request #2831: [FLINK-5010] [akka] Introduce default configuratio... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/18 14:27:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 14:27:58 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/11/18 14:44:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/11/18 14:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5099) Test testCancelPartitionRequest is instable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 17:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5100) Test testZooKeeperReelection is instable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 17:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5101) Test CassandraConnectorITCase instable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 17:31:00 UTC, 0 replies.
- [GitHub] flink pull request #2832: [FLINK-4936] [gelly] Operator names for Gelly inpu... - posted by greghogan <gi...@git.apache.org> on 2016/11/18 18:50:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4936) Operator names for Gelly inputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 18:50:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5101) Test CassandraConnectorITCase instable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/18 18:58:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME - posted by "Malte Schwarzer (JIRA)" <ji...@apache.org> on 2016/11/18 19:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ... - posted by fhueske <gi...@git.apache.org> on 2016/11/18 20:37:19 UTC, 10 replies.
- [jira] [Commented] (FLINK-4294) Allow access of composite type fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 20:37:59 UTC, 13 replies.
- [GitHub] flink pull request #2511: [FLINK-4288] [table] Make it possible to unregiste... - posted by fhueske <gi...@git.apache.org> on 2016/11/18 20:57:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-4288) Make it possible to unregister tables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/18 20:57:59 UTC, 2 replies.
- [jira] [Created] (FLINK-5102) Connection establishment does not react to interrupt - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/18 21:21:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5053) Incremental / lightweight snapshots for checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 21:25:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5031) Consecutive DataStream.split() ignored - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/11/19 06:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5103) Process virtual memory and physical memory used size gauge - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/19 07:17:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5103) TaskManager process virtual memory and physical memory used size gauge - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/19 07:18:58 UTC, 1 replies.
- [GitHub] flink pull request #2833: [FLINK-5103] [Metrics] TaskManager process virtual... - posted by zhuhaifengleon <gi...@git.apache.org> on 2016/11/19 07:38:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-5103) TaskManager process virtual memory and physical memory used size gauge - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/19 07:38:58 UTC, 1 replies.
- [GitHub] flink pull request #2834: [docs] Fix broken links and incorrect examples - posted by mindprince <gi...@git.apache.org> on 2016/11/19 08:44:11 UTC, 1 replies.
- [jira] [Created] (FLINK-5104) Implement BipartiteGraph validator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/19 19:24:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Andrew Efimov (JIRA)" <ji...@apache.org> on 2016/11/20 02:57:58 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Andrew Efimov (JIRA)" <ji...@apache.org> on 2016/11/20 03:01:59 UTC, 3 replies.
- [GitHub] flink issue #2758: [FLINK-4260] Support specifying ESCAPE character in LIKE ... - posted by miaoever <gi...@git.apache.org> on 2016/11/20 09:33:33 UTC, 6 replies.
- [GitHub] flink pull request #2835: [FLINK-3869] WindowedStream.apply with FoldFunctio... - posted by ymarzougui <gi...@git.apache.org> on 2016/11/20 09:55:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-5104) Implement BipartiteGraph validator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/20 12:41:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3110) Add support for partition-centric iterations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/20 12:56:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/20 13:10:58 UTC, 5 replies.
- [GitHub] flink pull request #2836: [FLINK-5092] Add maven profile with code coverage ... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/21 05:48:11 UTC, 10 replies.
- [jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 05:48:58 UTC, 18 replies.
- [jira] [Created] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/21 08:24:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5106) improving IncrementalAggregateReduceFunction - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/21 08:27:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/11/21 08:44:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/21 09:57:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/21 10:04:59 UTC, 10 replies.
- [jira] [Assigned] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 10:06:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 10:06:59 UTC, 2 replies.
- [GitHub] flink pull request #2837: [FLINK-5107] Introduced limit for prior execution ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/21 10:10:26 UTC, 6 replies.
- [jira] [Commented] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 10:12:58 UTC, 5 replies.
- [GitHub] flink issue #2837: [FLINK-5107] Introduced limit for prior execution attempt... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/21 10:13:32 UTC, 1 replies.
- [jira] [Created] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 10:26:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 10:36:59 UTC, 1 replies.
- [GitHub] flink pull request #2838: [FLINK-4712] [FLINK-4713] [ml] Ranking recommendat... - posted by gaborhermann <gi...@git.apache.org> on 2016/11/21 10:40:57 UTC, 5 replies.
- [jira] [Commented] (FLINK-4712) Implementing ranking predictions for ALS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 10:40:59 UTC, 11 replies.
- [jira] [Updated] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/21 10:52:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 11:26:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 11:30:58 UTC, 3 replies.
- [jira] [Assigned] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 11:30:58 UTC, 0 replies.
- [GitHub] flink pull request #2839: [FLINK-5071][yarn] adjust vcore validation check - posted by mxm <gi...@git.apache.org> on 2016/11/21 11:49:29 UTC, 1 replies.
- [GitHub] flink pull request #2840: [FLINK-4832] Count/Sum 0 elements - posted by ex00 <gi...@git.apache.org> on 2016/11/21 12:08:39 UTC, 12 replies.
- [jira] [Created] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "Móger Tibor László (JIRA)" <ji...@apache.org> on 2016/11/21 12:18:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "Móger Tibor László (JIRA)" <ji...@apache.org> on 2016/11/21 12:19:58 UTC, 1 replies.
- [GitHub] flink pull request #2841: [Docs] Fix a typo in code comments - posted by William-Sang <gi...@git.apache.org> on 2016/11/21 12:35:28 UTC, 1 replies.
- [GitHub] flink issue #2681: [FLINK-4155] [kafka] Move partition list fetching to open... - posted by rmetzger <gi...@git.apache.org> on 2016/11/21 12:51:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 12:51:58 UTC, 6 replies.
- [GitHub] flink pull request #2842: [FLINK-5097][gelly] Add is missing input type info... - posted by vasia <gi...@git.apache.org> on 2016/11/21 12:56:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 12:56:58 UTC, 13 replies.
- [GitHub] flink issue #2838: [FLINK-4712] [FLINK-4713] [ml] Ranking recommendation & e... - posted by thvasilo <gi...@git.apache.org> on 2016/11/21 12:58:28 UTC, 5 replies.
- [jira] [Created] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 13:52:58 UTC, 0 replies.
- [GitHub] flink pull request #2843: FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP te... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/21 13:56:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 13:56:58 UTC, 5 replies.
- [GitHub] flink issue #2831: [FLINK-5010] [akka] Introduce default configuration value... - posted by zentol <gi...@git.apache.org> on 2016/11/21 14:01:37 UTC, 3 replies.
- [GitHub] flink issue #2839: [FLINK-5071][yarn] adjust vcore validation check - posted by gyfora <gi...@git.apache.org> on 2016/11/21 14:04:17 UTC, 0 replies.
- [GitHub] flink issue #2841: [Docs] Fix a typo in code comments - posted by zentol <gi...@git.apache.org> on 2016/11/21 14:19:57 UTC, 1 replies.
- [jira] [Created] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode() - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 14:23:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 14:30:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 14:30:59 UTC, 0 replies.
- [GitHub] flink pull request #2844: taskManagerMemory attribute set wrong value - posted by 397090770 <gi...@git.apache.org> on 2016/11/21 14:31:36 UTC, 1 replies.
- [jira] [Closed] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 14:31:58 UTC, 0 replies.
- [GitHub] flink issue #2739: [FLINK-4991] [taskmanager] Fix too aggressive timeout and... - posted by zentol <gi...@git.apache.org> on 2016/11/21 14:35:12 UTC, 0 replies.
- [GitHub] flink pull request #2845: [FLINK-5096] Make the RollingSink rescalable. - posted by kl0u <gi...@git.apache.org> on 2016/11/21 14:37:10 UTC, 8 replies.
- [jira] [Commented] (FLINK-5096) Make the RollingSink rescalable. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 14:37:58 UTC, 13 replies.
- [jira] [Commented] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode() - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/21 14:40:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/21 14:50:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/21 14:50:58 UTC, 1 replies.
- [GitHub] flink issue #2826: [backport] [FLINK-5085] Execute CheckpointCoordinator's s... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/21 14:55:05 UTC, 4 replies.
- [jira] [Created] (FLINK-5112) Remove unused accumulator code from ArchivedExecutionJobVertex - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/21 14:59:59 UTC, 0 replies.
- [GitHub] flink pull request #2846: [FLINK-5112] [ExecutionGraph] Remove unused accumu... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/21 15:02:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-5112) Remove unused accumulator code from ArchivedExecutionJobVertex - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/21 15:02:59 UTC, 3 replies.
- [GitHub] flink issue #2846: [FLINK-5112] [ExecutionGraph] Remove unused accumulator a... - posted by zentol <gi...@git.apache.org> on 2016/11/21 15:08:23 UTC, 1 replies.
- [jira] [Closed] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode() - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 15:14:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/21 15:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5113) Make all the testing Functions implement the CheckpointedFucntion interface. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 15:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5114) PartitionState update with finished execution fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:25:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5115) Minimum time between checkpoints computed from trigger timestamp - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5116) Missing RocksDB state backend factory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5117) Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 15:35:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:37:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5118) Inconsistent records sent/received metrics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:45:58 UTC, 0 replies.
- [GitHub] flink pull request #2842: [FLINK-5097][gelly] Add missing input type informa... - posted by greghogan <gi...@git.apache.org> on 2016/11/21 15:52:50 UTC, 7 replies.
- [GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to... - posted by vasia <gi...@git.apache.org> on 2016/11/21 16:09:10 UTC, 4 replies.
- [jira] [Created] (FLINK-5119) Last taskmanager heartbeat not showing in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 16:11:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5120) Show TM PID in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 16:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5121) Integrate YARN application ID with web interface - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 16:28:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5118) Inconsistent records sent/received metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/21 16:29:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/21 16:39:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 16:52:58 UTC, 0 replies.
- [GitHub] flink issue #2319: [FLINK-4294] [table] Allow access of composite type field... - posted by twalthr <gi...@git.apache.org> on 2016/11/21 17:11:20 UTC, 2 replies.
- [GitHub] flink issue #2744: [FLINK-4928] [yarn] Implement FLIP-6 YARN Application Mas... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/21 17:20:05 UTC, 2 replies.
- [jira] [Updated] (FLINK-5113) Make all Testing Functions implement CheckpointedFunction Interface. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/21 17:25:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/21 17:54:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/21 19:46:58 UTC, 0 replies.
- [GitHub] flink issue #2834: [docs] Fix broken links and incorrect examples - posted by fhueske <gi...@git.apache.org> on 2016/11/21 20:04:03 UTC, 0 replies.
- [jira] [Created] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load - posted by "static-max (JIRA)" <ji...@apache.org> on 2016/11/21 21:47:58 UTC, 0 replies.
- [GitHub] flink pull request #2847: [FLINK-5031]Consecutive DataStream.split() ignored - posted by Renkai <gi...@git.apache.org> on 2016/11/22 06:16:48 UTC, 0 replies.
- [GitHub] flink pull request #2848: [FLINK-2662] [optimizer] Fix computation of global... - posted by fhueske <gi...@git.apache.org> on 2016/11/22 07:29:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/22 07:49:58 UTC, 4 replies.
- [jira] [Resolved] (FLINK-4294) Allow access of composite type fields - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/22 08:21:58 UTC, 0 replies.
- [GitHub] flink issue #2816: [backport] [FLINK-5073] Use Executor to run ZooKeeper cal... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/22 08:46:30 UTC, 0 replies.
- [GitHub] flink pull request #2826: [backport] [FLINK-5085] Execute CheckpointCoordina... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/22 08:49:16 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4895) Drop support for Hadoop 1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/22 09:49:58 UTC, 0 replies.
- [GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra... - posted by tonycox <gi...@git.apache.org> on 2016/11/22 10:13:49 UTC, 7 replies.
- [GitHub] flink issue #2825: [FLINK-5085] Execute CheckpointCoordinator's state discar... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/22 10:23:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/22 10:28:58 UTC, 2 replies.
- [GitHub] flink issue #2840: [FLINK-4832] Count/Sum 0 elements - posted by ex00 <gi...@git.apache.org> on 2016/11/22 11:14:42 UTC, 7 replies.
- [jira] [Created] (FLINK-5123) Add description how to do proper shading to Flink docs. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/22 11:50:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5123) Add description how to do proper shading to Flink docs. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/22 11:58:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5123) Add description how to do proper shading to Flink docs. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/22 11:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5124) Support more temporal arithmetic - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/22 12:01:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 14:18:59 UTC, 1 replies.
- [jira] [Created] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 14:18:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5121) Integrate YARN application ID with web interface - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/22 14:38:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5126) Remove Checked Exceptions from State Interfaces - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 14:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/22 15:01:07 UTC, 0 replies.
- [GitHub] flink pull request #2849: [FLINK-4631] Fixed stream task that was interrupte... - posted by chermenin <gi...@git.apache.org> on 2016/11/22 15:11:31 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/22 15:13:59 UTC, 0 replies.
- [GitHub] flink pull request #2850: [FLINK-4895] Drop Hadoop1 support - posted by rmetzger <gi...@git.apache.org> on 2016/11/22 15:16:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-4895) Drop support for Hadoop 1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 15:16:58 UTC, 7 replies.
- [GitHub] flink issue #2623: [FLINK-2608] Updated Twitter Chill version. - posted by chermenin <gi...@git.apache.org> on 2016/11/22 15:20:50 UTC, 5 replies.
- [jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 15:20:58 UTC, 6 replies.
- [GitHub] flink pull request #2681: [FLINK-4155] [kafka] Move partition list fetching ... - posted by asfgit <gi...@git.apache.org> on 2016/11/22 15:53:05 UTC, 0 replies.
- [jira] [Created] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/22 15:57:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/22 16:19:58 UTC, 0 replies.
- [GitHub] flink issue #2705: [FLINK-2597][FLINK-4050] Add wrappers for Kafka serialize... - posted by tzulitai <gi...@git.apache.org> on 2016/11/22 16:25:07 UTC, 0 replies.
- [jira] [Created] (FLINK-5129) make the BlobServer use a distributed file system - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/22 16:25:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 16:25:59 UTC, 0 replies.
- [GitHub] flink issue #2788: [FLINK-5026] Rename TimelyFlatMap to Process - posted by aljoscha <gi...@git.apache.org> on 2016/11/22 16:40:10 UTC, 2 replies.
- [GitHub] flink issue #2835: [FLINK-3869] WindowedStream.apply with FoldFunction is to... - posted by aljoscha <gi...@git.apache.org> on 2016/11/22 16:45:34 UTC, 1 replies.
- [jira] [Closed] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 16:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5130) Remove Deprecated Methods from WindowedStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 16:47:58 UTC, 0 replies.
- [GitHub] flink issue #2850: [FLINK-4895] Drop Hadoop1 support - posted by greghogan <gi...@git.apache.org> on 2016/11/22 16:58:37 UTC, 5 replies.
- [jira] [Commented] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/22 17:16:58 UTC, 0 replies.
- [GitHub] flink pull request #2851: [FLINK-5124] [table] Support more temporal arithme... - posted by twalthr <gi...@git.apache.org> on 2016/11/22 17:33:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-5124) Support more temporal arithmetic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 17:33:58 UTC, 4 replies.
- [GitHub] flink pull request #2852: Fix misprint in condition - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/22 18:55:28 UTC, 1 replies.
- [GitHub] flink issue #2852: Fix misprint in condition - posted by fhueske <gi...@git.apache.org> on 2016/11/22 19:16:31 UTC, 1 replies.
- [GitHub] flink issue #2824: [FLINK-5050] JSON.org license is CatX - posted by tedyu <gi...@git.apache.org> on 2016/11/22 21:25:35 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/22 21:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/22 22:11:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/22 22:11:58 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/11/22 22:12:29 UTC, 0 replies.
- [jira] [Closed] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/22 22:12:58 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/11/22 22:12:58 UTC, 0 replies.
- [GitHub] flink issue #2691: [FLINK-4910] Introduce safety net for closing file system... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/22 22:15:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-4910) Introduce safety net for closing file system streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/22 22:16:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/22 23:26:58 UTC, 0 replies.
- [GitHub] flink pull request #2691: [FLINK-4910] Introduce safety net for closing file... - posted by asfgit <gi...@git.apache.org> on 2016/11/22 23:27:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4910) Introduce safety net for closing file system streams - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/22 23:27:59 UTC, 0 replies.
- [GitHub] flink issue #2541: [FLINK-4669] scala api createLocalEnvironment() function ... - posted by shijinkui <gi...@git.apache.org> on 2016/11/23 00:12:35 UTC, 3 replies.
- [jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/23 00:12:59 UTC, 3 replies.
- [jira] [Created] (FLINK-5131) Fine-grained Resource Configuration - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 02:23:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5131) Fine-grained Resource Configuration - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:12:58 UTC, 4 replies.
- [jira] [Created] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:30:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:41:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5133) Add new setResource API for DataStream and DataSet - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:45:58 UTC, 0 replies.
- [GitHub] flink issue #2768: [FLINK-5023][FLINK-5024] Add SimpleStateDescriptor to cla... - posted by shixiaogang <gi...@git.apache.org> on 2016/11/23 03:49:51 UTC, 5 replies.
- [jira] [Updated] (FLINK-5133) Add new setResource API for DataStream and DataSet - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:01:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:03:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating job graph - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:05:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5135) ResourceProfile should be expanded to correspond with ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:26:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:28:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5136) ResourceManager should consider both slot resource profile and framework memory for requesting resource from cluster - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:35:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory for requesting resource from cluster by ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:37:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:42:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5137) Config JVM options and set onto the TaskManager container - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:57:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5137) Config JVM options and set onto the TaskManager container - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:01:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5137) Config JVM options and set onto the TaskManager container - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:01:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:02:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5136) Aggregation of slot ResourceProfile and framework memory by ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:02:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5133) Add new setResource API for DataStream and DataSet - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:02:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:02:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating job graph - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:02:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:15:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:16:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5139) consum kafka can set offset - posted by "jing lining (JIRA)" <ji...@apache.org> on 2016/11/23 07:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/23 07:53:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5141) Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/23 08:54:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5124) Support more temporal arithmetic - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/23 09:08:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 09:27:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 09:28:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Frank Lauterwald (JIRA)" <ji...@apache.org> on 2016/11/23 09:33:58 UTC, 0 replies.
- [GitHub] flink pull request #2623: [FLINK-2608] Updated Twitter Chill version. - posted by asfgit <gi...@git.apache.org> on 2016/11/23 09:41:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/23 09:45:59 UTC, 1 replies.
- [jira] [Reopened] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/23 09:47:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/23 09:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5143) Add EXISTS to list of supported operators - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/23 10:01:58 UTC, 0 replies.
- [GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/23 10:08:45 UTC, 7 replies.
- [GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit... - posted by rmetzger <gi...@git.apache.org> on 2016/11/23 10:09:20 UTC, 26 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/11/23 10:09:59 UTC, 28 replies.
- [GitHub] flink issue #2687: [FLINK-3123] [kafka] Allow custom specific start offsets ... - posted by rmetzger <gi...@git.apache.org> on 2016/11/23 10:10:40 UTC, 0 replies.
- [GitHub] flink pull request #2853: [FLINK-5143] [table] Add EXISTS to list of support... - posted by twalthr <gi...@git.apache.org> on 2016/11/23 10:48:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-5143) Add EXISTS to list of supported operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/23 10:48:58 UTC, 3 replies.
- [GitHub] flink pull request #2854: [typo] fix toString() of ContinuousEventTimeTrigge... - posted by mxm <gi...@git.apache.org> on 2016/11/23 11:03:22 UTC, 1 replies.
- [GitHub] flink issue #2854: [typo] fix toString() of ContinuousEventTimeTrigger - posted by zentol <gi...@git.apache.org> on 2016/11/23 11:07:38 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/23 11:14:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/23 11:14:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/23 11:15:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-5126) Remove Checked Exceptions from State Interfaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/23 11:16:58 UTC, 1 replies.
- [GitHub] flink pull request #2855: Add Tests in StateBackendTestBase that verify Defa... - posted by aljoscha <gi...@git.apache.org> on 2016/11/23 11:17:13 UTC, 3 replies.
- [jira] [Commented] (FLINK-4941) Show ship strategy in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/23 11:24:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4941) Show ship strategy in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/23 11:24:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/23 11:26:58 UTC, 0 replies.
- [GitHub] flink issue #2553: [FLINK-4686] [table] Add possibility to get column names - posted by twalthr <gi...@git.apache.org> on 2016/11/23 11:32:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-4686) Add possibility to get column names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/23 11:32:59 UTC, 0 replies.
- [GitHub] flink issue #2849: [FLINK-4631] Fixed stream task that was interrupted befor... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/23 11:45:30 UTC, 0 replies.
- [GitHub] flink issue #2848: [FLINK-2662] [optimizer] Fix computation of global proper... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/23 11:47:05 UTC, 2 replies.
- [GitHub] flink issue #2833: [FLINK-5103] [Metrics] TaskManager process virtual memory... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/23 11:58:08 UTC, 0 replies.
- [GitHub] flink issue #2823: [FLINK-4872] [types] Type erasure problem exclusively on ... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/23 12:04:22 UTC, 3 replies.
- [jira] [Created] (FLINK-5145) WebInterface to aggressive in pulling metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 12:06:59 UTC, 0 replies.
- [GitHub] flink pull request #2856: Removed excessive tests. - posted by chermenin <gi...@git.apache.org> on 2016/11/23 12:22:54 UTC, 1 replies.
- [GitHub] flink issue #2767: [FLINK-4988] Elasticsearch 5.x support - posted by StephanEwen <gi...@git.apache.org> on 2016/11/23 12:23:39 UTC, 4 replies.
- [jira] [Closed] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/23 13:10:59 UTC, 0 replies.
- [GitHub] flink issue #2853: [FLINK-5143] [table] Add EXISTS to list of supported oper... - posted by fhueske <gi...@git.apache.org> on 2016/11/23 13:12:01 UTC, 1 replies.
- [jira] [Created] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/23 13:22:58 UTC, 0 replies.
- [GitHub] flink pull request #2857: [FLINK-5146] Improved resource cleanup in RocksDB ... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/23 13:29:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/23 13:29:58 UTC, 3 replies.
- [jira] [Updated] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/23 13:33:58 UTC, 1 replies.
- [jira] [Created] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 13:33:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5000) Rename Methods in ManagedInitializationContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/23 13:58:58 UTC, 0 replies.
- [GitHub] flink pull request #2858: [FLINK-5000] Rename Methods in ManagedInitializati... - posted by aljoscha <gi...@git.apache.org> on 2016/11/23 13:59:47 UTC, 1 replies.
- [GitHub] flink issue #2858: [FLINK-5000] Rename Methods in ManagedInitializationConte... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/23 14:01:14 UTC, 0 replies.
- [GitHub] flink issue #2857: [FLINK-5146] Improved resource cleanup in RocksDB keyed s... - posted by aljoscha <gi...@git.apache.org> on 2016/11/23 14:29:55 UTC, 2 replies.
- [jira] [Created] (FLINK-5148) LocalFileSystem#delete can fail with NullpointerException - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 14:35:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5148) LocalFileSystem#delete can fail with NullpointerException - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 14:36:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 14:38:59 UTC, 0 replies.
- [GitHub] flink pull request #2859: [FLINK-5147] Prevent NPE in LocalFS#delete() - posted by zentol <gi...@git.apache.org> on 2016/11/23 14:44:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/23 14:44:58 UTC, 3 replies.
- [jira] [Created] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/23 14:59:59 UTC, 0 replies.
- [GitHub] flink pull request #2860: [FLINK-5149] let ContinuousEventTimeTrigger fire a... - posted by mxm <gi...@git.apache.org> on 2016/11/23 15:03:05 UTC, 1 replies.
- [GitHub] flink issue #2860: [FLINK-5149] let ContinuousEventTimeTrigger fire at the e... - posted by mxm <gi...@git.apache.org> on 2016/11/23 15:03:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/23 15:03:58 UTC, 5 replies.
- [GitHub] flink issue #2859: [FLINK-5147] Prevent NPE in LocalFS#delete() - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/23 15:08:13 UTC, 2 replies.
- [GitHub] flink issue #2755: [hotfix][docs] Stream joins don't support tuple position ... - posted by fhueske <gi...@git.apache.org> on 2016/11/23 15:09:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-5061) Remove ContinuousEventTimeTrigger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/23 15:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5150) WebUI metric-related resource leak - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 15:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5150) WebUI metric-related resource leak - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5151) Add discussion about object mutations to heap-based state backend docs. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 16:11:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3555) Web interface does not render job information properly - posted by "Sergey Sokur (JIRA)" <ji...@apache.org> on 2016/11/23 16:11:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4900) Implement Docker image support - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/23 16:45:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load - posted by "static-max (JIRA)" <ji...@apache.org> on 2016/11/23 16:52:58 UTC, 0 replies.
- [GitHub] flink pull request #2861: [FLINK-5122] Index requests will be retried if the... - posted by static-max <gi...@git.apache.org> on 2016/11/23 16:58:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction - posted by "static-max (JIRA)" <ji...@apache.org> on 2016/11/23 17:06:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/23 17:16:58 UTC, 0 replies.
- [GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con... - posted by tzulitai <gi...@git.apache.org> on 2016/11/23 17:32:34 UTC, 1 replies.
- [jira] [Closed] (FLINK-5143) Add EXISTS to list of supported operators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 20:17:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-4937) Add incremental group window aggregation for streaming Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 20:17:59 UTC, 0 replies.
- [jira] [Closed] (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/11/23 20:18:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 20:37:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/23 23:11:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5000) Rename Methods in ManagedInitializationContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 07:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5152) accepting NullValue for EV in Gelly examples - posted by "wouter ligtenberg (JIRA)" <ji...@apache.org> on 2016/11/24 09:05:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5152) accepting NullValue for EV in Gelly examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/24 09:18:58 UTC, 1 replies.
- [jira] [Closed] (FLINK-5152) accepting NullValue for EV in Gelly examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/24 09:21:59 UTC, 0 replies.
- [GitHub] flink issue #2856: Removed excessive tests. - posted by mxm <gi...@git.apache.org> on 2016/11/24 10:04:39 UTC, 2 replies.
- [jira] [Created] (FLINK-5153) Allow setting custom application tags for Flink on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/24 10:27:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/24 10:36:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/24 10:38:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/11/24 10:45:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/24 10:58:59 UTC, 0 replies.
- [GitHub] flink issue #2845: [FLINK-5096] Make the RollingSink rescalable. - posted by kl0u <gi...@git.apache.org> on 2016/11/24 11:22:46 UTC, 4 replies.
- [jira] [Created] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 11:28:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 11:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 11:49:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 11:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/11/24 13:13:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/24 14:02:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5157) Extending AllWindow Function Metadata - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2016/11/24 14:38:59 UTC, 0 replies.
- [GitHub] flink pull request #2862: [FLINK-4741] Fix for the proper shutdown the Serve... - posted by MayerRoman <gi...@git.apache.org> on 2016/11/24 15:32:22 UTC, 1 replies.
- [jira] [Commented] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 15:32:58 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/24 15:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/24 16:15:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/24 16:16:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/24 16:26:58 UTC, 1 replies.
- [GitHub] flink pull request #2863: [FLINK-5051] Backwards compatibility for serialize... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/24 16:26:58 UTC, 0 replies.
- [GitHub] flink issue #2863: [FLINK-5051] Backwards compatibility for serializers in b... - posted by StefanRRichter <gi...@git.apache.org> on 2016/11/24 16:27:23 UTC, 0 replies.
- [GitHub] flink pull request #2864: [FLINK-5055][security] skip Hadoop UGI login if un... - posted by mxm <gi...@git.apache.org> on 2016/11/24 17:19:13 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/11/24 21:52:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4649) Implement bipartite graph metrics - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/24 22:21:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/24 22:32:58 UTC, 0 replies.
- [GitHub] flink pull request #2865: [FLINK-5002] Renamed getNumberOfUsedBuffers() meth... - posted by MayerRoman <gi...@git.apache.org> on 2016/11/25 07:39:46 UTC, 0 replies.
- [jira] [Created] (FLINK-5159) Improve perfomance of inner joins with a single row input - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/11/25 08:57:59 UTC, 0 replies.
- [GitHub] flink pull request #2866: [FLINK-5101] Refactor CassandraConnectorITCase - posted by zentol <gi...@git.apache.org> on 2016/11/25 10:57:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-5101) Test CassandraConnectorITCase instable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 10:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5160) SecurityContextTest#testCreateInsecureHadoopCtx fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 11:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5161) accepting NullValue for VV in Gelly examples and GSA - posted by "wouter ligtenberg (JIRA)" <ji...@apache.org> on 2016/11/25 11:56:58 UTC, 0 replies.
- [GitHub] flink issue #2862: [FLINK-4741] Fix for the proper shutdown the ServerBootst... - posted by zentol <gi...@git.apache.org> on 2016/11/25 12:12:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-5161) accepting NullValue for VV in Gelly examples and GSA - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/25 12:17:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5161) accepting NullValue for VV in Gelly examples and GSA - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/25 12:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5162) BlobRecoveryItCase#testBlobServerRecovery fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 12:23:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4870) ContinuousFileMonitoringFunction does not properly handle absolut Windows paths - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 12:25:58 UTC, 0 replies.
- [GitHub] flink pull request #2867: [FLINK-5145] WebInterface only polls selected metr... - posted by zentol <gi...@git.apache.org> on 2016/11/25 12:58:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-5145) WebInterface to aggressive in pulling metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 12:58:58 UTC, 0 replies.
- [GitHub] flink pull request #2868: [FLINK-4565] Support for SQL IN operator - posted by NickolayVasilishin <gi...@git.apache.org> on 2016/11/25 13:09:23 UTC, 1 replies.
- [jira] [Created] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/25 13:20:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/25 13:34:59 UTC, 4 replies.
- [GitHub] flink pull request #2869: [FLINK-3555] Web interface does not render job inf... - posted by bitchelov <gi...@git.apache.org> on 2016/11/25 13:46:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-3555) Web interface does not render job information properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 13:46:58 UTC, 2 replies.
- [jira] [Resolved] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 14:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 14:07:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/25 14:36:58 UTC, 0 replies.
- [GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit... - posted by AlexanderShoshin <gi...@git.apache.org> on 2016/11/25 14:59:47 UTC, 16 replies.
- [jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 14:59:58 UTC, 16 replies.
- [GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator - posted by NickolayVasilishin <gi...@git.apache.org> on 2016/11/25 15:03:53 UTC, 0 replies.
- [jira] [Reopened] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/25 15:17:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/25 15:17:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:17:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:17:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:17:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/25 15:17:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4950) Add support to include multiple Yarn application entries in Yarn properties file - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:19:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4950) Add support to include multiple Yarn application entries in Yarn properties file - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:19:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3932) Implement State Backend Security - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:20:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:20:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-3931) Implement Transport Encryption (SSL/TLS) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:20:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4897) Implement Dispatcher - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:22:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:22:59 UTC, 2 replies.
- [jira] [Created] (FLINK-5165) Checkpointing tests using FsStatebackend fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 15:22:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4901) Build DCOS Docker image - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:23:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4899) Implement DCOS package - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:23:58 UTC, 1 replies.
- [jira] [Updated] (FLINK-4918) Add SSL support to Mesos artifact server - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:24:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:24:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-4921) Upgrade to Mesos 1.0.1 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:24:59 UTC, 1 replies.
- [GitHub] flink issue #2827: [FLINK-4921] Upgrade to Mesos 1.0.1 - posted by mxm <gi...@git.apache.org> on 2016/11/25 15:27:08 UTC, 3 replies.
- [jira] [Updated] (FLINK-5029) Implement KvState SSL - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:27:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-5030) Support hostname verification - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:27:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4922) Write documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:27:59 UTC, 1 replies.
- [jira] [Updated] (FLINK-5091) Formalize the AppMaster environment for docker compability - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:28:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-3883) Rename flink clients for inclusion on system path - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:33:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-3903) Homebrew Installation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:34:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-3903) Homebrew Installation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:34:58 UTC, 0 replies.
- [GitHub] flink issue #2843: FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP test fail... - posted by zentol <gi...@git.apache.org> on 2016/11/25 15:36:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/25 15:37:59 UTC, 0 replies.
- [GitHub] flink pull request #2871: [FLINK-5163] Ports the production functions to the... - posted by kl0u <gi...@git.apache.org> on 2016/11/25 15:58:15 UTC, 0 replies.
- [GitHub] flink pull request #2872: [FLINK-5158] [ckPtCoord] Handle exceptions from Co... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/25 15:58:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 15:58:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/25 15:58:59 UTC, 6 replies.
- [jira] [Assigned] (FLINK-4680) Add SlidingRow row-windows for streaming tables - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/25 16:01:00 UTC, 0 replies.
- [GitHub] flink pull request #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/25 16:19:02 UTC, 4 replies.
- [jira] [Created] (FLINK-5166) TextInputFormatTest.testNestedFileRead - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/25 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5167) StreamExecutionEnvironment's set function return `this` instead of void - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/26 00:21:58 UTC, 0 replies.
- [GitHub] flink pull request #2874: [FLINK-5167] StreamExecutionEnvironment set functi... - posted by shijinkui <gi...@git.apache.org> on 2016/11/26 07:22:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-5167) StreamExecutionEnvironment's set function return `this` instead of void - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/26 07:22:58 UTC, 4 replies.
- [jira] [Created] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link} - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/26 08:13:59 UTC, 0 replies.
- [GitHub] flink pull request #2875: [FLINK-5168] Scaladoc annotation link use [[]] ins... - posted by shijinkui <gi...@git.apache.org> on 2016/11/26 08:16:50 UTC, 3 replies.
- [jira] [Commented] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link} - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/26 08:16:59 UTC, 5 replies.
- [jira] [Updated] (FLINK-5166) TextInputFormatTest.testNestedFileRead - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/26 08:20:58 UTC, 2 replies.
- [GitHub] flink issue #2874: [FLINK-5167] StreamExecutionEnvironment set function retu... - posted by fhueske <gi...@git.apache.org> on 2016/11/26 08:50:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-5166) TextInputFormatTest.testNestedFileRead - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/26 09:12:58 UTC, 7 replies.
- [GitHub] flink pull request #2876: [FLINK-5166] TextInputFormatTest.testNestedFileRea... - posted by shijinkui <gi...@git.apache.org> on 2016/11/26 09:46:02 UTC, 3 replies.
- [GitHub] flink issue #2876: [FLINK-5166] TextInputFormatTest.testNestedFileRead - posted by zentol <gi...@git.apache.org> on 2016/11/26 19:14:57 UTC, 1 replies.
- [jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/11/27 04:31:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5096) Make the RollingSink rescalable. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/27 11:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/27 11:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5112) Remove unused accumulator code from ArchivedExecutionJobVertex - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/27 11:52:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/28 07:42:58 UTC, 0 replies.
- [GitHub] flink pull request #2877: [FLINK-5141] Implement Flip6LocalStreamEnvironment... - posted by ifndef-SleePy <gi...@git.apache.org> on 2016/11/28 07:55:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 07:55:58 UTC, 1 replies.
- [GitHub] flink pull request #2878: [FLINK-4929] [yarn] Implement FLIP-6 YARN TaskExec... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/28 08:34:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-4929) Implement FLIP-6 YARN TaskManager Runner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 08:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5169) Make consumption of input channels fair - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 08:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/28 09:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/28 09:10:59 UTC, 0 replies.
- [GitHub] flink issue #2875: [FLINK-5168] Scaladoc annotation link use [[]] instead of... - posted by fhueske <gi...@git.apache.org> on 2016/11/28 09:14:25 UTC, 1 replies.
- [GitHub] flink pull request #2879: [FLINK-5170] [runtime] fix mis judge of hostname i... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/28 09:17:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 09:17:59 UTC, 3 replies.
- [jira] [Closed] (FLINK-5167) StreamExecutionEnvironment's set function return `this` instead of void - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/28 09:19:58 UTC, 0 replies.
- [GitHub] flink pull request #2880: [FLINK-5171] [runtime] fix wrong use of Preconditi... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/28 09:23:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 09:23:58 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3787) Yarn client does not report unfulfillable container constraints - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/11/28 09:25:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 09:51:58 UTC, 0 replies.
- [GitHub] flink pull request #2881: [FLINK-4993] Don't Allow Trigger.onMerge() to retu... - posted by aljoscha <gi...@git.apache.org> on 2016/11/28 10:09:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-4100) RocksDBStateBackend#close() can throw NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 10:13:58 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3787) Yarn client does not report unfulfillable container constraints - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/28 10:19:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 10:21:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4100) RocksDBStateBackend#close() can throw NPE - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/28 10:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5173) Upgrade RocksDB dependency - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 10:37:58 UTC, 0 replies.
- [GitHub] flink pull request #2882: [FLINK-5169] [network] Make consumption of InputCh... - posted by uce <gi...@git.apache.org> on 2016/11/28 10:40:47 UTC, 5 replies.
- [jira] [Commented] (FLINK-5169) Make consumption of input channels fair - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 10:40:58 UTC, 6 replies.
- [jira] [Created] (FLINK-5174) Fix memory leak in the CEP library. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/28 10:41:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/28 10:46:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/28 10:47:58 UTC, 0 replies.
- [GitHub] flink issue #2880: [FLINK-5171] [runtime] fix wrong use of Preconditions.che... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/28 10:53:23 UTC, 0 replies.
- [GitHub] flink issue #2879: [FLINK-5170] [runtime] fix mis judge of hostname in AkkaU... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/28 11:02:06 UTC, 1 replies.
- [GitHub] flink issue #2881: [FLINK-4993] Don't Allow Trigger.onMerge() to return Trig... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/28 11:03:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-3893) LeaderChangeStateCleanupTest times out - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 11:07:58 UTC, 0 replies.
- [GitHub] flink pull request #2883: [FLINK-5088] [network] Add capacity limit option t... - posted by uce <gi...@git.apache.org> on 2016/11/28 11:17:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-5088) Add option to limit subpartition queue length - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 11:17:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/28 11:18:58 UTC, 4 replies.
- [GitHub] flink pull request #2884: [FLINK-4825] [table] Implement a RexExecutor that ... - posted by twalthr <gi...@git.apache.org> on 2016/11/28 11:27:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-5175) StreamExecutionEnvironment's set function return `this` instead of void - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/28 11:30:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5175) StreamExecutionEnvironment's set function return `this` instead of void - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/28 11:30:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5176) Properly wait for component shutdown in Runner components - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/28 11:31:58 UTC, 0 replies.
- [GitHub] flink issue #2817: [FLINK-5076] Shutting down TM when shutting down mini clu... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/28 11:32:29 UTC, 1 replies.
- [GitHub] flink issue #2874: [FLINK-5175] StreamExecutionEnvironment's set function re... - posted by shijinkui <gi...@git.apache.org> on 2016/11/28 11:34:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-5175) StreamExecutionEnvironment's set function return `this` instead of void - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 11:34:59 UTC, 1 replies.
- [jira] [Closed] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/28 12:09:58 UTC, 0 replies.
- [GitHub] flink issue #2751: Window operator changes - posted by aljoscha <gi...@git.apache.org> on 2016/11/28 12:10:43 UTC, 0 replies.
- [GitHub] flink issue #2750: [FLINK-5007] [checkpointing] Retain externalized checkpoi... - posted by uce <gi...@git.apache.org> on 2016/11/28 12:45:26 UTC, 0 replies.
- [GitHub] flink issue #2752: [FLINK-4814] [checkpointing] Use checkpoint directory for... - posted by uce <gi...@git.apache.org> on 2016/11/28 12:47:48 UTC, 0 replies.
- [jira] [Created] (FLINK-5177) Improve nullability handling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/28 12:56:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 13:01:01 UTC, 0 replies.
- [GitHub] flink issue #2828: [FLINK-5093] java.util.ConcurrentModificationException is... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/28 14:09:23 UTC, 1 replies.
- [GitHub] flink pull request #2885: Damping - posted by joseprupi <gi...@git.apache.org> on 2016/11/28 14:13:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-2549) Add topK operator for DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 14:13:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 14:13:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5050) JSON.org license is CatX - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 14:15:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5129) make the BlobServer use a distributed file system - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/28 14:15:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5050) JSON.org license is CatX - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 14:15:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link} - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 14:16:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link} - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 14:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/28 14:17:58 UTC, 0 replies.
- [GitHub] flink issue #2855: Add Tests in StateBackendTestBase that verify Default-Val... - posted by aljoscha <gi...@git.apache.org> on 2016/11/28 14:39:39 UTC, 0 replies.
- [jira] [Created] (FLINK-5179) MetricRegistry life-cycle issues with HA - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/28 14:51:58 UTC, 0 replies.
- [GitHub] flink issue #2877: [FLINK-5141] Implement Flip6LocalStreamEnvironment to run... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/28 15:18:40 UTC, 0 replies.
- [GitHub] flink pull request #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG li... - posted by zentol <gi...@git.apache.org> on 2016/11/28 15:19:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 15:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5180) Include blocked on bounded queue length in back pressure stats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 15:20:58 UTC, 0 replies.
- [GitHub] flink issue #2873: [backport] [FLINK-5158] [ckPtCoord] Handle exceptions fro... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/28 15:23:20 UTC, 0 replies.
- [GitHub] flink issue #2883: [FLINK-5088] [network] Add capacity limit option to parti... - posted by StephanEwen <gi...@git.apache.org> on 2016/11/28 15:27:10 UTC, 2 replies.
- [GitHub] flink pull request #2887: [FLINK-4870] [FLINK-5162] Fix issues on windows re... - posted by zentol <gi...@git.apache.org> on 2016/11/28 15:36:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-4870) ContinuousFileMonitoringFunction does not properly handle absolut Windows paths - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 15:36:59 UTC, 0 replies.
- [GitHub] flink pull request #2888: [FLINK-5160] Fix SecurityContextTest#testCreateIns... - posted by zentol <gi...@git.apache.org> on 2016/11/28 15:38:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-5160) SecurityContextTest#testCreateInsecureHadoopCtx fails on windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 15:39:00 UTC, 0 replies.
- [GitHub] flink pull request #2889: [FLINK-5164] Disable some Hadoop-compat tests on W... - posted by zentol <gi...@git.apache.org> on 2016/11/28 15:43:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 15:43:59 UTC, 2 replies.
- [GitHub] flink pull request #2890: [hotfix] properly encapsulate the original excepti... - posted by NicoK <gi...@git.apache.org> on 2016/11/28 15:45:22 UTC, 0 replies.
- [jira] [Created] (FLINK-5181) Add Tests in StateBackendTestBase that verify Default-Value Behaviour - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/28 16:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/28 16:27:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/28 16:28:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5076) Shutting down TM when shutting down new mini cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/28 16:30:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/28 16:31:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/28 16:36:59 UTC, 1 replies.
- [jira] [Closed] (FLINK-5181) Add Tests in StateBackendTestBase that verify Default-Value Behaviour - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/28 17:01:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-3932) Implement State Backend Security - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/11/28 17:28:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 17:32:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 17:32:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5026) Rename TimelyFlatMap to Process - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/28 17:46:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5182) Implement SSL file-shipping - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/28 18:00:00 UTC, 0 replies.
- [GitHub] flink pull request #2891: [FLINK-5129] make the BlobServer use a distributed... - posted by NicoK <gi...@git.apache.org> on 2016/11/28 18:16:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 18:16:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/11/28 19:50:58 UTC, 0 replies.
- [GitHub] flink issue #2882: [FLINK-5169] [network] Make consumption of InputChannels ... - posted by uce <gi...@git.apache.org> on 2016/11/28 19:57:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5183) [py] Support multiple jobs per Python plan file - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/11/28 20:00:59 UTC, 0 replies.
- [GitHub] flink issue #2884: [FLINK-4825] [table] Implement a RexExecutor that uses Fl... - posted by fhueske <gi...@git.apache.org> on 2016/11/28 21:43:10 UTC, 1 replies.
- [GitHub] flink issue #2889: [FLINK-5164] Disable some Hadoop-compat tests on Windows - posted by fhueske <gi...@git.apache.org> on 2016/11/28 21:51:04 UTC, 1 replies.
- [GitHub] flink pull request #2892: [FLINK-5109] fix invalid content-encoding header o... - posted by Hapcy <gi...@git.apache.org> on 2016/11/28 23:24:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/28 23:24:58 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-4692) Add tumbling group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/29 01:49:58 UTC, 0 replies.
- [GitHub] flink pull request #2893: [FLINK-5128]Get Kafka partitions in FlinkKafkaProd... - posted by Renkai <gi...@git.apache.org> on 2016/11/29 06:52:55 UTC, 0 replies.
- [jira] [Created] (FLINK-5184) Error result of compareSerialized in RowComparator class - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/11/29 06:58:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/11/29 07:21:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/11/29 07:22:58 UTC, 4 replies.
- [GitHub] flink issue #2893: [FLINK-5128]Get Kafka partitions in FlinkKafkaProducer on... - posted by tzulitai <gi...@git.apache.org> on 2016/11/29 08:03:42 UTC, 0 replies.
- [jira] [Created] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5187) Create analog of Row in core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5188) Redirect dependencies - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5189) deprecate and delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:56:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 09:01:15 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5184) Error result of compareSerialized in RowComparator class - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/11/29 09:08:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4872) Type erasure problem exclusively on cluster execution - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/29 09:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5190) ZooKeeperLeaderRetrievalService should not close the zk client when stop - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/29 09:27:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/11/29 09:30:58 UTC, 0 replies.
- [GitHub] flink pull request #2894: [FLINK-5184] fix bug: Error result of compareSeria... - posted by godfreyhe <gi...@git.apache.org> on 2016/11/29 11:31:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-5184) Error result of compareSerialized in RowComparator class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 11:31:58 UTC, 3 replies.
- [GitHub] flink issue #2894: [FLINK-5184] fix bug: Error result of compareSerialized i... - posted by fhueske <gi...@git.apache.org> on 2016/11/29 12:10:45 UTC, 1 replies.
- [GitHub] flink pull request #2843: [FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP t... - posted by BorisOsipov <gi...@git.apache.org> on 2016/11/29 12:11:38 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2435) Add support for custom CSV field parsers - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/29 12:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5191) ConnectedComponentsWithDeferredUpdateITCase failed - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/29 14:01:01 UTC, 0 replies.
- [jira] [Created] (FLINK-5192) Provide better log config templates - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5194) Log heartbeats on TRACE level - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:29:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5195) Log JobManager configuration on start up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5196) Don't log InputChannelDescriptor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:34:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5196) Don't log InputChannelDescriptor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5197) Late JobStatusChanges can interfere with running jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5198) Overwrite TaskState toString - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5199) Improve logging of submitted job graph actions in HA case - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:37:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5200) Display recovery information in Webfrontend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:43:59 UTC, 0 replies.
- [GitHub] flink pull request #2874: [FLINK-5175] StreamExecutionEnvironment's set func... - posted by asfgit <gi...@git.apache.org> on 2016/11/29 14:44:14 UTC, 0 replies.
- [jira] [Closed] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/29 14:45:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-4832) Count/Sum 0 elements - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/29 14:46:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-5184) Error result of compareSerialized in RowComparator class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/29 14:52:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-5195) Log JobManager configuration on start up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5197) Late JobStatusChanged messages can interfere with running jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5201) Promote loaded config properties to INFO - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:01:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:02:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4260) Allow SQL's LIKE ESCAPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/29 15:03:58 UTC, 0 replies.
- [GitHub] flink pull request #2895: [FLINK-5197] [jm] Ignore outdated JobStatusChanged... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/29 15:06:41 UTC, 1 replies.
- [jira] [Created] (FLINK-5203) YARNHighAvailabilityITCase fails to deploy YARN cluster - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:06:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5197) Late JobStatusChanged messages can interfere with running jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 15:06:58 UTC, 7 replies.
- [GitHub] flink pull request #2896: [FLINK-5197] [jm] Ignore outdated JobStatusChanged... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/29 15:07:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5204) Flakey YARNSessionCapacitySchedulerITCase (NullPointerException) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5205) Asynchronous remove job messages can interfere with recovered or resubmitted jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 15:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5206) Flakey PythonPlanBinderTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:17:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5206) Flakey PythonPlanBinderTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/29 15:22:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5207) Decrease HadoopFileSystem logging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 16:02:59 UTC, 0 replies.
- [GitHub] flink issue #2892: [FLINK-5109] fix invalid content-encoding header of webmo... - posted by greghogan <gi...@git.apache.org> on 2016/11/29 16:21:18 UTC, 1 replies.
- [GitHub] flink pull request #2897: [FLINK-4676] [connectors] Merge batch and streamin... - posted by fhueske <gi...@git.apache.org> on 2016/11/29 16:57:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 16:57:58 UTC, 1 replies.
- [GitHub] flink issue #2896: [FLINK-5197] [jm] Ignore outdated JobStatusChanged messag... - posted by uce <gi...@git.apache.org> on 2016/11/29 17:12:25 UTC, 0 replies.
- [jira] [Created] (FLINK-5208) Increase application attempt timeout for the YARN tests on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/29 17:15:59 UTC, 0 replies.
- [GitHub] flink pull request #2898: [FLINK-5109] fix invalid content-encoding header o... - posted by Hapcy <gi...@git.apache.org> on 2016/11/29 17:16:48 UTC, 0 replies.
- [GitHub] flink pull request #2899: Various logging improvements - posted by uce <gi...@git.apache.org> on 2016/11/29 17:34:52 UTC, 9 replies.
- [GitHub] flink pull request #2900: Rebased: Keytab & TLS support for Flink on Mesos S... - posted by mxm <gi...@git.apache.org> on 2016/11/29 17:47:01 UTC, 1 replies.
- [GitHub] flink issue #2898: [FLINK-5109] fix invalid content-encoding header of webmo... - posted by greghogan <gi...@git.apache.org> on 2016/11/29 17:49:30 UTC, 2 replies.
- [jira] [Closed] (FLINK-4921) Upgrade to Mesos 1.0.1 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/29 17:51:58 UTC, 0 replies.
- [GitHub] flink pull request #2901: [FLINK-3921] StringParser encoding - posted by greghogan <gi...@git.apache.org> on 2016/11/29 18:05:54 UTC, 0 replies.
- [jira] [Created] (FLINK-5209) Fix TaskManager metrics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/29 21:24:58 UTC, 0 replies.
- [GitHub] flink pull request #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics - posted by greghogan <gi...@git.apache.org> on 2016/11/29 22:05:35 UTC, 7 replies.
- [jira] [Commented] (FLINK-5209) Fix TaskManager metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/29 22:05:59 UTC, 7 replies.
- [jira] [Assigned] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state - posted by "Roman Maier (JIRA)" <ji...@apache.org> on 2016/11/30 07:14:58 UTC, 0 replies.
- [GitHub] flink pull request #2903: [FLINK-5704] [runtime] add a zookeeper based runni... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/30 08:37:45 UTC, 0 replies.
- [GitHub] flink pull request #2904: [FLINK-5091] Formalize the Mesos AppMaster environ... - posted by EronWright <gi...@git.apache.org> on 2016/11/30 08:41:30 UTC, 1 replies.
- [jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 08:41:58 UTC, 1 replies.
- [GitHub] flink pull request #2905: [FLINK-5190] [runtime] fix ZooKeeperLeaderRetrieva... - posted by shuai-xu <gi...@git.apache.org> on 2016/11/30 09:10:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-5190) ZooKeeperLeaderRetrievalService should not close the zk client when stop - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 09:10:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Andrew Efimov (JIRA)" <ji...@apache.org> on 2016/11/30 09:40:58 UTC, 0 replies.
- [GitHub] flink pull request #2906: [FLINK-5132][FLINK-5133][FLINK-5134][Core,DataStre... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/11/30 09:52:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 09:52:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/30 09:58:58 UTC, 0 replies.
- [GitHub] flink pull request #2907: [FLINK-5135][JM]ResourceProfile for slot request s... - posted by wangzhijiang999 <gi...@git.apache.org> on 2016/11/30 10:17:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 10:17:59 UTC, 0 replies.
- [GitHub] flink issue #2900: Rebased: Keytab & TLS support for Flink on Mesos Setup - posted by mxm <gi...@git.apache.org> on 2016/11/30 10:41:00 UTC, 1 replies.
- [GitHub] flink issue #2897: [FLINK-4676] [connectors] Merge batch and streaming conne... - posted by zentol <gi...@git.apache.org> on 2016/11/30 10:50:09 UTC, 0 replies.
- [GitHub] flink pull request #2908: [maven] properly attach the CEP Scala source code - posted by mxm <gi...@git.apache.org> on 2016/11/30 11:26:32 UTC, 1 replies.
- [jira] [Updated] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/30 12:17:58 UTC, 0 replies.
- [GitHub] flink issue #2896: [backport] [FLINK-5197] [jm] Ignore outdated JobStatusCha... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/30 12:40:01 UTC, 0 replies.
- [GitHub] flink issue #2895: [FLINK-5197] [jm] Ignore outdated JobStatusChanged messag... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/30 12:45:03 UTC, 1 replies.
- [jira] [Closed] (FLINK-5197) Late JobStatusChanged messages can interfere with running jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 12:47:58 UTC, 0 replies.
- [GitHub] flink pull request #2896: [backport] [FLINK-5197] [jm] Ignore outdated JobSt... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/30 12:48:14 UTC, 0 replies.
- [GitHub] flink issue #2908: [maven] properly attach the CEP Scala source code - posted by zentol <gi...@git.apache.org> on 2016/11/30 12:52:07 UTC, 0 replies.
- [GitHub] flink pull request #2909: [FLINK-5193] [jm] Harden job recovery in case of r... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/30 13:11:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 13:11:59 UTC, 4 replies.
- [GitHub] flink pull request #2910: [backport] [FLINK-5193] [jm] Harden job recovery i... - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/30 13:13:08 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2435) Add support for custom CSV field parsers - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/11/30 14:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5210) Failing performCheckpoint method causes task to fail - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 14:06:58 UTC, 0 replies.
- [GitHub] flink issue #2891: [FLINK-5129] make the BlobServer use a distributed file s... - posted by NicoK <gi...@git.apache.org> on 2016/11/30 14:12:29 UTC, 0 replies.
- [GitHub] flink issue #2899: Various logging improvements - posted by tillrohrmann <gi...@git.apache.org> on 2016/11/30 14:20:22 UTC, 1 replies.
- [GitHub] flink pull request #2911: [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to p... - posted by NicoK <gi...@git.apache.org> on 2016/11/30 14:42:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 14:42:58 UTC, 1 replies.
- [GitHub] flink issue #2911: [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to point to... - posted by NicoK <gi...@git.apache.org> on 2016/11/30 14:44:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-4895) Drop support for Hadoop 1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/30 14:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5211) Include an example configuration for all reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/30 14:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/30 15:01:10 UTC, 0 replies.
- [GitHub] flink pull request #2912: [FLINK-5114] [network] Handle partition producer s... - posted by uce <gi...@git.apache.org> on 2016/11/30 15:01:39 UTC, 0 replies.
- [GitHub] flink pull request #2913: [backport] [FLINK-5114] [network] Handle partition... - posted by uce <gi...@git.apache.org> on 2016/11/30 15:04:19 UTC, 0 replies.
- [jira] [Created] (FLINK-5213) Missing @Override in Task - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/30 15:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-5213) Missing @Override in Task - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/30 15:18:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-4855) Add partitionedKeyBy to DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 16:52:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2999) Support connected keyed streams - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 16:53:58 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 16:55:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 16:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 17:13:58 UTC, 0 replies.
- [GitHub] flink pull request #2914: [FLINK-4611] Make "AUTO" credential provider as de... - posted by tony810430 <gi...@git.apache.org> on 2016/11/30 17:15:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 17:15:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5215) Close checkpoint streams upon cancellation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 17:17:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 17:20:58 UTC, 0 replies.
- [GitHub] flink pull request #2734: Keytab & TLS support for Flink on Mesos Setup - posted by asfgit <gi...@git.apache.org> on 2016/11/30 17:32:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-4826) Add keytab based kerberos support for Mesos environment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 17:32:58 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5188) Redirect dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 18:14:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5188) Redirect dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 18:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 18:40:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-5188) Shade dependency - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/30 19:49:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-5188) Shade dependency - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/30 19:50:58 UTC, 1 replies.
- [GitHub] flink issue #2617: [FLINK-4705] Instrument FixedLengthRecordSorter - posted by greghogan <gi...@git.apache.org> on 2016/11/30 19:56:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-4705) Instrument FixedLengthRecordSorter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/30 19:56:59 UTC, 0 replies.
- [GitHub] flink issue #2809: [FLINK-5069] [Metrics] Pending checkpoint statistics gaug... - posted by zentol <gi...@git.apache.org> on 2016/11/30 20:25:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/30 21:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/30 21:52:58 UTC, 0 replies.
- [jira] [Closed] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/30 21:53:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/30 21:53:59 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/30 21:56:58 UTC, 0 replies.