lincoln-lil commented on code in PR #21219:
URL: https://github.com/apache/flink/pull/21219#discussion_r1018704994
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkSnapshotConverter.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the
Myasuka commented on code in PR #21281:
URL: https://github.com/apache/flink/pull/21281#discussion_r1018741944
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java:
##
@@ -204,7 +204,8 @@ private void checkFailureAgainstCounter(
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631491#comment-17631491
]
Leonard Xu commented on FLINK-18356:
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631489#comment-17631489
]
Leonard Xu commented on FLINK-26644:
1.16:
MartijnVisser commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1309863752
@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
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631485#comment-17631485
]
Qingsheng Ren commented on FLINK-26974:
---
[
https://issues.apache.org/jira/browse/FLINK-29594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631483#comment-17631483
]
Qingsheng Ren commented on FLINK-29594:
---
[
https://issues.apache.org/jira/browse/FLINK-26632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631479#comment-17631479
]
Qingsheng Ren commented on FLINK-26632:
---
[
https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631464#comment-17631464
]
jiasheng55 commented on FLINK-12130:
[~gvijay452] It seems I don't have permission to assign this
gaborgsomogyi commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1309794401
@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
JasonLeeCoding commented on PR #20466:
URL: https://github.com/apache/flink/pull/20466#issuecomment-1309769676
@wuchong please help review when you are free, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29839.
-
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
> HiveServer2 endpoint
dingweiqings commented on code in PR #20755:
URL: https://github.com/apache/flink/pull/20755#discussion_r1018624588
##
flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriterTest.java:
##
@@ -82,13 +83,13 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29857.
-
Resolution: Fixed
> Fix failure to connect to 'HiveServer2Endpoint' when using hive3 beeline
>
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29857:
-
Assignee: yuzelin
> Fix failure to connect to 'HiveServer2Endpoint' when using hive3
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631430#comment-17631430
]
Shengkai Fang commented on FLINK-29857:
---
release-1.16: a74023501e3f48c6a0c61cab8b1d212b8ea83ee9
dingweiqings commented on code in PR #20755:
URL: https://github.com/apache/flink/pull/20755#discussion_r1018624229
##
flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriterTest.java:
##
@@ -70,6 +70,7 @@ public void
dingweiqings commented on code in PR #20755:
URL: https://github.com/apache/flink/pull/20755#discussion_r1018624229
##
flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriterTest.java:
##
@@ -70,6 +70,7 @@ public void
fsk119 closed pull request #21229: [FLINK-29857][hive] Fix failure to connect
to 'HiveServer2Endpoint' when using hive3 beeline
URL: https://github.com/apache/flink/pull/21229
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-29970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
钟洋洋 updated FLINK-29970:
Description:
When I use the native k8s method to deploy my flink application cluster, if I
do not manually
[
https://issues.apache.org/jira/browse/FLINK-29970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
钟洋洋 updated FLINK-29970:
Issue Type: New Feature (was: Bug)
> Prometheus cannot collect flink metrics
>
[
https://issues.apache.org/jira/browse/FLINK-29970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
钟洋洋 updated FLINK-29970:
Description:
When I use the native k8s method to deploy my flink application cluster, if I
do not manually
[
https://issues.apache.org/jira/browse/FLINK-29970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
钟洋洋 updated FLINK-29970:
Description:
When I use the native k8s method to deploy my flink application cluster, if I
do not manually
钟洋洋 created FLINK-29970:
---
Summary: Prometheus cannot collect flink metrics
Key: FLINK-29970
URL: https://issues.apache.org/jira/browse/FLINK-29970
Project: Flink
Issue Type: Bug
Components:
1996fanrui commented on PR #21281:
URL: https://github.com/apache/flink/pull/21281#issuecomment-1309709403
@Myasuka Please help take a look in your free time, thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
flinkbot commented on PR #21281:
URL: https://github.com/apache/flink/pull/21281#issuecomment-1309707084
## CI report:
* 57a945e1e31779602a525232a453a34078250341 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29969:
---
Labels: pull-request-available (was: )
> Show the root cause when exceeded checkpoint
1996fanrui opened a new pull request, #21281:
URL: https://github.com/apache/flink/pull/21281
## What is the purpose of the change
Add the root cause when exceeded checkpoint tolerable failure threshold,
it's helpful during troubleshooting.
After change:
swuferhong commented on code in PR #21219:
URL: https://github.com/apache/flink/pull/21219#discussion_r1018581030
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkSnapshotRequirementProgram.scala:
##
@@ -0,0 +1,37 @@
Rui Fan created FLINK-29969:
---
Summary: Show the root cause when exceeded checkpoint tolerable
failure threshold
Key: FLINK-29969
URL: https://issues.apache.org/jira/browse/FLINK-29969
Project: Flink
flinkbot commented on PR #21280:
URL: https://github.com/apache/flink/pull/21280#issuecomment-1309694048
## CI report:
* 2b58ef7b154406c7fae66eccdb4bad64cc7fc7d6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29966:
---
Labels: pull-request-available (was: )
> Replace and redesign the Python api documentation
HuangXingBo opened a new pull request, #21280:
URL: https://github.com/apache/flink/pull/21280
## What is the purpose of the change
*This pull request will replace and redesign the Python api documentation
base*
*I made a demo site to make it easier to review:
Caizhi Weng created FLINK-29968:
---
Summary: Update streaming query document for Table Store to
include full compaction changelog producer
Key: FLINK-29968
URL: https://issues.apache.org/jira/browse/FLINK-29968
[
https://issues.apache.org/jira/browse/FLINK-29752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29752.
---
Resolution: Fixed
master: 0bce24e7e2430430f01344c4355bae5387b91e50
> Modify Flink Table Store
tsreaper merged PR #361:
URL: https://github.com/apache/flink-table-store/pull/361
--
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:
lincoln lee created FLINK-29967:
---
Summary: Optimize determinism requirements from sink node with
considering that SinkUpsertMaterializer already supports upsertKey
Key: FLINK-29967
URL:
[
https://issues.apache.org/jira/browse/FLINK-28743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28743:
Fix Version/s: 1.17.0
> Support validating the determinism for StreamPhysicalMatchRecognize
>
Huang Xingbo created FLINK-29966:
Summary: Replace and redesign the Python api documentation base
Key: FLINK-29966
URL: https://issues.apache.org/jira/browse/FLINK-29966
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631364#comment-17631364
]
Xintong Song commented on FLINK-8712:
-
When this issue is originally reported, one major problem is
flinkbot commented on PR #21279:
URL: https://github.com/apache/flink/pull/21279#issuecomment-1309597966
## CI report:
* b1367b0848ee9a38321f7d19e77aa8dfa775133f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29853:
---
Labels: pull-request-available (was: )
> Older jackson-databind found in
jbusche opened a new pull request, #436:
URL: https://github.com/apache/flink-kubernetes-operator/pull/436
Signed-off-by: James Busche
## What is the purpose of the change
The existing version 2.13.4 of jackson-databind has a high vulnerability
(CVSS 7.5) that is fixed in
dependabot[bot] opened a new pull request, #21279:
URL: https://github.com/apache/flink/pull/21279
Bumps [socket.io-parser](https://github.com/socketio/socket.io-parser) from
4.0.4 to 4.0.5.
Release notes
Sourced from
liuzhuang2017 commented on PR #21255:
URL: https://github.com/apache/flink/pull/21255#issuecomment-1309571893
@wuchong , Sorry to bother you again, can you help me review this pr? Thank
you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
liuzhuang2017 commented on PR #21256:
URL: https://github.com/apache/flink/pull/21256#issuecomment-1309571420
@wuchong , Sorry to bother you again, can you help me review this pr? Thank
you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631342#comment-17631342
]
Yun Gao commented on FLINK-27341:
-
Hi [~chesnay] sorry for missing the comment, I also think we should
[
https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-27341:
---
Assignee: Weihua Hu
> TaskManager running together with JobManager are bind to 127.0.0.1
>
gaoyunhaii commented on code in PR #21077:
URL: https://github.com/apache/flink/pull/21077#discussion_r1018510193
##
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncRetryStrategies.scala:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-29853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631313#comment-17631313
]
James Busche commented on FLINK-29853:
--
OK, good news - 2.14.0 has GA'd and looks good. Image
MartijnVisser commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1309438932
@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
gaborgsomogyi commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1309415509
Couple of tests failed because they expect hardcoded name so rolled them
back.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631286#comment-17631286
]
Jun Qin commented on FLINK-25920:
-
Thanks [~KristoffSC] for getting back to this quickly. Let me ask,
MartijnVisser commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1309356738
@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
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277
]
Krzysztof Chmielewski edited comment on FLINK-25920 at 11/9/22 8:41 PM:
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277
]
Krzysztof Chmielewski edited comment on FLINK-25920 at 11/9/22 8:41 PM:
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277
]
Krzysztof Chmielewski edited comment on FLINK-25920 at 11/9/22 8:40 PM:
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277
]
Krzysztof Chmielewski commented on FLINK-25920:
---
[~bdine] could you share what kind of
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631274#comment-17631274
]
Jun Qin commented on FLINK-25920:
-
Our customer also facing the same problem here with 1.15.1 + aligned
gaborgsomogyi commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1309275901
@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
[
https://issues.apache.org/jira/browse/FLINK-29964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29964:
---
Labels: pull-request-available (was: )
> Support Spark/Hive with OSS
>
LadyForest opened a new pull request, #369:
URL: https://github.com/apache/flink-table-store/pull/369
Currently, we rely on Flink's plugin mechanism to initialize Filesystem,
which does not apply to other engines like Spark/Hive. This PR resolves
- Invoke `Filesystem#initialize` to
[
https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631234#comment-17631234
]
Roman Khachatryan edited comment on FLINK-29913 at 11/9/22 7:08 PM:
[
https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631234#comment-17631234
]
Roman Khachatryan commented on FLINK-29913:
---
Thanks a lot for noticing and reporting this
[
https://issues.apache.org/jira/browse/FLINK-29965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631232#comment-17631232
]
Jane Chan commented on FLINK-29965:
---
Please assign the ticket to me, thanks, cc [~lzljs3620320]
>
Jane Chan created FLINK-29965:
-
Summary: Support Spark/Hive with S3
Key: FLINK-29965
URL: https://issues.apache.org/jira/browse/FLINK-29965
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631231#comment-17631231
]
Jane Chan commented on FLINK-29964:
---
Please assign the ticket to me, thanks [~lzljs3620320]
>
Jane Chan created FLINK-29964:
-
Summary: Support Spark/Hive with OSS
Key: FLINK-29964
URL: https://issues.apache.org/jira/browse/FLINK-29964
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631227#comment-17631227
]
Jane Chan edited comment on FLINK-29963 at 11/9/22 6:57 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-29963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631227#comment-17631227
]
Jane Chan commented on FLINK-29963:
---
Hi [~lzljs3620320], I've tested oss and s3 on spark and hive,
Jane Chan created FLINK-29963:
-
Summary: Flink Table Store supports pluggable filesystem
Key: FLINK-29963
URL: https://issues.apache.org/jira/browse/FLINK-29963
Project: Flink
Issue Type:
flinkbot commented on PR #21278:
URL: https://github.com/apache/flink/pull/21278#issuecomment-1309217603
## CI report:
* 87d0282d3ac9de2ab32c88baaed83156d5dc3f49 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1309212456
Conceptually not all tests need random topics just where retry is happening.
Of course adding random in general would be better design. If you guys asking
me then later on we need
vvcephei closed pull request #21277: [FLINK-29962] Exclude jamon 2.3.1 from
dependencies
URL: https://github.com/apache/flink/pull/21277
--
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
vvcephei opened a new pull request, #21278:
URL: https://github.com/apache/flink/pull/21278
## 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
[
https://issues.apache.org/jira/browse/FLINK-29962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29962:
---
Labels: pull-request-available (was: )
> Exclude Jamon 2.3.1
> ---
>
>
vvcephei opened a new pull request, #21277:
URL: https://github.com/apache/flink/pull/21277
Working on an official AF PR as well.
--
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
flinkbot commented on PR #21276:
URL: https://github.com/apache/flink/pull/21276#issuecomment-1309203451
## CI report:
* dbdf86231424369bfb410975db04efde1587e608 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
John Roesler created FLINK-29962:
Summary: Exclude Jamon 2.3.1
Key: FLINK-29962
URL: https://issues.apache.org/jira/browse/FLINK-29962
Project: Flink
Issue Type: Improvement
gvijay452 opened a new pull request, #21276:
URL: https://github.com/apache/flink/pull/21276
## What is the purpose of the change
This change allows users to dynamically pass kerberos keytab and principal
name when submitting a flink job.
Ex: flink run -m yarn-cluster -yD
gaborgsomogyi commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1018279703
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java:
##
@@ -1238,7 +1238,7 @@ public
gaborgsomogyi commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1309176863
> I found one other timeout (but that should be the last one; all others are
already covered by your PR as far as I can see):
gaborgsomogyi commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1018270360
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java:
##
@@ -429,13 +428,12 @@ private void
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1018264629
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed
gvijay452 closed pull request #21275: [FLINK-12130][clients] : Allow dynamic
loading of kerberos keytab from client end
URL: https://github.com/apache/flink/pull/21275
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
flinkbot commented on PR #21275:
URL: https://github.com/apache/flink/pull/21275#issuecomment-1309153532
## CI report:
* 3635cbb567abc0ea8cebeaba90d8ed22f699eee8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gvijay452 opened a new pull request, #21275:
URL: https://github.com/apache/flink/pull/21275
## What is the purpose of the change
This change allows users to dynamically pass kerberos keytab and principal
name when submitting a flink job.
Ex: flink run -m yarn-cluster -yD
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-29961:
--
Description:
Make referencing custom image clearer for Docker.
- Rephrase the words how to
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-29961:
--
Priority: Minor (was: Major)
> Make referencing custom image clearer for Docker
>
liuml07 commented on PR #20935:
URL: https://github.com/apache/flink/pull/20935#issuecomment-1309120781
This was a hotfix PR but since the latest change introduces some example
code, I created a JIRA for it.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-29961:
--
Labels: pull-request-available (was: )
> Make referencing custom image clearer for Docker
>
Mingliang Liu created FLINK-29961:
-
Summary: Make referencing custom image clearer for Docker
Key: FLINK-29961
URL: https://issues.apache.org/jira/browse/FLINK-29961
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631170#comment-17631170
]
Vijayakumar Govindasamy commented on FLINK-12130:
-
[~lingyaKK] [~aljoscha]
eskabetxe commented on PR #20097:
URL: https://github.com/apache/flink/pull/20097#issuecomment-1309046982
@wanglijie95 if you need anything from me, feel free to contact via slack
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on PR #21273:
URL: https://github.com/apache/flink/pull/21273#issuecomment-1309041953
## CI report:
* 23d188c9f10bd248bda82f2fa4d029a4f658a183 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21274:
URL: https://github.com/apache/flink/pull/21274#issuecomment-1309042189
## CI report:
* 317182979bac386e334d3220d36561378d53b11d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
vahmed-hamdy opened a new pull request, #21274:
URL: https://github.com/apache/flink/pull/21274
## What is the purpose of the change
This is a bug fix, where `AsyncSinkWriter` doesn't register callback on
state restoration causing records to reside in buffer more than
vahmed-hamdy opened a new pull request, #21273:
URL: https://github.com/apache/flink/pull/21273
## What is the purpose of the change
This is a bug fix, where `AsyncSinkWriter` doesn't register callback on
state restoration causing records to reside in buffer more than
jd-hatzenbuhler commented on PR #20808:
URL: https://github.com/apache/flink/pull/20808#issuecomment-1309029922
@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
[
https://issues.apache.org/jira/browse/FLINK-29960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631150#comment-17631150
]
Danny Cranmer commented on FLINK-29960:
---
Merged commit
1 - 100 of 247 matches
Mail list logo
