[
https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-19757:
--
Description:
when we check jdk LocalDateTime code，we find that
public static LocalDateTime
[
https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-19757:
--
Description:
when we check jdk LocalDateTime code，we find that
{code:java}
// code
flinkbot commented on pull request #13738:
URL: https://github.com/apache/flink/pull/13738#issuecomment-714211013
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
curcur commented on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
[
https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218728#comment-17218728
]
Jark Wu commented on FLINK-19757:
-
Hi [~zhoujira86], the current implementation is correct.
The
flinkbot edited a comment on pull request #13653:
URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488
## CI report:
* cadf9a2a13d3113395f199431881fff216b9a50a Azure:
flinkbot edited a comment on pull request #13721:
URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063
## CI report:
* 1e1971368a88e3457dbf60cecfe319d58649092d Azure:
Yun Gao created FLINK-19758:
---
Summary: Implement a new unified File Sink based on the new Sink
API
Key: FLINK-19758
URL: https://issues.apache.org/jira/browse/FLINK-19758
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-19743:
-
Summary: Add Source metrics definitions (was: Add metrics definitions.)
> Add Source metrics
godfreyhe merged pull request #13737:
URL: https://github.com/apache/flink/pull/13737
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
[
https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218765#comment-17218765
]
Dian Fu edited comment on FLINK-19759 at 10/22/20, 5:54 AM:
cc [~TsReaper]
[
https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218772#comment-17218772
]
Dian Fu commented on FLINK-19759:
-
Upgrade to blocker as it's continuously failing.
>
[
https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-19755:
-
Description:
{code:java}
symbol tax price rowtime
= ===
jackylau created FLINK-19755:
Summary: flink cep
Key: FLINK-19755
URL: https://issues.apache.org/jira/browse/FLINK-19755
Project: Flink
Issue Type: Bug
Components: Library / CEP
danbosnichill commented on pull request #13711:
URL: https://github.com/apache/flink/pull/13711#issuecomment-714186065
I switched to `java.time.Duration`.
I did not switch other calls to `ExponentialBackoffRetryStrategy`. I do not
know the code base well enough to say if this is
leonardBang commented on a change in pull request #13729:
URL: https://github.com/apache/flink/pull/13729#discussion_r509860215
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveLookupFunction.java
##
@@ -47,29 +59,46
[
https://issues.apache.org/jira/browse/FLINK-18971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-18971.
Resolution: Done
Done via
* master: dd481134f24e8fd1ce65e827e0c5c6350c5be9b2
> Support to mount
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
flinkbot edited a comment on pull request #13581:
URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397
## CI report:
* 1e187203b15559b08d15a0cca949ca15a8a3bafe Azure:
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
WeiZhong94 opened a new pull request #13739:
URL: https://github.com/apache/flink/pull/13739
## What is the purpose of the change
*This pull request supports iterating MapState and MapView*
## Brief change log
- *Support iterating MapState and MapView*
##
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-713341581
Thanks @rkhachatryan so much for the great question on how different threads
access the same view (in other words, threading model in netty + task thread
interaction on
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-713341581
Thanks @rkhachatryan so much for the great question on how different threads
access the same view (in other words, threading model in netty + task thread
interaction on
xiaogang zhou created FLINK-19757:
-
Summary: TimeStampData can cause time inconsistent problem
Key: FLINK-19757
URL: https://issues.apache.org/jira/browse/FLINK-19757
Project: Flink
Issue
flinkbot edited a comment on pull request #13623:
URL: https://github.com/apache/flink/pull/13623#issuecomment-708132144
## CI report:
* 1de96f52dee7fc493ca0cad827189955520362cc Azure:
flinkbot edited a comment on pull request #13653:
URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488
## CI report:
* cadf9a2a13d3113395f199431881fff216b9a50a Azure:
flinkbot edited a comment on pull request #13729:
URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157
## CI report:
* 659b57b42486d3b79197653fec933ce42766388e Azure:
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
[
https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218724#comment-17218724
]
xiaozilong commented on FLINK-19687:
cc [~godfreyhe]
> Support to get execution plan in
curcur edited a comment on pull request #13648:
URL: https://github.com/apache/flink/pull/13648#issuecomment-714211577
> * Visilibity in normal case: none of the felds written in `releaseView`
are `volatile`. So in normal case (`t1:release` then `t2:createReadView`) `t2`
can see some
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r50975
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectionService.java
##
@@ -0,0 +1,219 @@
gm7y8 removed a comment on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-714126117
@flinkbot approve description
This is an automated message from the Apache Git Service.
To respond to the
flinkbot edited a comment on pull request #13690:
URL: https://github.com/apache/flink/pull/13690#issuecomment-712304240
## CI report:
* 518581ab52a2d976ff344404a6828cec23c260f9 Azure:
flinkbot edited a comment on pull request #13739:
URL: https://github.com/apache/flink/pull/13739#issuecomment-714232634
## CI report:
* 9f75014b48308eb93937e11fcd8f4da80de12bd4 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19759:
Priority: Blocker (was: Major)
> DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable
>
[
https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218771#comment-17218771
]
Dian Fu commented on FLINK-19759:
-
[
https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218765#comment-17218765
]
Dian Fu commented on FLINK-19759:
-
cc [~TsReaper]
>
flinkbot edited a comment on pull request #13581:
URL: https://github.com/apache/flink/pull/13581#issuecomment-706519397
## CI report:
* 1e187203b15559b08d15a0cca949ca15a8a3bafe Azure:
flinkbot commented on pull request #13739:
URL: https://github.com/apache/flink/pull/13739#issuecomment-714227770
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
[
https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218759#comment-17218759
]
xiaogang zhou commented on FLINK-19757:
---
[~jark] thx for commenting, if i run the sql
[
https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19757:
---
Labels: pull-request-available (was: )
> TimeStampData can cause time inconsistent problem
flinkbot edited a comment on pull request #13721:
URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063
## CI report:
* 1e1971368a88e3457dbf60cecfe319d58649092d Azure:
flinkbot edited a comment on pull request #13729:
URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157
## CI report:
* f028c8d52466fbd6fd5a9cbf3ed85dcbc65fd2ac Azure:
flinkbot commented on pull request #13738:
URL: https://github.com/apache/flink/pull/13738#issuecomment-714225386
## CI report:
* 065898f3ea61da7479e614517c03acfbce10ebfb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13736:
URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394
## CI report:
* 259c893dcb4b5692df54cfe7739f95d9e34096e6 Azure:
wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r509891311
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java
##
@@ -0,0 +1,80 @@
+/*
KarmaGYZ commented on pull request #13581:
URL: https://github.com/apache/flink/pull/13581#issuecomment-714242065
cc @zhijiangW
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-19759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19759:
Labels: test-stability (was: )
> DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable
>
Dian Fu created FLINK-19759:
---
Summary: DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange
is instable
Key: FLINK-19759
URL: https://issues.apache.org/jira/browse/FLINK-19759
Project: Flink
guoweiM commented on pull request #13678:
URL: https://github.com/apache/flink/pull/13678#issuecomment-714246544
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot edited a comment on pull request #13736:
URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394
## CI report:
* 259c893dcb4b5692df54cfe7739f95d9e34096e6 Azure:
zhougit86 opened a new pull request #13738:
URL: https://github.com/apache/flink/pull/13738
… problem
## What is the purpose of the change
fix the timestampdata inconsistent problem
## Brief change log
add offset in toLocalDateTime
minus offset in
wuchong commented on pull request #13653:
URL: https://github.com/apache/flink/pull/13653#issuecomment-714215751
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot commented on pull request #13739:
URL: https://github.com/apache/flink/pull/13739#issuecomment-714232634
## CI report:
* 9f75014b48308eb93937e11fcd8f4da80de12bd4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13738:
URL: https://github.com/apache/flink/pull/13738#issuecomment-714225386
## CI report:
* 065898f3ea61da7479e614517c03acfbce10ebfb Azure:
gm7y8 commented on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-714249342
> > > @XComp I was able to identify the code fix. I working to unit test it
had some issue with Flink set up to start a job with checkpoint and savepoint.
it might take a day or
[
https://issues.apache.org/jira/browse/FLINK-19754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218776#comment-17218776
]
little-tomato commented on FLINK-19754:
---
Source: Custom Source -> Map -> Map -> Filter -> Map ->
flinkbot edited a comment on pull request #13678:
URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155
## CI report:
* Unknown: [CANCELED](TBD)
* 463b5c8ed21f93caaeb7b938aa9e72abb35619b2 UNKNOWN
Bot commands
The @flinkbot bot supports the
flinkbot edited a comment on pull request #13733:
URL: https://github.com/apache/flink/pull/13733#issuecomment-713860477
## CI report:
* 1b4ff41cb703a3a8ee4d47db5f7008e7ea1ba6b3 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/191536267)
*
flinkbot edited a comment on pull request #13734:
URL: https://github.com/apache/flink/pull/13734#issuecomment-713860781
## CI report:
* 579ce0811c6f1f9db73f832e7291e0ea2d642e12 UNKNOWN
* e517e7d0eb27b285a0b8a4ca0b85a64e8b1466ce UNKNOWN
Bot commands
The
flinkbot edited a comment on pull request #13734:
URL: https://github.com/apache/flink/pull/13734#issuecomment-713860781
## CI report:
* 579ce0811c6f1f9db73f832e7291e0ea2d642e12 UNKNOWN
* e517e7d0eb27b285a0b8a4ca0b85a64e8b1466ce Azure:
flinkbot edited a comment on pull request #13733:
URL: https://github.com/apache/flink/pull/13733#issuecomment-713860477
## CI report:
* 1b4ff41cb703a3a8ee4d47db5f7008e7ea1ba6b3 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/191536267)
*
gm7y8 commented on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-714118740
> > @XComp I was able to identify the code fix. I working to unit test it
had some issue with Flink set up to start a job with checkpoint and savepoint.
it might take a day or so
gm7y8 commented on a change in pull request #13458:
URL: https://github.com/apache/flink/pull/13458#discussion_r509822287
##
File path: flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts
##
@@ -114,6 +115,8 @@ export interface CheckPointConfigInterface {
flinkbot edited a comment on pull request #13678:
URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155
## CI report:
* 2798c88d1f869baf79e35af9ae67ac954f636857 Azure:
QingdongZeng3 commented on pull request #13690:
URL: https://github.com/apache/flink/pull/13690#issuecomment-714144954
@flinkbot run azure
@flinkbot run travis
This is an automated message from the Apache Git Service.
To
flinkbot edited a comment on pull request #13678:
URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155
## CI report:
* 966c1aca195e5f2af7f32a485a48e0f5eebb35d0 Azure:
flinkbot commented on pull request #13736:
URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394
## CI report:
* 259c893dcb4b5692df54cfe7739f95d9e34096e6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
dianfu closed pull request #13687:
URL: https://github.com/apache/flink/pull/13687
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
flinkbot commented on pull request #13737:
URL: https://github.com/apache/flink/pull/13737#issuecomment-714194471
## CI report:
* 20fd494ddd03e04ffe024ee24e4a31941950f787 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13732:
URL: https://github.com/apache/flink/pull/13732#issuecomment-713724613
## CI report:
* 3f19217861e90c324e6c02a1fde7b705381b72d8 Azure:
flinkbot edited a comment on pull request #13734:
URL: https://github.com/apache/flink/pull/13734#issuecomment-713860781
## CI report:
* 579ce0811c6f1f9db73f832e7291e0ea2d642e12 UNKNOWN
* e517e7d0eb27b285a0b8a4ca0b85a64e8b1466ce UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218676#comment-17218676
]
Kezhu Wang commented on FLINK-19717:
[~rmetzger] Thanks for response. Let's wait their decision.
gm7y8 commented on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-714126117
@flinkbot approve description
This is an automated message from the Apache Git Service.
To respond to the
HuangXingBo opened a new pull request #13736:
URL: https://github.com/apache/flink/pull/13736
## What is the purpose of the change
*This pull request will reduce pyflink e2e test parallelism to optimize
pyflink e2e test*
## Brief change log
- *Set pyflink e2e
[
https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-19755:
-
Summary: flink cep docs exist looping match when coming to 17, 14 using
AFTER MATCH SKIP TO LAST A
flinkbot commented on pull request #13736:
URL: https://github.com/apache/flink/pull/13736#issuecomment-714174767
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
[
https://issues.apache.org/jira/browse/FLINK-19742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-19742:
-
Issue Type: Bug (was: Improvement)
> Invalid command in flink-end-to-end-tests README
>
[
https://issues.apache.org/jira/browse/FLINK-17375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-17375:
-
Fix Version/s: 1.12.0
> Clean up CI system related scripts
> --
[
https://issues.apache.org/jira/browse/FLINK-19742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-19742:
-
Affects Version/s: 1.12.0
> Invalid command in flink-end-to-end-tests README
>
[
https://issues.apache.org/jira/browse/FLINK-19742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-19742:
-
Fix Version/s: 1.12.0
> Invalid command in flink-end-to-end-tests README
>
[
https://issues.apache.org/jira/browse/FLINK-19742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-19742:
-
Priority: Major (was: Minor)
> Invalid command in flink-end-to-end-tests README
>
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218707#comment-17218707
]
Jark Wu commented on FLINK-19629:
-
Fixed in
- master: 3c661074b2a597db312ebaf6734c58eb66464ba4
-
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19629:
Summary: Fix NullPointException when deserializing map field with null
value for Avro format (was: Avro
[
https://issues.apache.org/jira/browse/FLINK-19754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218721#comment-17218721
]
Jark Wu commented on FLINK-19754:
-
Could you share the job graph in Web UI?
> Cannot have more than one
flinkbot edited a comment on pull request #13737:
URL: https://github.com/apache/flink/pull/13737#issuecomment-714194471
## CI report:
* 20fd494ddd03e04ffe024ee24e4a31941950f787 Azure:
flinkbot edited a comment on pull request #13729:
URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157
## CI report:
* 659b57b42486d3b79197653fec933ce42766388e Azure:
flinkbot commented on pull request #13733:
URL: https://github.com/apache/flink/pull/13733#issuecomment-713860477
## CI report:
* 1b4ff41cb703a3a8ee4d47db5f7008e7ea1ba6b3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #13734:
URL: https://github.com/apache/flink/pull/13734#issuecomment-713860781
## CI report:
* 579ce0811c6f1f9db73f832e7291e0ea2d642e12 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13595:
URL: https://github.com/apache/flink/pull/13595#issuecomment-707168234
## CI report:
* d574b6bceaf041e56f5ba5e8e4e827b7d97a2c46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19533:
---
Labels: pull-request-available (was: )
> Add state assignment to channel state during
AHeise opened a new pull request #13735:
URL: https://github.com/apache/flink/pull/13735
## What is the purpose of the change
Currently, recovery with rescaled channel state is failing. This PR enhances
`StateAssignmentOperation` to reassignment channel state and create a
[
https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218690#comment-17218690
]
jackylau commented on FLINK-19755:
--
h5. i think it will exist looping match when coming to 17, 14 using
shizhengchao commented on pull request #13634:
URL: https://github.com/apache/flink/pull/13634#issuecomment-714188821
> LGTM.
>
> Could you also prepare a pull request for release-1.11 branch?
Ok， i will finish as soon as possible
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19629:
Fix Version/s: 1.11.3
> Avro format cause NullPointException，as null value in MAP type's value type
>
wuchong merged pull request #13634:
URL: https://github.com/apache/flink/pull/13634
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
1 - 100 of 570 matches
Mail list logo
