martin-g commented on code in PR #20498:
URL: https://github.com/apache/flink/pull/20498#discussion_r990945324
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/KubernetesJobManagerSpecification.java:
##
@@ -30,10 +30,15 @@ public class KubernetesJobManage
martin-g commented on code in PR #20467:
URL: https://github.com/apache/flink/pull/20467#discussion_r990934450
##
docs/layouts/shortcodes/generated/kubernetes_config_configuration.html:
##
@@ -206,6 +212,12 @@
Enum
The exposed type of the rest service.
[
https://issues.apache.org/jira/browse/FLINK-29544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29544:
--
Assignee: ConradJam
> Update Flink doc
>
>
> Key: FLINK-2954
[
https://issues.apache.org/jira/browse/FLINK-29543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29543:
--
Assignee: ConradJam
> Jar Run Rest Handler Support Flink Configuration
>
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29557:
---
Description:
In the {{SimpleOperatorFactory#of}}, only {{StreamSink}} is handled to register
as {{SimpleOut
HuangXingBo commented on PR #20902:
URL: https://github.com/apache/flink/pull/20902#issuecomment-1272780005
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29557:
---
Description:
In the {{SimpleOperatorFactory#of}}, only {{StreamSink}} is handled to register
as {{SimpleOut
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29557:
---
Description:
In the {{SimpleOperatorFactory#of}}, only {{StreamSink}} is handled to register
as {{SimpleOut
JingsongLi commented on code in PR #312:
URL: https://github.com/apache/flink-table-store/pull/312#discussion_r990905569
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/FullChangelogMergeFunctionWrapper.java:
##
@@ -0,0 +1,183 @@
+/*
+
Aitozi created FLINK-29557:
--
Summary: The SinkOperator's OutputFormat function is not recognized
Key: FLINK-29557
URL: https://issues.apache.org/jira/browse/FLINK-29557
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614859#comment-17614859
]
Xingbo Huang commented on FLINK-28766:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-27591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614858#comment-17614858
]
Yunhong Zheng commented on FLINK-27591:
---
Hi, [~godfreyhe] , I would like to get th
zjureel commented on PR #313:
URL:
https://github.com/apache/flink-table-store/pull/313#issuecomment-1272741579
Hi @JingsongLi I tried to fix
[FLINK-27958](https://issues.apache.org/jira/browse/FLINK-27958) and the main
changes are described as above. Can you help to review the implementa
[
https://issues.apache.org/jira/browse/FLINK-27958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27958:
---
Labels: pull-request-available (was: )
> Compare batch maxKey to reduce comparisons in Sort
hehuiyuan commented on PR #20995:
URL: https://github.com/apache/flink/pull/20995#issuecomment-1272740132
@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 commen
zjureel opened a new pull request, #313:
URL: https://github.com/apache/flink-table-store/pull/313
Currently the `SortMergeReader` will compare and sort the readers after
reading one batch from them to ensure that the sequence is correct. The readers
are created from `SortedRun` list and th
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614854#comment-17614854
]
Xingbo Huang commented on FLINK-29427:
--
https://dev.azure.com/apache-flink/apache-f
gaaraG closed pull request #20625: [FLINK-29040]When using the JDBC Catalog,
the custom cannot be applie…
URL: https://github.com/apache/flink/pull/20625
--
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
HuangXingBo closed pull request #20928: [FLINK-29477][python] Fix
ClassCastException when collecting primitive array
URL: https://github.com/apache/flink/pull/20928
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
flinkbot commented on PR #21000:
URL: https://github.com/apache/flink/pull/21000#issuecomment-1272722772
## CI report:
* d833f0c507a094720c0fee83d7f406294f0302d4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
cun8cun8 opened a new pull request, #21000:
URL: https://github.com/apache/flink/pull/21000
## 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 o
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990880285
##
docs/content/docs/operators/feature/vectorassembler.md:
##
@@ -44,11 +46,12 @@ Types of input columns must be either vector or numerical
value.
### Parameters
cun8cun8 closed pull request #20947: [FLINK-29353]Support UNIX_TIMESTAMP
built-in function in Table API
URL: https://github.com/apache/flink/pull/20947
--
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 t
tsreaper opened a new pull request, #312:
URL: https://github.com/apache/flink-table-store/pull/312
We need to introduce a special `MergeFunction` to produce changelogs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-29293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29293:
---
Assignee: Caizhi Weng
> Introduce a MergeFunction for full compaction
> ---
[
https://issues.apache.org/jira/browse/FLINK-29297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29297.
---
> Group Table Store file writers into SingleFileWriter and RollingFileWriter
> -
tsreaper merged PR #310:
URL: https://github.com/apache/flink-table-store/pull/310
--
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...@fl
zhipeng93 merged PR #161:
URL: https://github.com/apache/flink-ml/pull/161
--
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.apac
zhipeng93 commented on PR #161:
URL: https://github.com/apache/flink-ml/pull/161#issuecomment-1272706717
Thanks for the update. Merging
--
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 specifi
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/10/22 2:01 AM:
-
yunfengzhou-hub commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990872536
##
docs/content/docs/operators/feature/vectorassembler.md:
##
@@ -156,12 +160,13 @@ input_data_table = t_env.from_data_stream(
[DenseVectorTypeInfo()
klion26 commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990876505
##
_config.yml:
##
@@ -73,6 +73,22 @@ FLINK_TABLE_STORE_GITHUB_REPO_NAME: flink-table-store
# md1_url:
https://repo.maven.apache.org/maven2/org/apache/flink/f
flinkbot commented on PR #20999:
URL: https://github.com/apache/flink/pull/20999#issuecomment-1272697175
## CI report:
* cfe704b280ba4978c70a6f7df1a192c5d04d0b8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29408:
---
Labels: pull-request-available test-stability (was: test-stability)
> HiveCatalogITCase fai
luoyuxia opened a new pull request, #20999:
URL: https://github.com/apache/flink/pull/20999
## 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 o
RocMarshal commented on PR #20989:
URL: https://github.com/apache/flink/pull/20989#issuecomment-1272681554
@gaoyunhaii Could you help to check it ? thx~
--
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
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: screenshot-1.png
> Flink Sql: implicit type conversion between BIGINT and VARCHAR(2147483647) is
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val tabl
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
snuyanzin commented on PR #20410:
URL: https://github.com/apache/flink/pull/20410#issuecomment-1272641859
rebased to solve conflicts
--
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 c
MartijnVisser commented on PR #20980:
URL: https://github.com/apache/flink/pull/20980#issuecomment-1272613196
@syhily Thanks, I've made the changes. Please check again, I'll wait for CI
to pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please
MartijnVisser commented on PR #20170:
URL: https://github.com/apache/flink/pull/20170#issuecomment-1272611849
@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 comm
MartijnVisser commented on PR #20994:
URL: https://github.com/apache/flink/pull/20994#issuecomment-1272611408
Does this really make sense for the filesource? I can envision that having a
scanned index access for a filesystem isn't exactly the most resource or
solution friendly solution.
MartijnVisser commented on code in PR #20997:
URL: https://github.com/apache/flink/pull/20997#discussion_r990828362
##
flink-connectors/flink-sql-connector-hive-2.3.9/pom.xml:
##
@@ -48,7 +45,7 @@ under the License.
org.apache.hive
darenwkt opened a new pull request, #8:
URL: https://github.com/apache/flink-connector-dynamodb/pull/8
Added license check as maven plugin to be used in ci workflow for license
check.
Added Download Flink Binary to ci workflow to use flink-ci-tools package.
--
This is an automa
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
[样式|https://issues.apache.org/jira/projects/FLINK/issues/FLINK-29556?filter=allopenissues#]Zepp
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Environment: Flink 1.13.6, Apache Zeppelin, Mysql
> Flink Sql: implicit type conversion between BIGINT and V
flinkbot commented on PR #20998:
URL: https://github.com/apache/flink/pull/20998#issuecomment-1272582996
## CI report:
* e0846a7213873e458e898e710d53f4519d97b27f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary view first：
%flink
val table = btenv.sqlQu
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: image-2022-10-10-00-47-58-672.png
image-2022-10-10-00-47-38-627.png
Descrip
[
https://issues.apache.org/jira/browse/FLINK-29497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29497:
---
Labels: pull-request-available (was: )
> Provide an option to publish the flink-dist jar fi
tweise opened a new pull request, #20998:
URL: https://github.com/apache/flink/pull/20998
## What is the purpose of the change
Adds a maven property to control publishing of the flink-dist jar. By
default the jar file isn't published, retaining the existing behavior.
Publishing can b
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin 中脚本如下
首先创建一些临时表：
%flink
val table = btenv.sqlQuery("""
select a.agentcode,b.upage
[ https://issues.apache.org/jira/browse/FLINK-29556 ]
Luochg deleted comment on FLINK-29556:
was (Author: JIRAUSER296715):
*table b_186_P2:*
!image-2022-10-10-00-42-29-986.png!
*table b_186_P2_1:*
!image-2022-10-10-00-41-18-313.png!
*Error In
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin 中脚本如下
首先创建一些临时表：
%flink
val table = btenv.sqlQuery("""
select a.agentcode,b.upage
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614744#comment-17614744
]
Luochg edited comment on FLINK-29556 at 10/9/22 4:42 PM:
-
*table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: image-2022-10-10-00-40-03-422.png
> Flink Sql: implicit type conversion between BIGINT and VARCH
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614744#comment-17614744
]
Luochg commented on FLINK-29556:
!image-2022-10-10-00-40-03-422.png!
> Flink Sql: impli
[
https://issues.apache.org/jira/browse/FLINK-29497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614743#comment-17614743
]
Thomas Weise commented on FLINK-29497:
--
Hi [~chesnay] , at the moment we are using
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: Flink Sql: implicit type conversion between BIGINT and
VARCHAR(2147483647) is not supported on join
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: implicit type conversion between BIGINT and VARCHAR(2147483647) is
not supported on join's conditio
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: flink sql 执行过程报implicit type conversion between BIGINT and
VARCHAR(2147483647) is not supported on
Luochg created FLINK-29556:
--
Summary: flink sql 执行过程报java.lang.NullPointerException异常
Key: FLINK-29556
URL: https://issues.apache.org/jira/browse/FLINK-29556
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-27479.
--
Resolution: Fixed
> HybridSource refreshes availability future
> -
[
https://issues.apache.org/jira/browse/FLINK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27479:
-
Fix Version/s: (was: 1.15.3)
> HybridSource refreshes availability future
>
tweise merged PR #20215:
URL: https://github.com/apache/flink/pull/20215
--
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-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28979:
---
Fix Version/s: kubernetes-operator-1.3.0
> Add another owner into the JM deployment's owner referenc
[
https://issues.apache.org/jira/browse/FLINK-29507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29507.
--
Resolution: Fixed
merged to main 39a275f4f4c306061d37991644f81e4625737e93
> Make e2e tests independen
[
https://issues.apache.org/jira/browse/FLINK-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28979.
--
Resolution: Fixed
merged to main 62eb68c812713378f7f66fde01cf14370a2252e4
> Add another owner into th
[
https://issues.apache.org/jira/browse/FLINK-29507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29507:
---
Labels: pull-request-available (was: )
> Make e2e tests independent of the current director
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614724#comment-17614724
]
Eugene Koblov commented on FLINK-27344:
---
Paul, do you have more details on exact s
gyfora merged PR #393:
URL: https://github.com/apache/flink-kubernetes-operator/pull/393
--
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
gyfora merged PR #377:
URL: https://github.com/apache/flink-kubernetes-operator/pull/377
--
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
flinkbot commented on PR #20997:
URL: https://github.com/apache/flink/pull/20997#issuecomment-1272559812
## CI report:
* ab8ea0b88dcaf06f8249d20945c7f57b904c5c78 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990798648
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date: 2022-10-
gyfora commented on code in PR #394:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r990795976
##
docs/content/docs/custom-resource/reference.md:
##
@@ -251,6 +261,7 @@ This page serves as a full reference for FlinkDeployment
custom resource defin
godfreyhe commented on PR #574:
URL: https://github.com/apache/flink-web/pull/574#issuecomment-1272547331
> Some nits on links
Thanks for the review~
--
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
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990791541
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date: 2022-10-
flinkbot commented on PR #20996:
URL: https://github.com/apache/flink/pull/20996#issuecomment-1272523220
## CI report:
* 45246b4fa4b05a55cbff2c29a0233ab9790b4780 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29551:
---
Labels: pull-request-available (was: )
> Improving adaptive hash join by using sort merge j
lsyldliu opened a new pull request, #20996:
URL: https://github.com/apache/flink/pull/20996
## What is the purpose of the change
Improving adaptive hash join by using sort-merge join strategy per partition
instead of all partitions
## Brief change log
- *Improving
[
https://issues.apache.org/jira/browse/FLINK-29555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liwei li updated FLINK-29555:
-
Description:
env:
Flink 1.14.3
{code:java}
EnvironmentSettings.Builder settingsBuilder = Environment
liwei li created FLINK-29555:
Summary: GlobalStreamingCommitterHandler not call
notifyCheckpointCompleted after endOfInput
Key: FLINK-29555
URL: https://issues.apache.org/jira/browse/FLINK-29555
Project:
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614698#comment-17614698
]
xiaogang zhou commented on FLINK-29545:
---
I tried to get some info when block happ
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1272509188
@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-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:27 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:22 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:11 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou commented on FLINK-29545:
---
1， yes, I have debug this task to many ti
[
https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29554:
---
Labels: pull-request-available (was: )
> Add partial-update.ignore-delete option to avoid e
1 - 100 of 123 matches
Mail list logo
