osdir.com

Mail Thread Index

• Date Index

[Prev Page][Next Page]

---

• [jira] [Created] (FLINK-11234) ExternalTableCatalogBuilder unable to build a batch-only table, Eron Wright (JIRA)
• [jira] [Created] (FLINK-11233) Small typo in documentation - Jobs in Flink correspond "do" dataflow graphs., Shuangjiang Li (JIRA)
• [DISCUSSION] Complete restart after successive failures, Gyula Fóra
• [jira] [Created] (FLINK-11232) Empty Start Time of sub-task on web dashboard, BoWang (JIRA)
• [jira] [Created] (FLINK-11231) Unified the definition of Java DataStream and Scala DataStream interface for set parallelism, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large., jiwei (JIRA)
• [jira] [Created] (FLINK-11229) Support ScalarFunction for the where/filter clause., vinoyang (JIRA)
• [jira] [Created] (FLINK-11228) Flink web UI can not read stdout logs, wxmimperio (JIRA)
• Hbase state backend in Flink, Naveen Kumar
  • <Possible follow-ups>
  • Re: Hbase state backend in Flink, Gyula Fóra
  • Re: Hbase state backend in Flink, miki haiat
  • Re: Hbase state backend in Flink, Chen Qin
  • Re: Hbase state backend in Flink, Yu Li
  • Re: Hbase state backend in Flink, Chen Qin
• [jira] [Created] (FLINK-11227) The DescriptorProperties contains some bounds checking errors, Xingcan Cui (JIRA)
• [jira] [Created] (FLINK-11226) Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream, Albert Bikeev (JIRA)
• [jira] [Created] (FLINK-11225) Error state of addedJobGraphs when Dispatcher with concurrent revoking and granting leadership, dongtingting (JIRA)
• [jira] [Created] (FLINK-11224) Log is missing in scala-shell, Jeff Zhang (JIRA)
• [jira] [Created] (FLINK-11223) Time zone problem of row time field, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase, Hequn Cheng (JIRA)
• [ANNOUNCE] Apache Flink 1.5.6 released, Thomas Weise
  • <Possible follow-ups>
  • Re: [ANNOUNCE] Apache Flink 1.5.6 released, jincheng sun
  • Re: [ANNOUNCE] Apache Flink 1.5.6 released, vino yang
  • Re: [ANNOUNCE] Apache Flink 1.5.6 released, Jeff Zhang
  • Re: [ANNOUNCE] Apache Flink 1.5.6 released, Till Rohrmann
  • Re: [ANNOUNCE] Apache Flink 1.5.6 released, Stephan Ewen
• [jira] [Created] (FLINK-11221) Support delimited identifiers in TableAPI, Hequn Cheng (JIRA)
• [jira] [Created] (FLINK-11220) Can not Select row time field in JOIN query, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11219) Upgrade Jackson dependency to 2.9.6, xuqianjin (JIRA)
• =?gb18030?b?u9i4tKO6RGlzY3VzcyBvbiBVcGdyYWRlIENhbGNp?==?gb18030?b?dGUgZGVwZW5kZW5jeSB0byAxLjE4?=, =?gb18030?b?zrTAtNH0ueI=?=
• Discuss on Upgrade Calcite dependency to 1.18, qianjin xu
• [jira] [Created] (FLINK-11218) fix the default restart delay value, lamber-ken (JIRA)
• [jira] [Created] (FLINK-11217) Back to top button is missing in the Joining document and is not properly placed in the Process Function document, leesf (JIRA)
• [jira] [Created] (FLINK-11216) Back to top button is missing in the Joining document and is not properly placed in the Process Function document, leesf (JIRA)
• [jira] [Created] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms, Liu (JIRA)
• [jira] [Created] (FLINK-11214) Support non mergable aggregates for group windows on batch table, Dian Fu (JIRA)
• [jira] [Created] (FLINK-11213) Is there any condition that large amount of redis connection created on each TM?, lzh9 (JIRA)
• [jira] [Created] (FLINK-11212) operator metric key can repalce operator name by operator id, lining (JIRA)
• Re: [DISCUSS] Proposal of external shuffle service, zhijiang
  • <Possible follow-ups>
  • Re: [DISCUSS] Proposal of external shuffle service, zhijiang
• [ANNOUNCE] Apache Flink 1.6.3 released, Tzu-Li (Gordon) Tai
  • <Possible follow-ups>
  • Re: [ANNOUNCE] Apache Flink 1.6.3 released, vino yang
  • Re: [ANNOUNCE] Apache Flink 1.6.3 released, Till Rohrmann
  • Re: [ANNOUNCE] Apache Flink 1.6.3 released, jincheng sun
  • Re: [ANNOUNCE] Apache Flink 1.6.3 released, Stephan Ewen
• [ANNOUNCE] Apache Flink 1.7.1 released, Chesnay Schepler
  • <Possible follow-ups>
  • Re: [ANNOUNCE] Apache Flink 1.7.1 released, Till Rohrmann
  • Re: [ANNOUNCE] Apache Flink 1.7.1 released, vino yang
  • Re: [ANNOUNCE] Apache Flink 1.7.1 released, jincheng sun
  • Re: [ANNOUNCE] Apache Flink 1.7.1 released, Stephan Ewen
• [jira] [Created] (FLINK-11211) ReinterpretDataStreamAsKeyedStreamITCase failed on Travis, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-11210) Enable auto state cleanup strategy for RANGE OVER, Hequn Cheng (JIRA)
• [RESULT] [VOTE] Release 1.6.3, release candidate #1, Tzu-Li (Gordon) Tai
• [jira] [Created] (FLINK-11209) Provide more complete guidance for the log usage documentation, vinoyang (JIRA)
• [RESULT] [VOTE] Release 1.5.6, release candidate #1, Thomas Weise
  • <Possible follow-ups>
  • Re: [RESULT] [VOTE] Release 1.5.6, release candidate #1, Thomas Weise
  • Re: [RESULT] [VOTE] Release 1.5.6, release candidate #1, Chesnay Schepler
  • Re: [RESULT] [VOTE] Release 1.5.6, release candidate #1, Chesnay Schepler
• [RESULT] [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
  • <Possible follow-ups>
  • Re: [RESULT] [VOTE] Release 1.7.1, release candidate #2, Thomas Weise
  • Re: [RESULT] [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
  • Re: [RESULT] [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
• Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors, dhanuka ranasinghe
  • <Possible follow-ups>
  • Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors, Hequn Cheng
  • Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors, dhanuka ranasinghe
  • Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors, dhanuka ranasinghe
  • Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors, Hequn Cheng
  • Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors, dhanuka ranasinghe
• [jira] [Created] (FLINK-11208) Decrease build/testing time of modules, Till Rohrmann (JIRA)
• [ANNOUNCE] Weekly community update #51, Till Rohrmann
• [jira] [Created] (FLINK-11207) Update Apache commons-compress from 1.4.1 to 1.18, Nico Kruber (JIRA)
• [jira] [Created] (FLINK-11206) sql statement parser enhancement, ambition (JIRA)
• [jira] [Created] (FLINK-11205) Task Manager Metaspace Memory Leak, Nawaid Shamim (JIRA)
• Question about Flink optimizer on Stream API, Felipe Gutierrez
• [jira] [Created] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication., kelun wang (JIRA)
• [jira] [Created] (FLINK-11203) FunctionContext of AggregateFunction will not be initialized for window GroupBy, Hequn Cheng (JIRA)
• [jira] [Created] (FLINK-11201) flink-test-utils dependency issue, eugen yushin (JIRA)
• [jira] [Created] (FLINK-11202) log split file, every job has one log file, chauncy (JIRA)
• [jira] [Created] (FLINK-11200) Port DataView classes to flink-table-common, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11199) Support interactive programming in Flink, Jiangjie Qin (JIRA)
• [jira] [Created] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich), Chirag Dewan (JIRA)
• [jira] [Created] (FLINK-11197) Improve migration test comments about how to generate snapshots, Hequn Cheng (JIRA)
• [jira] [Created] (FLINK-11196) Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files, Mark Cho (JIRA)
• [jira] [Created] (FLINK-11195) Extend AbstractS3FileSystemFactory.createHadoopFileSystem to accept URI and Hadoop Configuration, Mark Cho (JIRA)
• [jira] [Created] (FLINK-11192) rockdb customize configuration Covered jobmaster, Fan weiwen (JIRA)
• [jira] [Created] (FLINK-11194) missing Scala 2.12 build of HBase connector, Zhenhao Li (JIRA)
• [jira] [Created] (FLINK-11193) rockdb customize configuration Covered jobmaster, Fan weiwen (JIRA)
• [jira] [Created] (FLINK-11191) Exception in code generation when ambiguous columns in MATCH_RECOGNIZE, Dawid Wysakowicz (JIRA)
• [VOTE] Release 1.6.3, release candidate #1, Tzu-Li (Gordon) Tai
  • <Possible follow-ups>
  • Re: [VOTE] Release 1.6.3, release candidate #1, Chesnay Schepler
  • Re: [VOTE] Release 1.6.3, release candidate #1, Aljoscha Krettek
  • Re: [VOTE] Release 1.6.3, release candidate #1, Timo Walther
  • Re: [VOTE] Release 1.6.3, release candidate #1, Till Rohrmann
  • Re: [VOTE] Release 1.6.3, release candidate #1, Tzu-Li (Gordon) Tai
• [jira] [Created] (FLINK-11190) Log stack trace on declined checkpoint, Daniel Harper (JIRA)
• [jira] [Created] (FLINK-11189) Deprecated documentation for readSequenceFile function, shin chen (JIRA)
• [VOTE] Release 1.5.6, release candidate #1, Thomas Weise
  • <Possible follow-ups>
  • Re: [VOTE] Release 1.5.6, release candidate #1, Chesnay Schepler
  • Re: [VOTE] Release 1.5.6, release candidate #1, Thomas Weise
  • Re: [VOTE] Release 1.5.6, release candidate #1, Chesnay Schepler
  • Re: [VOTE] Release 1.5.6, release candidate #1, Aljoscha Krettek
  • Re: [VOTE] Release 1.5.6, release candidate #1, Timo Walther
  • Re: [VOTE] Release 1.5.6, release candidate #1, Thomas Weise
  • Re: [VOTE] Release 1.5.6, release candidate #1, Chesnay Schepler
  • Re: [VOTE] Release 1.5.6, release candidate #1, Till Rohrmann
  • Re: [VOTE] Release 1.5.6, release candidate #1, Nico Kruber
  • Re: [VOTE] Release 1.5.6, release candidate #1, Thomas Weise
  • Re: [VOTE] Release 1.5.6, release candidate #1, Chesnay Schepler
  • Re: [VOTE] Release 1.5.6, release candidate #1, Fabian Hueske
• [jira] [Created] (FLINK-11188) Bounded over should not enable state retention time, Hequn Cheng (JIRA)
• [DISCUSS] Flink Kerberos Improvement, Rong Rong
  • <Possible follow-ups>
  • Re: [DISCUSS] Flink Kerberos Improvement, Shuyi Chen
  • Re: [DISCUSS] Flink Kerberos Improvement, Rong Rong
• [jira] [Created] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues, Addison Higham (JIRA)
• Re: StreamingFileSink causing AmazonS3Exception, Addison Higham
  • <Possible follow-ups>
  • Re: StreamingFileSink causing AmazonS3Exception, Addison Higham
• [jira] [Created] (FLINK-11186) Support for event-time balancing for multiple Kafka comsumer partitions, Tom Schamberger (JIRA)
• [jira] [Created] (FLINK-11185) StreamSourceOperatorWatermarksTest failed with InterruptedException, Biao Liu (JIRA)
• [jira] [Created] (FLINK-11184) Rework TableSource and TableSink interfaces, Timo Walther (JIRA)
• [jira] [Created] (FLINK-11183) Flink 1.7 wrong memory graphite metrics, Mario Georgiev (JIRA)
• [jira] [Created] (FLINK-11182) JobManagerHACheckpointRecoveryITCase need be improved, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11181) SimpleRecoveryITCaseBase test error, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11179) JoinCancelingITCase#testCancelSortMatchWhileDoingHeavySorting test error, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11178) Check flink-test module for 1.7.1-rc2, sunjincheng (JIRA)
• [jira] [Created] (FLINK-11177) Node health tracker, ryantaocer (JIRA)
• [jira] [Created] (FLINK-11176) Improve the harness tests to use the code-generated operator, Dian Fu (JIRA)
• [jira] [Created] (FLINK-11175) The sample code describing the Processing time used in TableSource is incorrect, vinoyang (JIRA)
• [jira] [Created] (FLINK-11174) flink Metrics Prometheus labels support chinese, Fan weiwen (JIRA)
• [jira] [Created] (FLINK-11173) Proctime Attribute validation throws an incorrect exception message, vinoyang (JIRA)
• [jira] [Created] (FLINK-11172) Remove the max retention time in StreamQueryConfig, Yangze Guo (JIRA)
• [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
  • <Possible follow-ups>
  • Re: [VOTE] Release 1.7.1, release candidate #2, Hequn Cheng
  • Re: [VOTE] Release 1.7.1, release candidate #2, jincheng sun
  • Re: [VOTE] Release 1.7.1, release candidate #2, jincheng sun
  • Re: [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
  • Re: [VOTE] Release 1.7.1, release candidate #2, Timo Walther
  • Re: [VOTE] Release 1.7.1, release candidate #2, Till Rohrmann
  • Re: [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
  • Re: [VOTE] Release 1.7.1, release candidate #2, Chesnay Schepler
• [jira] [Created] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend, Sayat Satybaldiyev (JIRA)
• [jira] [Created] (FLINK-11170) Support DISTINCT aggregates in MATCH_RECOGNIZE, Dawid Wysakowicz (JIRA)
• CEP - Support for multiple pattern, bupt_ljy
  • <Possible follow-ups>
  • Re: CEP - Support for multiple pattern, fudian.fd
  • Re: CEP - Support for multiple pattern, Dawid Wysakowicz
• [jira] [Created] (FLINK-11169) [hotfix][runtime] fix the problem of not being reloaded for jobmanager's log after clicking the refresh button in web ui, Jiayong Mo (JIRA)
• 回复：Apply for flink contributor permission, Tony Xintong Song
• [jira] [Created] (FLINK-11168) LargePlanTest times out on Travis, Chesnay Schepler (JIRA)
• [CANCELED] [VOTE] Release 1.7.1, release candidate #1, Chesnay Schepler
• [VOTE] Release 1.7.1, release candidate #1, Chesnay Schepler