[
https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407229#comment-17407229
]
Arvid Heise commented on FLINK-15451:
-
I got a case now
[
https://issues.apache.org/jira/browse/FLINK-24051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407202#comment-17407202
]
Arvid Heise commented on FLINK-24051:
-
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23817:
---
Assignee: Arvid Heise
> Write documentation for standardized operator metrics
>
[
https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23796.
-
Resolution: Fixed
> UnalignedCheckpointRescaleITCase JVM crash on Azure
>
[
https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406575#comment-17406575
]
Arvid Heise commented on FLINK-23913:
-
Note that this failure predates the fix in FLINK-23794. If
[
https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23913.
-
Resolution: Fixed
> UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure
[
https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406573#comment-17406573
]
Arvid Heise commented on FLINK-23796:
-
Note that this failure predates the fix in FLINK-23794. If
[
https://issues.apache.org/jira/browse/FLINK-23776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405965#comment-17405965
]
Arvid Heise commented on FLINK-23776:
-
Merged an improvement as
[
https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23794.
-
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405625#comment-17405625
]
Arvid Heise commented on FLINK-23945:
-
{quote}
I tried to debug using the source code, and then
[
https://issues.apache.org/jira/browse/FLINK-23877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405157#comment-17405157
]
Arvid Heise commented on FLINK-23877:
-
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23877.
-
Resolution: Fixed
> Embedded Pulsar broker backend for testing
>
[
https://issues.apache.org/jira/browse/FLINK-23877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23877:
---
Assignee: Yufan Sheng
> Embedded Pulsar broker backend for testing
>
[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405107#comment-17405107
]
Arvid Heise commented on FLINK-23969:
-
I assigned you, please wait for the documentation (just be
[
https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23969:
---
Assignee: Liu
> Test Pulsar source end 2 end
>
>
>
Arvid Heise created FLINK-23969:
---
Summary: Test Pulsar source end 2 end
Key: FLINK-23969
URL: https://issues.apache.org/jira/browse/FLINK-23969
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404373#comment-17404373
]
Arvid Heise edited comment on FLINK-23886 at 8/25/21, 11:49 AM:
{quote}
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404373#comment-17404373
]
Arvid Heise commented on FLINK-23886:
-
{quote}
Flink actually synchronizes invocations of onTimer()
[
https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404366#comment-17404366
]
Arvid Heise edited comment on FLINK-23945 at 8/25/21, 11:41 AM:
Your
[
https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404366#comment-17404366
]
Arvid Heise edited comment on FLINK-23945 at 8/25/21, 11:41 AM:
Your
[
https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404366#comment-17404366
]
Arvid Heise commented on FLINK-23945:
-
Your syntax is incorrect. s3:/// is always setting the bucket
[
https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23647:
---
Assignee: Arvid Heise
> UnalignedCheckpointStressITCase crashed on azure
>
[
https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404035#comment-17404035
]
Arvid Heise edited comment on FLINK-23913 at 8/24/21, 8:16 PM:
---
This is
[
https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404035#comment-17404035
]
Arvid Heise commented on FLINK-23913:
-
This is probably caused by FLINK-23794.
>
[
https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23796.
-
Resolution: Fixed
> UnalignedCheckpointRescaleITCase JVM crash on Azure
>
[
https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404034#comment-17404034
]
Arvid Heise commented on FLINK-23796:
-
I haven't seen any new reports. There is still the
[
https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-22889:
---
Assignee: Arvid Heise (was: Roman Khachatryan)
> JdbcExactlyOnceSinkE2eTest.testInsert
[
https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23794:
---
Assignee: Arvid Heise (was: Roman Khachatryan)
> JdbcExactlyOnceSinkE2eTest JVM crash on
[
https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403204#comment-17403204
]
Arvid Heise commented on FLINK-23794:
-
Wow thanks for the in-depth analysis.
I think I'll fix that
[
https://issues.apache.org/jira/browse/FLINK-23879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402542#comment-17402542
]
Arvid Heise commented on FLINK-23879:
-
Thanks for fixing [~chesnay]! Sorry for creating the mess - I
[
https://issues.apache.org/jira/browse/FLINK-23640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402398#comment-17402398
]
Arvid Heise commented on FLINK-23640:
-
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23640.
-
Fix Version/s: 1.14.0
Resolution: Fixed
> Create a KafkaRecordSerializationSchemas
[
https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23801:
---
Assignee: Qingsheng Ren
> Add FLIP-33 metrics to KafkaSource
>
[
https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23801.
-
Resolution: Fixed
> Add FLIP-33 metrics to KafkaSource
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402397#comment-17402397
]
Arvid Heise commented on FLINK-23801:
-
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23773:
---
Assignee: Qingsheng Ren
> KafkaPartitionSplitReader should remove empty splits from
[
https://issues.apache.org/jira/browse/FLINK-23838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23838.
-
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402116#comment-17402116
]
Arvid Heise commented on FLINK-23528:
-
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23854:
---
Assignee: Arvid Heise
> KafkaSink error when restart from the checkpoint with a lower
[
https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401591#comment-17401591
]
Arvid Heise commented on FLINK-23796:
-
On a related note, shouldn't Flink more gracefully exit on
[
https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401588#comment-17401588
]
Arvid Heise commented on FLINK-23796:
-
I have merged FLINK-23776, let's check back if this issue
[
https://issues.apache.org/jira/browse/FLINK-23776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23776.
-
Resolution: Fixed
Merged into master as 976026b63175e63009749936416fc9581a0bf56b.
>
[
https://issues.apache.org/jira/browse/FLINK-23854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23854:
Description:
The KafkaSink throws the exception when restarted with a lower parallelism and
the
[
https://issues.apache.org/jira/browse/FLINK-23854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23854:
Description:
The KafkaSink throws the exception when restarted with a lower parallelism and
the
[
https://issues.apache.org/jira/browse/FLINK-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23528:
---
Assignee: Arvid Heise
> stop-with-savepoint can fail with FlinkKinesisConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401025#comment-17401025
]
Arvid Heise commented on FLINK-20731:
-
[~syhily] just to clarify: It would be awesome if you could
[
https://issues.apache.org/jira/browse/FLINK-23858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23858:
Description:
The new Source apparently changed the way we specify records without
timestamps.
Arvid Heise created FLINK-23858:
---
Summary: Clarify StreamRecord#timestamp.
Key: FLINK-23858
URL: https://issues.apache.org/jira/browse/FLINK-23858
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23674.
-
Resolution: Duplicate
> flink restart with checkpoint ,kafka producer throw exception
>
[
https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400147#comment-17400147
]
Arvid Heise commented on FLINK-23674:
-
This seems to be a duplicate of FLINK-23509. The fix is
[
https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400072#comment-17400072
]
Arvid Heise edited comment on FLINK-23674 at 8/17/21, 5:31 AM:
---
Of course
[
https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400072#comment-17400072
]
Arvid Heise edited comment on FLINK-23674 at 8/17/21, 5:30 AM:
---
Of course
[
https://issues.apache.org/jira/browse/FLINK-23710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23710.
-
Fix Version/s: 1.14.0
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-20731.
-
Fix Version/s: 1.14.0
Release Note: Flink now directly provides a way to read data from
Arvid Heise created FLINK-23817:
---
Summary: Write documentation for standardized operator metrics
Key: FLINK-23817
URL: https://issues.apache.org/jira/browse/FLINK-23817
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399936#comment-17399936
]
Arvid Heise commented on FLINK-23647:
-
> I think it's still a bit fragile:
> 1. It assumes that the
Arvid Heise created FLINK-23816:
---
Summary: Test new (Kafka) metrics in cluster
Key: FLINK-23816
URL: https://issues.apache.org/jira/browse/FLINK-23816
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22790:
Fix Version/s: 1.14.0
> HybridSource end-to-end test
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22790:
Labels: release-testing (was: )
> HybridSource end-to-end test
>
>
[
https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-22790:
Priority: Blocker (was: Major)
> HybridSource end-to-end test
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-23814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23814:
Labels: release-testing (was: )
> Test FLIP-143 KafkaSink
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-23767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23767.
-
Fix Version/s: 1.14.0
Assignee: Arvid Heise
Resolution: Fixed
Merged into
[
https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399754#comment-17399754
]
Arvid Heise commented on FLINK-23797:
-
[~trohrm...@apache.org] could that be connected to your
[
https://issues.apache.org/jira/browse/FLINK-23785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23785.
-
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23807:
Description:
{{MiniClusterTestEnvironment#triggerTaskManagerFailover}} checks the job status
to
Arvid Heise created FLINK-23807:
---
Summary: Use metrics to detect restarts in
MiniClusterTestEnvironment#triggerTaskManagerFailover
Key: FLINK-23807
URL: https://issues.apache.org/jira/browse/FLINK-23807
Arvid Heise created FLINK-23803:
---
Summary: Improve instantiation of InMemoryReporter
Key: FLINK-23803
URL: https://issues.apache.org/jira/browse/FLINK-23803
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-23795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399526#comment-17399526
]
Arvid Heise commented on FLINK-23795:
-
Probably a duplicate of FLINK-23759.
>
[
https://issues.apache.org/jira/browse/FLINK-23793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-23793.
---
Resolution: Duplicate
This is a duplicate of FLINK-23785, fix available for review.
>
[
https://issues.apache.org/jira/browse/FLINK-23776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399522#comment-17399522
]
Arvid Heise commented on FLINK-23776:
-
Thanks for the report. I will investigate.
> Performance
[
https://issues.apache.org/jira/browse/FLINK-23785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399385#comment-17399385
]
Arvid Heise commented on FLINK-23785:
-
Synchronizing access to the reporter unfortunately only
[
https://issues.apache.org/jira/browse/FLINK-23785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23785:
---
Assignee: Arvid Heise
> SinkITCase.testMetrics fails with ConcurrentModification on Azure
[
https://issues.apache.org/jira/browse/FLINK-23652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23652.
-
Release Note: Connectors using unified Source and Sink interface expose
certain standardized
[
https://issues.apache.org/jira/browse/FLINK-23735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23735.
-
Fix Version/s: 1.14.0
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398757#comment-17398757
]
Arvid Heise edited comment on FLINK-23639 at 8/13/21, 6:19 PM:
---
Merged
[
https://issues.apache.org/jira/browse/FLINK-19554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-19554.
-
Assignee: Qingsheng Ren
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23639.
-
Fix Version/s: 1.14.0
Release Note: Table API/SQL write to Kafka with the new KafkaSink.
[
https://issues.apache.org/jira/browse/FLINK-23767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23767:
Issue Type: Improvement (was: Bug)
> FLIP-180: Adjust StreamStatus and Idleness definition
>
Arvid Heise created FLINK-23767:
---
Summary: FLIP-180: Adjust StreamStatus and Idleness definition
Key: FLINK-23767
URL: https://issues.apache.org/jira/browse/FLINK-23767
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23759:
Description:
In a private run on AZP, I found a run where {{notifyCheckpointComplete}} was
Arvid Heise created FLINK-23759:
---
Summary: notifyCheckpointComplete without corresponding
snapshotState
Key: FLINK-23759
URL: https://issues.apache.org/jira/browse/FLINK-23759
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397832#comment-17397832
]
Arvid Heise commented on FLINK-23678:
-
Ignoring test in ac42bb3d146 on master.
>
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397830#comment-17397830
]
Arvid Heise commented on FLINK-23678:
-
The new errors are related to FLINK-23408. We do not see a
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23678:
Attachment: extracted.log
> KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails
[
https://issues.apache.org/jira/browse/FLINK-23722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397606#comment-17397606
]
Arvid Heise edited comment on FLINK-23722 at 8/11/21, 8:13 PM:
---
Merged
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23678:
Priority: Critical (was: Major)
>
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-23678:
Priority: Major (was: Blocker)
> KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23678.
-
Resolution: Fixed
Merged into master as 58ff344e5e5fdd397e0f9276561b746ddabbadea.
>
[
https://issues.apache.org/jira/browse/FLINK-23722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23722.
-
Fix Version/s: 1.14.0
Resolution: Fixed
Merged into master as
[
https://issues.apache.org/jira/browse/FLINK-23722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397370#comment-17397370
]
Arvid Heise commented on FLINK-23722:
-
Downgrading to 3.3.0 yields HADOOP-17337. 3.2.2 looks good
Arvid Heise created FLINK-23722:
---
Summary: S3 Tests fail on AZP: Unable to find a region via the
region provider chain. Must provide an explicit region in the builder or setup
environment to supply a region.
Key: FLINK-23722
[
https://issues.apache.org/jira/browse/FLINK-23462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397220#comment-17397220
]
Arvid Heise commented on FLINK-23462:
-
This is now good to go. Thanks [~Liebing]!
> Translate the
[
https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-18562.
-
Release Note: Flink now supports reading from Azure Data Lake Store Gen 2
with the
[
https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17396853#comment-17396853
]
Arvid Heise commented on FLINK-23647:
-
Here is my solution to solve the test instability in code
[
https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17396845#comment-17396845
]
Arvid Heise commented on FLINK-23647:
-
Yes, it would also avoid ugly hacks like
[
https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23696:
---
Assignee: Fabian Paul
> RMQSourceTest.testRedeliveredSessionIDsAck fails on azure
>
[
https://issues.apache.org/jira/browse/FLINK-23255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-23255.
-
Resolution: Fixed
Merged into master as f8ce4d792a9725e550941fb9d5f4579055e80cf8.
> Add JUnit
[
https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17395843#comment-17395843
]
Arvid Heise commented on FLINK-23674:
-
Can you please provide the full log?
> flink restart with
[
https://issues.apache.org/jira/browse/FLINK-23683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23683:
---
Assignee: Fabian Paul
> KafkaSinkITCase hangs on azure
> --
>
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23678:
---
Assignee: Fabian Paul
> KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee
301 - 400 of 1238 matches
Mail list logo
