dev@flink.apache.org, 2017-12

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

- [jira] [Created] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/01 05:19:00 UTC, 0 replies.
- Re: [VOTE] Release 1.4.0, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/12/01 05:47:35 UTC, 5 replies.
- [jira] [Created] (FLINK-8182) Unable to read hdfs file system directory(which contains sub directories) recursively - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/01 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8183) Add native Avro type support to the Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8184) Return raw JsonPlan instead of escaped string value in JobDetailsInfo - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/01 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8185) Make first level flattening optional for input and output - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 12:36:00 UTC, 0 replies.
- Flink 1.4.0-RC2 Hadoop Build - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2017/12/01 12:41:52 UTC, 5 replies.
- [jira] [Created] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/01 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8187) Web client does not print errors - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/01 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8188) Clean up flink-contrib - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/01 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8189) move flink-statebackend-rocksdb out of flink-contrib - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/01 19:53:00 UTC, 0 replies.
- Clean up flink-contrib: Remove flink-streaming-contrib and migrate its class to other modules - posted by Bowen Li <bo...@offerupnow.com> on 2017/12/02 09:10:55 UTC, 0 replies.
- [jira] [Created] (FLINK-8190) Add extra FlinkKafkaConsumer constructors to expose pattern-based topic subscription functionality - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 06:55:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-23 Model Serving - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/04 09:54:10 UTC, 0 replies.
- [CANCEL] [VOTE] Release 1.4.0, release candidate #2 - posted by Aljoscha Krettek <al...@apache.org> on 2017/12/04 09:57:19 UTC, 0 replies.
- [jira] [Created] (FLINK-8192) Properly annotate APIs of all Flink connectors with @Public / @PublicEvolving / @Internal - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/04 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8193) Rework quickstart exclusions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/04 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8194) Disable akka.actor.warn-about-java-serializer-usage to suppress akka warnings when using the Java serializer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/04 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8195) Add Redis Sink - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/04 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8196) Fix Hadoop Servled Dependency Exclusion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/04 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8197) Support include conf directories in flink config - posted by "Hao Sun (JIRA)" <ji...@apache.org> on 2017/12/04 20:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/05 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8199) Annotation for Elasticsearch connector - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/05 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/12/05 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8201) YarnResourceManagerTest causes license checking failure - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2017/12/05 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8202) Update queryable section on configuration page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/05 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8203) Make schema definition of DataStream/DataSet to Table conversion more flexible - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/05 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8204) Failing JobManagerLeaderSessionIDITCase on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/05 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8205) Multi key get - posted by "Martin Eden (JIRA)" <ji...@apache.org> on 2017/12/06 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8206) Clean up and refactor RecordWriter Tests - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8207) Unify TestPooledBufferProvider and TestInfinityBufferProvider - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8208) Reduce mockito usage in RecordWriterTest - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8209) Do not relay on specific method names in LocalBufferPoolTest - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8210) Do not use mockito for collecting results in MockEnvironment - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8211) Rename ResultPartitionWriter to OutputGate - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/06 10:14:00 UTC, 0 replies.
- [VOTE] Release 1.4.0, release candidate #3 - posted by Aljoscha Krettek <al...@apache.org> on 2017/12/06 13:56:08 UTC, 14 replies.
- [jira] [Created] (FLINK-8213) Prevent potential metric-related ClassCastExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/06 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8214) Do not use mockito for collecting results in StreamMockEnvironment - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/06 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8215) Collections codegen exception when constructing Array or Map via SQL API - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/12/07 00:38:00 UTC, 0 replies.
- Performance of docker-flink - posted by Jayant Ameta <wi...@gmail.com> on 2017/12/07 03:48:44 UTC, 0 replies.
- [jira] [Created] (FLINK-8216) Unify test utils in flink-connector-kinesis - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/07 07:21:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8217) Properly annotate APIs of flink-connector-kinesis - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/07 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8218) move flink-connector-kinesis examples from /src to /test - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/07 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8219) Kinesis Connector metrics - posted by "Gary Oslon (JIRA)" <ji...@apache.org> on 2017/12/07 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8220) Define set of network throughput benchmarks in Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/07 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8221) Implement set of network latency benchmarks in Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/07 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8222) Update Scala version - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/07 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8223) Update Hadoop versions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/12/07 18:29:00 UTC, 0 replies.
- Dataworks Summit EU call for abstracts - posted by Alan Gates <al...@gmail.com> on 2017/12/07 18:46:04 UTC, 0 replies.
- TaskManager job lifecycle hooks - posted by Ben Sidhom <si...@google.com.INVALID> on 2017/12/07 21:57:06 UTC, 4 replies.
- [jira] [Created] (FLINK-8224) Should shudownApplication when job terminated in job mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/08 09:38:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency - posted by "Sendoh (JIRA)" <ji...@apache.org> on 2017/12/08 09:38:03 UTC, 0 replies.
- Test conflicts in JoinTest - posted by Xingcan Cui <xi...@gmail.com> on 2017/12/08 11:25:15 UTC, 1 replies.
- [jira] [Created] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/12/09 02:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8227) Optimize the performance of SharedBufferSerializer - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/12/09 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8228) Code cleanup - pointless bitwise expressions - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/12/09 08:16:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8229) Cannot use broadcast in StreamingEnvironment - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/09 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8230) NPE in OrcRowInputFormat on nested structs - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/12/10 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8231) Extend AbstractRestHandler to return response headers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8232) Create RestHandler for long running operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8233) Retrieve ExecutionResult by REST polling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/11 08:46:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8235) Cannot run spotbugs for single module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8236) Allow to set the parallelism of table queries - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/11 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2017/12/11 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8238) StreamTaskTestHarness should only allow one setup call - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8239) Extend StreamTaskTestHarness to support TwoInput head operators - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/11 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8241) Remove ResultPartitionWriter related PrepareForTest annotations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/11 17:23:00 UTC, 0 replies.
- Storing large lists into state per key - posted by Jan Lukavský <je...@seznam.cz> on 2017/12/12 09:23:52 UTC, 10 replies.
- [RESULT][VOTE] Release 1.4.0, release candidate #3 - posted by Aljoscha Krettek <al...@apache.org> on 2017/12/12 09:58:52 UTC, 2 replies.
- [jira] [Created] (FLINK-8242) ClassCastException in OrcTableSource.toOrcPredicate - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/12 11:01:05 UTC, 0 replies.
- [jira] [Created] (FLINK-8243) OrcTableSource should recursively read all files in nested directories of the input path. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/12 11:04:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.4.0 released - posted by Aljoscha Krettek <al...@apache.org> on 2017/12/12 11:46:09 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink 1.4.0 released - posted by Fabian Hueske <fh...@gmail.com> on 2017/12/12 12:39:48 UTC, 0 replies.
- [jira] [Created] (FLINK-8244) There are two zookeeper client created when read data from hbase in the flink yarn session model - posted by "zhanglibing000 (JIRA)" <ji...@apache.org> on 2017/12/12 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8245) Add some interval between logs when requested resources are not available - posted by "Wind (JIRA)" <ji...@apache.org> on 2017/12/12 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8246) Download page must not link to dist.apache.org - posted by "Sebb (JIRA)" <ji...@apache.org> on 2017/12/12 15:57:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/13 01:41:00 UTC, 0 replies.
- Long running Flink job on yarn is getting failed after some time. - posted by Shivam Sharma <28...@gmail.com> on 2017/12/13 07:24:09 UTC, 2 replies.
- [jira] [Created] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 - posted by "jia liu (JIRA)" <ji...@apache.org> on 2017/12/13 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8249) Kinesis Producer dont cpnfigure region - posted by "Joao Boto (JIRA)" <ji...@apache.org> on 2017/12/13 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8250) Remove RecordSerializer#instantiateMetrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/13 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8251) Add some network micro-benchmarks in Flink - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/13 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8252) Convert network benchmarks to streaming benchmarks - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/13 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8253) flink-docs-stable still points to 1.3 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/12/13 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8254) REST API documentation wonky due to shading - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/12/13 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8255) Key expressions on named rows types do not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/13 15:53:02 UTC, 0 replies.
- Issues in migrating code from 1.3.2 to 1.4.0 - posted by Shivam Sharma <28...@gmail.com> on 2017/12/13 18:25:39 UTC, 4 replies.
- [jira] [Created] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException - posted by "Ryan Brideau (JIRA)" <ji...@apache.org> on 2017/12/13 20:15:00 UTC, 6 replies.
- [jira] [Created] (FLINK-8257) Unify the value checks for setParallelism() - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/14 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8258) Enable query configuration for batch queries - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/14 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8259) Release flink 1.4 docker image on dockerhub - posted by "Gytis Zilinskas (JIRA)" <ji...@apache.org> on 2017/12/14 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8260) Document API of Kafka 0.11 Producer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/14 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8261) Typos in the shading exclusion for jsr305 in the quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8262) IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/14 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8264) Add Scala to the parent-first loading patterns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/14 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8265) Missing jackson dependency for flink-mesos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/12/14 20:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8266) Add network memory to ResourceProfile - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/15 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8267) Kinesis Producer example setting Region key - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2017/12/15 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/12/15 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8269) Set netRuntime in JobExecutionResult - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/15 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/16 00:10:00 UTC, 0 replies.
- how to assign jira task to myself ? - posted by Lynch Lee <ji...@gmail.com> on 2017/12/16 04:59:30 UTC, 2 replies.
- [jira] [Created] (FLINK-8271) upgrade AmazonKinesisClient - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/17 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8272) 1.4 & Scala: Exception when querying the state - posted by "Juan Miguel Cejuela (JIRA)" <ji...@apache.org> on 2017/12/17 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8273) Configs shown on JobManager WebUI maybe not the real runtime value - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2017/12/17 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/18 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8276) Annotation for Kafka connector - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/12/18 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8277) Optimize code generation by using local references - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8278) Scala examples in Metric documentation do not compile - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/18 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8280) Enable checkstyle for org.apache.flink.runtime.blob - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable - posted by "brucewoo (JIRA)" <ji...@apache.org> on 2017/12/18 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8282) Transformation with TwoInputStreamOperator fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/18 15:35:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/12/18 16:31:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8284) Custom metrics not being exposed for Prometheus - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/18 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8285) Iterator Data Sink doesn't mention required module - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/18 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8286) Investigate Flink-Yarn-Kerberos integration for flip-6 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/12/18 21:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8287) Flink Kafka Producer docs should clearly state what partitioner is used by default - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/18 23:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8288) Register the web interface url to yarn for yarn job mode - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/12/19 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8 - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2017/12/19 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password - posted by "Lynch Lee (JIRA)" <ji...@apache.org> on 2017/12/19 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8292) Remove unnecessary force cast in DataStreamSource - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2017/12/19 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8293) Rework Flink's type and serialization docs - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8294) Missing examples/links in Data Sink docs - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2017/12/19 12:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-8295) Netty shading does not work properly - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/19 15:41:00 UTC, 0 replies.
- [DISCUSS] FLIP-24 - SQL Client - posted by Timo Walther <tw...@apache.org> on 2017/12/19 15:53:29 UTC, 1 replies.
- Re: [DISCUSS] Service Authorization (SSL client authentication) - posted by Eron Wright <er...@gmail.com> on 2017/12/19 18:16:20 UTC, 0 replies.
- Using SQL with dynamic tables where rows are updated - posted by Ghassan Yammine <Gh...@bazaarvoice.com> on 2017/12/19 20:08:33 UTC, 2 replies.
- [jira] [Created] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/19 20:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8297) RocksDBListState stores whole list in single byte[] - posted by "Jan Lukavský (JIRA)" <ji...@apache.org> on 2017/12/19 20:59:00 UTC, 0 replies.
- Docker images - posted by Felix Cheung <fe...@hotmail.com> on 2017/12/20 03:20:09 UTC, 0 replies.
- Facing issue of long running Flink job on Yarn - posted by Shivam Sharma <28...@gmail.com> on 2017/12/20 09:57:50 UTC, 3 replies.
- [jira] [Created] (FLINK-8298) Shutdown MockEnvironment - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/12/20 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8299) Retrieve ExecutionResult by REST polling - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/20 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8300) Make JobExecutionResult accessible from JobMaster - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/20 16:37:00 UTC, 0 replies.
- Flink-Yarn-Kerberos integration - posted by Shuyi Chen <su...@gmail.com> on 2017/12/20 19:21:36 UTC, 1 replies.
- Can I make my contributions to apache flink as a committer now? - posted by 王振涛 <95...@qq.com> on 2017/12/21 01:49:34 UTC, 1 replies.
- Time-stamp of output from a window operator - posted by Jagadish Venkatraman <ja...@gmail.com> on 2017/12/21 07:10:06 UTC, 3 replies.
- [jira] [Created] (FLINK-8301) Support Unicode in codegen for TableAPI && SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/21 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8302) Support shift_left and shift_right in TableAPI - posted by "DuBin (JIRA)" <ji...@apache.org> on 2017/12/21 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8303) Update Savepoint Compatibility Table for 1.4 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/21 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8304) Document Kubernetes and Flink HA setup - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/12/21 10:57:01 UTC, 0 replies.
- Redis command - posted by miki haiat <mi...@gmail.com> on 2017/12/21 12:49:53 UTC, 1 replies.
- [jira] [Created] (FLINK-8305) Docker port mapping doesn't work for JobManager RPC port on Official Flink image - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2017/12/21 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/12/21 18:53:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments - posted by "Colin Williams (JIRA)" <ji...@apache.org> on 2017/12/22 00:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/22 10:03:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8309) JVM sigsegv crash when enabling async checkpoints - posted by "Kevin Pullin (JIRA)" <ji...@apache.org> on 2017/12/22 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8310) Flink 1.4 Column 'rowtime' not found in any table - posted by "Xuan Nguyen (JIRA)" <ji...@apache.org> on 2017/12/22 20:49:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8311) Flink needs documentation for network access control - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/12/22 22:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/12/23 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8313) Please add REAMD file for flink-web repository - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/12/23 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8314) Add support for Kinesis Firehose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2017/12/23 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2017/12/23 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8316) The CsvTableSink and the CsvInputFormat are not in sync - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/12/23 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8317) Expose met triggering of Savepoints via HTTP - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/12/24 10:57:00 UTC, 0 replies.
- Flink 1.3 -- get data from Cassandra as generic ResultSet and convert it to DataSet - posted by Gregory Melekh <gm...@interwise.com> on 2017/12/24 12:41:04 UTC, 1 replies.
- [jira] [Created] (FLINK-8318) Conflict jackson library with ElasticSearch connector - posted by "Jihyun Cho (JIRA)" <ji...@apache.org> on 2017/12/26 07:39:00 UTC, 0 replies.
- Need to restart flink job on yarn as supervisord does - posted by Shivam Sharma <28...@gmail.com> on 2017/12/26 08:29:29 UTC, 2 replies.
- [jira] [Created] (FLINK-8319) Savepoint restore failing in CEP - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/12/26 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8320) Flink cluster does not work on Java 9 - posted by "Steve Layland (JIRA)" <ji...@apache.org> on 2017/12/26 09:56:00 UTC, 0 replies.
- CEP: Dynamic Patterns - posted by Rafi Aroch <ra...@walkme.com> on 2017/12/26 12:51:25 UTC, 6 replies.
- [jira] [Created] (FLINK-8321) Generate _SUCCESS (map-reduce style) when folder has been written！ - posted by "yanxiaobin (JIRA)" <ji...@apache.org> on 2017/12/26 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8322) support getting existing timers from TimerService - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/12/27 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8323) Fix Mod scala function bug - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/27 15:40:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/28 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8325) Add support for constant parameters in GROUP WINDOW aggregate - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/12/28 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/12/28 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8327) ClassLoader resolution of child-first does not appear to work - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/12/29 07:51:02 UTC, 0 replies.
- [jira] [Created] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/29 17:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8329) Move YarnClient out of YarnClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/29 17:22:05 UTC, 0 replies.
- [jira] [Created] (FLINK-8330) Remove FlinkYarnCLI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/29 17:28:00 UTC, 0 replies.
- Dynamic SessionWindow gaps - posted by Dyana Rose <dy...@salecycle.com> on 2017/12/29 19:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/12/29 21:26:00 UTC, 0 replies.
- Change 'bitwise or' to 'logical or' at StreamExecutionEnvironment.java:1597 - posted by Peter Klavins <kl...@netspace.net.au> on 2017/12/30 00:09:25 UTC, 1 replies.
- [jira] [Created] (FLINK-8332) Move dispose savepoint into ClusterClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/31 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8333) Split command options from deployment options in CliFrontend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/12/31 17:55:00 UTC, 0 replies.