beam-issues mailing list archives: April 2020

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 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · Next »Thread · Author · Date
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-7923) Interactive Beam Wed, 01 Apr, 00:10
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators Wed, 01 Apr, 00:22
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators Wed, 01 Apr, 00:23
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 00:34
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 00:41
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators Wed, 01 Apr, 00:45
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8831) Python PreCommit Failures: Could not copy file '/some/path/file.egg' Wed, 01 Apr, 01:42
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 02:01
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 02:10
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators Wed, 01 Apr, 02:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators Wed, 01 Apr, 02:19
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 02:28
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 02:46
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 03:20
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9263) Bump python sdk fnapi version to enable status reporting Wed, 01 Apr, 03:30
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 04:39
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9636) Run Dataflow ValidatesRunner (:runners:google-cloud-dataflow-java:validatesRunnerLegacyWorkerTest) failing Wed, 01 Apr, 05:18
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9008) Add readAll() method to CassandraIO Wed, 01 Apr, 05:37
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9008) Add readAll() method to CassandraIO Wed, 01 Apr, 05:38
Alex Van Boxel (Jira) [jira] [Commented] (BEAM-9456) Upgrade to gradle 6.2 Wed, 01 Apr, 06:00
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-7923) Interactive Beam Wed, 01 Apr, 06:06
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9147) [Java] PTransform that integrates Video Intelligence functionality Wed, 01 Apr, 06:13
MinWang (Jira) [jira] [Commented] (BEAM-2466) Add Kafka Streams runner Wed, 01 Apr, 07:17
Maximilian Michels (Jira) [jira] [Created] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 08:02
Maximilian Michels (Jira) [jira] [Closed] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 08:03
Maximilian Michels (Jira) [jira] [Updated] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 08:03
Ismaël Mejía (Jira) [jira] [Updated] (BEAM-9652) BigQueryIO MultiPartitionsWriteTables fails with ClassCastException: java.lang.Object cannot be cast to org.apache.beam.sdk.values.KV Wed, 01 Apr, 08:10
Ismaël Mejía (Jira) [jira] [Updated] (BEAM-9651) StreamingDataflowWorker stuck waiting for org.apache.beam.runners.dataflow.worker.windmill.DirectStreamObserver.onNext Wed, 01 Apr, 08:10
Ismaël Mejía (Jira) [jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results Wed, 01 Apr, 08:11
Ismaël Mejía (Jira) [jira] [Updated] (BEAM-9650) Add consistent slowly changing side inputs support Wed, 01 Apr, 08:11
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:12
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:16
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:16
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:17
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:17
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:17
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:17
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:18
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:18
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1819) Key should be available in @OnTimer methods Wed, 01 Apr, 08:19
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9653) remove _AvroSource in favor of using _FastAvroSource Wed, 01 Apr, 08:36
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9653) remove _AvroSource in favor of using _FastAvroSource Wed, 01 Apr, 08:36
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 09:12
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 09:15
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 09:34
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input. Wed, 01 Apr, 10:08
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9654) Update Jet Runner to 4.0 Wed, 01 Apr, 10:35
Kyle Winkelman (Jira) [jira] [Commented] (BEAM-2466) Add Kafka Streams runner Wed, 01 Apr, 11:59
Maximilian Michels (Jira) [jira] [Updated] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 12:02
Maximilian Michels (Jira) [jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 12:05
Léopold Boudard (Jira) [jira] [Commented] (BEAM-9645) Python flinkrunner cannot inspect container Wed, 01 Apr, 12:21
Léopold Boudard (Jira) [jira] [Created] (BEAM-9655) Stateful Dataflow runner? Wed, 01 Apr, 12:44
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9550) beam_PostCommit_Python_Chicago_Taxi_Flink OOM Wed, 01 Apr, 13:05
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9550) beam_PostCommit_Python_Chicago_Taxi_Flink OOM Wed, 01 Apr, 13:06
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 13:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9652) BigQueryIO MultiPartitionsWriteTables fails with ClassCastException: java.lang.Object cannot be cast to org.apache.beam.sdk.values.KV Wed, 01 Apr, 13:55
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9652) BigQueryIO MultiPartitionsWriteTables fails with ClassCastException: java.lang.Object cannot be cast to org.apache.beam.sdk.values.KV Wed, 01 Apr, 13:55
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9476) KinesisIO DescribeStream transient errors are not retried Wed, 01 Apr, 14:05
Brian Hulette (Jira) [jira] [Commented] (BEAM-9546) Support for batching a schema-aware PCollection and processing as a Dataframe Wed, 01 Apr, 14:27
Luke Cwik (Jira) [jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 14:55
Luke Cwik (Jira) [jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 15:00
Maximilian Michels (Jira) [jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 15:19
dasch (Jira) [jira] [Commented] (BEAM-9456) Upgrade to gradle 6.2 Wed, 01 Apr, 15:50
Alexey Romanenko (Jira) [jira] [Commented] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner Wed, 01 Apr, 16:26
Alexey Romanenko (Jira) [jira] [Updated] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner Wed, 01 Apr, 16:27
Alexey Romanenko (Jira) [jira] [Updated] (BEAM-9627) KafkaIO needs better support for SSL Wed, 01 Apr, 16:47
Alexey Romanenko (Jira) [jira] [Updated] (BEAM-9525) KafkaIO attempting to make connection when uploading via Dataflow Runner Wed, 01 Apr, 16:47
Alexey Romanenko (Jira) [jira] [Commented] (BEAM-9627) KafkaIO needs better support for SSL Wed, 01 Apr, 16:47
Ismaël Mejía (Jira) [jira] [Updated] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 16:51
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-8889) Make GcsUtil use GoogleCloudStorage Wed, 01 Apr, 17:01
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-1894) Race conditions in python direct runner eager mode Wed, 01 Apr, 17:55
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9650) Add consistent slowly changing side inputs support Wed, 01 Apr, 17:55
Léopold Boudard (Jira) [jira] [Created] (BEAM-9656) Reading from pubsub in portable FlinkRunner Wed, 01 Apr, 17:57
Léopold Boudard (Jira) [jira] [Updated] (BEAM-9656) Reading from pubsub in portable FlinkRunner Wed, 01 Apr, 18:09
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9652) BigQueryIO MultiPartitionsWriteTables fails with ClassCastException: java.lang.Object cannot be cast to org.apache.beam.sdk.values.KV Wed, 01 Apr, 18:13
Léopold Boudard (Jira) [jira] [Updated] (BEAM-9656) Reading from pubsub in portable FlinkRunner Wed, 01 Apr, 18:13
Léopold Boudard (Jira) [jira] [Commented] (BEAM-9656) Reading from pubsub in portable FlinkRunner Wed, 01 Apr, 18:20
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9636) Run Dataflow ValidatesRunner (:runners:google-cloud-dataflow-java:validatesRunnerLegacyWorkerTest) failing Wed, 01 Apr, 18:28
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9624) Combine operation should support only converting to accumulators Wed, 01 Apr, 18:34
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-3097) Allow BigQuerySource to take a ValueProvider as a table input. Wed, 01 Apr, 18:35
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 18:46
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 18:46
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 18:46
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9639) Abstract bundle execution logic from stage execution logic Wed, 01 Apr, 18:51
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9642) Add SDF execution-time runners Wed, 01 Apr, 18:54
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9562) Remove timer from PCollection and treat timers as Elements Wed, 01 Apr, 19:20
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 19:42
ASF GitHub Bot (Jira) [jira] [Work logged] (BEAM-9608) Add context managers for FnApiRunner to manage execution of each bundle Wed, 01 Apr, 19:42
Luke Cwik (Jira) [jira] [Commented] (BEAM-8944) Python SDK harness performance degradation with UnboundedThreadPoolExecutor Wed, 01 Apr, 19:49
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 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · Next »Thread · Author · Date
Box list
Dec 2021504
Nov 20215206
Oct 20214806
Sep 20215100
Aug 20214569
Jul 20213617
Jun 20214793
May 20216033
Apr 20216937
Mar 20217106
Feb 20215271
Jan 20214939
Dec 20203819
Nov 20204274
Oct 20204776
Sep 20207240
Aug 20208989
Jul 20205851
Jun 202017961
May 20204714
Apr 20205404
Mar 20205316
Feb 20204938
Jan 20205069
Dec 20194839
Nov 20194670
Oct 20193948
Sep 20193661
Aug 20194546
Jul 20194345
Jun 20194398
May 20194454
Apr 20194369
Mar 20193560
Feb 20193619
Jan 20194402
Dec 20182799
Nov 20183761
Oct 20182638