[
https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476009#comment-17476009
]
Piotr Nowojski commented on FLINK-22643:
Thanks for the analysis! Ok, sounds goo
wuchong commented on pull request #18361:
URL: https://github.com/apache/flink/pull/18361#issuecomment-1012894487
Sure @liyubin117 , I will review it the next days.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
JingsongLi commented on a change in pull request #7:
URL: https://github.com/apache/flink-table-store/pull/7#discussion_r784634047
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Equal.java
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784635071
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java
##
@@ -113,6 +124,19 @@ public long g
JingsongLi closed pull request #8:
URL: https://github.com/apache/flink-table-store/pull/8
--
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-
[
https://issues.apache.org/jira/browse/FLINK-25630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475253#comment-17475253
]
Jingsong Lee edited comment on FLINK-25630 at 1/14/22, 8:11 AM:
--
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784638145
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java
##
@@ -50,17 +50,28 @@
class C
slinkydeveloper commented on a change in pull request #18352:
URL: https://github.com/apache/flink/pull/18352#discussion_r784638813
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunctionHelper.java
##
@@ -243,6 +244,36 @
twalthr closed pull request #18342:
URL: https://github.com/apache/flink/pull/18342
--
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-unsubsc
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784639062
##
File path: docs/content/docs/connectors/table/kinesis.md
##
@@ -255,349 +271,399 @@ Connector Options
scan.stream.initpos
o
[
https://issues.apache.org/jira/browse/FLINK-25230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25230.
Fix Version/s: 1.15.0
Resolution: Fixed
> Harden type serialization in JSON plan
>
[
https://issues.apache.org/jira/browse/FLINK-25230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476013#comment-17476013
]
Timo Walther commented on FLINK-25230:
--
commit 75992f495192b84cfe406d7e24a1188c7cb2
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784639844
##
File path: docs/content/docs/connectors/table/hbase.md
##
@@ -103,34 +105,39 @@ Connector Options
table-name
required
+
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784640093
##
File path: docs/content/docs/connectors/table/filesystem.md
##
@@ -325,33 +347,43 @@ Time extractors define extracting time from partition
val
[
https://issues.apache.org/jira/browse/FLINK-25654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-25654:
---
Assignee: Yuxin Tan
> Remove the redundant lock in SortMergeResultPartition
> -
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784640693
##
File path: docs/content/docs/connectors/table/elasticsearch.md
##
@@ -67,15 +67,17 @@ Connector Options
Option
Requir
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784642224
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java
##
@@ -204,6 +203,21 @@ public long getSt
tsreaper commented on a change in pull request #7:
URL: https://github.com/apache/flink-table-store/pull/7#discussion_r784642303
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Equal.java
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to th
twalthr closed pull request #18215:
URL: https://github.com/apache/flink/pull/18215
--
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-unsubsc
[
https://issues.apache.org/jira/browse/FLINK-25392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25392.
Fix Version/s: 1.15.0
Release Note:
It is recommended to update statement sets to the new SQL
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784645598
##
File path: docs/content/docs/connectors/table/kinesis.md
##
@@ -178,69 +184,79 @@ Connector Options
aws.credentials.provider
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784648887
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateObject.java
##
@@ -63,4 +63,14 @@
* @return Size of the state in byte
JingsongLi merged pull request #7:
URL: https://github.com/apache/flink-table-store/pull/7
--
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-
twalthr commented on a change in pull request #18352:
URL: https://github.com/apache/flink/pull/18352#discussion_r784649660
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunction.java
##
@@ -58,9 +60,13 @@
/** Ret
[
https://issues.apache.org/jira/browse/FLINK-25643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-25643.
Resolution: Fixed
master: 82af5e63f0a6aded5bdeb7e147cc58721f7154aa
> Introduce Predicate to table
twalthr commented on a change in pull request #18352:
URL: https://github.com/apache/flink/pull/18352#discussion_r784653224
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunctionHelper.java
##
@@ -243,6 +244,36 @@ public
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784653673
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
##
@@ -368
twalthr commented on pull request #18352:
URL: https://github.com/apache/flink/pull/18352#issuecomment-1012916947
@slinkydeveloper I addressed the test feedback. Please have another look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784655215
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
##
@@ -368
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-23933:
-
Parent: FLINK-25647
Issue Type: Sub-task (was: Improvement)
> flink-json formats suppor
[
https://issues.apache.org/jira/browse/FLINK-18590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-18590:
-
Parent: FLINK-25647
Issue Type: Sub-task (was: Improvement)
> Support json array explod
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784658077
##
File path:
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.html
##
@@ -45,12 +45,13 @@
>
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784658411
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskStateStats.java
##
@@ -85,6 +88,7 @@
this.subtaskIndex = su
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r784658633
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandle.java
##
@@ -38,5 +38,5 @@
* created.
*/
twalthr commented on a change in pull request #18176:
URL: https://github.com/apache/flink/pull/18176#discussion_r784660922
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemTableSinkStreamingITCase.java
##
@@ -0,0 +1,9
slinkydeveloper commented on a change in pull request #18352:
URL: https://github.com/apache/flink/pull/18352#discussion_r784660032
##
File path: docs/content/docs/dev/table/functions/udfs.md
##
@@ -240,7 +240,9 @@ An implementation class must extend from one of the
available
twalthr commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784663143
##
File path: docs/content/docs/connectors/table/elasticsearch.md
##
@@ -67,15 +67,17 @@ Connector Options
Option
Required
+
slinkydeveloper commented on a change in pull request #18176:
URL: https://github.com/apache/flink/pull/18176#discussion_r784664043
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemTableSource.java
##
@@ -272,7
tillrohrmann commented on a change in pull request #18169:
URL: https://github.com/apache/flink/pull/18169#discussion_r784661497
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java
##
@@ -684,6 +694,7 @@ public void onGetContainerStatusE
slinkydeveloper commented on a change in pull request #18176:
URL: https://github.com/apache/flink/pull/18176#discussion_r784664915
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemTableSource.java
##
@@ -272,7
slinkydeveloper commented on a change in pull request #18176:
URL: https://github.com/apache/flink/pull/18176#discussion_r784665455
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemTableSinkStreamingITCase.java
##
@@ -
twalthr commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784666001
##
File path: docs/content/docs/connectors/table/filesystem.md
##
@@ -325,33 +347,43 @@ Time extractors define extracting time from partition
values.
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784666452
##
File path: docs/content/docs/connectors/table/elasticsearch.md
##
@@ -67,15 +67,17 @@ Connector Options
Option
Requir
dawidwys commented on a change in pull request #18332:
URL: https://github.com/apache/flink/pull/18332#discussion_r784667192
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
##
@@ -1175,6 +1185,31 @@ private void terminateMiniClus
Myasuka commented on pull request #18324:
URL: https://github.com/apache/flink/pull/18324#issuecomment-1012931948
@rkhachatryan , what do you mean "How does this work after up-scaling? Will
state size be reported e.g. twice"? Checkpoint state size would only report
during taking checkpoint
[
https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-24886:
-
Assignee: jackylau
> flink flame args bug, may we need to modify TimeUtils to supports
[
https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476034#comment-17476034
]
Timo Walther commented on FLINK-21896:
--
[~soumyajitsahu] We currently don't support
[
https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476034#comment-17476034
]
Timo Walther edited comment on FLINK-21896 at 1/14/22, 9:03 AM:
--
tillrohrmann closed pull request #1:
URL: https://github.com/apache/flink/pull/1
--
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-un
mingwayXue commented on pull request #17971:
URL: https://github.com/apache/flink/pull/17971#issuecomment-101293
ok, i will try again.thks
--
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
mingwayXue closed pull request #17971:
URL: https://github.com/apache/flink/pull/17971
--
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-unsu
[
https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-24886.
-
Resolution: Fixed
Fixed via 4cd0e396514a6efd7a180a3aea106124d919ebf4
> flink flame args bug, ma
mingwayXue opened a new pull request #18362:
URL: https://github.com/apache/flink/pull/18362
## 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 commented on pull request #18362:
URL: https://github.com/apache/flink/pull/18362#issuecomment-1012941846
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 pr
dawidwys commented on pull request #18355:
URL: https://github.com/apache/flink/pull/18355#issuecomment-1012943170
LGTM from my side.
@qinjunjerry do you mind checking if something else should be documented
here?
--
This is an automated message from the Apache Git Service.
To resp
twalthr commented on a change in pull request #18352:
URL: https://github.com/apache/flink/pull/18352#discussion_r784680356
##
File path: docs/content/docs/dev/table/functions/udfs.md
##
@@ -240,7 +240,9 @@ An implementation class must extend from one of the
available base cla
Yun Gao created FLINK-25655:
---
Summary: FlinkKafkaInternalProducerITCase.testInitTransactionId
failed on azure
Key: FLINK-25655
URL: https://issues.apache.org/jira/browse/FLINK-25655
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476042#comment-17476042
]
Yun Gao commented on FLINK-25655:
-
Perhaps cc [~fpaul]
> FlinkKafkaInternalProducerITC
Myasuka commented on a change in pull request #18297:
URL: https://github.com/apache/flink/pull/18297#discussion_r784683300
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java
##
@@ -83,11 +80,7 @@ public Keyed
slinkydeveloper commented on a change in pull request #18290:
URL: https://github.com/apache/flink/pull/18290#discussion_r784700282
##
File path: docs/content/docs/connectors/table/filesystem.md
##
@@ -325,33 +347,43 @@ Time extractors define extracting time from partition
val
slinkydeveloper commented on pull request #18349:
URL: https://github.com/apache/flink/pull/18349#issuecomment-1012963542
@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
fapaul commented on a change in pull request #18257:
URL: https://github.com/apache/flink/pull/18257#discussion_r784705632
##
File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml
##
@@ -143,6 +143,12 @@ under the License.
org.apa
fapaul commented on pull request #18257:
URL: https://github.com/apache/flink/pull/18257#issuecomment-1012968641
@MartijnVisser can you also open a ticket to update it for the kinesis e2e
tests?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
fapaul merged pull request #18257:
URL: https://github.com/apache/flink/pull/18257
--
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
wenlong88 opened a new pull request #18363:
URL: https://github.com/apache/flink/pull/18363
## What is the purpose of the change
this pr is a follow up work of FLINK-25392, aims at adding support new
statement set syntax in sql client and update related docs.
## Brief change l
[
https://issues.apache.org/jira/browse/FLINK-25504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476051#comment-17476051
]
Fabian Paul commented on FLINK-25504:
-
Merged in master: 28417562dbca16ac018cceaeccb
[
https://issues.apache.org/jira/browse/FLINK-25504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul resolved FLINK-25504.
-
Resolution: Fixed
> Update and synchronise used versions of Kafka Client and Confluent Platform
fapaul commented on pull request #17937:
URL: https://github.com/apache/flink/pull/17937#issuecomment-1012970412
@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
flinkbot commented on pull request #18363:
URL: https://github.com/apache/flink/pull/18363#issuecomment-1012971326
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 pr
TanYuxin-tyx opened a new pull request #18364:
URL: https://github.com/apache/flink/pull/18364
## What is the purpose of the change
After [FLINK-2372](https://issues.apache.org/jira/browse/FLINK-2372), the
task canceler will never call the close method of ResultPartit
MonsterChenzhuo commented on a change in pull request #17994:
URL: https://github.com/apache/flink/pull/17994#discussion_r784710332
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java
#
[
https://issues.apache.org/jira/browse/FLINK-25654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25654:
---
Labels: pull-request-available (was: )
> Remove the redundant lock in SortMergeResultPartit
MonsterChenzhuo commented on a change in pull request #17994:
URL: https://github.com/apache/flink/pull/17994#discussion_r784711945
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java
#
JingGe commented on pull request #18333:
URL: https://github.com/apache/flink/pull/18333#issuecomment-1012975101
@codecholeric many thanks for your reply. I would(and also had) suggest the
first solution to use test jar in maven without any customized filter logic.
@zentol Do you have any
flinkbot commented on pull request #18364:
URL: https://github.com/apache/flink/pull/18364#issuecomment-1012976033
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 pr
flinkbot edited a comment on pull request #17711:
URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757
## CI report:
* b4e978359c87b33f8c5de84f6e0987f712335b19 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17937:
URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170
## CI report:
* Unknown: [CANCELED](TBD)
* 5bffc54d9cfaa9245563f623b76b98cf35e1ff81 UNKNOWN
Bot commands
The @flinkbot bot supports the fol
flinkbot edited a comment on pull request #18050:
URL: https://github.com/apache/flink/pull/18050#issuecomment-988466514
## CI report:
* ad7f9baa5052478388323f894dcbcf22fabd2a2b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18176:
URL: https://github.com/apache/flink/pull/18176#issuecomment-999490583
## CI report:
* a8c8f216f8d9f5ff1e0d7e34f583840dcefc6263 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18261:
URL: https://github.com/apache/flink/pull/18261#issuecomment-1004646772
## CI report:
* 34a1f33bd217d3c2e99b06a64c9ccbd1ab2d6e45 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18189:
URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224
## CI report:
* 870e758087dab73a66bd5e5a09fc736478094d3b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18297:
URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142
## CI report:
* eeb8c798bc364480d8e2b5ecf8b55c54397cef14 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18201:
URL: https://github.com/apache/flink/pull/18201#issuecomment-1000767373
## CI report:
* 0c1bfde3e87dd0c60c90df35d592da0f884ee996 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18290:
URL: https://github.com/apache/flink/pull/18290#issuecomment-1006716199
## CI report:
* 0d8e419c43838e6d85155feadee7e096e3990e0d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18349:
URL: https://github.com/apache/flink/pull/18349#issuecomment-1011991081
## CI report:
* Unknown: [CANCELED](TBD)
* 47668982c9897b1f8d8d7ffa8b10ac8a134f088c UNKNOWN
Bot commands
The @flinkbot bot supports the fo
[
https://issues.apache.org/jira/browse/FLINK-25655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476055#comment-17476055
]
Fabian Paul commented on FLINK-25655:
-
I'll take a look.
> FlinkKafkaInternalProduc
flinkbot commented on pull request #18352:
URL: https://github.com/apache/flink/pull/18352#issuecomment-1012981301
## CI report:
* aab8d5779881c1c1575c9c15e263e28fce50a215 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18353:
URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377
## CI report:
* 988fcbec1b60588c4c0cb2249a94f258145f7040 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18355:
URL: https://github.com/apache/flink/pull/18355#issuecomment-1012981476
## CI report:
* 6b89b5c2cb9734084a479e7dfcea82a3218dd3ff UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18358:
URL: https://github.com/apache/flink/pull/18358#issuecomment-1012981567
## CI report:
* f081bab4fe89823da05cbad2f0be0ebae668e310 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18360:
URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724
## CI report:
* d7927cf9b7e4205d59e788be867174141d7cd901 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18359:
URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632
## CI report:
* 111d05bc4d409c357223c238e67bcb34880a1951 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-25651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25651:
---
Labels: pull-request-available (was: )
> Flink1.14.2 DataStream Connectors Kafka Deserializ
MonsterChenzhuo commented on a change in pull request #17994:
URL: https://github.com/apache/flink/pull/17994#discussion_r784717516
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java
#
flinkbot edited a comment on pull request #17937:
URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170
## CI report:
* Unknown: [CANCELED](TBD)
* 5bffc54d9cfaa9245563f623b76b98cf35e1ff81 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620
dmvk commented on a change in pull request #18332:
URL: https://github.com/apache/flink/pull/18332#discussion_r784718698
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
##
@@ -1175,6 +1185,31 @@ private void terminateMiniClusterS
flinkbot edited a comment on pull request #17711:
URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757
## CI report:
* b4e978359c87b33f8c5de84f6e0987f712335b19 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18050:
URL: https://github.com/apache/flink/pull/18050#issuecomment-988466514
## CI report:
* ad7f9baa5052478388323f894dcbcf22fabd2a2b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18176:
URL: https://github.com/apache/flink/pull/18176#issuecomment-999490583
## CI report:
* a8c8f216f8d9f5ff1e0d7e34f583840dcefc6263 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18189:
URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224
## CI report:
* 870e758087dab73a66bd5e5a09fc736478094d3b Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
1 - 100 of 475 matches
Mail list logo