[
https://issues.apache.org/jira/browse/BEAM-10829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10829:
Fix Version/s: 2.25.0
> Support Kafka Headers in KafkaWri
[
https://issues.apache.org/jira/browse/BEAM-10829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10829:
Status: Resolved (was: Open)
> Support Kafka Headers in KafkaWri
[
https://issues.apache.org/jira/browse/BEAM-10759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10759:
Fix Version/s: 2.25.0
> KafkaIO with Avro deserializer fails with evolved sch
[
https://issues.apache.org/jira/browse/BEAM-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10673:
Fix Version/s: 2.25.0
> DynamoDBIO.RetryConfiguration does not have public construc
[
https://issues.apache.org/jira/browse/BEAM-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10673:
Status: Open (was: Triage Needed)
> DynamoDBIO.RetryConfiguration does not have pub
[
https://issues.apache.org/jira/browse/BEAM-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10673:
Summary: DynamoDBIO.RetryConfiguration in AWS v2 is not correctly exposed
(was
[
https://issues.apache.org/jira/browse/BEAM-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10673:
Status: Resolved (was: Open)
> DynamoDBIO.RetryConfiguration in AWS v2 is not correctly expo
Lourens Naudé created BEAM-10865:
Summary: Support for Kafka deserialization API with headers (since
Kafka API 2.1.0)
Key: BEAM-10865
URL: https://issues.apache.org/jira/browse/BEAM-10865
Project
[
https://issues.apache.org/jira/browse/BEAM-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lourens Naudé updated BEAM-10865:
-
Description:
References mailing list posts:
* Original
[https://lists.apache.org/thread.html
/jira/browse/BEAM-11023
Project: Beam
Issue Type: Test
Components: runner-spark
Reporter: Ismaël Mejía
Assignee: Etienne Chauchot
While working on BEAM-10969 I noticed that some VR tests of the Structured
Streaming runner were failing. After
[
https://issues.apache.org/jira/browse/BEAM-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11023:
Status: Open (was: Triage Needed)
> GroupByKeyTest testLargeKeys100MB
Ismaël Mejía created BEAM-11027:
---
Summary: ZetaSQL Nexmark run takes too long because of excessive
logging
Key: BEAM-11027
URL: https://issues.apache.org/jira/browse/BEAM-11027
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-11027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11027:
Description:
The execution of the Nexmark ZetaSQL tests takes too long and produces a
gigantic
[
https://issues.apache.org/jira/browse/BEAM-11027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11027:
Description:
The execution of the Nexmark ZetaSQL tests takes too long and produces a
gigantic
[
https://issues.apache.org/jira/browse/BEAM-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11028:
Status: Open (was: Triage Needed)
> NullPointerException when running Flink Nexmark tests
Ismaël Mejía created BEAM-11028:
---
Summary: NullPointerException when running Flink Nexmark tests on
Streaming after switch to SDF based translation
Key: BEAM-11028
URL: https://issues.apache.org/jira/browse/BEAM
[
https://issues.apache.org/jira/browse/BEAM-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11028:
Description:
When running Nexmark on Streaming mode with Flink locally via:
/gradlew
[
https://issues.apache.org/jira/browse/BEAM-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11028:
Fix Version/s: 2.25.0
> NullPointerException when running Flink Nexmark tests on Streaming af
[
https://issues.apache.org/jira/browse/BEAM-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209203#comment-17209203
]
Ismaël Mejía commented on BEAM-11028:
-
Looks like streaming runs are not wor
[
https://issues.apache.org/jira/browse/BEAM-11028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209203#comment-17209203
]
Ismaël Mejía edited comment on BEAM-11028 at 10/6/20, 10:4
Ismaël Mejía created BEAM-11030:
---
Summary: Nexmark Query 3 produces inconsistent output size on
Direct runner
Key: BEAM-11030
URL: https://issues.apache.org/jira/browse/BEAM-11030
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-11030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209207#comment-17209207
]
Ismaël Mejía commented on BEAM-11030:
-
[~lcwik] I don't think this is relat
[
https://issues.apache.org/jira/browse/BEAM-11027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11027:
Status: Resolved (was: Open)
> ZetaSQL Nexmark run takes too long because of excessive logg
Ismaël Mejía created BEAM-11055:
---
Summary: Update log4j to version 2.13.3
Key: BEAM-11055
URL: https://issues.apache.org/jira/browse/BEAM-11055
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-11030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212210#comment-17212210
]
Ismaël Mejía commented on BEAM-11030:
-
I see, good to know it is unrelated.
[
https://issues.apache.org/jira/browse/BEAM-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Schöneweiß reassigned BEAM-3378:
Assignee: Dominik Schöneweiß
> Using ValueProvider with FixedWindows and Durat
[
https://issues.apache.org/jira/browse/BEAM-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11050:
Fix Version/s: 2.26.0
> AggregatorCombiner reuses mutable accumT across multiple merges leading
[
https://issues.apache.org/jira/browse/BEAM-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11050:
Status: Resolved (was: Open)
> AggregatorCombiner reuses mutable accumT across multiple mer
[
https://issues.apache.org/jira/browse/BEAM-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10800:
Status: Resolved (was: Triage Needed)
> Beam Dependency Update Request: com.azure:azure-stor
[
https://issues.apache.org/jira/browse/BEAM-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía reassigned BEAM-10800:
---
Assignee: Pawel Pasterz
> Beam Dependency Update Request: com.azure:azure-storage-b
[
https://issues.apache.org/jira/browse/BEAM-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10803:
Status: Resolved (was: Triage Needed)
> Beam Dependency Update Request: com.microsoft.azure:az
[
https://issues.apache.org/jira/browse/BEAM-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10800:
Fix Version/s: 2.26.0
> Beam Dependency Update Request: com.azure:azure-storage-b
[
https://issues.apache.org/jira/browse/BEAM-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10803:
Fix Version/s: 2.26.0
> Beam Dependency Update Request: com.microsoft.azure:azure-stor
[
https://issues.apache.org/jira/browse/BEAM-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía reassigned BEAM-10803:
---
Assignee: Pawel Pasterz
> Beam Dependency Update Request: com.microsoft.azure:azure-stor
[
https://issues.apache.org/jira/browse/BEAM-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-3378 started by Dominik Schöneweiß.
> Using ValueProvider with FixedWindows and Durat
[
https://issues.apache.org/jira/browse/BEAM-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216504#comment-17216504
]
Ismaël Mejía commented on BEAM-5573:
jna dependency was removed by the associat
[
https://issues.apache.org/jira/browse/BEAM-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-5573:
---
Status: Resolved (was: Open)
> Beam Dependency Update Request: net.java.dev.jna:
[
https://issues.apache.org/jira/browse/BEAM-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10370:
Fix Version/s: 2.26.0
> Beam Dependency Update Request: redis.clients:je
[
https://issues.apache.org/jira/browse/BEAM-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-6124:
---
Status: Resolved (was: Triage Needed)
> Beam Dependency Update Request: redis.clie
[
https://issues.apache.org/jira/browse/BEAM-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10370:
Summary: Update jedis to version 3.3.0 (was: Beam Dependency Update
Request: redis.clients:jedis
[
https://issues.apache.org/jira/browse/BEAM-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10370:
Status: Resolved (was: Triage Needed)
> Update jedis to version 3.
[
https://issues.apache.org/jira/browse/BEAM-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía reassigned BEAM-10370:
---
Assignee: Pawel Pasterz
> Beam Dependency Update Request: redis.clients:je
[
https://issues.apache.org/jira/browse/BEAM-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-8928:
---
Fix Version/s: 2.26.0
> Beam Dependency Update Request: ru.yandex.clickhouse:clickhouse-j
[
https://issues.apache.org/jira/browse/BEAM-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-8928:
---
Summary: Update clickhouse-jdbc to version 0.2.4 (was: Beam Dependency
Update Request
[
https://issues.apache.org/jira/browse/BEAM-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía reassigned BEAM-8928:
--
Assignee: Pawel Pasterz
> Update clickhouse-jdbc to version 0.
[
https://issues.apache.org/jira/browse/BEAM-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-8928:
---
Status: Resolved (was: Open)
> Update clickhouse-jdbc to version 0.
[
https://issues.apache.org/jira/browse/BEAM-8927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-8927:
---
Status: Resolved (was: Open)
> Beam Dependency Update Request: ru.yandex.clickho
Ismaël Mejía created BEAM-11080:
---
Summary: Beam Java SNAPSHOTS should not be built with Java 11
Key: BEAM-11080
URL: https://issues.apache.org/jira/browse/BEAM-11080
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11080:
Description:
{quote}{{We have a series of jobs that check forwards compatibility of our apps
with
[
https://issues.apache.org/jira/browse/BEAM-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11080:
Description:
{quote}{{We have a series of jobs that check forwards compatibility of our apps
with
[
https://issues.apache.org/jira/browse/BEAM-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11080:
Description:
{quote}{{We have a series of jobs that check forwards compatibility of our apps
with
[
https://issues.apache.org/jira/browse/BEAM-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10706:
Issue Type: New Feature (was: Bug)
> DynamoDBIO fail to write to the same key in sh
[
https://issues.apache.org/jira/browse/BEAM-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10706:
Status: Open (was: Triage Needed)
> DynamoDBIO fail to write to the same key in short consecut
[
https://issues.apache.org/jira/browse/BEAM-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10706:
Issue Type: Bug (was: New Feature)
> DynamoDBIO fail to write to the same key in sh
[
https://issues.apache.org/jira/browse/BEAM-950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-950:
--
Issue Type: Improvement (was: Bug)
> DoFn Setup and Teardown methods should have access
[
https://issues.apache.org/jira/browse/BEAM-950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-950:
--
Status: Open (was: Triage Needed)
> DoFn Setup and Teardown methods should have access
[
https://issues.apache.org/jira/browse/BEAM-10492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10492:
Status: Resolved (was: In Progress)
> DLP transforms don't accept sid
[
https://issues.apache.org/jira/browse/BEAM-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-10410:
Summary: Python KafkaIO should be in io package. (was: Python KafakaIO
should be in io package
[
https://issues.apache.org/jira/browse/BEAM-10314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183474#comment-17183474
]
Alexander Faxå commented on BEAM-10314:
---
I am still affected by this and
[
https://issues.apache.org/jira/browse/BEAM-10314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Faxå updated BEAM-10314:
--
Labels: (was: stale-P2)
> Writing containers containing nested Decimal to BigQuery fa
[
https://issues.apache.org/jira/browse/BEAM-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9850:
---
Component/s: (was: sdk-java-core)
> Key should be available in @OnTimer methods (Spark Run
[
https://issues.apache.org/jira/browse/BEAM-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9850:
---
Issue Type: Improvement (was: Bug)
> Key should be available in @OnTimer methods (Spark Run
[
https://issues.apache.org/jira/browse/BEAM-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9850:
---
Fix Version/s: 2.25.0
> Key should be available in @OnTimer methods (Spark Run
[
https://issues.apache.org/jira/browse/BEAM-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9850:
---
Status: Resolved (was: Open)
> Key should be available in @OnTimer methods (Spark Run
[
https://issues.apache.org/jira/browse/BEAM-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-7304:
---
Component/s: runner-twister2
> Twister2 Beam runner
>
>
>
[
https://issues.apache.org/jira/browse/BEAM-10829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía reassigned BEAM-10829:
---
Assignee: Omkar Deshpande
> Support Kafka Headers in KafkaWri
Teodor Spæren created BEAM-11146:
Summary: Add option to disable copying between Flink runner
Key: BEAM-11146
URL: https://issues.apache.org/jira/browse/BEAM-11146
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11080:
Status: Resolved (was: Open)
> Beam Java SNAPSHOTS should not be built with Java
[
https://issues.apache.org/jira/browse/BEAM-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222818#comment-17222818
]
Ismaël Mejía commented on BEAM-11080:
-
That was it, it is working as expected
Lars Schöning created BEAM-11153:
Summary: Support parameterized queries in beam.io.ReadFromBigQuery
Key: BEAM-11153
URL: https://issues.apache.org/jira/browse/BEAM-11153
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Teodor Spæren updated BEAM-11146:
-
External issue URL: https://github.com/apache/beam/pull/13240
> Add option to disable copy
[
https://issues.apache.org/jira/browse/BEAM-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11146:
Status: Open (was: Triage Needed)
> Add option to disable copying between Flink run
[
https://issues.apache.org/jira/browse/BEAM-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Teodor Spæren updated BEAM-11146:
-
Status: Resolved (was: Open)
> Add option to disable copying between Flink run
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11191:
Status: Open (was: Triage Needed)
> clearGlobalState() method failing on Flink runner 1.10
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11191:
Priority: P2 (was: P0)
> clearGlobalState() method failing on Flink runner 1.10 and 1
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11191:
Priority: P1 (was: P0)
> clearGlobalState() method failing on Flink runner 1.10 and 1
[
https://issues.apache.org/jira/browse/BEAM-11055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226294#comment-17226294
]
Ismaël Mejía commented on BEAM-11055:
-
[~znick] I was investigating this today
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský reassigned BEAM-11191:
---
Assignee: Jan Lukavský
> clearGlobalState() method failing on Flink runner 1.10 and 1
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11191:
Fix Version/s: 2.26.0
> clearGlobalState() method failing on Flink runner 1.10 and 1
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226784#comment-17226784
]
Jan Lukavský commented on BEAM-11191:
-
[~james-woods] thanks for the report!
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11191:
Status: Resolved (was: Open)
> clearGlobalState() method failing on Flink runner 1.10 and 1
[
https://issues.apache.org/jira/browse/BEAM-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11023:
Description:
While working on BEAM-10969 I noticed that some VR tests of the Structured
Streaming
[
https://issues.apache.org/jira/browse/BEAM-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-11191:
Status: Resolved (was: Resolved)
> clearGlobalState() method failing on Flink runner 1.10
[
https://issues.apache.org/jira/browse/BEAM-11055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-11055:
Summary: Update log4j to version 2.14.0 (was: Update log4j to version
2.13.3)
> Update log4j
Ismaël Mejía created BEAM-11258:
---
Summary: Beam labels in github not appearing
Key: BEAM-11258
URL: https://issues.apache.org/jira/browse/BEAM-11258
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-10083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157745#comment-17157745
]
Ismaël Mejía commented on BEAM-10083:
-
Sorry I missed this message, Spark 2.x
Michał Walenia created BEAM-10492:
-
Summary: DLP transforms don't accept side inputs
Key: BEAM-10492
URL: https://issues.apache.org/jira/browse/BEAM-10492
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-10492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-10492 started by Michał Walenia.
-
> DLP transforms don't accept sid
[
https://issues.apache.org/jira/browse/BEAM-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía resolved BEAM-8727.
Fix Version/s: 2.24.0
Resolution: Fixed
> Beam Dependency Update Requ
[
https://issues.apache.org/jira/browse/BEAM-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158693#comment-17158693
]
Ismaël Mejía commented on BEAM-8727:
[~aromanenko] I suppose we should resolve/c
Jan Lukavský created BEAM-10510:
---
Summary: NPE when closing UnboundedSourceWrapper
Key: BEAM-10510
URL: https://issues.apache.org/jira/browse/BEAM-10510
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-10510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-10510:
Description:
2020-07-16 14:51:00,282 ERROR
org.apache.flink.streaming.runtime.tasks.StreamTask
Jan Lukavský created BEAM-10533:
---
Summary: Remove watermark hold from RequiresTimeSortedInput
Key: BEAM-10533
URL: https://issues.apache.org/jira/browse/BEAM-10533
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-10533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský resolved BEAM-10533.
-
Fix Version/s: 2.24.0
Resolution: Fixed
> Remove watermark hold f
[
https://issues.apache.org/jira/browse/BEAM-10510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský resolved BEAM-10510.
-
Fix Version/s: 2.24.0
Resolution: Fixed
> NPE when closing UnboundedSourceWrap
[
https://issues.apache.org/jira/browse/BEAM-10400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-10400:
Status: Resolved (was: Open)
> DirectRunner: race condition in watermark upd
[
https://issues.apache.org/jira/browse/BEAM-10400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-10400:
Fix Version/s: 2.24.0
> DirectRunner: race condition in watermark upd
[
https://issues.apache.org/jira/browse/BEAM-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský reassigned BEAM-8648:
--
Assignee: Jan Lukavský
> Euphoria: Deprecate OutputHints from public
[
https://issues.apache.org/jira/browse/BEAM-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-8648:
---
Fix Version/s: 2.24.0
> Euphoria: Deprecate OutputHints from public
[
https://issues.apache.org/jira/browse/BEAM-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jan Lukavský updated BEAM-8648:
---
Status: Resolved (was: Open)
> Euphoria: Deprecate OutputHints from public
1 - 100 of 213100 matches
Mail list logo
