beam-commits mailing list archives: July 2019

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
al...@apache.org [beam] branch master updated: [BEAM-7632] Update Python quickstart guide for Flink and Spark Wed, 17 Jul, 00:33
al...@apache.org [beam] branch master updated: Add Python snippet for Regex transform Wed, 17 Jul, 00:49
al...@apache.org [beam] branch master updated (2b5e30d -> 38f8f3a) Wed, 17 Jul, 18:56
al...@apache.org [beam] branch master updated: Skip DoFn params test in Python 2 on Windows Sat, 20 Jul, 01:08
al...@apache.org [beam] branch master updated (11215fc -> 7fe54a0) Sat, 20 Jul, 01:46
al...@apache.org [beam] branch master updated (ff7a803 -> ab80cc5) Mon, 22 Jul, 17:29
al...@apache.org [beam] branch master updated: Update Python 3 entry in Python SDK roadmap. Mon, 22 Jul, 22:54
al...@apache.org [beam] branch master updated (75875de -> e9009cf) Tue, 23 Jul, 16:45
al...@apache.org [beam] branch master updated (5796931 -> 667bf85) Wed, 24 Jul, 15:52
al...@apache.org [beam] branch master updated (8050915 -> ea024fc) Thu, 25 Jul, 00:28
al...@apache.org [beam] branch master updated: Upgrade google-cloud-core and google-cloud-bigquery dependencies Fri, 26 Jul, 21:57
al...@apache.org [beam] branch master updated (a60d550 -> c4c75bd) Tue, 30 Jul, 17:39
al...@apache.org [beam] branch master updated: Change retry policy for dataflow's list_messages Tue, 30 Jul, 22:32
al...@apache.org [beam] branch master updated: Fixed type on singleton side inputs sample Wed, 31 Jul, 01:30
al...@apache.org [beam] branch master updated: [BEAM-7389] Add code examples for Filter page (#9184) Wed, 31 Jul, 22:09
amaliu...@apache.org [beam] branch master updated: [BEAM-7728] [SQL] Support ParquetTable (#9054) Tue, 30 Jul, 23:40
amaliu...@apache.org [beam] branch rw_beam_zetasql created (now 3c36700) Wed, 31 Jul, 23:00
amaliu...@apache.org [beam] 01/01: [BEAM-7832] Add ZetaSQL as a dialect in BeamSQL. Wed, 31 Jul, 23:01
an...@apache.org [beam] branch master updated: [BEAM-7545] Adding RowCount to TextTable. Mon, 01 Jul, 16:46
an...@apache.org [beam] branch release-2.14.0 updated (524272b -> 18f64aa) Thu, 11 Jul, 15:48
an...@apache.org [beam] branch release-2.14.0 updated: Update pyarrow version requirement in setup.py Thu, 11 Jul, 17:28
an...@apache.org [beam] branch release-2.14.0 updated: Merge pull request #8925 from apache/aaltay-patch-1 Thu, 11 Jul, 17:28
an...@apache.org [beam] branch release-2.14.0 updated: BEAM-7548 fix flaky tests for ApproximateUnique Thu, 11 Jul, 18:07
an...@apache.org [beam] branch release-2.14.0 updated: [BEAM-7424] Retry HTTP 429 errors from GCS Thu, 11 Jul, 20:18
an...@apache.org [beam] branch master updated: [BEAM-7729] Fixes the bug by checking the value first before parsing it. Fri, 12 Jul, 16:30
an...@apache.org [beam] branch release-2.14.0 updated: [BEAM-7689] make a temporary directory unique for FileBaseSink Fri, 12 Jul, 19:54
an...@apache.org [beam] branch master updated (76bc70d -> 8656d4c) Thu, 18 Jul, 00:49
an...@apache.org [beam] branch master updated: [BEAM-7783] Adding BeamTableStatistics. Mon, 22 Jul, 17:11
an...@apache.org [beam] branch release-2.14.0 updated: Relax pydot requirements. Tue, 23 Jul, 21:32
an...@apache.org [beam] branch release-2.14.0 updated: Revert "Moving to 2.15.0-SNAPSHOT on master branch." Wed, 24 Jul, 20:59
an...@apache.org svn commit: r35011 - in /dev/beam/2.14.0: ./ apache-beam-2.14.0-source-release.zip apache-beam-2.14.0-source-release.zip.asc apache-beam-2.14.0-source-release.zip.sha512 Wed, 24 Jul, 22:29
an...@apache.org svn commit: r35012 - in /dev/beam/2.14.0/python: ./ apache-beam-2.14.0.zip apache-beam-2.14.0.zip.asc apache-beam-2.14.0.zip.sha512 Wed, 24 Jul, 22:30
an...@apache.org svn commit: r35024 - /dev/beam/2.14.0/python/ Thu, 25 Jul, 19:47
an...@apache.org [beam] tag v2.14.0-RC1 created (now ae926f9) Thu, 25 Jul, 21:29
an...@apache.org [beam] branch master updated: [BEAM-7823] Implementing a Custom NonCumulativeCost Handler Fri, 26 Jul, 01:24
an...@apache.org [beam] branch master updated: [BEAM-7783] BeamIOSourceRel using custom BeamStatistics Mon, 29 Jul, 16:35
an...@apache.org [beam] branch master updated: [BEAM-7623] Add support to select MAP with Row as values in Beam SQL Mon, 29 Jul, 17:47
an...@apache.org [beam] branch master updated: [BEAM-7808] Add method to convert avro field to beam field Wed, 31 Jul, 16:54
an...@apache.org [beam] branch master updated: Update design-documents.md Wed, 31 Jul, 21:38
apill...@apache.org [beam] branch master updated (f2a2f2a -> 10fd794) Thu, 11 Jul, 19:54
apill...@apache.org [beam] 01/01: Merge pull request #8930: [BEAM-7621] Null pointer exception when accessing null row fields in BeamSql Thu, 11 Jul, 19:54
apill...@apache.org [beam] branch sql-shade created (now e63133e) Wed, 17 Jul, 18:30
apill...@apache.org [beam] 01/01: Remove unneeded relocation for protobuf. Wed, 17 Jul, 18:30
apill...@apache.org [beam] branch sql-shade deleted (was e63133e) Wed, 17 Jul, 18:30
aromane...@apache.org [beam] branch master updated (f22070b -> 0d74293) Mon, 01 Jul, 12:30
aromane...@apache.org [beam] 01/01: Merge pull request #8963: [BEAM-7640] Create amazon-web-services2 module and AwsOptions Mon, 01 Jul, 12:30
aromane...@apache.org [beam] branch master updated (fbd1f4c -> 3643f43) Tue, 02 Jul, 16:00
aromane...@apache.org [beam] 01/01: Merge pull request #8983: [BEAM-7640] Rename the package name for amazon-web-services2 from aws to aws2 Tue, 02 Jul, 16:00
aromane...@apache.org [beam] branch master updated (b79f24c -> 32e2e3e) Wed, 03 Jul, 13:21
aromane...@apache.org [beam] 01/01: Merge pull request #8986: [BEAM-4420] Add KafkaIO Integration Tests Wed, 03 Jul, 13:21
aromane...@apache.org [beam] branch master updated (cfecfb0 -> b2f0171) Thu, 04 Jul, 09:41
aromane...@apache.org [beam] 01/01: Merge pull request #8995: [BEAM-7682] Fix Combine.GroupedValues javadoc code snippet Thu, 04 Jul, 09:41
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated: Add metrics support in DoFn Fri, 05 Jul, 14:53
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated: Add setEnableSparkMetricSinks() Mon, 08 Jul, 09:57
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated: Add setEnableSparkMetricSinks() method Mon, 08 Jul, 16:03
aromane...@apache.org [beam] branch master updated: [BEAM-6480] Adds AvroIO sink for generic records. (#9005) Tue, 09 Jul, 13:00
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated: Persist all output Dataset if there are multiple outputs in pipeline Enabled Use*Metrics tests Wed, 10 Jul, 17:12
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated (df41a8b -> b9c8925) Fri, 12 Jul, 11:37
aromane...@apache.org [beam] 01/02: Added metrics sinks and tests Fri, 12 Jul, 11:37
aromane...@apache.org [beam] 02/02: Make spotless happy Fri, 12 Jul, 11:37
aromane...@apache.org [beam] branch release-2.14.0 updated (3187089 -> 4c3a329) Wed, 17 Jul, 09:14
aromane...@apache.org [beam] 01/01: Merge pull request #9078: [release-2.14.0][BEAM-7715] Mark user facing APIs related to External transforms as @Experimental Wed, 17 Jul, 09:14
aromane...@apache.org [beam] branch master updated (ccfd31e -> adb281f) Wed, 17 Jul, 14:19
aromane...@apache.org [beam] 01/01: Merge pull request #9073: [BEAM-4420] KafkaIOIT metrics collection Wed, 17 Jul, 14:19
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated: Use "sparkMaster" in local mode to obtain number of shuffle partitions + spotless apply Fri, 19 Jul, 13:50
aromane...@apache.org [beam] branch spark-runner_structured-streaming updated: Fix hardcoded value Fri, 19 Jul, 14:42
boyu...@apache.org [beam] branch master updated: Tiny typo fix Mon, 01 Jul, 23:46
boyu...@apache.org [beam] branch master updated: Fix RestrictionTracker docstring Mon, 08 Jul, 22:19
boyu...@apache.org [beam] branch master updated (5fb21e3 -> 6fd2490) Mon, 15 Jul, 19:28
boyu...@apache.org [beam] branch master updated: Add last_attempted_record_start to python OffsetRangeTracker (#9058) Thu, 18 Jul, 21:44
boyu...@apache.org [beam] branch master updated (ea024fc -> 9f933a6) Thu, 25 Jul, 04:39
chamik...@apache.org [beam] branch master updated (7f83599 -> b79f24c) Tue, 02 Jul, 22:02
chamik...@apache.org [beam] 01/01: Merge pull request #8878: [BEAM-5315] improve test coverage bigquery special chars Tue, 02 Jul, 22:02
chamik...@apache.org [beam] branch master updated: [BEAM-7389] Add Python snippet for Partition transform (#8904) Wed, 10 Jul, 21:21
chamik...@apache.org [beam] branch master updated (4169307 -> 5b68aae) Wed, 10 Jul, 22:44
chamik...@apache.org [beam] 01/01: Merge pull request #9013: [BEAM-7689] make a temporary directory unique for FileBaseSink Wed, 10 Jul, 22:44
chamik...@apache.org [beam] branch master updated (a199e6b -> f2a2f2a) Thu, 11 Jul, 17:52
chamik...@apache.org [beam] 01/01: Merge pull request #8989: Remove unused NEWLINE in TextSink.TextWriter Thu, 11 Jul, 17:53
chamik...@apache.org [beam] branch master updated (db59a3d -> a0ec59b) Wed, 17 Jul, 03:37
chamik...@apache.org [beam] 01/01: Merge pull request #9059: [BEAM-7743] Fix stream position bug in BigQuery Storage stream source. Wed, 17 Jul, 03:37
chamik...@apache.org [beam] branch master updated (23a879f -> 94a3c85) Mon, 22 Jul, 04:27
chamik...@apache.org [beam] 01/01: Merge pull request #8945: [BEAM-5191] Support for BigQuery clustering Mon, 22 Jul, 04:27
chamik...@apache.org [beam] branch master updated (5c6f428 -> 4eb7610) Thu, 25 Jul, 17:46
chamik...@apache.org [beam] 01/01: Merge pull request #9079: [BEAM-7495] Add progress reporting to the BigQuery source Thu, 25 Jul, 17:46
chamik...@apache.org [beam] branch master updated (c4c75bd -> 0f2c9dd) Tue, 30 Jul, 18:48
chamik...@apache.org [beam] 01/01: Merge pull request #9165: [BEAM-7824] Sets a default environment for Dataflow runner Tue, 30 Jul, 18:48
d...@apache.org [beam] branch master updated (4e40b53 -> 8f6247e) Mon, 29 Jul, 16:07
d...@apache.org [beam] 01/01: Merge pull request #9176: [BEAM-7366] Restore Spotless check for Flink Runner Mon, 29 Jul, 16:07
d...@apache.org [beam] branch master updated (fb83467 -> c787b5e) Tue, 30 Jul, 11:06
echauc...@apache.org [beam] branch spark-runner_structured-streaming updated (dcb3949 -> fc83520) Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 01/13: Fix bug in the window merging logic Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 02/13: Remove the mapPartition that adds a key per partition because otherwise spark will reduce values per key instead of globally Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 03/13: Remove CombineGlobally translation because it is less performant than the beam sdk one (key + combinePerKey.withHotkeyFanout) Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 04/13: Now that there is only Combine.PerKey translation, make only one Aggregator Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 05/13: Clean no more needed KVHelpers Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 06/13: Clean not more needed RowHelpers Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 07/13: Clean not more needed WindowingHelpers Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 08/13: Fix javadoc of AggregatorCombiner Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 09/13: Fixed immutable list bug Fri, 05 Jul, 13:53
echauc...@apache.org [beam] 10/13: add comment in combine globally test Fri, 05 Jul, 13:53
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
Dec 2019121
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