dev  

Messages by Thread

• • Re: Checkpoint metrics. Jamie Grier
  • Re: Checkpoint metrics. Jamie Grier
  • Re: Checkpoint metrics. Jamie Grier
  • Re: Checkpoint metrics. Konstantin Knauf
  • Re: Checkpoint metrics. Jamie Grier
• [jira] [Created] (FLINK-14056) AtOm+Electron+TypedE-Mail KORAY DURGUT (Jira)
• [jira] [Created] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" Bowen Li (Jira)
• [jira] [Created] (FLINK-14054) Enable checkpointing via job configuration Jun Qin (Jira)
• [jira] [Created] (FLINK-14053) blink planner dense_rank corner case bug jackylau (Jira)
• [ANNOUNCE] Zili Chen becomes a Flink committer Till Rohrmann
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Forward Xu
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Dian Fu
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Terry Wang
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Zhu Zhu
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer bupt_ljy
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Benchao Li
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Biao Liu
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Fabian Hueske
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Guowei Ma
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer SHI Xiaogang
  • RE: [ANNOUNCE] Zili Chen becomes a Flink committer xingcanc
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Jark Wu
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Hequn Cheng
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Rong Rong
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Yangze Guo
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Yun Gao
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Yun Tang
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Xintong Song
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Leonard Xu
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Zili Chen
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Paul Lam
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer Becket Qin
  • Re: [ANNOUNCE] Zili Chen becomes a Flink committer zhijiang
• [jira] [Created] (FLINK-14052) Generalize AkkaOptions to RpcOptions Till Rohrmann (Jira)
• [DISCUSS] Drop older versions of Kafka Connectors (0.9, 0.10) for Flink 1.10 Stephan Ewen
• [jira] [Created] (FLINK-14051) Deploy job cluster in attached mode TisonKun (Jira)
• [jira] [Created] (FLINK-14050) Refactor YarnClusterDescriptor inheritance TisonKun (Jira)
• [jira] [Created] (FLINK-14049) Update error message for failed partition updates to include task name Stephan Ewen (Jira)
• [jira] [Created] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment Gyula Fora (Jira)
• [jira] [Created] (FLINK-14047) Hide secret values when displaying user configuration/global job parameters in web UI Till Rohrmann (Jira)
• [jira] [Created] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case hailong wang (Jira)
• [jira] [Created] (FLINK-14045) Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy Gary Yao (Jira)
• [jira] [Created] (FLINK-14044) Reducing synchronization in AsyncWaitOperator Arvid Heise (Jira)
• [jira] [Created] (FLINK-14043) SavepointMigrationTestBase is super slow Till Rohrmann (Jira)
• [jira] [Created] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction Yuval Itzchakov (Jira)
• How to implement grouping set in stream 刘建刚
  • Re: How to implement grouping set in stream Dian Fu
• [jira] [Created] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils TisonKun (Jira)
• [jira] [Created] (FLINK-14040) Enable a cron job to run MiniCluster tests for schedulerNG Zhu Zhu (Jira)
• [jira] [Created] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode Ying Xu (Jira)
• [jira] [Created] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout liupengcheng (Jira)
• [jira] [Created] (FLINK-14037) Deserializing the input/output formats failed: unread block data liupengcheng (Jira)
• [jira] [Created] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type Leonard Xu (Jira)
• [jira] [Created] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem Congxian Qiu(klion26) (Jira)
• [DISCUSS] modular built-in functions Bowen Li
  • Re: [DISCUSS] modular built-in functions Xuefu Z
• [jira] [Created] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final Niels van Kaam (Jira)
• [jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode Zhenqiu Huang (Jira)
• [jira] [Created] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable Yun Tang (Jira)
• [jira] [Created] (FLINK-14031) flink-examples should add blink dependency on flink-examples-table Jimmy Wong (Jira)
• [jira] [Created] (FLINK-14030) Nonequivalent conversion happens in Table planner Leonard Xu (Jira)
• [jira] [Created] (FLINK-14029) Update Flink's Mesos scheduling behavior to reject all expired offers Piyush Narang (Jira)
• [jira] [Created] (FLINK-14028) Support logging aggregation in Python user-defined functions Dian Fu (Jira)
• [jira] [Created] (FLINK-14027) Add documentation for Python user-defined functions Dian Fu (Jira)
• [jira] [Created] (FLINK-14026) Manage the resource of Python worker properly Dian Fu (Jira)
• [jira] [Created] (FLINK-14025) Support to run the Python worker in docker mode Dian Fu (Jira)
• [jira] [Created] (FLINK-14024) Support use-defined metrics in Python user-defined functions Dian Fu (Jira)
• [jira] [Created] (FLINK-14023) Support accessing job parameters in Python user-defined functions Dian Fu (Jira)
• [jira] [Created] (FLINK-14022) Add validation check for places where Python ScalarFunction cannot be used Dian Fu (Jira)
• [jira] [Created] (FLINK-14021) Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node Dian Fu (Jira)
• [jira] [Created] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness Dian Fu (Jira)
• [jira] [Created] (FLINK-14019) Python environment and dependency management Dian Fu (Jira)
• [jira] [Created] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work Dian Fu (Jira)
• [jira] [Created] (FLINK-14017) Support to start up Python worker in process mode Dian Fu (Jira)
• [jira] [Created] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions Dian Fu (Jira)
• [jira] [Created] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution Dian Fu (Jira)
• [jira] [Created] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution Dian Fu (Jira)
• [jira] [Created] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table Dian Fu (Jira)
• [jira] [Created] (FLINK-14012) Failed to start job for consuming Secure Kafka after the job cancel Daebeom Lee (Jira)
• [jira] [Created] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator Alex (Jira)
• Call for approving Elasticsearch 7.x connector vino yang
  • Re: Call for approving Elasticsearch 7.x connector Aljoscha Krettek
• [jira] [Created] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down TisonKun (Jira)
• [jira] [Created] (FLINK-14009) Cron jobs broken due to verifying incorrect NOTICE-binary file Till Rohrmann (Jira)
• [jira] [Created] (FLINK-14008) Flink Scala 2.12 binary distribution contains incorrect NOTICE-binary file Till Rohrmann (Jira)
• [DISCUSS] Retrieval services in non-high-availability scenario Zili Chen
  • Re: [DISCUSS] Retrieval services in non-high-availability scenario Till Rohrmann
  • Re: [DISCUSS] Retrieval services in non-high-availability scenario Zili Chen
  • Re: [DISCUSS] Retrieval services in non-high-availability scenario Till Rohrmann
  • Re: [DISCUSS] Retrieval services in non-high-availability scenario Zili Chen
• [jira] [Created] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API sunjincheng (Jira)
• [jira] [Created] (FLINK-14006) Add doc for how to using Java UDFs in Python API sunjincheng (Jira)
• [jira] [Created] (FLINK-14005) Support Hive version 2.2.0 Xuefu Zhang (Jira)
• 确定取消 Lynn Chen
• [jira] [Created] (FLINK-14004) Define SourceReader interface to verify the integration with StreamOneInputProcessor zhijiang (Jira)
• [ANNOUNCE] Weekly Community Update 2019/33-36 Konstantin Knauf
• [jira] [Created] (FLINK-14003) Add access to customized state other than built in state types Shimin Yang (Jira)
• [jira] [Created] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic Gyula Fora (Jira)
• [jira] [Created] (FLINK-14001) add a API to enable user to get the operator code generated by Flink engine Dezhi Cai (Jira)
• [DISCUSS] Supporting multiple Flink versions vs. tech debt David Morávek
  • Re: [DISCUSS] Supporting multiple Flink versions vs. tech debt David Morávek
• [jira] [Created] (FLINK-14000) Remove legacy ProcessShutDownThread Zhu Zhu (Jira)
• [jira] [Created] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE Dian Fu (Jira)
• [jira] [Created] (FLINK-13998) Fix ORC test failure with Hive 2.0.x Xuefu Zhang (Jira)
• [jira] [Created] (FLINK-13997) Remove legacy LeaderAddressAndId TisonKun (Jira)
• [DISCUSS] Features for Apache Flink 1.10 Gary Yao
  • Re: [DISCUSS] Features for Apache Flink 1.10 Kostas Kloudas
  • Re: [DISCUSS] Features for Apache Flink 1.10 zhijiang
  • Re: [DISCUSS] Features for Apache Flink 1.10 Jark Wu
  • Re: [DISCUSS] Features for Apache Flink 1.10 Dian Fu
  • Re: [DISCUSS] Features for Apache Flink 1.10 Zhu Zhu
  • Re: [DISCUSS] Features for Apache Flink 1.10 Till Rohrmann
  • Re: [DISCUSS] Features for Apache Flink 1.10 Xintong Song
  • Re: [DISCUSS] Features for Apache Flink 1.10 Xuefu Z
  • Re: [DISCUSS] Features for Apache Flink 1.10 Yu Li
  • Re: [DISCUSS] Features for Apache Flink 1.10 Aljoscha Krettek
  • Re: [DISCUSS] Features for Apache Flink 1.10 Biao Liu
• [jira] [Created] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases Chesnay Schepler (Jira)
• [DISCUSS] FLIP-67: Global partitions lifecycle Chesnay Schepler
  • Re: [DISCUSS] FLIP-67: Global partitions lifecycle Till Rohrmann
  • Re: [DISCUSS] FLIP-67: Global partitions lifecycle zhijiang
• [jira] [Created] (FLINK-13995) Fix shading of the licence information of netty Arvid Heise (Jira)
• [ANNOUNCE] Kostas Kloudas joins the Flink PMC Fabian Hueske
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Dian Fu
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Till Rohrmann
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Zili Chen
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Jeff Zhang
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Dawid Wysakowicz
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Forward Xu
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Yu Li
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Zhu Zhu
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC zhijiang
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Jark Wu
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Hequn Cheng
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Thomas Weise
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Gary Yao
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC ying
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Kurt Young
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Xintong Song
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC vino yang
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Peter Huang
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC myasuka
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Becket Qin
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Yun Gao
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Kostas Kloudas
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC JingsongLee
  • Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Biao Liu
• [VOTE] Release 1.8.2, release candidate #1 Jark Wu
  • Re: [VOTE] Release 1.8.2, release candidate #1 jincheng sun
  • Re: [VOTE] Release 1.8.2, release candidate #1 Dian Fu
  • Re: [VOTE] Release 1.8.2, release candidate #1 Kurt Young
  • Re: [VOTE] Release 1.8.2, release candidate #1 Till Rohrmann
  • Re: [VOTE] Release 1.8.2, release candidate #1 Jark Wu
• [jira] [Created] (FLINK-13994) Translate "Getting Started" overview to Chinese Fabian Hueske (Jira)
• [jira] [Created] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode Guowei Ma (Jira)
• Checkpointing clarification Dominik Wosiński
  • Re: Checkpointing clarification Dian Fu
  • Re: Checkpointing clarification Zhu Zhu
  • Re: Checkpointing clarification Dominik Wosiński
  • Re: Checkpointing clarification Paul Lam
  • Re: Checkpointing clarification Till Rohrmann
• [jira] [Created] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics TisonKun (Jira)
• [jira] [Created] (FLINK-13991) Add git exclusion for 1.9+ features to 1.8 Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-13990) Remove JobModificationException TisonKun (Jira)
• [jira] [Created] (FLINK-13989) Remove legacy ClassloadingProps TisonKun (Jira)
• [jira] [Created] (FLINK-13988) Remove legacy JobManagerMode TisonKun (Jira)
• Is Flink documentation deployment script broken ? Jark Wu
  • Re: Is Flink documentation deployment script broken ? Chesnay Schepler
  • Re: Is Flink documentation deployment script broken ? Jark Wu
• [jira] [Created] (FLINK-13987) add new logs api, see more log files and can see logs by pages lining (Jira)
  • Re: [jira] [Created] (FLINK-13987) add new logs api, see more log files and can see logs by pages lining jing
• [DISCUSS] Support customize state in customized KeyedStateBackend shimin yang
  • Re: [DISCUSS] Support customize state in customized KeyedStateBackend Yu Li
  • Re: [DISCUSS] Support customize state in customized KeyedStateBackend Yun Tang
  • Re: [DISCUSS] Support customize state in customized KeyedStateBackend shimin yang
  • Re: [DISCUSS] Support customize state in customized KeyedStateBackend shimin yang
• [DISCUSS] FLIP-63: Rework table partition support JingsongLee
  • Re: [DISCUSS] FLIP-63: Rework table partition support Biao Liu
  • Re: [DISCUSS] FLIP-63: Rework table partition support JingsongLee
  • Re: [DISCUSS] FLIP-63: Rework table partition support Biao Liu
  • Re: [DISCUSS] FLIP-63: Rework table partition support Kurt Young
  • Re: [DISCUSS] FLIP-63: Rework table partition support JingsongLee
• [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete JingsongLee
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete shimin yang
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete Jark Wu
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete Dian Fu
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete shimin yang
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete Dian Fu
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete shimin yang
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete JingsongLee
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete shimin yang
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete Dian Fu
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete Stephan Ewen
  • Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete JingsongLee
• [DISCUSS] FLIP-66: Support time attribute in SQL DDL Jark Wu
  • Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL Danny Chan
  • Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL Forward Xu
  • Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL Dian Fu
  • Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL Jark Wu
  • Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL Kurt Young

• Earlier messages
• Later messages