osdir.com

Mail Thread Index

• Date Index

[Prev Page][Next Page]

---

• [jira] [Created] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile(), Bowen Li (JIRA)
• [jira] [Created] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala, Andrew Roberts (JIRA)
• Re: [Proposal] Utilities for reading, transforming and creatingStreaming savepoints, bupt_ljy
  • <Possible follow-ups>
  • Re: [Proposal] Utilities for reading, transforming and creatingStreaming savepoints, vino yang
  • Re: [Proposal] Utilities for reading, transforming and creatingStreaming savepoints, 陈梓立
• [Proposal] Utilities for reading, transforming and creating Streaming savepoints, Gyula Fóra
  • <Possible follow-ups>
  • Re: [Proposal] Utilities for reading, transforming and creating Streaming savepoints, Piotr Nowojski
  • Re: [Proposal] Utilities for reading, transforming and creating Streaming savepoints, Gyula Fóra
  • Re: [Proposal] Utilities for reading, transforming and creating Streaming savepoints, Jamie Grier
  • Re: [Proposal] Utilities for reading, transforming and creating Streaming savepoints, Paris Carbone
• [jira] [Created] (FLINK-10166) Dependency problems when executing SQL query in sql-client, Dawid Wysakowicz (JIRA)
• [jira] [Created] (FLINK-10165) JarRunHandler/JarRunRequestBody should allow to pass program arguments as escaped json list, Maciej Prochniak (JIRA)
• [jira] [Created] (FLINK-10164) Add support for resuming from savepoints to StandaloneJobClusterEntrypoint, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10163) Support CREATE VIEW in SQL Client, Timo Walther (JIRA)
• [jira] [Created] (FLINK-10162) Add host in checkpoint detail, xymaqingxiang (JIRA)
• [jira] [Created] (FLINK-10161) Add host in checkpoint detail, xymaqingxiang (JIRA)
• [jira] [Created] (FLINK-10160) Index out of bound when serializing operator state, Zdenek (JIRA)
• ODP: How to handle tests that need docker?, Dominik Wosiński
• How to handle tests that need docker?, Niels Basjes
  • <Possible follow-ups>
  • Re: How to handle tests that need docker?, Till Rohrmann
  • Re: How to handle tests that need docker?, Gary Yao
• [jira] [Created] (FLINK-10159) TestHarness#initializeState(xyz) calls after TestHarness#open() are being silently ignored, Piotr Nowojski (JIRA)
• [VOTE] Release 1.5.3, release candidate #1, Chesnay Schepler
  • <Possible follow-ups>
  • Re: [VOTE] Release 1.5.3, release candidate #1, Till Rohrmann
• ODP: [DISCUSS] Release Flink 1.5.3, Dominik Wosiński
• [jira] [Created] (FLINK-10158) The DataOutputSerializer may consume excessive memory, aitozi (JIRA)
• [jira] [Created] (FLINK-10157) The TTL state not allow `null` state value, chengjie.wu (JIRA)
• [DISCUSS] Release Flink 1.5.3, Chesnay Schepler
  • <Possible follow-ups>
  • Re: [DISCUSS] Release Flink 1.5.3, vino yang
  • Re: [DISCUSS] Release Flink 1.5.3, Chesnay Schepler
  • Re: [DISCUSS] Release Flink 1.5.3, Till Rohrmann
  • Re: [DISCUSS] Release Flink 1.5.3, vino yang
  • Re: [DISCUSS] Release Flink 1.5.3, Timo Walther
  • Re: [DISCUSS] Release Flink 1.5.3, Piotr Nowojski
  • Re: [DISCUSS] Release Flink 1.5.3, Stefan Richter
  • Re: [DISCUSS] Release Flink 1.5.3, Elias Levy
  • Re: [DISCUSS] Release Flink 1.5.3, Chesnay Schepler
• [jira] [Created] (FLINK-10156) Drop the Table.writeToSink() method, Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-10155) JobExecutionException when using evictor followed with map, Prithvi Raj (JIRA)
• [jira] [Created] (FLINK-10154) Make sure we always read at least one record in KinesisConnector, Jamie Grier (JIRA)
• [jira] [Created] (FLINK-10153) Add tutorial section to documentation, Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-10152) Add reverse supported in TableAPI and SQL, Guibo Pan (JIRA)
• [jira] [Created] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource, Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-10150) Inconsistent number of "Records received" / "Records sent", Helmut Zechmann (JIRA)
• [jira] [Created] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so., Rune Skou Larsen (JIRA)
• [jira] [Created] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x, David Haglund (JIRA)
• [jira] [Created] (FLINK-10147) numBytesOut metric lagging behind, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-10146) numBuffersOut not updated properly, Nico Kruber (JIRA)
• [ANNOUNCE] Weekly community update #33, Till Rohrmann
• [jira] [Created] (FLINK-10145) Add replace supported in TableAPI and SQL, Guibo Pan (JIRA)
• [jira] [Created] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages", dalongliu (JIRA)
• [jira] [Created] (FLINK-10143) date_format, sean.miao (JIRA)
• [jira] [Created] (FLINK-10142) Reduce synchronization overhead for credit notifications, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-10141) Reduce lock contention introduced with 1.5, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-10140) Log files are not available via web UI in containerized environment, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10139) Update migration tests for 1.6, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10138) Queryable state (rocksdb) end-to-end test failed on Travis, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10137) YARN: Log completed Containers, Gary Yao (JIRA)
• [jira] [Created] (FLINK-10136) Add REPEAT supported in Table API and SQL, vinoyang (JIRA)
• [jira] [Created] (FLINK-10135) The JobManager doesn't report the cluster-level metrics, Joey Echeverria (JIRA)
• [jira] [Created] (FLINK-10134) UTF-16 support for TextInputFormat, David Dreyfus (JIRA)
• [jira] [Created] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters), Xiangyu Zhu (JIRA)
• [jira] [Created] (FLINK-10132) Incremental cleanup of local expired state with TTL discovered in full snapshot, Andrey Zagrebin (JIRA)
• [Discuss] Outer join support and timestamp assignment for IntervalJoin, Florian Schmidt
  • <Possible follow-ups>
  • Re: [Discuss] Outer join support and timestamp assignment for IntervalJoin, Elias Levy
  • Re: [Discuss] Outer join support and timestamp assignment for IntervalJoin, Fabian Hueske
• [jira] [Created] (FLINK-10131) Improve logging around ResultSubpartition, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file, Keshav Lodhi (JIRA)
• [jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster, Keshav Lodhi (JIRA)
• [jira] [Created] (FLINK-10128) Timeout on transfering jars on travis-ci, buptljy (JIRA)
• [jira] [Created] (FLINK-10127) Add TypeInformation and serializers for JDK7 Instant, Alexey Trenikhin (JIRA)
• [jira] [Created] (FLINK-10126) There should be a Scala DataSource, Alexis Sarda-Espinosa (JIRA)
• [jira] [Created] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState, Ted Yu (JIRA)
• [jira] [Created] (FLINK-10124) Use ByteArrayDataInput/OutputView instead of stream + wrapper, Stefan Richter (JIRA)
• [jira] [Created] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10122) KafkaConsumer should use partitionable state over union state if partition discovery is not active, Stefan Richter (JIRA)
• [jira] [Created] (FLINK-10121) Introduce methods to remove registered operator states, Stefan Richter (JIRA)
• Request contribution permission, 邓林
  • <Possible follow-ups>
  • Re: Request contribution permission, Timo Walther
• [jira] [Created] (FLINK-10120) Support string representation for types like array, buptljy (JIRA)
• [jira] [Created] (FLINK-10119) 存在数据非json格式，使用KafkaJsonTableSource的话，job无法拉起。, sean.miao (JIRA)
• [jira] [Created] (FLINK-10118) Queryable state MapState entry query, Elias Levy (JIRA)
• [jira] [Created] (FLINK-10117) REST API for Queryable State, Elias Levy (JIRA)
• [jira] [Created] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-keyl, Will (JIRA)
• [jira] [Created] (FLINK-10115) Upload Project to WEB UI has issue, Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-10114) Support Orc for StreamingFileSink, zhangminglei (JIRA)
• [jira] [Created] (FLINK-10113) Drop support for pre 1.6 shared buffer state, Dawid Wysakowicz (JIRA)
• [jira] [Created] (FLINK-10112) https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT, Yazdan Shirvany (JIRA)
• [DISCUSS] Improve Tutorials section of documentation, Fabian Hueske
  • <Possible follow-ups>
  • Re: [DISCUSS] Improve Tutorials section of documentation, Aljoscha Krettek
  • Re: [DISCUSS] Improve Tutorials section of documentation, 陈梓立
  • Re: [DISCUSS] Improve Tutorials section of documentation, vino yang
  • Re: [DISCUSS] Improve Tutorials section of documentation, Till Rohrmann
  • Re: [DISCUSS] Improve Tutorials section of documentation, Fabian Hueske
  • Re: [DISCUSS] Improve Tutorials section of documentation, Fabian Hueske
• [ANNOUNCE] Apache Flink 1.6.0 released, Till Rohrmann
  • <Possible follow-ups>
  • Re: [ANNOUNCE] Apache Flink 1.6.0 released, vino yang
• [jira] [Created] (FLINK-10111) Test failure because of HAQueryableStateFsBackendITCase#testMapState thorws NPE, vinoyang (JIRA)
• [RESULT] [VOTE] Release 1.6.0, release candidate #4, Till Rohrmann
• [jira] [Created] (FLINK-10110) Harden e2e Kafka shutdown, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10109) Add documentation for StreamingFileSink, Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException, Xingcan Cui (JIRA)
• [jira] [Created] (FLINK-10107) SQL Client end-to-end test fails for releases, Timo Walther (JIRA)
• [jira] [Created] (FLINK-10106) Include test name in temp directory of e2e test, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated, vinoyang (JIRA)
• [Discussion] Move cluster creation functions from flink-cli.sh to other scripts, Renjie Liu
• [jira] [Created] (FLINK-10104) Job super slow to start, Florian (JIRA)
• [jira] [Created] (FLINK-10103) Refine built-in-functions docs for SQL, Hequn Cheng (JIRA)
• [jira] [Created] (FLINK-10102) EXECUTION_FAILOVER_STRATEGY docs are wrong, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10101) Mesos web ui url is missing., Renjie Liu (JIRA)
• [jira] [Created] (FLINK-10100) Optimizer pushes partitioning past Null-Filter, Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-10099) Rework YarnResourceManagerTest, 陈梓立 (JIRA)
• [jira] [Created] (FLINK-10098) Programmatically select timer storage backend, Elias Levy (JIRA)
• [jira] [Created] (FLINK-10097) More tests to increase StreamingFileSink test coverage, Kostas Kloudas (JIRA)
• [ANNOUNCE] Weekly community update #32, Till Rohrmann
• [VOTE] Release 1.6.0, release candidate #4, Till Rohrmann
  • <Possible follow-ups>
  • Re: [VOTE] Release 1.6.0, release candidate #4, Piotr Nowojski
  • Re: [VOTE] Release 1.6.0, release candidate #4, Chesnay Schepler
  • Re: [VOTE] Release 1.6.0, release candidate #4, Till Rohrmann
  • Re: [VOTE] Release 1.6.0, release candidate #4, Chesnay Schepler
  • Re: [VOTE] Release 1.6.0, release candidate #4, Aljoscha Krettek
  • Re: [VOTE] Release 1.6.0, release candidate #4, Chesnay Schepler
  • Re: [VOTE] Release 1.6.0, release candidate #4, Dawid Wysakowicz
  • Re: [VOTE] Release 1.6.0, release candidate #4, Timo Walther
  • Re: [VOTE] Release 1.6.0, release candidate #4, vino yang
  • Re: [VOTE] Release 1.6.0, release candidate #4, Till Rohrmann
  • Re: [VOTE] Release 1.6.0, release candidate #4, Till Rohrmann
  • Re: [VOTE] Release 1.6.0, release candidate #4, Yaz Sh
  • Re: [VOTE] Release 1.6.0, release candidate #4, Till Rohrmann
  • Re: [VOTE] Release 1.6.0, release candidate #4, Yaz Sh
• [jira] [Created] (FLINK-10096) Metrics report incorrect subtask ids, Piotr Nowojski (JIRA)
• [jira] [Created] (FLINK-10095) Change the serialisation order in TTL value wrapper, Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-10094) Always backup default config for end-to-end tests, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10093) Update StatefulJobWBroadcastStateMigrationITCase, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10092) Update StatefulJobSavepointMigrationITCase, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10091) Update WindowOperatorMigrationTest, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10090) Update ContinuousFileProcessingMigrationTest, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10089) Update FlinkKafkaConsumerBaseMigrationTest, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10088) error when trying to run flink-sql-client on windows, anubhav tarar (JIRA)
• [jira] [Created] (FLINK-10087) Update BucketingSinkMigrationTest, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10086) Update CEPMigrationTest, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10085) Update AbstractOperatorRestoreTestBase, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10084) Migration tests weren't updated for 1.5 & 1.6, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10083) Kafka08ITCase#testOneSourceMultiplePartitions failed on travis, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10082) Initialize StringBuilder in Slf4jReporter with estimated size, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10081) Asynchronous (un)registration of metrics, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10080) Add support for processing time to interval join, Florian Schmidt (JIRA)
• [VOTE] Release 1.6.0, release candidate #3, Till Rohrmann
  • <Possible follow-ups>
  • Re: [VOTE] Release 1.6.0, release candidate #3, Andrey Zagrebin
  • Re: [VOTE] Release 1.6.0, release candidate #3, Till Rohrmann