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

---

- [jira] [Created] (FLINK-9484) Improve generic type inference for User-Defined Functions - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 00:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 00:49:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-9468) get outputLimit of LimitedConnectionsFileSystem incorrectly - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/01 01:13:00 UTC, 0 replies.
- [GitHub] flink issue #5582: [FLINK-8790][State] Improve performance for recovery from... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/01 01:57:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-8790) Improve performance for recovery from incremental checkpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 01:58:00 UTC, 25 replies.
- [GitHub] flink issue #6082: [FLINK-9444][table] KafkaAvroTableSource failed to work f... - posted by suez1224 <gi...@git.apache.org> on 2018/06/01 04:05:28 UTC, 12 replies.
- [jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 04:06:00 UTC, 27 replies.
- [GitHub] flink issue #6108: [FLINK-9367] [Streaming Connectors] Allow to do truncate(... - posted by zhangxinyu1 <gi...@git.apache.org> on 2018/06/01 04:17:19 UTC, 8 replies.
- [jira] [Commented] (FLINK-9367) Truncate() in BucketingSink is only allowed after hadoop2.7 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 04:18:00 UTC, 9 replies.
- [jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed - posted by "Luke Hutchison (JIRA)" <ji...@apache.org> on 2018/06/01 05:36:00 UTC, 6 replies.
- [GitHub] flink pull request #6091: [FLINK-7789][DataStream API] Add handler for Async... - posted by pnowojski <gi...@git.apache.org> on 2018/06/01 07:30:12 UTC, 5 replies.
- [jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 07:31:00 UTC, 7 replies.
- [GitHub] flink pull request #5582: [FLINK-8790][State] Improve performance for recove... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/01 08:30:25 UTC, 21 replies.
- [GitHub] flink pull request #6107: [FLINK-9366] DistributedCache works with Distribut... - posted by dawidwys <gi...@git.apache.org> on 2018/06/01 08:49:40 UTC, 11 replies.
- [jira] [Commented] (FLINK-9366) Distribute Cache only works for client-accessible files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 08:50:00 UTC, 13 replies.
- [GitHub] flink pull request #6109: [FLINK-9483] 'Building Flink' doc doesn't highligh... - posted by zentol <gi...@git.apache.org> on 2018/06/01 09:45:15 UTC, 5 replies.
- [jira] [Commented] (FLINK-9483) "Building Flink" doc doesn't highlight quick build command - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 09:46:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-9482) Not applicable functions for TIME - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/01 10:19:00 UTC, 0 replies.
- [GitHub] flink pull request #5982: [FLINK-9325][checkpoint]generate the meta file for... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/01 11:42:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 11:43:00 UTC, 3 replies.
- [GitHub] flink pull request #6110: [hotfix] fix EXECUTION_FAILOVER_STRATEGY's comment... - posted by makeyang <gi...@git.apache.org> on 2018/06/01 11:50:46 UTC, 0 replies.
- [GitHub] flink pull request #4949: [FLINK-7866] [runtime] Weigh list of preferred loc... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/01 12:10:59 UTC, 7 replies.
- [jira] [Commented] (FLINK-7866) Weigh list of preferred locations for scheduling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 12:11:00 UTC, 8 replies.
- [GitHub] flink pull request #6104: [FLINK-9476]Emit late elements in CEP as sideOutPu... - posted by dawidwys <gi...@git.apache.org> on 2018/06/01 12:11:18 UTC, 12 replies.
- [jira] [Commented] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 12:12:00 UTC, 16 replies.
- [jira] [Created] (FLINK-9485) Improving Flink’s timer management for large state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9486) Introduce TimerState in keyed state backend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7087) Implement Flip-6 container entry point - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 12:43:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9486) Introduce TimerState in keyed state backend - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/01 12:47:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9486) Introduce TimerState in keyed state backend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9487) Prepare InternalTimerHeap for asynchronous snapshots - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9488) Create common entry point for master and workers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 12:51:00 UTC, 0 replies.
- [GitHub] flink issue #5983: [FLINK-7789][DataStream API] Add handler for Async IO ope... - posted by pnowojski <gi...@git.apache.org> on 2018/06/01 12:51:26 UTC, 0 replies.
- [jira] [Created] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9490) Provide backwards compatibility for timer state of Flink 1.5 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9490) Provide backwards compatibility for timer state of Flink 1.5 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9491) Implement timer service based on RocksDB - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/06/01 13:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/06/01 13:26:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 13:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/06/01 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 13:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/01 13:43:00 UTC, 0 replies.
- [GitHub] flink issue #6059: [Flink-9418] Migrate SharedBuffer to use MapState - posted by kl0u <gi...@git.apache.org> on 2018/06/01 13:57:21 UTC, 4 replies.
- [GitHub] flink pull request #3557: [FLINK-6087] Fix file-path filtering in Continuous... - posted by ymarzougui <gi...@git.apache.org> on 2018/06/01 14:09:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-6087) The file-filter is only applied to directories in ContinuousFileMonitoringFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/01 14:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9491) Implement timer data structure based on RocksDB - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/01 14:25:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/01 15:48:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9495) Implement ResourceManager for Kubernetes - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/01 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9496) Job created time is reset after restart - posted by "Abhinav Bajaj (JIRA)" <ji...@apache.org> on 2018/06/01 17:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9497) Job Configuration showing the password in plain text - posted by "Vinay (JIRA)" <ji...@apache.org> on 2018/06/01 17:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9497) Job Configuration showing the password in plain text - posted by "Vinay (JIRA)" <ji...@apache.org> on 2018/06/01 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests" - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/01 19:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/01 20:18:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/01 20:27:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request - posted by "Esteban Serrano (JIRA)" <ji...@apache.org> on 2018/06/01 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9500) FileUploadHandler does not handle EmptyLastHttpContent - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/01 22:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9501) Allow Object.class type in user-define functions as parameter types but not result types - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9501) Allow Object.class type in user-define functions as parameter types but not result types - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:32:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9501) Allow Object or Wildcard type in user-define functions as parameter types but not result types - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:32:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:36:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-9484) Improve generic type inference for User-Defined Functions - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/01 23:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9503) Migrate integration tests for iterative aggregators - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/01 23:43:00 UTC, 0 replies.
- [GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector - posted by XiaoZYang <gi...@git.apache.org> on 2018/06/02 08:24:22 UTC, 8 replies.
- [jira] [Commented] (FLINK-9168) Pulsar Sink Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 08:25:00 UTC, 12 replies.
- [jira] [Commented] (FLINK-9500) FileUploadHandler does not handle EmptyLastHttpContent - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/02 12:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6103: [FLINK-9413] [distributed coordination] Tasks can ... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/02 12:37:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 12:38:00 UTC, 8 replies.
- [GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/02 12:42:20 UTC, 16 replies.
- [jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 12:43:00 UTC, 52 replies.
- [GitHub] flink pull request #6059: [Flink-9418] Migrate SharedBuffer to use MapState - posted by Aitozi <gi...@git.apache.org> on 2018/06/02 12:43:56 UTC, 7 replies.
- [jira] [Closed] (FLINK-9464) Clean up pom files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/02 12:49:00 UTC, 0 replies.
- [GitHub] flink pull request #6093: [FLINK-9464] Various pom.xml file clean ups - posted by asfgit <gi...@git.apache.org> on 2018/06/02 12:49:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-9464) Clean up pom files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/02 12:54:00 UTC, 0 replies.
- [GitHub] flink pull request #6111: [FLINK-9504]Change the log level of checkpoint dur... - posted by Aitozi <gi...@git.apache.org> on 2018/06/02 13:11:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/02 13:12:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-7789) Add handler for Async IO operator timeouts - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/06/02 13:44:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9496) Job created time is reset after restart - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/02 14:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9497) Job Configuration showing the password in plain text - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/02 14:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9503) Migrate integration tests for iterative aggregators - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/02 14:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9505) End-to-end test: Flink- - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 14:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 14:53:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9505) End-to-end test: Quickstarts for Scala - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 14:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming] - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 14:58:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming] - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 15:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming] - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 15:08:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming] - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/02 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/03 07:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/03 07:58:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/03 10:16:00 UTC, 43 replies.
- [GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/03 11:05:14 UTC, 6 replies.
- [jira] [Issue Comment Deleted] (FLINK-9442) Flink Scaling not working - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/03 12:48:00 UTC, 0 replies.
- [GitHub] flink issue #6043: [FLINK-7386] evolve RequestIndexer API to make it working... - posted by cjolif <gi...@git.apache.org> on 2018/06/03 13:05:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/03 13:06:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/03 15:04:00 UTC, 8 replies.
- [jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/03 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/03 15:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/06/03 16:15:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo - posted by "Jeffrey Carter (JIRA)" <ji...@apache.org> on 2018/06/03 17:12:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9508) General Spell Check on Flink Docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/03 21:02:00 UTC, 0 replies.
- [GitHub] flink pull request #6112: [FLINK-9508][Docs]General Spell Check on Flink Doc... - posted by medcv <gi...@git.apache.org> on 2018/06/03 21:08:33 UTC, 18 replies.
- [jira] [Commented] (FLINK-9508) General Spell Check on Flink Docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/03 21:09:00 UTC, 20 replies.
- [jira] [Created] (FLINK-9509) CLI usage are not same as CLI docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/03 21:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9509) CLI usage are not same as CLI docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/03 21:17:00 UTC, 0 replies.
- [GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/04 05:36:11 UTC, 7 replies.
- [jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 05:37:00 UTC, 15 replies.
- [GitHub] flink issue #6092: [FLINK-9352] In Standalone checkpoint recover mode many j... - posted by yanghua <gi...@git.apache.org> on 2018/06/04 06:37:20 UTC, 3 replies.
- [jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 06:38:00 UTC, 3 replies.
- [GitHub] flink issue #6007: [FLINK-8518][Table API & SQL] Support DOW for EXTRACT - posted by twalthr <gi...@git.apache.org> on 2018/06/04 07:19:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 07:20:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/04 07:29:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9510) State TTL API with cleanup on explicit access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9510) State TTL API with cleanup on explicit access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9511) Make StateDescriptor configurable with optional TTL - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:50:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9511) Make StateDescriptor configurable with optional TTL - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9513) Wrap state binder with TTL logic - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9513) Wrap state binder with TTL logic - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 07:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9514) Create wrapper with TTL logic for value state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9514) Create wrapper with TTL logic for value state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9516) Create wrapper with TTL logic for map state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9515) Create wrapper with TTL logic for list state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:02:00 UTC, 0 replies.
- [GitHub] flink issue #6104: [FLINK-9476]Emit late elements in CEP as sideOutPut - posted by dawidwys <gi...@git.apache.org> on 2018/06/04 08:02:59 UTC, 3 replies.
- [jira] [Updated] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/04 08:03:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-7789) Add handler for Async IO operator timeouts - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/04 08:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7789) Add handler for Async IO operator timeouts - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/04 08:10:00 UTC, 0 replies.
- [GitHub] flink issue #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer Backpr... - posted by fmthoma <gi...@git.apache.org> on 2018/06/04 08:20:40 UTC, 4 replies.
- [jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 08:21:00 UTC, 27 replies.
- [GitHub] flink issue #6111: [FLINK-9504]Change the log level of checkpoint duration t... - posted by StephanEwen <gi...@git.apache.org> on 2018/06/04 08:27:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-9509) CLI usage are not same as CLI docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/04 08:29:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9509) CLI usage are not same as CLI docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/04 08:30:00 UTC, 0 replies.
- [GitHub] flink issue #6094: [FLINK-9468][filesystem] fix calculate outputLimit incorr... - posted by StephanEwen <gi...@git.apache.org> on 2018/06/04 08:35:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-9468) get outputLimit of LimitedConnectionsFileSystem incorrectly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 08:36:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/04 08:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/04 08:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/04 09:19:00 UTC, 8 replies.
- [jira] [Updated] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/04 09:33:00 UTC, 0 replies.
- [GitHub] flink issue #5448: [FLINK-6469] Configure Memory Sizes with units - posted by StephanEwen <gi...@git.apache.org> on 2018/06/04 09:42:47 UTC, 6 replies.
- [jira] [Commented] (FLINK-6469) Configure Memory Sizes with units - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 09:43:00 UTC, 20 replies.
- [jira] [Assigned] (FLINK-9458) Unable to recover from job failure on YARN with NPE - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 09:45:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-4303) Add CEP examples - posted by "blues zheng (JIRA)" <ji...@apache.org> on 2018/06/04 09:53:00 UTC, 0 replies.
- [GitHub] flink issue #6112: [FLINK-9508][Docs]General Spell Check on Flink Docs - posted by medcv <gi...@git.apache.org> on 2018/06/04 10:07:15 UTC, 1 replies.
- [GitHub] flink issue #6047: [FLINK-8160]Extend OperatorHarness to expose... - posted by zentol <gi...@git.apache.org> on 2018/06/04 10:09:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-8160) Extend OperatorHarness to expose metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 10:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/04 10:12:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/04 10:13:00 UTC, 0 replies.
- [GitHub] flink issue #6107: [FLINK-9366] DistributedCache works with Distributed File... - posted by zentol <gi...@git.apache.org> on 2018/06/04 10:29:35 UTC, 1 replies.
- [GitHub] flink pull request #6049: [FLINK-9398][Client] Fix CLI list running job retu... - posted by zentol <gi...@git.apache.org> on 2018/06/04 10:49:38 UTC, 7 replies.
- [jira] [Commented] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 10:50:00 UTC, 9 replies.
- [jira] [Assigned] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 10:54:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9517) Fixing broken links on CLI Docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/04 11:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/04 11:17:00 UTC, 5 replies.
- [GitHub] flink pull request #6113: [FLINK-9517][Docs]Fixing broken links on CLI and U... - posted by medcv <gi...@git.apache.org> on 2018/06/04 11:20:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 11:21:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9518) SSL setup Docs config example has wrong keys password - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/04 11:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9518) SSL setup Docs config example has wrong keys password - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/04 11:36:00 UTC, 3 replies.
- [GitHub] flink pull request #6114: [FLINK-9518][Docs] SSL setup Docs config example h... - posted by medcv <gi...@git.apache.org> on 2018/06/04 11:36:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-9518) SSL setup Docs config example has wrong keys password - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 11:37:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/06/04 11:56:00 UTC, 2 replies.
- [GitHub] flink pull request #6087: [FLINK-9410] [yarn] Replace NMClient with NMClient... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/04 12:29:52 UTC, 7 replies.
- [jira] [Commented] (FLINK-9410) Replace NMClient with NMClientAsync in YarnResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 12:30:00 UTC, 8 replies.
- [jira] [Created] (FLINK-9519) table example jar did not copy into example dir - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 12:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9519) table example jar did not copy into example dir - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 12:32:00 UTC, 0 replies.
- [GitHub] flink pull request #6094: [FLINK-9468][filesystem] fix calculate outputLimit... - posted by asfgit <gi...@git.apache.org> on 2018/06/04 13:00:30 UTC, 0 replies.
- [GitHub] flink issue #6087: [FLINK-9410] [yarn] Replace NMClient with NMClientAsync i... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/04 13:18:08 UTC, 0 replies.
- [GitHub] flink pull request #6115: [FLINK-9435][java] Remove per-key selection Tuple ... - posted by NicoK <gi...@git.apache.org> on 2018/06/04 14:21:37 UTC, 0 replies.
- [jira] [Updated] (FLINK-9520) JarFileCreator does not support Java MethodReferences - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/04 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9520) JarFileCreator does not support Java MethodReferences - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/04 14:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 14:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/04 14:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/04 14:43:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-6538) Emit late elements as Side Outputs - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/04 14:43:01 UTC, 0 replies.
- [GitHub] flink issue #4949: [FLINK-7866] [runtime] Weigh list of preferred locations ... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/04 15:26:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-7866) Weigh list of preferred locations for scheduling - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/04 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9521) Add build plugin to package table example jar - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/04 15:46:00 UTC, 0 replies.
- [GitHub] flink pull request #6116: [FLINK-9498][build] Disable dependency convergence... - posted by yew1eb <gi...@git.apache.org> on 2018/06/04 16:12:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 16:13:00 UTC, 12 replies.
- [GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl... - posted by yew1eb <gi...@git.apache.org> on 2018/06/04 16:13:54 UTC, 11 replies.
- [GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer... - posted by bowenli86 <gi...@git.apache.org> on 2018/06/04 18:27:45 UTC, 22 replies.
- [GitHub] flink issue #5786: [FLINK-9109] [doc] Update documentation for CLI - posted by zorro786 <gi...@git.apache.org> on 2018/06/04 19:38:53 UTC, 5 replies.
- [jira] [Commented] (FLINK-9109) Add flink modify command to documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 19:39:00 UTC, 8 replies.
- [GitHub] flink issue #6089: [FLINK-9451]End-to-end test: Scala Quickstarts - posted by medcv <gi...@git.apache.org> on 2018/06/04 19:41:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-9451) End-to-end test: Scala Quickstarts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/04 19:42:00 UTC, 10 replies.
- [jira] [Commented] (FLINK-9447) "sensible" vs. "sensitive" in Code Contribution Process - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/04 19:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9522) Rework Flink website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/04 20:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9523) Add Kafka examples for Flink Table/SQL API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/06/04 22:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "yan zhou (JIRA)" <ji...@apache.org> on 2018/06/04 23:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "yan zhou (JIRA)" <ji...@apache.org> on 2018/06/04 23:04:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "yan zhou (JIRA)" <ji...@apache.org> on 2018/06/04 23:28:00 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "yan zhou (JIRA)" <ji...@apache.org> on 2018/06/04 23:30:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover - posted by "Nikolas Davis (JIRA)" <ji...@apache.org> on 2018/06/05 00:18:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9363) Bump up the Jackson version - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/05 01:04:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/05 01:05:00 UTC, 0 replies.
- [GitHub] flink issue #6060: [FLINK-8946] TaskManager stop sending metrics after JobMa... - posted by yanghua <gi...@git.apache.org> on 2018/06/05 03:11:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 05:43:00 UTC, 0 replies.
- [GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to... - posted by suez1224 <gi...@git.apache.org> on 2018/06/05 06:12:27 UTC, 13 replies.
- [jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 06:35:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 06:35:00 UTC, 0 replies.
- [GitHub] flink pull request #6117: [hotfix][checkstyle] fix checkstyle of CEPOperator... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/05 06:39:59 UTC, 1 replies.
- [GitHub] flink issue #6117: [hotfix][checkstyle] fix checkstyle of CEPOperatorTest - posted by sihuazhou <gi...@git.apache.org> on 2018/06/05 06:40:11 UTC, 1 replies.
- [GitHub] flink issue #6113: [FLINK-9517][Docs]Fixing broken links on CLI and Upgrade ... - posted by zentol <gi...@git.apache.org> on 2018/06/05 06:46:33 UTC, 0 replies.
- [GitHub] flink issue #6114: [FLINK-9518][Docs] SSL setup Docs config example has wron... - posted by zentol <gi...@git.apache.org> on 2018/06/05 06:46:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 06:49:00 UTC, 7 replies.
- [jira] [Closed] (FLINK-9518) SSL setup Docs config example has wrong keys password - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 06:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 06:58:00 UTC, 0 replies.
- [GitHub] flink pull request #6118: [FLINK-9525][filesystem] Add missing `META-INF/ser... - posted by yew1eb <gi...@git.apache.org> on 2018/06/05 07:04:15 UTC, 0 replies.
- [GitHub] flink issue #5798: [FLINK-7917] The return of taskInformationOrBlobKey shoul... - posted by yanghua <gi...@git.apache.org> on 2018/06/05 07:10:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 07:11:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/06/05 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9526) BucketingSink end-to-end test failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 07:15:00 UTC, 0 replies.
- [GitHub] flink pull request #6119: [FLINK-9458] Ignore SharedSlot in CoLocationConstr... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/05 07:17:35 UTC, 1 replies.
- [GitHub] flink issue #6101: [FLINK-9458] Unable to recover from job failure on YARN w... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/05 07:18:12 UTC, 1 replies.
- [GitHub] flink pull request #6101: [FLINK-9458] Unable to recover from job failure on... - posted by yanghua <gi...@git.apache.org> on 2018/06/05 07:19:14 UTC, 0 replies.
- [GitHub] flink pull request #: - posted by roycao-xhs <gi...@git.apache.org> on 2018/06/05 07:28:36 UTC, 1 replies.
- [GitHub] flink pull request #6096: [FLINK-9440][streaming] Expose cancelation of time... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/05 07:48:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-9440) Allow cancelation and reset of timers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 07:49:00 UTC, 6 replies.
- [GitHub] flink issue #6118: [FLINK-9525][filesystem] Add missing `META-INF/services/*... - posted by zentol <gi...@git.apache.org> on 2018/06/05 08:08:12 UTC, 3 replies.
- [GitHub] flink pull request #6007: [FLINK-8518][Table API & SQL] Support DOW for EXTR... - posted by asfgit <gi...@git.apache.org> on 2018/06/05 08:10:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-8650) Add tests and documentation for WINDOW clause - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 08:16:00 UTC, 11 replies.
- [jira] [Comment Edited] (FLINK-8650) Add tests and documentation for WINDOW clause - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 08:16:00 UTC, 0 replies.
- [GitHub] flink pull request #5786: [FLINK-9109] [doc] Update documentation for CLI - posted by zentol <gi...@git.apache.org> on 2018/06/05 08:16:35 UTC, 2 replies.
- [GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc... - posted by twalthr <gi...@git.apache.org> on 2018/06/05 08:18:41 UTC, 10 replies.
- [jira] [Commented] (FLINK-9448) contribute-code.html references Hadoop 1.x support - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/05 08:29:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9448) contribute-code.html references Hadoop 1.x support - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/05 08:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module... - posted by twalthr <gi...@git.apache.org> on 2018/06/05 08:46:08 UTC, 0 replies.
- [GitHub] flink issue #6120: [FLINK-7251] [types] Remove the flink-java8 module and im... - posted by twalthr <gi...@git.apache.org> on 2018/06/05 08:46:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 08:47:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9527) Paths initialize with URI are not normalized - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 08:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9527) Paths initialize with URI are not normalized - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 08:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9527) Paths initialized with URI are not normalized - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 08:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9526) BucketingSink end-to-end test failed on Travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/05 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/05 09:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly. - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/05 10:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/05 10:20:00 UTC, 0 replies.
- [GitHub] flink issue #6110: [hotfix] fix EXECUTION_FAILOVER_STRATEGY's comments error... - posted by makeyang <gi...@git.apache.org> on 2018/06/05 10:33:56 UTC, 0 replies.
- [GitHub] flink issue #6096: [FLINK-9440][streaming] Expose cancelation of timers thro... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/05 10:34:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly. - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/05 11:10:00 UTC, 9 replies.
- [jira] [Assigned] (FLINK-9467) No Watermark display on Web UI - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 11:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6121: [FLINK-9482] [table] EXTRACT function argument val... - posted by bioker <gi...@git.apache.org> on 2018/06/05 11:38:31 UTC, 4 replies.
- [jira] [Commented] (FLINK-9482) Not applicable functions for TIME - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 11:39:00 UTC, 4 replies.
- [GitHub] flink pull request #6122: [FLINK-9467][metrics] Fix queried watermark metric... - posted by zentol <gi...@git.apache.org> on 2018/06/05 11:51:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-9467) No Watermark display on Web UI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 11:52:00 UTC, 7 replies.
- [jira] [Created] (FLINK-9529) Do not expose keyed methods on ProcessFunction.Context - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/05 11:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/05 11:56:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9521) Add build plugin to package table example jar - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/05 12:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8790) Improve performance for recovery from incremental checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/05 12:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9440) Allow cancelation and reset of timers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/05 12:29:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9521) Add build plugin to package table example jar - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/05 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9530) Task numRecords metrics broken for chains - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/05 12:53:00 UTC, 0 replies.
- [GitHub] flink pull request #5798: [FLINK-7917] The return of taskInformationOrBlobKe... - posted by asfgit <gi...@git.apache.org> on 2018/06/05 12:59:14 UTC, 0 replies.
- [GitHub] flink issue #6079: [FLINK-8430] [table] Implement stream-stream non-window f... - posted by twalthr <gi...@git.apache.org> on 2018/06/05 12:59:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-8430) Implement stream-stream non-window full outer join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 13:00:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-8941) SpanningRecordSerializationTest fails on Travis - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/06/05 13:10:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8602) Improve recovery performance for rocksdb backend - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 13:16:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8430) Implement stream-stream non-window full outer join - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 13:39:00 UTC, 0 replies.
- [GitHub] flink pull request #6079: [FLINK-8430] [table] Implement stream-stream non-w... - posted by asfgit <gi...@git.apache.org> on 2018/06/05 13:39:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-5878) Add stream-stream non-window inner/outer join - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 13:41:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-7043) Optimize state handling in NFA - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/05 13:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/05 13:58:01 UTC, 0 replies.
- [GitHub] flink issue #6049: [FLINK-9398][Client] Fix CLI list running job returns all... - posted by walterddr <gi...@git.apache.org> on 2018/06/05 14:27:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-9521) Add shade plugin executions to package table example jar - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/05 14:29:00 UTC, 2 replies.
- [GitHub] flink pull request #6123: [FLINK-9521] Add shade plugin executions to packag... - posted by yanghua <gi...@git.apache.org> on 2018/06/05 14:41:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-9521) Add shade plugin executions to package table example jar - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 14:42:00 UTC, 8 replies.
- [GitHub] flink issue #6123: [FLINK-9521] Add shade plugin executions to package table... - posted by zentol <gi...@git.apache.org> on 2018/06/05 14:44:39 UTC, 6 replies.
- [jira] [Closed] (FLINK-8941) SpanningRecordSerializationTest fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/05 14:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9441) Hadoop Required Dependency List Not Clear - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/05 15:10:00 UTC, 3 replies.
- [jira] [Closed] (FLINK-9452) Flink 1.5 document version title shows snapshot - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/05 15:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9445) start-scala-shell.sh fails on macOS when Java 9 & 10 are installed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/05 15:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9527) Paths initialized with URI are not normalized - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/06/05 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9531) Improve logging during type extraction of the Row type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 15:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9531) Improve logging during type extraction of the Row type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/05 15:52:00 UTC, 0 replies.
- [GitHub] flink pull request #5410: [FLINK-8468] [RabbitMQ Connector] Take advantage o... - posted by GJL <gi...@git.apache.org> on 2018/06/05 15:57:12 UTC, 40 replies.
- [jira] [Commented] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 15:58:01 UTC, 42 replies.
- [GitHub] flink pull request #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pa... - posted by Aitozi <gi...@git.apache.org> on 2018/06/05 16:19:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/05 16:20:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-8601) Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 16:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 16:34:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-8753) Introduce savepoint that go though the incremental checkpoint path - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/05 16:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8845) Use WriteBatch to improve performance for recovery in RocksDB backend - posted by "Noam Liran (JIRA)" <ji...@apache.org> on 2018/06/05 20:35:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder - posted by "Mahesh Senniappan (JIRA)" <ji...@apache.org> on 2018/06/05 20:48:00 UTC, 4 replies.
- [GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units - posted by zentol <gi...@git.apache.org> on 2018/06/05 21:03:38 UTC, 13 replies.
- [jira] [Closed] (FLINK-9109) Add flink modify command to documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/05 21:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9527) Paths initialized with URI are not normalized - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 00:03:00 UTC, 0 replies.
- [GitHub] flink issue #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern i... - posted by Aitozi <gi...@git.apache.org> on 2018/06/06 00:42:19 UTC, 2 replies.
- [jira] [Created] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect - posted by "Abdul Qadeer (JIRA)" <ji...@apache.org> on 2018/06/06 01:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect - posted by "Abdul Qadeer (JIRA)" <ji...@apache.org> on 2018/06/06 01:18:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9533) CEP - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9534) CEP - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9533) CEP cant deal with the known outOfOrder config with event time - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9533) CEP cant deal with the known outOfOrder config with event time - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:53:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9534) CEP - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/06 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked. - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/06/06 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9536) Rolling logs using log4j.properties, prevents them from showing on the UI. - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/06/06 06:35:00 UTC, 0 replies.
- [GitHub] flink pull request #6125: [FLINK-9532] Flink Overview of Jobs Documentation ... - posted by yanghua <gi...@git.apache.org> on 2018/06/06 06:52:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 06:53:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked. - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 06:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9471) Job ending exceptions being logged at Info level - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 06:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9536) Rolling logs using log4j.properties, prevents them from showing on the UI. - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 06:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 07:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9537) JobManager isolation in session mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/06 07:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9533) CEP cant deal with the known outOfOrder config with event time - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/06 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9538) Make KeyedStateFunction an interface - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/06 07:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9538) Make KeyedStateFunction an interface - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/06 07:44:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9538) Make KeyedStateFunction an interface - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/06 07:45:00 UTC, 19 replies.
- [jira] [Closed] (FLINK-9533) CEP cant deal with the known outOfOrder config with event time - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/06 07:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9533) CEP cant deal with the known outOfOrder config with event time - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/06 07:47:00 UTC, 0 replies.
- [GitHub] flink pull request #6126: [FLINK-9530][metrics] Fix numRecords task metric f... - posted by zentol <gi...@git.apache.org> on 2018/06/06 08:00:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-9530) Task numRecords metrics broken for chains - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 08:01:00 UTC, 8 replies.
- [GitHub] flink pull request #6127: [FLINK-9368][py][tests] Add Python API E2E test - posted by zentol <gi...@git.apache.org> on 2018/06/06 08:13:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-9368) End-to-end test: Python API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 08:14:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-8744) Add annotations for documenting common/advanced options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 08:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8886) Job isolation via scheduling in shared cluster - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/06 08:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8886) Job isolation via scheduling in shared cluster - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/06 08:42:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9539) Integrate flink-shaded 4.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 09:10:00 UTC, 0 replies.
- [GitHub] flink pull request #6128: [FLINK-9539][build] Integrate flink-shaded 4.0 - posted by zentol <gi...@git.apache.org> on 2018/06/06 09:15:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-9539) Integrate flink-shaded 4.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 09:16:00 UTC, 3 replies.
- [GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1 - posted by zentol <gi...@git.apache.org> on 2018/06/06 09:16:35 UTC, 13 replies.
- [jira] [Commented] (FLINK-3952) Bump Netty to 4.1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 09:17:00 UTC, 17 replies.
- [jira] [Created] (FLINK-9540) Apache Flink 1.4.2 S3 Hadooplibrary for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/06 09:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9540) Apache Flink 1.4.2 S3 Hadooplibrary for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/06 09:33:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9540) Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/06 09:39:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8886) Job isolation via scheduling in shared cluster - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/06 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/06 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9542) ExEnv#registerCachedFile should accept Path - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 11:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9538) Make KeyedStateFunction an interface - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 11:16:00 UTC, 0 replies.
- [GitHub] flink issue #5954: [FLINK-9276] Improve error message when TaskManager fails - posted by yanghua <gi...@git.apache.org> on 2018/06/06 11:22:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-9276) Improve error message when TaskManager fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 11:23:00 UTC, 1 replies.
- [GitHub] flink pull request #6089: [FLINK-9451]End-to-end test: Scala Quickstarts - posted by zentol <gi...@git.apache.org> on 2018/06/06 12:42:35 UTC, 8 replies.
- [jira] [Created] (FLINK-9543) Expose JobMaster IDs to metric system - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/06 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9544) Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/06/06 13:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9544) Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/06/06 13:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked. - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2018/06/06 14:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9544) Downgrade kinesis protocole from CBOR to JSON not possible as required by kinesalite - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/06/06 15:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9544) Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/06/06 15:50:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9543) Expose JobMaster IDs to metric system - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/06 16:22:00 UTC, 1 replies.
- [GitHub] flink pull request #6129: [FLINK-9503] Migrate integration tests for iterati... - posted by yanghua <gi...@git.apache.org> on 2018/06/06 16:26:55 UTC, 7 replies.
- [jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 16:27:00 UTC, 11 replies.
- [jira] [Commented] (FLINK-9540) Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/06 17:20:00 UTC, 6 replies.
- [jira] [Closed] (FLINK-9540) Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/06 17:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/06 17:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/06 17:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/06/06 18:11:00 UTC, 0 replies.
- [GitHub] flink issue #6084: [FLINK-8654][Docs] Extend quickstart docs on how to submi... - posted by medcv <gi...@git.apache.org> on 2018/06/06 22:53:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-8654) Extend quickstart docs on how to submit jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/06 22:54:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9545) Support read file for N times in Flink stream - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/06/06 23:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot - posted by "Chris Schneider (JIRA)" <ji...@apache.org> on 2018/06/06 23:38:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9545) Support read a file multiple times in Flink DataStream - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/06/07 00:15:00 UTC, 2 replies.
- [GitHub] flink pull request #6130: [FLINK-9545] Support read a file multiple times in... - posted by bowenli86 <gi...@git.apache.org> on 2018/06/07 00:17:35 UTC, 6 replies.
- [jira] [Commented] (FLINK-9545) Support read a file multiple times in Flink DataStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 00:18:00 UTC, 15 replies.
- [GitHub] flink pull request #6131: [hotfix][docs] Fix Table API scala example code - posted by zjffdu <gi...@git.apache.org> on 2018/06/07 00:52:32 UTC, 1 replies.
- [GitHub] flink issue #6129: [FLINK-9503] Migrate integration tests for iterative aggr... - posted by yanghua <gi...@git.apache.org> on 2018/06/07 03:41:00 UTC, 3 replies.
- [GitHub] flink pull request #6132: [FLINK-9456][Distributed Coordination]Let Resource... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/07 05:41:23 UTC, 11 replies.
- [jira] [Commented] (FLINK-9456) Let ResourceManager notify JobManager about failed/killed TaskManagers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 05:42:00 UTC, 16 replies.
- [GitHub] flink pull request #6133: [FLINK-9351][Distributed Coordination] RM stop ass... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/07 06:20:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-9351) RM stop assigning slot to Job because the TM killed before connecting to JM successfully - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 06:21:00 UTC, 1 replies.
- [GitHub] flink issue #6132: [FLINK-9456][Distributed Coordination]Let ResourceManager... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/07 06:21:04 UTC, 4 replies.
- [GitHub] flink issue #6133: [FLINK-9351][Distributed Coordination] RM stop assigning ... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/07 06:21:50 UTC, 0 replies.
- [GitHub] flink issue #6081: [FLINK-8067] User code ClassLoader not set before calling... - posted by yanghua <gi...@git.apache.org> on 2018/06/07 07:13:20 UTC, 6 replies.
- [jira] [Commented] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 07:14:00 UTC, 15 replies.
- [GitHub] flink pull request #6134: [FLINK-9538] Make KeyedStateFunction an interface - posted by yanghua <gi...@git.apache.org> on 2018/06/07 07:32:03 UTC, 12 replies.
- [GitHub] flink issue #6131: [hotfix][docs] Fix Table API scala example code - posted by fhueske <gi...@git.apache.org> on 2018/06/07 08:18:17 UTC, 0 replies.
- [jira] [Created] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0 - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/07 08:26:00 UTC, 0 replies.
- [GitHub] flink pull request #6135: [FLINK-9546][core] Fix the checking of heartbeatTi... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/07 08:28:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 08:29:00 UTC, 1 replies.
- [GitHub] flink issue #6135: [FLINK-9546][core] Fix the checking of heartbeatTimeoutIn... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/07 08:29:03 UTC, 0 replies.
- [jira] [Updated] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/07 09:23:00 UTC, 2 replies.
- [GitHub] flink issue #6130: [FLINK-9545] Support read a file multiple times in Flink ... - posted by aljoscha <gi...@git.apache.org> on 2018/06/07 09:26:04 UTC, 5 replies.
- [GitHub] flink issue #6134: [FLINK-9538] Make KeyedStateFunction an interface - posted by yanghua <gi...@git.apache.org> on 2018/06/07 10:39:44 UTC, 5 replies.
- [jira] [Created] (FLINK-9547) CEP pattern not called on windowed stream - posted by "Lucas Resch (JIRA)" <ji...@apache.org> on 2018/06/07 15:31:00 UTC, 0 replies.
- [GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto... - posted by surryr <gi...@git.apache.org> on 2018/06/07 15:36:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-9547) CEP pattern not called on windowed stream - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/07 15:43:00 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-9547) CEP pattern not called on windowed stream - posted by "Lucas Resch (JIRA)" <ji...@apache.org> on 2018/06/07 18:07:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability - posted by "Vipul Singh (JIRA)" <ji...@apache.org> on 2018/06/07 18:18:00 UTC, 4 replies.
- [GitHub] flink pull request #6136: FLINK-4303] [CEP] Add CEP examples - posted by kisimple <gi...@git.apache.org> on 2018/06/07 18:23:01 UTC, 3 replies.
- [jira] [Commented] (FLINK-4303) Add CEP examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 18:24:00 UTC, 10 replies.
- [GitHub] flink issue #6136: FLINK-4303] [CEP] Add CEP examples - posted by kisimple <gi...@git.apache.org> on 2018/06/07 18:25:41 UTC, 1 replies.
- [jira] [Created] (FLINK-9548) Flink Apache Kudu Connector - posted by "Sandish Kumar HN (JIRA)" <ji...@apache.org> on 2018/06/07 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 21:30:00 UTC, 0 replies.
- [GitHub] flink pull request #6137: [FLINK-9549][DOC]Fix FlickCEP Docs broken link and... - posted by medcv <gi...@git.apache.org> on 2018/06/07 21:45:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 21:46:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9550) FlinkCEP snippet example has some syntax errors - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 21:51:00 UTC, 0 replies.
- [GitHub] flink pull request #6138: [FLINK-9550][DOC]FlinkCEP snippet example has some... - posted by medcv <gi...@git.apache.org> on 2018/06/07 22:00:33 UTC, 5 replies.
- [jira] [Commented] (FLINK-9550) FlinkCEP snippet example has some syntax errors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 22:01:00 UTC, 8 replies.
- [jira] [Created] (FLINK-9551) FlinkCEP Scala Combining Patterns table has two missing pattern - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 22:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9551) FlinkCEP Scala Combining Patterns table has a missing pattern - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/07 22:08:00 UTC, 0 replies.
- [GitHub] flink pull request #6139: [FLINK-9551][DOCS]FlinkCEP Scala Combining Pattern... - posted by medcv <gi...@git.apache.org> on 2018/06/07 22:10:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-9551) FlinkCEP Scala Combining Patterns table has a missing pattern - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/07 22:11:00 UTC, 3 replies.
- [GitHub] flink issue #6128: [FLINK-9539][build] Integrate flink-shaded 4.0 - posted by medcv <gi...@git.apache.org> on 2018/06/07 22:23:17 UTC, 1 replies.
- [jira] [Closed] (FLINK-9482) Not applicable functions for TIME - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/06/08 01:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/06/08 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9553) Migrate integration tests for DataSinkITCase - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/08 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9554) flink scala shell doesn't work in yarn mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/06/08 02:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/06/08 02:39:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/06/08 02:44:00 UTC, 0 replies.
- [GitHub] flink pull request #6140: [FLINK-9554] flink scala shell doesn't work in yar... - posted by zjffdu <gi...@git.apache.org> on 2018/06/08 02:47:24 UTC, 0 replies.
- [GitHub] flink issue #6140: [FLINK-9554] flink scala shell doesn't work in yarn mode - posted by zjffdu <gi...@git.apache.org> on 2018/06/08 02:55:35 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/08 03:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6141: flink-metrics-datadog: beautify metric name by exc... - posted by DmitryBe <gi...@git.apache.org> on 2018/06/08 04:03:29 UTC, 1 replies.
- [GitHub] flink issue #6136: [FLINK-4303] [CEP] Add CEP examples - posted by kisimple <gi...@git.apache.org> on 2018/06/08 04:25:01 UTC, 3 replies.
- [GitHub] flink issue #5410: [FLINK-8468] [RabbitMQ Connector] Take advantage of AMQP ... - posted by GJL <gi...@git.apache.org> on 2018/06/08 06:42:14 UTC, 1 replies.
- [jira] [Created] (FLINK-9555) Support table api in scala shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/06/08 07:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9555) Support table api in scala shell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/06/08 07:14:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-9547) CEP pattern not called on windowed stream - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/08 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/08 07:55:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9540) Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/08 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9557) FlinkTypeFactory should support BigInteger type - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/08 11:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9557) FlinkTypeFactory should support BigInteger type - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/08 11:12:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/06/08 11:34:00 UTC, 2 replies.
- [GitHub] flink issue #6141: flink-metrics-datadog: beautify metric name by excluding ... - posted by medcv <gi...@git.apache.org> on 2018/06/08 13:12:10 UTC, 1 replies.
- [GitHub] flink pull request #6136: [FLINK-4303] [CEP] Add CEP examples - posted by medcv <gi...@git.apache.org> on 2018/06/08 13:13:42 UTC, 0 replies.
- [jira] [Created] (FLINK-9558) Memory leaks during usage with disabled checkpointing - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/08 14:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/08 14:25:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/08 14:52:00 UTC, 0 replies.
- [GitHub] flink issue #5992: [FLINK-8944] [Kinesis Connector] Use listShards instead o... - posted by kailashhd <gi...@git.apache.org> on 2018/06/08 15:41:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/08 15:42:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/08 16:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/08 16:08:00 UTC, 0 replies.
- [GitHub] flink pull request #6142: [FLINK-9499] Allow POST parameters to be used for ... - posted by st96d045 <gi...@git.apache.org> on 2018/06/08 16:23:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/08 16:24:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9540) Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8 and fails - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/06/08 17:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9537) JobManager isolation in session mode - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/09 01:29:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/09 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9560) RateLimiting for FileSystem - posted by "Etienne CARRIERE (JIRA)" <ji...@apache.org> on 2018/06/09 04:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/06/09 08:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI - posted by "Alexandr Arkhipov (JIRA)" <ji...@apache.org> on 2018/06/09 12:10:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI - posted by "Alexandr Arkhipov (JIRA)" <ji...@apache.org> on 2018/06/09 12:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException - posted by "Alexandr Arkhipov (JIRA)" <ji...@apache.org> on 2018/06/09 12:46:00 UTC, 0 replies.
- [GitHub] flink issue #6139: [FLINK-9551][DOCS]FlinkCEP Scala Combining Patterns table... - posted by medcv <gi...@git.apache.org> on 2018/06/09 14:01:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9561) Lack of the api to set RocksDB Option by flink config - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/09 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9562) Wrong wording in flink-optimizer module - posted by "Alexandr Arkhipov (JIRA)" <ji...@apache.org> on 2018/06/09 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9563) Migrate integration tests for CEP - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/09 18:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9562) Wrong wording in flink-optimizer module - posted by "Alexandr Arkhipov (JIRA)" <ji...@apache.org> on 2018/06/09 21:18:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/09 23:30:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/09 23:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8554) Upgrade AWS SDK - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/09 23:33:00 UTC, 0 replies.
- [GitHub] flink pull request #6143: [hotfix] [docs] Fixed scala variable declaration w... - posted by 2start <gi...@git.apache.org> on 2018/06/09 23:51:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-9561) Lack of the api to set RocksDB Option by flink config - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/10 04:21:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9561) Lack of the api to set RocksDB Option by flink config - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/10 04:27:00 UTC, 0 replies.
- [GitHub] flink pull request #6144: [hotfix][javadoc]Fix the incorrect java doc for Op... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/10 04:39:26 UTC, 1 replies.
- [GitHub] flink pull request #5660: [FLINK-8861] [table] Add support for batch queries... - posted by xccui <gi...@git.apache.org> on 2018/06/10 09:21:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-8861) Add support for batch queries in SQL Client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/10 09:22:00 UTC, 4 replies.
- [GitHub] flink issue #5660: [FLINK-8861] [table] Add support for batch queries in SQL... - posted by xccui <gi...@git.apache.org> on 2018/06/10 09:23:11 UTC, 2 replies.
- [jira] [Closed] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/10 19:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/10 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9564) Expose end-to-end module directory to test scripts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 07:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9564) Expose end-to-end module directory to test scripts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 07:53:00 UTC, 0 replies.
- [GitHub] flink pull request #6145: [FLINK-9564][tests] Expose flink-end-to-end module... - posted by zentol <gi...@git.apache.org> on 2018/06/11 07:55:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 07:56:00 UTC, 7 replies.
- [GitHub] flink pull request #6146: [FLINK-9564][tests] Expose flink-end-to-end module... - posted by zentol <gi...@git.apache.org> on 2018/06/11 07:56:40 UTC, 1 replies.
- [jira] [Created] (FLINK-9565) Evaluating scalar UDFs in parallel - posted by "yinhua.dai (JIRA)" <ji...@apache.org> on 2018/06/11 08:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9565) Evaluating scalar UDFs in parallel - posted by "yinhua.dai (JIRA)" <ji...@apache.org> on 2018/06/11 08:08:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 08:31:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9566) Support listing all jobs in CliFrontend#list - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 08:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9557) FlinkTypeFactory should support BigInteger type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/11 09:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9557) FlinkTypeFactory should support BigInteger type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/11 09:30:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9567) Flink does not release resource in Yarn Cluster mode - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/06/11 09:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9567) Flink does not release resource in Yarn Cluster mode - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/06/11 09:54:00 UTC, 11 replies.
- [GitHub] flink issue #6119: [FLINK-9458] Ignore SharedSlot in CoLocationConstraint wh... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/11 11:24:29 UTC, 1 replies.
- [GitHub] flink pull request #6147: [FLINK-9280][rest] Rework JobSubmitHandler to acce... - posted by zentol <gi...@git.apache.org> on 2018/06/11 12:12:07 UTC, 67 replies.
- [jira] [Commented] (FLINK-9280) Extend JobSubmitHandler to accept jar files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 12:13:00 UTC, 110 replies.
- [GitHub] flink issue #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1 - posted by pnowojski <gi...@git.apache.org> on 2018/06/11 12:22:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-8946) TaskManager stop sending metrics after JobManager failover - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 12:25:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 12:40:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 12:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9539) Integrate flink-shaded 4.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 12:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9508) General Spell Check on Flink Docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 13:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9508) General Spell Check on Flink Docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/11 13:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9560) RateLimiting for FileSystem - posted by "Etienne CARRIERE (JIRA)" <ji...@apache.org> on 2018/06/11 13:42:00 UTC, 2 replies.
- [jira] [Resolved] (FLINK-8861) Add support for batch queries in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/11 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9568) Wrong error handling for batch input formats with invalid paths - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/11 14:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9568) Wrong error handling for batch input formats with invalid paths - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/11 14:03:00 UTC, 1 replies.
- [GitHub] flink issue #6145: [FLINK-9564][tests] Expose flink-end-to-end module direct... - posted by medcv <gi...@git.apache.org> on 2018/06/11 14:22:02 UTC, 1 replies.
- [GitHub] flink issue #6146: [FLINK-9564][tests] Expose flink-end-to-end module direct... - posted by medcv <gi...@git.apache.org> on 2018/06/11 14:22:25 UTC, 1 replies.
- [GitHub] flink pull request #6148: [FLINK-7554][Tests] Add a testing RuntimeContext t... - posted by buptljy <gi...@git.apache.org> on 2018/06/11 14:31:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-7554) Add a testing RuntimeContext to test utilities - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 14:32:00 UTC, 1 replies.
- [GitHub] flink pull request #6149: [FLINK-9560] Add RateLimiting for FileSystem - posted by etiennecarriere <gi...@git.apache.org> on 2018/06/11 14:39:54 UTC, 23 replies.
- [jira] [Commented] (FLINK-9560) RateLimiting for FileSystem - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 14:40:00 UTC, 27 replies.
- [jira] [Commented] (FLINK-6670) remove CommonTestUtils.createTempDirectory() - posted by "Mahesh Senniappan (JIRA)" <ji...@apache.org> on 2018/06/11 15:07:00 UTC, 0 replies.
- [GitHub] flink issue #6126: [FLINK-9530][metrics] Fix numRecords task metric for chai... - posted by zentol <gi...@git.apache.org> on 2018/06/11 15:50:04 UTC, 6 replies.
- [GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo... - posted by twalthr <gi...@git.apache.org> on 2018/06/11 16:22:52 UTC, 28 replies.
- [jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 16:23:01 UTC, 30 replies.
- [jira] [Comment Edited] (FLINK-8946) TaskManager stop sending metrics after JobManager failover - posted by "Nikolas Davis (JIRA)" <ji...@apache.org> on 2018/06/11 17:42:00 UTC, 0 replies.
- [GitHub] flink pull request #6150: [FLINK-9562] [flink-optimizer] Wrong wording in fl... - posted by alex-arkhipov <gi...@git.apache.org> on 2018/06/11 19:58:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-9562) Wrong wording in flink-optimizer module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/11 19:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9236) Use Apache Parent POM 19 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/12 00:23:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/12 00:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8920) Split code generated input unboxing code - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/12 01:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9568) Wrong error handling for batch input formats with invalid paths - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/12 01:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9236) Use Apache Parent POM 19 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/12 02:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/12 07:52:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-8759) Bump Netty to 4.0.56 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/12 07:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/12 07:58:00 UTC, 8 replies.
- [jira] [Created] (FLINK-9570) SQL Client merging environments uses AbstractMap - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/12 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9569) Confusing construction of AvroSerializers for generic records - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/12 08:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9570) SQL Client merging environments uses AbstractMap - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/12 08:44:00 UTC, 6 replies.
- [GitHub] flink pull request #6151: [FLINK-9569] [avro] Fix confusing construction of ... - posted by tzulitai <gi...@git.apache.org> on 2018/06/12 08:56:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-9569) Confusing construction of AvroSerializers for generic records - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 08:57:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9568) Wrong error handling for batch input formats with invalid paths - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9566) Support listing all jobs in CliFrontend#list - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9451) End-to-end test: Scala Quickstarts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:38:00 UTC, 0 replies.
- [GitHub] flink pull request #6060: [FLINK-8946] TaskManager stop sending metrics afte... - posted by asfgit <gi...@git.apache.org> on 2018/06/12 09:39:14 UTC, 0 replies.
- [jira] [Closed] (FLINK-9564) Expose end-to-end module directory to test scripts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:40:00 UTC, 0 replies.
- [GitHub] flink issue #6127: [FLINK-9368][py][tests] Add Python API E2E test - posted by zentol <gi...@git.apache.org> on 2018/06/12 09:42:09 UTC, 0 replies.
- [jira] [Updated] (FLINK-9368) End-to-end test: Python API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9368) End-to-end test: Python API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 09:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/12 09:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8768) Change NettyMessageDecoder to inherit from LengthFieldBasedFrameDecoder - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/12 09:47:00 UTC, 0 replies.
- [GitHub] flink pull request #5570: [FLINK-8768][network] Let NettyMessageDecoder inhe... - posted by asfgit <gi...@git.apache.org> on 2018/06/12 09:47:33 UTC, 0 replies.
- [GitHub] flink pull request #5571: [FLINK-8759][network] preparations for the update ... - posted by asfgit <gi...@git.apache.org> on 2018/06/12 09:47:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 09:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8768) Change NettyMessageDecoder to inherit from LengthFieldBasedFrameDecoder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 09:48:00 UTC, 0 replies.
- [GitHub] flink pull request #6152: 9467 - posted by zentol <gi...@git.apache.org> on 2018/06/12 10:25:50 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments - posted by "blues zheng (JIRA)" <ji...@apache.org> on 2018/06/12 11:47:00 UTC, 0 replies.
- [GitHub] flink pull request #5900: [FLINK-9222][docs] add documentation for setting u... - posted by twalthr <gi...@git.apache.org> on 2018/06/12 12:10:45 UTC, 13 replies.
- [jira] [Commented] (FLINK-9222) Add a Gradle Quickstart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 12:11:00 UTC, 14 replies.
- [jira] [Closed] (FLINK-8946) TaskManager stop sending metrics after JobManager failover - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/12 12:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9514) Create wrapper with TTL logic for value state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 12:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9515) Create wrapper with TTL logic for list state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 12:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9513) Wrap state binder with TTL logic - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 12:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9516) Create wrapper with TTL logic for map state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9571) Switch to internal states in StateBinder - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 13:01:00 UTC, 0 replies.
- [GitHub] flink pull request #6153: [FLINK-9557] [formats] Parse 'integer' type as Big... - posted by twalthr <gi...@git.apache.org> on 2018/06/12 13:04:52 UTC, 1 replies.
- [jira] [Created] (FLINK-9572) Extend InternalAppendingState with internal stored state access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/12 13:06:00 UTC, 0 replies.
- [GitHub] flink issue #6153: [FLINK-9557] [formats] Parse 'integer' type as BigDecimal - posted by twalthr <gi...@git.apache.org> on 2018/06/12 14:01:12 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9570) SQL Client merging environments uses AbstractMap - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/12 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9573) Check for leadership with leader session id - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/12 14:10:00 UTC, 0 replies.
- [GitHub] flink pull request #6154: [FLINK-9573] Extend LeaderElectionService#hasLeade... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/12 14:20:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-9573) Check for leadership with leader session id - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 14:21:00 UTC, 4 replies.
- [GitHub] flink pull request #6155: [FLINK-9494] Fix race condition in Dispatcher with... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/12 14:23:09 UTC, 3 replies.
- [jira] [Commented] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 14:24:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-9220) Table program cannot be compiled - posted by "Rakesh Chalasani (JIRA)" <ji...@apache.org> on 2018/06/12 15:08:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-9220) Table program cannot be compiled - posted by "Rakesh Chalasani (JIRA)" <ji...@apache.org> on 2018/06/12 15:10:00 UTC, 1 replies.
- [GitHub] flink pull request #6156: [FLINK-9572] Extend InternalAppendingState with in... - posted by azagrebin <gi...@git.apache.org> on 2018/06/12 15:30:57 UTC, 21 replies.
- [jira] [Commented] (FLINK-9572) Extend InternalAppendingState with internal stored state access - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/12 15:31:00 UTC, 25 replies.
- [GitHub] flink issue #6156: [FLINK-9572] Extend InternalAppendingState with internal ... - posted by azagrebin <gi...@git.apache.org> on 2018/06/12 15:31:41 UTC, 3 replies.
- [GitHub] flink issue #5900: [FLINK-9222][docs] add documentation for setting up Gradl... - posted by NicoK <gi...@git.apache.org> on 2018/06/12 22:04:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-9548) Flink Apache Kudu Connector - posted by "Sandish Kumar HN (JIRA)" <ji...@apache.org> on 2018/06/13 04:14:00 UTC, 5 replies.
- [GitHub] flink pull request #6157: [FLINK-9570][SQL-CLIENT]Fixed merging environments - posted by Wosin <gi...@git.apache.org> on 2018/06/13 07:29:49 UTC, 1 replies.
- [jira] [Resolved] (FLINK-9458) Unable to recover from job failure on YARN with NPE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 07:44:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9463) Setting taskmanager.network.netty.transport to epoll - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 07:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9463) Setting taskmanager.network.netty.transport to epoll - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 07:53:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3952) Bump Netty to 4.1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 07:54:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8796) Update "Upgrading Applications and Flink Versions" for 1.5 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 08:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 08:08:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9220) Table program cannot be compiled - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/13 08:21:00 UTC, 0 replies.
- [GitHub] flink issue #5777: [FLINK-7897] Consider using nio.Files for file deletion i... - posted by yanghua <gi...@git.apache.org> on 2018/06/13 08:43:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 08:44:00 UTC, 6 replies.
- [jira] [Closed] (FLINK-3952) Bump Netty to 4.1 - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/13 08:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 09:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9382) Inconsistent file storage behavior in FileCache - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 09:23:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9382) Inconsistent file storage behavior in FileCache - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/13 09:23:00 UTC, 0 replies.
- [GitHub] flink pull request #6081: [FLINK-8067] User code ClassLoader not set before ... - posted by pnowojski <gi...@git.apache.org> on 2018/06/13 09:25:59 UTC, 8 replies.
- [GitHub] flink pull request #6158: [FLINK-8785][rest] Handle JobSubmissionExceptions - posted by zentol <gi...@git.apache.org> on 2018/06/13 09:26:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 09:27:00 UTC, 9 replies.
- [GitHub] flink pull request #5877: [FLINK-8785][Job-Submission]Handle JobSubmissionEx... - posted by buptljy <gi...@git.apache.org> on 2018/06/13 09:32:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-9463) Setting taskmanager.network.netty.transport to epoll - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/13 09:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/13 09:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9574) Add a dedicated documentation page for state evolution - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/13 10:32:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9574) Add a dedicated documentation page for state evolution - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/13 10:32:00 UTC, 0 replies.
- [GitHub] flink issue #5960: [Flink-8725] Separate state from NFA in CEP library - posted by kl0u <gi...@git.apache.org> on 2018/06/13 10:32:15 UTC, 0 replies.
- [GitHub] flink pull request #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass"... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/13 10:43:44 UTC, 10 replies.
- [jira] [Commented] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 10:44:00 UTC, 16 replies.
- [jira] [Created] (FLINK-9575) Potential race condition when removing JobGraph in HA - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/13 11:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9575) Potential race condition when removing JobGraph in HA - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/13 11:24:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-9575) Potential race condition when removing JobGraph in HA - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 11:26:00 UTC, 3 replies.
- [GitHub] flink issue #3034: [FLINK-5363] Fire timers when window state is currently e... - posted by cjolif <gi...@git.apache.org> on 2018/06/13 12:05:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-5363) Fire timers when window state is currently empty - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 12:06:00 UTC, 0 replies.
- [GitHub] flink issue #6157: [FLINK-9570][SQL-CLIENT]Fixed merging environments - posted by twalthr <gi...@git.apache.org> on 2018/06/13 12:08:23 UTC, 0 replies.
- [GitHub] flink issue #6053: [FLINK-9257][E2E Tests] Fix wrong "All tests pass" messag... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/13 12:09:18 UTC, 5 replies.
- [GitHub] flink issue #5762: [FLINK-9078][E2ETests] Add test that verifies correct avr... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/13 12:39:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 12:40:00 UTC, 0 replies.
- [GitHub] flink issue #5342: [FLINK-8479] Timebounded stream join - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/13 12:55:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 12:56:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9576) Wrong contiguity documentation - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9577) Divide-by-zero in PageRank - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 13:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9570) SQL Client merging environments uses AbstractMap - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/13 13:23:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8686) Improve basic embedded SQL client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/13 13:24:00 UTC, 0 replies.
- [GitHub] flink pull request #6159: [FLINK-9487] Prepare InternalTimerHeap for asynchr... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/13 13:31:49 UTC, 9 replies.
- [jira] [Commented] (FLINK-9487) Prepare InternalTimerHeap for asynchronous snapshots - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 13:32:00 UTC, 13 replies.
- [GitHub] flink issue #6159: [FLINK-9487] Prepare InternalTimerHeap for asynchronous s... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/13 13:32:26 UTC, 3 replies.
- [jira] [Created] (FLINK-9578) Allow to define an auto watermark interval in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/13 13:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9578) Allow to define an auto watermark interval in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/13 13:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9577) Divide-by-zero in PageRank - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/13 14:55:00 UTC, 0 replies.
- [GitHub] flink pull request #5960: [Flink-8725] Separate state from NFA in CEP librar... - posted by asfgit <gi...@git.apache.org> on 2018/06/13 14:56:15 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9538) Make KeyedStateFunction an interface - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 14:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9418) Migrate SharedBuffer to use MapState - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 14:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6939) Not store IterativeCondition with NFA state - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8725) Separate NFA-state from NFA in CEP library - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6939) Not store IterativeCondition with NFA state - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-6939) Not store IterativeCondition with NFA state - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8725) Separate NFA-state from NFA in CEP library - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6983) Do not serialize States with NFA - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:04:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-6983) Do not serialize States with NFA - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/13 15:04:00 UTC, 0 replies.
- [GitHub] flink pull request #6160: [FLINK-9578] [sql-client] Allow to define an auto ... - posted by twalthr <gi...@git.apache.org> on 2018/06/13 15:06:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-9578) Allow to define an auto watermark interval in SQL Client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9579) Remove unnecessary check with cep elementQueue - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/13 15:20:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9548) Flink Apache Kudu Connector - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/13 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/13 19:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9581) Redundant spaces for Collect at sql.md - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/13 20:39:00 UTC, 0 replies.
- [GitHub] flink pull request #6161: [FLINK-9581] Remove extra spaces to make COLLECT l... - posted by snuyanzin <gi...@git.apache.org> on 2018/06/13 20:43:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-9581) Redundant spaces for Collect at sql.md - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/13 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9582) dist assemblies access files outside of flink-dist - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 21:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9582) dist assemblies access jars outside of flink-dist - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/13 21:50:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/13 23:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9579) Remove unnecessary clear with cep elementQueue - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/14 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9583) Wrong number of TaskManagers' slots after recovery. - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/06/14 03:30:00 UTC, 0 replies.
- [GitHub] flink issue #6149: [FLINK-9560] Add RateLimiting for FileSystem - posted by etiennecarriere <gi...@git.apache.org> on 2018/06/14 05:52:44 UTC, 3 replies.
- [GitHub] flink pull request #6162: [FLINK-9579][CEP]Remove unneeded clear on elementQ... - posted by Aitozi <gi...@git.apache.org> on 2018/06/14 06:56:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-9579) Remove unnecessary clear with cep elementQueue - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 06:57:00 UTC, 6 replies.
- [GitHub] flink issue #6162: [FLINK-9579][CEP]Remove unneeded clear on elementQueueSta... - posted by dawidwys <gi...@git.apache.org> on 2018/06/14 07:56:07 UTC, 4 replies.
- [jira] [Updated] (FLINK-7591) Support partition by and order by of MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/14 08:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4542) Add MULTISET operations - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/14 08:56:00 UTC, 4 replies.
- [GitHub] flink issue #6155: [FLINK-9494] Fix race condition in Dispatcher with granti... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/14 08:59:31 UTC, 1 replies.
- [jira] [Created] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 09:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/14 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 09:41:00 UTC, 0 replies.
- [GitHub] flink pull request #6163: [hotfix][table] Fix a incorrect exception message. - posted by kisimple <gi...@git.apache.org> on 2018/06/14 09:46:36 UTC, 1 replies.
- [jira] [Resolved] (FLINK-9572) Extend InternalAppendingState with internal stored state access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/14 10:02:00 UTC, 0 replies.
- [GitHub] flink issue #5843: [FLINK-8744][docs] Generate "Common Option" section - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/14 10:03:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-8744) Add annotations for documenting common/advanced options - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 10:04:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9586) Make collection sources parallelisable - posted by "Sina Madani (JIRA)" <ji...@apache.org> on 2018/06/14 10:09:00 UTC, 0 replies.
- [GitHub] flink pull request #5777: [FLINK-7897] Consider using nio.Files for file del... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/14 10:13:56 UTC, 3 replies.
- [GitHub] flink pull request #6164: [FLINK-9584][connector] Properly close the output ... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/14 10:14:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files - posted by "Andrei Shumanski (JIRA)" <ji...@apache.org> on 2018/06/14 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9588) Reuse the same conditionContext with in a same computationState - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/14 14:10:00 UTC, 0 replies.
- [GitHub] flink pull request #6165: [FLINK-9577] Divide-by-zero in PageRank - posted by yanghua <gi...@git.apache.org> on 2018/06/14 14:17:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-9577) Divide-by-zero in PageRank - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 14:18:00 UTC, 2 replies.
- [GitHub] flink pull request #6166: [FLINK-9580] Potentially unclosed ByteBufInputStre... - posted by yanghua <gi...@git.apache.org> on 2018/06/14 14:20:27 UTC, 3 replies.
- [GitHub] flink pull request #6167: [FLINK-9582][build] Rework flink-dist assemblies - posted by zentol <gi...@git.apache.org> on 2018/06/14 14:20:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 14:21:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-9582) dist assemblies access jars outside of flink-dist - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 14:21:00 UTC, 0 replies.
- [GitHub] flink pull request #6168: [FLINK-9588]Reused context with same computation s... - posted by Aitozi <gi...@git.apache.org> on 2018/06/14 14:28:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-9588) Reuse the same conditionContext with in a same computationState - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 14:29:00 UTC, 14 replies.
- [GitHub] flink issue #6165: [FLINK-9577] Divide-by-zero in PageRank - posted by zentol <gi...@git.apache.org> on 2018/06/14 14:30:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/14 14:51:00 UTC, 0 replies.
- [GitHub] flink pull request #6169: [FLINK-8573] Extend ProgramInvocationException mes... - posted by azagrebin <gi...@git.apache.org> on 2018/06/14 15:01:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-8573) Print JobID for failed jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 15:02:00 UTC, 3 replies.
- [GitHub] flink issue #6169: [FLINK-8573] Extend ProgramInvocationException message wi... - posted by azagrebin <gi...@git.apache.org> on 2018/06/14 15:10:53 UTC, 0 replies.
- [GitHub] flink pull request #6083: [FLINK-8983] End-to-end test: Confluent schema reg... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/14 15:56:14 UTC, 35 replies.
- [jira] [Created] (FLINK-9589) PythonOperationInfo should be immutable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 15:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/14 16:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9573) Check for leadership with leader session id - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/14 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9590) HistogramDump should be immutable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9591) Remove remnants of distributed-cache logic - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 17:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder - posted by "Mahesh Senniappan (JIRA)" <ji...@apache.org> on 2018/06/14 18:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 18:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9380) Failing end-to-end tests should not clean up logs - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/14 19:19:00 UTC, 5 replies.
- [jira] [Created] (FLINK-9592) Notify on moving into pending/ final state - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/14 20:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9592) Notify on moving file into pending/ final state - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/14 20:27:00 UTC, 2 replies.
- [GitHub] flink pull request #6170: [FLINK-9563]: Using a custom sink function for tes... - posted by deepaks4077 <gi...@git.apache.org> on 2018/06/14 21:05:32 UTC, 12 replies.
- [jira] [Commented] (FLINK-9563) Migrate integration tests for CEP - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/14 21:06:00 UTC, 19 replies.
- [GitHub] flink issue #6170: [FLINK-9563]: Using a custom sink function for tests in C... - posted by deepaks4077 <gi...@git.apache.org> on 2018/06/14 21:28:40 UTC, 6 replies.
- [jira] [Closed] (FLINK-9530) Task numRecords metrics broken for chains - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 23:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5843: [FLINK-8744][docs] Generate "Common Option" sectio... - posted by asfgit <gi...@git.apache.org> on 2018/06/14 23:51:43 UTC, 0 replies.
- [jira] [Closed] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 23:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8744) Add annotations for documenting common/advanced options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 23:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9589) PythonOperationInfo should be immutable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 23:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9591) Remove remnants of distributed-cache logic - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 23:53:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9590) HistogramDump should be immutable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/14 23:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/15 04:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9567) Flink does not release resource in Yarn Cluster mode - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/06/15 06:03:00 UTC, 16 replies.
- [jira] [Resolved] (FLINK-8573) Print JobID for failed jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 07:11:00 UTC, 0 replies.
- [GitHub] flink pull request #5421: [FLINK-8573] [client] Add more information for pri... - posted by asfgit <gi...@git.apache.org> on 2018/06/15 07:11:36 UTC, 0 replies.
- [jira] [Created] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/15 07:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6171: [FLINK-9593] Unified After Match semantics with SQ... - posted by dawidwys <gi...@git.apache.org> on 2018/06/15 07:46:32 UTC, 5 replies.
- [GitHub] flink issue #6171: [FLINK-9593] Unified After Match semantics with SQL MATCH... - posted by dawidwys <gi...@git.apache.org> on 2018/06/15 07:46:56 UTC, 1 replies.
- [jira] [Commented] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/15 07:47:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-9592) Notify on moving file into pending/ final state - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/06/15 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/06/15 08:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/06/15 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/15 08:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/15 08:48:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-9592) Notify on moving file into pending/ final state - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/06/15 08:53:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/15 08:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/15 08:54:00 UTC, 1 replies.
- [GitHub] flink pull request #6172: [FLINK-9594][E2E tests] Improve docs for new test ... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/15 09:21:32 UTC, 7 replies.
- [jira] [Commented] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/15 09:22:00 UTC, 10 replies.
- [GitHub] flink issue #6172: [FLINK-9594][E2E tests] Improve docs for new test runner] - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/15 09:22:41 UTC, 0 replies.
- [GitHub] flink issue #6168: [FLINK-9588][CEP]Reused context with same computation sta... - posted by Aitozi <gi...@git.apache.org> on 2018/06/15 09:23:36 UTC, 2 replies.
- [jira] [Updated] (FLINK-9380) Failing end-to-end tests should not clean up logs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 10:10:00 UTC, 1 replies.
- [GitHub] flink issue #6166: [FLINK-9580] Potentially unclosed ByteBufInputStream in R... - posted by yanghua <gi...@git.apache.org> on 2018/06/15 12:04:06 UTC, 2 replies.
- [jira] [Created] (FLINK-9596) Ability to configure logging using the same log4j file - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/15 12:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9596) Ability to configure logging using single log4j file - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/15 12:40:00 UTC, 0 replies.
- [GitHub] flink pull request #6168: [FLINK-9588][CEP]Reused context with same computat... - posted by dawidwys <gi...@git.apache.org> on 2018/06/15 12:47:00 UTC, 10 replies.
- [GitHub] flink issue #5846: [FLINK-9143] [client] Restart strategy defined in flink-c... - posted by dawidwys <gi...@git.apache.org> on 2018/06/15 12:53:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/15 12:54:00 UTC, 1 replies.
- [GitHub] flink pull request #6173: [FLINK-9571] Refactor StateBinder to internal back... - posted by azagrebin <gi...@git.apache.org> on 2018/06/15 14:16:13 UTC, 10 replies.
- [jira] [Commented] (FLINK-9571) Switch to internal states in StateBinder - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/15 14:17:00 UTC, 14 replies.
- [GitHub] flink issue #6173: [FLINK-9571] Refactor StateBinder to internal backend spe... - posted by azagrebin <gi...@git.apache.org> on 2018/06/15 14:17:20 UTC, 3 replies.
- [GitHub] flink issue #6138: [FLINK-9550][DOC]FlinkCEP snippet example has some syntax... - posted by medcv <gi...@git.apache.org> on 2018/06/15 14:18:57 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9159) Sanity check default timeout values - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/15 14:29:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint with iterations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 14:32:01 UTC, 3 replies.
- [jira] [Commented] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint with iterations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 14:36:11 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 14:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9382) Inconsistent file storage behavior in FileCache - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 14:48:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9597) Flink fail to scale! - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/15 14:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8979) Extend Kafka end-to-end tests to run with different versions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9597) Flink fail to scale! - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/15 15:01:00 UTC, 18 replies.
- [jira] [Updated] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9159) Sanity check default timeout values - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9000) Add automated cluster framework tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:08:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9005) Cluster test: Run general purpose job with failures with Mesos - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:08:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9006) Cluster test: Run general purpose job with failures with Yarn and per-job mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:08:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-9468) get outputLimit of LimitedConnectionsFileSystem incorrectly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9597) Flink fail to scale! - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/15 15:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9597) Flink fail to scale! - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/15 15:18:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure - posted by "Prem Santosh (JIRA)" <ji...@apache.org> on 2018/06/15 15:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9098) ClassLoaderITCase unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 15:22:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-9366) Distribute Cache only works for client-accessible files - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/15 15:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9551) FlinkCEP Scala Combining Patterns table has a missing pattern - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/15 15:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9579) Remove unnecessary clear with cep elementQueue - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/15 15:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9597) Flink application does not scale as expected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/15 15:42:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception" - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception" - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:10:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-7881) flink can't deployed on yarn with ha - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7697) Add metrics for Elasticsearch Sink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/15 16:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9545) Support read a file multiple times in Flink DataStream - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/06/15 17:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9597) Flink application does not scale as expected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/15 17:23:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/15 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/15 19:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9487) Prepare InternalTimerHeap for asynchronous snapshots - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/15 20:23:00 UTC, 0 replies.
- [GitHub] flink issue #6076: [hotfix][docs] Specify operators behaviour on processing ... - posted by eliaslevy <gi...@git.apache.org> on 2018/06/16 01:52:48 UTC, 1 replies.
- [jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/16 02:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9380) Failing end-to-end tests should not clean up logs - posted by "Deepak Sharma (JIRA)" <ji...@apache.org> on 2018/06/16 02:47:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9597) Flink application does not scale as expected - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/16 09:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9597) Flink application does not scale as expected - posted by "swy (JIRA)" <ji...@apache.org> on 2018/06/16 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/16 10:07:00 UTC, 0 replies.
- [GitHub] flink pull request #6174: [FLINNK-9601][state]Try to reuse the snapshotData ... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/16 10:25:43 UTC, 0 replies.
- [GitHub] flink issue #6174: [FLINNK-9601][state]Try to reuse the snapshotData array a... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/16 10:26:31 UTC, 0 replies.
- [jira] [Created] (FLINK-9602) Extend CommonOption section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/16 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/16 14:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/16 14:30:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed when the amount of record is more than MAXIMUM_CAPACITY - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/16 14:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/16 14:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/16 14:55:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9602) Extend CommonOption section - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/16 14:56:00 UTC, 0 replies.
- [GitHub] flink pull request #6175: [FLINK-9585] Logger in ZooKeeperStateHandleStore i... - posted by yanghua <gi...@git.apache.org> on 2018/06/16 15:02:04 UTC, 1 replies.
- [GitHub] flink issue #6175: [FLINK-9585] Logger in ZooKeeperStateHandleStore is publi... - posted by yanghua <gi...@git.apache.org> on 2018/06/16 15:02:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/16 15:03:00 UTC, 4 replies.
- [GitHub] flink issue #6174: [FLINK-9601][state]Try to reuse the snapshotData array as... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/16 16:46:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed when the amount of record is more than MAXIMUM_CAPACITY - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/16 16:47:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/17 03:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/17 03:09:00 UTC, 1 replies.
- [GitHub] flink issue #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore probl... - posted by Myasuka <gi...@git.apache.org> on 2018/06/17 09:14:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/17 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9606) Support ParquetTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9607) Support ParquetTableSink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9606) Support ParquetTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9606) Support ParquetTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 12:59:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9607) Support ParquetTableSink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 13:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) - posted by "Rinat Sharipov (JIRA)" <ji...@apache.org> on 2018/06/17 13:02:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9604) Support KafkaProtoBufTableSource - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/17 13:04:00 UTC, 0 replies.
- [GitHub] flink pull request #6176: [FLINK-9603][connector-filesystem] fix part indexi... - posted by kent2171 <gi...@git.apache.org> on 2018/06/17 13:41:15 UTC, 0 replies.
- [GitHub] flink pull request #6177: Backport of Kinesis connector changes from 1.5 to ... - posted by tweise <gi...@git.apache.org> on 2018/06/17 19:04:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/18 05:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/18 05:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9606) Support ParquetTableSource - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/06/18 06:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9606) Support ParquetTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/18 07:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6174: [FLINK-9601][state]Try to reuse the snapshotData a... - posted by asfgit <gi...@git.apache.org> on 2018/06/18 07:49:31 UTC, 0 replies.
- [jira] [Closed] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed when the amount of record is more than MAXIMUM_CAPACITY - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/18 07:54:00 UTC, 0 replies.
- [GitHub] flink issue #6177: Backport of Kinesis connector changes from 1.5 to release... - posted by tzulitai <gi...@git.apache.org> on 2018/06/18 08:00:43 UTC, 3 replies.
- [jira] [Updated] (FLINK-9602) Extend CommonOption section - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 08:24:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/18 08:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/18 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/18 09:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/18 09:04:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/18 09:51:00 UTC, 16 replies.
- [jira] [Closed] (FLINK-9571) Switch to internal states in StateBinder - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/18 12:45:00 UTC, 0 replies.
- [GitHub] flink pull request #6178: [FLINK-9599][rest] Implement generic mechanism to ... - posted by zentol <gi...@git.apache.org> on 2018/06/18 13:21:50 UTC, 56 replies.
- [jira] [Commented] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/18 13:22:00 UTC, 95 replies.
- [GitHub] flink pull request #6179: [hotfix][docs] Removed duplicate line in windows d... - posted by Tobii42 <gi...@git.apache.org> on 2018/06/18 15:00:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:15:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9583) Wrong number of TaskManagers' slots after recovery. - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9576) Wrong contiguity documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:21:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9567) Flink does not release resource in Yarn Cluster mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9560) RateLimiting for FileSystem - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/18 15:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9548) Flink Apache Kudu Connector - posted by "Sandish Kumar HN (JIRA)" <ji...@apache.org> on 2018/06/18 16:24:00 UTC, 0 replies.
- [GitHub] flink pull request #6180: [FLINK-9524][Table API & SQL] check whether a clea... - posted by yzandrew <gi...@git.apache.org> on 2018/06/18 18:54:25 UTC, 3 replies.
- [jira] [Created] (FLINK-9610) Add Kafka partitioner that uses the key to partition by - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2018/06/18 19:16:00 UTC, 0 replies.
- [GitHub] flink pull request #6181: [FLINK-9610] [flink-connector-kafka-base] Add Kafk... - posted by nielsbasjes <gi...@git.apache.org> on 2018/06/18 19:54:26 UTC, 2 replies.
- [jira] [Commented] (FLINK-9610) Add Kafka partitioner that uses the key to partition by - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/18 19:55:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9610) Add Kafka partitioner that uses the key to partition by - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2018/06/18 20:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9612) Add option for minimal artifacts being pulled in meseos - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 01:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 01:45:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9612) Add option for minimal artifacts being pulled in meseos - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 01:45:00 UTC, 0 replies.
- [GitHub] flink issue #6088: [FLINK-9417][ Distributed Coordination] Send heartbeat re... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/19 05:22:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-9417) Send heartbeat requests from RPC endpoint's main thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/19 05:23:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9612) Add option for minimal artifacts being pulled in Mesos - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/19 07:51:00 UTC, 0 replies.
- [GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter - posted by lamber-ken <gi...@git.apache.org> on 2018/06/19 07:54:21 UTC, 6 replies.
- [jira] [Commented] (FLINK-9612) Add option for minimal artifacts being pulled in Mesos - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/19 08:05:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9613) YARNSessionCapacitySchedulerITCase failed because YarnTestBase.checkClusterEmpty() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/19 10:17:00 UTC, 0 replies.
- [GitHub] flink pull request #6108: [FLINK-9367] [Streaming Connectors] Allow to do tr... - posted by zhangxinyu1 <gi...@git.apache.org> on 2018/06/19 11:30:31 UTC, 0 replies.
- [GitHub] flink issue #6147: [FLINK-9280][rest] Rework JobSubmitHandler to accept jar/... - posted by zentol <gi...@git.apache.org> on 2018/06/19 11:53:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-9367) Truncate() in BucketingSink is only allowed after hadoop2.7 - posted by "zhangxinyu (JIRA)" <ji...@apache.org> on 2018/06/19 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/19 13:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/19 13:14:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9615) Add - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/19 13:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/19 13:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/19 13:51:00 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-9615) Add possibility to use Connectors as Sinks in SQL Client - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/19 13:57:00 UTC, 0 replies.
- [GitHub] flink pull request #6182: [FLINK-8795] Fixed local scala shell for Flip6 - posted by dawidwys <gi...@git.apache.org> on 2018/06/19 14:20:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-8795) Scala shell broken for Flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/19 14:21:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9616) DatadogHttpReporter fails to be created due to missing shaded dependency - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2018/06/19 14:49:00 UTC, 0 replies.
- [GitHub] flink pull request #6183: [FLINK-9616][metrics] Fix datadog to include shade... - posted by addisonj <gi...@git.apache.org> on 2018/06/19 15:04:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-9616) DatadogHttpReporter fails to be created due to missing shaded dependency - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/19 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9617) Provide alias for whole records in Table API - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/19 15:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8921) Split code generated call expression - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/19 16:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/06/19 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set - posted by "Aaron Langford (JIRA)" <ji...@apache.org> on 2018/06/20 00:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set - posted by "Aaron Langford (JIRA)" <ji...@apache.org> on 2018/06/20 00:17:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 01:02:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 01:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 01:27:00 UTC, 0 replies.
- [GitHub] flink pull request #6184: add prometheus pushgateway reporter - posted by lamber-ken <gi...@git.apache.org> on 2018/06/20 04:28:29 UTC, 0 replies.
- [GitHub] flink issue #6184: [FLINK-9187][METRICS] add prometheus pushgateway reporter - posted by lamber-ken <gi...@git.apache.org> on 2018/06/20 04:31:07 UTC, 0 replies.
- [jira] [Created] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/20 04:41:00 UTC, 0 replies.
- [GitHub] flink pull request #6185: [FLINK-9619][YARN] Eagerly close the connection wi... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/20 04:43:26 UTC, 0 replies.
- [GitHub] flink issue #6185: [FLINK-9619][YARN] Eagerly close the connection with task... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/20 04:43:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 04:44:00 UTC, 1 replies.
- [GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/20 05:49:03 UTC, 0 replies.
- [jira] [Created] (FLINK-9620) Add an alternative option to choose when deal with eventtime cep - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/20 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9621) Warning when enabling partition discovery - posted by "Olivier Zembri (JIRA)" <ji...@apache.org> on 2018/06/20 07:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8795) Scala shell broken for Flip6 - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/20 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9622) DistributedCacheDfsTest failed on travis - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/20 07:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9622) DistributedCacheDfsTest failed on travis - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/20 07:20:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9621) Warning when enabling partition discovery - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/20 08:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9621) Warning when enabling partition discovery - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/20 08:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7881) flink can't deployed on yarn with ha - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/20 08:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9439) DispatcherTest#testJobRecovery dead locks - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/20 08:48:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/20 09:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9622) DistributedCacheDfsTest failed on travis - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/06/20 09:44:00 UTC, 0 replies.
- [GitHub] flink issue #6178: [FLINK-9599][rest] Implement generic mechanism to access ... - posted by zentol <gi...@git.apache.org> on 2018/06/20 09:51:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-9602) Extend CommonOption section - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/20 09:52:00 UTC, 0 replies.
- [GitHub] flink pull request #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrapp... - posted by azagrebin <gi...@git.apache.org> on 2018/06/20 10:15:47 UTC, 63 replies.
- [jira] [Commented] (FLINK-9514) Create wrapper with TTL logic for value state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 10:16:00 UTC, 73 replies.
- [GitHub] flink issue #6186: [FLINK-9514,FLINK-9515,FLINK-9516] State ttl wrappers - posted by azagrebin <gi...@git.apache.org> on 2018/06/20 10:16:01 UTC, 9 replies.
- [jira] [Created] (FLINK-9623) Move zipping logic out of blobservice - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/20 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9624) Move jar/artifact upload logic out of JobGraph - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/20 10:43:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 11:58:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-9614) Improve the error message for Compiler#compile - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9625) Enrich the error information to user - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 12:03:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9625) Enrich the error information to user - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/20 12:05:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9626) Possible resource leak in FileSystem - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/20 12:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9626) Possible resource leak in FileSystem - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/20 12:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9626) Possible resource leak in FileSystem - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/20 12:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/06/20 12:40:00 UTC, 23 replies.
- [GitHub] flink pull request #6187: FLINK-9623][runtime] Move zipping logic out of blo... - posted by zentol <gi...@git.apache.org> on 2018/06/20 12:58:39 UTC, 4 replies.
- [jira] [Commented] (FLINK-9623) Move zipping logic out of blobservice - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 12:59:00 UTC, 5 replies.
- [jira] [Created] (FLINK-9627) Extending - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/20 13:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9627) Extending 'KafkaJsonTableSource' according to comments will result in NPE - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/20 13:19:00 UTC, 3 replies.
- [GitHub] flink pull request #6188: [FLINK-6846] add timestampAdd tableApi - posted by xueyumusic <gi...@git.apache.org> on 2018/06/20 13:34:49 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/06/20 13:37:00 UTC, 0 replies.
- [GitHub] flink pull request #6189: [FLINK-9599][rest] RestClient supports FileUploads... - posted by zentol <gi...@git.apache.org> on 2018/06/20 14:08:37 UTC, 31 replies.
- [jira] [Created] (FLINK-9628) Options to tolerate truncate failure in BucketingSink - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/06/20 14:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9604) Support KafkaProtoBufTableSource - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/20 14:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 15:53:00 UTC, 0 replies.
- [GitHub] flink issue #6182: [FLINK-8795] Fixed local scala shell for Flip6 - posted by tzulitai <gi...@git.apache.org> on 2018/06/20 16:00:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-8795) Scala shell broken for Flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 16:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9374) Flink Kinesis Producer does not backpressure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/20 20:59:00 UTC, 0 replies.
- [GitHub] flink pull request #6190: Add a simple pulsar source connector. - posted by cckellogg <gi...@git.apache.org> on 2018/06/20 21:55:19 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9627) Extending 'KafkaJsonTableSource' according to comments will result in NPE - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/20 23:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies - posted by "Georgii Gobozov (JIRA)" <ji...@apache.org> on 2018/06/21 00:18:00 UTC, 0 replies.
- [GitHub] flink pull request #6191: [FLINK-9629][metrics] Included datadog shaded depe... - posted by gobozov <gi...@git.apache.org> on 2018/06/21 00:27:48 UTC, 1 replies.
- [jira] [Updated] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 00:28:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 00:28:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException - posted by "Youjun Yuan (JIRA)" <ji...@apache.org> on 2018/06/21 00:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException - posted by "Youjun Yuan (JIRA)" <ji...@apache.org> on 2018/06/21 00:52:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8863) Add user-defined function support in SQL Client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 02:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9631) use Files.createDirectories instead of directory.mkdirs - posted by "makeyang (JIRA)" <ji...@apache.org> on 2018/06/21 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9632) SlotPool should notify the call when allocateSlot meet an exception - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/06/21 03:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9632) SlotPool should notify the caller when allocateSlot meet an exception - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/06/21 03:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9632) SlotPool should notify the caller when allocateSlot meet an exception - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/06/21 06:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9575) Potential race condition when removing JobGraph in HA - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/06/21 06:51:00 UTC, 0 replies.
- [GitHub] flink issue #6188: [FLINK-6846][Table API] add timestampAdd tableApi - posted by xueyumusic <gi...@git.apache.org> on 2018/06/21 07:05:47 UTC, 3 replies.
- [jira] [Updated] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task. - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/21 07:35:00 UTC, 0 replies.
- [GitHub] flink issue #6172: [FLINK-9594][E2E tests] Improve docs for new test runner - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/21 07:57:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/21 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9635) Local recovery scheduling can cause spread out of tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/21 08:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9635) Local recovery scheduling can cause spread out of tasks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/21 08:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task. - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/21 08:09:00 UTC, 1 replies.
- [GitHub] flink issue #5807: [FLINK-8982][E2E Tests] Add test for known failure of que... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/21 08:16:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-8982) End-to-end test: Queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 08:17:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8982) End-to-end test: Queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 08:17:00 UTC, 0 replies.
- [GitHub] flink pull request #6192: [FLINK-9567][runtime][yarn] Fix the bug that Flink... - posted by Clarkkkkk <gi...@git.apache.org> on 2018/06/21 08:20:09 UTC, 10 replies.
- [jira] [Assigned] (FLINK-9510) State TTL API with cleanup on explicit access - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/21 08:35:00 UTC, 0 replies.
- [GitHub] flink pull request #6193: [hotfix] [docs] Fix typo in index.md - posted by MichealShin <gi...@git.apache.org> on 2018/06/21 08:54:37 UTC, 1 replies.
- [GitHub] flink pull request #6194: [FLINK-9633][checkpoint] Use savepoint path's file... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/21 09:47:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-9633) Flink doesn't use the Savepoint path's filesystem to create the OuptutStream on Task. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 09:48:00 UTC, 1 replies.
- [GitHub] flink issue #6194: [FLINK-9633][checkpoint] Use savepoint path's file system... - posted by sihuazhou <gi...@git.apache.org> on 2018/06/21 09:49:12 UTC, 0 replies.
- [GitHub] flink issue #6193: [hotfix] [docs] Fix typo in index.md - posted by tzulitai <gi...@git.apache.org> on 2018/06/21 09:57:26 UTC, 0 replies.
- [GitHub] flink pull request #6195: [FLINK-9543][METRICS] Expose JobMaster ID to metri... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/21 10:03:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-9543) Expose JobMaster IDs to metric system - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 10:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9543) Expose JobMaster IDs to metric system - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 10:04:00 UTC, 5 replies.
- [jira] [Created] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/21 10:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/21 10:30:00 UTC, 0 replies.
- [GitHub] flink pull request #6152: [FLINK-9467][metrics][WebUI] Fix watermark display... - posted by kl0u <gi...@git.apache.org> on 2018/06/21 10:52:03 UTC, 2 replies.
- [jira] [Updated] (FLINK-9467) No Watermark display on Web UI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 10:53:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9623) Move zipping logic out of blobservice - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 11:23:00 UTC, 0 replies.
- [GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure... - posted by asfgit <gi...@git.apache.org> on 2018/06/21 11:45:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-8982) End-to-end test: Queryable state - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/06/21 11:46:00 UTC, 0 replies.
- [GitHub] flink issue #6187: FLINK-9623][runtime] Move zipping logic out of blobservic... - posted by zentol <gi...@git.apache.org> on 2018/06/21 12:24:31 UTC, 0 replies.
- [GitHub] flink issue #6152: [FLINK-9467][metrics][WebUI] Fix watermark display - posted by zentol <gi...@git.apache.org> on 2018/06/21 12:31:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-9511) Make StateDescriptor configurable with optional TTL - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/21 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9637) Add public user documentation for TTL feature - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/21 13:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8983) End-to-end test: Confluent schema registry - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 13:20:00 UTC, 0 replies.
- [GitHub] flink pull request #6196: [FLINK-9513] Implement TTL state wrappers factory ... - posted by azagrebin <gi...@git.apache.org> on 2018/06/21 13:34:59 UTC, 35 replies.
- [jira] [Commented] (FLINK-9513) Wrap state binder with TTL logic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 13:35:00 UTC, 37 replies.
- [jira] [Created] (FLINK-9638) Add helper script to run single e2e test - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/06/21 13:42:00 UTC, 0 replies.
- [GitHub] flink pull request #6197: [FLINK-9638][E2E Tests] Add helper script to run s... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/06/21 13:47:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-9638) Add helper script to run single e2e test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 13:48:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9638) Add helper script to run single e2e test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 13:48:00 UTC, 0 replies.
- [GitHub] flink issue #6197: [FLINK-9638][E2E Tests] Add helper script to run single t... - posted by tzulitai <gi...@git.apache.org> on 2018/06/21 14:01:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-9411) Support parquet rolling sink writer - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/06/21 14:08:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9411) Support parquet rolling sink writer - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/06/21 14:30:00 UTC, 0 replies.
- [GitHub] flink pull request #6198: [FLINK-9627] Extending KafkaJsonTableSource accord... - posted by yanghua <gi...@git.apache.org> on 2018/06/21 14:52:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-9627) Extending 'KafkaJsonTableSource' according to comments will result in NPE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 14:53:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-9623) Move zipping logic out of blobservice - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/21 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9639) Order "User Configuration" Alphabetically on Flink Dashboard - posted by "Guilherme Nobre (JIRA)" <ji...@apache.org> on 2018/06/21 15:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9522) Rework Flink website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/21 15:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9639) Order "User Configuration" Alphabetically on Flink Dashboard - posted by "Guilherme Nobre (JIRA)" <ji...@apache.org> on 2018/06/21 15:37:00 UTC, 2 replies.
- [GitHub] flink issue #6189: [FLINK-9599][rest] RestClient supports FileUploads - posted by zentol <gi...@git.apache.org> on 2018/06/21 16:11:40 UTC, 1 replies.
- [jira] [Created] (FLINK-9640) Checkpointing is aways aborted if any task has been finished - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/21 17:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9640) Checkpointing is aways aborted if any task has been finished - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/21 17:25:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9467) No Watermark display on Web UI - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/21 18:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/21 18:03:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 18:13:00 UTC, 0 replies.
- [GitHub] flink pull request #6199: [FLINK-9624][runtime] Move jar/artifact upload out... - posted by zentol <gi...@git.apache.org> on 2018/06/21 21:13:56 UTC, 21 replies.
- [jira] [Commented] (FLINK-9624) Move jar/artifact upload logic out of JobGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 21:14:00 UTC, 23 replies.
- [jira] [Updated] (FLINK-9624) Move jar/artifact upload logic out of JobGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 21:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9641) Pulsar Source Connector - posted by "Chris Kellogg (JIRA)" <ji...@apache.org> on 2018/06/21 22:23:00 UTC, 0 replies.
- [GitHub] flink pull request #6200: [FLINK-9641] [streaming-connectors] Flink pulsar s... - posted by cckellogg <gi...@git.apache.org> on 2018/06/21 22:26:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-9641) Pulsar Source Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 22:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9641) Pulsar Source Connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/21 22:27:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-4301) Parameterize Flink version in Quickstart bash script - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/06/22 03:29:00 UTC, 4 replies.
- [GitHub] flink pull request #6201: [FLINK-8866][Table API & SQL] Add support for unif... - posted by suez1224 <gi...@git.apache.org> on 2018/06/22 07:00:56 UTC, 29 replies.
- [jira] [Updated] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 07:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 07:01:00 UTC, 32 replies.
- [GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in... - posted by asfgit <gi...@git.apache.org> on 2018/06/22 07:33:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 07:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 07:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 07:34:00 UTC, 0 replies.
- [GitHub] flink pull request #6038: [FLINK-9394] [e2e] Test rescaling when resuming fr... - posted by asfgit <gi...@git.apache.org> on 2018/06/22 07:34:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 07:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9642) Reduce the count to deal with state during a CEP process - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/22 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2 - posted by "Vinay (JIRA)" <ji...@apache.org> on 2018/06/22 08:16:00 UTC, 0 replies.
- [GitHub] flink issue #6195: [FLINK-9543][METRICS] Expose JobMaster ID to metric syste... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/22 08:32:55 UTC, 2 replies.
- [jira] [Created] (FLINK-9644) Restore a job from savepoint in a local stream environment - posted by "Manuel Haddadi (JIRA)" <ji...@apache.org> on 2018/06/22 09:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9644) Restore a job from savepoint in a local stream environment - posted by "Manuel Haddadi (JIRA)" <ji...@apache.org> on 2018/06/22 09:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8795) Scala shell broken for Flip6 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 09:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 09:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 09:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9638) Add helper script to run single e2e test - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 09:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9374) Flink Kinesis Producer does not backpressure - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 09:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9374) Flink Kinesis Producer does not backpressure - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 09:29:00 UTC, 0 replies.
- [GitHub] flink pull request #6202: [FLINK-9493] Forward cause when releasing a TaskMa... - posted by azagrebin <gi...@git.apache.org> on 2018/06/22 09:43:44 UTC, 1 replies.
- [GitHub] flink issue #6202: [FLINK-9493] Forward cause when releasing a TaskManager a... - posted by azagrebin <gi...@git.apache.org> on 2018/06/22 09:43:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 09:44:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 09:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/22 10:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/06/22 10:20:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9599) Implement generic mechanism to receive files via rest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 10:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9500) FileUploadHandler does not handle EmptyLastHttpContent - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 10:50:00 UTC, 0 replies.
- [GitHub] flink pull request #6203: [FLINK-9289][rest] Rework JobSubmitHandler to acce... - posted by zentol <gi...@git.apache.org> on 2018/06/22 11:31:09 UTC, 14 replies.
- [jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 11:32:00 UTC, 15 replies.
- [jira] [Updated] (FLINK-9289) Parallelism of generated operators should have max parallism of input - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 11:32:00 UTC, 0 replies.
- [GitHub] flink pull request #6204: [FLINK-4301][docs] add version for quickstart scri... - posted by xueyumusic <gi...@git.apache.org> on 2018/06/22 12:38:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-4301) Parameterize Flink version in Quickstart bash script - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 13:10:00 UTC, 0 replies.
- [GitHub] flink issue #6199: [FLINK-9624][runtime] Move jar/artifact upload out of job... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/22 13:10:10 UTC, 1 replies.
- [GitHub] flink issue #6203: [FLINK-9289][rest] Rework JobSubmitHandler to accept jar/... - posted by zentol <gi...@git.apache.org> on 2018/06/22 13:11:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-9644) Restore a job from savepoint in a local stream environment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/22 13:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9550) FlinkCEP snippet example has some syntax errors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 13:58:01 UTC, 0 replies.
- [GitHub] flink pull request #6203: [FLINK-9280][rest] Rework JobSubmitHandler to acce... - posted by zentol <gi...@git.apache.org> on 2018/06/22 14:06:49 UTC, 37 replies.
- [jira] [Updated] (FLINK-9280) Extend JobSubmitHandler to accept jar files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 14:11:00 UTC, 0 replies.
- [GitHub] flink issue #6163: [hotfix][table] Fix a incorrect exception message. - posted by fhueske <gi...@git.apache.org> on 2018/06/22 14:18:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-9588) Reuse the same conditionContext with in a same computationState - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 14:25:00 UTC, 0 replies.
- [GitHub] flink issue #5961: [FLINK-8255][DataSet API, DataStream API] key expressions... - posted by snuyanzin <gi...@git.apache.org> on 2018/06/22 14:33:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-8255) Key expressions on named row types do not work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 14:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8255) Key expressions on named row types do not work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/22 14:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 15:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 15:48:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 15:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/22 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9647) Files uploaded to blobservice during job submission aren't rmeoved on failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9649) TaskManagers are not scheduled on Mesos - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/22 18:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9649) TaskManagers are not scheduled on Mesos - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/22 18:51:00 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-9649) TaskManagers are not scheduled on Mesos - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/22 20:06:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9648) Do not store distributed cache entries in ExecutionConfig - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/23 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9650) Support Protocol Buffers formats - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/23 07:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9650) Support Protocol Buffers formats - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/23 07:50:00 UTC, 0 replies.
- [GitHub] flink issue #6203: [FLINK-9280][rest] Rework JobSubmitHandler to accept jar/... - posted by zentol <gi...@git.apache.org> on 2018/06/23 09:42:59 UTC, 3 replies.
- [GitHub] flink pull request #6205: [FLINK-9642]Reduce the count to deal with state du... - posted by Aitozi <gi...@git.apache.org> on 2018/06/23 13:09:55 UTC, 16 replies.
- [jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/23 13:10:00 UTC, 22 replies.
- [jira] [Updated] (FLINK-9642) Reduce the count to deal with state during a CEP process - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/23 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9651) Add a Kafka table source factory with Protobuf format support - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/06/23 13:41:00 UTC, 0 replies.
- [GitHub] flink pull request #6188: [FLINK-6846][Table API] add timestampAdd tableApi - posted by walterddr <gi...@git.apache.org> on 2018/06/23 15:02:27 UTC, 17 replies.
- [GitHub] flink issue #6205: [FLINK-9642]Reduce the count to deal with state during a ... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/24 03:32:50 UTC, 5 replies.
- [jira] [Commented] (FLINK-6759) storm-examples cannot be built without cached dependencies - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/24 05:39:00 UTC, 1 replies.
- [GitHub] flink issue #6198: [FLINK-9627] Extending KafkaJsonTableSource according to ... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/24 06:19:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/24 06:29:00 UTC, 0 replies.
- [GitHub] flink issue #5894: [FLINK-9185] [runtime] Fix potential null dereference in ... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/24 06:38:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/24 06:39:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/24 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9652) Metrics for upstream and downstream - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/06/24 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation - posted by "steven-qin (JIRA)" <ji...@apache.org> on 2018/06/24 12:25:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation - posted by "steven-qin (JIRA)" <ji...@apache.org> on 2018/06/24 12:27:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/24 16:18:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9563) Migrate integration tests for CEP - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/24 18:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9653) Add operator name to latency metrics - posted by "Julian Stephen (JIRA)" <ji...@apache.org> on 2018/06/24 23:56:00 UTC, 0 replies.
- [GitHub] flink pull request #4269: FLINK-6557 Fixing tests for RocksDB state backend ... - posted by vschafer <gi...@git.apache.org> on 2018/06/25 01:27:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-6557) RocksDBKeyedStateBackend broken on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 01:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6557) RocksDBKeyedStateBackend broken on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 01:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9653) Add operator name to latency metrics - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/25 02:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9653) Add operator name to latency metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 07:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 07:59:00 UTC, 1 replies.
- [GitHub] flink issue #6191: [FLINK-9629][metrics] Included datadog shaded dependencie... - posted by zentol <gi...@git.apache.org> on 2018/06/25 08:05:39 UTC, 0 replies.
- [GitHub] flink issue #6192: [FLINK-9567][runtime][yarn] Fix the bug that Flink does n... - posted by Clarkkkkk <gi...@git.apache.org> on 2018/06/25 08:12:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-6469) Configure Memory Sizes with units - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 08:16:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 08:26:00 UTC, 0 replies.
- [GitHub] flink issue #6179: [hotfix][docs] Removed duplicate line in windows doc page - posted by zentol <gi...@git.apache.org> on 2018/06/25 08:27:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency - posted by "blues zheng (JIRA)" <ji...@apache.org> on 2018/06/25 08:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency - posted by "blues zheng (JIRA)" <ji...@apache.org> on 2018/06/25 08:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-553) Add getGroupKey() method to group-at-time operators - posted by "Lage Ragnarsson (JIRA)" <ji...@apache.org> on 2018/06/25 08:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9222) Add a Gradle Quickstart - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 08:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2 - posted by "Viktor Vlasov (JIRA)" <ji...@apache.org> on 2018/06/25 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9654) Internal error while deserializing custom Scala TypeSerializer instances - posted by "Zsolt Donca (JIRA)" <ji...@apache.org> on 2018/06/25 10:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9654) Internal error while deserializing custom Scala TypeSerializer instances - posted by "Zsolt Donca (JIRA)" <ji...@apache.org> on 2018/06/25 10:36:00 UTC, 6 replies.
- [GitHub] flink pull request #6206: [FLINK-9654] [core] Changed the check for anonymou... - posted by zsolt-donca <gi...@git.apache.org> on 2018/06/25 10:55:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-9654) Internal error while deserializing custom Scala TypeSerializer instances - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 10:56:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9503) Migrate integration tests for iterative aggregators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/25 11:23:00 UTC, 0 replies.
- [GitHub] flink issue #6125: [FLINK-9532] Flink Overview of Jobs Documentation Incorre... - posted by yanghua <gi...@git.apache.org> on 2018/06/25 11:23:32 UTC, 3 replies.
- [jira] [Assigned] (FLINK-8379) Improve type checking for DataView - posted by "blues zheng (JIRA)" <ji...@apache.org> on 2018/06/25 11:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8954) Escape control characters when outputting on SQL Client CLI - posted by "blues zheng (JIRA)" <ji...@apache.org> on 2018/06/25 11:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6087) The file-filter is only applied to directories in ContinuousFileMonitoringFunction - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2018/06/25 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9655) Externalized checkpoint E2E test fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 13:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9655) Externalized checkpoint E2E test fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 13:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9655) Externalized checkpoint E2E test fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 13:48:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9656) Environment java opts for flink run - posted by "Jozef Vilcek (JIRA)" <ji...@apache.org> on 2018/06/25 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9657) Suspicious output from Bucketing sink E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 14:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9657) Suspicious output from Bucketing sink E2E test - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/06/25 14:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9655) Externalized checkpoint E2E test fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 14:37:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9657) Suspicious output from Bucketing sink E2E test on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 14:37:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9658) Test data output directories are no longer cleaned up - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9659) Remove hard-coded sleeps in bucketing sink E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/25 17:41:00 UTC, 0 replies.
- [GitHub] flink issue #6200: [FLINK-9641] [streaming-connectors] Flink pulsar source c... - posted by sijie <gi...@git.apache.org> on 2018/06/25 20:34:50 UTC, 0 replies.
- [GitHub] flink issue #6180: [FLINK-9524][Table API & SQL] check whether a clean-up ti... - posted by yzandrew <gi...@git.apache.org> on 2018/06/25 23:20:48 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9658) Test data output directories are no longer cleaned up - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/06/26 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9660) Allow passing custom artifacts to Mesos workers - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/26 01:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9656) Environment java opts for flink run - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/26 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9661) TTL state should support to do time shift after restoring from checkpoint( savepoint). - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/26 03:40:00 UTC, 0 replies.
- [GitHub] flink pull request #6207: [FLINK-9660] [mesos] Allow passing custom artifact... - posted by lishim <gi...@git.apache.org> on 2018/06/26 04:12:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-9660) Allow passing custom artifacts to Mesos workers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 04:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9660) Allow passing custom artifacts to Mesos workers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 04:13:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9407) Support orc rolling sink writer - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/06/26 06:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/26 07:05:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9643) Flink allowing TLS 1.1 in spite of configuring TLS 1.2 - posted by "Viktor Vlasov (JIRA)" <ji...@apache.org> on 2018/06/26 07:53:00 UTC, 3 replies.
- [GitHub] flink issue #6206: [FLINK-9654] [core] Changed the check for anonymous class... - posted by zsolt-donca <gi...@git.apache.org> on 2018/06/26 08:07:32 UTC, 0 replies.
- [jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 08:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/26 08:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/26 08:21:00 UTC, 1 replies.
- [GitHub] flink pull request #6208: Disable local recovery scheduling - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/26 08:29:15 UTC, 0 replies.
- [GitHub] flink pull request #6209: [FLINK-9655][tests] Add missing parallelism parame... - posted by zentol <gi...@git.apache.org> on 2018/06/26 08:34:05 UTC, 0 replies.
- [GitHub] flink pull request #6210: [FLINK-9659][tests] Replace hard-coded sleeps - posted by zentol <gi...@git.apache.org> on 2018/06/26 08:35:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-9659) Remove hard-coded sleeps in bucketing sink E2E test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 08:36:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9659) Remove hard-coded sleeps in bucketing sink E2E test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9662) Task manager isolation for jobs - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/26 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9663) Allow jobs to be scheduled to task managers with special tags - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/26 08:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9663) Allow jobs to be scheduled to hosts that meet requirements. - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/26 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described - posted by "Mano Swerts (JIRA)" <ji...@apache.org> on 2018/06/26 09:22:00 UTC, 0 replies.
- [GitHub] flink issue #6209: [FLINK-9655][tests] Add missing parallelism parameters - posted by zhangminglei <gi...@git.apache.org> on 2018/06/26 09:27:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/26 10:07:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/26 10:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/26 10:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/26 12:10:00 UTC, 5 replies.
- [GitHub] flink issue #6196: [FLINK-9513] Implement TTL state wrappers factory and ser... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/26 12:10:44 UTC, 1 replies.
- [GitHub] flink pull request #6208: [FLINK-9634] Disable local recovery scheduling if ... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/26 12:22:56 UTC, 15 replies.
- [jira] [Updated] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 12:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 12:23:00 UTC, 17 replies.
- [jira] [Updated] (FLINK-9557) Parse 'integer' type as BigDecimal - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/26 12:54:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9557) FlinkTypeFactory should support BigInteger type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/06/26 12:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9557) Parse 'integer' type as BigDecimal - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 12:55:00 UTC, 0 replies.
- [GitHub] flink issue #6208: [FLINK-9634] Disable local recovery scheduling if local r... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/26 13:41:56 UTC, 1 replies.
- [GitHub] flink pull request #5995: [FLINK-9337] Implemented AvroDeserializationSchema - posted by medcv <gi...@git.apache.org> on 2018/06/26 14:01:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-9337) Implement AvroDeserializationSchema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 14:02:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-9337) Implement AvroDeserializationSchema - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 14:02:01 UTC, 2 replies.
- [jira] [Commented] (FLINK-6962) SQL DDL for input and output tables - posted by "YuFeng Shen (JIRA)" <ji...@apache.org> on 2018/06/26 16:07:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9665) PrometheusReporter does not properly unregister metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/26 16:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8654) Extend quickstart docs on how to submit jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 17:23:00 UTC, 0 replies.
- [GitHub] flink issue #5996: [FLINK-9343] [Example] Add Async Example with External Re... - posted by medcv <gi...@git.apache.org> on 2018/06/26 17:26:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-9343) Add Async Example with External Rest API call - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 17:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/26 17:27:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/06/26 18:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9662) Task manager isolation for jobs - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/26 22:22:00 UTC, 9 replies.
- [jira] [Updated] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/27 04:56:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9666) short-circuit logic should be used in boolean contexts - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/06/27 07:46:00 UTC, 0 replies.
- [GitHub] flink pull request #6211: [FLINK-9665] PrometheusReporter does not properly ... - posted by jelmerk <gi...@git.apache.org> on 2018/06/27 07:49:14 UTC, 2 replies.
- [jira] [Commented] (FLINK-9665) PrometheusReporter does not properly unregister metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 07:50:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9665) PrometheusReporter does not properly unregister metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9667) Scala docs are only generated for flink-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 07:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9667) Scala docs are only generated for flink-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9668) In some case Trigger.onProcessingTime don't exectue - posted by "qi quan (JIRA)" <ji...@apache.org> on 2018/06/27 08:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9668) In some case Trigger.onProcessingTime don't exectue - posted by "qi quan (JIRA)" <ji...@apache.org> on 2018/06/27 08:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9666) short-circuit logic should be used in boolean contexts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 08:14:00 UTC, 1 replies.
- [GitHub] flink pull request #6212: [FLINK-9666] short-circuit logic should be used in... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/27 08:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9666) short-circuit logic should be used in boolean contexts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 08:14:00 UTC, 9 replies.
- [jira] [Created] (FLINK-9669) Introduce task manager assignment store - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/27 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9670) Introduce slot manager factory - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/27 08:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9671) Add configuration to enable task manager isolation. - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/06/27 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9672) Fail fatally if we cannot submit job on added JobGraph signal - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 08:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 08:47:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 08:47:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9645) DispatcherTest.testSubmittedJobGraphListener fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 08:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9667) Scala docs are only generated for flink-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 08:49:00 UTC, 0 replies.
- [GitHub] flink pull request #6213: [FLINK-9672] Fail fatally if job submission fails ... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/27 09:08:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-9672) Fail fatally if we cannot submit job on added JobGraph signal - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 09:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9672) Fail fatally if we cannot submit job on added JobGraph signal - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 09:09:00 UTC, 3 replies.
- [GitHub] flink pull request #6214: [FLINK-9669] Add assignment store interface. - posted by liurenjie1024 <gi...@git.apache.org> on 2018/06/27 09:14:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-9669) Introduce task manager assignment store - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 09:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9669) Introduce task manager assignment store - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 09:15:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9673) Improve State efficiency of bounded OVER window operators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/27 09:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9673) Improve State efficiency of bounded OVER window operators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/27 09:27:00 UTC, 0 replies.
- [GitHub] flink issue #6211: [FLINK-9665] PrometheusReporter does not properly unregis... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/27 09:30:56 UTC, 1 replies.
- [jira] [Created] (FLINK-9674) Remove 65s sleep in QueryableState E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 09:34:00 UTC, 0 replies.
- [GitHub] flink issue #6212: [FLINK-9666] short-circuit logic should be used in boolea... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/27 09:34:16 UTC, 5 replies.
- [GitHub] flink pull request #6215: [FLINK-9217][kafka-tests] Disable testTimestamps f... - posted by pnowojski <gi...@git.apache.org> on 2018/06/27 09:41:55 UTC, 3 replies.
- [jira] [Updated] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9675) Avoid FileInputStream/FileOutputStream - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/27 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/27 09:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9662) Task manager isolation for jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 09:47:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9675) Avoid FileInputStream/FileOutputStream - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/06/27 09:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/27 09:49:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-9675) Avoid FileInputStream/FileOutputStream - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/06/27 09:58:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9675) Avoid FileInputStream/FileOutputStream - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 10:02:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9674) Remove 65s sleep in QueryableState E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 10:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/06/27 10:26:00 UTC, 0 replies.
- [GitHub] flink pull request #6216: [FLINK-9674][tests] Replace hard-coded sleeps in Q... - posted by zentol <gi...@git.apache.org> on 2018/06/27 11:13:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-9674) Remove 65s sleep in QueryableState E2E test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 11:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9674) Remove 65s sleep in QueryableState E2E test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 11:14:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9665) PrometheusReporter does not properly unregister metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9677) RestClient fails for large uploads - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 11:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9677) RestClient fails for large uploads - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 11:41:00 UTC, 0 replies.
- [GitHub] flink pull request #6217: [FLINK-9677][rest] Cleanup encoder after request h... - posted by zentol <gi...@git.apache.org> on 2018/06/27 11:57:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-9677) RestClient fails for large uploads - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 11:58:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9677) RestClient fails for large uploads - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9678) Remove hard-coded sleeps in HA E2E test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 12:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 12:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9647) Files uploaded to blobservice during job submission aren't removed on failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 12:45:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 12:47:00 UTC, 0 replies.
- [GitHub] flink issue #6090: [FLINK-8863] [SQL] Add user-defined function support in S... - posted by xccui <gi...@git.apache.org> on 2018/06/27 13:09:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-9634) Deactivate previous location based scheduling if local recovery is disabled - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 13:13:00 UTC, 0 replies.
- [GitHub] flink pull request #6218: [FLINK-9444] [formats] Add full SQL support for Av... - posted by twalthr <gi...@git.apache.org> on 2018/06/27 13:39:20 UTC, 0 replies.
- [jira] [Updated] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/27 13:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9474) Add runtime support of distinct filter using ElasticBloomFilter - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/06/27 13:59:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9679) Implement AvroSerializationSchema - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/06/27 14:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/27 14:42:00 UTC, 0 replies.
- [GitHub] flink issue #6217: [FLINK-9677][rest] Cleanup encoder after request has been... - posted by zentol <gi...@git.apache.org> on 2018/06/27 16:01:09 UTC, 0 replies.
- [GitHub] flink pull request #6219: [hotfix] Fixed typo in docs - posted by elbaulp <gi...@git.apache.org> on 2018/06/27 16:18:31 UTC, 3 replies.
- [jira] [Created] (FLINK-9680) Reduce heartbeat timeout for E2E tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/27 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9681) Make sure minRetentionTime not equal to maxRetentionTime - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/27 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9682) Add setDescription to execution environment and display it in the UI - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/06/27 16:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/27 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/27 19:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/27 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/27 21:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams - posted by "Ying Xu (JIRA)" <ji...@apache.org> on 2018/06/27 21:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6222) YARN: setting environment variables in an easier fashion - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/28 04:32:00 UTC, 0 replies.
- [GitHub] flink pull request #6220: [FLINK-9677][rest] Cleanup encoder after request h... - posted by zentol <gi...@git.apache.org> on 2018/06/28 07:01:56 UTC, 0 replies.
- [GitHub] flink issue #6220: [FLINK-9677][rest] Cleanup encoder after request has been... - posted by zentol <gi...@git.apache.org> on 2018/06/28 07:03:43 UTC, 0 replies.
- [jira] [Created] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole - posted by "Franz Thoma (JIRA)" <ji...@apache.org> on 2018/06/28 07:21:00 UTC, 0 replies.
- [GitHub] flink pull request #6221: [FLINK-9686] [kinesis] Enable Kinesis authenticati... - posted by fmthoma <gi...@git.apache.org> on 2018/06/28 07:42:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/28 07:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/28 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6222) YARN: setting environment variables in an easier fashion - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/28 07:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/28 07:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9560) RateLimiting for FileSystem - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/28 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9687) Delay the state fetch only when the triggerResult is fire - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/28 08:43:00 UTC, 0 replies.
- [GitHub] flink pull request #6222: [FLINK-8785][rest] Handle JobSubmissionExceptions - posted by zentol <gi...@git.apache.org> on 2018/06/28 09:02:56 UTC, 5 replies.
- [jira] [Closed] (FLINK-9629) Datadog metrics reporter does not have shaded dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/28 09:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/28 09:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9688) ATAN2 Sql Function support - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/28 09:19:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9688) ATAN2 Sql Function support - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/28 09:19:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9682) Add setDescription to execution environment and display it in the UI - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/28 09:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9688) ATAN2 Sql Function support - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/28 09:41:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-9624) Move jar/artifact upload logic out of JobGraph - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/28 10:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9666) short-circuit logic should be used in boolean contexts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/28 11:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9666) short-circuit logic should be used in boolean contexts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/28 11:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9687) Delay the state fetch only when the triggerResult is fire - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/06/28 13:01:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-9687) Delay the state fetch only when the triggerResult is fire - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/28 14:03:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster - posted by "Ethan Li (JIRA)" <ji...@apache.org> on 2018/06/28 15:46:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8745) Reduce travis usage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/06/28 15:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8983) End-to-end test: Confluent schema registry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/28 16:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9456) Let ResourceManager notify JobManager about failed/killed TaskManagers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/28 16:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9689) Flink consumer deserialization example - posted by "Satheesh (JIRA)" <ji...@apache.org> on 2018/06/28 16:56:01 UTC, 0 replies.
- [GitHub] flink pull request #6226: [FLINK-8650] Tests for WINDOW clause and documenta... - posted by snuyanzin <gi...@git.apache.org> on 2018/06/28 17:35:22 UTC, 9 replies.
- [jira] [Updated] (FLINK-8650) Add tests and documentation for WINDOW clause - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/28 17:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/06/28 18:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/28 19:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/06/28 21:51:00 UTC, 0 replies.
- [GitHub] flink issue #6224: [FLINK-9687]Delay the state fetch only when the triggerRe... - posted by Aitozi <gi...@git.apache.org> on 2018/06/28 23:31:50 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7588) Document RocksDB tuning for spinning disks - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/29 02:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9393) LocatableInputSplit#hashCode should take hostnames into account - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/29 02:59:00 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/29 03:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9640) Checkpointing is aways aborted if any task has been finished - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/06/29 03:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5440: [FLINK-6160] [flip-6] Retry JobManager/ResourceMan... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/29 06:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 06:04:00 UTC, 0 replies.
- [GitHub] flink issue #6201: [FLINK-8866][Table API & SQL] Add support for unified tab... - posted by suez1224 <gi...@git.apache.org> on 2018/06/29 06:41:10 UTC, 2 replies.
- [GitHub] flink pull request #6227: Heap abstractions rocks - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/29 08:47:15 UTC, 0 replies.
- [GitHub] flink pull request #6227: [FLINK-9491] Implement timer data structure based ... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/29 08:49:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-9491) Implement timer data structure based on RocksDB - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 08:50:00 UTC, 12 replies.
- [jira] [Commented] (FLINK-9689) Flink consumer deserialization example - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/06/29 08:51:00 UTC, 0 replies.
- [GitHub] flink pull request #6228: [FLINK-9491] Implement timer data structure based ... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/29 08:54:47 UTC, 9 replies.
- [GitHub] flink issue #6228: [FLINK-9491] Implement timer data structure based on Rock... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/29 08:55:36 UTC, 1 replies.
- [GitHub] flink issue #6210: [FLINK-9659][tests] Replace hard-coded sleeps - posted by twalthr <gi...@git.apache.org> on 2018/06/29 10:28:47 UTC, 1 replies.
- [GitHub] flink pull request #6102: [FLINK-9091][build] Dependency convergence run aga... - posted by twalthr <gi...@git.apache.org> on 2018/06/29 11:54:05 UTC, 3 replies.
- [jira] [Updated] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 11:54:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-9515) Create wrapper with TTL logic for list state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/29 12:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9516) Create wrapper with TTL logic for map state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/29 12:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9514) Create wrapper with TTL logic for value state - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/29 12:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/06/29 12:36:00 UTC, 0 replies.
- [GitHub] flink issue #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen sockets ... - posted by azagrebin <gi...@git.apache.org> on 2018/06/29 12:39:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 12:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 12:40:00 UTC, 3 replies.
- [GitHub] flink pull request #6229: [docs]Replaced deprecated `high-availability.stora... - posted by satybald <gi...@git.apache.org> on 2018/06/29 13:35:19 UTC, 0 replies.
- [GitHub] flink issue #5799: [FLINK-7775] Remove unreferenced method PermanentBlobCach... - posted by StefanRRichter <gi...@git.apache.org> on 2018/06/29 14:02:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 14:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/29 14:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/06/29 14:07:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/06/29 14:17:00 UTC, 0 replies.
- [GitHub] flink issue #6213: [FLINK-9672] Fail fatally if job submission fails on adde... - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/29 15:38:48 UTC, 0 replies.
- [jira] [Assigned] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams - posted by "Mingdao Yang (JIRA)" <ji...@apache.org> on 2018/06/29 16:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9627) Extending 'KafkaJsonTableSource' according to comments will result in NPE - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/06/29 16:55:00 UTC, 0 replies.
- [GitHub] flink issue #6226: [FLINK-8650] Tests for WINDOW clause and documentation up... - posted by snuyanzin <gi...@git.apache.org> on 2018/06/29 17:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/06/29 20:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/06/29 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/06/29 23:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/06/29 23:37:00 UTC, 6 replies.
- [GitHub] flink pull request #6230: [FLINK-9666] short-circuit logic should be used in... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/30 02:26:57 UTC, 1 replies.
- [GitHub] flink issue #6230: [FLINK-9666] short-circuit logic should be used in boolea... - posted by lamber-ken <gi...@git.apache.org> on 2018/06/30 02:32:24 UTC, 0 replies.
- [jira] [Updated] (FLINK-9681) Make sure minRetentionTime not equal to maxRetentionTime - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/06/30 03:24:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9672) Fail fatally if we cannot submit job on added JobGraph signal - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9694) potentially NPE in CompositeTypeSerializerConfigSnapshot constructor - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/30 06:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9694) Potentially NPE in CompositeTypeSerializerConfigSnapshot constructor - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/06/30 06:30:00 UTC, 2 replies.
- [GitHub] flink pull request #6231: [FLINK-9694] Potentially NPE in CompositeTypeSeria... - posted by yanghua <gi...@git.apache.org> on 2018/06/30 06:40:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-9694) Potentially NPE in CompositeTypeSerializerConfigSnapshot constructor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/30 06:41:00 UTC, 2 replies.
- [GitHub] flink issue #6231: [FLINK-9694] Potentially NPE in CompositeTypeSerializerCo... - posted by zhangminglei <gi...@git.apache.org> on 2018/06/30 07:43:35 UTC, 1 replies.
- [GitHub] flink issue #6229: [docs] Replaced deprecated `high-availability.storageDir`... - posted by yanghua <gi...@git.apache.org> on 2018/06/30 07:53:26 UTC, 0 replies.
- [GitHub] flink issue #6204: [FLINK-4301][docs] add version for quickstart script - posted by yanghua <gi...@git.apache.org> on 2018/06/30 09:22:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-7593) Generated plan does not create correct groups - posted by "Chunhui Shi (JIRA)" <ji...@apache.org> on 2018/06/30 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images - posted by "Leonid Ishimnikov (JIRA)" <ji...@apache.org> on 2018/06/30 15:00:00 UTC, 0 replies.
- [GitHub] flink pull request #6232: [FLINK-9695] [mesos] Add option for Mesos executor... - posted by lishim <gi...@git.apache.org> on 2018/06/30 15:39:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/30 15:40:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/30 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9696) Deep toString for arrays/map in SQL client - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/30 16:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9696) Deep toString for arrays/map in SQL client - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/06/30 16:16:00 UTC, 1 replies.
- [GitHub] flink pull request #6233: [FLINK-9696] Deep toString for array/map sql types - posted by snuyanzin <gi...@git.apache.org> on 2018/06/30 16:45:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-9696) Deep toString for arrays/map in SQL client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/30 16:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 17:56:00 UTC, 0 replies.
- [GitHub] flink issue #6214: [FLINK-9669] Add assignment store interface. - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/30 18:08:28 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 20:05:01 UTC, 0 replies.
- [GitHub] flink pull request #6229: [docs] Replaced deprecated `high-availability.stor... - posted by asfgit <gi...@git.apache.org> on 2018/06/30 20:15:59 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 20:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 20:36:00 UTC, 0 replies.
- [GitHub] flink pull request #6225: [FLINK-9684][historyserver] HistoryServer should i... - posted by asfgit <gi...@git.apache.org> on 2018/06/30 20:36:30 UTC, 0 replies.
- [jira] [Updated] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/06/30 20:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 21:00:00 UTC, 0 replies.
- [GitHub] flink issue #6219: [hotfix] Fixed typo in docs - posted by tillrohrmann <gi...@git.apache.org> on 2018/06/30 21:07:58 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9660) Allow passing custom artifacts to Mesos workers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 21:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9660) Allow passing custom artifacts to Mesos workers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 21:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/06/30 21:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9697) Provide connector for Kafka 2.0.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/06/30 22:00:00 UTC, 0 replies.