You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer - posted by "Bhaskar Divya (JIRA)" <ji...@apache.org> on 2018/01/01 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/01 17:40:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 07:56:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8337) GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8338) Make CustomCommandLines non static in CliFrontend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8340) Do not pass Configuration and configuration directory to CustomCommandLine methods - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8341) Remove unneeded CommandLineOptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8342) Remove ClusterClient generic type argument from ClusterDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8343) Add support for job cluster deployment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8344) Add support for HA to RestClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/01/02 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8346) add S3 signature v4 workaround to docs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/02 13:06:00 UTC, 0 replies.
- Re: Need to restart flink job on yarn as supervisord does - posted by Shivam Sharma <28...@gmail.com> on 2018/01/02 13:12:59 UTC, 1 replies.
- Re: Dynamic SessionWindow gaps - posted by Aljoscha Krettek <al...@apache.org> on 2018/01/02 13:45:49 UTC, 3 replies.
- [jira] [Created] (FLINK-8347) Make Cluster id typesafe - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8348) Print help for DefaultCLI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8349) Remove Yarn specific commands from YarnClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/02 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8350) replace "taskmanager.tmp.dirs" with "env.io.tmp.dirs" for all components - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/02 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8351) Canonical way to extract FoldingState QueryableStateStream - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2018/01/03 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/01/03 02:09:03 UTC, 0 replies.
- Re: [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric - posted by Marvin777 <xy...@gmail.com> on 2018/01/03 03:25:20 UTC, 1 replies.
- Invalid lambda deserialization - posted by Amit Jain <aj...@gmail.com> on 2018/01/03 10:41:41 UTC, 4 replies.
- [jira] [Created] (FLINK-8353) Add support for timezones - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/03 11:09:00 UTC, 0 replies.
- Re: Docker images - posted by Patrick Lucas <pa...@data-artisans.com> on 2018/01/03 12:55:15 UTC, 0 replies.
- [jira] [Created] (FLINK-8354) Flink Kafka connector ingonre Kafka message headers - posted by "Mohammad Abareghi (JIRA)" <ji...@apache.org> on 2018/01/03 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/01/03 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8356) JDBCAppendTableSink does not work for Hbase Phoenix Driver - posted by "Paul Wu (JIRA)" <ji...@apache.org> on 2018/01/03 21:25:04 UTC, 1 replies.
- Re: Flink-Yarn-Kerberos integration - posted by Shuyi Chen <su...@gmail.com> on 2018/01/03 23:43:19 UTC, 3 replies.
- [jira] [Created] (FLINK-8357) enable rolling in default log settings - posted by "Xu Mingmin (JIRA)" <ji...@apache.org> on 2018/01/04 00:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8358) Hostname used by DataDog metric reporter is not configurable - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/01/04 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8359) Update copyright date in NOTICE - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2018/01/04 11:54:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8360) Implement task-local state recovery - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/01/04 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8361) Remove create_release_files.sh - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2018/01/04 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8362) Shade Elasticsearch dependencies away - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/04 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8363) Build Hadoop 2.9.0 convenience binaries - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2018/01/04 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8364) ListState should return empty iterator rather than null when it has no value - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/04 21:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8365) Consider relax List type in HeapListState and HeapKeyedStateBackend - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/04 23:37:00 UTC, 0 replies.
- [SEATTLE MEETUP] Announcing First Seattle Apache Flink Meetup - posted by Bowen Li <bo...@gmail.com> on 2018/01/05 01:57:31 UTC, 0 replies.
- [jira] [Created] (FLINK-8366) Use Row instead of String as key when process upsert results - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/01/05 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8367) Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2018/01/05 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8368) Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2018/01/05 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8369) Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2018/01/05 09:38:00 UTC, 0 replies.
- Re: Using SQL with dynamic tables where rows are updated - posted by Fabian Hueske <fh...@gmail.com> on 2018/01/05 10:31:39 UTC, 6 replies.
- [jira] [Created] (FLINK-8370) Port AbstractAggregatingMetricsHandler to RestServerEndpoint - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/01/05 10:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8371) Buffers are not recycled in a non-spilled SpillableSubpartition upon release - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/05 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8372) NPEs stopping containers via YarnResourceManager and adding Tasks via TaskSlotTable - posted by "Sebastian Bauersfeld (JIRA)" <ji...@apache.org> on 2018/01/05 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8373) Inconsistencies in some FileSystem directory functions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/05 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8374) Unstable Yarn tests due to Akka Shutdown Exception Logging - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/05 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8375) Remove unnecessary synchronization in ResultPartition - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/01/05 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8376) Remove potentially unnecessary synchronization in SpillableSubpartition - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/01/05 14:11:00 UTC, 0 replies.
- Re: [DISCUSS] Service Authorization (SSL client authentication) - posted by Till Rohrmann <tr...@apache.org> on 2018/01/05 14:20:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8377) Document DataViews for user-defined aggregate functions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/05 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8378) Serialization and Deserialization of Kafka Avro messages from and to Row with Confluent Schema Registry - posted by "Christophe Philemotte (JIRA)" <ji...@apache.org> on 2018/01/05 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8379) Improve type checking for DataView - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/05 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8380) Dynamic BucketingSink paths based on ingested Kafka topics - posted by "Kyle Hamlin (JIRA)" <ji...@apache.org> on 2018/01/05 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8381) Document more flexible schema definition - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/05 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8382) sheduleRunAsync with a positive schedule delay does not work in JobMaster - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2018/01/06 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8383) flink-mesos build failing: duplicate Jackson relocation in shaded jar - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/06 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8384) Session Window Assigner with Dynamic Gaps - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2018/01/08 10:28:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8385) Fix exceptions in AbstractEventTimeWindowCheckpointingITCase - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/01/08 10:28:01 UTC, 0 replies.
- Queryable State - Count within Time Window - posted by Velu Mitwa <ve...@gmail.com> on 2018/01/08 14:13:33 UTC, 0 replies.
- [jira] [Created] (FLINK-8386) Scala API cannot create type information for Tuple interface - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/08 14:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8387) Do not allow filter(false) - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/08 15:37:01 UTC, 0 replies.
- aggregate stream of logs - posted by miki haiat <mi...@gmail.com> on 2018/01/08 15:40:23 UTC, 1 replies.
- [jira] [Created] (FLINK-8388) Snapshot documentation redirects to 1.4 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/08 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8389) Release all slots upon closing of JobMaster connection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/08 17:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8390) Refactor Hadoop kerberos integration test code - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/01/08 21:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8391) Improve dependency documentation for queryable state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/01/09 09:54:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-24 - SQL Client - posted by Timo Walther <tw...@apache.org> on 2018/01/09 15:35:07 UTC, 0 replies.
- Issues to work on for newbie to the Flink project - posted by Ashutosh Dubey <pr...@gmail.com> on 2018/01/09 15:47:22 UTC, 2 replies.
- [jira] [Created] (FLINK-8392) Simplify termination future completion - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/09 17:02:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8393) Reconnect to last known JobMaster when connection is lost - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/09 19:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/09 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8395) Create (derived) sliced Buffer class - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/09 21:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8396) Create (derived) duplicate Buffer class - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/09 21:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8397) Support ROW type in CassandraOutputFormat - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/01/10 00:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/10 04:38:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8399) Use independent configurations for the different timeouts in slot manager - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/01/10 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8400) Use the lexicographic smallest attribute as the common group id when extract unique key - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/01/10 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8401) Allow subclass to override write-failure behavior in CassandraOutputFormat - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/01/10 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/10 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8403) Flink Gelly examples hanging without returning result - posted by "flora karniav (JIRA)" <ji...@apache.org> on 2018/01/10 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8404) Mark Flip-6 tests with Flip6 annotation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/10 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8405) Keyed State in broadcasted data steam. - posted by "Marek Barak (JIRA)" <ji...@apache.org> on 2018/01/10 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8406) BucketingSink does not detect hadoop file systems - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/10 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/01/10 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/10 14:28:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/10 14:57:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/11 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/11 09:00:03 UTC, 0 replies.
- Call for Presentations FOSS Backstage open - posted by Isabel Drost-Fromm <is...@apache.org> on 2018/01/11 10:03:34 UTC, 0 replies.
- [jira] [Created] (FLINK-8412) Show outdated warning for 1.3 docs - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/11 10:56:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8413) Checkpointing in flink doesnt maintain the snapshot state - posted by "suganya (JIRA)" <ji...@apache.org> on 2018/01/11 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8414) Gelly performance seriously decreases when using the suggested parallelism configuration - posted by "flora karniav (JIRA)" <ji...@apache.org> on 2018/01/11 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8415) Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/11 19:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/12 00:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/12 00:08:18 UTC, 0 replies.
- [jira] [Created] (FLINK-8418) Kafka08ITCase.testStartFromLatest() times out on Travis - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/12 00:33:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/12 01:46:00 UTC, 0 replies.
- Ordering in ProcessFunction after emitting multiple events from WindowFunction - posted by Michał Stępień <ms...@freeportmetrics.com> on 2018/01/12 11:57:49 UTC, 1 replies.
- [jira] [Created] (FLINK-8420) Timeout exceptions are not properly recognized by RetryingRegistration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/12 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/12 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2018/01/12 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/12 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one - posted by "Joao Boto (JIRA)" <ji...@apache.org> on 2018/01/12 17:35:00 UTC, 0 replies.
- difference b/t filesystem and connector-filesystem - posted by cw7k <cw...@yahoo.com.INVALID> on 2018/01/12 18:22:42 UTC, 4 replies.
- [jira] [Created] (FLINK-8425) SpilledSubpartitionView not protected against concurrent release calls - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/01/12 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8426) Error in Generating Timestamp/Watermakr doc - posted by "Christophe Jolif (JIRA)" <ji...@apache.org> on 2018/01/12 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8427) Checkstyle for org.apache.flink.optimizer.costs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2018/01/12 21:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8428) Implement stream-stream non-window left outer join - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/01/13 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8429) Implement stream-stream non-window right outer join - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/01/13 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8430) Implement stream-stream non-window full outer join - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/01/13 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos - posted by "Dongwon Kim (JIRA)" <ji...@apache.org> on 2018/01/13 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8432) Add openstack swift filesystem - posted by "Jelmer Kuperus (JIRA)" <ji...@apache.org> on 2018/01/14 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8433) Update code example for "Managed Operator State" documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/01/14 17:15:00 UTC, 0 replies.
- When is the scheduled release for 1.4.1 ? We have been waiting for a fix https://issues.apache.org/jira/browse/FLINK-8226 which looks a potential fix - posted by Vishal Santoshi <vi...@gmail.com> on 2018/01/14 17:27:29 UTC, 1 replies.
- [jira] [Created] (FLINK-8434) The new yarn resource manager should take over the running task managers after failover - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/01/15 08:49:00 UTC, 0 replies.
- How to Join a dimension table in flink sql - posted by XiangWei Huang <xw...@gmail.com> on 2018/01/15 10:11:29 UTC, 2 replies.
- [DISCUSS] Releasing Flink 1.4.1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/01/15 10:49:53 UTC, 13 replies.
- [jira] [Created] (FLINK-8435) Adding BloomFilter/HyperLogLog state as Managed once - posted by "Moein Hosseini (JIRA)" <ji...@apache.org> on 2018/01/15 14:48:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/16 10:16:00 UTC, 0 replies.
- Adding expire option to redis connector - posted by miki haiat <mi...@gmail.com> on 2018/01/16 13:08:45 UTC, 0 replies.
- [jira] [Created] (FLINK-8437) SideOutput() API is ambiguous - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/16 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8438) Ensure that implicit Scala TypeInformation works in Eclipse IDE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/16 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8439) Document using a custom AWS Credentials Provider with flink-3s-fs-hadoop - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2018/01/16 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8440) Create Gitter Chanel for Flink users - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/01/16 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8441) serialize values and value separator directly to stream in RocksDBListState - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/16 22:18:00 UTC, 0 replies.
- Flink buffer request blocking leads to low performance - posted by "jian.wang@tendcloud.com" <ji...@tendcloud.com> on 2018/01/17 03:53:44 UTC, 0 replies.
- [jira] [Created] (FLINK-8442) Should recovery the input split when an execution failover with FailoverRegion - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/01/17 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8443) YARNSessionCapacitySchedulerITCase is flakky - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/01/17 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8444) Rework dependency setup docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/17 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8445) hostname used in metric names for taskmanager and jobmanager are not consistent - posted by "Chris Thomson (JIRA)" <ji...@apache.org> on 2018/01/17 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8446) Add support for multiple broadcast states. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/01/17 15:46:00 UTC, 0 replies.
- adding a new cloud filesystem - posted by cw7k <cw...@yahoo.com.INVALID> on 2018/01/17 23:32:21 UTC, 7 replies.
- Re: [DISCUSS] FLIP-23 Model Serving - posted by Fabian Hueske <fh...@gmail.com> on 2018/01/18 12:57:08 UTC, 2 replies.
- [jira] [Created] (FLINK-8457) Documentation for Building from Source is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/01/19 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8458) Add the switch for keeping both the old mode and the new credit-based mode - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/01/19 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/01/19 10:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8460) UtilsTest.testYarnFlinkResourceManagerJobManagerLostLeadership - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/19 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8461) Wrong logger configurations for shaded Netty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/19 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8462) TaskExecutor does not verify RM heartbeat timeouts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/19 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8463) Remove unnecessary thread blocking in RestClient#submitRequest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/19 17:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8464) TestRaftReconfigurationWithSimulatedRpc fails with assertion error - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/01/19 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8465) Retrieve correct leader component address in ClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/19 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8466) MemoryArchivist holding on to last thrown exception prevents the user code classloader from being garbage collected - posted by "Jelmer Kuperus (JIRA)" <ji...@apache.org> on 2018/01/20 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks - posted by "Jelmer Kuperus (JIRA)" <ji...@apache.org> on 2018/01/20 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8468) Allow the sink to be extended - posted by "Ph.Duveau (JIRA)" <ji...@apache.org> on 2018/01/20 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8469) unify RocksDB params in RocksDBPerformanceTest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/21 00:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8470) DelayTrigger and DelayAndCountTrigger in Flink Streaming Window API - posted by "Vijay Kansal (JIRA)" <ji...@apache.org> on 2018/01/22 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8471) Add Flip-6 configuration switch - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/22 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8472) Extend migration tests for Flink 1.4 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/22 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/22 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8474) Add documentation for HBaseTableSource - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/01/22 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8475) Move remaining sections to generated tables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/22 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8476) ConfigConstants#DEFAULT_HA_JOB_MANAGER_PORT unused - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/22 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8477) Add api to support for user to skip the first incomplete window data - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/01/22 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8478) Add support for time-bounded joins in DataStream API - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/22 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8479) Implement TwoInputStreamOperator to join two streams - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/22 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/22 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/22 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8482) Expose option to use min / max / left / right timestamp for joined streamrecords - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/22 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8483) Implement and expose outer joins - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/22 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8484) Kinesis consumer re-reads - posted by "Philip Luppens (JIRA)" <ji...@apache.org> on 2018/01/22 17:16:00 UTC, 0 replies.
- filesystem output partitioning - posted by cw7k <cw...@yahoo.com.INVALID> on 2018/01/22 22:42:30 UTC, 1 replies.
- [jira] [Created] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0 - posted by "Xuan Nguyen (JIRA)" <ji...@apache.org> on 2018/01/22 23:35:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8486) Connector for SOLR - posted by "Davide Gesino (JIRA)" <ji...@apache.org> on 2018/01/23 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8487) State loss after multiple restart attempts - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/01/23 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8488) Dispatcher does not recover jobs - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/01/23 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8489) Data is not emitted by second ElasticSearch connector - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/01/23 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8490) Allow custom docker parameters for docker tasks on Mesos - posted by "Jörg Schad (JIRA)" <ji...@apache.org> on 2018/01/23 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8491) Deprecate ConfigConstants#HA_MODE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/23 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8492) Fix unsupported exception for udtf with multi calc - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/01/23 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8493) Integrate queryable state with Flip-6 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/23 12:59:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/23 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8495) Serve main cluster components log and stdout file - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/23 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8496) WebUI does not display TM MemorySegment metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/01/23 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist - posted by "chris snow (JIRA)" <ji...@apache.org> on 2018/01/23 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator - posted by "Julian Bauß (JIRA)" <ji...@apache.org> on 2018/01/23 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8499) Kryo must not be child-first loaded - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/23 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) - posted by "yanxiaobin (JIRA)" <ji...@apache.org> on 2018/01/24 03:16:00 UTC, 0 replies.
- feedback request FLINK-8384 Dynamic Session Gaps - posted by Dyana Rose <dy...@salecycle.com> on 2018/01/24 08:58:29 UTC, 0 replies.
- [jira] [Created] (FLINK-8501) Use single BlobCacheService per TaskExecutor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/24 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8502) Remove LibraryCacheManager from JobMaster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/24 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/24 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8504) TaskExecutor does not properly deregisters JobManager from JobLeaderService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/24 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8505) SlotManager can reach inconsistent state - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/24 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8506) fullRestarts Gauge not incremented when jobmanager got killed - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/01/24 23:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8507) Upgrade Calcite dependency to 1.16 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/01/25 03:12:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8508) Remove RexSimplify from Flink repo - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/01/25 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8509) Remove SqlGroupedWindowFunction from Flink repo - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/01/25 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8510) Provide access to Delivery envelope in RabbitMQ Source - posted by "Wojciech Luczkow (JIRA)" <ji...@apache.org> on 2018/01/25 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8511) Remove legacy code for the TableType annotation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/25 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8512) HAQueryableStateFsBackendITCase unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/25 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints - posted by "chris snow (JIRA)" <ji...@apache.org> on 2018/01/25 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8514) move flink-connector-wikiedits to Apache Bahir - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/26 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8515) update RocksDBMapState to replace deprecated remove() with delete() - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/01/26 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/01/26 04:27:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8517) StaticlyNestedIterationsITCase.testJobWithoutObjectReuse unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/26 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/26 12:36:00 UTC, 0 replies.
- OperatorChain catch block failing with NPE instead of re-throwing the exception - posted by Joern Kottmann <ko...@gmail.com> on 2018/01/26 15:13:12 UTC, 1 replies.
- Kinesis consumer shard skew - FLINK-8516 - posted by Thomas Weise <th...@apache.org> on 2018/01/26 16:47:00 UTC, 8 replies.
- [jira] [Created] (FLINK-8519) FileAlreadyExistsException on Start Flink Session - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2018/01/27 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8520) CassandraConnectorITCase.testCassandraTableSink unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/29 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/29 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8522) DefaultOperatorStateBackend writes data in checkpoint that is never read. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/01/29 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/01/30 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8524) Incorrect JavaDoc in TypeExtractor.getBinaryOperatorReturnType - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/30 09:05:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8525) How to query state in flink 1.4.0? - posted by "jia liu (JIRA)" <ji...@apache.org> on 2018/01/30 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8526) When use some parallelism, the program will stuck in some setting. - posted by "zhu.qing (JIRA)" <ji...@apache.org> on 2018/01/30 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8527) Making stopping of Flip-6 components non-blocking - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/30 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8528) Bucket MapState of TimeBoundedStreamJoinOperator for improved performance - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/01/30 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8529) Let Yarn entry points use YarnConfigOptions#APPLICATION_MASTER_PORT - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/30 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8530) Enable detached job submission for RestClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/01/30 17:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/30 18:32:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8532) RebalancePartitioner should use Random value for its first partition - posted by "Yuta Morisawa (JIRA)" <ji...@apache.org> on 2018/01/31 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/01/31 08:02:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.5.0 - posted by Aljoscha Krettek <al...@apache.org> on 2018/01/31 09:38:28 UTC, 0 replies.
- [jira] [Created] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration. Will cause Caused by: java.io.FileNotFoundException release file error - posted by "zhu.qing (JIRA)" <ji...@apache.org> on 2018/01/31 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8535) Implement a basic set of table source factories - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/31 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/31 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/31 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8538) Add a Kafka table source factory with JSON format support - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/01/31 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8539) Introduce "CompletedCheckpointStorageLocation" to explicitly handle disposal of checkpoint storage locations - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/31 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8540) FileStateHandles must not attempt to delete their parent directory. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/01/31 15:55:00 UTC, 0 replies.