[beam] branch master updated: [BEAM-10206] Add Go Vet to Github Actions (#16612)

2022-01-28 Thread lostluck
This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new 6c9c208  [BEAM-10206] Add Go Vet to Github Actions (#16612)
6c9c208 is described below

commit 6c9c208197d3d74b1c3643d22716ad3b00213506
Author: Jack McCluskey <34928439+jrmcclus...@users.noreply.github.com>
AuthorDate: Fri Jan 28 22:48:59 2022 -0500

[BEAM-10206] Add Go Vet to Github Actions (#16612)
---
 .github/workflows/go_tests.yml | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/.github/workflows/go_tests.yml b/.github/workflows/go_tests.yml
index 7964636..d909a27 100644
--- a/.github/workflows/go_tests.yml
+++ b/.github/workflows/go_tests.yml
@@ -45,4 +45,6 @@ jobs:
   - name: Run coverage
 run: cd sdks/go/pkg && go test -coverprofile=coverage.txt 
-covermode=atomic ./...
   - name: Upload to codecov
-run: bash <(curl -s https://codecov.io/bash)
\ No newline at end of file
+run: bash <(curl -s https://codecov.io/bash)
+  - name: Run vet
+run: cd sdks/go/pkg/beam && go vet --copylocks=false --unsafeptr=false 
./...


[beam] branch nightly-refs/heads/master updated (5e528cf -> c06a927)

2022-01-28 Thread github-bot
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from 5e528cf  Merge pull request #16621: added GitHub example references to 
Python multilang quickstart
 add e18e2b9  Merge pull request #16579 from Revert "Revert "Merge pull 
request #15863 from [BEAM-13184] Autoshard…
 add 178cb7b  Merge pull request #16606 from [BEAM-13247] [Playground] 
Embedding iframe
 add fd95270  Update Python SDK beam-master tags (#16630)
 add 04fac55  Merge pull request #16592 from [BEAM-13722][Playground] Add 
precompiling of the graph into examples CI/CD
 add a4fcd93  Merge pull request #16505 from [BEAM-13527] [Playground] 
Pipeline options dialog
 add bdee4d0  [BEAM-13751] Don't block on gcloud when attempting to get 
default GCP region.
 add 03a556a  [BEAM-13751] Parameterize wait timeout so test doesn't waste 
2s.
 add 07e903b  [BEAM-13751] Add comment explaining sleep.
 add 51d7e63  Merge pull request #16639 from ibzib/BEAM-13751
 add c06a927  [BEAM-13293] XLang Jdbc IO for Go SDK (#16111)

No new revisions were added by this update.

Summary of changes:
 playground/backend/internal/api/v1/api.pb.go   | 587 +
 playground/backend/internal/api/v1/api_grpc.pb.go  |  38 ++
 playground/frontend/lib/api/v1/api.pb.dart |  96 
 playground/frontend/lib/api/v1/api.pbgrpc.dart |  33 ++
 playground/frontend/lib/api/v1/api.pbjson.dart |  20 +
 playground/frontend/lib/config/theme.dart  |  16 +
 playground/frontend/lib/constants/params.dart  |   2 +
 playground/frontend/lib/constants/sizes.dart   |   3 +-
 playground/frontend/lib/l10n/app_en.arb|  36 ++
 .../modules/editor/components/editor_textarea.dart |  33 +-
 .../pipeline_option_label.dart}|  14 +-
 .../pipeline_option_model.dart}|  13 +-
 .../pipeline_options_dropdown.dart}|  52 +-
 .../pipeline_options_dropdown_body.dart| 229 
 .../pipeline_options_dropdown_input.dart}  |  38 +-
 .../pipeline_options_dropdown_separator.dart}  |  20 +-
 .../pipeline_options_form.dart |  86 +++
 .../pipeline_options_text_field.dart   |  66 +++
 .../components/pipeline_options_text_field.dart|  81 ---
 .../lib/modules/editor/components/run_button.dart  |   2 +-
 .../lib/modules/output/components/output.dart  |   9 +-
 .../components/output_header/output_header.dart|   4 +-
 .../components/embedded_actions.dart   |  34 +-
 .../components/embedded_appbar_title.dart  |  85 +++
 .../components/embedded_editor.dart|   7 +-
 .../components/embedded_split_view.dart|  90 
 .../embedded_page_providers.dart}  |  98 ++--
 .../embedded_playground_page.dart  |  39 +-
 .../components/editor_textarea_wrapper.dart|   8 +-
 .../components/playground_page_body.dart   |   4 +-
 .../lib/pages/playground/playground_page.dart  |   7 +-
 .../pages/playground/states/playground_state.dart  |   1 +
 playground/frontend/lib/pages/routes.dart  |   4 +-
 playground/frontend/pubspec.lock   |   2 +-
 playground/frontend/pubspec.yaml   |   1 +
 playground/infrastructure/api/v1/api_pb2.py| 188 +--
 playground/infrastructure/api/v1/api_pb2_grpc.py   |  34 ++
 playground/infrastructure/cd_helper.py |  16 +-
 playground/infrastructure/config.py|   1 +
 playground/infrastructure/grpc_client.py   |  19 +
 playground/infrastructure/helper.py|   1 +
 .../dataflow/options/DefaultGcpRegionFactory.java  |  21 +-
 .../options/DataflowPipelineOptionsTest.java   |  92 +++-
 sdks/go.mod|   8 +-
 sdks/go.sum| 540 ++-
 sdks/go/pkg/beam/core/graph/coder/row_decoder.go   |   2 +-
 sdks/go/pkg/beam/io/xlang/jdbcio/jdbc.go   | 235 +
 sdks/go/test/integration/integration.go|   3 +
 sdks/go/test/integration/io/xlang/jdbc/jdbc.go |  68 +++
 .../go/test/integration/io/xlang/jdbc/jdbc_test.go | 113 
 sdks/java/container/boot.go|   4 +-
 sdks/java/container/build.gradle   |   4 +-
 .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java   | 112 +++-
 .../java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java |  39 ++
 .../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java|  30 ++
 .../apache_beam/runners/dataflow/internal/names.py |   4 +-
 .../content/en/get-started/try-beam-playground.md  |   2 +-
 .../www/site/layouts/shortcodes/playground.html|   4 +-
 58 files changed, 2811 insertions(+), 587 deletions(-)
 copy 
playground/frontend/lib/{pages/playground/components/close_listener_nonweb.dart 
=> 

[beam] branch master updated (51d7e63 -> c06a927)

2022-01-28 Thread lostluck
This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from 51d7e63  Merge pull request #16639 from ibzib/BEAM-13751
 add c06a927  [BEAM-13293] XLang Jdbc IO for Go SDK (#16111)

No new revisions were added by this update.

Summary of changes:
 sdks/go.mod|   8 +-
 sdks/go.sum| 540 -
 sdks/go/pkg/beam/core/graph/coder/row_decoder.go   |   2 +-
 sdks/go/pkg/beam/io/xlang/jdbcio/jdbc.go   | 235 +
 sdks/go/test/integration/integration.go|   3 +
 sdks/go/test/integration/io/xlang/jdbc/jdbc.go |  68 +++
 .../go/test/integration/io/xlang/jdbc/jdbc_test.go | 113 +
 sdks/java/container/boot.go|   4 +-
 sdks/java/container/build.gradle   |   4 +-
 9 files changed, 967 insertions(+), 10 deletions(-)
 create mode 100644 sdks/go/pkg/beam/io/xlang/jdbcio/jdbc.go
 create mode 100644 sdks/go/test/integration/io/xlang/jdbc/jdbc.go
 create mode 100644 sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go


[beam] branch master updated (a4fcd93 -> 51d7e63)

2022-01-28 Thread ibzib
This is an automated email from the ASF dual-hosted git repository.

ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from a4fcd93  Merge pull request #16505 from [BEAM-13527] [Playground] 
Pipeline options dialog
 new bdee4d0  [BEAM-13751] Don't block on gcloud when attempting to get 
default GCP region.
 new 03a556a  [BEAM-13751] Parameterize wait timeout so test doesn't waste 
2s.
 new 07e903b  [BEAM-13751] Add comment explaining sleep.
 new 51d7e63  Merge pull request #16639 from ibzib/BEAM-13751

The 34370 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../dataflow/options/DefaultGcpRegionFactory.java  | 21 +++--
 .../options/DataflowPipelineOptionsTest.java   | 92 --
 2 files changed, 101 insertions(+), 12 deletions(-)


[beam] branch master updated: Merge pull request #16505 from [BEAM-13527] [Playground] Pipeline options dialog

2022-01-28 Thread pabloem
This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new a4fcd93  Merge pull request #16505 from [BEAM-13527] [Playground] 
Pipeline options dialog
a4fcd93 is described below

commit a4fcd939dcfa35ad2517e5c7f05eb5bb1333f66f
Author: Aydar Farrakhov 
AuthorDate: Fri Jan 28 21:34:33 2022 +0300

Merge pull request #16505 from [BEAM-13527] [Playground] Pipeline options 
dialog

* [BEAM-13527] pipeline options dropdown

* [BEAM-13527] playground - parse pipeline error message

* [BEAM-13527] playground - fix parse options

* [BEAM-13527] playground - move pipelines options lines count to const

* [BEAM-13527] playground fix tests

* fix merge

* [BEAM-13527] pipeline options fix review comments

* [BEAM-13527] pipeline options fix review comments
---
 playground/frontend/lib/config/theme.dart  |  16 ++
 playground/frontend/lib/constants/sizes.dart   |   3 +-
 playground/frontend/lib/l10n/app_en.arb|  36 
 .../pipeline_option_label.dart |  35 
 .../pipeline_option_model.dart |  29 +++
 .../pipeline_options_dropdown.dart |  51 +
 .../pipeline_options_dropdown_body.dart| 229 +
 .../pipeline_options_dropdown_input.dart   |  48 +
 .../pipeline_options_dropdown_separator.dart   |  35 
 .../pipeline_options_form.dart |  86 
 .../pipeline_options_text_field.dart   |  66 ++
 .../components/pipeline_options_text_field.dart|  81 
 .../lib/modules/editor/components/run_button.dart  |   2 +-
 .../components/editor_textarea_wrapper.dart|   7 +-
 .../lib/pages/playground/playground_page.dart  |   7 +-
 .../pages/playground/states/playground_state.dart  |   1 +
 playground/frontend/pubspec.lock   |   2 +-
 playground/frontend/pubspec.yaml   |   1 +
 18 files changed, 644 insertions(+), 91 deletions(-)

diff --git a/playground/frontend/lib/config/theme.dart 
b/playground/frontend/lib/config/theme.dart
index fed037a..d9fd937 100644
--- a/playground/frontend/lib/config/theme.dart
+++ b/playground/frontend/lib/config/theme.dart
@@ -70,6 +70,17 @@ TextButtonThemeData createTextButtonTheme(Color textColor) {
   );
 }
 
+OutlinedButtonThemeData createOutlineButtonTheme(Color textColor) {
+  return OutlinedButtonThemeData(
+style: OutlinedButton.styleFrom(
+  primary: textColor,
+  shape: const RoundedRectangleBorder(
+borderRadius: BorderRadius.all(Radius.circular(kSmBorderRadius)),
+  ),
+),
+  );
+}
+
 ElevatedButtonThemeData createElevatedButtonTheme(Color primaryColor) {
   return ElevatedButtonThemeData(
 style: ElevatedButton.styleFrom(primary: primaryColor),
@@ -95,9 +106,12 @@ AppBarTheme createAppBarTheme(Color backgroundColor) {
 }
 
 TabBarTheme createTabBarTheme(Color textColor, Color indicatorColor) {
+  const labelStyle = TextStyle(fontWeight: kMediumWeight);
   return TabBarTheme(
 unselectedLabelColor: textColor,
 labelColor: textColor,
+labelStyle: labelStyle,
+unselectedLabelStyle: labelStyle,
 indicator: UnderlineTabIndicator(
   borderSide: BorderSide(width: 2.0, color: indicatorColor),
 ),
@@ -122,6 +136,7 @@ final kLightTheme = ThemeData(
   textTheme: createTextTheme(kLightText),
   popupMenuTheme: createPopupMenuTheme(),
   textButtonTheme: createTextButtonTheme(kLightText),
+  outlinedButtonTheme: createOutlineButtonTheme(kLightText),
   elevatedButtonTheme: createElevatedButtonTheme(kLightPrimary),
   tabBarTheme: createTabBarTheme(kLightText, kLightPrimary),
   dialogTheme: createDialogTheme(kLightText),
@@ -135,6 +150,7 @@ final kDarkTheme = ThemeData(
   textTheme: createTextTheme(kDarkText),
   popupMenuTheme: createPopupMenuTheme(),
   textButtonTheme: createTextButtonTheme(kDarkText),
+  outlinedButtonTheme: createOutlineButtonTheme(kDarkText),
   elevatedButtonTheme: createElevatedButtonTheme(kDarkPrimary),
   tabBarTheme: createTabBarTheme(kDarkText, kDarkPrimary),
   dialogTheme: createDialogTheme(kDarkText),
diff --git a/playground/frontend/lib/constants/sizes.dart 
b/playground/frontend/lib/constants/sizes.dart
index 24728b0..3962a19 100644
--- a/playground/frontend/lib/constants/sizes.dart
+++ b/playground/frontend/lib/constants/sizes.dart
@@ -27,7 +27,7 @@ const double kXxlSpacing = 36.0;
 // sizes
 const kHeaderButtonHeight = 46.0;
 const kRunButtonWidth = 150.0;
-const kRunButtonHeight = 40.0;
+const kButtonHeight = 40.0;
 const kIconButtonSplashRadius = 24.0;
 const kFooterHeight = 32.0;
 
@@ -59,3 +59,4 @@ const double kTitleFontSize = 18.0;
 
 //divider size
 const double kDividerHeight = 1.0;
+const double kLgDividerHeight = 2.0;
diff 

[beam] branch master updated (fd95270 -> 04fac55)

2022-01-28 Thread pabloem
This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


from fd95270  Update Python SDK beam-master tags (#16630)
 add 04fac55  Merge pull request #16592 from [BEAM-13722][Playground] Add 
precompiling of the graph into examples CI/CD

No new revisions were added by this update.

Summary of changes:
 playground/backend/internal/api/v1/api.pb.go  | 587 ++
 playground/backend/internal/api/v1/api_grpc.pb.go |  38 ++
 playground/frontend/lib/api/v1/api.pb.dart|  96 
 playground/frontend/lib/api/v1/api.pbgrpc.dart|  33 ++
 playground/frontend/lib/api/v1/api.pbjson.dart|  20 +
 playground/infrastructure/api/v1/api_pb2.py   | 188 +--
 playground/infrastructure/api/v1/api_pb2_grpc.py  |  34 ++
 playground/infrastructure/cd_helper.py|  16 +-
 playground/infrastructure/config.py   |   1 +
 playground/infrastructure/grpc_client.py  |  19 +
 playground/infrastructure/helper.py   |   1 +
 11 files changed, 762 insertions(+), 271 deletions(-)


[beam] branch master updated: Update Python SDK beam-master tags (#16630)

2022-01-28 Thread emilyye
This is an automated email from the ASF dual-hosted git repository.

emilyye pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
 new fd95270  Update Python SDK beam-master tags (#16630)
fd95270 is described below

commit fd95270fdbd8055aa9ed9d5576d220b1914adda1
Author: emily 
AuthorDate: Fri Jan 28 08:48:49 2022 -0800

Update Python SDK beam-master tags (#16630)
---
 sdks/python/apache_beam/runners/dataflow/internal/names.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/runners/dataflow/internal/names.py 
b/sdks/python/apache_beam/runners/dataflow/internal/names.py
index ce85259..be6a2c0 100644
--- a/sdks/python/apache_beam/runners/dataflow/internal/names.py
+++ b/sdks/python/apache_beam/runners/dataflow/internal/names.py
@@ -36,10 +36,10 @@ SERIALIZED_SOURCE_KEY = 'serialized_source'
 
 # Update this version to the next version whenever there is a change that will
 # require changes to legacy Dataflow worker execution environment.
-BEAM_CONTAINER_VERSION = 'beam-master-20220113'
+BEAM_CONTAINER_VERSION = 'beam-master-20220126'
 # Update this version to the next version whenever there is a change that
 # requires changes to SDK harness container or SDK harness launcher.
-BEAM_FNAPI_CONTAINER_VERSION = 'beam-master-20220117'
+BEAM_FNAPI_CONTAINER_VERSION = 'beam-master-20220126'
 
 DATAFLOW_CONTAINER_IMAGE_REPOSITORY = 'gcr.io/cloud-dataflow/v1beta3'