[
https://issues.apache.org/jira/browse/BEAM-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15985581#comment-15985581
]
Eugene Kirpichov commented on BEAM-2081:
I agree with this guidance. The only downside is it
[
https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1573.
--
Resolution: Fixed
Fix Version/s: (was: Not applicable)
First stable
[
https://issues.apache.org/jira/browse/BEAM-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1414.
--
Resolution: Fixed
> CountingInput should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1914.
--
> XML IO should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983364#comment-15983364
]
Eugene Kirpichov commented on BEAM-673:
---
[~iemejia] No - the fact that a DoFn's efficiency depends on
[
https://issues.apache.org/jira/browse/BEAM-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989264#comment-15989264
]
Eugene Kirpichov commented on BEAM-2114:
There's still another issue here: the display data
[
https://issues.apache.org/jira/browse/BEAM-2060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15987600#comment-15987600
]
Eugene Kirpichov commented on BEAM-2060:
We could support multi-byte encodings when reading, but at
Eugene Kirpichov created BEAM-2120:
--
Summary: TestDataflowRunner prints all messages from the job,
repeatedly
Key: BEAM-2120
URL: https://issues.apache.org/jira/browse/BEAM-2120
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989569#comment-15989569
]
Eugene Kirpichov commented on BEAM-2120:
Each call to waitToFinish() prints all messages the job
Eugene Kirpichov created BEAM-2108:
--
Summary: Integration tests for PubsubIO
Key: BEAM-2108
URL: https://issues.apache.org/jira/browse/BEAM-2108
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115164#comment-16115164
]
Eugene Kirpichov commented on BEAM-2671:
20820fa5477ffcdd4a9ef2e9340353ed3c5691a9, mentioned above,
[
https://issues.apache.org/jira/browse/BEAM-2734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115114#comment-16115114
]
Eugene Kirpichov commented on BEAM-2734:
Another issue is also something I broke with
[
https://issues.apache.org/jira/browse/BEAM-2734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2734:
--
Assignee: Eugene Kirpichov (was: Thomas Groh)
> Dataflow ValidatesRunner broken at
[
https://issues.apache.org/jira/browse/BEAM-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2512.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> TextIO should support watching for new files
>
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2671:
---
Fix Version/s: (was: 2.1.0)
> CreateStreamTest.testFirstElementLate validatesRunner test
Eugene Kirpichov created BEAM-2734:
--
Summary: Dataflow ValidatesRunner broken at HEAD
Key: BEAM-2734
URL: https://issues.apache.org/jira/browse/BEAM-2734
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-2734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2734:
---
Description:
[
https://issues.apache.org/jira/browse/BEAM-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2677.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> AvroIO.read without specifying a schema
>
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105918#comment-16105918
]
Eugene Kirpichov commented on BEAM-2671:
Any updates?
> CreateStreamTest.testFirstElementLate
[
https://issues.apache.org/jira/browse/BEAM-2699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105917#comment-16105917
]
Eugene Kirpichov commented on BEAM-2699:
By the way, this was found when testing a PR where
Eugene Kirpichov created BEAM-2699:
--
Summary: AppliedPTransform is used as a key in hashmaps but
PTransform is not hashable/equality-comparable
Key: BEAM-2699
URL: https://issues.apache.org/jira/browse/BEAM-2699
Eugene Kirpichov created BEAM-2754:
--
Summary: Simplify DefaultCoder
Key: BEAM-2754
URL: https://issues.apache.org/jira/browse/BEAM-2754
Project: Beam
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/BEAM-2754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119049#comment-16119049
]
Eugene Kirpichov commented on BEAM-2754:
cc: [~tgroh] [~kenn]
> Simplify DefaultCoder
>
[
https://issues.apache.org/jira/browse/BEAM-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109527#comment-16109527
]
Eugene Kirpichov commented on BEAM-1323:
This may be addressed by creating JdbcIO.readAll() that
[
https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105942#comment-16105942
]
Eugene Kirpichov commented on BEAM-92:
--
I'm not sure whether having the current JIRA still makes sense.
[
https://issues.apache.org/jira/browse/BEAM-2699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105927#comment-16105927
]
Eugene Kirpichov commented on BEAM-2699:
Relevant code:
[
https://issues.apache.org/jira/browse/BEAM-2699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105929#comment-16105929
]
Eugene Kirpichov commented on BEAM-2699:
Note that hashing this in general is fine, because this
[
https://issues.apache.org/jira/browse/BEAM-2699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106003#comment-16106003
]
Eugene Kirpichov commented on BEAM-2699:
You're right, this is another bug with the way things are
Eugene Kirpichov created BEAM-2753:
--
Summary: File DynamicDestinations side inputs don't work with
sharding
Key: BEAM-2753
URL: https://issues.apache.org/jira/browse/BEAM-2753
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2753:
---
Fix Version/s: 2.2.0
> File DynamicDestinations side inputs don't work with sharding
>
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117469#comment-16117469
]
Eugene Kirpichov commented on BEAM-2671:
Aviem - my apologies for misunderstanding previous
[
https://issues.apache.org/jira/browse/BEAM-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-1868:
---
Fix Version/s: 2.1.0
> CreateStreamTest testMultiOutputParDo is flaky on the Spark runner
>
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103907#comment-16103907
]
Eugene Kirpichov commented on BEAM-2671:
It's interesting that testMultiOutputParDo succeeds if you
[
https://issues.apache.org/jira/browse/BEAM-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104019#comment-16104019
]
Eugene Kirpichov commented on BEAM-2641:
The PR https://github.com/apache/beam/pull/3639 introduces
[
https://issues.apache.org/jira/browse/BEAM-2640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2640.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Introduce Create.ofProvider(ValueProvider)
>
[
https://issues.apache.org/jira/browse/BEAM-2641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2641.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Improve discoverability of TextIO.readAll() as a
[
https://issues.apache.org/jira/browse/BEAM-2656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2656.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Introduce AvroIO.readAll()
>
[
https://issues.apache.org/jira/browse/BEAM-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133395#comment-16133395
]
Eugene Kirpichov commented on BEAM-2774:
Related issue:
[
https://issues.apache.org/jira/browse/BEAM-2776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2776:
---
Component/s: sdk-py
> TextIO should support reading header lines
>
Eugene Kirpichov created BEAM-2776:
--
Summary: TextIO should support reading header lines
Key: BEAM-2776
URL: https://issues.apache.org/jira/browse/BEAM-2776
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-2776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2776:
---
Description:
Users frequently request the ability to skip some header rows when reading text
Eugene Kirpichov created BEAM-2781:
--
Summary: Should have a canonical Compression enum
Key: BEAM-2781
URL: https://issues.apache.org/jira/browse/BEAM-2781
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-1353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1353.
--
Resolution: Fixed
> Beam should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-1415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1415.
--
Resolution: Fixed
> PubsubIO should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15995167#comment-15995167
]
Eugene Kirpichov commented on BEAM-638:
---
TextIO and AvroIO can now write unbounded data, producing one
[
https://issues.apache.org/jira/browse/BEAM-1402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1402.
--
Resolution: Fixed
Assignee: Eugene Kirpichov (was: Reuven Lax)
> Make TextIO and AvroIO
[
https://issues.apache.org/jira/browse/BEAM-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2023.
--
Resolution: Fixed
> BigQueryIO.Write needs a way of dynamically specifying table schemas
>
[
https://issues.apache.org/jira/browse/BEAM-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2221.
--
Resolution: Fixed
> Make KafkaIO coder specification less awkward
>
[
https://issues.apache.org/jira/browse/BEAM-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1013:
--
Assignee: Melissa Pashniak (was: Eugene Kirpichov)
> Recheck all existing programming
[
https://issues.apache.org/jira/browse/BEAM-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011160#comment-16011160
]
Eugene Kirpichov commented on BEAM-1013:
The style-guide part of this is done. Melissa, is there
Eugene Kirpichov created BEAM-2301:
--
Summary: Standard expansion of SDF should be in
runners-core-construction
Key: BEAM-2301
URL: https://issues.apache.org/jira/browse/BEAM-2301
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2258.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> BigtableIO should use AutoValue for read and
Eugene Kirpichov created BEAM-2284:
--
Summary: Completely remove OldDoFn from Beam
Key: BEAM-2284
URL: https://issues.apache.org/jira/browse/BEAM-2284
Project: Beam
Issue Type: Task
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16005465#comment-16005465
]
Eugene Kirpichov edited comment on BEAM-2140 at 5/10/17 9:22 PM:
-
Aljoscha
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16005465#comment-16005465
]
Eugene Kirpichov commented on BEAM-2140:
Aljoscha - SDF code does not inspect watermarks.
Here's
[
https://issues.apache.org/jira/browse/BEAM-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2052.
--
Resolution: Fixed
This is now fixed when applying the sink to bounded collections.
For
[
https://issues.apache.org/jira/browse/BEAM-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1377.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Support Splittable DoFn in Dataflow streaming
[
https://issues.apache.org/jira/browse/BEAM-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056663#comment-16056663
]
Eugene Kirpichov commented on BEAM-1620:
Note: there are tests like SplittableDoFnTest that, in
[
https://issues.apache.org/jira/browse/BEAM-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2483:
---
Description:
https://github.com/apache/beam/pull/1898 adds Splittable DoFn to Dataflow
Eugene Kirpichov created BEAM-2476:
--
Summary: Dataflow streaming runner fails SDF
testWindowedSideInputWithCheckpoints
Key: BEAM-2476
URL: https://issues.apache.org/jira/browse/BEAM-2476
Project:
Eugene Kirpichov created BEAM-2483:
--
Summary: SplittableDoFnTest should not explicitly
setStreaming(true)
Key: BEAM-2483
URL: https://issues.apache.org/jira/browse/BEAM-2483
Project: Beam
Eugene Kirpichov created BEAM-2513:
--
Summary: TextIO should support watching files for new entries
Key: BEAM-2513
URL: https://issues.apache.org/jira/browse/BEAM-2513
Project: Beam
Issue
Eugene Kirpichov created BEAM-2512:
--
Summary: TextIO should support watching for new files
Key: BEAM-2512
URL: https://issues.apache.org/jira/browse/BEAM-2512
Project: Beam
Issue Type: New
Eugene Kirpichov created BEAM-2511:
--
Summary: TextIO should support reading a PCollection of filenames
Key: BEAM-2511
URL: https://issues.apache.org/jira/browse/BEAM-2511
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16063548#comment-16063548
]
Eugene Kirpichov commented on BEAM-2140:
On 1: the timer should not be dropped because ProcessFn is
[
https://issues.apache.org/jira/browse/BEAM-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16064054#comment-16064054
]
Eugene Kirpichov commented on BEAM-2447:
If the runner did not already take a checkpoint, and the
[
https://issues.apache.org/jira/browse/BEAM-2301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2301.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Standard expansion of SDF should be in
[
https://issues.apache.org/jira/browse/BEAM-788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016539#comment-16016539
]
Eugene Kirpichov commented on BEAM-788:
---
Yes.
> Execute ReduceFn directly, not via OldDoFn wrapper
>
[
https://issues.apache.org/jira/browse/BEAM-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2284.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Completely remove OldDoFn from Beam
>
[
https://issues.apache.org/jira/browse/BEAM-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2357.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> Add HCatalogIO (Hive)
> -
>
Eugene Kirpichov created BEAM-2447:
--
Summary: Reintroduce DoFn.ProcessContinuation
Key: BEAM-2447
URL: https://issues.apache.org/jira/browse/BEAM-2447
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-1824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-1824:
---
Description:
[~bchambers] suggested the following idea: while the runner implementation of
[
https://issues.apache.org/jira/browse/BEAM-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reopened BEAM-2052:
Apologies, for some reason I thought the PR was merged, and didn't check.
> Windowed file sinks
[
https://issues.apache.org/jira/browse/BEAM-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2218.
--
Resolution: Duplicate
didn't notice the jira.
> PubsubIO.readPubsubMessages function names are
[
https://issues.apache.org/jira/browse/BEAM-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2052.
--
Resolution: Fixed
> Windowed file sinks should support dynamic sharding
>
[
https://issues.apache.org/jira/browse/BEAM-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001197#comment-16001197
]
Eugene Kirpichov commented on BEAM-1013:
Many of them are most likely out of date due to
Eugene Kirpichov created BEAM-2218:
--
Summary: PubsubIO.readPubsubMessages function names are too long
Key: BEAM-2218
URL: https://issues.apache.org/jira/browse/BEAM-2218
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2221:
---
Fix Version/s: 2.0.0
> Make KafkaIO coder specification less awkward
>
Eugene Kirpichov created BEAM-2221:
--
Summary: Make KafkaIO coder specification less awkward
Key: BEAM-2221
URL: https://issues.apache.org/jira/browse/BEAM-2221
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2221:
---
Description:
readWithCoders and writeWithCoders functions are awkward because they don't
[
https://issues.apache.org/jira/browse/BEAM-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2210.
--
Resolution: Fixed
> PubsubIO.readPubsubMessagesWithoutAttributes is awkward
>
[
https://issues.apache.org/jira/browse/BEAM-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996945#comment-15996945
]
Eugene Kirpichov commented on BEAM-2170:
Sorry for the trouble, I'll fix this today around 1pm PST.
[
https://issues.apache.org/jira/browse/BEAM-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2170:
--
Assignee: Eugene Kirpichov
> PubsubIO.readStrings should handle messages without
[
https://issues.apache.org/jira/browse/BEAM-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2170.
--
Resolution: Fixed
> PubsubIO.readStrings should handle messages without metadata
>
Eugene Kirpichov created BEAM-2172:
--
Summary: ProcessBundleHandlerTest.testCreatingAndProcessingDoFn
fails at HEAD
Key: BEAM-2172
URL: https://issues.apache.org/jira/browse/BEAM-2172
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2114.
--
Resolution: Fixed
> KafkaIO broken with CoderException
> --
>
>
[
https://issues.apache.org/jira/browse/BEAM-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2154.
--
Resolution: Fixed
> Writing to large numbers of BigQuery tables causes out-of-memory
>
[
https://issues.apache.org/jira/browse/BEAM-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039463#comment-16039463
]
Eugene Kirpichov commented on BEAM-2414:
Please clarify what you mean by this.
> Add TwitterIO
>
[
https://issues.apache.org/jira/browse/BEAM-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039460#comment-16039460
]
Eugene Kirpichov commented on BEAM-2415:
Please clarify what you mean by this?
> Add FacebookIO
>
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065661#comment-16065661
]
Eugene Kirpichov commented on BEAM-2140:
Working backwards from that, in the "read Pubsub topic
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170471#comment-16170471
]
Eugene Kirpichov commented on BEAM-2140:
Thanks Aljoscha! It would be awesome to get this working
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170472#comment-16170472
]
Eugene Kirpichov commented on BEAM-2140:
Also note that this support is critical for portable
[
https://issues.apache.org/jira/browse/BEAM-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2837.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Writing To Spanner From Google Cloud DataFlow -
[
https://issues.apache.org/jira/browse/BEAM-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-407.
-
Resolution: Fixed
Fix Version/s: 2.2.0
> Inconsistent synchronization in
[
https://issues.apache.org/jira/browse/BEAM-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172818#comment-16172818
]
Eugene Kirpichov commented on BEAM-2826:
This will be addressed as part of the FileIO.write()
[
https://issues.apache.org/jira/browse/BEAM-2834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2834:
--
Assignee: Reuven Lax (was: Thomas Groh)
> NullPointerException @
[
https://issues.apache.org/jira/browse/BEAM-2981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16176837#comment-16176837
]
Eugene Kirpichov commented on BEAM-2981:
This should be fixed by a recent fix in the Dataflow
[
https://issues.apache.org/jira/browse/BEAM-2879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168669#comment-16168669
]
Eugene Kirpichov commented on BEAM-2879:
Actually, we already go through a GenericRecord ->
[
https://issues.apache.org/jira/browse/BEAM-2879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168666#comment-16168666
]
Eugene Kirpichov commented on BEAM-2879:
There is no reason why we didn't go Avro in the first
Eugene Kirpichov created BEAM-3030:
--
Summary: watchForNewFiles() can emit a file multiple times if it's
growing
Key: BEAM-3030
URL: https://issues.apache.org/jira/browse/BEAM-3030
Project: Beam
201 - 300 of 617 matches
Mail list logo
