dev  

Messages by Thread

• Please review FLINK-9610 Add Kafka partitioner that uses the key to partition by Niels Basjes
• Why not put "FLIP: Network Stack Improvements" into Confluence page? Tony Wei
  • Re: Why not put "FLIP: Network Stack Improvements" into Confluence page? Piotr Nowojski
  • Re: Why not put "FLIP: Network Stack Improvements" into Confluence page? Tony Wei
• Improvements to Mesos Deployments Using Docker Addison Higham
  • Re: Improvements to Mesos Deployments Using Docker Till Rohrmann
• [jira] [Created] (FLINK-9612) Add option for minimal artifacts being pulled in meseos Addison Higham (JIRA)
• [jira] [Created] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay Addison Higham (JIRA)
• [jira] [Created] (FLINK-9610) Add Kafka partitioner that uses the key to partition by Niels Basjes (JIRA)
• [ANNOUNCE] Weekly community update #25. Till Rohrmann
• [jira] [Created] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete mingleizhang (JIRA)
• [jira] [Created] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-9607) Support ParquetTableSink mingleizhang (JIRA)
• [jira] [Created] (FLINK-9606) Support ParquetTableSource mingleizhang (JIRA)
• [jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink mingleizhang (JIRA)
• [jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource mingleizhang (JIRA)
• v1.5 cancel job rest API Jake Croft
  • Re: v1.5 cancel job rest API Dawid Wysakowicz
• [jira] [Created] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) Rinat Sharipov (JIRA)
• [jira] [Created] (FLINK-9602) Extend CommonOption section Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY Sihua Zhou (JIRA)
• [jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function Elias Levy (JIRA)
• [jira] [Created] (FLINK-9599) Implement generic mechanism to receive files via rest Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure Prem Santosh (JIRA)
• [jira] [Created] (FLINK-9597) Flink fail to scale! swy (JIRA)
• [jira] [Created] (FLINK-9596) Ability to configure logging using the same log4j file Rinat Sharipov (JIRA)
• [jira] [Created] (FLINK-9595) Add instructions to docs about ceased support of KPL version used in Kinesis connector Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257 Florian Schmidt (JIRA)
• [jira] [Created] (FLINK-9593) Unify AfterMatch semantics with SQL MATCH_RECOGNIZE Dawid Wysakowicz (JIRA)
• [jira] [Created] (FLINK-9592) Notify on moving into pending/ final state Rinat Sharipov (JIRA)
• [jira] [Created] (FLINK-9591) Remove remnants of distributed-cache logic Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9590) HistogramDump should be immutable Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9589) PythonOperationInfo should be immutable Chesnay Schepler (JIRA)
• [ANNOUNCE] Registration for Flink Forward Berlin is open Fabian Hueske
• [jira] [Created] (FLINK-9588) Reuse the same conditionContext with in a same computationState aitozi (JIRA)
• [jira] [Created] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files Andrei Shumanski (JIRA)
• [jira] [Created] (FLINK-9586) Make collection sources parallelisable Sina Madani (JIRA)
• [jira] [Created] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9584) Unclosed streams in Bucketing-/RollingSink Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9583) Wrong number of TaskManagers' slots after recovery. Truong Duc Kien (JIRA)
• [jira] [Created] (FLINK-9582) dist assemblies access files outside of flink-dist Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9581) Redundant spaces for Collect at sql.md Sergey Nuyanzin (JIRA)
• [jira] [Created] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse Ted Yu (JIRA)
• [jira] [Created] (FLINK-9579) Remove unnecessary check with cep elementQueue aitozi (JIRA)
• [jira] [Created] (FLINK-9578) Allow to define an auto watermark interval in SQL Client Timo Walther (JIRA)
• [jira] [Created] (FLINK-9577) Divide-by-zero in PageRank Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9576) Wrong contiguity documentation Dawid Wysakowicz (JIRA)
• [jira] [Created] (FLINK-9575) Potential race condition when removing JobGraph in HA JIRA
• [jira] [Created] (FLINK-9574) Add a dedicated documentation page for state evolution Tzu-Li (Gordon) Tai (JIRA)
• [DISCUSS] Long-term goal of making flink-table Scala-free Timo Walther
  • Re: [DISCUSS] Long-term goal of making flink-table Scala-free Piotr Nowojski
  • Re: [DISCUSS] Long-term goal of making flink-table Scala-free Till Rohrmann
  • Re: [DISCUSS] Long-term goal of making flink-table Scala-free Fabian Hueske
• Re: WELCOME to dev@flink.apache.org Sandish Kumar HN
  • Re: WELCOME to dev@flink.apache.org Tzu-Li (Gordon) Tai
  • Re: WELCOME to dev@flink.apache.org Sandish Kumar HN
• how to build the connectors and examples from the source Chris Kellogg
  • Re: how to build the connectors and examples from the source Ted Yu
  • Re: how to build the connectors and examples from the source Chesnay Schepler
• Static code analysis for Flink project simeon.arkhipov
  • Re: Static code analysis for Flink project Ted Yu
  • Re: Static code analysis for Flink project Till Rohrmann
  • Re: Static code analysis for Flink project Chesnay Schepler
  • Re: Static code analysis for Flink project Piotr Nowojski
  • Re: Static code analysis for Flink project Chesnay Schepler
  • Re: Static code analysis for Flink project Till Rohrmann
  • Re: Static code analysis for Flink project Joern Kottmann
  • Re: Static code analysis for Flink project Chesnay Schepler
  • Re: Static code analysis for Flink project Joern Kottmann
• [jira] [Created] (FLINK-9573) Check for leadership with leader session id Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-9572) Extend InternalAppendingState with internal stored state access Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9571) Switch to internal states in StateBinder Andrey Zagrebin (JIRA)
• Clarity on Flink 1.5 Rescale mechanism Sampath Bhat
  • Re: Clarity on Flink 1.5 Rescale mechanism Stefan Richter
• [jira] [Created] (FLINK-9570) SQL Client merging environments uses AbstractMap JIRA
• [jira] [Created] (FLINK-9569) Confusing construction of AvroSerializers for generic records Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-9568) Wrong error handling for batch input formats with invalid paths Timo Walther (JIRA)
• [ANNOUNCE] Weekly community update #24 Till Rohrmann
• [jira] [Created] (FLINK-9567) Flink does not release resource in Yarn Cluster mode Shimin Yang (JIRA)
• [jira] [Created] (FLINK-9566) Support listing all jobs in CliFrontend#list Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9565) Evaluating scalar UDFs in parallel yinhua.dai (JIRA)
• [jira] [Created] (FLINK-9564) Expose end-to-end module directory to test scripts Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9563) Migrate integration tests for CEP Deepak Sharma (JIRA)
• [jira] [Created] (FLINK-9562) Wrong wording in flink-optimizer module Alexandr Arkhipov (JIRA)
• [jira] [Created] (FLINK-9561) Lack of the api to set RocksDB Option by flink config aitozi (JIRA)
• [jira] [Created] (FLINK-9560) RateLimiting for FileSystem Etienne CARRIERE (JIRA)
• [jira] [Created] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR Hequn Cheng (JIRA)
• [Proposal] Code Reviewer List Yaz Sh
  • Re: [Proposal] Code Reviewer List Chesnay Schepler
  • Re: [Proposal] Code Reviewer List Fabian Hueske
• [jira] [Created] (FLINK-9558) Memory leaks during usage with disabled checkpointing Rinat Sharipov (JIRA)
• [jira] [Created] (FLINK-9557) FlinkTypeFactory should support BigInteger type JIRA
• [jira] [Created] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable Timo Walther (JIRA)
• [jira] [Created] (FLINK-9555) Support table api in scala shell Jeff Zhang (JIRA)
• [jira] [Created] (FLINK-9554) flink scala shell doesn't work in yarn mode Jeff Zhang (JIRA)
• [jira] [Created] (FLINK-9553) Migrate integration tests for DataSinkITCase Deepak Sharma (JIRA)
• [jira] [Created] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint Truong Duc Kien (JIRA)
• [jira] [Created] (FLINK-9551) FlinkCEP Scala Combining Patterns table has two missing pattern Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9550) FlinkCEP snippet example has some syntax errors Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9548) Flink Apache Kudu Connector Sandish Kumar HN (JIRA)
• [jira] [Created] (FLINK-9547) CEP pattern not called on windowed stream Lucas Resch (JIRA)
• [jira] [Created] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0 Sihua Zhou (JIRA)
• Is there a Slack channel? Pablo Estrada
  • Re: Is there a Slack channel? Chesnay Schepler
• [jira] [Created] (FLINK-9545) Support read file for N times in Flink stream Bowen Li (JIRA)
• FINAL REMINDER: Apache EU Roadshow 2018 in Berlin next week! sharan
• Need help in understanding flink ordering of records Amol S - iProgrammer
• [jira] [Created] (FLINK-9544) Impossible to downgrade kinesis protocole from CBOR to JSON as required by kinesalite Ph.Duveau (JIRA)
• [jira] [Created] (FLINK-9543) Expose JobMaster IDs to metric system Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9542) ExEnv#registerCachedFile should accept Path Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-9540) Apache Flink 1.4.2 S3 Hadooplibrary for Hadoop 2.7 is built for Hadoop 2.8 and fails Razvan (JIRA)
• [jira] [Created] (FLINK-9539) Integrate flink-shaded 4.0 Chesnay Schepler (JIRA)
• [1.4.2] mvn clean package command takes to much time Marvin777
  • Re: [1.4.2] mvn clean package command takes to much time Chesnay Schepler
  • Re: [1.4.2] mvn clean package command takes to much time Marvin777
  • Re: [1.4.2] mvn clean package command takes to much time Chesnay Schepler
  • Re: [1.4.2] mvn clean package command takes to much time Marvin777
• [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. Bowen Li
  • Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. Thomas Weise
  • Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. Till Rohrmann
  • Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. Tzu-Li (Gordon) Tai
  • Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. Tzu-Li (Gordon) Tai
  • Re: [DISCUSS] Flink 1.4 and below STOPS writing to Kinesis after June 12th. Thomas Weise
• [jira] [Created] (FLINK-9538) Make KeyedStateFunction an interface Dawid Wysakowicz (JIRA)
• [jira] [Created] (FLINK-9537) JobManager isolation in session mode Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-9536) Rolling logs using log4j.properties, prevents them from showing on the UI. SUBRAMANYA SURESH (JIRA)
• [jira] [Created] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked. SUBRAMANYA SURESH (JIRA)
• [jira] [Created] (FLINK-9534) CEP aitozi (JIRA)
• [jira] [Created] (FLINK-9533) CEP aitozi (JIRA)
• [jira] [Created] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect Abdul Qadeer (JIRA)
• [jira] [Created] (FLINK-9531) Improve logging during type extraction of the Row type Timo Walther (JIRA)
• [jira] [Created] (FLINK-9530) Task numRecords metrics broken for chains Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9529) Do not expose keyed methods on ProcessFunction.Context Till Rohrmann (JIRA)
• Need help regarding MongoDB oplog tailing using flink. Amol S - iProgrammer
  • Re: Need help regarding MongoDB oplog tailing using flink. Chesnay Schepler
• [WEBSITE] Proposal to rework the Flink website Fabian Hueske
  • Re: [WEBSITE] Proposal to rework the Flink website Stephan Ewen
  • Re: [WEBSITE] Proposal to rework the Flink website Ted Yu
  • Re: [WEBSITE] Proposal to rework the Flink website Ken Krugler
  • Re: [WEBSITE] Proposal to rework the Flink website Aljoscha Krettek
  • Re: [WEBSITE] Proposal to rework the Flink website Fabian Hueske
  • Re: [WEBSITE] Proposal to rework the Flink website Fabian Hueske
• [jira] [Created] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly. Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-9527) Paths initialize with URI are not normalized Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9526) BucketingSink end-to-end test failed on Travis Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Hai Zhou (JIRA)
• Fwd: [DISCUSS] FLIP-6 Problems Renjie Liu
  • Re: [DISCUSS] FLIP-6 Problems Till Rohrmann
  • Re: [DISCUSS] FLIP-6 Problems Renjie Liu
  • Re: [DISCUSS] FLIP-6 Problems Stephan Ewen
  • Re: [DISCUSS] FLIP-6 Problems Renjie Liu
  • Re: [DISCUSS] FLIP-6 Problems Till Rohrmann
  • Re: [DISCUSS] FLIP-6 Problems Renjie Liu
  • Re: [DISCUSS] FLIP-6 Problems Stephan Ewen
  • Re: [DISCUSS] FLIP-6 Problems Renjie Liu
• [jira] [Created] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala yan zhou (JIRA)
• [jira] [Created] (FLINK-9523) Add Kafka examples for Flink Table/SQL API Shuyi Chen (JIRA)
• [jira] [Created] (FLINK-9522) Rework Flink website Fabian Hueske (JIRA)
• Flink Cassandra Sink - Setting TTL for the record Rohan Thimmappa
  • Re: Flink Cassandra Sink - Setting TTL for the record miki haiat
  • Re: Flink Cassandra Sink - Setting TTL for the record Rohan Thimmappa
• Re: Ask for SQL using kafka in Flink Shuyi Chen
  • Re: Ask for SQL using kafka in Flink Will Du
  • Re: Ask for SQL using kafka in Flink Timo Walther
• [jira] [Created] (FLINK-9521) Add build plugin to package table example jar vinoyang (JIRA)
• [jira] [Created] (FLINK-9520) JarFileCreator does not support Java MethodReferences Timo Walther (JIRA)
• [jira] [Created] (FLINK-9519) table example jar did not copy into example dir vinoyang (JIRA)
• [jira] [Created] (FLINK-9518) SSL setup Docs config example has wrong keys password Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9517) Fixing broken links on CLI Docs Yazdan Shirvany (JIRA)
• [DISCUSS] Flink 1.6 features Stephan Ewen
  • Re:[DISCUSS] Flink 1.6 features sihua zhou
  • Re: [DISCUSS] Flink 1.6 features Till Rohrmann
  • Re: [DISCUSS] Flink 1.6 features Che Lui Shum
  • Re: [DISCUSS] Flink 1.6 features Ben Yan
  • Re: [DISCUSS] Flink 1.6 features Stephan Ewen
  • Re: [DISCUSS] Flink 1.6 features Elias Levy
  • Re: [DISCUSS] Flink 1.6 features Elias Levy
  • Re: [DISCUSS] Flink 1.6 features zhangminglei
  • Re: [DISCUSS] Flink 1.6 features zhangminglei
  • Re: [DISCUSS] Flink 1.6 features zhangminglei
  • Re: [DISCUSS] Flink 1.6 features zhangminglei
  • Re: [DISCUSS] Flink 1.6 features sihua zhou
• [ANNOUNCE] Weekly community update #23 Till Rohrmann
• [jira] [Created] (FLINK-9516) Create wrapper with TTL logic for map state Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9515) Create wrapper with TTL logic for list state Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9514) Create wrapper with TTL logic for value state Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9513) Wrap state binder with TTL logic Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9511) Make StateDescriptor configurable with optional TTL Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9510) State TTL API with cleanup on explicit access Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-9509) CLI usage are not same as CLI docs Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9508) General Spell Check on Flink Docs Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition aitozi (JIRA)
• [jira] [Created] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop swy (JIRA)
• [jira] [Created] (FLINK-9505) End-to-end test: Quickstarts for Scala Yazdan Shirvany (JIRA)
• [jira] [Created] (FLINK-9504) Change checkpoint duration log level to debug to avoid too much log aitozi (JIRA)
• [FLINK - 9503] Starter task Deepak Sharma
  • Re: [FLINK - 9503] Starter task Chesnay Schepler

• Earlier messages