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-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:00
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 09:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:04
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 09:04
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:05
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 09:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:06
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 09:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:12
cjolif [GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ... Wed, 31 Jan, 09:16
zhijiangW [GitHub] flink issue #5381: [FLINK-8523][network] Stop assigning floating buffers for... Wed, 31 Jan, 09:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support Wed, 31 Jan, 09:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:17
GJL [GitHub] flink pull request #5353: [FLINK-8503] [flip6] Display TaskExecutor logs and... Wed, 31 Jan, 09:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint Wed, 31 Jan, 09:18
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 09:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 09:21
zhangminglei [GitHub] flink issue #5375: [FLINK-7095] [TaskManager] Add Command line parsing tool ... Wed, 31 Jan, 09:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main Wed, 31 Jan, 09:44
zentol [GitHub] flink pull request #5161: [FLINK-7608][metric] Refactor latency statistics m... Wed, 31 Jan, 09:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Wed, 31 Jan, 09:51
zentol [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Wed, 31 Jan, 09:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Wed, 31 Jan, 09:58
zentol [GitHub] flink issue #5378: [FLINK-8489][ES] Prevent side-effects when modifying user... Wed, 31 Jan, 10:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Wed, 31 Jan, 10:01
aljoscha [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Wed, 31 Jan, 10:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Wed, 31 Jan, 10:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Wed, 31 Jan, 10:07
zentol [GitHub] flink issue #5292: [FLINK-8422] [core] Checkstyle for org.apache.flink.api.j... Wed, 31 Jan, 10:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple Wed, 31 Jan, 10:08
zentol [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Wed, 31 Jan, 10:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Wed, 31 Jan, 10:12
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Wed, 31 Jan, 10:13
aljoscha [GitHub] flink issue #5369: [FLINK-8407][DataStream]Setting the parallelism after a p... Wed, 31 Jan, 10:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Wed, 31 Jan, 10:14
aljoscha [GitHub] flink issue #5343: [FLINK-8496][metrics] Create missing "Network" group Wed, 31 Jan, 10:16
xccui [GitHub] flink issue #5369: [FLINK-8407][DataStream]Setting the parallelism after a p... Wed, 31 Jan, 10:16
xccui [GitHub] flink pull request #5369: [FLINK-8407][DataStream]Setting the parallelism af... Wed, 31 Jan, 10:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Wed, 31 Jan, 10:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8496) WebUI does not display TM MemorySegment metrics Wed, 31 Jan, 10:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Wed, 31 Jan, 10:17
Steven Langbroek (JIRA) [jira] [Assigned] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks Wed, 31 Jan, 10:19
yanxiaobin (JIRA) [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 10:20
zentol [GitHub] flink issue #5343: [FLINK-8496][metrics] Create missing "Network" group Wed, 31 Jan, 10:29
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8496) WebUI does not display TM MemorySegment metrics Wed, 31 Jan, 10:30
zentol [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Wed, 31 Jan, 10:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Wed, 31 Jan, 10:37
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8020) Deadlock found in Flink Streaming job Wed, 31 Jan, 10:51
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator Wed, 31 Jan, 10:53
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator Wed, 31 Jan, 10:53
tillrohrmann [GitHub] flink pull request #5353: [FLINK-8503] [flip6] Display TaskExecutor logs and... Wed, 31 Jan, 10:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint Wed, 31 Jan, 10:57
Steven Langbroek (JIRA) [jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher Wed, 31 Jan, 10:57
tillrohrmann [GitHub] flink pull request #5353: [FLINK-8503] [flip6] Display TaskExecutor logs and... Wed, 31 Jan, 10:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint Wed, 31 Jan, 10:58
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-8019) Flink streaming job stopped at consuming Kafka data Wed, 31 Jan, 10:59
tillrohrmann [GitHub] flink pull request #5353: [FLINK-8503] [flip6] Display TaskExecutor logs and... Wed, 31 Jan, 10:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint Wed, 31 Jan, 11:00
zhu.qing (JIRA) [jira] [Created] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration. Will cause Caused by: java.io.FileNotFoundException release file error Wed, 31 Jan, 11:03
zhu.qing (JIRA) [jira] [Updated] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration. Will cause Caused : java.io.FileNotFoundException release file error Wed, 31 Jan, 11:03
zhu.qing (JIRA) [jira] [Updated] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration will cause a error (Caused : java.io.FileNotFoundException release file error) Wed, 31 Jan, 11:04
zentol [GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ... Wed, 31 Jan, 11:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 11:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart Wed, 31 Jan, 11:06
zentol [GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ... Wed, 31 Jan, 11:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Wed, 31 Jan, 11:07
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart Wed, 31 Jan, 11:07
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart Wed, 31 Jan, 11:09
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart Wed, 31 Jan, 11:09
aljoscha [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Wed, 31 Jan, 11:11
zentol [GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric... Wed, 31 Jan, 11:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 11:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Wed, 31 Jan, 11:12
zentol [GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric... Wed, 31 Jan, 11:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 11:13
tzulitai [GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric... Wed, 31 Jan, 11:18
zentol [GitHub] flink pull request #5335: (master) [FLINK-8419] [kafka] Register metrics for... Wed, 31 Jan, 11:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 11:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 11:19
aljoscha [GitHub] flink issue #5295: [FLINK-8384] [streaming] Session Window Assigner with Dyn... Wed, 31 Jan, 11:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps Wed, 31 Jan, 11:20
zentol [GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric... Wed, 31 Jan, 11:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 11:21
tzulitai [GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric... Wed, 31 Jan, 11:22
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions Wed, 31 Jan, 11:23
tzulitai [GitHub] flink pull request #: Wed, 31 Jan, 11:29
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration will cause a error (Caused : java.io.FileNotFoundException release file error) Wed, 31 Jan, 11:33
twalthr [GitHub] flink issue #5370: [hotfix] [table] Fix IndexOutOfBoundsException in DataStr... Wed, 31 Jan, 11:44
twalthr [GitHub] flink issue #5240: [FLINK-8240] [table] Create unified interfaces to configu... Wed, 31 Jan, 11:47
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources Wed, 31 Jan, 11:48
asfgit [GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ... Wed, 31 Jan, 11:48
Timo Walther (JIRA) [jira] [Resolved] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources Wed, 31 Jan, 11:49
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources Wed, 31 Jan, 11:49
Timo Walther (JIRA) [jira] [Created] (FLINK-8535) Implement a basic set of table source factories Wed, 31 Jan, 11:56
Timo Walther (JIRA) [jira] [Created] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties Wed, 31 Jan, 12:02
yew1eb [GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ... Wed, 31 Jan, 12:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support Wed, 31 Jan, 12:04
Timo Walther (JIRA) [jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support Wed, 31 Jan, 12:07
Timo Walther (JIRA) [jira] [Created] (FLINK-8538) Add a Kafka table source factory with JSON format support Wed, 31 Jan, 12:09
yew1eb [GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ... Wed, 31 Jan, 12:18
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
Sep 20194145
Aug 201910193
Jul 201911502
Jun 20198159
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