You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-8541) Mesos RM should recover from failover timeout - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/02/01 01:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/02/01 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen - posted by "chris snow (JIRA)" <ji...@apache.org> on 2018/02/01 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null - posted by "Bill Lee (JIRA)" <ji...@apache.org> on 2018/02/01 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8545) Implement upsert stream table source - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/01 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/01 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/02/02 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8548) Add Streaming State Machine Example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/02 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/02 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8550) Iterate over entryset instead of keys - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/02 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8551) Should BIGINT in Flink SQL will be enchance to - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2018/02/03 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8552) CliFrontend don't exit normal after job has been submitted with 'bin/flink run some_jar_ball' - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2018/02/03 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8553) switch flink-metrics-datadog to async mode - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/02/03 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8554) Upgrade AWS SDK - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/02/04 05:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8555) Fix TableFunction varargs length exceeds 254 for SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/02/04 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8556) Add proxy usage to Kinesis Connector to acces its endpoint - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/02/04 19:39:00 UTC, 0 replies.
- Why does jobmanager running needs slot ? - posted by mingleizhang <zm...@163.com> on 2018/02/05 07:35:17 UTC, 0 replies.
- Fetch Metrics - posted by Suvimal Yashraj <su...@ericsson.com> on 2018/02/05 09:17:50 UTC, 1 replies.
- [jira] [Created] (FLINK-8557) OperatorSubtaskDescriptionText causes failures on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/05 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8558) Add unified format interfaces and format discovery - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/05 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8559) JobManagerHACheckpointRecoveryITCase runs indefinitely on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/05 10:50:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-23 Model Serving - posted by Stavros Kontopoulos <st...@gmail.com> on 2018/02/05 12:10:57 UTC, 0 replies.
- [jira] [Created] (FLINK-8560) Access to the current key in ProcessFunction after keyBy() - posted by "Jürgen Thomann (JIRA)" <ji...@apache.org> on 2018/02/05 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8561) SharedBuffer line 573 uses == to compare BufferEntries instead of .equals. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/05 13:21:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.5.0 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/05 13:36:09 UTC, 18 replies.
- Timestamp/watermark support in Kinesis consumer - posted by Thomas Weise <th...@apache.org> on 2018/02/06 01:31:58 UTC, 14 replies.
- [jira] [Created] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/02/06 03:49:00 UTC, 0 replies.
- [Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink - posted by Bowen Li <bo...@gmail.com> on 2018/02/06 07:26:53 UTC, 1 replies.
- [jira] [Created] (FLINK-8563) Support consecutive DOT operators - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/06 07:36:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8564) SELECT DISTINCT without aggregations should not require a retract stream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/06 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8565) CheckpointOptionsTest unstable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/06 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8566) Replace retract/insert of same record for state retention timer resets - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/02/06 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8567) Maven-shade-plugin can't relocate Scala classes. - posted by "John Fang (JIRA)" <ji...@apache.org> on 2018/02/06 15:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8568) flink table's guava classes can't beed relocated by maven-shed-plugin. - posted by "John Fang (JIRA)" <ji...@apache.org> on 2018/02/06 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2018/02/06 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8570) Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2018/02/06 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2018/02/06 18:57:00 UTC, 0 replies.
- Terminating streaming test - posted by Thomas Weise <th...@apache.org> on 2018/02/07 00:21:22 UTC, 5 replies.
- [jira] [Created] (FLINK-8572) Flink1.4版本的document 左边的菜单点击无法跳转,左边的下拉菜单都无法下拉 - posted by "PengYang (JIRA)" <ji...@apache.org> on 2018/02/07 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8573) Print JobID for failed jobs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/07 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8574) Add timestamps to travis logging messages - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/07 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8575) BackPressureStatsTrackerITCase unstable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/07 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8576) Log message for QueryableState loading failure too verbose - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/07 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8577) Implement proctime DataStream to Table upsert conversion. - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/07 10:45:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8578) Implement rowtime DataStream to Table upsert conversion. - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/07 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8579) Support deletion flag for DataStream to Table upsert conversion. - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/07 10:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2018/02/07 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8581) Improve performance for low latency network - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8582) Introduce BufferConsumer concept - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8583) Pass BufferConsumer to subpartitions - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8584) Handle read-only buffers in DataInputDeserializer - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8585) Efficiently handle read-only buffers in DataInputDeserializer - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8586) Drop SpilledSubpartitionViewTest - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:04:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8587) Drop unused AdaptiveSpanningRecordDeserializer - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8588) Handle sliced buffers in RecordDeserializer - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8589) Add data polling method to InputGate - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8590) Drop ResultPartitionWriter#writeBufferToAllSubpartitions method - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8591) Handle unfinished BufferConsumers in subpartitions - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/07 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8592) LatencyMetric scope should include operator names - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/07 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8593) Latency metric docs are outdated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/07 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8594) Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/07 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8595) Include table source factory services in flink-table jar - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/07 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8596) Custom command line code does not correctly catch errors - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/07 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8597) Add examples for Connected Streams with Broadcast State. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/07 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8598) Intermittent test failure of BackPressureStatsTrackerITCase.testBackPressuredProducer - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/02/07 18:00:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.4.1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/07 18:29:07 UTC, 0 replies.
- [jira] [Created] (FLINK-8599) Improve the failure behavior of the ContinuousFileReaderOperator for bad files - posted by "Chengzhi Zhao (JIRA)" <ji...@apache.org> on 2018/02/07 22:51:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8600) BucketingSink errors out when used with Presto filesystem - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/02/07 23:30:00 UTC, 0 replies.
- build/devops - posted by cw7k <cw...@yahoo.com.INVALID> on 2018/02/08 00:06:26 UTC, 2 replies.
- [jira] [Created] (FLINK-8601) Introduce LinkedBloomFilterState for Approximate calculation and other situations of performance optimization - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/08 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8602) Accelerate recover from failover when use incremental checkpoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/08 08:22:00 UTC, 0 replies.
- Confused about method naming in heartbeatFromJobManager or heartbeatFromResourceManager - posted by mingleizhang <zm...@163.com> on 2018/02/08 12:06:53 UTC, 3 replies.
- [jira] [Created] (FLINK-8603) Split RestClusterClient#submitJob into submitJob and requestJobResult - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8604) Move JobTerminationHandler to WebMonitorEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8605) Enable job cancellation from the web UI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8606) Clean up Table API for Java users - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/08 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8607) Add a basic embedded SQL CLI client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/08 15:18:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8608) Add MiniDispatcher for job mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8609) Add support to deploy detached job mode clusters - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8610) Remove RestfulGateway from JobMasterGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8611) Add result future to JobManagerRunner - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8612) Add non-detached job mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8613) Return excess container in YarnResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8614) Enable Flip-6 per default - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/08 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn - posted by "Karrtik Iyer (JIRA)" <ji...@apache.org> on 2018/02/08 17:46:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8616) Missing null check in OperatorChain#pushToOperator masks ClassCastException - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2018/02/09 01:17:14 UTC, 0 replies.
- [jira] [Created] (FLINK-8617) Fix code generation bug while accessing Map type - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/02/09 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8618) Add S3 to the list of sinks on the delivery guarantees page - posted by "chris snow (JIRA)" <ji...@apache.org> on 2018/02/09 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8619) Some thing about Flink SQL distinct, I need help - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2018/02/09 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/02/09 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/09 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/09 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8622) flink-mesos: High memory usage of scheduler + job manager. GC never kicks in. - posted by "Bhumika Bayani (JIRA)" <ji...@apache.org> on 2018/02/09 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8624) flink-mesos: The flink rest-api sometimes becomes unresponsive - posted by "Bhumika Bayani (JIRA)" <ji...@apache.org> on 2018/02/09 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8625) Move OutputFlasherThread to Netty scheduled executor - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/09 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8626) Introduce BackPressureStatsTracker interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/09 15:07:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8627) Introduce SUSPENDING state - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/09 18:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8628) BucketingSink does not work wit S3 - posted by "dejan miljkovic (JIRA)" <ji...@apache.org> on 2018/02/09 19:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8629) Allow JobMaster to rescale jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/09 20:11:00 UTC, 0 replies.
- [VOTE] Release 1.4.1, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/10 14:21:03 UTC, 6 replies.
- [jira] [Created] (FLINK-8630) To support JSON schema to TypeInformation conversion - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/02/10 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8631) Add support for generic response types to RestClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/10 23:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8632) Generalize SavepointHandlers to be used for other asynchronous operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/10 23:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8633) Expose JobMaster#rescaleJob via the Dispatcher - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/11 00:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8634) Add asynchronous rescaling REST handlers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/11 00:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8635) Register asynchronous rescaling handler at WebMonitorEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/11 00:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8636) Pass TaskManagerServices to TaskExecutor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/11 23:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8637) Pass JobManagerSharedServices to JobMaster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/12 00:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8638) Job restart when Checkpoint On Barrier failed - posted by "Ran Tao (JIRA)" <ji...@apache.org> on 2018/02/12 03:28:00 UTC, 0 replies.
- Permission For New Contributor - posted by "T. Wang" <wa...@foxmail.com> on 2018/02/12 06:25:21 UTC, 1 replies.
- Batch job getting stuck - posted by Amit Jain <aj...@gmail.com> on 2018/02/12 09:10:42 UTC, 2 replies.
- [jira] [Created] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/12 14:40:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8640) Disable japicmp on java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/12 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8641) Move BootstrapTools#getTaskManagerShellCommand to flink-yarn - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/12 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8642) Initialize descriptors before use at getBroadcastState(). - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/13 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8643) Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/13 12:27:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8644) Shut down AkkaRpcActors with PoisonPill - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/13 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8645) Support convenient extension of parent-first ClassLoader patterns - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/13 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8646) Move docs directory to flink-docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/13 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8647) Introduce JobMasterConfiguration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/13 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8648) Allow for customization of emitRecordAndUpdateState in Kinesis connector - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/02/13 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8649) Scala StreamExecutionEnvironment.createInput should pass on the TypeInfo - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2018/02/13 17:31:00 UTC, 0 replies.
- IO metrics - posted by cw7k <cw...@yahoo.com.INVALID> on 2018/02/13 19:37:55 UTC, 4 replies.
- Why are checkpoint failures so serious? - posted by Ron Crocker <rc...@newrelic.com> on 2018/02/13 22:41:32 UTC, 4 replies.
- Support distinct aggregation over data stream on Table/SQL API - posted by Rong Rong <wa...@gmail.com> on 2018/02/14 02:07:19 UTC, 3 replies.
- [jira] [Created] (FLINK-8650) Add tests and documentation for WINDOW clause - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/14 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8651) Add support for different event-time OVER windows in a query - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/02/14 09:13:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8652) Reduce log level of QueryableStateClient.getKvState() to DEBUG - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/02/14 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8653) Remove slot request timeout from SlotPool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/14 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8654) Extend quickstart docs on how to submit jobs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/14 12:23:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8655) Add a default keyspace to CassandraSink - posted by "Christopher Hughes (JIRA)" <ji...@apache.org> on 2018/02/14 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8656) Add CLI command for rescaling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/14 14:07:00 UTC, 0 replies.
- Apache EU Roadshow CFP Closing Soon (23 February) - posted by Sharan F <sh...@apache.org> on 2018/02/14 15:18:36 UTC, 0 replies.
- [jira] [Created] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/14 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8658) NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient - posted by "sathiyarajan (JIRA)" <ji...@apache.org> on 2018/02/14 18:09:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8659) Add migration tests for Broadcast state. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/14 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8660) Enable the user to provide custom HAServices implementation - posted by "Krzysztof Białek (JIRA)" <ji...@apache.org> on 2018/02/14 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/02/15 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/15 10:37:00 UTC, 0 replies.
- [DISCUSS] Flink security improvements - posted by Shuyi Chen <su...@gmail.com> on 2018/02/15 12:19:48 UTC, 1 replies.
- Re: [RESULT] [VOTE] Release 1.4.1, release candidate #1 - posted by Tzu-Li Tai <tz...@gmail.com> on 2018/02/15 12:22:13 UTC, 2 replies.
- [jira] [Created] (FLINK-8663) Execution of DataStreams result in non functionality of size of Window for countWindow - posted by "Subham (JIRA)" <ji...@apache.org> on 2018/02/15 12:31:03 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.4.1 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/15 18:04:07 UTC, 2 replies.
- [jira] [Created] (FLINK-8664) Change termination future type of RpcEndpoint to Void - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/15 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8665) Allow RpcEndpoint#postStop to complete asynchronously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/15 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8666) Use AkkaUtils#testDispatcherConfig in MiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/15 19:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer() - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/02/15 20:31:00 UTC, 0 replies.
- Sessions online for #flinkforward SF. Register with 25% discount code. - posted by Fabian Hueske <fh...@gmail.com> on 2018/02/16 08:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-8668) Remove "hadoop classpath" from config.sh - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/16 09:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8669) Extend FutureUtils to have method to wait for the completion of all futures - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/16 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8670) Make MetricRegistryImpl#shutdown non blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/16 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8671) Split documented default value if it is too long - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/16 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8672) Support continuous processing in CSV table source - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/16 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8673) Don't let JobManagerRunner shut down itself - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/16 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8674) Efficiently handle alwaysFlush case (0ms flushTimeout) - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/16 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8675) Make shut down of RestServerEndpoint non blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/16 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8676) Memory Leak in AbstractKeyedStateBackend.applyToAllKeys() when backend is base on RocksDB - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/16 17:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8677) Make ClusterEntrypoint shut down non-blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/16 17:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8678) Make AkkaRpcService#stopService non-blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/16 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/16 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8680) Name printing sinks by default. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/16 19:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8681) Remove planVisualizer.html move notice - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/16 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8682) Make start/stop cluster scripts work without SSH for local HA setups - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/16 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8683) Add test for configuration docs completeness - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/16 20:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/16 20:58:00 UTC, 0 replies.
- Multiple windows on a single stream - posted by Carsten <ca...@ccmanalysis.de> on 2018/02/16 23:39:14 UTC, 2 replies.
- [jira] [Created] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB - posted by "Jahandar Musayev (JIRA)" <ji...@apache.org> on 2018/02/17 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8686) Improve basic embedded SQL client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/17 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/02/17 18:12:00 UTC, 0 replies.
- Reading a single input file in parallel? - posted by Niels Basjes <Ni...@basjes.nl> on 2018/02/18 12:28:11 UTC, 2 replies.
- Flink 1.3.2 -- mvn clean package -Pbuild-jar command takes to much time - posted by "Melekh, Gregory" <gm...@intl.att.com> on 2018/02/18 14:38:13 UTC, 2 replies.
- [jira] [Created] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/02/18 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8689) Add runtime support of distinct filter using MapView for GenerateAggregation - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/02/18 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/02/18 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8691) Update table API to support distinct operator on data stream - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/02/18 16:20:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8692) Mistake in MyMapFunction code snippet - posted by "Matt Hagen (JIRA)" <ji...@apache.org> on 2018/02/18 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/02/18 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8694) Make notifyDataAvailable call reliable - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/19 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8695) Move RocksDB State Backend from 'flink-contrib' to 'flink-state-backends' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/19 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8696) Remove JobManager local mode from the Unix Shell Scripts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/19 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/19 10:54:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8698) Use Flip-6 MiniCluster in Local(Stream)Environment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/19 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/19 12:20:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 3.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/02/19 12:25:36 UTC, 2 replies.
- [CANCEL] Release flink-shaded 3.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/02/19 13:00:23 UTC, 0 replies.
- [VOTE] Release flink-shaded 3.0, release candidate #2 - posted by Chesnay Schepler <ch...@apache.org> on 2018/02/19 13:13:16 UTC, 3 replies.
- [jira] [Created] (FLINK-8700) Port tests from FlinkMiniCluster to MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/19 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8701) Migrate SavepointMigrationTestBase to MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/19 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/19 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8702) Migrate tests from FlinkMiniCluster to MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/19 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/19 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8705) Integrate Remote(Stream)Environment with Flip-6 cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/19 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8706) Supported Data Types - Six or Seven - posted by "Matt Hagen (JIRA)" <ji...@apache.org> on 2018/02/19 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8707) Excessive amount of files opened by flink task manager - posted by "Alexander Gardner (JIRA)" <ji...@apache.org> on 2018/02/19 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8708) Unintended integer division in StandaloneThreadedGenerator - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/02/19 19:25:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8709) Flaky test: SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/02/19 21:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8710) AbstractYarnClusterDescriptor doesn't use pre-defined configs in Hadoop's YarnConfiguration - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/02/20 00:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8711) Flink with YARN use wrong SlotsPerTaskManager - posted by "Aleksandr (JIRA)" <ji...@apache.org> on 2018/02/20 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/20 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8713) FileInputFormatTest.testGetStatisticsMultipleOneFileWithCachedVersion unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/20 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8714) Suggest new users to use env.readTextFile method with 2 arguments (using the charset), not to rely on system charset (which varies across environments) - posted by "Michal Klempa (JIRA)" <ji...@apache.org> on 2018/02/20 12:09:04 UTC, 0 replies.
- [jira] [Created] (FLINK-8715) RocksDB does propagate reconfiguration of serializer to the states - posted by "Arvid Heise (JIRA)" <ji...@apache.org> on 2018/02/20 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8716) AvroSerializer does not use schema of snapshot - posted by "Arvid Heise (JIRA)" <ji...@apache.org> on 2018/02/20 12:58:00 UTC, 0 replies.
- Save the date: ApacheCon North America, September 24-27 in Montréal - posted by Rich Bowen <rb...@apache.org> on 2018/02/20 14:21:23 UTC, 0 replies.
- [jira] [Created] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating - posted by "Romain Revol (JIRA)" <ji...@apache.org> on 2018/02/20 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/20 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8719) add module description for flink-contrib to clarify its purpose - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/02/20 19:02:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8720) Logging exception - posted by "dejan miljkovic (JIRA)" <ji...@apache.org> on 2018/02/20 22:09:00 UTC, 0 replies.
- Verifying watermarks in integration test - posted by Thomas Weise <th...@apache.org> on 2018/02/21 06:09:11 UTC, 4 replies.
- HAQueryableStateRocksDBBackendITCase test cause outofmemoryerror and never stop - posted by mingleizhang <zm...@163.com> on 2018/02/21 08:07:46 UTC, 1 replies.
- [jira] [Created] (FLINK-8721) Client blocks indefinitely if job archiving fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/21 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8722) Refactor BroadcastState examples. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/21 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8723) Remove existing BroadcastState examples. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/21 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8724) Add BroadcastState examples with predetermined state transitions for the broadcast state - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/21 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8725) Separate NFA-state from NFA in CEP library - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/21 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8726) Code highlighting partially broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/21 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8727) Test instability in SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/21 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8728) Fail new worker requests immediately in Standalone mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/21 12:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8729) Migrate JSONGenerator from Slink to Jackson - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/21 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8730) Make SerializedThrowable deserialized from JSON re-throwable - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/21 14:22:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8731) TwoInputStreamTaskTest flaky on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/21 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8732) Cancel scheduling operation when cancelling the ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/21 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8733) fix SpillableSubpartition#spillFinishedBufferConsumers() not counting spilled bytes - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/21 17:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8734) SpillableSubpartition does not update byte statistics when spilled by a SpillableSubpartitionView - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/21 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8735) Add savepoint migration ITCase that covers operator state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/21 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8736) Memory segment offsets for slices of slices are wrong - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/21 17:10:00 UTC, 0 replies.
- FINAL REMINDER: CFP for Apache EU Roadshow Closes 25th February - posted by Sharan F <sh...@apache.org> on 2018/02/21 17:11:38 UTC, 0 replies.
- [jira] [Created] (FLINK-8737) Creating a union of UnionGate instances will fail with UnsupportedOperationException when retrieving buffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/21 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8738) Converge runtime dependency versions for 'scala-lang' and for 'com.typesafe:config' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/21 18:17:00 UTC, 0 replies.
- [DISCUSS] Move Flink Docker Files from Flink to 'docker-flink' - posted by Stephan Ewen <se...@apache.org> on 2018/02/21 21:41:37 UTC, 3 replies.
- [jira] [Created] (FLINK-8739) Optimize runtime support for distinct filter to reuse same distinct accumulator for filtering - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/02/21 22:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8740) Job-level metrics lost during job re-submission in HA mode - posted by "Joshua DeWald (JIRA)" <ji...@apache.org> on 2018/02/21 22:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8741) KafkaFetcher09/010/011 uses wrong user code classloader - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/02/22 08:43:03 UTC, 0 replies.
- [DISCUSS] Release Flink 1.4.2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/22 08:46:39 UTC, 7 replies.
- [jira] [Created] (FLINK-8742) Move ConfigDocsGenerator annotationt to flink-annotations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/22 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8743) Add annotation to override documented default - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/22 08:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-8744) Add annotations for documentation common/advanced options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/22 08:58:03 UTC, 0 replies.
- Serious memory leak in DefaultOperatorStateBackend - posted by Gyula Fóra <gy...@gmail.com> on 2018/02/22 10:10:16 UTC, 5 replies.
- [jira] [Created] (FLINK-8745) Reduce travis usage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/22 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8746) Support rescaling of jobs which are not fully running - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/22 11:44:00 UTC, 0 replies.
- apache beam in spring cloud dataflow - posted by shankara <sh...@gmail.com> on 2018/02/22 13:35:26 UTC, 1 replies.
- [jira] [Created] (FLINK-8747) The tag of waiting for floating buffers in RemoteInputChannel should be updated properly - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/02/22 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8748) Cancel slot requests for alternatively completed slots in SlotPool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/22 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8749) Release slots when scheduling operation is canceled in ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/22 16:14:00 UTC, 0 replies.
- How to use Dimension table in Flink TableAPI with StreamExecutionEnvironment ? - posted by 叶振宝 <82...@qq.com> on 2018/02/22 16:34:57 UTC, 4 replies.
- [jira] [Created] (FLINK-8750) InputGate may contain data after an EndOfPartitionEvent - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/22 17:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8751) Canceling a job results in a InterruptedException in the JM - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/02/23 05:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8752) ClassNotFoundException when using the user code class loader - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/02/23 05:14:00 UTC, 0 replies.
- Does `flink-connector-filesystem` work with Hadoop-Free Flink? - posted by Jamie Grier <jg...@lyft.com> on 2018/02/23 05:31:15 UTC, 5 replies.
- [jira] [Created] (FLINK-8753) Introduce Incremental savepoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/23 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8754) TaskManagerInfo is not serializable - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/23 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8755) SpilledSubpartitionView wrongly relys on the backlog for determining whether more data is available - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/23 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/23 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8757) Add MiniClusterResource.getClusterClient() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/23 10:14:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8758) Expose method for non-blocking job submission on ClusterClient - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/23 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8759) Bump Netty to 4.0.56 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/23 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8760) Correctly set `moreAvailable` flag in SingleInputGate and UnionInputGate - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/23 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8761) Various improvements to the Quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8763) Remove obsolete Dummy.java classes from quickstart projects. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:17:16 UTC, 0 replies.
- [jira] [Created] (FLINK-8762) Remove unnecessary examples and make "StreamingJob" the default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8764) Make quickstarts work out of the box for IDE and JAR packaging - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8765) Simplify quickstart properties - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8766) Pin scala runtime version for Java Quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:21:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8767) Set the maven.compiler.source and .target properties for Java Quickstart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/23 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8768) Change {{NettyMessageDecoder}} to inherit from {{LengthFieldBasedFrameDecoder}} - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/23 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8769) Quickstart job submission logs contain several exceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/23 13:25:00 UTC, 0 replies.
- RowSerializer - posted by Radu Tudoran <ra...@huawei.com> on 2018/02/23 13:44:06 UTC, 2 replies.
- [jira] [Created] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception" - posted by "Xinyang Gao (JIRA)" <ji...@apache.org> on 2018/02/23 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8771) Upgrade scalastyle to 1.0.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/02/23 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8772) FlinkKafkaConsumerBase partitions discover missing a log parameter - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2018/02/24 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8773) Make shut down of JobManagerRunner non blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/24 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8774) Make shut down of ResourceManagerRunner non blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/24 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8775) Make shut down of MiniCluster non blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/24 15:35:00 UTC, 0 replies.
- Flink Table 1.5-SNAPSHOT - posted by Pavel Ciorba <pa...@gmail.com> on 2018/02/24 17:40:55 UTC, 4 replies.
- [jira] [Created] (FLINK-8776) Cannot submit jobs from Web UI in FLIP-6 YARN Session - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/25 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8777) improve resource release when recovery from failover - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/26 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8778) Migrate queryable state ITCases to use MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/26 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/26 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8780) Add Broadcast State documentation. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/26 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8781) Try to reschedule failed tasks to previous allocation - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/02/26 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8782) Rmove count agg if it is generated for sum agg in over window - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/02/26 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8783) Test instability SlotPoolRpcTest.testExtraSlotsAreKept - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/26 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8784) Share network buffer pool among different partition operators - posted by "Garrett Li (JIRA)" <ji...@apache.org> on 2018/02/26 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/26 15:09:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8786) SpillableSubpartitionView#getNextBuffer always sets isMoreAvailable to false when switching from spillable to spilled - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/26 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8787) Deploying FLIP-6 YARN session fails - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/26 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8788) Enable quarantine monitor by default - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/26 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8790) Improve performance for recovery from incremental checkpoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/02/26 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8789) StoppableFunctions sometimes not detected - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/26 16:19:00 UTC, 0 replies.
- [DISCUS] Flink SQL Client dependency management - posted by Timo Walther <tw...@apache.org> on 2018/02/26 18:33:55 UTC, 5 replies.
- [jira] [Created] (FLINK-8791) Fix documentation on how to link dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/26 21:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8792) bad semantic of method MessageQueryParameter.convertStringToValue - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/02/27 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8793) Only key with password are hidden in Flink web interface - posted by "Etienne CARRIERE (JIRA)" <ji...@apache.org> on 2018/02/27 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8794) When using BucketingSink, it happens that one of the files is always in the [.in-progress] state - posted by "yanxiaobin (JIRA)" <ji...@apache.org> on 2018/02/27 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8795) Failed to submit JobGraph Apache Flink on Github Master Branch - posted by "kant kodali (JIRA)" <ji...@apache.org> on 2018/02/27 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8796) Update "Upgrading Applications and Flink Versions" for 1.5 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/27 10:45:02 UTC, 0 replies.
- [VOTE] Release 1.4.2, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/27 12:30:34 UTC, 3 replies.
- [jira] [Created] (FLINK-8797) Port AbstractOperatorRestoreTestBase to MiniClusterResource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/27 12:42:00 UTC, 0 replies.
- Checkpointing Event Time Watermarks - posted by vijay kansal <vi...@gmail.com> on 2018/02/27 12:50:01 UTC, 1 replies.
- [jira] [Created] (FLINK-8798) Make commons-logging a parent-first pattern - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/27 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/02/27 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8800) Set Logging to TRACE for org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/27 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/02/27 16:23:00 UTC, 0 replies.
- [RESULT][VOTE] Release flink-shaded 3.0, release candidate #2 - posted by Chesnay Schepler <ch...@apache.org> on 2018/02/28 09:20:13 UTC, 0 replies.
- [jira] [Created] (FLINK-8802) Concurrent serialization without duplicating serializers in state server. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/02/28 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/28 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8804) Bump flink-shaded dependency to 3.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/28 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8805) Optimize EventSerializer.isEvent method - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/02/28 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/02/28 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/28 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8808) Enable RestClusterClient to submit jobs to local Dispatchers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/28 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8809) Decrease maximum value of DirectMemory - posted by "Kirill A. Korinskiy (JIRA)" <ji...@apache.org> on 2018/02/28 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8810) Move end-to-end test scripts to end-to-end module - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/02/28 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8811) Add MiniClusterClient to allow fast MiniCluster operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/02/28 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8812) Possible resource leak in Flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/28 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8813) AutoParallellismITCase fails with Flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/28 18:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8814) Control over the extension of part files created by BucketingSink - posted by "Jelmer Kuperus (JIRA)" <ji...@apache.org> on 2018/02/28 19:52:00 UTC, 0 replies.