[
https://issues.apache.org/jira/browse/BEAM-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2588:
--
Assignee: Robert Bradshaw (was: Axel Magnuson)
> Portable Flink Runner Job API
> --
[
https://issues.apache.org/jira/browse/BEAM-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479875#comment-16479875
]
Eugene Kirpichov commented on BEAM-2588:
Axel said Robert is going to work on this.
Eugene Kirpichov created BEAM-4375:
--
Summary: Gradle doesn't run tests under RunWith(Enclosed.class)
Key: BEAM-4375
URL: https://issues.apache.org/jira/browse/BEAM-4375
Project: Beam
Issue T
[
https://issues.apache.org/jira/browse/BEAM-4267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16484476#comment-16484476
]
Eugene Kirpichov commented on BEAM-4267:
Woohoo! Now I think it just remains to hoo
[
https://issues.apache.org/jira/browse/BEAM-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4473.
--
Resolution: Fixed
Fix Version/s: 2.6.0
Fixed in https://github.com/apache/beam/pull/5585
[
https://issues.apache.org/jira/browse/BEAM-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4281.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> GrpcDataServiceTest.testMessageReceivedBySingleC
[
https://issues.apache.org/jira/browse/BEAM-4291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4291.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> ArtifactRetrievalService that retrieves artifact
[
https://issues.apache.org/jira/browse/BEAM-4216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4216.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> Flink: Staged artifacts are delivered to the SDK
[
https://issues.apache.org/jira/browse/BEAM-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2588.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> Portable Flink Runner Job API
>
[
https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4149.
--
Resolution: Duplicate
Fix Version/s: Not applicable
> Java SDK Harness should populate wo
[
https://issues.apache.org/jira/browse/BEAM-4145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4145:
--
Assignee: Eugene Kirpichov (was: Thomas Groh)
> Java SDK Harness populates control req
[
https://issues.apache.org/jira/browse/BEAM-4145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516491#comment-16516491
]
Eugene Kirpichov commented on BEAM-4145:
I'll take over tgroh's PR since he's curr
[
https://issues.apache.org/jira/browse/BEAM-4145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4145.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> Java SDK Harness populates control request heade
[
https://issues.apache.org/jira/browse/BEAM-3833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3833.
--
Resolution: Fixed
Fix Version/s: 2.6.0
https://github.com/apache/beam/pull/5566
> Java S
[
https://issues.apache.org/jira/browse/BEAM-3743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3743.
--
Resolution: Fixed
Fix Version/s: 2.6.0
https://github.com/apache/beam/pull/5566
> Suppor
[
https://issues.apache.org/jira/browse/BEAM-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3741.
--
Resolution: Fixed
Fix Version/s: 2.5.0
> Proto changes for splitting over Fn API
> --
[
https://issues.apache.org/jira/browse/BEAM-4267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4267.
--
Resolution: Fixed
Fix Version/s: 2.6.0
I think we're good here :)
> Implement a reusable
[
https://issues.apache.org/jira/browse/BEAM-4205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4205:
--
Assignee: Ankur Goenka
> Java: WordCount runs against manually started Flink at master
[
https://issues.apache.org/jira/browse/BEAM-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16522982#comment-16522982
]
Eugene Kirpichov commented on BEAM-4206:
Robert and Axel are working on this, and
[
https://issues.apache.org/jira/browse/BEAM-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4206:
--
Assignee: Axel Magnuson (was: Aljoscha Krettek)
> Python: WordCount runs against manu
[
https://issues.apache.org/jira/browse/BEAM-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3883.
--
Resolution: Fixed
> Python SDK stages artifacts when talking to job server
> ---
[
https://issues.apache.org/jira/browse/BEAM-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4689.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> Dataflow cannot deserialize SplittableParDo DoFn
[
https://issues.apache.org/jira/browse/BEAM-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1841.
--
Resolution: Won't Fix
Fix Version/s: Not applicable
Probably not worth investing more int
[
https://issues.apache.org/jira/browse/BEAM-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530528#comment-16530528
]
Eugene Kirpichov commented on BEAM-1841:
(especially because there is already a tr
[
https://issues.apache.org/jira/browse/BEAM-1824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1824.
--
Resolution: Won't Fix
Fix Version/s: Not applicable
At this point it's better to just imp
[
https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-217.
-
Resolution: Won't Fix
Not worth investing into BoundedSource anymore. But SDF will get this right.
[
https://issues.apache.org/jira/browse/BEAM-1190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-1190.
--
Resolution: Won't Fix
Fix Version/s: Not applicable
This is an old issue, proposing a con
[
https://issues.apache.org/jira/browse/BEAM-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2751.
--
Resolution: Fixed
Fix Version/s: 2.2.0
This can be done closely enough using FileIO.write
[
https://issues.apache.org/jira/browse/BEAM-2682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2682.
--
Resolution: Fixed
Fix Version/s: Not applicable
Was fixed a long time ago.
> Merge AvroI
[
https://issues.apache.org/jira/browse/BEAM-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2883.
--
Resolution: Fixed
Fix Version/s: Not applicable
Fixed a long time ago.
> Poor error mess
[
https://issues.apache.org/jira/browse/BEAM-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2826.
--
Resolution: Fixed
Fix Version/s: 2.2.0
This is indeed addressed by FileIO.write which I t
[
https://issues.apache.org/jira/browse/BEAM-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3834:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> Python SDK harness should detec
[
https://issues.apache.org/jira/browse/BEAM-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3837:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> Python SDK harness should under
[
https://issues.apache.org/jira/browse/BEAM-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3595.
--
Resolution: Fixed
Fix Version/s: 2.5.0
Yeah this was done to a sufficient degree some tim
[
https://issues.apache.org/jira/browse/BEAM-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3742:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> Support for running a streaming
[
https://issues.apache.org/jira/browse/BEAM-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3857:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> Dynamic output support for pyth
[
https://issues.apache.org/jira/browse/BEAM-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3945:
--
Assignee: Udi Meiri (was: Eugene Kirpichov)
> TFRecord Performance Tests doesn't work
[
https://issues.apache.org/jira/browse/BEAM-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3907.
--
Resolution: Fixed
Fix Version/s: 2.6.0
This will not need clarification since I fixed a b
[
https://issues.apache.org/jira/browse/BEAM-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3874:
--
Assignee: (was: Eugene Kirpichov)
> Switch AvroIO sink default codec to Snappy
> --
[
https://issues.apache.org/jira/browse/BEAM-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4064:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> ClassCastExeption when reading
[
https://issues.apache.org/jira/browse/BEAM-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4166.
--
Resolution: Fixed
Fix Version/s: 2.5.0
> FnApiDoFnRunner doesn't invoke setup/teardown
>
[
https://issues.apache.org/jira/browse/BEAM-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4204.
--
Resolution: Fixed
Fix Version/s: (was: Not applicable)
2.5.0
> Pyt
[
https://issues.apache.org/jira/browse/BEAM-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4204:
--
Assignee: Ankur Goenka (was: Eugene Kirpichov)
> Python: PortableRunner - p.run() via
[
https://issues.apache.org/jira/browse/BEAM-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-3268.
--
Resolution: Fixed
Fix Version/s: 2.5.0
> getPerDestinationOutputFilenames() is getting pr
[
https://issues.apache.org/jira/browse/BEAM-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4288:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> SplittableDoFn: splitAtFraction
[
https://issues.apache.org/jira/browse/BEAM-3194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-3194:
--
Assignee: Yueyang Qiu (was: Eugene Kirpichov)
> Support annotating that a DoFn require
[
https://issues.apache.org/jira/browse/BEAM-4372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4372:
--
Assignee: Yueyang Qiu (was: Eugene Kirpichov)
> Need an undeprecated Reshuffle transfo
Eugene Kirpichov created BEAM-4737:
--
Summary: SplittableDoFn dynamic rebalancing in Dataflow
Key: BEAM-4737
URL: https://issues.apache.org/jira/browse/BEAM-4737
Project: Beam
Issue Type: Bug
Eugene Kirpichov created BEAM-4745:
--
Summary: SDF tests broken by innocent change due to Dataflow
worker dependencies
Key: BEAM-4745
URL: https://issues.apache.org/jira/browse/BEAM-4745
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-4758:
--
Assignee: Chamikara Jayalath (was: Eugene Kirpichov)
> Avro-Protobuf support
> ---
[
https://issues.apache.org/jira/browse/BEAM-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16540614#comment-16540614
]
Eugene Kirpichov commented on BEAM-4758:
Hi - thanks for the feedback, this seems
Eugene Kirpichov created BEAM-4775:
--
Summary: JobService should support returning metrics
Key: BEAM-4775
URL: https://issues.apache.org/jira/browse/BEAM-4775
Project: Beam
Issue Type: Bug
Eugene Kirpichov created BEAM-4776:
--
Summary: Java PortableRunner should support metrics
Key: BEAM-4776
URL: https://issues.apache.org/jira/browse/BEAM-4776
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-4205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4205.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> Java: WordCount runs against manually started Fl
[
https://issues.apache.org/jira/browse/BEAM-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-4206.
--
Resolution: Fixed
Fix Version/s: 2.6.0
> Python: WordCount runs against manually started
[
https://issues.apache.org/jira/browse/BEAM-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-4777:
---
Component/s: (was: runner-core)
sdk-py-core
> Python PortableRunner shoul
Eugene Kirpichov created BEAM-4777:
--
Summary: Python PortableRunner should support metrics
Key: BEAM-4777
URL: https://issues.apache.org/jira/browse/BEAM-4777
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-4777:
---
Description: BEAM-4775 concerns adding metrics to the JobService API; the
current issue is abo
Eugene Kirpichov created BEAM-4778:
--
Summary: Less wasteful ArtifactStagingService
Key: BEAM-4778
URL: https://issues.apache.org/jira/browse/BEAM-4778
Project: Beam
Issue Type: Bug
Eugene Kirpichov created BEAM-4780:
--
Summary: Entry point for ULR JobService compatible with
TestPortableRunner
Key: BEAM-4780
URL: https://issues.apache.org/jira/browse/BEAM-4780
Project: Beam
Eugene Kirpichov created BEAM-4779:
--
Summary: Python PortableTestRunner that runs VR tests against a
given portable runner
Key: BEAM-4779
URL: https://issues.apache.org/jira/browse/BEAM-4779
Project:
Eugene Kirpichov created BEAM-4792:
--
Summary: Add support for bounded SDF to all runners
Key: BEAM-4792
URL: https://issues.apache.org/jira/browse/BEAM-4792
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544249#comment-16544249
]
Eugene Kirpichov commented on BEAM-4792:
https://github.com/apache/beam/pull/5940
[
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&focusedCommentId=16117469#comment-16117469
]
Eugene Kirpichov commented on BEAM-2671:
Aviem - my apologies for misunderstanding
[
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
>
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
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: sd
[
https://issues.apache.org/jira/browse/BEAM-2754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119049#comment-16119049
]
Eugene Kirpichov commented on BEAM-2754:
cc: [~tgroh] [~kenn]
> Simplify DefaultCo
[
https://issues.apache.org/jira/browse/BEAM-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16126416#comment-16126416
]
Eugene Kirpichov commented on BEAM-2140:
Sorry for the delayed response. The output
[
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 wh
[
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 non-u
[
https://issues.apache.org/jira/browse/BEAM-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16127687#comment-16127687
]
Eugene Kirpichov commented on BEAM-2768:
Could you tell more about how you're using
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
f
[
https://issues.apache.org/jira/browse/BEAM-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16133395#comment-16133395
]
Eugene Kirpichov commented on BEAM-2774:
Related issue: https://issues.apache.org/j
[
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-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-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16140180#comment-16140180
]
Eugene Kirpichov commented on BEAM-2802:
Please see BEAM-2586 and previous discussi
[
https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16140190#comment-16140190
]
Eugene Kirpichov commented on BEAM-2803:
Could you quantify "very slow" - what perf
[
https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142139#comment-16142139
]
Eugene Kirpichov commented on BEAM-2802:
What does the custom delimiter look like i
[
https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142141#comment-16142141
]
Eugene Kirpichov commented on BEAM-2803:
Thanks, do you have the Dataflow job IDs t
[
https://issues.apache.org/jira/browse/BEAM-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2753:
--
Assignee: Eugene Kirpichov (was: Reuven Lax)
> File DynamicDestinations side inputs don
[
https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142875#comment-16142875
]
Eugene Kirpichov commented on BEAM-2803:
Hmm, indeed, seems that shuffle is being q
[
https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142875#comment-16142875
]
Eugene Kirpichov edited comment on BEAM-2803 at 8/26/17 5:43 PM:
[
https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142905#comment-16142905
]
Eugene Kirpichov commented on BEAM-2803:
We can try another way to break fusion I g
Eugene Kirpichov created BEAM-2810:
--
Summary: Consider a faster Avro library in Python
Key: BEAM-2810
URL: https://issues.apache.org/jira/browse/BEAM-2810
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143372#comment-16143372
]
Eugene Kirpichov commented on BEAM-2810:
It might be a good idea to fix fastavro th
[
https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143916#comment-16143916
]
Eugene Kirpichov commented on BEAM-2802:
Hmm, I have a hard time thinking why someb
Eugene Kirpichov created BEAM-2816:
--
Summary: Create SplittableDoFnTester
Key: BEAM-2816
URL: https://issues.apache.org/jira/browse/BEAM-2816
Project: Beam
Issue Type: Bug
Componen
[
https://issues.apache.org/jira/browse/BEAM-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov reassigned BEAM-2390:
--
Assignee: Reuven Lax (was: Eric Johston)
> allow user to use .setTimePartitioning in Bi
[
https://issues.apache.org/jira/browse/BEAM-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2390.
--
Resolution: Fixed
This has been submitted. Release note: this is NOT update-compatible for
Dataf
[
https://issues.apache.org/jira/browse/BEAM-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147720#comment-16147720
]
Eugene Kirpichov commented on BEAM-2826:
The solution to this bug would be either a
Eugene Kirpichov created BEAM-2827:
--
Summary: Introduce AvroIO.watchForNewFiles
Key: BEAM-2827
URL: https://issues.apache.org/jira/browse/BEAM-2827
Project: Beam
Issue Type: Bug
Co
Eugene Kirpichov created BEAM-2828:
--
Summary: Create FileIO
Key: BEAM-2828
URL: https://issues.apache.org/jira/browse/BEAM-2828
Project: Beam
Issue Type: New Feature
Components: sd
[
https://issues.apache.org/jira/browse/BEAM-2827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2827.
--
Resolution: Fixed
> Introduce AvroIO.watchForNewFiles
> -
>
>
[
https://issues.apache.org/jira/browse/BEAM-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov closed BEAM-2644.
--
Resolution: Fixed
Fix Version/s: 2.2.0
> Make it easier to test runtime-accessible ValuePr
[
https://issues.apache.org/jira/browse/BEAM-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2516:
---
Fix Version/s: 2.2.0
> User reports 4 minutes to process 1 million line CSV in DirectRunner
> -
[
https://issues.apache.org/jira/browse/BEAM-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2790:
---
Fix Version/s: 2.2.0
> Error while reading from Amazon S3 via Hadoop File System
>
[
https://issues.apache.org/jira/browse/BEAM-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugene Kirpichov updated BEAM-2803:
---
Fix Version/s: (was: Not applicable)
2.2.0
> JdbcIO read is very slow wh
101 - 200 of 666 matches
Mail list logo