beam-commits mailing list archives: September 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 · Next »Thread · Author · Date
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2848) Validate nexmark with the Google Dataflow runner Wed, 06 Sep, 16:14
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2848) Validate nexmark with the Google Dataflow runner Wed, 06 Sep, 16:16
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2849) Validate nexmark with the Gearpump runner Wed, 06 Sep, 16:16
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2850) Add nexmark to Beam Continuous Integration Wed, 06 Sep, 16:17
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2851) Enable Pubsub as source/sink on Nexmark Wed, 06 Sep, 16:19
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2852) Add support for Kafka as source/sink on Nexmark Wed, 06 Sep, 16:20
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2853) Move the nexmark documentation to the website Wed, 06 Sep, 16:21
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2854) Add SQL versions of the Nexmark queries (when possible) Wed, 06 Sep, 16:24
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2855) Implement a python version of the nexmark queries Wed, 06 Sep, 16:25
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-2856) Fix Nexmark Query 10 'log to sharded files' to be less Google specific Wed, 06 Sep, 16:27
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2764) SolrIOTest fails in master branch Thu, 07 Sep, 20:05
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2764) SolrIOTest fails in master branch Thu, 07 Sep, 20:05
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-2764) SolrIOTest fails in master branch Thu, 07 Sep, 20:05
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2855) Implement a python version of the nexmark queries Thu, 07 Sep, 20:39
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2854) Add SQL versions of the Nexmark queries (when possible) Thu, 07 Sep, 20:39
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2852) Add support for Kafka as source/sink on Nexmark Thu, 07 Sep, 20:40
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-1532) Improve splitting (support sub-splits) for HBaseIO Thu, 07 Sep, 20:54
Ismaël Mejía (JIRA) [jira] [Assigned] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection Fri, 08 Sep, 10:03
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection Fri, 08 Sep, 10:55
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-2955) Create a Cloud Bigtable HBase connector Wed, 13 Sep, 20:05
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection Fri, 08 Sep, 12:30
Jean-Baptiste Onofré (JIRA) [jira] [Updated] (BEAM-2328) Add TikaIO Mon, 11 Sep, 06:04
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2328) Add TikaIO Mon, 11 Sep, 06:04
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2957) Fix flaky ElasticsearchIOTest.testSplit in beam-sdks-java-io-elasticsearch-tests-5 Mon, 18 Sep, 12:27
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-2347) Elasticsearch IO - test ES 5? Tue, 19 Sep, 08:14
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-2701) use a custom implementation of java.io.ObjectInputStream Thu, 21 Sep, 05:27
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1 Thu, 21 Sep, 05:30
Jean-Baptiste Onofré (JIRA) [jira] [Updated] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1 Thu, 21 Sep, 05:30
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2993) AvroIO.write without specifying a schema Fri, 29 Sep, 08:44
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-2993) AvroIO.write without specifying a schema Fri, 29 Sep, 09:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2828) Create FileIO Fri, 01 Sep, 00:41
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2803) JdbcIO read is very slow when query return a lot of rows Fri, 01 Sep, 01:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2822) Add support for progress reporting in fn API Fri, 01 Sep, 17:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter Fri, 01 Sep, 19:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2624) File-based sinks should produce a PCollection of written filenames Fri, 01 Sep, 20:35
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2821) isort and autopep8 the current Python code base Fri, 01 Sep, 22:11
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2833) TestPipeline fail to get Coder Fri, 01 Sep, 22:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2718) Add bundle retry logic to the DirectRunner Sat, 02 Sep, 00:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2836) Apply futurize stage 1 ("safe") Sat, 02 Sep, 05:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached Sun, 03 Sep, 06:07
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2825) Improve readability of SparkGroupAlsoByWindowViaWindowSet Sun, 03 Sep, 12:42
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2828) Create FileIO Sun, 03 Sep, 23:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2828) Create FileIO Sun, 03 Sep, 23:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2430) Java FnApiDoFnRunner to share across runners Mon, 04 Sep, 03:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2824) Support PipelineResult in JStormRunner Mon, 04 Sep, 05:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2824) Support PipelineResult in JStormRunner Mon, 04 Sep, 05:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1763) TestPipeline should ensure that all assertions succeeded Tue, 05 Sep, 02:40
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1920) Add Spark 2.x support in Spark runner Tue, 05 Sep, 13:26
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2795) FlinkRunner: translate using SDK-agnostic means Wed, 06 Sep, 04:48
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2844) Support implicit side inputs Wed, 06 Sep, 06:23
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2803) JdbcIO read is very slow when query return a lot of rows Wed, 06 Sep, 17:04
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2718) Add bundle retry logic to the DirectRunner Wed, 06 Sep, 21:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2718) Add bundle retry logic to the DirectRunner Thu, 07 Sep, 04:22
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2833) TestPipeline fail to get Coder Thu, 07 Sep, 04:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner Thu, 07 Sep, 18:40
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2764) SolrIOTest fails in master branch Thu, 07 Sep, 20:04
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2822) Add support for progress reporting in fn API Thu, 07 Sep, 20:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2865) Implement FileIO.write() Fri, 08 Sep, 01:43
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2866) StateTable should key off state id, not StateTag, since coders may have bad equality Fri, 08 Sep, 02:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2545) bigtable e2e tests failing - UNKNOWN: Stale requests/Error mutating row Fri, 08 Sep, 07:14
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection Fri, 08 Sep, 10:04
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2787) IllegalArgumentException with MongoDbIO with empty PCollection Fri, 08 Sep, 12:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2545) bigtable e2e tests failing - UNKNOWN: Stale requests/Error mutating row Fri, 08 Sep, 17:17
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1934) Code examples for CoGroupByKey Fri, 08 Sep, 18:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2861) test_delete_bq_table_succeeds fails with GOOGLE_APPLICATION_CREDENTIALS Fri, 08 Sep, 20:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2807) NullPointerException during checkpoint on FlinkRunner Fri, 08 Sep, 21:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-407) Inconsistent synchronization in OffsetRangeTracker.copy Fri, 08 Sep, 22:24
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2862) Add support for User State over the Fn API Sat, 09 Sep, 01:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-934) Findbugs doesn't pass in Java8 Examples Mon, 11 Sep, 04:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2328) Add TikaIO Mon, 11 Sep, 06:04
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-301) Add a Beam SQL DSL Mon, 11 Sep, 20:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-301) Add a Beam SQL DSL Mon, 11 Sep, 20:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2804) support TIMESTAMP in Sort Mon, 11 Sep, 21:12
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2804) support TIMESTAMP in Sort Mon, 11 Sep, 21:26
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2862) Add support for User State over the Fn API Mon, 11 Sep, 22:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2804) support TIMESTAMP in Sort Mon, 11 Sep, 22:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2866) StateTable should key off state id, not StateTag, since coders may have bad equality Mon, 11 Sep, 22:33
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2829) Add ability to set job labels in DataflowPipelineOptions Mon, 11 Sep, 23:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2861) test_delete_bq_table_succeeds fails with GOOGLE_APPLICATION_CREDENTIALS Tue, 12 Sep, 04:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2859) ProcessingTime based timers are not properly fired in case the watermark stays put Tue, 12 Sep, 07:40
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2516) User reports 4 minutes to process 1 million line CSV in DirectRunner Tue, 12 Sep, 23:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2516) User reports 4 minutes to process 1 million line CSV in DirectRunner Tue, 12 Sep, 23:59
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2516) User reports 4 minutes to process 1 million line CSV in DirectRunner Wed, 13 Sep, 02:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2632) TextIOReadTest creates pipelines with non-unique application names Wed, 13 Sep, 02:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2859) ProcessingTime based timers are not properly fired in case the watermark stays put Wed, 13 Sep, 08:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2790) Error while reading from Amazon S3 via Hadoop File System Wed, 13 Sep, 19:26
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2954) update shade configurations in extension/sql Wed, 13 Sep, 21:44
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2956) DataflowRunner incorrectly reports the user agent for the Dataflow distribution Thu, 14 Sep, 00:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2790) Error while reading from Amazon S3 via Hadoop File System Thu, 14 Sep, 09:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2467) KinesisIO watermark based on approximateArrivalTimestamp Thu, 14 Sep, 10:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2885) Support job+artifact APIs locally Thu, 14 Sep, 17:23
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2699) AppliedPTransform is used as a key in hashmaps but PTransform is not hashable/equality-comparable Thu, 14 Sep, 17:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2795) FlinkRunner: translate using SDK-agnostic means Thu, 14 Sep, 18:37
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1637) Create Elasticsearch IO compatible with ES 5.x Fri, 15 Sep, 00:26
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2807) NullPointerException during checkpoint on FlinkRunner Fri, 15 Sep, 08:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2948) Unable to find registrar when restoring flink job from savepoint Fri, 15 Sep, 09:25
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2790) Error while reading from Amazon S3 via Hadoop File System Fri, 15 Sep, 15:09
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2718) Add bundle retry logic to the DirectRunner Fri, 15 Sep, 15:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2959) Fix proto enums to not use 0 for a valid value Fri, 15 Sep, 18:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2808) Improve error message when DoFn @ProcessElement has the wrong window type Fri, 15 Sep, 19:32
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · Next »Thread · Author · Date
Box list
Aug 2019285
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