fanyon |
[GitHub] flink issue #3652: [FLINK-6210] close RocksDB in ListViaMergeSpeedMiniBenchm... |
Sat, 01 Apr, 02:11 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark |
Sat, 01 Apr, 02:12 |
Zhuoluo Yang (JIRA) |
[jira] [Comment Edited] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float |
Sat, 01 Apr, 02:17 |
Elias Levy (JIRA) |
[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend |
Sat, 01 Apr, 02:35 |
wenlong88 |
[GitHub] flink issue #3595: [FLINK-6162]Fix bug in ByteArrayOutputStreamWithPos#setPo... |
Sat, 01 Apr, 02:52 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition |
Sat, 01 Apr, 02:52 |
haohui |
[GitHub] flink issue #3613: [FLINK-5829] Bump Calcite version to 1.12 once available. |
Sat, 01 Apr, 04:47 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available |
Sat, 01 Apr, 04:47 |
godfrey he (JIRA) |
[jira] [Created] (FLINK-6237) support RAND and RAND_INTEGER on SQL |
Sat, 01 Apr, 05:14 |
godfreyhe |
[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER... |
Sat, 01 Apr, 06:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL |
Sat, 01 Apr, 06:34 |
Wenlong Lyu (JIRA) |
[jira] [Commented] (FLINK-5989) Protobuf in akka needs to be shaded |
Sat, 01 Apr, 07:10 |
godfrey he (JIRA) |
[jira] [Created] (FLINK-6238) support OVER on batch SQL |
Sat, 01 Apr, 07:10 |
Wenlong Lyu (JIRA) |
[jira] [Comment Edited] (FLINK-5989) Protobuf in akka needs to be shaded |
Sat, 01 Apr, 07:10 |
godfrey he (JIRA) |
[jira] [Updated] (FLINK-6238) support OVER on batch SQL |
Sat, 01 Apr, 07:12 |
godfrey he (JIRA) |
[jira] [Updated] (FLINK-6238) support OVER on batch SQL |
Sat, 01 Apr, 07:12 |
godfrey he (JIRA) |
[jira] [Updated] (FLINK-6238) support OVER on batch SQL |
Sat, 01 Apr, 07:13 |
Elias Levy (JIRA) |
[jira] [Created] (FLINK-6239) Sharing of State Across Operators |
Sat, 01 Apr, 07:39 |
Kurt Young (JIRA) |
[jira] [Commented] (FLINK-6218) Not able to access the rows in table after converting dataset to table after using registerdataset |
Sat, 01 Apr, 08:00 |
KurtYoung |
[GitHub] flink issue #3623: [FLINK-6196] [table] Support dynamic schema in Table Func... |
Sat, 01 Apr, 08:11 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function |
Sat, 01 Apr, 08:11 |
Shaoxuan Wang (JIRA) |
[jira] [Created] (FLINK-6240) codeGen dataStream aggregates that use AggregateAggFunction |
Sat, 01 Apr, 08:23 |
Shaoxuan Wang (JIRA) |
[jira] [Created] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction |
Sat, 01 Apr, 08:24 |
Shaoxuan Wang (JIRA) |
[jira] [Created] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates |
Sat, 01 Apr, 08:25 |
Shaoxuan Wang (JIRA) |
[jira] [Commented] (FLINK-5564) User Defined Aggregates |
Sat, 01 Apr, 08:29 |
Hequn Cheng (JIRA) |
[jira] [Updated] (FLINK-6090) Add RetractionRule at the stage of decoration |
Sat, 01 Apr, 13:56 |
Hequn Cheng (JIRA) |
[jira] [Updated] (FLINK-6090) Add RetractionRule at the stage of decoration |
Sat, 01 Apr, 13:56 |
Elias Levy (JIRA) |
[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration |
Sat, 01 Apr, 18:05 |
tony810430 |
[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition... |
Sat, 01 Apr, 18:41 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector |
Sat, 01 Apr, 18:42 |
tzulitai |
[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition... |
Sat, 01 Apr, 19:41 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector |
Sat, 01 Apr, 19:41 |
Elias Levy (JIRA) |
[jira] [Created] (FLINK-6243) Continuous Joins: True Sliding Window Joins |
Sat, 01 Apr, 21:23 |
Elias Levy (JIRA) |
[jira] [Commented] (FLINK-6239) Sharing of State Across Operators |
Sat, 01 Apr, 23:50 |
prabhu1984 |
[GitHub] flink issue #2897: [FLINK-4676] [connectors] Merge batch and streaming conne... |
Sun, 02 Apr, 06:48 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules |
Sun, 02 Apr, 06:48 |
Prabhu Kasinathan (JIRA) |
[jira] [Commented] (FLINK-1466) Add InputFormat to read HCatalog tables |
Sun, 02 Apr, 06:50 |
Prabhu Kasinathan (JIRA) |
[jira] [Commented] (FLINK-1913) Document how to access data in HCatalog |
Sun, 02 Apr, 06:51 |
Swapnil Sarda (JIRA) |
[jira] [Commented] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select |
Sun, 02 Apr, 08:49 |
Swapnil Sarda (JIRA) |
[jira] [Comment Edited] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select |
Sun, 02 Apr, 08:52 |
manuzhang |
[GitHub] flink pull request #3661: [FLINK-4953] Allow access to "time" in ProcessWind... |
Sun, 02 Apr, 11:46 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context |
Sun, 02 Apr, 11:47 |
manuzhang |
[GitHub] flink issue #3661: [FLINK-4953] Allow access to "time" in ProcessWindowFunct... |
Sun, 02 Apr, 12:52 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context |
Sun, 02 Apr, 12:52 |
manuzhang |
[GitHub] flink issue #3661: [FLINK-4953] Allow access to "time" in ProcessWindowFunct... |
Sun, 02 Apr, 13:32 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-4953) Allow access to "time" in ProcessWindowFunction.Context |
Sun, 02 Apr, 13:33 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink pull request #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:19 |
mjsax |
[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo... |
Mon, 03 Apr, 01:20 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:20 |
mjsax |
[GitHub] flink issue #3615: [FLINK-2720] support flink-storm metrics |
Mon, 03 Apr, 01:21 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility |
Mon, 03 Apr, 01:21 |
Ted Yu (JIRA) |
[jira] [Comment Edited] (FLINK-4499) Introduce findbugs maven plugin |
Mon, 03 Apr, 01:51 |
Ted Yu (JIRA) |
[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() |
Mon, 03 Apr, 01:52 |
Ted Yu (JIRA) |
[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() |
Mon, 03 Apr, 01:52 |
Ted Yu (JIRA) |
[jira] [Updated] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions |
Mon, 03 Apr, 01:52 |
Ted Yu (JIRA) |
[jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext |
Mon, 03 Apr, 01:52 |
Ted Yu (JIRA) |
[jira] [Updated] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue |
Mon, 03 Apr, 01:52 |
kalmanchapman |
[GitHub] flink pull request #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:15 |
kalmanchapman |
[GitHub] flink pull request #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:15 |
kalmanchapman |
[GitHub] flink pull request #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:15 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:15 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:15 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:15 |
kalmanchapman |
[GitHub] flink pull request #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:15 |
kalmanchapman |
[GitHub] flink pull request #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:15 |
kalmanchapman |
[GitHub] flink pull request #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:16 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:16 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:16 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:16 |
kalmanchapman |
[GitHub] flink issue #2735: [FLINK-2094] [ml] implements Word2Vec for FlinkML |
Mon, 03 Apr, 02:20 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 02:20 |
Lev Konstantinovskiy (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 03:07 |
Kalman Chapman (JIRA) |
[jira] [Commented] (FLINK-2094) Implement Word2Vec |
Mon, 03 Apr, 03:33 |
radu (JIRA) |
[jira] [Commented] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction |
Mon, 03 Apr, 07:30 |
radu (JIRA) |
[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins |
Mon, 03 Apr, 07:33 |
Dawid Wysakowicz (JIRA) |
[jira] [Created] (FLINK-6244) Emit timeouted Patterns as Side Output |
Mon, 03 Apr, 08:05 |
Fabian Hueske (JIRA) |
[jira] [Commented] (FLINK-1913) Document how to access data in HCatalog |
Mon, 03 Apr, 08:27 |
tillrohrmann |
[GitHub] flink issue #3596: [FLINK-6155] Introduce an endpoint id for RpcEndpoints |
Mon, 03 Apr, 09:22 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6155) Allow to specify endpoint names |
Mon, 03 Apr, 09:22 |
aljoscha |
[GitHub] flink issue #3616: [FLINK-6188] Correctly handle PARALLELISM_DEFAULT in stre... |
Mon, 03 Apr, 10:14 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6188) Some setParallelism() methods can't cope with default parallelism |
Mon, 03 Apr, 10:14 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-6060) reference nonexistent class in the scaladoc |
Mon, 03 Apr, 10:24 |
Aljoscha Krettek (JIRA) |
[jira] [Updated] (FLINK-6060) reference nonexistent class in the scaladoc |
Mon, 03 Apr, 10:24 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-5090) Expose optionally detailed metrics about network queue lengths |
Mon, 03 Apr, 10:36 |
NicoK |
[GitHub] flink issue #3348: [FLINK-5090] [network] Add metrics for details about inbo... |
Mon, 03 Apr, 10:36 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration |
Mon, 03 Apr, 10:40 |
Aljoscha Krettek (JIRA) |
[jira] [Comment Edited] (FLINK-3089) State API Should Support Data Expiration |
Mon, 03 Apr, 10:40 |