shuiqiangchen commented on PR #19958:
URL: https://github.com/apache/flink/pull/19958#issuecomment-1157258316
@dianfu Thanks, I will refer to those commits in the ticket you mentioned.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1157248524
@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-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Description:
The meta.name of FlinkDeployment CR meta.name must be match the regex:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Description:
The meta.name of FlinkDeployment CR meta.name must be match the regex:
{{}}
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Summary: Add validation for the meta.name of FlinkDeployment CR (was: Add
validation for meta.name of
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28087:
---
Labels: pull-request-available (was: )
> Add validation for meta.name of FlinkDeployment
Grypse opened a new pull request, #270:
URL: https://github.com/apache/flink-kubernetes-operator/pull/270
The meta.name of FlinkDeployment CR meta.name must be match the regex:
` '[a-z]([-a-z0-9]*[a-z0-9])?'`
By RRC-1035, a DNS-1035 label must consist of lower case alphanumeric
dianfu commented on code in PR #19295:
URL: https://github.com/apache/flink/pull/19295#discussion_r898692689
##
docs/content/docs/libs/cep.md:
##
@@ -718,6 +718,35 @@ next.within(Time.seconds(10))
{{< /tab >}}
{{< /tabs >}}
+Notice that A pattern sequence can end in
dianfu commented on code in PR #19295:
URL: https://github.com/apache/flink/pull/19295#discussion_r898652853
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java:
##
@@ -157,11 +157,8 @@ public static boolean canProduceEmptyMatches(final
liuzhuang2017 commented on PR #19966:
URL: https://github.com/apache/flink/pull/19966#issuecomment-1157228755
@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
luoyuxia commented on code in PR #19851:
URL: https://github.com/apache/flink/pull/19851#discussion_r898680314
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala:
##
@@ -351,9 +351,11 @@ object
luoyuxia commented on code in PR #19851:
URL: https://github.com/apache/flink/pull/19851#discussion_r898680313
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala:
##
@@ -351,9 +351,11 @@ object
luoyuxia commented on code in PR #19851:
URL: https://github.com/apache/flink/pull/19851#discussion_r898679763
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/utils/ScalarOperatorsTestBase.scala:
##
@@ -67,8 +67,8 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Description:
The FlinkDeployment CR meta.name must be match the regex:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-27953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554894#comment-17554894
]
zoucao edited comment on FLINK-27953 at 6/16/22 3:57 AM:
-
Hi [~godfreyhe], could
[
https://issues.apache.org/jira/browse/FLINK-27953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554894#comment-17554894
]
zoucao commented on FLINK-27953:
Hi [~godfrey], could you have time to take a look?
> using the
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Summary: Add validation for meta.name of FlinkDeployment CR (was:
FlinkDeployment meta.name validation)
>
lincoln-lil commented on PR #19942:
URL: https://github.com/apache/flink/pull/19942#issuecomment-1157199426
@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-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Summary: FlinkDeployment meta.name validation (was: FlinkDeployment name
validation)
> FlinkDeployment
[
https://issues.apache.org/jira/browse/FLINK-27987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-27987:
--
Assignee: godfrey he (was: Yunhong Zheng)
> Let FileSystemTableSource extend from
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Description:
The FlinkDeployment CR meta.name must be match the regex:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-28074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-28074:
---
Description: Currently, DESCRIBE command only show the schema of a given
table, EXTENDED does not
[
https://issues.apache.org/jira/browse/FLINK-28087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fred k updated FLINK-28087:
---
Attachment: operator-flink.jpg
> FlinkDeployment name validation
> ---
>
>
Fred k created FLINK-28087:
--
Summary: FlinkDeployment name validation
Key: FLINK-28087
URL: https://issues.apache.org/jira/browse/FLINK-28087
Project: Flink
Issue Type: Improvement
flinkbot commented on PR #19984:
URL: https://github.com/apache/flink/pull/19984#issuecomment-1157186972
## CI report:
* 6726e9d27b74ebe57e9e986ebc4a8fe8a3afc628 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhoulii opened a new pull request, #19984:
URL: https://github.com/apache/flink/pull/19984
## What is the purpose of the change
- test the serialized object in
GlobFilePathFilterTest#testGlobFilterSerializable
- Rework GlobFilePathFilterTest to be based on AssertJ
##
gaoyunhaii commented on PR #545:
URL: https://github.com/apache/flink-web/pull/545#issuecomment-1157179944
Thanks @zhuzhurk @wanglijie95 for the review! I have updated the blogs
according to the comments and also rewrite some part.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-25655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554883#comment-17554883
]
lincoln lee commented on FLINK-25655:
-
Any new progress here? I encountered two in a row, recent
gaoyunhaii commented on PR #546:
URL: https://github.com/apache/flink-web/pull/546#issuecomment-1157174790
Thanks @wanglijie95 for the update! 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
Jingsong Lee created FLINK-28086:
Summary: Table Store Catalog supports partition methods
Key: FLINK-28086
URL: https://issues.apache.org/jira/browse/FLINK-28086
Project: Flink
Issue Type:
imaffe commented on code in PR #19973:
URL: https://github.com/apache/flink/pull/19973#discussion_r898643192
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -369,6 +373,18 @@ public
flinkbot commented on PR #19983:
URL: https://github.com/apache/flink/pull/19983#issuecomment-1157166737
## CI report:
* 7cac33be1271b73b8f28069ee17db53a790bef29 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
imaffe commented on PR #19974:
URL: https://github.com/apache/flink/pull/19974#issuecomment-1157166125
I'm not very familiar with the object-reuse deserialization schema here.
Could you describe briefly why we introduce this change ?
--
This is an automated message from the Apache Git
godfreyhe commented on PR #19939:
URL: https://github.com/apache/flink/pull/19939#issuecomment-1157166185
Thanks for the review, I will merge it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27878:
---
Labels: pull-request-available (was: )
> Add Retry Support For Async I/O In DataStream API
lincoln-lil opened a new pull request, #19983:
URL: https://github.com/apache/flink/pull/19983
## What is the purpose of the change
This is the implementation of
[FLIP-232](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211883963)
## Brief change log
* add new
imaffe commented on PR #19977:
URL: https://github.com/apache/flink/pull/19977#issuecomment-1157163612
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 comment.
To unsubscribe,
imaffe commented on PR #19978:
URL: https://github.com/apache/flink/pull/19978#issuecomment-1157163110
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 comment.
To unsubscribe,
flinkbot commented on PR #19982:
URL: https://github.com/apache/flink/pull/19982#issuecomment-1157162626
## CI report:
* 698c594f054ff7ef72dc5982dc71e7fcd2d6d359 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Aitozi commented on PR #19840:
URL: https://github.com/apache/flink/pull/19840#issuecomment-1157161267
@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.
Aitozi commented on PR #19840:
URL: https://github.com/apache/flink/pull/19840#issuecomment-1157161191
The failed test with unfinished test case
`org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase.runCheckpointedProgram`
can finish locally
--
This is an automated message
flinkbot commented on PR #19981:
URL: https://github.com/apache/flink/pull/19981#issuecomment-1157160602
## CI report:
* 7544a90ee0babb2b5b087d4cab91b4f6442b968b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19980:
URL: https://github.com/apache/flink/pull/19980#issuecomment-1157160564
## CI report:
* 6e88bc91064cdec9d581add9928c3d9f05e835af UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
PatrickRen opened a new pull request, #19982:
URL: https://github.com/apache/flink/pull/19982
Unchanged back port of #19828 on release-1.14
--
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
imaffe commented on code in PR #19976:
URL: https://github.com/apache/flink/pull/19976#discussion_r898633161
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtils.java:
##
@@ -30,13 +31,35 @@
import
PatrickRen opened a new pull request, #19981:
URL: https://github.com/apache/flink/pull/19981
Unchanged back port of #19828 on release-1.15
--
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
PatrickRen opened a new pull request, #19980:
URL: https://github.com/apache/flink/pull/19980
Unchanged back port of #19456 on release-1.15
--
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
flinkbot commented on PR #19979:
URL: https://github.com/apache/flink/pull/19979#issuecomment-1157156391
## CI report:
* 79f25b1182a1f059b30603b78e95f9ce47c4f61b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
imaffe commented on code in PR #19099:
URL: https://github.com/apache/flink/pull/19099#discussion_r898626758
##
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/PulsarTestContext.java:
##
@@ -19,44 +19,61 @@
package
PatrickRen opened a new pull request, #19979:
URL: https://github.com/apache/flink/pull/19979
Unchanged back port of #19456 on release-1.14
--
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
[
https://issues.apache.org/jira/browse/FLINK-28077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554862#comment-17554862
]
fanrui commented on FLINK-28077:
Hi [~mapohl] [~chesnay] , thanks for this information, I will take a
tsreaper commented on code in PR #158:
URL: https://github.com/apache/flink-table-store/pull/158#discussion_r898626398
##
flink-table-store-hive/src/main/java/org/apache/flink/table/store/hive/HiveSchema.java:
##
@@ -73,11 +90,134 @@ public static HiveSchema extract(Properties
tsreaper commented on code in PR #158:
URL: https://github.com/apache/flink-table-store/pull/158#discussion_r898626041
##
flink-table-store-hive/src/main/java/org/apache/flink/table/store/hive/HiveSchema.java:
##
@@ -18,50 +18,67 @@
package org.apache.flink.table.store.hive;
deadwind4 commented on code in PR #19777:
URL: https://github.com/apache/flink/pull/19777#discussion_r898621744
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -107,7 +107,7 @@
*
deadwind4 commented on code in PR #19777:
URL: https://github.com/apache/flink/pull/19777#discussion_r898621580
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -107,7 +107,7 @@
*
liujiawinds commented on PR #19965:
URL: https://github.com/apache/flink/pull/19965#issuecomment-1157128850
@JingsongLi Could you review this pr?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
yunfengzhou-hub commented on PR #109:
URL: https://github.com/apache/flink-ml/pull/109#issuecomment-1157125976
Got it. From the information provided in
[FLINK-27454](https://issues.apache.org/jira/browse/FLINK-27454) it seems that
AbstractTestBase would still extend TestBaseUtils until
flinkbot commented on PR #19978:
URL: https://github.com/apache/flink/pull/19978#issuecomment-1157016182
## CI report:
* a0384dee5b76b645ec0947dd208ce027cbce9717 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554812#comment-17554812
]
Yufan Sheng edited comment on FLINK-27736 at 6/15/22 10:33 PM:
---
Tks for
[
https://issues.apache.org/jira/browse/FLINK-27736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554812#comment-17554812
]
Yufan Sheng commented on FLINK-27736:
-
Tks for your report This is a known bug and fixed in
[
https://issues.apache.org/jira/browse/FLINK-27881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27881:
---
Labels: pull-request-available (was: )
> The key(String) in PulsarMessageBuilder returns
syhily opened a new pull request, #19978:
URL: https://github.com/apache/flink/pull/19978
## What is the purpose of the change
The PulsarMessageBuild.key(String) always return null, which cause NPE.
## Brief change log
`return this` instead of `return null`
##
[
https://issues.apache.org/jira/browse/FLINK-27881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554811#comment-17554811
]
Yufan Sheng commented on FLINK-27881:
-
I'll submit a PR today. This is a known bug.
> The
Yufan Sheng created FLINK-28085:
---
Summary: Close all the pending Pulsar transactions when flink
shutdown the pipeline.
Key: FLINK-28085
URL: https://issues.apache.org/jira/browse/FLINK-28085
Project:
flinkbot commented on PR #19977:
URL: https://github.com/apache/flink/pull/19977#issuecomment-1156981879
## CI report:
* 9756d018cd49ff6b7f3f6f1a46e5dd1b6cc4aaa4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28084:
---
Labels: pull-request-available (was: )
> Pulsar unordered reader should disable retry and
syhily opened a new pull request, #19977:
URL: https://github.com/apache/flink/pull/19977
## What is the purpose of the change
Pulsar unordered reader is used for Shared and Key_Shared subscriptions. It
would reconsume a message if it didn't acknowledge in a transaction. But this
[
https://issues.apache.org/jira/browse/FLINK-28084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-28084:
Description: UnroderdPulsarSourceReader currently calls reconsume, but this
feature relys on
[
https://issues.apache.org/jira/browse/FLINK-27400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-27400:
Description: UnroderdPulsarSourceReader currently calls reconsume, but this
feature relys on
[
https://issues.apache.org/jira/browse/FLINK-27400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-27400:
Description: Pulsar has a lot of internal topics which is used for
metadata. It couldn't be
Yufan Sheng created FLINK-28084:
---
Summary: Pulsar unordered reader should disable retry and delete
reconsume logic.
Key: FLINK-28084
URL: https://issues.apache.org/jira/browse/FLINK-28084
Project:
flinkbot commented on PR #19976:
URL: https://github.com/apache/flink/pull/19976#issuecomment-1156917077
## CI report:
* 67a21b87b36684c7dd551e29e77663be2487075e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27400:
---
Labels: pull-request-available (was: )
> Pulsar connector subscribed the system topic when
syhily opened a new pull request, #19976:
URL: https://github.com/apache/flink/pull/19976
## What is the purpose of the change
The current Pulsar connector would subscribe the Pulsar internal system
topics, which is not allowed.
## Brief change log
Add a method for
flinkbot commented on PR #19975:
URL: https://github.com/apache/flink/pull/19975#issuecomment-1156883644
## CI report:
* d11c0d8f91702f7c7d83819edd30916aed2940ec UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27611:
---
Labels: pull-request-available (was: )
> ConcurrentModificationException during
syhily opened a new pull request, #19975:
URL: https://github.com/apache/flink/pull/19975
## What is the purpose of the change
Pulsar entered a ConcurrentModificationException because I don't property
used the Iterator. This PR fixes this issue.
## Brief change log
flinkbot commented on PR #19974:
URL: https://github.com/apache/flink/pull/19974#issuecomment-1156861952
## CI report:
* 2dc70b01fc3387cab385936f03069075471aecac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28083:
---
Labels: pull-request-available (was: )
> PulsarSource cannot work with object-reusing
syhily opened a new pull request, #19974:
URL: https://github.com/apache/flink/pull/19974
## What is the purpose of the change
This pull request moves record deserializing in PulsarSource from
SplitFetcher to RecordEmitter to support object-reusing deserializer.
## Brief
Yufan Sheng created FLINK-28083:
---
Summary: PulsarSource cannot work with object-reusing
DeserializationSchema.
Key: FLINK-28083
URL: https://issues.apache.org/jira/browse/FLINK-28083
Project: Flink
flinkbot commented on PR #19973:
URL: https://github.com/apache/flink/pull/19973#issuecomment-1156816241
## CI report:
* f2c2ed2a6537a36091a3c0da129537a523b08d16 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28082:
---
Labels: pull-request-available (was: )
> Support end to end encryption on Pulsar
syhily opened a new pull request, #19973:
URL: https://github.com/apache/flink/pull/19973
## What is the purpose of the change
Add the end-to-end encryption support for Pulsar.
## Brief change log
Add the CryptoKeyReader for both Pulsar source and sink. Add encryption
Yufan Sheng created FLINK-28082:
---
Summary: Support end to end encryption on Pulsar connector.
Key: FLINK-28082
URL: https://issues.apache.org/jira/browse/FLINK-28082
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554703#comment-17554703
]
Jing Ge commented on FLINK-28043:
-
Just want to let you know that I will find time to do it this week.
syhily commented on PR #19473:
URL: https://github.com/apache/flink/pull/19473#issuecomment-1156706620
@fapaul This is PR ready, I think.
--
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
[
https://issues.apache.org/jira/browse/FLINK-27790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-27790:
--
Summary: Port ADD JAR /SHOW JARS syntax implementation from SqlClient to
TableEnvironment side (was:
flinkbot commented on PR #19972:
URL: https://github.com/apache/flink/pull/19972#issuecomment-1156690944
## CI report:
* da9be03ef90e2e12873a3ef5c72996f2fa8fa964 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily opened a new pull request, #19972:
URL: https://github.com/apache/flink/pull/19972
## What is the purpose of the change
## Brief change log
This task modifies the `flink-connector-pulsar` module, adding some new
mechanisms to set the initial consuming position.
-
[
https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27399:
---
Labels: pull-request-available (was: )
> Pulsar connector didn't set start consuming
coderappee commented on PR #109:
URL: https://github.com/apache/flink-ml/pull/109#issuecomment-1156647134
> Hi @coderappee , thanks for creating this PR. Could you please illustrate
why do we need to add these static imports? For now the test cases can still
pass without these imports.
[
https://issues.apache.org/jira/browse/FLINK-25842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-25842:
Assignee: Yuan Mei
> [v2] FLIP-158: Generalized incremental checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-23143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-23143:
Assignee: Hangxiang Yu
> Support state migration
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-28081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-28081:
-
Assignee: Gabor Somogyi
> Remove deprecated Hadoop specific Flink configuration
Gabor Somogyi created FLINK-28081:
-
Summary: Remove deprecated Hadoop specific Flink configuration
options
Key: FLINK-28081
URL: https://issues.apache.org/jira/browse/FLINK-28081
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554667#comment-17554667
]
Yuan Mei commented on FLINK-25458:
--
As discussed offline and summarized here:
* The first step is to
eskabetxe commented on PR #19925:
URL: https://github.com/apache/flink/pull/19925#issuecomment-1156625342
@MartijnVisser could you forward to someone that can check this?
--
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-25458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-25458:
Assignee: Yanfei Lei
> Support local recovery
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-27790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-27790:
--
Summary: Port ADD/ShowJar syntax implementation from SqlClient to
TableEnvironment side (was: Move
1 - 100 of 295 matches
Mail list logo
