dev@flink.apache.org, 2018-09

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

- [jira] [Created] (FLINK-10277) Add AppendStreamTableSink and UpsertStreamTableSink - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/09/03 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10278) Flink in YARN cluster uses wrong path when looking for Kerberos Keytab - posted by "Ben La Monica (JIRA)" <ji...@apache.org> on 2018/09/03 18:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10279) Better clarification for status - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/09/03 22:20:00 UTC, 0 replies.
- Cancel flink job occur exception. - posted by "devinduan (段丁瑞)" <de...@tencent.com> on 2018/09/04 10:22:05 UTC, 5 replies.
- Cancel flink job occur exception - posted by "devinduan (段丁瑞)" <de...@tencent.com> on 2018/09/04 12:12:25 UTC, 1 replies.
- Flink1.6.0 submit job and got "No content to map due to end-of-input" Error - posted by ? ?? <pa...@hotmail.com> on 2018/09/04 14:06:46 UTC, 1 replies.
- [jira] [Created] (FLINK-10280) json that contains an object can not be parse - posted by "sean.miao (JIRA)" <ji...@apache.org> on 2018/09/05 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10281) Table function parse regular expression contains backslash failed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/09/05 03:31:00 UTC, 0 replies.
- 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error - posted by 潘功森 <pa...@hotmail.com> on 2018/09/05 05:27:26 UTC, 2 replies.
- Re: Flink 1.7 Development Priorities - posted by "yzhou@coupang.com" <yz...@coupang.com> on 2018/09/05 06:17:53 UTC, 0 replies.
- 答复: 答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error - posted by 潘功森 <pa...@hotmail.com> on 2018/09/05 08:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-10282) Provide separate thread-pool for REST endpoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/05 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10283) FileCache logs unnecessary warnings - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/05 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero. - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/09/05 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10285) Bum shade-plugin to 3.1.1 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/05 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper - posted by "Sayat Satybaldiyev (JIRA)" <ji...@apache.org> on 2018/09/05 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10287) Flink HA Persist Cancelled Job in Zookeeper - posted by "Sayat Satybaldiyev (JIRA)" <ji...@apache.org> on 2018/09/05 14:51:00 UTC, 0 replies.
- State for moving average calculation - posted by Ken Krugler <kk...@transpac.com> on 2018/09/06 01:01:55 UTC, 0 replies.
- [DISCUSS] -- Need to be able to access multiple s3 buckets with different authentication from within a single job - posted by Dave Brewster <da...@me.com.INVALID> on 2018/09/06 01:02:26 UTC, 1 replies.
- [jira] [Created] (FLINK-10288) Failover Strategy improvement - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/09/06 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10289) Classify Exceptions to different category for apply different failover strategy - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/09/06 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10290) Conversion error in StreamScan and BatchScan - posted by "wangsan (JIRA)" <ji...@apache.org> on 2018/09/06 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/06 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/06 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10293) RemoteStreamEnvironment does not forward port to RestClusterClient - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/06 08:25:02 UTC, 0 replies.
- [jira] [Created] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/06 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results - posted by "Gaurav Singhania (JIRA)" <ji...@apache.org> on 2018/09/06 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10296) TypeExtractor only validates/matches exact POJO classes - posted by "James Morgan (JIRA)" <ji...@apache.org> on 2018/09/06 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10297) PostVersionedIOReadableWritable ignores result of InputStream.read(...) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/07 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10298) Batch Job Failover Strategy - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/09/07 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10299) RowSerializer.copy data value cast exception - posted by "ambition (JIRA)" <ji...@apache.org> on 2018/09/07 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10300) Prometheus job level metrics not removed after job finished - posted by "Helmut Zechmann (JIRA)" <ji...@apache.org> on 2018/09/07 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10301) Allow a custom Configuration in StreamNetworkBenchmarkEnvironment - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/07 11:39:00 UTC, 0 replies.
- [ANNOUNCE] New committer Gary Yao - posted by Till Rohrmann <tr...@apache.org> on 2018/09/07 13:14:44 UTC, 18 replies.
- Re: [DISCUSS] Proposal of external shuffle service - posted by Till Rohrmann <tr...@apache.org> on 2018/09/07 14:00:48 UTC, 0 replies.
- [jira] [Created] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/07 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10303) Fix critical vulnerabilities Python API - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/09/07 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10304) Remove deprecated AbstractYarnClusterDescriptor field - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/07 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10305) flink-conf.yaml grows continuously - posted by "Dimitrije (JIRA)" <ji...@apache.org> on 2018/09/07 18:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10306) Support the display of log file from any position on webUI - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/09/08 09:36:00 UTC, 0 replies.
- PubSub connector (FLINK-9311) - posted by Richard Deurwaarder <ri...@xeli.eu> on 2018/09/08 18:31:22 UTC, 0 replies.
- Elasticsearch InputFormat - posted by Michael Gendelman <ge...@gmail.com> on 2018/09/08 21:48:32 UTC, 3 replies.
- [jira] [Created] (FLINK-10307) instruct users to email us with proper code snippets - posted by "Nicos Maris (JIRA)" <ji...@apache.org> on 2018/09/09 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10308) remove docker folder - posted by "Nicos Maris (JIRA)" <ji...@apache.org> on 2018/09/09 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10309) Cancel flink job occurs java.net.ConnectException - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/09/09 07:55:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #37 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/10 06:32:11 UTC, 0 replies.
- [jira] [Created] (FLINK-10310) Cassandra Sink - Handling failing requests - posted by "Jayant Ameta (JIRA)" <ji...@apache.org> on 2018/09/10 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/10 07:58:04 UTC, 0 replies.
- [jira] [Created] (FLINK-10312) Wrong / missing exception when submitting job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/10 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10313) Wrong FileCache warning about improper use of releaseJob() when not using DistributedCache - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/10 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10314) Blocking calls in Execution Graph creation bring down cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/10 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10315) Let JDBCAppendTableSink be built with java.sql.Connection - posted by "François Lacombe (JIRA)" <ji...@apache.org> on 2018/09/10 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10316) Kinesalite bug fix (FLINK-9402) doesn't fully fix the problem. - posted by "Joseph Sims (JIRA)" <ji...@apache.org> on 2018/09/10 21:27:00 UTC, 0 replies.
- Could you please assign issue-10002 to me? - posted by Xinyu Zhang <ws...@gmail.com> on 2018/09/11 02:02:01 UTC, 1 replies.
- 回复：[ANNOUNCE] New committer Gary Yao - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/09/11 06:45:43 UTC, 0 replies.
- 回复：[DISCUSS] Proposal of external shuffle service - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/09/11 07:20:51 UTC, 0 replies.
- [jira] [Created] (FLINK-10317) Configure Metaspace size by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/11 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10318) Add option to build Hadoop-free job image to build.sh - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/09/11 09:45:00 UTC, 0 replies.
- Speakers needed for Apache DC Roadshow - posted by Rich Bowen <rb...@apache.org> on 2018/09/11 15:05:52 UTC, 0 replies.
- Jar availability after cluster restart - posted by Ri...@natwestmarkets.com.INVALID on 2018/09/11 16:49:31 UTC, 1 replies.
- [jira] [Created] (FLINK-10319) Avoid requestPartitionState from JM but always try retrigger - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/12 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10320) Introduce JobMaster schedule micro-benchmark - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/12 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10321) Make the condition of broadcast partitioner simple - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/09/12 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10322) Unused instance variable MetricRegistry in ResourceManager - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/09/12 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10323) A single backslash cannot be successfully parsed in Java Table API - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/09/12 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10324) Replace ZooKeeperStateHandleStore#getAllSortedByNameAndLock by getAllAndLock - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/12 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10325) [State TTL] Refactor TtlListState to use only loops, no java stream API for performance - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/09/12 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10326) Simplify ZooKeeperSubmittedJobGraphStore constructor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/12 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/09/12 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10328) Stopping the ZooKeeperSubmittedJobGraphStore should release all currently held locks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/12 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10329) Fail with exception if job cannot be removed by ZooKeeperSubmittedJobGraphStore#removeJobGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/12 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10330) Code Compilation failed in local mode - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/09/13 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10331) Fix unnecessary flush requests to the network stack - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/13 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10332) Move data available notification in PipelinedSubpartition out of the synchronized block - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/13 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 08:50:00 UTC, 0 replies.
- Kinesis connector shard discovery mechanism - posted by Евгений Юшин <ev...@gmail.com> on 2018/09/13 08:52:33 UTC, 1 replies.
- [jira] [Created] (FLINK-10334) Move RetrievableStateStorageHelper out of ZooKeeperStateHandleStore - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10335) Create common ZooKeeperStateStore based on ZooKeeperStateHandleStore and RetrievableStateStorageHelper - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10336) Use ZooKeeperStateStore in ZooKeeperSubmittedJobGraphStore - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10337) Use ZooKeeperStateStore in ZooKeeperCompletedCheckpointStore - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10338) Use ZooKeeperStateStore in ZooKeeperMesosWorkerStore - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/09/13 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10340) Implement Cosh udf - posted by "Sergey Tsvetkov (JIRA)" <ji...@apache.org> on 2018/09/13 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10341) Add option to print flink command when running bin/flink - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/09/13 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed - posted by "Oleksandr Nitavskyi (JIRA)" <ji...@apache.org> on 2018/09/13 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10343) Expose setCurrentKey method to streamRuntimeContext - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/09/13 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10344) Rethink SubmittedJobGraphListener - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10345) Rethink SubmittedJobGraphListener - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/13 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/14 13:36:00 UTC, 0 replies.
- Please review : Re: PubSub connector (FLINK-9311) - posted by Niels Basjes <Ni...@basjes.nl> on 2018/09/14 13:40:57 UTC, 1 replies.
- [DISCUSS] Release Flink 1.5.4 and 1.6.1 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/14 15:29:08 UTC, 3 replies.
- [jira] [Created] (FLINK-10347) Kafka09SecuredRunITCase failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/14 17:09:00 UTC, 0 replies.
- spring boot application load to flink 1.5.1 - posted by flink-stgo-qba <sw...@gmail.com> on 2018/09/14 22:27:34 UTC, 1 replies.
- [jira] [Created] (FLINK-10348) Solve data skew when consuming data from kafka - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/09/15 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10349) Unify stopActor* utils - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/15 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10350) Add assignTimestampsAndWatermarks in KeyedStream - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/09/15 15:20:00 UTC, 0 replies.
- [VOTE] Release 1.5.4, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/15 21:26:21 UTC, 6 replies.
- [VOTE] Release 1.6.1, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/15 21:32:49 UTC, 9 replies.
- [jira] [Created] (FLINK-10351) Ignore specific operator's state when restore from savepoint - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/09/16 18:47:00 UTC, 0 replies.
- [PROPOSAL] [community] A more structured approach to reviews and contributions - posted by Stephan Ewen <se...@apache.org> on 2018/09/17 08:00:19 UTC, 15 replies.
- [jira] [Created] (FLINK-10352) Bind Task's URLClassLoader to TaskExecutor's slot - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/17 09:58:00 UTC, 0 replies.
- 回复：[PROPOSAL] [community] A more structured approach to reviews and contributions - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/09/17 10:05:29 UTC, 0 replies.
- [jira] [Created] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/09/17 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10354) Savepoints should be counted as retained checkpoints - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/17 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10355) The order of the column should start from 1. - posted by "lihongli (JIRA)" <ji...@apache.org> on 2018/09/17 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/17 14:39:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #38 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/17 14:46:41 UTC, 0 replies.
- [jira] [Created] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/17 14:56:00 UTC, 0 replies.
- CEP & checkpoints/savepoints - posted by Ron Crocker <rc...@newrelic.com.INVALID> on 2018/09/17 17:09:44 UTC, 2 replies.
- [jira] [Created] (FLINK-10358) Flink kinesis connector could throw NPE during getRecords() call - posted by "Ying Xu (JIRA)" <ji...@apache.org> on 2018/09/17 18:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10359) Scala example in DataSet docs is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/09/17 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10360) support timeout in savepoint REST api - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/09/17 23:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/18 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10362) Bundles S3 connectors load wrong Hadoop config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/18 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10363) S3 FileSystem factory prints secrets into logs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/18 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10364) Test instability in NonHAQueryableStateFsBackendITCase#testMapState - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/18 08:54:02 UTC, 0 replies.
- [jira] [Created] (FLINK-10365) Consolidate shaded Hadoop classes for filesystems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/18 09:15:00 UTC, 0 replies.
- Watermark alignment during unit tests - posted by Евгений Юшин <ev...@gmail.com> on 2018/09/18 09:40:42 UTC, 1 replies.
- [jira] [Created] (FLINK-10366) Create a shared base for S3 file systems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/18 09:53:00 UTC, 0 replies.
- ***UNCHECKED*** [jira] [Created] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/09/19 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10368) 'Kerberized YARN on Docker test' instable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/19 11:58:00 UTC, 0 replies.
- ***UNCHECKED*** [jira] [Created] (FLINK-10369) Enable YARNITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/19 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10370) DistributedCache does not work in job cluster mode. - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/19 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10371) Allow to enable SSL mutual authentication on REST endpoints by configuration - posted by "Johannes Dillmann (JIRA)" <ji...@apache.org> on 2018/09/19 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10372) There is no API to configure the timer state backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/09/20 00:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10373) CoGroup Window support lateness - posted by "huangzhenhua (JIRA)" <ji...@apache.org> on 2018/09/20 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10374) [Map State] Let user value serializer handle null values - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/09/20 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10375) ExceptionInChainedStubException hides wrapped exception in cause - posted by "Mike Pedersen (JIRA)" <ji...@apache.org> on 2018/09/20 11:52:00 UTC, 0 replies.
- [Possible Bug] Savepoints Akka Timeout - posted by Sayat Satybaldiyev <sa...@gmail.com> on 2018/09/20 12:04:37 UTC, 1 replies.
- [jira] [Created] (FLINK-10376) BlobCacheCleanupTest.testPermanentBlobCleanup failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/20 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/20 12:58:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.5.4, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/20 13:38:46 UTC, 1 replies.
- [RESULT] [VOTE] Release 1.6.1, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/20 13:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-10378) Hide/Comment out contribute guide from PULL_REQUEST_TEMPLATE - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/20 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10379) Can not use Table Functions in Java Table API - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/09/20 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream - posted by "Sayat Satybaldiyev (JIRA)" <ji...@apache.org> on 2018/09/20 14:34:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.5.4 released - posted by Till Rohrmann <tr...@apache.org> on 2018/09/20 14:36:22 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.6.1 released - posted by Till Rohrmann <tr...@apache.org> on 2018/09/20 14:37:48 UTC, 0 replies.
- [jira] [Created] (FLINK-10381) concurrent submit job get ProgramAbortException - posted by "Youjun Yuan (JIRA)" <ji...@apache.org> on 2018/09/20 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink - posted by "Chengzhi Zhao (JIRA)" <ji...@apache.org> on 2018/09/20 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10383) Hadoop configurations on the classpath seep into the S3 file system configs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/20 17:44:00 UTC, 0 replies.
- [DISCUSS] [Contributing] (1) - Pull Request Template - posted by Stephan Ewen <se...@apache.org> on 2018/09/20 19:41:11 UTC, 0 replies.
- [DISCUSS] [Contributing] (2) - Review Steps - posted by Stephan Ewen <se...@apache.org> on 2018/09/20 19:52:42 UTC, 8 replies.
- [DISCUSS] [Contributing] (3) - Review Tooling - posted by Stephan Ewen <se...@apache.org> on 2018/09/20 19:56:32 UTC, 5 replies.
- [jira] [Created] (FLINK-10384) Add Sinh math function supported in Table API and SQL - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/09/21 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10385) Implement a waitUntilCondition utils - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/21 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10386) Remove legacy class TaskExecutionStateListener - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/09/21 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10387) StateBackend create methods should return interface not abstract KeyedStateBackend classes - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2018/09/21 09:42:00 UTC, 0 replies.
- Codespeed deployment for Flink - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/09/21 14:59:45 UTC, 5 replies.
- [jira] [Created] (FLINK-10388) RestClientTest sometimes fails with AssertionError - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/09/21 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/09/21 20:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10390) DataDog metric reporter leak warning - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/09/21 22:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/09/21 23:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10392) Remove legacy mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/22 17:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10393) Remove legacy entrypoints from startup scripts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/22 17:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10394) Remove legacy mode testing profiles from Travis config - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/22 17:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10395) Remove legacy mode switch from parent pom - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/22 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10396) Remove codebase switch from MiniClusterResource - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/22 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10397) Remove CoreOptions#MODE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/22 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10398) Add Tanh math function supported in Table API and SQL - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/09/23 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10399) Refractor ParameterTool#fromArgs - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/23 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10400) Return failed JobResult if job terminates in state FAILED or CANCELED - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/23 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10401) Port ProcessFailureCancelingITCase to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/23 19:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10402) Port AbstractTaskManagerProcessFailureRecoveryTest to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/23 20:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10403) Port JobManagerHAProcessFailureBatchRecoveryITCase to new code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/24 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10404) Declarative resource management - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/24 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10405) Port JobManagerFailsITCase to new code base - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/24 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10406) Port JobManagerTest to new code base - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/24 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10407) Reactive container mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/24 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10408) Cannot use window information in Table functions - posted by "Alexis Sarda-Espinosa (JIRA)" <ji...@apache.org> on 2018/09/24 09:24:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #39 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/24 10:11:58 UTC, 0 replies.
- [jira] [Created] (FLINK-10409) Collection data sink does not propagate exceptions - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/24 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10410) Search for broken links on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/24 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10411) Make ClusterEntrypoint more modular - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/24 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2018/09/25 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10413) requestPartitionState messages overwhelms JM RPC main thread - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2018/09/25 03:46:00 UTC, 0 replies.
- 回复：Codespeed deployment for Flink - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/09/25 05:59:40 UTC, 0 replies.
- [jira] [Created] (FLINK-10414) Add skip to next strategy - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/25 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10415) RestClient does not react to lost connection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/25 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10416) Add to rat excludes files generated by jepsen tests - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/25 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10417) Add option to throw exception on pattern variable miss with SKIP_TO_FIRST/LAST - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/25 10:01:00 UTC, 0 replies.
- Enrich testing doc with more unit test examples using AbstractStreamOperator - posted by Tony Wei <to...@gmail.com> on 2018/09/25 10:30:16 UTC, 4 replies.
- [jira] [Created] (FLINK-10418) Add COSH math function supported in Table API and SQL - posted by "Aleksei Izmalkin (JIRA)" <ji...@apache.org> on 2018/09/25 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/25 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10420) Create and drop view in sql client should check the view created based on the configuration. - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/09/25 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/09/25 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10422) Follow AWS specs in Kinesis Consumer - posted by "eugen yushin (JIRA)" <ji...@apache.org> on 2018/09/25 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2018/09/25 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10424) Inconsistency between JsonSchemaConveerter and FlinkTypeFactory - posted by "Dominik Wosiński (JIRA)" <ji...@apache.org> on 2018/09/25 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10425) taskmaster.host is not respected - posted by "Andrew Kowpak (JIRA)" <ji...@apache.org> on 2018/09/25 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10426) Port TaskTest to new code base - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/25 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10427) Port JobSubmitTest to new code base - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/26 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10428) AbstractServerBase should bind to any address per default - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/09/26 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/26 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10430) Extract scheduling-related code from Executions - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/26 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10431) Extract scheduling-related code from SlotPool - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/26 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10432) Introduce bulk/group-aware scheduling - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/26 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10433) Stepwise creation of the ExecutionGraph sub-structures - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/09/26 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10434) Blob file not removed after job execution. - posted by "Piotr Szczepanek (JIRA)" <ji...@apache.org> on 2018/09/26 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10435) Client sporadically hangs after Ctrl + C - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/09/26 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10436) Example config uses deprecated key jobmanager.rpc.address - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/09/26 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/26 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10438) Built in functions should document the returned types - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/09/26 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10439) Race condition during job suspension - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/09/26 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch - posted by "Benoit MERIAUX (JIRA)" <ji...@apache.org> on 2018/09/26 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10441) Don't log warning when creating upload directory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/09/26 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10442) Make declined savepoints visible in WebUI - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/26 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10443) Flink Yarn CLI hanging after unsuccessful deployment - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/26 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10444) Make S3 entropy injection work with FileSystem safety net - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/09/26 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10445) CLI stuck with (potentially incorrect) SSL config - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/26 16:33:00 UTC, 0 replies.
- Handling burst I/O when using tumbling/sliding windows - posted by Rong Rong <wa...@gmail.com> on 2018/09/26 17:21:01 UTC, 5 replies.
- [jira] [Created] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/09/26 23:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10447) Create Bucketing Table Sink. - posted by "Suxing Lee (JIRA)" <ji...@apache.org> on 2018/09/27 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10448) VALUES clause is translated into a separate operator per value - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/09/27 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10449) Docker flink hostname is locked to "cluster" - posted by "Mike Pedersen (JIRA)" <ji...@apache.org> on 2018/09/27 09:12:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10450) Broken links in the documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/27 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10451) TableFunctionCollector should handle the life cycle of ScalarFunction - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/09/27 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10452) Expose Additional Metrics to Reason about Statesize - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/09/27 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10453) Move hadoop 2.4 travis profile into cron job - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/27 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/27 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10455) Potential Kafka producer leak in case of failures - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/09/27 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10456) Remove org.apache.flink.api.common.time.Deadline - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/28 03:28:00 UTC, 0 replies.
- Discuss about [FLINK-10134] UTF-16 support for TextInputFormat bug fixed - posted by x1q1j1 <x1...@qq.com> on 2018/09/28 05:07:45 UTC, 0 replies.
- [jira] [Created] (FLINK-10457) Support SequenceFile for StreamingFileSink - posted by "Jihyun Cho (JIRA)" <ji...@apache.org> on 2018/09/28 08:02:00 UTC, 0 replies.
- Re: Discuss about [FLINK-10134] UTF-16 support for TextInputFormat bug fixed - posted by Chesnay Schepler <ch...@apache.org> on 2018/09/28 10:46:06 UTC, 0 replies.
- [jira] [Created] (FLINK-10458) Enable dependencyConvergence for flink-shaded - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/09/28 10:55:00 UTC, 0 replies.
- [DISCUSS] Dropping flink-storm? - posted by Till Rohrmann <tr...@apache.org> on 2018/09/28 13:22:24 UTC, 8 replies.
- [DISCUSS] Feature freeze for Flink 1.7 - posted by Till Rohrmann <tr...@apache.org> on 2018/09/28 14:19:58 UTC, 1 replies.
- [jira] [Created] (FLINK-10459) Flink cluster does not work properly in kubernetes - posted by "Georgii Gobozov (JIRA)" <ji...@apache.org> on 2018/09/28 17:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10460) DataDog reporter JsonMappingException - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/09/28 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10461) Speed up download file procedure when restore - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2018/09/29 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/09/29 03:53:00 UTC, 0 replies.
- 回复：[DISCUSS] Dropping flink-storm? - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/09/29 05:53:34 UTC, 0 replies.
- [jira] [Created] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/09/29 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely. - posted by "huangjiatian (JIRA)" <ji...@apache.org> on 2018/09/29 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10465) Jepsen: runit supervised sshd is stopped on tear down - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/09/29 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10466) flink-yarn-tests should depend flink-dist - posted by "tison (JIRA)" <ji...@apache.org> on 2018/09/29 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10467) Upgrade commons-compress to 1.18 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/09/30 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10468) Potential missing break for PARTITION_CUSTOM in OutputEmitter ctor - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/09/30 15:24:00 UTC, 0 replies.