flink-issues mailing list archives: January 2018

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support Wed, 31 Jan, 12:19
tzulitai [GitHub] flink issue #5268: [FLINK-8398] [kinesis, tests] Harden KinesisDataFetcherTe... Wed, 31 Jan, 12:27
asfgit [GitHub] flink pull request #5370: [hotfix] [table] Fix IndexOutOfBoundsException in ... Wed, 31 Jan, 12:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests Wed, 31 Jan, 12:28
tzulitai [GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ... Wed, 31 Jan, 12:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 12:37
tzulitai [GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ... Wed, 31 Jan, 12:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 12:40
tzulitai [GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip... Wed, 31 Jan, 12:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 12:41
twalthr [GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access... Wed, 31 Jan, 12:42
twalthr [GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access... Wed, 31 Jan, 12:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column Wed, 31 Jan, 12:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column Wed, 31 Jan, 12:43
twalthr [GitHub] flink issue #5347: [FLINK-8492][table] Fix calc cost bug Wed, 31 Jan, 12:49
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8492) [FLINK-8492][table] Fix calc cost bug Wed, 31 Jan, 12:50
Xingcan Cui (JIRA) [jira] [Assigned] (FLINK-8538) Add a Kafka table source factory with JSON format support Wed, 31 Jan, 12:50
tzulitai [GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip... Wed, 31 Jan, 12:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 12:54
tzulitai [GitHub] flink issue #5329: [FLINK-8409] [kafka] Fix potential NPE in KafkaConsumerTh... Wed, 31 Jan, 12:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE Wed, 31 Jan, 12:55
zentol [GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip... Wed, 31 Jan, 12:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 12:57
tzulitai [GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip... Wed, 31 Jan, 12:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 12:58
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart Wed, 31 Jan, 13:00
tzulitai [GitHub] flink pull request #5335: (master) [FLINK-8419] [kafka] Register metrics for... Wed, 31 Jan, 13:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 13:08
Timo Walther (JIRA) [jira] [Updated] (FLINK-8492) Improve cost estimation for Calcs Wed, 31 Jan, 13:15
asfgit [GitHub] flink pull request #5347: [FLINK-8492][table] Fix calc cost bug Wed, 31 Jan, 13:15
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8492) Improve cost estimation for Calcs Wed, 31 Jan, 13:16
Timo Walther (JIRA) [jira] [Resolved] (FLINK-8492) Improve cost estimation for Calcs Wed, 31 Jan, 13:16
tillrohrmann [GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery Wed, 31 Jan, 13:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8360) Implement task-local state recovery Wed, 31 Jan, 13:21
zentol [GitHub] flink issue #5155: [FLINK-4812][metrics] Expose currentLowWatermark for all ... Wed, 31 Jan, 13:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators Wed, 31 Jan, 13:22
twalthr [GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l... Wed, 31 Jan, 13:23
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join Wed, 31 Jan, 13:24
tzulitai [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Wed, 31 Jan, 13:26
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple Wed, 31 Jan, 13:27
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Wed, 31 Jan, 13:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Wed, 31 Jan, 13:27
asfgit [GitHub] flink pull request #3478: Flink 4816 Executions failed from "DEPLOYING" shou... Wed, 31 Jan, 13:27
asfgit [GitHub] flink pull request #4847: [hotfix][doc]CEP docs review to remove weasel word... Wed, 31 Jan, 13:27
asfgit [GitHub] flink pull request #5305: Release 1.3 Wed, 31 Jan, 13:27
asfgit [GitHub] flink pull request #5378: [FLINK-8489][ES] Prevent side-effects when modifyi... Wed, 31 Jan, 13:27
asfgit [GitHub] flink pull request #5208: [FLINK-8265] [Mesos] Missing jackson dependency fo... Wed, 31 Jan, 13:27
asfgit [GitHub] flink pull request #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin Wed, 31 Jan, 13:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo Wed, 31 Jan, 13:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Wed, 31 Jan, 13:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8496) WebUI does not display TM MemorySegment metrics Wed, 31 Jan, 13:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin Wed, 31 Jan, 13:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8265) Missing jackson dependency for flink-mesos Wed, 31 Jan, 13:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple Wed, 31 Jan, 13:28
asfgit [GitHub] flink pull request #5343: [FLINK-8496][metrics] Create missing "Network" gro... Wed, 31 Jan, 13:28
asfgit [GitHub] flink pull request #2192: Flink 4034 Maven dependency convergence Wed, 31 Jan, 13:28
asfgit [GitHub] flink pull request #5292: [FLINK-8422] [core] Checkstyle for org.apache.flin... Wed, 31 Jan, 13:28
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-8496) WebUI does not display TM MemorySegment metrics Wed, 31 Jan, 13:30
Ufuk Celebi (JIRA) [jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher Wed, 31 Jan, 13:32
tzulitai [GitHub] flink issue #5316: [FLINK-8022][kafka-tests] Disable at-least-once tests for... Wed, 31 Jan, 13:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8022) Kafka at-least-once tests fail occasionally Wed, 31 Jan, 13:36
twalthr [GitHub] flink issue #5373: [FLINK-8230] [orc] Fix NPEs when reading nested columns. Wed, 31 Jan, 13:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs Wed, 31 Jan, 13:40
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher Wed, 31 Jan, 13:44
asfgit [GitHub] flink pull request #5373: [FLINK-8230] [orc] Fix NPEs when reading nested co... Wed, 31 Jan, 13:46
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs Wed, 31 Jan, 13:47
Timo Walther (JIRA) [jira] [Resolved] (FLINK-8230) NPE in OrcRowInputFormat on nested structs Wed, 31 Jan, 13:49
twalthr [GitHub] flink issue #5145: [FLINK-8230] [ORC] Improved mapping of Orc records to Fli... Wed, 31 Jan, 13:49
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs Wed, 31 Jan, 13:50
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-8267) update Kinesis Producer example for setting Region key Wed, 31 Jan, 14:00
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-8267) update Kinesis Producer example for setting Region key Wed, 31 Jan, 14:00
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-8267) update Kinesis Producer example for setting Region key Wed, 31 Jan, 14:01
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions Wed, 31 Jan, 14:09
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions Wed, 31 Jan, 14:09
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions Wed, 31 Jan, 14:09
zentol [GitHub] flink pull request #5394: [FLINK-6571][tests] Catch InterruptedException in ... Wed, 31 Jan, 14:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions Wed, 31 Jan, 14:10
zentol [GitHub] flink issue #5163: [FLINK-8254][REST][docs] Bandaid generated documentation Wed, 31 Jan, 14:16
zentol [GitHub] flink pull request #5163: [FLINK-8254][REST][docs] Bandaid generated documen... Wed, 31 Jan, 14:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8254) REST API documentation wonky due to shading Wed, 31 Jan, 14:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8254) REST API documentation wonky due to shading Wed, 31 Jan, 14:17
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the number of cpu, join and shuffle operators will easly cause deadlock. Wed, 31 Jan, 15:05
dyanarose [GitHub] flink issue #5295: [FLINK-8384] [streaming] Session Window Assigner with Dyn... Wed, 31 Jan, 15:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps Wed, 31 Jan, 15:07
aljoscha [GitHub] flink issue #5155: [FLINK-4812][metrics] Expose currentLowWatermark for all ... Wed, 31 Jan, 15:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators Wed, 31 Jan, 15:11
aljoscha [GitHub] flink issue #5295: [FLINK-8384] [streaming] Session Window Assigner with Dyn... Wed, 31 Jan, 15:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps Wed, 31 Jan, 15:19
tzulitai [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 15:20
tzulitai [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 15:20
tzulitai [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 15:20
tzulitai [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 15:20
tzulitai [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 15:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 15:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 15:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 15:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 15:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 15:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 15:25
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 15:25
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
Box list
Jun 20194733
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300