dev@flink.apache.org, 2018-05

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

- [jira] [Created] (FLINK-9280) Extend JobSubmitHandler to accept jar files - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/01 08:43:00 UTC, 0 replies.
- ApacheCon North America 2018 schedule is now live. - posted by Rich Bowen <rb...@apache.org> on 2018/05/01 12:36:05 UTC, 0 replies.
- Re: request for contributor permission - posted by Steven Wu <st...@gmail.com> on 2018/05/01 20:46:30 UTC, 1 replies.
- [jira] [Created] (FLINK-9281) LogBack not working - posted by "Tim (JIRA)" <ji...@apache.org> on 2018/05/01 23:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9282) Update quickstart page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/02 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9283) Update cluster execution docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/02 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9284) Update CLI page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/02 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9285) Update REST API page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/02 08:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9286) Upadte classloading debugging page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/02 08:56:00 UTC, 0 replies.
- Re: Introduction - posted by Fabian Hueske <fh...@gmail.com> on 2018/05/02 09:49:09 UTC, 1 replies.
- [jira] [Created] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode - posted by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/05/02 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9288) clarify a few points in the event time / watermark docs - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2018/05/02 11:49:00 UTC, 0 replies.
- Re: [Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink - posted by Fabian Hueske <fh...@gmail.com> on 2018/05/02 12:36:44 UTC, 8 replies.
- [jira] [Created] (FLINK-9289) Parallelism of generated operators should have max parallism of input - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/05/02 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9290) The job is unable to recover from a checkpoint - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/05/02 15:03:00 UTC, 0 replies.
- Flink consuming more memory than expected - posted by Gabriel Pelielo <ga...@hotmail.com> on 2018/05/02 21:20:12 UTC, 3 replies.
- [jira] [Created] (FLINK-9291) Checkpoint failure (CIRCULAR REFERENCE:java.lang.NegativeArraySizeException) - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/05/03 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9292) Remove TypeInfoParser - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/03 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9293) SlotPool should check slot id when accepting a slot offer with existing allocation id - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/05/03 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/05/03 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode - posted by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/05/03 16:25:00 UTC, 0 replies.
- Confusing error message in MemCheckpointStreamFactory with large state size? - posted by Ken Krugler <kk...@transpac.com> on 2018/05/04 02:56:07 UTC, 3 replies.
- [jira] [Created] (FLINK-9296) Support distinct aggregation on non-windowed grouped streaming tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/05/04 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9297) Make size of JobManager's ioExecutor configurable - posted by "Jelmer Kuperus (JIRA)" <ji...@apache.org> on 2018/05/04 15:14:00 UTC, 0 replies.
- Support more intelligent function lookup in FunctionCatalog for UDF - posted by Rong Rong <wa...@gmail.com> on 2018/05/04 18:09:34 UTC, 5 replies.
- [jira] [Created] (FLINK-9298) setup_quickstart hanging - posted by "Alex Chen (JIRA)" <ji...@apache.org> on 2018/05/04 20:44:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2018/05/04 22:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9300) Improve error message when in-memory state is too large - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2018/05/04 22:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9301) NotSoMiniClusterIterations job fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/05 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9302) Checkpoints continues to fail when using filesystem state backend with CIRCULAR REFERENCE:java.io.IOException - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/05/05 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/05/07 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9304) Timer service shutdown should not be interrupted - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/07 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9305) Register flink-s3-fs-* for the s3a:// scheme as well - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/05/07 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9306) Execute YARN IT tests for legacy and new mode - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/05/07 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9307) Running flink program doesn't print infos in console any more - posted by "Alex Chen (JIRA)" <ji...@apache.org> on 2018/05/07 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9308) The method enableCheckpointing with low values like 10 are forming DoS on Kafka Clusters - posted by "Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org> on 2018/05/07 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9309) Recommend HA setup on Production Readiness Checklist - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/05/07 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9310) Update default cyphersuites - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/07 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9311) PubSub connector - posted by "Richard Deurwaarder (JIRA)" <ji...@apache.org> on 2018/05/07 18:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9312) Perform mutual authentication during SSL handshakes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/07 19:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9313) Enable mutual authentication for RPC (akka) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/07 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9314) Enable SSL mutual authentication for Netty / TaskManagers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/07 20:00:00 UTC, 0 replies.
- [HA] Is it possible to remove external dependency caused by high-availability.zookeeper.storageDir - posted by Hao Chen <cn...@gmail.com> on 2018/05/08 02:31:50 UTC, 1 replies.
- [jira] [Created] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2018/05/08 02:55:00 UTC, 0 replies.
- Request for contributor permission - posted by blues zheng <ki...@163.com> on 2018/05/08 03:56:45 UTC, 2 replies.
- [jira] [Created] (FLINK-9316) Expose operator unique ID to the DataStream operators. - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/05/08 15:46:00 UTC, 0 replies.
- [ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber - posted by Fabian Hueske <fh...@gmail.com> on 2018/05/08 18:52:52 UTC, 13 replies.
- [jira] [Created] (FLINK-9317) Async I/O API Example For Scala has Variable Name error - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/05/09 05:29:00 UTC, 0 replies.
- 回复：[ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2018/05/09 06:06:06 UTC, 0 replies.
- [jira] [Created] (FLINK-9318) Mark ConfigOptionsDocsCompletenessTest as IT case - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/09 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9319) Move some flink-docs dependencies into profiles - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/09 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9320) Update `test-ha.sh` end-to-end test to use general purpose DataStream job - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/05/09 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9321) Rename SubtasksAllAccumulatorsHandlers - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/09 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9322) Add exception throwing map function that simulates failures to the general purpose DataStream job - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/05/09 09:34:00 UTC, 0 replies.
- Version Compatibility of Flink-1.4.2 with Zookeeper-3.4.11 - posted by Stalin Jeyaraj <st...@ekaplus.com> on 2018/05/09 10:14:33 UTC, 0 replies.
- [jira] [Created] (FLINK-9323) Move checkstyle configuration - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/09 11:14:00 UTC, 0 replies.
- Re: Version Compatibility of Flink-1.4.2 with Zookeeper-3.4.11 - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/09 11:50:48 UTC, 0 replies.
- [jira] [Created] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/09 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9325) generate the _meta file only when the writing is totally successful - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/09 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode - posted by "Samuel Doyle (JIRA)" <ji...@apache.org> on 2018/05/09 18:41:00 UTC, 0 replies.
- Flink Memory Usage - posted by Pedro Elias <pe...@poli.ufrj.br> on 2018/05/09 19:12:10 UTC, 0 replies.
- [jira] [Created] (FLINK-9327) Support explicit ROW value constructor in Flink SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/05/09 21:29:00 UTC, 0 replies.
- [Discuss] FLIP-26 - SSL Mutual Authentication - posted by Eron Wright <er...@gmail.com> on 2018/05/10 00:30:38 UTC, 2 replies.
- KPL in current stable 1.4.2 and below, upcoming problem - posted by Dyana Rose <dy...@salecycle.com> on 2018/05/10 08:35:11 UTC, 1 replies.
- [jira] [Created] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2018/05/10 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/05/10 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9330) Improve logging of SlotPool for debugging purposes - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/10 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9331) MesosResourceManager sometimes does not request new Containers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/10 13:17:00 UTC, 0 replies.
- [VOTE] Release 1.5.0, release candidate #2 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/10 16:37:05 UTC, 10 replies.
- [jira] [Created] (FLINK-9332) Fix Codegen error of CallGenerator - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/05/11 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9333) QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/05/11 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/05/11 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9335) Expose client logs via Flink UI - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/05/11 08:30:00 UTC, 0 replies.
- REMINDER: Apache EU Roadshow 2018 schedule announced! - posted by sh...@apache.org on 2018/05/11 12:13:36 UTC, 0 replies.
- [jira] [Created] (FLINK-9336) Queryable state fails with Exception after task manager restore - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/05/11 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9337) Implement AvroDeserializationSchema - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/05/11 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9338) Implement RegistryAvroDeserializationSchema - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/05/11 16:55:00 UTC, 0 replies.
- Re: [DISCUSS] Service Authorization (redux) - posted by Stephan Ewen <se...@apache.org> on 2018/05/11 18:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-9339) Accumulators are not UI accessible running in FLIP-6 mode - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2018/05/11 18:18:00 UTC, 0 replies.
- [DISCUSS] Configuration for local recovery - posted by Stephan Ewen <se...@apache.org> on 2018/05/11 18:41:07 UTC, 4 replies.
- [jira] [Created] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/05/11 20:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9341) Oracle: "Type is not supported: Date" - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2018/05/11 21:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9342) conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/05/12 01:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9343) Add Async Example with External Rest API call - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/05/12 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9344) Support INTERSECT and INTERSECT ALL for streaming - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/05/12 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9345) Support EXCEPT and EXCEPT ALL for streaming - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/05/12 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9346) Update documents for supporting intersect/except in streaming - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/05/12 15:13:00 UTC, 0 replies.
- Elasticsearch Sink - posted by Christophe Jolif <cj...@gmail.com> on 2018/05/12 16:14:23 UTC, 10 replies.
- [jira] [Created] (FLINK-9347) BlobServerConnection throws misleading exception for empty files - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/12 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9348) scalastyle documentatiom for IntelliJ IDE setup - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/05/12 21:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9349) KafkaConnector Exception while fetching from multiple kafka topics - posted by "Vishal Santoshi (JIRA)" <ji...@apache.org> on 2018/05/13 14:50:00 UTC, 0 replies.
- request for JIRA contributor permissions - posted by Yaz Sh <ya...@gmail.com> on 2018/05/13 16:25:07 UTC, 2 replies.
- [jira] [Created] (FLINK-9350) Parameter baseInterval has wrong check message in CheckpointCoordinator constructor - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/05/14 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9351) RM stop assigning slot to Job because the TM killed before connecting to JM successfully - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/14 05:41:00 UTC, 0 replies.
- [DISCUSS] Adding new interfaces in [Stream]ExecutionEnvironment - posted by Shuyi Chen <su...@gmail.com> on 2018/05/14 06:14:33 UTC, 9 replies.
- [jira] [Created] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/05/14 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9353) End-to-end test: Kubernetes integration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/05/14 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9354) print execution times for end-to-end tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/14 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9355) Simplify configuration of local recovery to a simple on/off - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/14 09:22:00 UTC, 0 replies.
- Closing (automatically?) inactive pull requests - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/05/14 10:04:43 UTC, 14 replies.
- [jira] [Created] (FLINK-9356) Improve error message for when queryable state not ready / reachable - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/05/14 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9357) Add margins to yarn exception excerpts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/14 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9358) Closing of unestablished RM connections can cause NPE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/14 11:03:00 UTC, 0 replies.
- Rewriting a new file instead of writing a ".valid-length" file in BucketSink when restoring - posted by 张馨予 <34...@qq.com> on 2018/05/14 11:37:24 UTC, 3 replies.
- [jira] [Created] (FLINK-9359) Update quickstart docs to only mention Java 8 - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2018/05/14 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9360) HA end-to-end nightly test takes more than 15 min in Travis CI - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/05/14 12:50:00 UTC, 0 replies.
- Snapshots and RC-candidate maven artifacts - posted by Flavio Pompermaier <po...@okkam.it> on 2018/05/14 13:51:08 UTC, 3 replies.
- [jira] [Created] (FLINK-9361) Changing refresh interval in changelog mode leads to exception - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/05/14 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9362) Document that Flink doesn't guarantee transaction of modifying state and register timers in processElement() - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/05/14 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9363) Bump up the Jackson version - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/05/14 23:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9364) Add doc for the memory usage in flink - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/15 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9365) Add version information to remote rpc messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/15 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9366) Distribute Cache only works for client-accessible files - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/15 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9367) Truncate() in BucketingSink is only allowed after hadoop2.7 - posted by "zhangxinyu (JIRA)" <ji...@apache.org> on 2018/05/15 11:22:00 UTC, 0 replies.
- 回复： Rewriting a new file instead of writing a ".valid-length" file inBucketSink when restoring - posted by Xinyu Zhang <34...@qq.com> on 2018/05/15 12:01:55 UTC, 3 replies.
- [jira] [Created] (FLINK-9368) End-to-end test: Python API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/15 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9369) DistributedCache returns parent directory for directories - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/15 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9370) Activate distributed cache end-to-end test - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/15 13:00:03 UTC, 0 replies.
- 回复：回复： Rewriting a new file instead of writing a ".valid-length" file inBucketSink when restoring - posted by Xinyu Zhang <34...@qq.com> on 2018/05/15 13:05:18 UTC, 0 replies.
- [VOTE] Release 1.5.0, release candidate #3 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/15 15:32:57 UTC, 4 replies.
- [jira] [Created] (FLINK-9371) High Availability JobManager Registration Failure - posted by "Jason Kania (JIRA)" <ji...@apache.org> on 2018/05/15 19:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9372) Typo on Elasticsearch website link (elastic.io --> elastic.co) - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/05/15 22:03:00 UTC, 0 replies.
- Re: Rewriting a new file instead of writing a ".valid-length" file inBucketSink when restoring - posted by Xinyu Zhang <ws...@foxmail.com> on 2018/05/16 02:41:46 UTC, 0 replies.
- [jira] [Created] (FLINK-9373) Always call RocksIterator.status() to check the internal error of RocksDB - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/16 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9374) Flink Kinesis Producer does not backpressure - posted by "Franz Thoma (JIRA)" <ji...@apache.org> on 2018/05/16 07:56:00 UTC, 0 replies.
- CloudWatch Metrics Reporter - posted by Rafi Aroch <ra...@gmail.com> on 2018/05/16 08:12:20 UTC, 3 replies.
- [jira] [Created] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/16 08:27:00 UTC, 0 replies.
- [DISCUSS] Drop "canEqual" from TypeInformation, TypeSerializer, etc. - posted by Stephan Ewen <se...@apache.org> on 2018/05/16 08:35:23 UTC, 4 replies.
- [jira] [Created] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution) - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/05/16 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/05/16 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9378) Improve TableException message with TypeName usage - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/05/16 09:53:00 UTC, 0 replies.
- [DISCUSS] GitBox - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/16 10:40:19 UTC, 17 replies.
- [jira] [Created] (FLINK-9379) HA end-to-end test failing locally - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/16 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9380) Failing end-to-end tests should not clean up logs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/16 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9381) BlobServer data for a job is not getting cleaned up at JM - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/05/16 12:10:00 UTC, 0 replies.
- Re: Errors checkpointing to S3 for high-scale jobs - posted by Stephan Ewen <se...@apache.org> on 2018/05/16 12:26:16 UTC, 0 replies.
- [jira] [Created] (FLINK-9382) Inconsistent file storage behavior in FileCache - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/16 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9383) Extend DistributedCache E2E test to cover directories - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/05/16 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9384) KafkaAvroTableSource failed to work due to type mismatch - posted by "Jun Zhang (JIRA)" <ji...@apache.org> on 2018/05/16 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9385) Operators with two inputs should show "Records Received" in Web UI separately, rather than added together - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/05/16 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9386) Remove netty-router dependency - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/05/16 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9387) Several log message errors in queryable-state module - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/05/17 07:31:00 UTC, 0 replies.
- Field Grouping in Flink - posted by Garvit Sharma <ga...@gmail.com> on 2018/05/17 08:04:04 UTC, 1 replies.
- [jira] [Created] (FLINK-9388) Inconsistency in job shutdown produces confusing log message - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/17 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9389) Improve error message when cancelling job in state canceled via REST API - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/05/17 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/17 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9391) Support UNNEST in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/05/17 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9392) Add @FunctionalInterface annotations to all core functional interfaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/17 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9393) LocatableInputSplit#hashCode should take hostnames into account - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/05/17 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/05/17 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9395) multiple left outer joins to subqueries with array values fail - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2018/05/17 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9396) Allow streaming sources (especially Files, Kafka) to set max queued input elements - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/05/17 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9397) Individual Buffer Timeout of 0 incorrectly leads to default timeout - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/17 18:05:00 UTC, 0 replies.
- [VOTE] Release 1.5.0, release candidate #4 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/18 00:50:51 UTC, 12 replies.
- [jira] [Created] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/05/18 01:44:00 UTC, 0 replies.
- [NOTE] Tracking release notes in the documentation - posted by Fabian Hueske <fh...@gmail.com> on 2018/05/18 09:39:23 UTC, 0 replies.
- [jira] [Created] (FLINK-9399) TPCHQuery3 fails due to Serialization issues - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/05/18 15:23:00 UTC, 0 replies.
- Flink Forward Berlin 2018 - Call for Presentations open until 4th June - posted by Fabian Hueske <fh...@gmail.com> on 2018/05/18 15:25:05 UTC, 0 replies.
- [jira] [Created] (FLINK-9400) change import statement for flink-scala - posted by "thinkerou (JIRA)" <ji...@apache.org> on 2018/05/18 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9401) Data lost when rescaling the job from incremental checkpoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/19 00:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9402) Kinesis consumer validation incorrectly requires aws.region property - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/05/19 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9403) Documentation continues to refer to removed methods - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/05/20 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9404) Adapter viewfs in BucketingSink when verify that truncate actually works - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2018/05/21 05:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9405) On Yarn, History server does not report jobs affected by cluster cancellation. - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/05/21 19:13:00 UTC, 0 replies.
- Increasing Disk Read Throughput and IOPS - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2018/05/22 06:12:26 UTC, 5 replies.
- [VOTE] Enable GitBox integration - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/22 07:32:12 UTC, 1 replies.
- [CANCELED][VOTE] Enable GitBox integration - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/22 08:09:12 UTC, 0 replies.
- [VOTE] Enable GitBox integration (#2) - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/22 08:12:20 UTC, 13 replies.
- [jira] [Created] (FLINK-9406) Request finished partition state fails due to referential equality comparison - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/22 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9407) Support orc rolling sink writer - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/05/22 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9408) Retry JM-RM connection in case of explicit disconnect - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/22 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9409) Missing assembly-dependencies in flink-dist/pom.xml - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/05/22 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9410) Replace NMClient with NMClientAsync in YarnResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/22 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9411) Support parquet rolling sink writer - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/05/22 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9412) Add a REST-based SQL Client Gateway - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/05/22 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/22 23:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9414) Remove jline-terminal and jline-reader from LICENSE file - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/22 23:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/05/23 01:12:00 UTC, 0 replies.
- [VOTE] Release 1.5.0, release candidate #5 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/23 01:18:17 UTC, 11 replies.
- [jira] [Created] (FLINK-9416) Make job submission retriable operation in case of a ongoing leader election - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/23 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9417) Send heartbeat requests from RPC endpoint's main thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/23 07:25:00 UTC, 0 replies.
- [PROPOSAL] Introduce Elastic Bloom Filter For Flink - posted by sihua zhou <su...@163.com> on 2018/05/23 07:56:33 UTC, 6 replies.
- [jira] [Created] (FLINK-9418) Migrate SharedBuffer to use MapState - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/05/23 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9419) UNION should not be treated as retraction producing operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/05/23 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9420) Add tests for SQL IN sub-query operator in streaming - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/05/23 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/23 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/05/23 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9423) Implement efficient deletes for heap based timer service - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/23 13:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-9424) BlobClientSslTest does not work in all environments - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/05/23 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9425) Make release scripts compliant with ASF release policy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/23 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9426) Harden RocksDBWriteBatchPerformanceTest.benchMark() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/23 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown. - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/05/23 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/05/23 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9429) Quickstart E2E not working locally - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/23 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/05/24 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9431) Introduce TimeEnd State to flink cep - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/05/24 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9432) Support extract epoch, decade, millisecond, microsecond - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/05/24 11:11:00 UTC, 0 replies.
- Merging PR to release branches during RC voting - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/05/24 12:24:23 UTC, 3 replies.
- [jira] [Created] (FLINK-9433) SystemProcessingTimeService does not work properly - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/05/24 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9434) Test instability in YARNSessionCapacitySchedulerITCase# - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/05/24 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in KeySelectorUtil#ComparableKeySelector - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/05/24 15:27:00 UTC, 0 replies.
- Flink 1.5 - Job fails to execute in multiple taskmanagers (parallelism > 1) - posted by Edward Rojas <ed...@gmail.com> on 2018/05/24 16:21:20 UTC, 6 replies.
- [VOTE] Release 1.5.0, release candidate #6 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/24 16:51:06 UTC, 8 replies.
- [jira] [Created] (FLINK-9436) Remove generic parameter namespace from InternalTimeServiceManager - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/05/25 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9437) Revert cypher suite update - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/25 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/05/25 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9439) DispatcherTest#testJobRecovery dead locks - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/05/25 12:04:01 UTC, 0 replies.
- [PROPOSAL] Improving Flink’s timer management for large state - posted by Stefan Richter <s....@data-artisans.com> on 2018/05/25 14:13:00 UTC, 6 replies.
- [RESULT] [VOTE] Release 1.5.0, release candidate #6 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/25 15:56:42 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.5.0 release - posted by Till Rohrmann <tr...@apache.org> on 2018/05/25 16:46:28 UTC, 3 replies.
- [jira] [Created] (FLINK-9440) Allow cancelation and reset of timers - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/05/25 21:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9441) Hadoop Required Dependency List Not Clear - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/05/26 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9442) Flink Scaling not working - posted by "Yow Siew Wai (JIRA)" <ji...@apache.org> on 2018/05/26 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9443) Remove unused parameter in StreamGraphHasherV2 - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/05/26 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9444) KafkaAvroTableSource failed to work for map fields - posted by "Jun Zhang (JIRA)" <ji...@apache.org> on 2018/05/26 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9445) start-scala-shell.sh fails on macOS when Java 9 & 10 are installed - posted by "Andrew Janke (JIRA)" <ji...@apache.org> on 2018/05/26 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9446) Compatibility table not up-to-date - posted by "Razvan (JIRA)" <ji...@apache.org> on 2018/05/26 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9447) "sensible" vs. "sensitive" in Code Contribution Process - posted by "Andrew Janke (JIRA)" <ji...@apache.org> on 2018/05/26 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9448) contribute-code.html references Hadoop 1.x support - posted by "Andrew Janke (JIRA)" <ji...@apache.org> on 2018/05/26 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9449) `mvn clean` fails on macOS 10.13 - posted by "Andrew Janke (JIRA)" <ji...@apache.org> on 2018/05/26 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9450) Job hangs if S3 access it denied during checkpoints - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/05/27 05:12:00 UTC, 0 replies.
- [RESULT][VOTE] Enable GitBox integration (#2) - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/27 10:07:12 UTC, 0 replies.
- [jira] [Created] (FLINK-9451) End-to-end test: Scala Quickstarts - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/05/27 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9452) Flink 1.5 document version title shows snapshot - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/05/28 04:59:00 UTC, 0 replies.
- [ANNOUNCE] Final Reminder - Call for Presentations - Flink Forward Berlin 2018 - posted by Fabian Hueske <fh...@gmail.com> on 2018/05/28 13:58:09 UTC, 0 replies.
- [jira] [Created] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI - posted by "Andrei Shumanski (JIRA)" <ji...@apache.org> on 2018/05/28 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9454) Build instructions for MapR do not work - posted by "Andrei Shumanski (JIRA)" <ji...@apache.org> on 2018/05/28 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/28 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9456) Let ResourceManager notify JobManager about failed/killed TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/28 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9457) Cancel container requests when cancelling pending slot allocations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/28 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9458) Unable to recover from job failure on YARN with NPE - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/05/29 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/05/29 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9460) Redundant output in table & upsert semantics - posted by "zhengcanbin (JIRA)" <ji...@apache.org> on 2018/05/29 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/29 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9462) Disentangle flink-json and flink-table - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/29 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9463) Setting taskmanager.network.netty.transport to epoll - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/05/29 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9464) Clean up pom files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/29 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9465) Separate timeout for savepoint and checkpoint - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/05/29 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9466) LocalRecoveryRocksDBFullITCase failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/29 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9467) No Watermark display on Web UI - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/05/29 11:29:00 UTC, 0 replies.
- Pull request failing Travis IO test for unknown reason - posted by jp...@gmail.com, jp...@gmail.com on 2018/05/29 12:18:47 UTC, 4 replies.
- [jira] [Created] (FLINK-9468) get outputLimit of LimitedConnectionsFileSystem incorrectly - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/29 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9469) Add tests that cover PatternStream#flatSelect - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/05/29 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9470) Allow querying the key in KeyedProcessFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/05/29 14:46:00 UTC, 0 replies.
- Re: [jira] [Commented] (FLINK-8353) Add support for timezones - posted by Kaibo Zhou <zk...@gmail.com> on 2018/05/29 16:15:37 UTC, 0 replies.
- [jira] [Created] (FLINK-9471) Job ending exceptions being logged at Info level - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/05/29 19:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9472) Maven archetype code has typo in documentation - posted by "Alexey Tsitkin (JIRA)" <ji...@apache.org> on 2018/05/29 20:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9473) Compilation fails after upgrade to Calcite 1.17 - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/05/30 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9474) Introduce an approximate version of "count distinct" - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/30 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9475) introduce an approximate version of "select distinct" - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/30 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/05/30 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/05/30 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9478) Use Yarn application proxy to communicate with Flink cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/05/30 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9479) Let the rescale API to use local recovery - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/30 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9480) Let local recovery support rescaling - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/05/30 08:29:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 4.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/30 11:33:30 UTC, 3 replies.
- [ANNOUNCE] Weekly community update #22 - posted by Till Rohrmann <tr...@apache.org> on 2018/05/30 11:35:32 UTC, 0 replies.
- [CANCELED][VOTE] Release flink-shaded 4.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/30 12:14:33 UTC, 0 replies.
- [VOTE] Release flink-shaded 4.0, release candidate #2 - posted by Chesnay Schepler <ch...@apache.org> on 2018/05/30 13:51:12 UTC, 3 replies.
- Failure restarting Flink 1.5.0 job from checkpoint - posted by Ken Krugler <kk...@transpac.com> on 2018/05/30 23:46:34 UTC, 2 replies.
- [jira] [Created] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/05/31 08:55:00 UTC, 0 replies.
- [SQL] [CALCITE] not applicable function for TIME - posted by Viktor Vlasov <vi...@gmail.com> on 2018/05/31 13:53:13 UTC, 4 replies.
- [jira] [Created] (FLINK-9482) Not applicable functions for TIME - posted by "Viktor Vlasov (JIRA)" <ji...@apache.org> on 2018/05/31 14:21:00 UTC, 0 replies.
- REMINDER: Apache EU Roadshow 2018 in Berlin is less than 2 weeks away! - posted by sh...@apache.org on 2018/05/31 20:51:47 UTC, 0 replies.
- [jira] [Created] (FLINK-9483) "Building Flink" doc doesn't highlight quick build command - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/05/31 23:15:00 UTC, 0 replies.