beam-commits mailing list archives: June 2017

Site index · List index
Message list1 · 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 · Next »Thread · Author · Date
François Wagner (JIRA) [jira] [Created] (BEAM-2429) Conflicting filesystems with used of HadoopFileSystem Fri, 09 Jun, 09:11
François Wagner (JIRA) [jira] [Updated] (BEAM-2429) Conflicting filesystems with used of HadoopFileSystem Fri, 09 Jun, 09:13
François Wagner (JIRA) [jira] [Updated] (BEAM-2429) Conflicting filesystems with used of HadoopFileSystem Fri, 09 Jun, 09:14
François Wagner (JIRA) [jira] [Commented] (BEAM-2429) Conflicting filesystems with used of HadoopFileSystem Mon, 12 Jun, 12:43
François Wagner (JIRA) [jira] [Resolved] (BEAM-2429) Conflicting filesystems with used of HadoopFileSystem Mon, 12 Jun, 12:50
Guillermo Rodríguez Cano (JIRA) [jira] [Commented] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:17
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:18
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:18
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:19
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:19
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:20
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 22 Jun, 23:22
Guillermo Rodríguez Cano (JIRA) [jira] [Commented] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Fri, 23 Jun, 00:01
Guillermo Rodríguez Cano (JIRA) [jira] [Commented] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Sat, 24 Jun, 01:09
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Sat, 24 Jun, 01:10
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Sat, 24 Jun, 01:11
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Sat, 24 Jun, 01:14
Guillermo Rodríguez Cano (JIRA) [jira] [Commented] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Sat, 24 Jun, 14:03
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Sat, 24 Jun, 14:04
Guillermo Rodríguez Cano (JIRA) [jira] [Commented] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Mon, 26 Jun, 15:06
Guillermo Rodríguez Cano (JIRA) [jira] [Comment Edited] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Mon, 26 Jun, 15:08
Guillermo Rodríguez Cano (JIRA) [jira] [Commented] (BEAM-2490) ReadFromText function is not taking all data with glob operator (*) Thu, 29 Jun, 22:19
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2409) Spark runner produces exactly twice the number of results in streaming mode when use triggers to re-window results on global window. Mon, 05 Jun, 14:28
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2409) Spark runner produces exactly twice the number of results in streaming mode when use triggers to re-window results on global window. Mon, 05 Jun, 14:30
Ismaël Mejía (JIRA) [jira] [Comment Edited] (BEAM-2409) Spark runner produces exactly twice the number of results in streaming mode when use triggers to re-window results on global window. Mon, 05 Jun, 14:30
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2411) Make the write transform of HBaseIO simpler Mon, 05 Jun, 21:14
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2412) Update HBaseIO to use HBase client 1.2.6 Mon, 05 Jun, 21:17
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-1158) Add HCatalog (Hive) example using HadoopInputFormatIO Tue, 06 Jun, 09:04
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-1158) Add HCatalog (Hive) example using HadoopInputFormatIO Tue, 06 Jun, 09:05
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2357) Add HCatalogIO (Hive) Thu, 08 Jun, 07:47
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-2411) Make the write transform of HBaseIO simpler Tue, 20 Jun, 09:55
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2481) Update commons-lang3 dependency to version 3.6 Tue, 20 Jun, 12:11
Ismaël Mejía (JIRA) [jira] [Assigned] (BEAM-2481) Update commons-lang3 dependency to version 3.6 Tue, 20 Jun, 12:12
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-2481) Update commons-lang3 dependency to version 3.6 Wed, 21 Jun, 07:56
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-1458) Checkpoint support in Beam Wed, 21 Jun, 16:56
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-2471) Add Amazon EMR DynamoDB example using HadoopInputFormatIO Tue, 27 Jun, 10:13
Ismaël Mejía (JIRA) [jira] [Closed] (BEAM-2471) Add Amazon EMR DynamoDB example using HadoopInputFormatIO Tue, 27 Jun, 10:13
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode Wed, 28 Jun, 06:12
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode Wed, 28 Jun, 07:10
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode Wed, 28 Jun, 09:25
Ismaël Mejía (JIRA) [jira] [Assigned] (BEAM-2530) Make Beam compatible with Java 9 Wed, 28 Jun, 15:02
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2530) Make Beam compatible with Java 9 Wed, 28 Jun, 15:02
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2530) Make Beam compatible with Java 9 Wed, 28 Jun, 15:07
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-1531) Support dynamic work rebalancing for HBaseIO Wed, 28 Jun, 22:09
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2204) fix error in CALCITE-1761 Wed, 28 Jun, 22:31
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-1531) Support dynamic work rebalancing for HBaseIO Thu, 29 Jun, 07:54
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2396) Support adding jars to spark runner Thu, 01 Jun, 10:58
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2397) Document use of adding jars to spark runner Thu, 01 Jun, 10:59
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2397) Document use of adding jars to spark runner Thu, 01 Jun, 10:59
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2396) Support adding jars to spark runner Thu, 01 Jun, 10:59
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2396) Support adding jars to spark runner Thu, 01 Jun, 11:36
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2328) Introduce Apache Tika Input component Thu, 01 Jun, 11:42
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2328) Introduce Apache Tika Input component Thu, 01 Jun, 11:43
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2328) Introduce Apache Tika Input component Thu, 01 Jun, 11:51
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2375) upgrade beam-version to 2.0.0 Fri, 02 Jun, 15:43
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0 Fri, 02 Jun, 15:43
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0 Tue, 06 Jun, 05:29
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0 Tue, 06 Jun, 05:54
Jean-Baptiste Onofré (JIRA) [jira] [Comment Edited] (BEAM-2375) upgrade beam-version to 2.0.0 Tue, 06 Jun, 05:58
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2415) Add facebookIO Tue, 06 Jun, 11:38
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2414) Add TwitterIO Tue, 06 Jun, 11:38
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2417) Add ZeroMQIO Tue, 06 Jun, 11:40
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2416) Add AkkaIO Tue, 06 Jun, 11:40
Jean-Baptiste Onofré (JIRA) [jira] [Updated] (BEAM-2415) Add FacebookIO Tue, 06 Jun, 14:47
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2415) Add facebookIO Tue, 06 Jun, 14:47
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2414) Add TwitterIO Tue, 06 Jun, 14:47
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-1679) create gRPC IO Tue, 06 Jun, 14:48
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2414) Add TwitterIO Tue, 06 Jun, 19:17
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2415) Add FacebookIO Tue, 06 Jun, 19:18
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-245) Create Cassandra IO Wed, 07 Jun, 06:06
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2420) Add push-down predicate in CassandraIO Wed, 07 Jun, 12:48
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2410) Remove TransportClient from ElasticSearchIO to decouple IO and ES versions Fri, 09 Jun, 05:32
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-1323) Add parallelism/splitting in JdbcIO Mon, 12 Jun, 17:02
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2412) Update HBaseIO to use HBase client 1.2.6 Tue, 13 Jun, 06:01
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2456) Introduce generic metric poll thread interceptor Fri, 16 Jun, 07:06
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-423) Refactore HDFS IO to use the "new" IO style Fri, 16 Jun, 07:25
Jean-Baptiste Onofré (JIRA) [jira] [Updated] (BEAM-975) Issue with MongoDBIO Fri, 16 Jun, 07:26
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2455) Backlog size retrieval for Kinesis source Sun, 18 Jun, 05:56
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2466) Add Kafka Streams runner Mon, 19 Jun, 08:40
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-975) Issue with MongoDBIO Mon, 19 Jun, 19:31
Jean-Baptiste Onofré (JIRA) [jira] [Updated] (BEAM-2456) Introduce generic metric poll thread interceptor & generic sink Fri, 23 Jun, 07:20
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2489) Use dynamic ES port in HIFIOWithElasticTest in module IO :: Hadoop :: jdk1.8-tests Fri, 23 Jun, 13:14
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-1237) Create AmqpIO Tue, 27 Jun, 13:35
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2488) Elasticsearch IO should read also in replica shards Wed, 28 Jun, 08:12
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2529) SpannerWriteIT failing in postcommit Wed, 28 Jun, 14:20
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2529) SpannerWriteIT failing in postcommit Wed, 28 Jun, 14:23
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2529) SpannerWriteIT failing in postcommit Wed, 28 Jun, 14:24
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2376) JdbcIO should allow multiple statements Thu, 29 Jun, 13:39
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2540) Make JdbcIO batch size configurable Thu, 29 Jun, 13:40
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2540) Make JdbcIO batch size configurable Thu, 29 Jun, 13:40
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2529) SpannerWriteIT failing in postcommit Fri, 30 Jun, 05:30
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2529) SpannerWriteIT failing in postcommit Fri, 30 Jun, 05:30
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-2546) Create InfluxDbIO Fri, 30 Jun, 08:38
Paweł Kaczmarczyk (JIRA) [jira] [Created] (BEAM-2455) Backlog size retrieval for Kinesis source Fri, 16 Jun, 06:55
Paweł Kaczmarczyk (JIRA) [jira] [Commented] (BEAM-2455) Backlog size retrieval for Kinesis source Sat, 17 Jun, 19:18
Paweł Kaczmarczyk (JIRA) [jira] [Created] (BEAM-2467) KinesisIO watermark based on approximateArrivalTimestamp Mon, 19 Jun, 12:42
Paweł Kaczmarczyk (JIRA) [jira] [Created] (BEAM-2468) Reading Kinesis records in the background Mon, 19 Jun, 12:47
Paweł Kaczmarczyk (JIRA) [jira] [Created] (BEAM-2469) Handling Kinesis shards splits and merges Mon, 19 Jun, 12:57
Paweł Kaczmarczyk (JIRA) [jira] [Commented] (BEAM-2455) Backlog size retrieval for Kinesis source Mon, 19 Jun, 13:02
Paweł Kaczmarczyk (JIRA) [jira] [Comment Edited] (BEAM-2455) Backlog size retrieval for Kinesis source Mon, 19 Jun, 13:26
Message list1 · 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 · Next »Thread · Author · Date
Box list
Aug 2019311
Jul 2019387
Jun 2019332
May 2019464
Apr 2019336
Mar 2019259
Feb 2019367
Jan 2019518
Dec 2018368
Nov 2018448
Oct 20184197
Sep 20184689
Aug 20184453
Jul 20184320
Jun 20186163
May 20185547
Apr 20185962
Mar 20184479
Feb 20181955
Jan 20182670
Dec 20171428
Nov 20172364
Oct 20171972
Sep 20172095
Aug 20172291
Jul 20172998
Jun 20172879
May 20175577
Apr 20175171
Mar 20174068
Feb 20172908
Jan 20171848
Dec 20163374
Nov 20162900
Oct 20162712
Sep 20161298
Aug 20161500
Jul 20161550
Jun 20161725
May 20161092
Apr 20161731
Mar 20161158
Feb 2016294