| 397090770 |
[GitHub] beam pull request #2398: [BEAM-1856]HDFSFileSink class do not use the same c... |
Sat, 01 Apr, 09:38 |
| 397090770 |
[GitHub] beam pull request #2398: [BEAM-1856]HDFSFileSink class do not use the same c... |
Sat, 01 Apr, 09:39 |
| 397090770 |
[GitHub] beam pull request #2399: [BEAM-1856] |
Sat, 01 Apr, 09:44 |
| 397090770 |
[GitHub] beam pull request #2488: [BEAM-1491]Identify HADOOP_CONF_DIR(or YARN_CONF_DI... |
Tue, 11 Apr, 06:45 |
| 397090770 |
[GitHub] beam pull request #2759: [BEAM-1491]Identify HADOOP_CONF_DIR(or YARN_CONF_DI... |
Fri, 28 Apr, 09:31 |
| 397090770 |
[GitHub] beam pull request #2488: [BEAM-1491]Identify HADOOP_CONF_DIR(or YARN_CONF_DI... |
Fri, 28 Apr, 09:32 |
| Gergely Novák (JIRA) |
[jira] [Created] (BEAM-2110) HDFSFileSource throws IndexOutOfBoundsException when trying to read big file (gaming_data1.csv) |
Fri, 28 Apr, 11:47 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1870) ByteKey / ByteKeyRangeTracker should not use ByteString on public API surface |
Tue, 04 Apr, 16:49 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1550) HBaseIO tests timeout precommit |
Wed, 05 Apr, 04:31 |
| Ismaël Mejía (JIRA) |
[jira] [Closed] (BEAM-1550) HBaseIO tests timeout precommit |
Wed, 05 Apr, 04:32 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1881) Exclude protobuf-lite everywhere |
Wed, 05 Apr, 04:36 |
| Ismaël Mejía (JIRA) |
[jira] [Comment Edited] (BEAM-1881) Exclude protobuf-lite everywhere |
Wed, 05 Apr, 04:44 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1678) Create MemcachedIO |
Fri, 07 Apr, 05:54 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1678) Create MemcachedIO |
Fri, 07 Apr, 05:54 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1920) Add Spark 2.x support in Spark runner |
Mon, 10 Apr, 14:10 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1722) Get PubsubIO and the remaining parts of the GCP IOs out of the core SDK |
Tue, 11 Apr, 22:46 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1722) Move PubsubIO out of the core SDK |
Wed, 12 Apr, 13:08 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1722) Move PubsubIO out of the core SDK |
Wed, 12 Apr, 13:09 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-911) Most of IOs API should be flagged by @Experimental |
Wed, 12 Apr, 14:21 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1733) Python SDK build process leaks tox dependency into user space |
Wed, 12 Apr, 14:59 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-911) Mark API of multiple IOs as @Experimental |
Wed, 12 Apr, 15:17 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-981) Not possible to directly submit a pipeline on spark cluster |
Wed, 12 Apr, 15:49 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-981) Not possible to directly submit a pipeline on spark cluster |
Wed, 12 Apr, 15:49 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-981) Not possible to directly submit a pipeline on spark cluster |
Wed, 12 Apr, 15:50 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1722) Move PubsubIO out of the core SDK |
Wed, 12 Apr, 15:54 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1870) ByteKey / ByteKeyRangeTracker should not use ByteString on public API surface |
Sat, 15 Apr, 21:38 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-1984) Enable dependency analysis of non-compile dependencies |
Sun, 16 Apr, 15:52 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1984) Enable dependency analysis of non-compile dependencies |
Sun, 16 Apr, 15:52 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1984) Enable dependency analysis of non-compile dependencies |
Sun, 16 Apr, 15:52 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1993) Remove special unbounded Flink source/sink |
Tue, 18 Apr, 14:26 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1994) Remove Flink examples package |
Tue, 18 Apr, 14:28 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1993) Remove special unbounded Flink source/sink |
Tue, 18 Apr, 15:40 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1994) Remove Flink examples package |
Wed, 19 Apr, 13:17 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1783) Add Integration Tests for HBaseIO |
Wed, 19 Apr, 14:27 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1783) Add Integration Tests for HBaseIO |
Wed, 19 Apr, 14:27 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1533) Switch split implementation to use Beam’s classes for HBaseIO |
Wed, 19 Apr, 14:27 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1532) Improve splitting (support sub-splits) for HBaseIO |
Wed, 19 Apr, 14:28 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1531) Support dynamic work rebalancing for HBaseIO |
Wed, 19 Apr, 14:29 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-2005) Add a Hadoop FileSystem implementation of Beam's FileSystem |
Thu, 20 Apr, 07:43 |
| Ismaël Mejía (JIRA) |
[jira] [Closed] (BEAM-273) Update Flink Runner version |
Thu, 20 Apr, 12:38 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-273) Update Flink Runner version |
Thu, 20 Apr, 12:38 |
| Ismaël Mejía (JIRA) |
[jira] [Closed] (BEAM-1103) Add Tests For Aggregators in Flink Runner |
Thu, 20 Apr, 12:46 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1103) Add Tests For Aggregators in Flink Runner |
Thu, 20 Apr, 12:46 |
| Ismaël Mejía (JIRA) |
[jira] [Closed] (BEAM-140) Improve examples provided with the Flink runner |
Thu, 20 Apr, 12:52 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-140) Improve examples provided with the Flink runner |
Thu, 20 Apr, 12:52 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1868) CreateStreamTest is flaky on the Spark runner |
Thu, 20 Apr, 13:08 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-108) Support multiple Scala versions on the Flink runner |
Thu, 20 Apr, 13:15 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-2028) Support multiple Scala versions on the Spark runner |
Thu, 20 Apr, 13:18 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-2043) Issues with Apache Beam logos |
Fri, 21 Apr, 13:59 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-2043) Issues with Apache Beam logos |
Fri, 21 Apr, 14:00 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-2044) Upgrade HBaseIO to use HBase client version 1.3.1 |
Fri, 21 Apr, 14:42 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1948) Null pointer exception in DirectRunner.DirectPipelineResult.getAggregatorValues() |
Fri, 21 Apr, 17:02 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-2046) Better API for querying metrics |
Fri, 21 Apr, 21:58 |
| Ismaël Mejía (JIRA) |
[jira] [Reopened] (BEAM-2044) Upgrade HBaseIO to use HBase client version 1.3.1 |
Sat, 22 Apr, 12:28 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x) |
Sat, 22 Apr, 12:41 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x) |
Sat, 22 Apr, 12:42 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1520) Implement TFRecordIO (Reading/writing Tensorflow Standard format) |
Sun, 23 Apr, 19:49 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1836) Reopen BigQuery utils after #2271 |
Sun, 23 Apr, 19:53 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-715) Migrate AvroHDFSFileSource/HDFSFileSource/HDFSFileSink to use AutoValue to reduce boilerplate |
Sun, 23 Apr, 20:02 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-2025) WordCount Example lacks a link to Python full source code |
Sun, 23 Apr, 20:38 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-673) Data locality for Read.Bounded |
Mon, 24 Apr, 20:06 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-673) Data locality for Read.Bounded |
Mon, 24 Apr, 20:15 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-673) Data locality for Read.Bounded |
Mon, 24 Apr, 20:16 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-1886) Remove TextIO override in Flink runner |
Mon, 24 Apr, 20:26 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1886) Remove TextIO override in Flink runner |
Mon, 24 Apr, 20:26 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-2075) Update flink runner to use flink version 1.2.1 |
Tue, 25 Apr, 12:54 |
| Ismaël Mejía (JIRA) |
[jira] [Resolved] (BEAM-2075) Update flink runner to use flink version 1.2.1 |
Tue, 25 Apr, 13:24 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1158) Create HiveIO |
Tue, 25 Apr, 19:01 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-1158) Create HiveIO |
Tue, 25 Apr, 19:01 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-673) Data locality for Read.Bounded |
Tue, 25 Apr, 19:54 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-673) Data locality for Read.Bounded |
Wed, 26 Apr, 20:53 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-673) Data locality for Read.Bounded |
Wed, 26 Apr, 20:53 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-2085) DoFn could give hints to runners on resource requirements |
Wed, 26 Apr, 20:57 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-981) Not possible to directly submit a pipeline on spark cluster |
Thu, 27 Apr, 08:25 |
| Ismaël Mejía (JIRA) |
[jira] [Created] (BEAM-2090) Create a maven artifact to build a ready to install version of the Beam Flink runner |
Thu, 27 Apr, 09:03 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-2056) Add tests for exporting Beam Metrics to Flink Metrics |
Thu, 27 Apr, 13:26 |
| Ismaël Mejía (JIRA) |
[jira] [Assigned] (BEAM-1764) Remove aggregators from Flink Runner |
Thu, 27 Apr, 22:15 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1764) Remove aggregators from Flink Runner |
Thu, 27 Apr, 22:17 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1764) Remove aggregators from Flink Runner |
Thu, 27 Apr, 22:18 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1765) Remove Aggregators from Spark runner |
Thu, 27 Apr, 22:20 |
| Ismaël Mejía (JIRA) |
[jira] [Updated] (BEAM-1765) Remove Aggregators from Spark runner |
Thu, 27 Apr, 22:29 |
| Ismaël Mejía (JIRA) |
[jira] [Commented] (BEAM-2104) Consider adding interactive notebooks as examples |
Fri, 28 Apr, 12:58 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Assigned] (BEAM-1857) Add Neo4jIO |
Sun, 02 Apr, 05:45 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1857) Add Neo4jIO |
Sun, 02 Apr, 05:46 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1859) sorter extension depends on hadoop but does not declare as such in repository artifact |
Mon, 03 Apr, 04:06 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1859) sorter extension depends on hadoop but does not declare as such in repository artifact |
Mon, 03 Apr, 05:09 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1773) Consider allowing Source#validate() to throw exception |
Mon, 03 Apr, 15:16 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1900) create feature branch 'dsls_sql' for Beam SQL |
Thu, 06 Apr, 17:03 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Resolved] (BEAM-1856) HDFSFileSink class do not use the same configuration in master and slave |
Thu, 06 Apr, 17:22 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1918) a BasicDoFn with abstract methods |
Sat, 08 Apr, 07:11 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Created] (BEAM-1920) Add Spark 2.x support in Spark runner |
Sun, 09 Apr, 08:56 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1920) Add Spark 2.x support in Spark runner |
Sun, 09 Apr, 09:31 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Assigned] (BEAM-1922) DataSource in JdbcIO is not closed |
Sun, 09 Apr, 19:31 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Assigned] (BEAM-1922) DataSource in JdbcIO is not closed |
Sun, 09 Apr, 19:32 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1922) DataSource in JdbcIO is not closed |
Sun, 09 Apr, 19:32 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-1900) create feature branch 'dsls_sql' for Beam SQL |
Sun, 09 Apr, 19:57 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Resolved] (BEAM-1900) create feature branch 'dsls_sql' for Beam SQL |
Sun, 09 Apr, 19:58 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Resolved] (BEAM-1921) expose connectionProperties in JdbcIO |
Sun, 09 Apr, 20:17 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Commented] (BEAM-995) Apache Pig DSL |
Tue, 11 Apr, 11:56 |
| Jean-Baptiste Onofré (JIRA) |
[jira] [Assigned] (BEAM-1946) Add IO module for restful api |
Wed, 12 Apr, 06:01 |