wanglijie95 commented on code in PR #22840:
URL: https://github.com/apache/flink/pull/22840#discussion_r1257432832
##
flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java:
##
@@ -116,6 +118,18 @@ interface InitContext {
*/
SerializationSchem
wanglijie95 commented on PR #22840:
URL: https://github.com/apache/flink/pull/22840#issuecomment-1627716447
@eskabetxe I add a test `SinkWriterOperatorTest#testInitContext` to test the
changes :)
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
lincoln-lil opened a new pull request, #22972:
URL: https://github.com/apache/flink/pull/22972
## What is the purpose of the change
This is a subtask of FLINK-32457, it added test cases of unsupported usage
for JSON_OBJECTAGG & JSON_ARRAYAGG and also update the related docs(expand the
im
[
https://issues.apache.org/jira/browse/FLINK-32457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32457:
---
Labels: pull-request-available (was: )
> update current documentation of JSON_OBJECTAGG/JSO
flinkbot commented on PR #22972:
URL: https://github.com/apache/flink/pull/22972#issuecomment-1627737552
## CI report:
* c897b784d41f2c0fcfb6f114e9f0f42f2fbf5174 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp merged PR #22919:
URL: https://github.com/apache/flink/pull/22919
--
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: issues-unsubscr...@flink.apache.
[
https://issues.apache.org/jira/browse/FLINK-31837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-31837.
---
Fix Version/s: 1.18.0
Resolution: Fixed
master: d2e6b94b374a40551a5cb1a81af2683f4a9ce
XComp commented on PR #22967:
URL: https://github.com/apache/flink/pull/22967#issuecomment-1627765353
I rebased to most-recent master after the aforementioned PRs were merged. I
fixed the occurrences of `contender.?id` in a separate commit and force-pushed
the changes.
--
This is an auto
zhouchitc commented on PR #16927:
URL: https://github.com/apache/flink/pull/16927#issuecomment-1627923943
Hi, when I merged these commits on my home branch(based on 1.14.2), I still
met this problem.
> Introduce file merging configuration
> ---
flinkbot commented on PR #22973:
URL: https://github.com/apache/flink/pull/22973#issuecomment-1627980326
## CI report:
* 9045ee1175cf2e59e3f9fc7a8b0d2a3ec31281d0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-32566:
-
Affects Version/s: (was: 1.17.1)
> HeapBytesVector meets java.lang.NegativeArraySizeException
>
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32566:
-
Description:
When reading the parquet format files, if the data of some fields is too large,
HeapBytesV
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32566:
-
Affects Version/s: 1.17.1
> HeapBytesVector meets java.lang.NegativeArraySizeException
> ---
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32566:
-
Description:
When reading the parquet format files, if the data of some fields is too
large(to support
leonardBang merged PR #662:
URL: https://github.com/apache/flink-web/pull/662
--
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: issues-unsubscr...@flink.a
[
https://issues.apache.org/jira/browse/FLINK-32555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-32555.
Resolution: Fixed
Resolved in flink-web(asf-site): 65990f39399a51b9d010c4fab110d4d6ca71f127
> Add
[
https://issues.apache.org/jira/browse/FLINK-32555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-32555:
---
Summary: Add a post to record SIGMOD System Award for Apache Flink (was:
Add a page to show SIGMOD
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741463#comment-17741463
]
Yun Tang commented on FLINK-32566:
--
It seems that the {{HeapBytesVector}} would reserve
宇宙先生 created FLINK-32567:
Summary: when Flink write azure data lake storage,error occur
Key: FLINK-32567
URL: https://issues.apache.org/jira/browse/FLINK-32567
Project: Flink
Issue Type: Bug
swuferhong commented on code in PR #22966:
URL: https://github.com/apache/flink/pull/22966#discussion_r1257622849
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java:
##
@@ -165,6 +167,51 @@ public class OptimizerConfig
swuferhong commented on code in PR #22966:
URL: https://github.com/apache/flink/pull/22966#discussion_r1257790505
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java:
##
@@ -165,6 +167,51 @@ public class OptimizerConfig
23 matches
Mail list logo
