LI Mingkun created FLINK-29481:
--
Summary: Show JobType on WebUI
Key: FLINK-29481
URL: https://issues.apache.org/jira/browse/FLINK-29481
Project: Flink
Issue Type: Improvement
Component
Salva created FLINK-29480:
-
Summary: Skip invalid messages when writing
Key: FLINK-29480
URL: https://issues.apache.org/jira/browse/FLINK-29480
Project: Flink
Issue Type: Improvement
Compon
Thanks for the quick response!
Would this mean, that we have different connectors for Iceberg 0.14, and
Iceberg 0.15. Would these different versions kept in different repository?
My feeling is that this model is fine for the stable/slow moving systems
like Hive/HBase. For other systems, which are
jackylau created FLINK-29479:
Summary: support whether using system env for pythonpath
Key: FLINK-29479
URL: https://issues.apache.org/jira/browse/FLINK-29479
Project: Flink
Issue Type: Bug
Samrat Deb created FLINK-29478:
--
Summary: Flink sql Connector hive to support 3.1.3
Key: FLINK-29478
URL: https://issues.apache.org/jira/browse/FLINK-29478
Project: Flink
Issue Type: Improvemen
Juntao Hu created FLINK-29477:
-
Summary: ClassCastException when collect primitive array to Python
Key: FLINK-29477
URL: https://issues.apache.org/jira/browse/FLINK-29477
Project: Flink
Issue Typ
Hi,
Has anyone had experience setup Flink cluster and run Flink jobs in FIPS[1]
mode ?
[1] https://en.wikipedia.org/wiki/Federal_Information_Processing_Standards
Best,
Ted Chang
Hi Devs!
Based on the initial testing we identified 3 critical issues that together
warrant a new release candidate:
https://issues.apache.org/jira/browse/FLINK-29464
https://issues.apache.org/jira/browse/FLINK-29469
https://issues.apache.org/jira/browse/FLINK-29474
The issues have been fixed an
If you look at ElasticSearch [1] as an example there are different variants
of the connector depending on the "connected" system:
- flink-connector-elasticsearch6
- flink-connector-elasticsearch7
Looks like Hive and HBase follow a similar pattern in the main Flink repo/
[1] https://github.com/apa
Alexander Fedulov created FLINK-29476:
-
Summary: Kinesis Connector retry mechanism not applied to
EOFException
Key: FLINK-29476
URL: https://issues.apache.org/jira/browse/FLINK-29476
Project: Flin
Hi Team,
Just joining the conversation for the first time, so pardon me if I repeat
already answered questions.
It might be already discussed, but I think the version for the "connected"
system could be important as well.
There might be some API changes between Iceberg 0.14.2, and 1.0.0, which
w
Matyas Orhidi created FLINK-29475:
-
Summary: Add WARNING/ERROR checker for the operator in e2e tests
Key: FLINK-29475
URL: https://issues.apache.org/jira/browse/FLINK-29475
Project: Flink
Iss
Matyas Orhidi created FLINK-29474:
-
Summary: Name collision: Group already contains a Metric with the
name
Key: FLINK-29474
URL: https://issues.apache.org/jira/browse/FLINK-29474
Project: Flink
Chesnay Schepler created FLINK-29473:
Summary: Move Flink CI utils into separate project
Key: FLINK-29473
URL: https://issues.apache.org/jira/browse/FLINK-29473
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-29472:
Summary: Create shared release scripts
Key: FLINK-29472
URL: https://issues.apache.org/jira/browse/FLINK-29472
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-29471:
Summary: Create a flink-connector-parent pom
Key: FLINK-29471
URL: https://issues.apache.org/jira/browse/FLINK-29471
Project: Flink
Issue Type: Sub-t
Chesnay Schepler created FLINK-29470:
Summary: Setup shared utils for connector externalization
Key: FLINK-29470
URL: https://issues.apache.org/jira/browse/FLINK-29470
Project: Flink
Issu
2) No; the branch names would not have a Flink version in them; v1.0.0,
v1.0.1 etc.
On 29/09/2022 14:03, Martijn Visser wrote:
If I summarize it correctly, that means that:
1. The versioning scheme would be -, where there will never be a
patch release for a minor version if a newer minor versi
If I summarize it correctly, that means that:
1. The versioning scheme would be -, where there will never be a
patch release for a minor version if a newer minor version already exists.
E.g., 1.0.0-1.15; 1.0.1-1.15; 1.1.0-1.15; 1.2.0-1.15;
2. The branch naming scheme would be vmajor.minor-flink-m
Gyula Fora created FLINK-29469:
--
Summary: Generate noop.jar instead of committing into source
Key: FLINK-29469
URL: https://issues.apache.org/jira/browse/FLINK-29469
Project: Flink
Issue Type: I
MartijnVisser merged PR #2:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr.
MartijnVisser commented on PR #2:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/2#issuecomment-1262073428
@zentol Ideally this will be available for
https://github.com/apache/flink-connector-rabbitmq/pull/1 benefits from it when
rebasing
--
This is an automated message fr
Sergey Nuyanzin created FLINK-29468:
---
Summary: Update jackson-bom to 2.13.4
Key: FLINK-29468
URL: https://issues.apache.org/jira/browse/FLINK-29468
Project: Flink
Issue Type: Technical Debt
+1 (non-binding)
- downloaded the artifacts
- compiled from source
- verified checksum
- verified signatures
On Thu, Sep 29, 2022 at 9:26 AM Martijn Visser
wrote:
> Thanks for pushing this release Chesnay.
>
> +1 (binding)
>
> - Verified that checksums and GPG files match the released files
> -
Martijn Visser created FLINK-29467:
--
Summary: Sync RabbitMQ CI setup with Elasticsearch CI setup
Key: FLINK-29467
URL: https://issues.apache.org/jira/browse/FLINK-29467
Project: Flink
Issue
Martijn Visser created FLINK-29466:
--
Summary: Update org.postgresql:postgresql to 42.5.0
Key: FLINK-29466
URL: https://issues.apache.org/jira/browse/FLINK-29466
Project: Flink
Issue Type: Te
Xin Hao created FLINK-29465:
---
Summary: Supports limit factor in the resource definition
Key: FLINK-29465
URL: https://issues.apache.org/jira/browse/FLINK-29465
Project: Flink
Issue Type: Improvemen
Gyula Fora created FLINK-29464:
--
Summary: JobID generation logic could lead to state loss
Key: FLINK-29464
URL: https://issues.apache.org/jira/browse/FLINK-29464
Project: Flink
Issue Type: Impro
Thanks for pushing this release Chesnay.
+1 (binding)
- Verified that checksums and GPG files match the released files
- Verified that no binaries exist in the source archive
- Build the source with Maven
- Checked that POM files point to the same version
- Verified licenses
- Verified web PR
Be
29 matches
Mail list logo
