[
https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903135#comment-15903135
]
Eugene Kirpichov commented on BEAM-68:
--
I think this needs a discussion on the Beam dev@ mailing list.
[
https://issues.apache.org/jira/browse/BEAM-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1422:
--
Assignee: Eugene Kirpichov (was: Davor Bonaci)
> ParDo should comply with PTransform
[
https://issues.apache.org/jira/browse/BEAM-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905236#comment-15905236
]
Eugene Kirpichov commented on BEAM-1678:
What would this transform / family of transforms do?
>
[
https://issues.apache.org/jira/browse/BEAM-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905227#comment-15905227
]
Eugene Kirpichov commented on BEAM-1679:
Discussion currently happening on the mailing list:
[
https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905240#comment-15905240
]
Eugene Kirpichov commented on BEAM-1581:
I would recommend to preserve the decomposition and make
[
https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15906648#comment-15906648
]
Eugene Kirpichov commented on BEAM-1581:
[~aviemzur] - I think XML source/sink are a bad design in
[
https://issues.apache.org/jira/browse/BEAM-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905722#comment-15905722
]
Eugene Kirpichov commented on BEAM-1678:
Note that all IO's are families of PTransforms (usually
Eugene Kirpichov created BEAM-1712:
--
Summary: TestPipeline.run doesn't actually waitUntilFinish
Key: BEAM-1712
URL: https://issues.apache.org/jira/browse/BEAM-1712
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923329#comment-15923329
]
Eugene Kirpichov commented on BEAM-1712:
OK, seems like that is in fact what happens. So this bug
[
https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-1712:
---
Priority: Major (was: Blocker)
> TestPipeline.run doesn't actually waitUntilFinish
>
[
https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923326#comment-15923326
]
Eugene Kirpichov commented on BEAM-1712:
An optimistic interpretation is probably that Flink runner
[
https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923351#comment-15923351
]
Eugene Kirpichov commented on BEAM-1712:
As an intermediate step to unifying everything under
[
https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923321#comment-15923321
]
Eugene Kirpichov commented on BEAM-1712:
[
https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1589#comment-1589
]
Eugene Kirpichov commented on BEAM-1573:
Yes, this would be a backward-incompatible change. We are
[
https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15896989#comment-15896989
]
Eugene Kirpichov commented on BEAM-1573:
At a conference right now, but quick comment: yes, as
[
https://issues.apache.org/jira/browse/BEAM-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1416.
--
> Write transform should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1426.
--
> SortValues should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889586#comment-15889586
]
Eugene Kirpichov commented on BEAM-1424:
Actual backward-incompatible changes: kv renamed to kvs,
[
https://issues.apache.org/jira/browse/BEAM-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1424.
--
> ToString should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890855#comment-15890855
]
Eugene Kirpichov commented on BEAM-849:
---
I disagree that "unbounded pipelines" can't finish
[
https://issues.apache.org/jira/browse/BEAM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890861#comment-15890861
]
Eugene Kirpichov commented on BEAM-1562:
See my comment on BEAM-849: as an alternative, we can use
Eugene Kirpichov created BEAM-1578:
--
Summary: Runners should put PT overrides into a list rather than
map
Key: BEAM-1578
URL: https://issues.apache.org/jira/browse/BEAM-1578
Project: Beam
Eugene Kirpichov created BEAM-1594:
--
Summary: JOB_STATE_DRAINED should be terminal for waitUntilFinish()
Key: BEAM-1594
URL: https://issues.apache.org/jira/browse/BEAM-1594
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1427:
--
Assignee: Eugene Kirpichov
> BigQueryIO should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-1915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961586#comment-15961586
]
Eugene Kirpichov commented on BEAM-1915:
It happens to also be the last occurrence in the Beam
[
https://issues.apache.org/jira/browse/BEAM-1915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961587#comment-15961587
]
Eugene Kirpichov commented on BEAM-1915:
cc: [~kenn]
> Remove OldDoFn dependency in
[
https://issues.apache.org/jira/browse/BEAM-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961590#comment-15961590
]
Eugene Kirpichov commented on BEAM-1910:
Got the error again.
[
https://issues.apache.org/jira/browse/BEAM-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961592#comment-15961592
]
Eugene Kirpichov commented on BEAM-1910:
I guess I also would like a way to run mvn verify but skip
[
https://issues.apache.org/jira/browse/BEAM-1903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1903.
--
Resolution: Fixed
Fix Version/s: First stable release
> Splittable DoFn should report
[
https://issues.apache.org/jira/browse/BEAM-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1904.
--
Resolution: Fixed
Fix Version/s: First stable release
This is effectively done in
Eugene Kirpichov created BEAM-1913:
--
Summary: TFRecordIO should comply with PTransform style guide
Key: BEAM-1913
URL: https://issues.apache.org/jira/browse/BEAM-1913
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-1428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1428:
--
Assignee: (was: Davor Bonaci)
> KinesisIO should comply with PTransform style guide
[
https://issues.apache.org/jira/browse/BEAM-644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15957959#comment-15957959
]
Eugene Kirpichov commented on BEAM-644:
---
I don't think there's an SDF-specific issue here: it applies
Eugene Kirpichov created BEAM-1910:
--
Summary: test_using_slow_impl very flaky locally
Key: BEAM-1910
URL: https://issues.apache.org/jira/browse/BEAM-1910
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961285#comment-15961285
]
Eugene Kirpichov commented on BEAM-1581:
Yeah, JacksonIO sounds like good idea. It also has fewer
[
https://issues.apache.org/jira/browse/BEAM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-1913:
---
Labels: backward-incompatible starter (was: backwards-incompatible starter)
> TFRecordIO
[
https://issues.apache.org/jira/browse/BEAM-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1914:
--
Assignee: (was: Davor Bonaci)
> XML IO 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 updated BEAM-1914:
---
Labels: backward-incompatible starter (was: )
> XML IO should comply with PTransform style
[
https://issues.apache.org/jira/browse/BEAM-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-1414:
---
Labels: backward-incompatible starter (was: backward-incompatible)
> CountingInput should
[
https://issues.apache.org/jira/browse/BEAM-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1414:
--
Assignee: (was: Davor Bonaci)
> CountingInput should comply with PTransform style
[
https://issues.apache.org/jira/browse/BEAM-447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15947688#comment-15947688
]
Eugene Kirpichov edited comment on BEAM-447 at 4/7/17 9:46 PM:
---
Remaining
Eugene Kirpichov created BEAM-1914:
--
Summary: XML IO should comply with PTransform style guide
Key: BEAM-1914
URL: https://issues.apache.org/jira/browse/BEAM-1914
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-447.
-
Resolution: Duplicate
I've filed separate JIRAs for the remaining sub-items.
> Stop referring to
Eugene Kirpichov created BEAM-1979:
--
Summary: Outputting to an undeclared side output TupleTag should
throw
Key: BEAM-1979
URL: https://issues.apache.org/jira/browse/BEAM-1979
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-1913:
--
Assignee: Eugene Kirpichov
> TFRecordIO 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 reassigned BEAM-1914:
--
Assignee: Eugene Kirpichov
> XML IO should comply with PTransform style guide
>
[
https://issues.apache.org/jira/browse/BEAM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1913.
--
Resolution: Fixed
Fix Version/s: First stable release
> TFRecordIO should comply with
[
https://issues.apache.org/jira/browse/BEAM-1355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15973593#comment-15973593
]
Eugene Kirpichov commented on BEAM-1355:
Stephen - do you think then, perhaps, that we should
[
https://issues.apache.org/jira/browse/BEAM-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15973669#comment-15973669
]
Eugene Kirpichov commented on BEAM-1910:
Vikas, any updates? This is heavily interfering with the
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106185#comment-16106185
]
Eugene Kirpichov commented on BEAM-2671:
It's overwhelmingly likely the last one as I mentioned
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105124#comment-16105124
]
Eugene Kirpichov commented on BEAM-2671:
I'm not sure about bumping it to 2.2.0. It looks quite
[
https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111508#comment-16111508
]
Eugene Kirpichov commented on BEAM-1190:
GCS object listing is strongly consistent now. However the
Eugene Kirpichov created BEAM-2716:
--
Summary: AvroReader should refuse dynamic splits while in the last
block
Key: BEAM-2716
URL: https://issues.apache.org/jira/browse/BEAM-2716
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111671#comment-16111671
]
Eugene Kirpichov commented on BEAM-2716:
I think this affects only Avro, other file-based formats
[
https://issues.apache.org/jira/browse/BEAM-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2670.
--
Resolution: Fixed
> ParDoTest.testPipelineOptionsParameter* validatesRunner tests fail on Spark
Eugene Kirpichov created BEAM-2712:
--
Summary: SerializablePipelineOptions should not call
FileSystems.setDefaultPipelineOptions.
Key: BEAM-2712
URL: https://issues.apache.org/jira/browse/BEAM-2712
[
https://issues.apache.org/jira/browse/BEAM-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2712:
--
Assignee: (was: Kenneth Knowles)
> SerializablePipelineOptions should not call
>
Eugene Kirpichov created BEAM-2706:
--
Summary: Create JdbcIO.readAll()
Key: BEAM-2706
URL: https://issues.apache.org/jira/browse/BEAM-2706
Project: Beam
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/BEAM-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109644#comment-16109644
]
Eugene Kirpichov commented on BEAM-1323:
Filed https://issues.apache.org/jira/browse/BEAM-2706 for
[
https://issues.apache.org/jira/browse/BEAM-2684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114002#comment-16114002
]
Eugene Kirpichov commented on BEAM-2684:
As an intermediate step, perhaps, add a bunch of logging
[
https://issues.apache.org/jira/browse/BEAM-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2768:
--
Assignee: Reuven Lax (was: Kenneth Knowles)
> Fix bigquery.WriteTables generating
[
https://issues.apache.org/jira/browse/BEAM-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127687#comment-16127687
]
Eugene Kirpichov commented on BEAM-2768:
Could you tell more about how you're using
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16126416#comment-16126416
]
Eugene Kirpichov commented on BEAM-2140:
Sorry for the delayed response. The output watermark
[
https://issues.apache.org/jira/browse/BEAM-2700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2700.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> BigQueryIO should support using file load jobs
[
https://issues.apache.org/jira/browse/BEAM-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2447.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Reintroduce DoFn.ProcessContinuation
>
Eugene Kirpichov created BEAM-2623:
--
Summary: Create Watch transform for emitting new elements in a
family of growing sets
Key: BEAM-2623
URL: https://issues.apache.org/jira/browse/BEAM-2623
[
https://issues.apache.org/jira/browse/BEAM-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2406.
--
Resolution: Fixed
Fix Version/s: 2.1.0
> NullPointerException when writing an empty table
Eugene Kirpichov created BEAM-2628:
--
Summary: AvroSource.split() sequentially opens every matched file
Key: BEAM-2628
URL: https://issues.apache.org/jira/browse/BEAM-2628
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2640:
---
Issue Type: New Feature (was: Bug)
> Introduce Create.ofProvider(ValueProvider)
>
Eugene Kirpichov created BEAM-2640:
--
Summary: Introduce Create.ofProvider(ValueProvider)
Key: BEAM-2640
URL: https://issues.apache.org/jira/browse/BEAM-2640
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2532.
--
Resolution: Fixed
Assignee: Neville Li (was: Chamikara Jayalath)
Fix Version/s:
[
https://issues.apache.org/jira/browse/BEAM-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2544.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> AvroIOTest is flaky
> ---
>
>
[
https://issues.apache.org/jira/browse/BEAM-2628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2628.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> AvroSource.split() sequentially opens every
[
https://issues.apache.org/jira/browse/BEAM-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2608.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Unclosed BoundedReader in
Eugene Kirpichov created BEAM-2656:
--
Summary: Introduce AvroIO.readAll()
Key: BEAM-2656
URL: https://issues.apache.org/jira/browse/BEAM-2656
Project: Beam
Issue Type: Bug
Eugene Kirpichov created BEAM-2680:
--
Summary: Improve scalability of the Watch transform
Key: BEAM-2680
URL: https://issues.apache.org/jira/browse/BEAM-2680
Project: Beam
Issue Type: Bug
Eugene Kirpichov created BEAM-2682:
--
Summary: Merge AvroIOTest and AvroIOTransformTest
Key: BEAM-2682
URL: https://issues.apache.org/jira/browse/BEAM-2682
Project: Beam
Issue Type: Bug
Eugene Kirpichov created BEAM-2677:
--
Summary: AvroIO.read without specifying a schema
Key: BEAM-2677
URL: https://issues.apache.org/jira/browse/BEAM-2677
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103911#comment-16103911
]
Eugene Kirpichov commented on BEAM-2671:
Actually that test is
[
https://issues.apache.org/jira/browse/BEAM-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2670:
--
Assignee: Eugene Kirpichov (was: Stas Levin)
> ParDoTest.testPipelineOptionsParameter*
[
https://issues.apache.org/jira/browse/BEAM-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103815#comment-16103815
]
Eugene Kirpichov commented on BEAM-2670:
I found the issue and have a fix.
>
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16103868#comment-16103868
]
Eugene Kirpichov commented on BEAM-2671:
CreateStreamTest.testMultiOutputParDo() is failing as
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16104459#comment-16104459
]
Eugene Kirpichov commented on BEAM-2671:
I wonder if these tests have something to do with
Eugene Kirpichov created BEAM-2684:
--
Summary: AmqpIOTest is flaky
Key: BEAM-2684
URL: https://issues.apache.org/jira/browse/BEAM-2684
Project: Beam
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/BEAM-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1820.
--
Resolution: Won't Fix
Fix Version/s: Not applicable
The consensus on dev@ is that
Eugene Kirpichov created BEAM-2686:
--
Summary: PTransform's should always set a Coder on their output
PCollections
Key: BEAM-2686
URL: https://issues.apache.org/jira/browse/BEAM-2686
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093588#comment-16093588
]
Eugene Kirpichov commented on BEAM-2640:
Coder inference for this is complicated by the fact that
[
https://issues.apache.org/jira/browse/BEAM-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093633#comment-16093633
]
Eugene Kirpichov commented on BEAM-2643:
See also https://github.com/apache/beam/pull/3598
> Add
Eugene Kirpichov created BEAM-2641:
--
Summary: Improve discoverability of TextIO.readAll() as a
replacement of TextIO.read() for large globs
Key: BEAM-2641
URL: https://issues.apache.org/jira/browse/BEAM-2641
Eugene Kirpichov created BEAM-2607:
--
Summary: Enforce that SDF must return stop() after a failed
tryClaim() call
Key: BEAM-2607
URL: https://issues.apache.org/jira/browse/BEAM-2607
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2511.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> TextIO should support reading a PCollection of
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068782#comment-16068782
]
Eugene Kirpichov commented on BEAM-2140:
Conceptually, watermarks are for PCollections - lower
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16068740#comment-16068740
]
Eugene Kirpichov commented on BEAM-2140:
So, to elaborate on what Kenn said. We dug a bit deeper
Eugene Kirpichov created BEAM-2536:
--
Summary: Simplify specifying coders on PCollectionTuple
Key: BEAM-2536
URL: https://issues.apache.org/jira/browse/BEAM-2536
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070428#comment-16070428
]
Eugene Kirpichov commented on BEAM-2532:
[~reuvenlax] I think you had some thoughts about how to
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065429#comment-16065429
]
Eugene Kirpichov edited comment on BEAM-2140 at 6/27/17 8:38 PM:
-
Okay, I
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065429#comment-16065429
]
Eugene Kirpichov commented on BEAM-2140:
Okay, I see that I misunderstood what the watermark hold
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065626#comment-16065626
]
Eugene Kirpichov commented on BEAM-2140:
_we can't advance the watermark as though it was
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16065627#comment-16065627
]
Eugene Kirpichov commented on BEAM-2140:
...Or is the problem that the watermark of the output
[
https://issues.apache.org/jira/browse/BEAM-673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983950#comment-15983950
]
Eugene Kirpichov commented on BEAM-673:
---
On second thought, this might be related to SDF: processing
101 - 200 of 617 matches
Mail list logo
