ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions |
Mon, 22 Jan, 15:15 |
tillrohrmann |
[GitHub] flink issue #5318: [FLINK-8462] [flip6] Filter invalid heartbeat timeouts in... |
Mon, 22 Jan, 15:16 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8462) TaskExecutor does not verify RM heartbeat timeouts |
Mon, 22 Jan, 15:17 |
tzulitai |
[GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric... |
Mon, 22 Jan, 15:40 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions |
Mon, 22 Jan, 15:41 |
aitozi (JIRA) |
[jira] [Created] (FLINK-8477) Add api to support for user to skip the first incomplete window data |
Mon, 22 Jan, 15:52 |
Florian Schmidt (JIRA) |
[jira] [Created] (FLINK-8478) Add support for time-bounded joins in DataStream API |
Mon, 22 Jan, 15:53 |
Florian Schmidt (JIRA) |
[jira] [Created] (FLINK-8479) Implement TwoInputStreamOperator to join two streams |
Mon, 22 Jan, 15:56 |
Florian Schmidt (JIRA) |
[jira] [Created] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator |
Mon, 22 Jan, 15:58 |
Florian Schmidt (JIRA) |
[jira] [Created] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator |
Mon, 22 Jan, 15:58 |
Florian Schmidt (JIRA) |
[jira] [Updated] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator |
Mon, 22 Jan, 16:00 |
Florian Schmidt (JIRA) |
[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords |
Mon, 22 Jan, 16:01 |
Florian Schmidt (JIRA) |
[jira] [Created] (FLINK-8482) Expose option to use min / max / left / right timestamp for joined streamrecords |
Mon, 22 Jan, 16:01 |
zohar-mizrahi |
[GitHub] flink issue #5333: [FLINK-5886] Python API for streaming applications |
Mon, 22 Jan, 16:02 |
Florian Schmidt (JIRA) |
[jira] [Created] (FLINK-8483) Implement and expose outer joins |
Mon, 22 Jan, 16:03 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-5886) Python API for streaming applications |
Mon, 22 Jan, 16:03 |
zentol |
[GitHub] flink issue #5333: [FLINK-5886] Python API for streaming applications |
Mon, 22 Jan, 16:04 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-5886) Python API for streaming applications |
Mon, 22 Jan, 16:05 |
zentol |
[GitHub] flink issue #5333: [FLINK-5886] Python API for streaming applications |
Mon, 22 Jan, 16:06 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-5886) Python API for streaming applications |
Mon, 22 Jan, 16:07 |
aljoscha |
[GitHub] flink issue #5332: [FLINK-6464][streaming] Stabilize default window operator... |
Mon, 22 Jan, 17:15 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6464) Metric name is not stable |
Mon, 22 Jan, 17:16 |
Philip Luppens (JIRA) |
[jira] [Created] (FLINK-8484) Kinesis consumer re-reads |
Mon, 22 Jan, 17:16 |
Philip Luppens (JIRA) |
[jira] [Updated] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart |
Mon, 22 Jan, 17:16 |
StephanEwen |
[GitHub] flink issue #5331: [FLINK-8473][webUI] Improve error behavior of JarListHand... |
Mon, 22 Jan, 17:30 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted |
Mon, 22 Jan, 17:31 |
Eron Wright (JIRA) |
[jira] [Commented] (FLINK-5018) Make source idle timeout user configurable |
Mon, 22 Jan, 17:38 |
Steven Zhen Wu (JIRA) |
[jira] [Commented] (FLINK-8043) change fullRestarts (for fine grained recovery) from guage to counter |
Mon, 22 Jan, 18:01 |
Steven Zhen Wu (JIRA) |
[jira] [Closed] (FLINK-8043) change fullRestarts (for fine grained recovery) from guage to counter |
Mon, 22 Jan, 18:01 |
Tzu-Li (Gordon) Tai (JIRA) |
[jira] [Commented] (FLINK-5018) Make source idle timeout user configurable |
Mon, 22 Jan, 18:12 |
Tzu-Li (Gordon) Tai (JIRA) |
[jira] [Comment Edited] (FLINK-5018) Make source idle timeout user configurable |
Mon, 22 Jan, 18:12 |
Tzu-Li (Gordon) Tai (JIRA) |
[jira] [Comment Edited] (FLINK-5018) Make source idle timeout user configurable |
Mon, 22 Jan, 18:13 |
Tzu-Li (Gordon) Tai (JIRA) |
[jira] [Comment Edited] (FLINK-5018) Make source idle timeout user configurable |
Mon, 22 Jan, 18:14 |
Eron Wright (JIRA) |
[jira] [Commented] (FLINK-5018) Make source idle timeout user configurable |
Mon, 22 Jan, 18:17 |
Tzu-Li (Gordon) Tai (JIRA) |
[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions |
Mon, 22 Jan, 18:18 |
zentol |
[GitHub] flink issue #5332: [FLINK-6464][streaming] Stabilize default window operator... |
Mon, 22 Jan, 18:52 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-6464) Metric name is not stable |
Mon, 22 Jan, 18:53 |
zentol |
[GitHub] flink issue #5331: [FLINK-8473][webUI] Improve error behavior of JarListHand... |
Mon, 22 Jan, 18:56 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8473) JarListHandler may fail with NPE if directory is deleted |
Mon, 22 Jan, 18:57 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:24 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
fhueske |
[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources |
Mon, 22 Jan, 21:25 |
bowenli86 |
[GitHub] flink pull request #5301: [FLINK-8267] [Kinesis Connector] update Kinesis Pr... |
Mon, 22 Jan, 21:35 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8267) update Kinesis Producer example for setting Region key |
Mon, 22 Jan, 21:36 |
asfgit |
[GitHub] flink pull request #5318: [FLINK-8462] [flip6] Filter invalid heartbeat time... |
Mon, 22 Jan, 21:55 |
asfgit |
[GitHub] flink pull request #5319: [FLINK-8463] [rest] Remove blocking of IO executor... |
Mon, 22 Jan, 21:55 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8463) Remove unnecessary thread blocking in RestClient#submitRequest |
Mon, 22 Jan, 21:56 |