You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] Table API / SQL internal timestamp handling - posted by Xingcan Cui <xi...@gmail.com> on 2017/08/01 04:04:46 UTC, 2 replies.
- [jira] [Created] (FLINK-7331) Remove Flink's futures from ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/01 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7332) Remove Flink's futures from TaskExecutor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/01 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7333) Remove Flink's futures from Task - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/01 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7334) Replace Flink's futures by CompletableFuture in RpcGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/01 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7335) Remove Flink's own future implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/01 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7336) Remove Flink's futures from AkkaRpcActor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/01 09:36:00 UTC, 0 replies.
- Re: Towards a spec for robust streaming SQL, Part 2 - posted by Fabian Hueske <fh...@gmail.com> on 2017/08/01 13:40:48 UTC, 2 replies.
- Re: [DISCUSS] Service Authorization (redux) - posted by Aljoscha Krettek <al...@apache.org> on 2017/08/01 14:22:15 UTC, 5 replies.
- [jira] [Created] (FLINK-7337) Refactor handling of time indicator attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/08/01 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7338) User Defined aggregation with constants causes error under in lowerbound over window extraction - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2017/08/01 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7339) aggregationToString fails when user defined aggregation contains constants - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2017/08/01 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7340) Taskmanager hung after temporary DNS outage - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2017/08/01 19:30:00 UTC, 0 replies.
- Re: Class Cache - posted by Mike Accola <ma...@us.ibm.com> on 2017/08/01 22:15:07 UTC, 0 replies.
- [jira] [Created] (FLINK-7341) Update code snippets in documentation - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/08/01 23:00:08 UTC, 0 replies.
- Re:Re: KeyBy fields do not support java.lang.Array? - posted by Xu Pingyong <xu...@163.com> on 2017/08/02 02:40:18 UTC, 0 replies.
- [jira] [Created] (FLINK-7342) Add support for Regular Expression Operators (RLIKE) - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/02 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7343) Kafka010ProducerITCase instability - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/08/02 07:04:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/08/02 07:09:11 UTC, 0 replies.
- Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release - posted by Stefan Richter <s....@data-artisans.com> on 2017/08/02 07:12:25 UTC, 7 replies.
- [jira] [Created] (FLINK-7345) Add BRANCH PATTERN. - posted by "zhangxiaoyu (JIRA)" <ji...@apache.org> on 2017/08/02 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7346) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow killed by maven watchdog on Travis - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/02 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7347) "removeAll" is extremely inefficient in MessageAcknowledgingSourceBase.notifyCheckpointComplete - posted by "Yonatan Most (JIRA)" <ji...@apache.org> on 2017/08/02 08:56:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7348) Allow redundant modifiers on methods - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/02 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7349) Only execute checkstyle in one build profile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/02 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7350) only execute japicmp in one build profile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/02 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/02 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7352) ExecutionGraphRestartTest timeouts - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/02 12:46:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7353) Bring project README.md up to date - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/08/02 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7354) test instability in LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/02 14:10:02 UTC, 0 replies.
- Re: [VOTE] Release 1.3.2, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/08/02 14:13:31 UTC, 6 replies.
- [jira] [Created] (FLINK-7355) YARNSessionFIFOITCase#testfullAlloc does not run anymore - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/02 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7356) misleading s3 file uri in configuration file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/02 18:59:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/08/03 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7358) Add implicitly converts support for User-defined function - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/03 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig - posted by "yf (JIRA)" <ji...@apache.org> on 2017/08/03 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7360) Support Scala map type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/03 08:07:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7361) flink-web doesn't build with ruby 2.4 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/03 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7362) CheckpointProperties are not correctly set when restoring savepoint with HA enabled - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/03 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7363) add hashes and signatures to the download page - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/03 11:42:00 UTC, 0 replies.
- State Backend - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2017/08/03 14:45:43 UTC, 0 replies.
- [jira] [Created] (FLINK-7364) Log exceptions from user code in streaming jobs - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/08/03 18:17:00 UTC, 0 replies.
- [CANCEL] [VOTE] Release 1.3.2, release candidate #2 - posted by Aljoscha Krettek <al...@apache.org> on 2017/08/03 19:12:45 UTC, 0 replies.
- [jira] [Created] (FLINK-7365) warning of attempt to override final parameter: fs.s3.buffer.dir - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/03 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7366) Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/03 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7367) Parameterize FlinkKinesisProducer on RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/04 00:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7368) MetricStore makes cpu spin at 100% - posted by "Nico Chen (JIRA)" <ji...@apache.org> on 2017/08/04 03:07:03 UTC, 0 replies.
- [VOTE] Release 1.3.2, release candidate #3 - posted by Aljoscha Krettek <al...@apache.org> on 2017/08/04 06:00:35 UTC, 10 replies.
- [jira] [Created] (FLINK-7369) Add more information for `Key group index out of range of key group range` exception - posted by "Benedict Jin (JIRA)" <ji...@apache.org> on 2017/08/04 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7370) rework operator documentation - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/04 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2017/08/04 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7372) Remove ActorGateway from JobGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/04 22:28:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.3.2, release candidate #3 - posted by Aljoscha Krettek <al...@apache.org> on 2017/08/05 06:07:04 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.3.2 released - posted by Aljoscha Krettek <al...@apache.org> on 2017/08/05 07:12:41 UTC, 2 replies.
- [jira] [Created] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/08/05 18:06:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7374) Type Erasure in GraphUtils$MapTo - posted by "Matthias Kricke (JIRA)" <ji...@apache.org> on 2017/08/06 13:41:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7375) Remove ActorGateway from JobClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/06 16:03:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7376) Cleanup options class and test classes in flink-clients - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/06 19:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7377) Implement FixedBufferPool for floating buffers in SingleInputGate - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/07 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7378) Implement the FixedBufferPool for floating buffers of SingleInputGate - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/07 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7379) Remove `HighAvailabilityServices` from client constructor. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/07 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7380) Limit usage of Row type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/07 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/07 11:58:00 UTC, 0 replies.
- How to run wordcount program on Multi-node Cluster. - posted by "P. Ramanjaneya Reddy" <ra...@gmail.com> on 2017/08/07 12:00:02 UTC, 9 replies.
- [jira] [Created] (FLINK-7382) Broken links in `Apache Flink Documentation` page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/07 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7383) Remove ConfigurationUtil - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/07 12:37:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7384) Unify event and processing time handling in the AbstractKeyedCEPPatternOperator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/07 16:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/08/08 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/08/08 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7387) Let RpcEndpoint directly implement RpcGateways - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/08 08:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/08/08 09:56:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7389) Remove Calcite PushProjector - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/08 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7390) Download links for broken for 1.2.0 to 1.3.1 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/08 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7391) Normalize release entries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/08 13:35:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink-shaded 1.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2017/08/08 16:28:55 UTC, 0 replies.
- [jira] [Created] (FLINK-7392) Enable more predicate push-down in joins - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/08/08 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7393) Refactor FlinkKinesisConsumerTest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/08 19:18:00 UTC, 0 replies.
- Behaviour when a task in a running job fails - posted by Luis Alves <lm...@gmail.com> on 2017/08/08 22:45:38 UTC, 2 replies.
- [jira] [Created] (FLINK-7394) Implement basic InputChannel for credit-based logic - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/09 05:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/09 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/09 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs - posted by "saif.aljumaili (JIRA)" <ji...@apache.org> on 2017/08/09 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7398) Table API operators/UDFs must not store Logger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/09 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7399) Add checkstyle rule to forbid codehaus jackson imports - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/09 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7400) off-heap limits set to conservatively in yarn - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/09 14:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-7401) EnvironmentInformation.getMaxJvmHeapMemory does not return the value given via -Xmx - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/09 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7402) Ineffective null check in NettyMessage#write() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/09 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7403) Remove expandLocalRef() before code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/09 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7404) Table API batch join code-gen's equi-join conditions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/08/09 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7405) Reduce excessive warning logging from DatadogHttpReporter - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/09 21:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/10 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/08/10 05:16:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7408) Extract WebRuntimeMonitor options from JobManagerOptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/10 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7409) WebRuntimeMonitor blocks serving threads - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/10 10:56:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7410) Add getName method to UserDefinedFunction - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2017/08/10 11:07:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7411) minor performance improvements in NettyMessage - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/10 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/10 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/10 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7414) Hardcode scala.version to 2.11 in flink-quickstart-scala - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/10 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7415) Add comments for cassandra test class `BatchExample` - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/10 15:03:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/10 15:34:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7417) Create flink-shaded-jackson - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/08/10 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7418) Replace all uses of jackson with flink-shaded-jackson - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/08/10 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7419) Shade jackson dependency in flink-avro - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/08/10 17:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7420) Move all Avro code to flink-avro - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/08/10 18:03:05 UTC, 0 replies.
- [jira] [Created] (FLINK-7421) AvroRow(De)serializationSchema not serializable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/10 19:11:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7422) Upgrade Kinesis Client Library (KCL) in flink-connector-kinesis from 1.6.2 to 1.8.1 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/10 22:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7423) Always reuse an instance to get elements from an inputFormat - posted by "Xu Pingyong (JIRA)" <ji...@apache.org> on 2017/08/11 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7424) `CEP` component make `KeyedStream` choose wrong channel - posted by "Benedict Jin (JIRA)" <ji...@apache.org> on 2017/08/11 04:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7425) Support Map in TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/11 04:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7426) Table API does not support null values in keys - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/11 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7427) integrate PartitionRequestProtocol into NettyProtocol - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/11 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7428) avoid one additional buffer copy when receiving messages - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/11 09:14:00 UTC, 0 replies.
- How to access HDFS file from flink - posted by "P. Ramanjaneya Reddy" <ra...@gmail.com> on 2017/08/11 09:31:04 UTC, 1 replies.
- [jira] [Created] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/08/11 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions - posted by "Peter Ertl (JIRA)" <ji...@apache.org> on 2017/08/11 11:05:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7431) test instability in JobManagerFailsITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/11 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7432) Unclosed HighAvailabilityServices instance in QueryableStateClient - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/11 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/11 16:31:01 UTC, 0 replies.
- Which branch should I build for Flink 1.3.2 - posted by Bowen Li <bo...@offerupnow.com> on 2017/08/11 21:53:32 UTC, 4 replies.
- How to build flink-dist.jar from source code - posted by Michael Fong <mc...@gmail.com> on 2017/08/12 01:19:19 UTC, 2 replies.
- [jira] [Created] (FLINK-7434) Scafolding of an scala project should rely on "sbt new" - posted by "Svend Vanderveken (JIRA)" <ji...@apache.org> on 2017/08/12 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP - posted by "daiqing (JIRA)" <ji...@apache.org> on 2017/08/12 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7436) HBaseConnectorITCase NullPointerException - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/08/12 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7437) Upgrade calcite to calcite 1.14 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/12 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7438) Some classes are eclipsed by classes in package scala - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/12 23:46:01 UTC, 0 replies.
- Number of consumers per IntermediateResult - posted by Luis Alves <lm...@gmail.com> on 2017/08/13 16:59:27 UTC, 2 replies.
- [jira] [Created] (FLINK-7439) Support variable arguments for UDTF - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/14 02:09:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7440) Add eager serializable checks on provided de-/serialization schemas for Kinesis consumer / producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/08/14 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7441) Double quote string literals is not supported in Table API and SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/14 08:41:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7442) Add option for using a child-first classloader for loading user code - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/14 09:54:00 UTC, 0 replies.
- Looking for a Mentor - posted by Sumit Sarin <su...@gmail.com> on 2017/08/14 11:35:17 UTC, 4 replies.
- [jira] [Created] (FLINK-7443) Store and deserializer fields in MetricFetcher should be final - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/14 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7444) Make external calls non-blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/14 12:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7445) Remove FLINK-1234 reference from PR template - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/14 21:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/15 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7447) Hope add more committer information to "Community & Project Info" page. - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/15 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7448) Keep the data type unchanged when register an existing field as rowtime - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/15 06:43:01 UTC, 0 replies.
- Permission for a new contributor - posted by Mingdao <mi...@gmail.com> on 2017/08/15 07:18:10 UTC, 4 replies.
- [jira] [Created] (FLINK-7449) Improve and enhance documentation for incremental checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/08/15 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/15 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7451) Query fails when non-ascii characters are used in string literals - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/15 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7452) Add helper methods for all built-in Flink types to Types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/15 11:12:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7453) FlinkKinesisProducer logs empty aws region - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/16 04:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7454) update 'Monitoring Current Event Time' section of Flink doc - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/16 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7455) RocksDB TTL support - posted by "Andrey Konyaev (JIRA)" <ji...@apache.org> on 2017/08/16 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/16 10:21:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7457) Make dispatcher HA - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/16 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7458) Generalize GatewayRetriever for WebRuntimeMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/16 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7459) Introduce RedirectHandler for the WebRuntimeMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/16 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7460) Close all ColumnFamilyHandles when restoring rescaled incremental checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/08/16 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7461) Remove Backwards compatibility for Flink 1.1 from Flink 1.4 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/08/16 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7462) Add very obvious warning about outdated docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/08/16 16:01:07 UTC, 0 replies.
- [DISCUSS] Stop serving docs for Flink version prior to 1.0 - posted by Ufuk Celebi <uc...@apache.org> on 2017/08/16 16:02:50 UTC, 12 replies.
- Which window function to use to start a window at anytime - posted by Bowen Li <bo...@offerupnow.com> on 2017/08/16 21:18:37 UTC, 0 replies.
- [jira] [Created] (FLINK-7463) Release nascent workers on slot request timeout - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/08/16 23:15:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7464) Add useful build-in Aggregate function into TabalAPI&SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/17 07:36:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7465) Add build-in BloomFilterCount on TableAPI&SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/17 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7466) Add a flink connector for Apache RocketMQ - posted by "yukon (JIRA)" <ji...@apache.org> on 2017/08/17 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7467) a slow client on the BlobServer may block writing operations - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/17 10:03:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7468) Implement Netty sender backlog logic for credit-based - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/08/17 15:52:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7469) Handle slot requests occuring before RM registration completes - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/08/17 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7470) Acquire RM leadership before registering with Mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/08/17 20:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7471) Improve bounded OVER support non-retract method AGG - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/17 21:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7472) Release task managers gracefully - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/08/17 21:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7473) Possible Leak in GlobalWindows - posted by "Steve Jerman (JIRA)" <ji...@apache.org> on 2017/08/17 23:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs - posted by "Joe (JIRA)" <ji...@apache.org> on 2017/08/18 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7475) ListState support update - posted by "yf (JIRA)" <ji...@apache.org> on 2017/08/18 06:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7476) Try to recover from failure in TwoPhaseCommitSinkFunction.beginTransaction - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/08/18 08:08:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7477) Use "hadoop classpath" to augment classpath when available - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/18 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7478) Update documentation for sql insert and api change in TableAPI & SQL - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/08/18 10:53:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7479) Support to retrieve the past event by an offset - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/08/18 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7480) Set HADOOP_CONF_DIR to sane default if not set - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/18 14:39:00 UTC, 0 replies.
- Ask for permission to contribute the community - posted by 蔡孟錡 <pe...@gmail.com> on 2017/08/20 05:17:09 UTC, 1 replies.
- [jira] [Created] (FLINK-7481) Binary search with integer overflow possibility - posted by "Baihua Su (JIRA)" <ji...@apache.org> on 2017/08/20 07:32:00 UTC, 0 replies.
- Re: [ANNOUNCE] Flink Forward Berlin (11-13 Sep 2017) Call for Submissions is open now - posted by Robert Metzger <rm...@apache.org> on 2017/08/20 20:31:48 UTC, 0 replies.
- [jira] [Created] (FLINK-7482) StringWriter to support compression - posted by "Felix Cheung (JIRA)" <ji...@apache.org> on 2017/08/20 22:52:02 UTC, 0 replies.
- Request for contributor permissions - posted by Hai Zhou <ye...@gmail.com> on 2017/08/21 01:21:23 UTC, 2 replies.
- [jira] [Created] (FLINK-7483) BlobCache cleanup timer not reset after job re-registration - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/21 10:22:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5 - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/08/21 11:12:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7485) Using DataView interface to improve (MIN/MAX)WithRetractAggFunction. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/21 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7486) flink-mesos: Support for adding unique attribute / group_by attribute constraints - posted by "Bhumika Bayani (JIRA)" <ji...@apache.org> on 2017/08/21 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7487) test instability in ClassLoaderITCase (no resources available) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/21 15:12:00 UTC, 0 replies.
- Changing parallelism on BucketingSink - posted by Felix Cheung <fe...@hotmail.com> on 2017/08/21 17:04:56 UTC, 1 replies.
- [jira] [Created] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/22 00:50:01 UTC, 0 replies.
- mvn checkstyle error vs IDE based stylecheck - posted by Michael Fong <mc...@gmail.com> on 2017/08/22 12:30:46 UTC, 4 replies.
- Not able to run beam appliction on Flink cluster environment - posted by "P. Ramanjaneya Reddy" <ra...@gmail.com> on 2017/08/22 12:43:30 UTC, 2 replies.
- [jira] [Created] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/22 14:40:00 UTC, 0 replies.
- [DISCUSS] Flink 1.4 and time based release - posted by Stephan Ewen <se...@apache.org> on 2017/08/22 16:32:08 UTC, 7 replies.
- [jira] [Created] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader - posted by "Miguel Rui Pereira Marques (JIRA)" <ji...@apache.org> on 2017/08/22 16:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/08/22 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7492) Memsql Connector - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2017/08/22 18:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7493) Create Pinot Connector - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2017/08/22 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7494) No license headers in ".travis.yml" file - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/23 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/23 17:31:00 UTC, 0 replies.
- Support for multiple HDFS - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2017/08/23 18:00:33 UTC, 5 replies.
- [jira] [Created] (FLINK-7496) Support greedy quantifier followed by an optional pattern - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/08/24 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7497) Allow users to add custom user context stored in state in TwoPhaseCommitSinkFunction - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/08/24 09:13:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7498) Bind together state fields of TwoPhaseCommitSinkFunction - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/08/24 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7499) double buffer release in SpillableSubpartitionView - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/24 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7500) Set JobMaster leader session id in main thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/24 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7501) Generalize leader id of RegisteredRpcConnection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/24 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7502) PrometheusReporter improvements - posted by "Maximilian Bode (JIRA)" <ji...@apache.org> on 2017/08/24 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7503) Config options taskmanager.log.path and jobmanager.web.log.path are misleading, if not broken - posted by "Felix Dreissig (JIRA)" <ji...@apache.org> on 2017/08/24 14:10:00 UTC, 0 replies.
- Optional vs Nullable - posted by Piotr Nowojski <pi...@data-artisans.com> on 2017/08/24 14:58:36 UTC, 3 replies.
- [jira] [Created] (FLINK-7504) Fence ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/24 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7505) Use lambdas in suppressed exception idiom - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/08/24 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7506) Fence JobMaster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/24 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7507) Fence Dispatcher - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/24 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/24 22:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7509) Refactorings to AggregateCodeGenerator - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/25 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/25 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7511) Remove dead code after dropping backward compatibility with <=1.2 - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/08/25 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7512) avoid unnecessary buffer copies during network serialization - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7513) remove TestBufferFactory#MOCK_BUFFER - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7515) allow actual 0-length content in NettyMessage#allocateBuffer() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7516) MemorySegment: do not allow copies into a read-only ByteBuffer - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7518) pass our own buffer instances to netty - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 11:31:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7519) Enrich ClientRestException with HttpResponseStatus - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/25 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7520) let our Buffer class extend from netty's buffer class - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7521) Remove the 10MB limit from the current REST implementation. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/25 12:08:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7522) Add termination future to ClusterEntrypoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/25 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7523) test instability in LocalStreamEnvironmentITCase#testRunIsolatedJob - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/08/25 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/25 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7525) Add config option to disable Cancel functionality on UI - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/08/25 22:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7526) TaskExecutor should filter out duplicate JobManager gained leadership messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 10:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7527) Add redirection logic to AbstractRestHandler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7528) Create Dispatcher REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7529) Retrieve complete REST address from RestfulGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7530) Port existing REST handlers to support Flip-6 components - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7531) Move existing REST handler to flink-runtime - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7532) Add StaticFileServerHandler to DispatcherRestEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7533) Retry failed gateway retrievals in the LeaderGatewayRetriever - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 17:43:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7534) Create LegacyRestHandlerAdapter for the old REST handlers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7535) Port DashboardConfigHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/08/26 20:37:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7536) Add MongoDB Source/Sink for Flink Streaming - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/27 05:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7537) Add InfluxDB Sink for Flink Streaming - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/27 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7538) Add InfluxDB Sink for Flink Streaming - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/27 05:47:02 UTC, 0 replies.
- Streaming job gets slower and slower - posted by "Aparup Banerjee (apbanerj)" <ap...@cisco.com> on 2017/08/27 07:03:57 UTC, 0 replies.
- Serialization Issue - posted by Alexandru Gutan <al...@gmail.com> on 2017/08/27 13:50:41 UTC, 3 replies.
- [jira] [Created] (FLINK-7539) Make AvroOutputFormat default codec configurable - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/08/27 15:20:01 UTC, 0 replies.
- Sync Flink - posted by ziv <zi...@elbitsystems.com> on 2017/08/28 06:10:16 UTC, 2 replies.
- [jira] [Created] (FLINK-7540) submit a job on yarn-cluster mode or start a yarn-session failed,in hadoop cluster with capitalized hostname - posted by "Tong Yan Ou (JIRA)" <ji...@apache.org> on 2017/08/28 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7541) Redistribute operator state using OperatorID - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/08/28 12:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7542) Some tests in AggregateITCase fail for some Time Zones - posted by "Usman Younas (JIRA)" <ji...@apache.org> on 2017/08/28 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7543) Simplify REST parameter access. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/28 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7544) Make all PathParameters mandatory - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/08/28 14:44:00 UTC, 0 replies.
- Re: [DISCUSS] NOTICE - posted by Nico Kruber <ni...@data-artisans.com> on 2017/08/28 16:14:34 UTC, 0 replies.
- [jira] [Created] (FLINK-7545) Support MEMBER OF Operator for Multiset SQL type - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/08/28 18:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7546) Support SUBMULTISET_OF Operator for Multiset SQL type - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/08/28 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/08/29 00:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7548) Support watermark generation for TableSource - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/08/29 02:28:02 UTC, 0 replies.
- "Unable to find registrar for hdfs" on Flink cluster - posted by "P. Ramanjaneya Reddy" <ra...@gmail.com> on 2017/08/29 06:59:21 UTC, 1 replies.
- [jira] [Created] (FLINK-7549) CEP - Pattern not discovered if source streaming is very fast - posted by "Paolo Rendano (JIRA)" <ji...@apache.org> on 2017/08/29 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7550) Give names to REST client/server for clearer logging. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/29 10:35:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7551) Add VERSION to the REST urls. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/29 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7552) Extend SinkFunction interface with SinkContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/29 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7553) Use new SinkFunction interface in FlinkKafkaProducer010 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/29 13:48:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7554) Add a testing RuntimeContext to test utilities - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/08/29 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7555) Use flink-shaded-guava-18 to replace guava dependencies - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/29 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7556) Fix fetch size configurable in JDBCInputFormat for MySQL Driver - posted by "Nycholas de Oliveira e Oliveira (JIRA)" <ji...@apache.org> on 2017/08/29 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7557) Fix typo for s3a config in AWS deployment documentation - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/08/30 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7558) Improve SQL ValidationException message. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/08/30 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7559) Typo in flink-quickstart pom.xml - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/30 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7560) Add Reset button for Plan Visualizer Page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/30 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7561) Add support for pre-aggregation in DataStream API - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/08/30 15:48:00 UTC, 0 replies.
- [DISCUSS] Watermark boundary condition - posted by Eron Wright <er...@gmail.com> on 2017/08/30 18:37:13 UTC, 1 replies.
- [jira] [Created] (FLINK-7562) uploaded jars sort by upload-time on dashboard page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/08/31 03:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7563) Fix watermark semantics in CEP operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/31 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7564) Fix Watermark semantics in Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/08/31 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7565) Add support for HTTP 1.1 (Chunked transfer encoding) to Flink web UI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/08/31 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7566) if there's only one checkpointing metadata file in , `flink run -s ` should resume from that metadata file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/08/31 21:39:00 UTC, 0 replies.