osdir.com

Mail Thread Index

• Date Index

[Prev Page][Next Page]

---

• [jira] [Created] (FLINK-11120) The bug of timestampadd handles time, xuqianjin (JIRA)
• [DISCUSS] Enhance convenience of TableEnvironment in TableAPI/SQL, jincheng sun
• [jira] [Created] (FLINK-11119) Incorrect Scala example for Table Function, Denys Fakhritdinov (JIRA)
• [jira] [Created] (FLINK-11118) Refactor and unify rowtime timestamp extractor interface, vinoyang (JIRA)
• [jira] [Created] (FLINK-11117) Migrate connector classes to flink-table-spi, vinoyang (JIRA)
• [jira] [Created] (FLINK-11116) Clean-up temporary files that upon recovery, they belong to no checkpoint., Kostas Kloudas (JIRA)
• [jira] [Created] (FLINK-11115) Port some flink.ml algorithms to table based, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11114) Support wrapping inference pipeline as a UDF function in SQL, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11113) Support periodically update models when inferencing, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11112) Support pipeline import/export, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11111) Create a new set of parameters, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11108) Create a new set of table based ML Pipeline classes, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11110) Support pipeline stage type inference, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11109) Create Table based optimizers, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured, Yun Tang (JIRA)
• [jira] [Created] (FLINK-11106) Remove legacy flink-yarn component, TisonKun (JIRA)
• [NOTICE] Mandatory relocation of Apache git repositories on git-wip-us.apache.org, Daniel Gruno
• [jira] [Created] (FLINK-11105) Add an new implementation of the HighAvailabilityServices using etcd, Yang Wang (JIRA)
• [DISCUSS] Creating last bug fix release for 1.5 branch, Till Rohrmann
  • <Possible follow-ups>
  • Re: [DISCUSS] Creating last bug fix release for 1.5 branch, vino yang
  • Re: [DISCUSS] Creating last bug fix release for 1.5 branch, qi luo
  • Re: [DISCUSS] Creating last bug fix release for 1.5 branch, Ufuk Celebi
  • Re: [DISCUSS] Creating last bug fix release for 1.5 branch, Jeff Zhang
  • Re: [DISCUSS] Creating last bug fix release for 1.5 branch, jincheng sun
• [SURVEY] Usage of flink-python and flink-streaming-python, Till Rohrmann
  • <Possible follow-ups>
  • Re: [SURVEY] Usage of flink-python and flink-streaming-python, Xianda Ke
  • Re: [SURVEY] Usage of flink-python and flink-streaming-python, Xianda Ke
• [ANNOUNCE] Weekly community update #49, Till Rohrmann
• [jira] [Created] (FLINK-11104) LEFT JOIN with Table Function not working, Denys Fakhritdinov (JIRA)
• [jira] [Created] (FLINK-11103) Set a default uncaught exception handler, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-11101) Ineffective openjdk exclusion Presto S3 FileSystem module, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11100) Presto S3 FileSystem E2E test broken, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11099) Migrate flink-table runtime Row Types classes, xuqianjin (JIRA)
• [jira] [Created] (FLINK-11098) Migrate flink-table runtime Row Types classes, xuqianjin (JIRA)
• [jira] [Created] (FLINK-11097) Migrate flink-table runtime io classes, xuqianjin (JIRA)
• [jira] [Created] (FLINK-11096) Create a new table based flink ML package, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11095) Table based ML Pipeline, Weihua Jiang (JIRA)
• [jira] [Created] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in new execution causes NPE on snapshot, Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-11093) Migrate flink-table runtime Function classes, xueyu (JIRA)
• [jira] [Created] (FLINK-11092) Migrate flink-table runtime Selector and Collector classes, xueyu (JIRA)
• Discuss [FLINK-9740] Support group windows over intervals of months, =?gb18030?b?eDFxMWox?=
• [jira] [Created] (FLINK-11090) Unused parameter in WindowedStream.aggregate(), Hequn Cheng (JIRA)
• [jira] [Created] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11089) Log filecache directory removed messages, liuzhaokun (JIRA)
• dev apply, sf lee
• [jira] [Created] (FLINK-11088) Improve Kerberos Authentication using Keytab in YARN proxy user mode, Rong Rong (JIRA)
• [jira] [Created] (FLINK-11086) flink-hadoop-compatibility tests fail for 3.x hadoop versions, Sebastian Klemke (JIRA)
• [jira] [Created] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0, Edward Rojas (JIRA)
• [jira] [Created] (FLINK-11085) flink-s3-fs-presto, Chesnay Schepler (JIRA)
• Apply for permission to solve flink's jira issues, shen lei
  • <Possible follow-ups>
  • Re: Apply for permission to solve flink's jira issues, Timo Walther
• delay one of the datastream when performing join operation on event-time and watermark, Rakesh Kumar
  • <Possible follow-ups>
  • Re: delay one of the datastream when performing join operation on event-time and watermark, jincheng sun
• [jira] [Created] (FLINK-11084) Incorrect ouput after two successive split and select, Shimin Yang (JIRA)
• [jira] [Created] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable, boshu Zheng (JIRA)
• [jira] [Created] (FLINK-11082) Increase backlog only if it is available for consumption, zhijiang (JIRA)
• [DISCUSS] Improvement to Flink Window Operator with Slicing, Rong Rong
• [ANNOUNCE] Flink licensing guide, Till Rohrmann
• [jira] [Created] (FLINK-11081) Support binding port range for REST server, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11079) Update LICENSE and NOTICE files for flnk-storm-examples, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11078) Capability to define the numerical range for running TaskExecutors, TisonKun (JIRA)
• [jira] [Created] (FLINK-11077) Make subtask aware of the timeout of checkpoint and abort the current ongoing asynccheckpoint, aitozi (JIRA)
• [jira] [Created] (FLINK-11076) Processing for Avro generated classes is very slow, Maciej Bryński (JIRA)
• [jira] [Created] (FLINK-11075) Remove redundant code path in CompatibilityUtil, Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-11074) Improve the harness test to make it possible test with state backend, Dian Fu (JIRA)
• [jira] [Created] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer, Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-11072) KafkaITCase.testKeyValueSupport failure, Bowen Li (JIRA)
• [jira] [Created] (FLINK-11071) Dynamic proxy classes cannot be resolved when deserializing job graph, Oleg Zhukov (JIRA)
• Proposal regarding Queryable State, Galen Warren
• [jira] [Created] (FLINK-11070) Add stream-stream non-window cross join, Hequn Cheng (JIRA)
• [jira] [Created] (FLINK-11069) Remove FutureUtil, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-11068) Port Table class to Java, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11067) Port TableEnvironments to Java, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11066) Migrate main Table API classes to flink-table-api-base, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11065) Migrate flink-table runtime classes, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11064) Setup a new flink-table module structure, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11063) Make flink-table Scala-free, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11062) web ui log error, lining (JIRA)
• [jira] [Created] (FLINK-11061) Add travis profile that would run on each commit with scala 2.12, Dawid Wysakowicz (JIRA)
• [jira] [Created] (FLINK-11060) Unable to set number of task manager and slot per task number in scala shell local mode, Jeff Zhang (JIRA)
• [jira] [Created] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout, shuai.xu (JIRA)
• [jira] [Created] (FLINK-11058) FlinkKafkaProducer011 fails when kafka broker crash, cz (JIRA)
• [jira] [Created] (FLINK-11057) where in grammar will cause stream inner join loigcal, yuemeng (JIRA)
• [jira] [Created] (FLINK-11056) Remove MesosApplicationMasterRunner, TisonKun (JIRA)
• [jira] [Created] (FLINK-11055) Allow Queryable State to be transformed on the TaskManager before being returned to the client, Galen Warren (JIRA)
• [jira] [Created] (FLINK-11054) Ingest Long value as TIMESTAMP attribute, Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-11053) Examples in documentation not compiling, Avi Levi (JIRA)
• Re: [DISCUSS] Support Higher-order functions in Flink sql, Zhang, Xuefu
• [jira] [Created] (FLINK-11052) Add Bounded(Group Window) FlatAggregate operator to batch Table API, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11051) Add Bounded(Group Window) FlatAggregate operator to streaming Table API, sunjincheng (JIRA)
• 回复：[DISCUSS] Unified Core API for Streaming and Batch, zhijiang
• [DISCUSS] Support Higher-order functions in Flink sql, winifred.wenhui.tang@xxxxxxxxx
  • <Possible follow-ups>
  • Re: [DISCUSS] Support Higher-order functions in Flink sql, Jark Wu
  • Re: Re: [DISCUSS] Support Higher-order functions in Flink sql, TANG Wen-hui
  • Re: [DISCUSS] Support Higher-order functions in Flink sql, Timo Walther
• [jira] [Created] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound, Liu (JIRA)
• [jira] [Created] (FLINK-11049) Unable to execute partial DAG, Jeff Zhang (JIRA)
• [DISCUSS] Unified Core API for Streaming and Batch, 孙海波
  • <Possible follow-ups>
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, jincheng sun
  • Re:[DISCUSS] Unified Core API for Streaming and Batch, Haibo Sun
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Stephan Ewen
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Wang Feng
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Kurt Young
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Guowei Ma
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Haibo Sun
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Shuai Xu
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Aljoscha Krettek
  • Re: [DISCUSS] Unified Core API for Streaming and Batch, Haibo Sun
• [jira] [Created] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore, Thomas Weise (JIRA)
• [jira] [Created] (FLINK-11047) CoGroupGroupSortTranslationTest does not compile with scala 2.12, Chesnay Schepler (JIRA)
• withPartitioner() vs calling partitionCustom() beforehand, Giannis Evagorou
  • <Possible follow-ups>
  • Re: withPartitioner() vs calling partitionCustom() beforehand, Till Rohrmann
  • Re: withPartitioner() vs calling partitionCustom() beforehand, Giannis Evagorou
• [jira] [Created] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry, luoguohao (JIRA)
• [jira] [Created] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor, Hequn Cheng (JIRA)
• [ANNOUNCE] Call for Presentations Extended for Flink Forward San Francisco 2019, Fabian Hueske
• [jira] [Created] (FLINK-11039) LogicalExchange and HashPartitioner realization, ambition (JIRA)
• [ANNOUNCE] Apache Flink 1.7.0 released, Till Rohrmann
  • <Possible follow-ups>
  • Re: [ANNOUNCE] Apache Flink 1.7.0 released, Hequn Cheng
  • Re: [ANNOUNCE] Apache Flink 1.7.0 released, Dominik Wosiński
  • Re: [ANNOUNCE] Apache Flink 1.7.0 released, Shuyi Chen
  • Re: [ANNOUNCE] Apache Flink 1.7.0 released, Bowen Li
• [jira] [Created] (FLINK-11038) Rewrite Kafka at-least-once it cases, Piotr Nowojski (JIRA)
• [jira] [Created] (FLINK-11037) Introduce another greedy mechanism for distributing floating buffers, zhijiang (JIRA)
• [jira] [Created] (FLINK-11036) Streaming classloader end-to-end test does not work on source releases, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder, zhijiang (JIRA)
• [jira] [Created] (FLINK-11034) Provide "rewriting config” to file system factory , Wei-Che Wei (JIRA)
• [RESULT] [VOTE] Release 1.7.0, release candidate #3, Till Rohrmann
  • <Possible follow-ups>
  • Re: [RESULT] [VOTE] Release 1.7.0, release candidate #3, Tzu-Li Chen
  • Re: [RESULT] [VOTE] Release 1.7.0, release candidate #3, Thomas Weise
  • Re: [RESULT] [VOTE] Release 1.7.0, release candidate #3, Tzu-Li Chen
• [jira] [Created] (FLINK-11032) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-11033) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-11031) How to consume the Hive data in Flink using Scala, Preethi.C (JIRA)
• [jira] [Created] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema, Maciej Bryński (JIRA)
• [jira] [Created] (FLINK-11029) Incorrect parameter in Working with state doc, Yangze Guo (JIRA)
• [jira] [Created] (FLINK-11028) Disable deployment of flink-fs-tests, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11027) JobManagerHAProcessFailureRecoveryITCase#testDispatcherProcessFailure failed on Travis, Kostas Kloudas (JIRA)
• [jira] [Created] (FLINK-11026) Rework creation of sql-client connector/format jars, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11025) Connector shading is inconsistent, Chesnay Schepler (JIRA)
• Looking for relevant sources related to connecting Apache Flink and Edgent., Felipe Gutierrez
  • <Possible follow-ups>
  • Re: Looking for relevant sources related to connecting Apache Flink and Edgent., Kostas Kloudas
  • Re: Looking for relevant sources related to connecting Apache Flink and Edgent., Kostas Kloudas
  • Re: Looking for relevant sources related to connecting Apache Flink and Edgent., Felipe Gutierrez
  • Re: Looking for relevant sources related to connecting Apache Flink and Edgent., Felipe Gutierrez
  • Re: Looking for relevant sources related to connecting Apache Flink and Edgent., Fabian Hueske
• Submitting job with savepoint through StreamExecutionEnvironment, Thomas Weise
  • <Possible follow-ups>
  • Re: Submitting job with savepoint through StreamExecutionEnvironment, Chesnay Schepler