snuyanzin commented on PR #20128:
URL: https://github.com/apache/flink/pull/20128#issuecomment-1487979862
@MartijnVisser seems I found the reason
It looks the issue was in inconsistent jna dependency provided by
flink-end-to-end-tests.
At the same time testcontainers 1.17.6. depends
paul8263 commented on PR #20343:
URL: https://github.com/apache/flink/pull/20343#issuecomment-1487976782
@flinkbot run azure
--
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.
[
https://issues.apache.org/jira/browse/FLINK-31220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706223#comment-17706223
]
Gyula Fora commented on FLINK-31220:
The key here is the additionalProperties field that captures
[
https://issues.apache.org/jira/browse/FLINK-31220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706222#comment-17706222
]
Gyula Fora commented on FLINK-31220:
Seems to me that this will be a backward compatible change.
lindong28 commented on PR #228:
URL: https://github.com/apache/flink-ml/pull/228#issuecomment-1487958825
@zhipeng93 Can you help review this PR?
--
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
[
https://issues.apache.org/jira/browse/FLINK-30607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706208#comment-17706208
]
Xuannan Su commented on FLINK-30607:
[~dianfu] Thanks for the patch! This is very useful in our use
reswqa commented on PR #22280:
URL: https://github.com/apache/flink/pull/22280#issuecomment-1487919501
Thanks @TanYuxin-tyx for the review, I have addressed all the comments in
the fix-up commit, please take a look again.
--
This is an automated message from the Apache Git Service.
To
reswqa commented on code in PR #22280:
URL: https://github.com/apache/flink/pull/22280#discussion_r1151370945
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImpl.java:
##
@@ -251,6 +273,18 @@ public Buffer.DataType
reswqa commented on code in PR #22280:
URL: https://github.com/apache/flink/pull/22280#discussion_r1151370945
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImpl.java:
##
@@ -251,6 +273,18 @@ public Buffer.DataType
flinkbot commented on PR #22292:
URL: https://github.com/apache/flink/pull/22292#issuecomment-1487913850
## CI report:
* f6d2f99966982ac7a3360aaf4fdefd5cda3d4995 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lindong28 opened a new pull request, #228:
URL: https://github.com/apache/flink-ml/pull/228
## What is the purpose of the change
Make the feature engineering algorithm names consistent in the website
[
https://issues.apache.org/jira/browse/FLINK-31651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31651:
---
Labels: pull-request-available (was: )
> Improve logging of granting/revoking leadership
wanglijie95 opened a new pull request, #22292:
URL: https://github.com/apache/flink/pull/22292
## What is the purpose of the change
Currently, the log level of granting/revoking leadership of
JobMasterServiceLeadershipRunner is DEBUG. However, we usually configure it to
INFO level in
flinkbot commented on PR #22291:
URL: https://github.com/apache/flink/pull/22291#issuecomment-1487893751
## CI report:
* 27545880e14511404102f8c5390a03d152b8e03e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706201#comment-17706201
]
haishui commented on FLINK-31632:
-
This problem seems to be caused by the overflow of
[
https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31632:
---
Labels: pull-request-available (was: )
> watermark aligned idle source can't resume
>
haishui126 opened a new pull request, #22291:
URL: https://github.com/apache/flink/pull/22291
## What is the purpose of the change
This PR aims to fix maxAllowedWatermark overflow when source is idle, which
leads to source can't resume to active.
## Brief change log
haishui126 closed pull request #22290: 31632
URL: https://github.com/apache/flink/pull/22290
--
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-31545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31545:
--
Assignee: Fang Yong
> FlinkConnection creates and manages statements
>
Lijie Wang created FLINK-31651:
--
Summary: Improve logging of granting/revoking leadership in
JobMasterServiceLeadershipRunner to INFO level
Key: FLINK-31651
URL: https://issues.apache.org/jira/browse/FLINK-31651
[
https://issues.apache.org/jira/browse/FLINK-31547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31547:
--
Assignee: Fang Yong
> Introduce FlinkResultSetMetaData for jdbc driver
>
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-31650:
---
Affects Version/s: 1.15.4
> Incorrect busyMsTimePerSecond metric value for FINISHED task
>
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706199#comment-17706199
]
Lijie Wang commented on FLINK-31650:
I guess this is because the value of busyMsTimePerSecond is
haishui126 opened a new pull request, #22290:
URL: https://github.com/apache/flink/pull/22290
## What is the purpose of the change
This PR aims to fix maxAllowedWatermark overflow when source is idle, which
leads to source can't resume to active.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-31429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31429.
Resolution: Fixed
> Support CTAS(create table as) streaming job with schema changes in table
[
https://issues.apache.org/jira/browse/FLINK-31435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31435.
Resolution: Fixed
> Introduce event parser for MySql Debezium JSON format in Table Store
>
[
https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30419.
Resolution: Fixed
> Allow tuning of transaction timeout
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706198#comment-17706198
]
Jingsong Lee commented on FLINK-30419:
--
https://github.com/apache/incubator-paimon/issues/754
>
[
https://issues.apache.org/jira/browse/FLINK-27958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27958.
Resolution: Fixed
> Compare batch maxKey to reduce comparisons in SortMergeReader
>
[
https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-3.
Resolution: Fixed
> Introduce CatalogTestBase
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-31001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31001.
Resolution: Fixed
> Introduce Hive writer
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-27103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27103.
Resolution: Fixed
> Don't store redundant primary key fields
>
[
https://issues.apache.org/jira/browse/FLINK-27002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27002.
Resolution: Fixed
> Optimize batch multiple partitions inserting
>
[
https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31190.
Resolution: Fixed
> Supports Spark call procedure command on Table Store
>
[
https://issues.apache.org/jira/browse/FLINK-28086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28086.
Resolution: Fixed
> Table Store Catalog supports partition methods
>
[
https://issues.apache.org/jira/browse/FLINK-31194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31194.
Resolution: Fixed
> Introduces savepoint mechanism of Table Store
>
[
https://issues.apache.org/jira/browse/FLINK-31195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31195.
Resolution: Fixed
> FullChangelogStoreSinkWrite bucket writer conflicts with rescale
>
[
https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706196#comment-17706196
]
Yanfei Lei commented on FLINK-31593:
I found the following log in
[
https://issues.apache.org/jira/browse/FLINK-30945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30945.
Resolution: Fixed
https://github.com/apache/incubator-paimon/issues/745
> FTS does not support
mynkyu closed pull request #22265: [docs] task_failure_recovery.md typo fix
URL: https://github.com/apache/flink/pull/22265
--
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
FangYongs closed pull request #18490: [FLINK-25794][sql-runtime] Clean cache
after memory segments in it after they are released to MemoryManager
URL: https://github.com/apache/flink/pull/18490
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot commented on PR #22289:
URL: https://github.com/apache/flink/pull/22289#issuecomment-1487875564
## CI report:
* 351a2da4884f5e57cf0e71bf2c35905bf03a3d7b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31545:
---
Labels: pull-request-available (was: )
> FlinkConnection creates and manages statements
>
FangYongs opened a new pull request, #22289:
URL: https://github.com/apache/flink/pull/22289
## What is the purpose of the change
This PR aims to create `Executor` in `FlinkConnection` and supports
catalog/schema related operations
## Brief change log
- Create `Executor`
Lijie Wang created FLINK-31650:
--
Summary: Incorrect busyMsTimePerSecond metric value for FINISHED
task
Key: FLINK-31650
URL: https://issues.apache.org/jira/browse/FLINK-31650
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-31650:
---
Description:
As shown in the figure below, the busyMsTimePerSecond of the FINISHED task is
100%,
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1151334278
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayPositionFunction.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1151333109
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1151332401
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1151331431
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns
TanYuxin-tyx commented on code in PR #22280:
URL: https://github.com/apache/flink/pull/22280#discussion_r1150216597
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImplTest.java:
##
@@ -392,6 +395,46 @@ void
[
https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706184#comment-17706184
]
Xuannan Su commented on FLINK-24456:
Thanks for the effort! This is a particularly useful feature in
luoyuxia commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1151325075
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayPositionFunction.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-30327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706183#comment-17706183
]
Xin Li commented on FLINK-30327:
Hi [~mapohl] I would like to try this.
> Adding a values.schema.json
[
https://issues.apache.org/jira/browse/FLINK-31220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706180#comment-17706180
]
Xin Li commented on FLINK-31220:
Hi [~gyfora], this heard like importing the pod spec in the controller
liuyongvs commented on PR #19873:
URL: https://github.com/apache/flink/pull/19873#issuecomment-1487848508
hi @snuyanzin ,will you go on? if not, i can take it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31076.
Resolution: Fixed
> Supports filter predicate in Parquet format of table store
>
[
https://issues.apache.org/jira/browse/FLINK-30723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30723.
Resolution: Fixed
> Introduce filter pushdown for parquet format
>
[
https://issues.apache.org/jira/browse/FLINK-30572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30572.
Resolution: Fixed
> Make parquet as default data file format
>
[
https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31224.
Resolution: Fixed
> Add metrics for flink table store
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-26465.
Resolution: Fixed
> Optimize SortMergeReader: use loser tree to reduce comparisons
>
[
https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30857.
Resolution: Fixed
> Create table does not create topic with multiple partitions
>
[
https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706179#comment-17706179
]
Jingsong Lee commented on FLINK-30857:
--
Kafka topic should be created by users..
> Create table
[
https://issues.apache.org/jira/browse/FLINK-31039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31039.
Resolution: Fixed
> ChangelogWithKeyFileStoreTableITCase in table store is not stable
>
[
https://issues.apache.org/jira/browse/FLINK-31011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31011.
Resolution: Fixed
> upgrade hiverunner version
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-31074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31074.
Resolution: Fixed
> Introduce value filter for table store
>
[
https://issues.apache.org/jira/browse/FLINK-31013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31013.
Resolution: Fixed
> Session window aggregation cannot trigger window using event time
>
[
https://issues.apache.org/jira/browse/FLINK-30580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30580.
Resolution: Fixed
> [umbrella] Refactor tests for table store
>
[
https://issues.apache.org/jira/browse/FLINK-31129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31129.
Resolution: Fixed
> Introduce FlinkEmbeddedHiveRunner for junit5 in table store
>
[
https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30603.
Resolution: Fixed
> CompactActionITCase in table store is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-30740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30740.
Resolution: Fixed
https://github.com/apache/incubator-paimon/issues/740
> INSERT to Kafka does
[
https://issues.apache.org/jira/browse/FLINK-28661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28661.
Resolution: Fixed
> Introduce generic mode for table store catalog
>
[
https://issues.apache.org/jira/browse/FLINK-30248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30248.
Resolution: Fixed
> Spark writer supports insert overwrite
>
[
https://issues.apache.org/jira/browse/FLINK-27628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27628.
Resolution: Fixed
> Table Store records and fetches incorrect results with NaN
>
[
https://issues.apache.org/jira/browse/FLINK-29953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29953.
Resolution: Fixed
> Get rid of flink-connector-hive dependency in flink-table-store-hive
>
[
https://issues.apache.org/jira/browse/FLINK-29756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29756.
Resolution: Fixed
https://github.com/apache/incubator-paimon/issues/735
> Support materialized
[
https://issues.apache.org/jira/browse/FLINK-29490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29490.
Resolution: Fixed
> Timestamp LTZ is unsupported in table store
>
[
https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30326.
Resolution: Fixed
I close this, I think it is difficult to implement in paimon, if necessary,
[
https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30590.
Resolution: Fixed
> Remove set default value manually for table options
>
[
https://issues.apache.org/jira/browse/FLINK-30317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30317.
Resolution: Fixed
> Create table in FTS catalog with s3 warehouse throws
[
https://issues.apache.org/jira/browse/FLINK-30317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706174#comment-17706174
]
Jingsong Lee commented on FLINK-30317:
--
https://github.com/apache/incubator-paimon/issues/733
>
[
https://issues.apache.org/jira/browse/FLINK-30390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30390.
Resolution: Fixed
> Ensure that no compaction is in progress before closing the writer
>
[
https://issues.apache.org/jira/browse/FLINK-30564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30564.
Resolution: Fixed
> Select from a new table with Kafka LogStore crashes with
>
[
https://issues.apache.org/jira/browse/FLINK-30394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30394.
Resolution: Fixed
> [umbrella] Refactor filesystem support in table store
>
[
https://issues.apache.org/jira/browse/FLINK-30564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706173#comment-17706173
]
Jingsong Lee commented on FLINK-30564:
--
https://github.com/apache/incubator-paimon/issues/732
>
liuyongvs commented on PR #22277:
URL: https://github.com/apache/flink/pull/22277#issuecomment-1487759850
hi @snuyanzin @fsk119 @damumu0625 fix all your reviews, thanks very much
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
liuyongvs commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1151267746
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -287,4 +301,46 @@ Stream
liuyongvs commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1151267646
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayReverseFunction.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
mas-chen opened a new pull request, #19:
URL: https://github.com/apache/flink-connector-kafka/pull/19
…or so that checkpoints can correctly fail
This closes #22150.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
RamanVerma commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#discussion_r1151169873
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducerITCase.java:
##
@@ -81,12 +80,58 @@ void
tzulitai commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#discussion_r1151180651
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -67,6 +72,14 @@ private static
tzulitai commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#discussion_r1151177809
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -67,6 +72,14 @@ private static
tzulitai commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#discussion_r1151177809
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -67,6 +72,14 @@ private static
tzulitai commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#discussion_r1151177809
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -67,6 +72,14 @@ private static
RamanVerma commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#discussion_r1151154666
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -67,6 +72,14 @@ private static
snuyanzin commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1151097522
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -287,4 +301,46 @@ Stream
mbalassi commented on code in PR #551:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/551#discussion_r1151088576
##
docs/layouts/shortcodes/generated/kubernetes_operator_config_configuration.html:
##
@@ -236,6 +236,12 @@
Duration
The
snuyanzin commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1151088509
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayReverseFunction.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
mxm opened a new pull request, #556:
URL: https://github.com/apache/flink-kubernetes-operator/pull/556
In a prior change we set the processing rates and capacity (true processing
rate) to near zero values to allow scaling down in case of idle tasks. This has
worked well but caused issues
tzulitai commented on PR #5:
URL:
https://github.com/apache/flink-connector-kafka/pull/5#issuecomment-1487370775
Changes LGTM, +1 to @Ge's comment on extending `UpsertKafkaTableITCase`
before we merge this.
--
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 244 matches
Mail list logo
