beam-commits mailing list archives: August 2017

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 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2724) MSEC counters should support Structured Names in Dataflow Wed, 23 Aug, 00:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached Wed, 23 Aug, 08:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached Wed, 23 Aug, 08:31
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2788) Use SerializablePipelineOptions to serde PipelineOptions Wed, 23 Aug, 14:09
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2430) Java FnApiDoFnRunner to share across runners Wed, 23 Aug, 14:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-160) Port 'NexMark Queries' to Beam for use as integration test Wed, 23 Aug, 17:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2796) _ExecutorServiceParallelExecutor.await_for_completion does not actually await for _ExecutorService to shutdown Wed, 23 Aug, 17:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2484) Add streaming examples for Python Wed, 23 Aug, 20:11
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2798) rename simpleQuery to query and query to queryMulti Thu, 24 Aug, 00:41
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Thu, 24 Aug, 00:46
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2644) Make it easier to test runtime-accessible ValueProvider's Thu, 24 Aug, 02:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2671) CreateStreamTest.testFirstElementLate validatesRunner test fails on Spark runner Thu, 24 Aug, 06:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1531) Support dynamic work rebalancing for HBaseIO Thu, 24 Aug, 09:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2724) MSEC counters should support Structured Names in Dataflow Thu, 24 Aug, 16:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2798) rename simpleQuery to query and query to queryMulti Thu, 24 Aug, 17:16
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2484) Add streaming examples for Python Thu, 24 Aug, 18:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2703) KafkaIO: watermark outside the bounds of BoundedWindow Thu, 24 Aug, 21:38
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2792) Populate All Runner API Components from the Python SDK Thu, 24 Aug, 22:43
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner Thu, 24 Aug, 22:53
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2703) KafkaIO: watermark outside the bounds of BoundedWindow Fri, 25 Aug, 00:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Fri, 25 Aug, 01:41
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Fri, 25 Aug, 01:41
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1531) Support dynamic work rebalancing for HBaseIO Fri, 25 Aug, 07:24
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Fri, 25 Aug, 16:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2792) Populate All Runner API Components from the Python SDK Fri, 25 Aug, 19:17
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2753) File DynamicDestinations side inputs don't work with sharding Fri, 25 Aug, 21:55
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2796) _ExecutorServiceParallelExecutor.await_for_completion does not actually await for _ExecutorService to shutdown Fri, 25 Aug, 22:09
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2809) update JavaDoc of BeamSortRel Fri, 25 Aug, 23:48
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2809) update JavaDoc of BeamSortRel Sun, 27 Aug, 04:15
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2784) Fix issues from automated conversion to allow Python 2 functionality Sun, 27 Aug, 08:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1899) JStorm runner Mon, 28 Aug, 06:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Mon, 28 Aug, 16:55
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2792) Populate All Runner API Components from the Python SDK Mon, 28 Aug, 17:05
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2484) Add streaming examples for Python Mon, 28 Aug, 19:15
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2814) test_as_singleton_with_different_defaults test is flaky Mon, 28 Aug, 23:47
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2612) support variance builtin aggregation function Tue, 29 Aug, 00:02
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2612) support variance builtin aggregation function Tue, 29 Aug, 00:02
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2816) Create SplittableDoFnTester Tue, 29 Aug, 00:13
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter Tue, 29 Aug, 11:33
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2820) SDKs should measure time spent for active element Tue, 29 Aug, 17:39
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-301) Add a Beam SQL DSL Tue, 29 Aug, 17:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Tue, 29 Aug, 18:17
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2822) Add support for progress reporting in fn API Tue, 29 Aug, 19:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2612) support variance builtin aggregation function Tue, 29 Aug, 20:36
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2390) allow user to use .setTimePartitioning in BigQueryIO.write Tue, 29 Aug, 21:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2581) KinesisClientProvider interface needs to be public Tue, 29 Aug, 23:07
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Wed, 30 Aug, 01:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2632) TextIOReadTest create pipelines with non-unique application names Wed, 30 Aug, 06:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2824) Support PipelineResult in JStormRunner Wed, 30 Aug, 07:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2824) Support PipelineResult in JStormRunner Wed, 30 Aug, 07:44
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner Wed, 30 Aug, 13:05
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2825) Improve readability of SparkGroupAlsoByWindowViaWindowSet Wed, 30 Aug, 13:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner Wed, 30 Aug, 13:07
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-301) Add a Beam SQL DSL Wed, 30 Aug, 18:13
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2827) Introduce AvroIO.watchForNewFiles Wed, 30 Aug, 19:13
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2644) Make it easier to test runtime-accessible ValueProvider's Wed, 30 Aug, 19:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Wed, 30 Aug, 21:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Wed, 30 Aug, 23:12
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Wed, 30 Aug, 23:26
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2753) File DynamicDestinations side inputs don't work with sharding Wed, 30 Aug, 23:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2814) test_as_singleton_with_different_defaults test is flaky Wed, 30 Aug, 23:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2718) Add bundle retry logic to the DirectRunner Thu, 31 Aug, 00:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2781) Should have a canonical Compression enum Thu, 31 Aug, 00:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2829) Add ability to set job labels in DataflowPipelineOptions Thu, 31 Aug, 01:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Thu, 31 Aug, 18:20
Adam Levy (JIRA) [jira] [Created] (BEAM-2715) Expose PubsubSource to create UnboundedSource and utilize withMaxNumRecords from BoundedReadFromUnboundedSource Wed, 02 Aug, 17:09
Adam Levy (JIRA) [jira] [Commented] (BEAM-2715) Expose PubsubSource to create UnboundedSource and utilize withMaxNumRecords from BoundedReadFromUnboundedSource Wed, 16 Aug, 21:13
Ahmet Altay (JIRA) [jira] [Updated] (BEAM-2713) Support Python native types in Beam typehints Wed, 02 Aug, 00:17
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-1874) Google Cloud Storage TextIO read fails with gz-files having Content-Encoding: gzip header Thu, 03 Aug, 04:14
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-1874) Google Cloud Storage TextIO read fails with gz-files having Content-Encoding: gzip header Thu, 03 Aug, 16:16
Ahmet Altay (JIRA) [jira] [Created] (BEAM-2729) Post commit fail: Input to GroupByKey must be of Tuple or Any type Fri, 04 Aug, 16:18
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-2729) Post commit fail: Input to GroupByKey must be of Tuple or Any type Fri, 04 Aug, 21:30
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-2587) Build fails due to python sdk Fri, 04 Aug, 21:30
Ahmet Altay (JIRA) [jira] [Comment Edited] (BEAM-2587) Build fails due to python sdk Fri, 04 Aug, 21:31
Ahmet Altay (JIRA) [jira] [Resolved] (BEAM-2729) Post commit fail: Input to GroupByKey must be of Tuple or Any type Sun, 06 Aug, 23:47
Ahmet Altay (JIRA) [jira] [Created] (BEAM-2755) Wordcount it test fail Tue, 08 Aug, 22:29
Ahmet Altay (JIRA) [jira] [Resolved] (BEAM-2731) Add a generic Reshuffle transform to Python SDK Wed, 09 Aug, 01:43
Ahmet Altay (JIRA) [jira] [Resolved] (BEAM-2755) Wordcount it test fail Fri, 11 Aug, 22:01
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-1251) Python 3 Support Wed, 16 Aug, 18:56
Ahmet Altay (JIRA) [jira] [Created] (BEAM-2797) Update unit tests for python mobile gaming examples Wed, 23 Aug, 20:12
Ahmet Altay (JIRA) [jira] [Resolved] (BEAM-2797) Update unit tests for python mobile gaming examples Thu, 24 Aug, 22:17
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-2797) Update unit tests for python mobile gaming examples Thu, 24 Aug, 22:17
Ahmet Altay (JIRA) [jira] [Created] (BEAM-2813) error: option --test-pipeline-options not recognized Mon, 28 Aug, 20:43
Ahmet Altay (JIRA) [jira] [Created] (BEAM-2814) test_as_singleton_with_different_defaults test is flaky Mon, 28 Aug, 20:58
Ahmet Altay (JIRA) [jira] [Updated] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range Mon, 28 Aug, 21:11
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range Mon, 28 Aug, 21:12
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-2815) Python DirectRunner is unusable with input files in the 100-250MB range Mon, 28 Aug, 21:12
Ahmet Altay (JIRA) [jira] [Updated] (BEAM-2814) test_as_singleton_with_different_defaults test is flaky Mon, 28 Aug, 21:18
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-2813) error: option --test-pipeline-options not recognized Mon, 28 Aug, 23:01
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-2813) error: option --test-pipeline-options not recognized Mon, 28 Aug, 23:38
Ahmet Altay (JIRA) [jira] [Resolved] (BEAM-2813) error: option --test-pipeline-options not recognized Mon, 28 Aug, 23:39
Ahmet Altay (JIRA) [jira] [Created] (BEAM-2818) Test for circular dependencies Tue, 29 Aug, 00:22
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-2784) Fix issues from automated conversion to allow Python 2 functionality Tue, 29 Aug, 19:53
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-1927) Add tfrecord io to built in IO list Wed, 30 Aug, 21:47
Ahmet Altay (JIRA) [jira] [Resolved] (BEAM-1927) Add tfrecord io to built in IO list Wed, 30 Aug, 21:47
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-1927) Add tfrecord io to built in IO list Wed, 30 Aug, 21:47
Alex Filatov (JIRA) [jira] [Commented] (BEAM-2684) AmqpIOTest is flaky Thu, 10 Aug, 19:46
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-2140) Fix SplittableDoFn ValidatesRunner tests in FlinkRunner Mon, 07 Aug, 18:17
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-956) Execute ReduceFnRunner Directly in Flink Runner Thu, 24 Aug, 14:18
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-2806) support View.CreatePCollectionView in FlinkRunner Fri, 25 Aug, 08:49
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 · Next »Thread · Author · Date
Box list
Jul 2020111
Jun 2020328
May 2020369
Apr 2020435
Mar 20203566
Feb 2020812
Jan 2020365
Dec 2019281
Nov 2019299
Oct 2019545
Sep 2019348
Aug 2019351
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