Mail Thread 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
- [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
- [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
- [ANNOUNCE] Apache Flink 1.6.3 released,
Tzu-Li (Gordon) Tai
- [ANNOUNCE] Apache Flink 1.7.1 released,
Chesnay Schepler
- [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
- [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
- [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
- [jira] [Created] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues,
Addison Higham (JIRA)
- 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
- [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