[
https://issues.apache.org/jira/browse/FLINK-25554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-25554.
---
Fix Version/s: 1.16.0
1.17.0
1.15.3
Resolution:
XComp merged PR #21068:
URL: https://github.com/apache/flink/pull/21068
--
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.
XComp merged PR #21067:
URL: https://github.com/apache/flink/pull/21067
--
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.
XComp merged PR #21066:
URL: https://github.com/apache/flink/pull/21066
--
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-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619272#comment-17619272
]
Sergey Nuyanzin edited comment on FLINK-27998 at 10/18/22 6:55 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619272#comment-17619272
]
Sergey Nuyanzin commented on FLINK-27998:
-
Since it was suggested moving forward
XComp commented on PR #21067:
URL: https://github.com/apache/flink/pull/21067#issuecomment-1281896315
I'm going ahead with merging the PR since this change actually doesn't
really require a test run.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
[
https://issues.apache.org/jira/browse/FLINK-29658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29658.
Assignee: Juntao Hu
Resolution: Fixed
Merged into release-1.15 via 5e4da2cc868b28bfdadd689f2
XComp commented on PR #21067:
URL: https://github.com/apache/flink/pull/21067#issuecomment-1281895908
The other test failure is related to FLINK-15661
--
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 #21086: [FLINK-29658][python] Add LocalTime
support when converting Table to DataStream
URL: https://github.com/apache/flink/pull/21086
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-15661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-15661:
--
Attachment: FLINK-15661.extracted-logs.tar.gz
> JobManagerHAProcessFailureRecoveryITCase.testD
[
https://issues.apache.org/jira/browse/FLINK-15661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-15661:
---
I'm reopening the issue. This test caused [this build
failure|https://dev.azure.com/apache-flin
[
https://issues.apache.org/jira/browse/FLINK-15661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619270#comment-17619270
]
Matthias Pohl edited comment on FLINK-15661 at 10/18/22 6:51 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619269#comment-17619269
]
Shengkai Fang commented on FLINK-29646:
---
Thanks for the mention. Recently I work w
[
https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29648.
Resolution: Fixed
Merged into master via ef0489b5131d03112d8a4ef11962a2d1ba6a9f54
Merged into rel
[
https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619268#comment-17619268
]
Sergey Nuyanzin commented on FLINK-20873:
-
[~godfreyhe] since it was suggested
[
https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29648:
Assignee: Juntao Hu
> "LocalDateTime not supported" error when retrieving Java TypeInform
HuangXingBo closed pull request #21079: [FLINK-29648][python] Fix
"LocalDateTime not supported" error
URL: https://github.com/apache/flink/pull/21079
--
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-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29671:
--
Affects Version/s: 1.17.0
> Kubernetes e2e test fails during test initialization
> ---
XComp commented on PR #21067:
URL: https://github.com/apache/flink/pull/21067#issuecomment-1281873889
e2e test failure related to FLINK-29671
--
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 s
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29671:
--
Labels: starter test-stability (was: test-stability)
> Kubernetes e2e test fails during test
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619259#comment-17619259
]
Matthias Pohl commented on FLINK-29671:
---
This [Github community issue
#8535|https
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619256#comment-17619256
]
Yanfei Lei commented on FLINK-28758:
Hi [~renqs] , would you like to take a look? Is
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r997761529
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Description:
When I'm using the Kafka connector, and to set kafka's consumption boundary ("
setBounded ")
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619248#comment-17619248
]
Matthias Pohl edited comment on FLINK-29671 at 10/18/22 6:17 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619248#comment-17619248
]
Matthias Pohl commented on FLINK-29671:
---
I'm lowering the priority to {{Major}} be
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29671:
--
Priority: Major (was: Critical)
> Kubernetes e2e test fails during test initialization
>
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29671:
--
Description:
There are two build failures ([branch based on
release-1.16|https://dev.azure.co
[
https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29671:
--
Description:
There are two build failures ([branch based on
release-1.16|https://dev.azure.co
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-29580:
-
Assignee: Yufan Sheng
> pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't works and s
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-29580:
--
Issue Type: Improvement (was: Bug)
> pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't work
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-29580:
--
Fix Version/s: 1.17.0
> pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't works and should
tisonkun commented on code in PR #21075:
URL: https://github.com/apache/flink/pull/21075#discussion_r997746983
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java:
##
@@ -60,6 +60,8 @@ public static
syhily commented on code in PR #21075:
URL: https://github.com/apache/flink/pull/21075#discussion_r997745089
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java:
##
@@ -60,6 +60,8 @@ public static Tr
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619242#comment-17619242
]
Yufan Sheng commented on FLINK-29580:
-
OK, I think you are right.
> pulsar.consumer
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng closed FLINK-29580.
---
> pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't works and should
> be removed
> -
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng resolved FLINK-29580.
-
Resolution: Fixed
> pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't works and should
tisonkun commented on code in PR #21075:
URL: https://github.com/apache/flink/pull/21075#discussion_r997742396
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java:
##
@@ -60,6 +60,8 @@ public static
flinkbot commented on PR #21093:
URL: https://github.com/apache/flink/pull/21093#issuecomment-1281845599
## CI report:
* 4ccfa593898bfe628956eae7ea7f991f799fc039 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21092:
URL: https://github.com/apache/flink/pull/21092#issuecomment-1281845006
## CI report:
* e178958e65e6ca571a89d2395957e69897ff02f1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21091:
URL: https://github.com/apache/flink/pull/21091#issuecomment-1281844486
## CI report:
* b85a2713aa6272a16934e6d84a14b454a97c7b9d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21090:
URL: https://github.com/apache/flink/pull/21090#issuecomment-1281843997
## CI report:
* 366a8af55b68c20bc9f4c3ca51d73e4d5a611aa9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily commented on PR #21069:
URL: https://github.com/apache/flink/pull/21069#issuecomment-1281843417
The main cause of this fix is just because some bugs in Pulsar. Pulsar
always wrap single message id into a batch message id. This fix will throws
detailed exception with batch message siz
[
https://issues.apache.org/jira/browse/FLINK-28820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-28820:
-
Assignee: Yufan Sheng
> Pulsar Connector PulsarSink performance issue when delivery guarantee i
[
https://issues.apache.org/jira/browse/FLINK-28960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-28960:
-
Assignee: Yufan Sheng
> Pulsar throws java.lang.NoClassDefFoundError:
> javax/xml/bind/annotat
dependabot[bot] opened a new pull request, #21090:
URL: https://github.com/apache/flink/pull/21090
Bumps [snakeyaml](https://bitbucket.org/snakeyaml/snakeyaml) from 1.27 to
1.31.
Commits
https://bitbucket.org/snakeyaml/snakeyaml/commits/a3e641b8d6337d9916b5d709278fd668b0eb8507"
tisonkun merged PR #21072:
URL: https://github.com/apache/flink/pull/21072
--
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
[
https://issues.apache.org/jira/browse/FLINK-29433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-29433.
-
Resolution: Fixed
master via 25c429734f5beeafda482463e2b61326b7216261
> Support Auth through the builde
tisonkun merged PR #21071:
URL: https://github.com/apache/flink/pull/21071
--
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
[
https://issues.apache.org/jira/browse/FLINK-29433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-29433:
-
Assignee: Yufan Sheng
> Support Auth through the builder pattern in Pulsar connector
>
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619232#comment-17619232
]
Zili Chen commented on FLINK-29580:
---
master via 2bab5adc1a1d36d35ed971a007db9e311dc036
tisonkun merged PR #21070:
URL: https://github.com/apache/flink/pull/21070
--
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
[
https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619230#comment-17619230
]
Zili Chen commented on FLINK-29580:
---
It's OK to apply on new minor releases. But will
[
https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-29613:
-
Assignee: Yufan Sheng
> Wrong message size assertion in Pulsar's batch message
> --
XComp commented on PR #20168:
URL: https://github.com/apache/flink/pull/20168#issuecomment-1281823045
Thanks for your contribution @zhoulii. Just a minor comment about the
timeouts: Keep in mind that we actually want to remove timeouts from JUnit
tests (see [coding
guidelines](https://flin
[
https://issues.apache.org/jira/browse/FLINK-29620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619222#comment-17619222
]
liad shachoach commented on FLINK-29620:
not solved by 1.2.0, I will try to upgr
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619217#comment-17619217
]
Aitozi commented on FLINK-10929:
Nice to see a good discussion about Arrow support here.
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-28440:
---
Component/s: Runtime / Checkpointing
> EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fail
Samrat002 commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1281758305
@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.
wsry commented on PR #21083:
URL: https://github.com/apache/flink/pull/21083#issuecomment-1281753232
@reswqa Thanks for the fix. Merged.
--
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 specif
wsry merged PR #21083:
URL: https://github.com/apache/flink/pull/21083
--
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.o
lindong28 commented on PR #163:
URL: https://github.com/apache/flink-ml/pull/163#issuecomment-1281747469
Thanks for the PR. LGTM.
--
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
lindong28 merged PR #163:
URL: https://github.com/apache/flink-ml/pull/163
--
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
[
https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619204#comment-17619204
]
godfrey he commented on FLINK-27998:
Can this ticket be closed since "Upgrade Calcit
[
https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-21239.
--
Resolution: Won't Fix
This ticket can be closed since "Upgrade Calcite version to 1.32" has been
crea
[
https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-20873.
--
Resolution: Won't Fix
> Upgrade Calcite version to 1.27
> ---
>
>
zhoulii commented on PR #20168:
URL: https://github.com/apache/flink/pull/20168#issuecomment-1281741638
Thanks for reviewing, I will rebase the change and address the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619201#comment-17619201
]
godfrey he commented on FLINK-20873:
This ticket can be closed since "Upgrade Calci
zhuzhurk commented on PR #20168:
URL: https://github.com/apache/flink/pull/20168#issuecomment-1281737718
Thanks for opening this PR! @zhoulii
Now the Flink master is ready to merge changes for Flink 1.17 and we can
continue with this migration work.
Would you rebase the change to the
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Summary: Apache Kafka Connector‘s “ setBounded” not valid (was: Apache
Kafka 连接器的“ setBounded”不生效)
> Apa
LadyForest commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1281732704
@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-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangwei updated FLINK-29674:
-
Description:
When I'm using the official Apache Kafka connector, I see that the official
means to set k
klion26 commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r997655058
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
klion26 commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r997655058
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
zoltar9264 commented on PR #20965:
URL: https://github.com/apache/flink/pull/20965#issuecomment-1281721537
Hi @Myasuka , can you help me merge 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
zoltar9264 commented on PR #20975:
URL: https://github.com/apache/flink/pull/20975#issuecomment-1281721579
Hi @Myasuka , can you help me merge 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
[
https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-26668.
--
Resolution: Invalid
> Unsupportedoperation exception caused by createActualEdge error in adaptive
> b
[
https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619187#comment-17619187
]
Lijie Wang commented on FLINK-26668:
This issue was caused by applying a deprecated
[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619188#comment-17619188
]
luoyuxia commented on FLINK-29653:
--
cc [~fsk119]
> close DynamicResult but it was alr
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangwei updated FLINK-29674:
-
Description:
我在使用官方提供的Apache Kafka
连接器时，我看到官方有提供设置kafka的消费边界的方法（setBounded），当我的job正常执行时（无故障），我设置的边界是有效的
jiangwei created FLINK-29674:
Summary: Apache Kafka 连接器的“ setBounded”不生效
Key: FLINK-29674
URL: https://issues.apache.org/jira/browse/FLINK-29674
Project: Flink
Issue Type: Bug
Component
[
https://issues.apache.org/jira/browse/FLINK-29657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619186#comment-17619186
]
luoyuxia commented on FLINK-29657:
--
I see. The most Hive sql statements in Hive 1.2 sh
flinkbot commented on PR #21089:
URL: https://github.com/apache/flink/pull/21089#issuecomment-1281702271
## CI report:
* 68f62b647fe793d1a54eb40d3cc6062c3cd85d36 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619183#comment-17619183
]
Sriram Ganesh commented on FLINK-29644:
---
Please check the PR. https://github.com/a
[
https://issues.apache.org/jira/browse/FLINK-29644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29644:
---
Labels: pull-request-available starter (was: starter)
> Reference Kubernetes operator from
rgsriram opened a new pull request, #21089:
URL: https://github.com/apache/flink/pull/21089
## What is the purpose of the change
*Flink docs don't have any documentation link related to Flink Kubernetes
operator. This change lets us see the Flink Kubernetes operator and how to use
it
[
https://issues.apache.org/jira/browse/FLINK-29673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619181#comment-17619181
]
waywtdcc commented on FLINK-29673:
--
please assign this to me.
> Support sqlserver cata
waywtdcc created FLINK-29673:
Summary: Support sqlserver catalog
Key: FLINK-29673
URL: https://issues.apache.org/jira/browse/FLINK-29673
Project: Flink
Issue Type: Improvement
Component
[
https://issues.apache.org/jira/browse/FLINK-29652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619179#comment-17619179
]
luoyuxia commented on FLINK-29652:
--
Thanks for the explanation.
[~fsk119] Could you pl
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619177#comment-17619177
]
waywtdcc commented on FLINK-28985:
--
Please assign this to me.
> support create table l
[
https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619176#comment-17619176
]
waywtdcc commented on FLINK-29672:
--
please assign this to me
> Support oracle catalog
[
https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-29672:
-
Fix Version/s: (was: 1.16.1)
> Support oracle catalog
> ---
>
>
waywtdcc created FLINK-29672:
Summary: Support oracle catalog
Key: FLINK-29672
URL: https://issues.apache.org/jira/browse/FLINK-29672
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-29672:
-
Fix Version/s: 1.16.1
> Support oracle catalog
> ---
>
> Key: FLINK
lindong28 commented on code in PR #163:
URL: https://github.com/apache/flink-ml/pull/163#discussion_r997598885
##
flink-ml-python/pyflink/ml/core/wrapper.py:
##
@@ -22,16 +22,15 @@
from pyflink.common import typeinfo, Time
from pyflink.common.typeinfo import _from_java_type, T
nirtsruya commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r997544803
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Li
kristoffSC commented on code in PR #21052:
URL: https://github.com/apache/flink/pull/21052#discussion_r997537278
##
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/CheckpointCountingSource.java:
##
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the
nirtsruya commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r997534733
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Li
kristoffSC commented on code in PR #21052:
URL: https://github.com/apache/flink/pull/21052#discussion_r997534738
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/TestSink.java:
##
@@ -397,6 +400,54 @@ public void endOfInput() {
}
1 - 100 of 252 matches
Mail list logo
