dev@flink.apache.org, 2018-03

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

- [jira] [Created] (FLINK-8815) EventTime won't work as reduce - posted by "benwang li (JIRA)" <ji...@apache.org> on 2018/03/01 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/01 02:30:00 UTC, 0 replies.
- [VOTE] Release 1.4.2, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/03/01 04:30:14 UTC, 6 replies.
- [jira] [Created] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/01 06:31:00 UTC, 0 replies.
- Proposal - Change shard discovery in Flink Kinesis Connector to use ListShards - posted by Kailash Dayanand <kd...@lyft.com> on 2018/03/01 06:38:32 UTC, 7 replies.
- [jira] [Created] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/01 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8819) Rework travis script to use build stages - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/01 08:29:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.5.0 - posted by shashank734 <sh...@gmail.com> on 2018/03/01 08:56:07 UTC, 3 replies.
- [jira] [Created] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/01 10:08:00 UTC, 0 replies.
- Re: [DISCUS] Flink SQL Client dependency management - posted by Fabian Hueske <fh...@gmail.com> on 2018/03/01 10:38:20 UTC, 1 replies.
- [jira] [Created] (FLINK-8821) Fix BigDecimal divide in AvgAggFunction - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/03/01 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8822) RotateLogFile may not work well when sed version is below 4.2 - posted by "Xin Liu (JIRA)" <ji...@apache.org> on 2018/03/01 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8823) Add network profiling/diagnosing metrics. - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/03/01 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8824) In Kafka Consumers, replace 'getCanonicalClassName()' with 'getClassName()' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/01 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8825) Disallow new String() without charset in checkstyle - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/03/01 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8826) In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/03/01 16:13:00 UTC, 0 replies.
- [DISCUSS] Convert main Table API classes into traits - posted by Timo Walther <tw...@apache.org> on 2018/03/01 18:58:00 UTC, 4 replies.
- [jira] [Created] (FLINK-8827) When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed - posted by "Donghui Xu (JIRA)" <ji...@apache.org> on 2018/03/02 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8828) Add collect method to DataStream / DataSet scala api - posted by "Jelmer Kuperus (JIRA)" <ji...@apache.org> on 2018/03/02 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8829) Flink in EMR(YARN) is down due to Akka communication issue - posted by "Aleksandr Filichkin (JIRA)" <ji...@apache.org> on 2018/03/02 07:44:00 UTC, 0 replies.
- Re: Checkpointing Event Time Watermarks - posted by vijay kansal <vi...@gmail.com> on 2018/03/02 08:06:46 UTC, 1 replies.
- [jira] [Created] (FLINK-8830) YarnResourceManager throws NullPointerException - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/03/02 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8831) Create SQL Client dependencies - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/02 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8832) Create a SQL Client Kafka fat-jar - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/02 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8833) Create SQL Client JSON format fat-jar - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/02 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state - posted by "Daniel Harper (JIRA)" <ji...@apache.org> on 2018/03/02 09:50:00 UTC, 0 replies.
- StreamSQL queriable state - posted by Stefano Bortoli <st...@huawei.com> on 2018/03/02 09:58:07 UTC, 13 replies.
- [jira] [Created] (FLINK-8835) Fix TaskManager config keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/02 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/03/02 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8837) Move DataStreamUtils to package 'experimental'. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/02 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8838) Add Support UNNEST a MultiSet type field - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2018/03/02 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8839) Table source factory discovery is broken in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/02 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8840) Pull out YarnClient initialization out of AbstractYarnClusterDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/02 14:29:00 UTC, 0 replies.
- Re: Verifying watermarks in integration test - posted by Thomas Weise <th...@apache.org> on 2018/03/02 16:33:56 UTC, 0 replies.
- [jira] [Created] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/03/02 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8842) Change default REST port to 8081 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/02 19:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8843) Decouple bind REST address from advertised address - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/02 19:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8844) Export job jar file name or job version property via REST API - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/03/02 22:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8845) Introducing `parallel recovery` mode for fully checkpoint (savepoint) - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/03 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8846) ntroducing `parallel recovery` mode for incremental checkpoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/03 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8847) Modules containing package-info.java are always recompiled - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/03 19:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine. - posted by "Yesheng Ma (JIRA)" <ji...@apache.org> on 2018/03/04 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2018/03/04 17:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8850) SQL Client does not support Event-time - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/04 18:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8851) SQL Client fails if same file is used as default and env configuration - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/04 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8852) SQL Client does not work with new FLIP-6 mode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/04 18:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8853) SQL Client cannot emit query results that contain a rowtime attribute - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/04 18:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/04 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8855) SQL client result serving gets stuck in result-mode=table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/04 18:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8856) Move all interrupt() calls to TaskCanceler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/05 00:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8857) HBase connector read example throws exception at the end. - posted by "Xu Zhang (JIRA)" <ji...@apache.org> on 2018/03/05 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8858) SQL Client to submit long running query in file - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/03/05 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/05 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8860) SlotManager spamming log files - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/05 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8861) Add support for batch queries in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/05 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8862) Support HBase snapshot read - posted by "Xu Zhang (JIRA)" <ji...@apache.org> on 2018/03/05 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8863) Add user-defined function support in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/05 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8864) Add CLI query history - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/05 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8865) Add CLI query code completion in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/05 14:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/05 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2018/03/05 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8868) Support Table Function as Table - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/03/05 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8869) Kafka restore from checkpoint without react to the new add partition to kafka server - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/03/05 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8870) End-to-end tests wrongly pass if md5sum is not installed - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/03/05 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/05 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8872) Yarn detached mode via -yd does not detach - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/05 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8873) move unit tests of KeyedStream.scala from DataStreamTest.scala to KeyedStreamTest.scala - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/03/05 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8874) rewrite Flink docs/dev/stream/operators/process_function.md to recommend using KeyedProcessFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/03/05 21:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8875) Watermark tab on Web Interface should display low watermark in ISO8601 - posted by "Daniel Harper (JIRA)" <ji...@apache.org> on 2018/03/06 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8876) Improve concurrent access handling in stateful serializers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8877) Configure Kryo's log level based on Flink's log level - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8878) Check for concurrent access to Kryo Serializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8879) Add concurrent access check to AvroSerializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8880) Validate configurations for SQL Client - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/03/06 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8881) Accumulators not updated for running jobs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/06 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8882) flink-tests fails with core dump - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/06 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should tread ThreadDeath as fatal. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/06 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8886) Job isolation via scheduling in shared cluster - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/03/06 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/06 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2018/03/06 22:50:00 UTC, 0 replies.
- Incorrect Rest URL - posted by mingleizhang <zm...@163.com> on 2018/03/07 03:14:11 UTC, 4 replies.
- [jira] [Created] (FLINK-8889) Do not override config values in TestBaseUtils#startCluster - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/07 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8890) Compare checkpoints in order in CompletedCheckpoint.checkpointsMatch() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/03/07 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8891) RestServerEndpoint can bind on local address only - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/07 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8892) Travis Build: Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test (integration-tests) on project flink-tests_2.11 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/03/07 18:08:00 UTC, 0 replies.
- Re: [RESULT] [VOTE] Release 1.4.2, release candidate #2 - posted by Tzu-Li Tai <tz...@gmail.com> on 2018/03/08 04:12:51 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.4.2 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/03/08 04:47:16 UTC, 0 replies.
- [jira] [Created] (FLINK-8893) NPE when netty try to allocate directBuffer - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/03/08 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8894) CurrentJobIdsHandler fails to serialize response - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/08 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8895) Job failed when one kafka broker shutdown - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/03/08 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1" - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/08 11:20:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.3.3 with only critical fixes - posted by Aljoscha Krettek <al...@apache.org> on 2018/03/08 15:36:15 UTC, 5 replies.
- [jira] [Created] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/03/08 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8898) Materialize time indicators in conditions of LogicalFilter - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/03/08 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/08 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/08 17:06:01 UTC, 0 replies.
- [jira] [Created] (FLINK-8901) YARN application name for Flink (per-job) submissions claims it is using only 1 TaskManager - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/08 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8902) Re-scaling job sporadically fails with KeeperException - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/08 17:29:00 UTC, 0 replies.
- Re: [DISCUSS] Flink security improvements - posted by Shuyi Chen <su...@gmail.com> on 2018/03/09 00:05:51 UTC, 3 replies.
- Using the BucketingSink with Flink 1.4.0 - posted by lr...@lyft.com, lr...@lyft.com on 2018/03/09 01:11:01 UTC, 0 replies.
- Change build-target to a specific folder - posted by mingleizhang <zm...@163.com> on 2018/03/09 07:00:33 UTC, 6 replies.
- Re: Using the BucketingSink with Flink 1.4.0 - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/03/09 08:43:23 UTC, 2 replies.
- Error : Temporary failure in name resolutionost - posted by mingleizhang <zm...@163.com> on 2018/03/09 08:49:19 UTC, 2 replies.
- [jira] [Created] (FLINK-8903) Error calculation based on rolling window in table API and SQL API - posted by "lilizhao (JIRA)" <ji...@apache.org> on 2018/03/09 09:26:00 UTC, 0 replies.
- [DISCUSS] Add end-to-end tests using Docker Compose - posted by Aljoscha Krettek <al...@apache.org> on 2018/03/09 09:47:14 UTC, 4 replies.
- [jira] [Created] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/09 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8905) RestClusterClient#getMaxSlots returns 0 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/09 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8906) Flip6DefaultCLI is not tested in org.apache.flink.client.cli tests - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/09 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8907) Unable to start the process by start-cluster.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/03/09 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8908) MapSerializer creates new serializer even if key and value serializers are stateless - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/03/09 10:59:00 UTC, 0 replies.
- [DISCUSS] Inverted (child-first) class loading - posted by Stephan Ewen <se...@apache.org> on 2018/03/09 11:21:18 UTC, 5 replies.
- [jira] [Created] (FLINK-8909) pyflink.sh not working with yarn - posted by "Hitesh Tiwari (JIRA)" <ji...@apache.org> on 2018/03/09 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/09 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8911) Add separate script for nightly end-to-end tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/03/09 13:03:00 UTC, 0 replies.
- Machine Learning Library Contribution - posted by Nico Duldhardt <nd...@gmail.com> on 2018/03/09 14:03:14 UTC, 1 replies.
- [jira] [Created] (FLINK-8912) Web UI does not render error messages correctly in FLIP-6 mode - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/09 14:25:00 UTC, 0 replies.
- Flink 1.5-SNAPSHOT on Kubernetes - posted by Pavel Ciorba <pa...@gmail.com> on 2018/03/09 21:03:14 UTC, 0 replies.
- [jira] [Created] (FLINK-8913) RocksDB state backend crashes in hadoop28-scala_2.11-alpine image - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2018/03/09 21:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8914) CEP's greedy() modifier doesn't work - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2018/03/10 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/10 21:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8916) Checkpointing Mode is shown to be always "At Least Once" in Web UI - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/11 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8917) FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient - posted by "jianran.tfh (JIRA)" <ji...@apache.org> on 2018/03/12 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8918) Introduce Runtime Filter Join - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/12 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/03/12 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8920) Split code generated input unboxing code - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/12 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8921) Split code generated call expression - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/12 09:20:03 UTC, 0 replies.
- [jira] [Created] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/12 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8923) Set an uncaught exception handler for ForkJoinPool - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/12 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8924) Add @Old junit category - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/12 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8925) Activate flip6 on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/12 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8926) Shutdown client proxy on test end. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/03/12 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/12 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8928) Improve error message on server binding error. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/03/12 14:22:00 UTC, 0 replies.
- [VOTE] Release 1.3.3, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/03/12 16:09:53 UTC, 3 replies.
- [jira] [Created] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore) - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/03/12 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work - posted by "Wind (JIRA)" <ji...@apache.org> on 2018/03/12 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8931) TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/12 19:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8932) Mesos taskmanager should reserve port for query server - posted by "Jared Stehler (JIRA)" <ji...@apache.org> on 2018/03/12 20:15:00 UTC, 0 replies.
- Starting open source development with Flink - posted by Deepak Sharma <de...@gmail.com> on 2018/03/13 02:39:47 UTC, 1 replies.
- [jira] [Created] (FLINK-8933) Avoid calling Class#newInstance - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/13 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8934) Cancel slot requests for otherwisely fulfilled requests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/13 07:21:00 UTC, 0 replies.
- flink web ui authentication - posted by Sampath Bhat <sa...@gmail.com> on 2018/03/13 10:17:19 UTC, 2 replies.
- [jira] [Created] (FLINK-8935) Implement remaining methods in MiniClusterClient - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/13 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8936) Provide only AWS region or endpoint in line with the SDK - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2018/03/13 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8937) Refactor flink end-to-end test skeleton - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/03/13 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8938) Not remove job graph during job master failover - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2018/03/14 04:12:00 UTC, 0 replies.
- Re: [CANCELLED] [VOTE] Release 1.3.3, release candidate #1 - posted by Tzu-Li Tai <tz...@gmail.com> on 2018/03/14 05:27:13 UTC, 0 replies.
- [jira] [Created] (FLINK-8939) Provide better support for saving streaming data to s3 - posted by "chris snow (JIRA)" <ji...@apache.org> on 2018/03/14 07:52:00 UTC, 0 replies.
- Flip 6 mesos support - posted by Renjie Liu <li...@gmail.com> on 2018/03/14 08:32:33 UTC, 27 replies.
- [VOTE] Release 1.3.3, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/03/14 10:26:48 UTC, 7 replies.
- [jira] [Created] (FLINK-8940) Implement JobMaster#disposeSavepoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/14 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8941) SpanningRecordSerializationTest fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/14 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8942) Pass targer ResourceID to HeartbeatListener#retrievePayload - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/14 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8943) Jobs will not recover if DFS is temporarily unavailable - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/14 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2018/03/14 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8945) Allow customization of the KinesisProxy Interface - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2018/03/14 16:08:00 UTC, 0 replies.
- Correct way to reference Hadoop dependencies in Flink 1.4.0 - posted by lr...@lyft.com, lr...@lyft.com on 2018/03/14 18:38:56 UTC, 4 replies.
- Re: [Proposal] CEP library changes - review request - posted by Aljoscha Krettek <al...@apache.org> on 2018/03/14 20:17:21 UTC, 5 replies.
- [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0 - posted by Aljoscha Krettek <al...@apache.org> on 2018/03/15 00:40:00 UTC, 8 replies.
- [jira] [Created] (FLINK-8946) TaskManager stop sending metrics after JobManager failover - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/03/15 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8947) Timeout handler issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/03/15 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8948) RescalingITCase fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8949) Rest API failure with long URL - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/03/15 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8950) "Materialize" Tables to avoid recomputation. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/15 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/15 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8952) Support setting the parallelism of individual operators of a query - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/15 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/15 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8954) Escape control characters when outputting on SQL Client CLI - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/15 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8955) Port ClassLoaderITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8956) Port RescalingITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8957) Port JMXJobManagerMetricTest to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8958) Port TaskCancelAsyncProducerConsumerITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8959) Port AccumulatorLiveITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8960) Port SavepointITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8961) Port JobRetrievalITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8962) Port AccumulatorErrorITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8964) Port JobSubmissionFailsITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8965) Port TimestampITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8967) Port NetworkStackThroughputITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/15 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8968) Fix native resource leak caused by ReadOptions - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/15 16:11:00 UTC, 0 replies.
- Re: [RESULT] [VOTE] Release 1.3.3, release candidate #2 - posted by Tzu-Li Tai <tz...@gmail.com> on 2018/03/15 19:43:18 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.3.3 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/03/15 20:24:32 UTC, 5 replies.
- [jira] [Created] (FLINK-8969) Move TimerService into state backend - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/03/16 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8970) Add more automated end-to-end tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8971) Create general purpose testing job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8972) Create general purpose DataSet testing job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8974) End-to-end test: Run general purpose DataSet job with failures in standalone mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8975) End-to-end test: Resume from savepoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8976) End-to-end test: Resume with different parallelism - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8977) End-to-end test: Manually resume job after terminal failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8978) End-to-end test: Job upgrade - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8979) Extend Kafka end-to-end tests to run with different versions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8980) End-to-end test: BucketingSink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8981) End-to-end test: Kerberos security - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8982) End-to-end test: Queryable state - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8983) End-to-end test: Confluent schema registry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8984) Disabling credit based flow control deadlocks Flink on checkpoint - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/03/16 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8985) End-to-end test: CLI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8986) End-to-end test: REST - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8987) End-to-end test: Avro state evolution - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8988) End-to-end test: Cassandra connector - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8989) End-to-end test: ElasticSearch connector - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8991) End-to-end test: Ganglia metrics reporter - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8992) Implement source and operator that validate exactly-once - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8994) Add a test operator with keyed state that uses Avro serializer (from schema/by reflection) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8996) Include an operator with broadcast and union state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8997) Add sliding window aggregation to the job - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8998) Add user-defined watermark assigner and timestamp extractor to the test job - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-8999) Ensure the job has an operator with operator state. - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9000) Add automated cluster framework tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9001) Add operators with input type that goes through Kryo serialization (registered/generic/custom) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic) - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9003) Add operators with input type that goes through custom, stateful serialization - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9005) Cluster test: Run general purpose job with failures with Mesos - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9006) Cluster test: Run general purpose job with failures with Yarn and per-job mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9007) Cluster test: Kinesis connector - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9008) End-to-end test: Quickstarts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/16 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few instances are created. - posted by "Pankaj (JIRA)" <ji...@apache.org> on 2018/03/16 13:29:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.5 release testing effort - posted by Till Rohrmann <tr...@apache.org> on 2018/03/16 14:23:59 UTC, 0 replies.
- [jira] [Created] (FLINK-9010) NoResourceAvailableException with FLIP-6 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/16 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9011) YarnResourceManager spamming log file at INFO level - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/16 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9012) Shaded Hadoop S3A end-to-end test failing with S3 bucket in Ireland - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/16 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/16 15:18:00 UTC, 0 replies.
- Re: Yarn deployment takes long on some networks - posted by Aljoscha Krettek <al...@apache.org> on 2018/03/16 17:41:44 UTC, 1 replies.
- [jira] [Created] (FLINK-9014) Adapt BackPressureStatsTracker to work with credit-based flow control - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/16 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9015) Upgrade Calcite dependency to 1.17 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/03/16 22:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9016) Unregister jobs from JobMetricGroup after termination - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/17 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9017) FlinkKafkaProducer011ITCase.testFlinkKafkaProducer011FailBeforeNotify times out on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/18 17:49:00 UTC, 0 replies.
- FLIP-6 / Kubernetes - posted by Thomas Weise <th...@apache.org> on 2018/03/18 20:05:34 UTC, 8 replies.
- [jira] [Created] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/19 01:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9019) Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/19 01:28:00 UTC, 0 replies.
- Flink on Kubernetes issue - posted by Sampath Bhat <sa...@gmail.com> on 2018/03/19 06:56:09 UTC, 3 replies.
- Flink on kubernetes flink-conf.yaml - posted by Sampath Bhat <sa...@gmail.com> on 2018/03/19 07:47:47 UTC, 1 replies.
- [jira] [Created] (FLINK-9020) Move test projects of end-to-end tests in separate modules - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/03/19 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9021) org.apache.flink.table.codegen.CodeGenException: Unsupported call: TUMBLE - posted by "yizhou (JIRA)" <ji...@apache.org> on 2018/03/19 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()` - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/19 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9023) Make full thread dump in case of test timeout - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/03/19 13:07:00 UTC, 0 replies.
- Job manager - Zookeeper HA - posted by Sampath Bhat <sa...@gmail.com> on 2018/03/19 13:36:36 UTC, 2 replies.
- [jira] [Created] (FLINK-9024) IntelliJ IDEA support run and debug Flink code - posted by "chillon.m (JIRA)" <ji...@apache.org> on 2018/03/19 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9025) Problem with convert String to Row - posted by "ChenDonghe (JIRA)" <ji...@apache.org> on 2018/03/19 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/19 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9027) Web UI does not cleanup temporary files - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/19 17:48:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #12 - posted by Till Rohrmann <tr...@apache.org> on 2018/03/19 18:06:11 UTC, 2 replies.
- [jira] [Created] (FLINK-9028) flip6 should check config before starting cluster - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/20 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9029) Getting write permission from HDFS after updating flink-1.40 to flink-1.4.2 - posted by "Mohammad Abareghi (JIRA)" <ji...@apache.org> on 2018/03/20 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9030) JobManager fails to archive job to FS when TM is lost - posted by "Jared Stehler (JIRA)" <ji...@apache.org> on 2018/03/20 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9031) DataSet Job result changes when adding rebalance after union - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/20 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/03/20 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9033) Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/03/20 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9034) State Descriptors drop TypeInformation on serialization - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/20 20:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9035) State Descriptors have broken hashCode() and equals() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/20 20:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9036) Add default value via suppliers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/20 20:23:00 UTC, 0 replies.
- Too many open files - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2018/03/20 21:13:26 UTC, 1 replies.
- [jira] [Created] (FLINK-9037) Test flake Kafka09ITCase#testCancelingEmptyTopic - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/21 08:31:00 UTC, 0 replies.
- Re: Is Hadoop 3.0 integration planned? - posted by Stephan Ewen <se...@apache.org> on 2018/03/21 08:36:39 UTC, 0 replies.
- [jira] [Created] (FLINK-9038) YARNSessionCapacitySchedulerITCase fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/21 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9039) Broken link to Hadoop Setup Guide in docs - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/03/21 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9040) JobVertex#setMaxParallelism does not valid argument - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/21 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/21 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9042) Port ResumeCheckpointManuallyITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/21 10:53:00 UTC, 0 replies.
- Request for contributor permissions - posted by Qi Yu <yu...@gmail.com> on 2018/03/21 11:13:14 UTC, 1 replies.
- [jira] [Created] (FLINK-9043) Flink recover from checkpoint like Spark Streaming - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/03/21 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9044) Fork a new stream in a stream - posted by "Herbert Koelman (JIRA)" <ji...@apache.org> on 2018/03/21 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9045) LocalEnvironment with web UI does not work with flip-6 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/21 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9046) Improve error messages when receiving unexpected messages. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/03/21 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9047) SlotPool can fail to release slots - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/21 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/21 18:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/03/21 20:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9050) Expose operator IO counter metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/21 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9051) Invert flip6 profile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/21 22:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9052) Flink complains when scala.Option is used inside POJO - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/03/22 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9053) RescalingITCase failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/22 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9054) IllegalStateException: Buffer pool is destroyed - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/03/22 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9055) WebUI shows job as Running although not enough resources are available - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/22 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/22 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9057) NPE in CreditBasedSequenceNumberingViewReader when cancelling before initilization was complete - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/22 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9058) Relax ListState.addAll() and ListState.update() to take Iterable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/03/22 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9059) Add support for unified table source and sink declaration in environment file - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/03/22 20:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/03/22 21:42:00 UTC, 0 replies.
- Errors checkpointing to S3 for high-scale jobs - posted by Jamie Grier <jg...@lyft.com> on 2018/03/22 22:46:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2018/03/22 22:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9062) As the Chinese government closed its visit to Google（GFW），the drop-down menu about document on the home page （https://flink.apache.org/） doesn't work . - posted by "PengYang (JIRA)" <ji...@apache.org> on 2018/03/23 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9063) Possible SpillableSubpartitionTest testSpillFinishedBufferConsumers test failure - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/03/23 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9064) Add Scaladoc link to documentation - posted by "Matt Hagen (JIRA)" <ji...@apache.org> on 2018/03/23 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9065) CorrelateITCasse failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/23 12:06:05 UTC, 0 replies.
- [jira] [Created] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/03/23 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9067) End-to-end test: Stream SQL query with failure and retry - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/03/23 23:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9068) Website documentation issue - html tag visible on screen - posted by "SHANKAR GANESH (JIRA)" <ji...@apache.org> on 2018/03/24 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9069) Fix some double semi-colons to single semi-colons, and update checkstyle - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/24 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9070) Improve performance of RocksDBMapState.clear() - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/03/25 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9071) Dataflow programming model documentation example is referencing deprecated RollingSink - posted by "Christophe Jolif (JIRA)" <ji...@apache.org> on 2018/03/25 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9072) Host name with "_" causes cluster exception - posted by "liuzhuo (JIRA)" <ji...@apache.org> on 2018/03/26 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/03/26 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9074) End-to-end test: Resume from retained checkpoints - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/03/26 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9075) BucketingSink S3 does not work on local cluster - posted by "dejan miljkovic (JIRA)" <ji...@apache.org> on 2018/03/26 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9076) Make credit-based floating buffers optional - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/26 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9077) flip6 cluster framework doesn't work on mesos - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/03/26 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/03/26 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9079) Job Id or Job Name in task manager logs - posted by "Rohit Singh (JIRA)" <ji...@apache.org> on 2018/03/26 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak - posted by "Rohit Singh (JIRA)" <ji...@apache.org> on 2018/03/26 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/26 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9082) Submission with higher parallelism than task slots fails with TimeoutException - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/26 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9083) Add async backpressure support to Cassandra Connector - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/26 18:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9084) Upgrade cassandra-driver-core to 3.4.0 to introduce BusyPoolException retries - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/26 18:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9085) Add a rate limiter to the Cassandra Connector - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/26 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9086) Use INTERNAL_HADOOP_CLASSPATHS as classpath for launching Yarn cluster for Scala Shell - posted by "Keda Ruan (JIRA)" <ji...@apache.org> on 2018/03/26 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 20:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9089) Upgrade Orc dependency to 1.4.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 20:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9090) Replace UUID.randomUUID with deterministic PRNG - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 22:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/03/26 23:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9092) End to end test for elasticsearch2.x - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/03/27 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9093) If Google can't be accessed,the document can't be use - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2018/03/27 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9094) AccumulatorLiveITCase unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/27 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9095) Add metrics for Cassandra Connector - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/27 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9096) flip 6 allocates different resources for different jobs - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/03/27 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9097) Jobs can be dropped in HA when job submission fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/27 09:53:00 UTC, 0 replies.
- [DISCUSS] Implement end-to-end tests in Java - posted by Timo Walther <tw...@apache.org> on 2018/03/27 12:00:07 UTC, 7 replies.
- [jira] [Created] (FLINK-9098) ClassLoaderITCase unstable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/03/27 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9099) Failing allocated slots not noticed - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/27 12:46:00 UTC, 0 replies.
- SSL config on Kubernetes - Dynamic IP - posted by Edward Alexander Rojas Clavijo <ed...@gmail.com> on 2018/03/27 12:48:37 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #13 - posted by Till Rohrmann <tr...@apache.org> on 2018/03/27 16:40:19 UTC, 0 replies.
- [jira] [Created] (FLINK-9100) Shadow/Hide password from configuration that is logged to log file - posted by "Szymon Szczypiński (JIRA)" <ji...@apache.org> on 2018/03/27 21:56:00 UTC, 0 replies.
- Compressing files with the Bucketing Sink - posted by lr...@lyft.com, lr...@lyft.com on 2018/03/27 23:59:48 UTC, 2 replies.
- [jira] [Created] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/03/28 08:00:00 UTC, 0 replies.
- Load Shedding - posted by Luis Alves <lm...@gmail.com> on 2018/03/28 09:44:18 UTC, 5 replies.
- [jira] [Created] (FLINK-9102) Make the JobGraph disable queued scheduling for Flip6LocalStreamEnvironment - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/28 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9103) SSL verification on TaskManager when parallelism > 1 - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/03/28 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9104) Re-generate REST API documentation for FLIP-6 - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/29 08:13:00 UTC, 0 replies.
- Subject: Last chance to register for Flink Forward SF (April 10). Get 25% discount - posted by Stephan Ewen <se...@apache.org> on 2018/03/29 09:34:43 UTC, 0 replies.
- [jira] [Created] (FLINK-9105) Table program compiles failed - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/03/29 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9106) Add UnfencedMainThreadExecutor to FencedRpcEndpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/29 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9107) Document timer coalescing for ProcessFunctions - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/29 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9108) invalid ProcessWindowFunction link in Document - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2018/03/29 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9109) Add flink modify command to documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/29 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9110) Building docs with Ruby 2.5 fails if bunder is not globally installed - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/03/29 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9111) SSL Passwords written to log file in plain text - posted by "Vinay (JIRA)" <ji...@apache.org> on 2018/03/29 14:28:00 UTC, 0 replies.
- Adding a part suffix setter to the BucketingSink - posted by lr...@lyft.com, lr...@lyft.com on 2018/03/29 14:55:43 UTC, 1 replies.
- [jira] [Created] (FLINK-9112) Let end-to-end tests upload the components logs in case of a failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/29 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/03/29 16:14:00 UTC, 0 replies.
- Using Slack for online discussions - posted by Thomas Weise <th...@apache.org> on 2018/03/29 17:22:38 UTC, 2 replies.
- [jira] [Created] (FLINK-9114) Enable user-provided, custom CheckpointRecoveryFactory for non-HA deployments - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/30 00:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9115) Support addition of part suffix in BucketingSink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/03/30 00:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9116) Introduce getAll and removeAll for MapState - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/03/30 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9117) Disable artifact download in mesos container environment. - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/03/30 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/03/30 23:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9119) example code error in Concepts & Common API - posted by "chillon.m (JIRA)" <ji...@apache.org> on 2018/03/31 16:18:00 UTC, 0 replies.