KarmaGYZ opened a new pull request #17370:
URL: https://github.com/apache/flink/pull/17370
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
flinkbot edited a comment on pull request #17361:
URL: https://github.com/apache/flink/pull/17361#issuecomment-927655234
## CI report:
* a7234eeb1a7150ca6140de39fae8d1ee1c47389b Azure:
MartijnVisser commented on pull request #17360:
URL: https://github.com/apache/flink/pull/17360#issuecomment-929009820
We're receiving a lot of community feedback that new features are not or not
properly documented. It would be really good if we can get the documentation in
with this PR.
MartijnVisser commented on pull request #17349:
URL: https://github.com/apache/flink/pull/17349#issuecomment-929007543
I would leave it out of the Flink docs and work together on creating a blog
post out of this. I do believe the AsyncSinkBase will be in 1.15, so we should
do a blog when
flinkbot commented on pull request #17368:
URL: https://github.com/apache/flink/pull/17368#issuecomment-929006965
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot commented on pull request #17369:
URL: https://github.com/apache/flink/pull/17369#issuecomment-929006927
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
Robert Metzger created FLINK-24392:
--
Summary: Upgrade presto s3 fs implementation to Trinio >= 348
Key: FLINK-24392
URL: https://issues.apache.org/jira/browse/FLINK-24392
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19792:
---
Labels: auto-deprioritized-major pull-request-available (was:
auto-deprioritized-major)
>
Airblader commented on pull request #17368:
URL: https://github.com/apache/flink/pull/17368#issuecomment-929004253
There seems to be some overlap with
https://flink.apache.org/contributing/code-style-and-quality-components.html
with this?
--
This is an automated message from the Apache
slinkydeveloper opened a new pull request #17369:
URL: https://github.com/apache/flink/pull/17369
## What is the purpose of the change
Fix IntervalJoin runtime exception with equality predicate:
```
Caused by: java.lang.IllegalArgumentException: Key group 89 is not
matriv commented on a change in pull request #17341:
URL: https://github.com/apache/flink/pull/17341#discussion_r717378373
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CoalesceFunctionITCase.java
##
@@ -40,23 +41,28 @@
dannycranmer commented on pull request #17360:
URL: https://github.com/apache/flink/pull/17360#issuecomment-929000972
We will also need a documentation update similar to this:
-
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/formats/avro-confluent/
If
matriv commented on a change in pull request #17341:
URL: https://github.com/apache/flink/pull/17341#discussion_r717375199
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInFunctionTestBase.java
##
@@ -383,18 +439,69
matriv commented on a change in pull request #17341:
URL: https://github.com/apache/flink/pull/17341#discussion_r717374754
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInFunctionTestBase.java
##
@@ -383,18 +439,69
slinkydeveloper opened a new pull request #17368:
URL: https://github.com/apache/flink/pull/17368
## What is the purpose of the change
This PR adds a new page to add module specific guides for flink contributors.
## Brief change log
- Added the new module
matriv commented on a change in pull request #17341:
URL: https://github.com/apache/flink/pull/17341#discussion_r717367218
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInFunctionTestBase.java
##
@@ -261,6 +248,14 @@
flinkbot edited a comment on pull request #17367:
URL: https://github.com/apache/flink/pull/17367#issuecomment-928966227
## CI report:
* 82ee22fc68368972162785a3d390b0d39bfe0cfd Azure:
flinkbot edited a comment on pull request #17361:
URL: https://github.com/apache/flink/pull/17361#issuecomment-927655234
## CI report:
* a7234eeb1a7150ca6140de39fae8d1ee1c47389b Azure:
flinkbot edited a comment on pull request #17350:
URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692
## CI report:
* 8829be9b9a5b8ec95c8940853e7abd7f174ddf7b Azure:
[
https://issues.apache.org/jira/browse/FLINK-24377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421250#comment-17421250
]
Xintong Song commented on FLINK-24377:
--
Fixed via:
- master (1.15):
dannycranmer commented on a change in pull request #17360:
URL: https://github.com/apache/flink/pull/17360#discussion_r717342648
##
File path:
dannycranmer commented on pull request #17360:
URL: https://github.com/apache/flink/pull/17360#issuecomment-928976369
Can you please add an e2e test for the Table API support?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
twalthr commented on a change in pull request #17341:
URL: https://github.com/apache/flink/pull/17341#discussion_r717335148
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInFunctionTestBase.java
##
@@ -261,6 +248,14
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Summary: Support AWS Glue Schema Registry Avro for Table API (was: AWS
Glue Schema Registry
fapaul commented on a change in pull request #17342:
URL: https://github.com/apache/flink/pull/17342#discussion_r717339774
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java
flinkbot commented on pull request #17367:
URL: https://github.com/apache/flink/pull/17367#issuecomment-928966227
## CI report:
* 82ee22fc68368972162785a3d390b0d39bfe0cfd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #17350:
URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692
## CI report:
* 8829be9b9a5b8ec95c8940853e7abd7f174ddf7b Azure:
zentol commented on a change in pull request #14544:
URL: https://github.com/apache/flink/pull/14544#discussion_r717315877
##
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java
MartijnVisser commented on pull request #14544:
URL: https://github.com/apache/flink/pull/14544#issuecomment-928956978
I found two more minor references:
https://github.com/apache/flink/blob/master/flink-end-to-end-tests/test-scripts/kafka-common.sh#L55
Also the flag at
pnowojski commented on pull request #32:
URL: https://github.com/apache/flink-benchmarks/pull/32#issuecomment-928949800
> Unforunately it's not that perfect, as the ALIGNED checkpoint do not match
the math anymore. Or do they?
You can run the benchmark with different debloating
flinkbot commented on pull request #17367:
URL: https://github.com/apache/flink/pull/17367#issuecomment-928944825
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
dawidwys commented on a change in pull request #32:
URL: https://github.com/apache/flink-benchmarks/pull/32#discussion_r717316018
##
File path:
src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java
##
@@ -97,43 +100,119 @@
})
@Warmup(iterations =
[
https://issues.apache.org/jira/browse/FLINK-24382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24382:
---
Labels: pull-request-available (was: )
> RecordsOut metric for sinks is inaccurate
>
fapaul opened a new pull request #17367:
URL: https://github.com/apache/flink/pull/17367
…or to allow sinks emitting a flexible number of records
## What is the purpose of the change
Initially, we assumed every incoming record of a sink creates one
outgoing
pnowojski commented on a change in pull request #32:
URL: https://github.com/apache/flink-benchmarks/pull/32#discussion_r717314024
##
File path:
src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java
##
@@ -97,43 +100,119 @@
})
@Warmup(iterations =
flinkbot edited a comment on pull request #17365:
URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859
## CI report:
* 90a9e38f9e4e8f8cfb04adbe2e946941ff1f5be1 Azure:
flinkbot edited a comment on pull request #17366:
URL: https://github.com/apache/flink/pull/17366#issuecomment-928921801
## CI report:
* cae5f8a0dcb68cd8b17cce7903b997f8701a74bc Azure:
xintongsong closed pull request #17362:
URL: https://github.com/apache/flink/pull/17362
--
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:
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421218#comment-17421218
]
Shengnan YU edited comment on FLINK-23933 at 9/28/21, 7:38 AM:
---
I also
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421218#comment-17421218
]
Shengnan YU edited comment on FLINK-23933 at 9/28/21, 7:38 AM:
---
I also
[
https://issues.apache.org/jira/browse/FLINK-24391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-24391:
Description: Sometimes we only need to extra some columns of the json
message for indexing but
Shengnan YU created FLINK-24391:
---
Summary: flink-json formats should support an option to extract
the raw message into a column
Key: FLINK-24391
URL: https://issues.apache.org/jira/browse/FLINK-24391
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421218#comment-17421218
]
Shengnan YU commented on FLINK-23933:
-
I also advise that an option to extract the raw message into
[
https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421216#comment-17421216
]
Yordan Pavlov commented on FLINK-16267:
---
[~gunjansharma1409]
We work-around it, which works for
[
https://issues.apache.org/jira/browse/FLINK-24389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk updated FLINK-24389:
--
Labels: starter (was: )
> getDescription() in `CatalogTableImpl` should check null
>
[
https://issues.apache.org/jira/browse/FLINK-24389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421213#comment-17421213
]
Ingo Bürk commented on FLINK-24389:
---
+1. Would you like to send a PR for that?
> getDescription() in
flinkbot commented on pull request #17366:
URL: https://github.com/apache/flink/pull/17366#issuecomment-928921801
## CI report:
* cae5f8a0dcb68cd8b17cce7903b997f8701a74bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #17362:
URL: https://github.com/apache/flink/pull/17362#issuecomment-927655340
## CI report:
* d6a34e5d67500ab94d9b7c1a5a615ff582388563 Azure:
flinkbot edited a comment on pull request #17365:
URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859
## CI report:
* 90a9e38f9e4e8f8cfb04adbe2e946941ff1f5be1 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-20845:
---
Release Note: Support for Scala 2.11 has been removed.
> Drop support for Scala 2.11
>
[
https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421206#comment-17421206
]
Roman Khachatryan commented on FLINK-24374:
---
rkhachatryan commented on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-928906726
All commits:
`[FLINK-21357][runtime/statebackend]Periodic materialization for generalized
incremental checkpoints`
`[refactor] move AsyncExceptionHandler from
flinkbot commented on pull request #17366:
URL: https://github.com/apache/flink/pull/17366#issuecomment-928905078
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-24374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24374:
---
Labels: pull-request-available test-stability (was: test-stability)
>
dawidwys opened a new pull request #17366:
URL: https://github.com/apache/flink/pull/17366
## What is the purpose of the change
The checkpoint stats are updated after the corresponding future for a
checkpoint is completed. Therefore we might retrieve the old stats that
do
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717269001
##
File path:
flink-state-backends/flink-statebackend-changelog/src/test/resources/log4j2-test.properties
##
@@ -18,11 +18,11 @@
# Set root
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717267357
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
flinkbot edited a comment on pull request #17365:
URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859
## CI report:
* 90a9e38f9e4e8f8cfb04adbe2e946941ff1f5be1 Azure:
flinkbot edited a comment on pull request #17245:
URL: https://github.com/apache/flink/pull/17245#issuecomment-917600794
## CI report:
* d5699dd1fd9fc300bc188e9d77969333d749f8c9 Azure:
pnowojski commented on a change in pull request #468:
URL: https://github.com/apache/flink-web/pull/468#discussion_r717259595
##
File path: _posts/2021-09-21-release-1.14.0.md
##
@@ -0,0 +1,344 @@
+---
+layout: post
+title: "Apache Flink 1.14.0 Release Announcement"
+date:
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717262224
##
File path: pom.xml
##
@@ -1518,7 +1518,7 @@ under the License.
random: enable it
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717262224
##
File path: pom.xml
##
@@ -1518,7 +1518,7 @@ under the License.
random: enable it
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717261649
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
##
@@ -127,13 +128,29 @@
private boolean forceAvro =
rkhachatryan commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717260198
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/materializer/PeriodicMaterializer.java
pnowojski commented on a change in pull request #468:
URL: https://github.com/apache/flink-web/pull/468#discussion_r717258622
##
File path: _posts/2021-09-21-release-1.14.0.md
##
@@ -0,0 +1,344 @@
+---
+layout: post
+title: "Apache Flink 1.14.0 Release Announcement"
+date:
RocMarshal commented on pull request #17352:
URL: https://github.com/apache/flink/pull/17352#issuecomment-928891934
@Airblader Thank you so much for your suggestions. I updated the pr. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
JackWangCS commented on pull request #17245:
URL: https://github.com/apache/flink/pull/17245#issuecomment-928889427
Hi @lirui-apache , thanks for review. Currently, the CI on azure is not
stable now:
https://dev.azure.com/JackWangCS/Flink/_build/results?buildId=45=results.
I will re-run
zekai-li commented on pull request #17365:
URL: https://github.com/apache/flink/pull/17365#issuecomment-928887908
@is
--
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
[
https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421178#comment-17421178
]
Gunjan Sharma commented on FLINK-16267:
---
[~YordanPavlov] Were you able to circumvent this issue?
flinkbot edited a comment on pull request #17352:
URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700
## CI report:
* f1b1ebfc77aef1a0b658eec93b1f0be9ebe0c0c7 Azure:
curcur commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717251548
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@@
curcur commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717252158
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@@
curcur commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r717251548
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
##
@@
801 - 873 of 873 matches
Mail list logo
