Yang Wang created FLINK-26367:
-
Summary: Move sanity check in FlinkService#cancelJob to
DefaultDeploymentValidator
Key: FLINK-26367
URL: https://issues.apache.org/jira/browse/FLINK-26367
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
realdengziqi updated FLINK-26334:
-
Priority: Blocker (was: Major)
> when the (timestamp - offset + windowSize) is less than 0 the
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* ce34627cabe844f0af69ddca6f1b5599e5bf1ef8 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-26141.
-
Resolution: Fixed
Fixed via:
main: baaed88b21a27df0eb26a5bdce4516ec3c7510c1
> Support last-state
lindong28 closed pull request #66:
URL: https://github.com/apache/flink-ml/pull/66
--
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:
lindong28 commented on pull request #66:
URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050616922
Thanks 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 to the
flinkbot edited a comment on pull request #18917:
URL: https://github.com/apache/flink/pull/18917#issuecomment-1050613556
## CI report:
* 7bd2b6a4ebda7ea5b727984a4b4877c0dbf8432b Azure:
flinkbot commented on pull request #18917:
URL: https://github.com/apache/flink/pull/18917#issuecomment-1050613861
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
flinkbot commented on pull request #18917:
URL: https://github.com/apache/flink/pull/18917#issuecomment-1050613556
## CI report:
* 7bd2b6a4ebda7ea5b727984a4b4877c0dbf8432b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
zhaishujie opened a new pull request #18917:
URL: https://github.com/apache/flink/pull/18917
## 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
lindong28 commented on pull request #66:
URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050611807
@zhipeng93 It is generally preferred to have a test to reproduce this bug
with high likelihood, or be able to reproduce this bug manually. This is
generally done on a
[
https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497959#comment-17497959
]
Konstantin Knauf commented on FLINK-26354:
--
>From my perspective consistency with existing
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408
]
Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:39 AM:
# Why using a
flinkbot edited a comment on pull request #18915:
URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485121
## CI report:
* acc2bffef19cb00ce33dac3330cd0e1b7d692835 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408
]
Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:32 AM:
# Why using a
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408
]
Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:32 AM:
# Why using a
[
https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26136.
--
Resolution: Fixed
Merged: 85d997eaa0310a298bb3a3a704afacf3844635f7
> Implement shared validation
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497947#comment-17497947
]
Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:25 AM:
The severity of
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497947#comment-17497947
]
Yuan Mei commented on FLINK-26306:
--
>From the number shared, I do agree that this is an
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497947#comment-17497947
]
Yuan Mei edited comment on FLINK-26306 at 2/25/22, 7:12 AM:
>From the number
wangyang0918 commented on a change in pull request #18739:
URL: https://github.com/apache/flink/pull/18739#discussion_r814522068
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
##
@@ -1829,4 +1809,41 @@ public static void
1996fanrui commented on pull request #18852:
URL: https://github.com/apache/flink/pull/18852#issuecomment-1050574741
> @1996fanrui , thanks a lot for these changes. I left a several comments in
the PR, please, take a look. I also have an one question: According to ticket,
you had a
flinkbot edited a comment on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 684cc9586eed1e214683ea3d881e30bbc1065670 Azure:
[
https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-18229:
Assignee: huweihua
> Pending worker requests should be properly cleared
>
[
https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497938#comment-17497938
]
Xintong Song commented on FLINK-18229:
--
Thanks for volunteering, [~huwh]. You are assigned.
>
[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497937#comment-17497937
]
Yang Wang commented on FLINK-26356:
---
I think we could always use the {{-rest.}} to access the
Flink
[
https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
realdengziqi updated FLINK-26334:
-
Affects Version/s: 1.15.0
> when the (timestamp - offset + windowSize) is less than 0 the
[
https://issues.apache.org/jira/browse/FLINK-25963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497933#comment-17497933
]
Yang Wang commented on FLINK-25963:
---
FYI: I have enabled the auto link reference for
[
https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497929#comment-17497929
]
huweihua commented on FLINK-18229:
--
Hi [~xtsong] , I would like to deal with this issue, could you
RocMarshal edited a comment on pull request #18480:
URL: https://github.com/apache/flink/pull/18480#issuecomment-1037264660
@gaoyunhaii @wuchong Could you help me to merge it if there's nothing
Inappropriate? Thank you very much.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497923#comment-17497923
]
luoyuxia edited comment on FLINK-26355 at 2/25/22, 6:14 AM:
[~zoucao]
[
https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497923#comment-17497923
]
luoyuxia commented on FLINK-26355:
--
[~zoucao] HiveTableSqlFunction is deprecated. I think the better
wangyang0918 commented on pull request #17502:
URL: https://github.com/apache/flink/pull/17502#issuecomment-1050551870
Sorry for the late response. @dmvk I think your suggestion makes sense to
me. Then we will have only one place `waitForNewLeader` or
`waitForEmptyLeaderInformation` to
shenzhu commented on pull request #24:
URL: https://github.com/apache/flink-table-store/pull/24#issuecomment-1050550061
Hey @tsreaper , I updated this PR and added some tests, would you mind
taking a look again when you have a moment? Thanks!
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497918#comment-17497918
]
zoucao commented on FLINK-26355:
I use default dialect with hive module rather than hive dialect. Is it
schumiyi commented on pull request #18914:
URL: https://github.com/apache/flink/pull/18914#issuecomment-1050529549
@wuchong @JingsongLi Would you like to review this pr? Thanks for your time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot edited a comment on pull request #18916:
URL: https://github.com/apache/flink/pull/18916#issuecomment-1050514075
## CI report:
* be996b8c559bb17a7a4f3c3d397b79ed70d8ec9b Azure:
flinkbot commented on pull request #18916:
URL: https://github.com/apache/flink/pull/18916#issuecomment-1050515056
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
flinkbot commented on pull request #18916:
URL: https://github.com/apache/flink/pull/18916#issuecomment-1050514075
## CI report:
* be996b8c559bb17a7a4f3c3d397b79ed70d8ec9b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26314:
---
Labels: pull-request-available test-stability (was: test-stability)
>
pltbkd opened a new pull request #18916:
URL: https://github.com/apache/flink/pull/18916
## What is the purpose of the change
This pull request fixes the unstable test case of
StreamingCompactingFileSinkITCase since the compactor of FileSink can't work
with unaligned
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26360:
-
Description:
Currently, we have a support for hive synatax compatibility in flink as
described in
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26360:
-
Description:
Currently, we have a support for hive synatax compatibility in flink as
described in
[
https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26366:
-
Description:
In hive, it allow to write data into the filesystem from queries using the
following sql
flinkbot edited a comment on pull request #18891:
URL: https://github.com/apache/flink/pull/18891#issuecomment-1048391421
## CI report:
* 4a1e6f20a8703f2fa59879da3d287e5ad5e284c5 Azure:
luoyuxia created FLINK-26366:
Summary: Support "insert directory"
Key: FLINK-26366
URL: https://issues.apache.org/jira/browse/FLINK-26366
Project: Flink
Issue Type: Sub-task
flinkbot edited a comment on pull request #18891:
URL: https://github.com/apache/flink/pull/18891#issuecomment-1048391421
## CI report:
* 4a1e6f20a8703f2fa59879da3d287e5ad5e284c5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-26360:
---
Assignee: luoyuxia
> [Umbrella] Improvement for Hive Query Syntax Compatibility
>
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-26360:
Fix Version/s: 1.16.0
> [Umbrella] Improvement for Hive Query Syntax Compatibility
>
[
https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497891#comment-17497891
]
luoyuxia commented on FLINK-26355:
--
[~zoucao] Thanks for reporting it. Seems you're using hive
v-qiunan commented on pull request #18915:
URL: https://github.com/apache/flink/pull/18915#issuecomment-1050498632
hello
--
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-26365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26365:
-
Description:
Currently we can't get call Hive UDAF that requires constant arguments like
[
https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497887#comment-17497887
]
Gen Luo commented on FLINK-26314:
-
I found that the PseudoRandomValueSelector is selecting PT0S for
luoyuxia created FLINK-26365:
Summary: improve hive udaf
Key: FLINK-26365
URL: https://issues.apache.org/jira/browse/FLINK-26365
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26364:
-
Description:
There're some issue sreported releated to calling hive udft like
[
https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497885#comment-17497885
]
zoucao commented on FLINK-26355:
Hi, [~luoyuxia], I found this problem in the process of driving the
[
https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26364:
-
Description:
There're some issue sreported releated to calling hive udft like
[
https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26364:
-
Description:
There're some issue sreported releated to calling hive udft like
flinkbot edited a comment on pull request #18915:
URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485121
## CI report:
* acc2bffef19cb00ce33dac3330cd0e1b7d692835 Azure:
luoyuxia created FLINK-26364:
Summary: Improve hive udtf
Key: FLINK-26364
URL: https://issues.apache.org/jira/browse/FLINK-26364
Project: Flink
Issue Type: Sub-task
Reporter:
zhipeng93 edited a comment on pull request #66:
URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050431249
Hi Dong, Thanks for the review.
> Could you confirm that the flaky test could be reproduced before this
patch but not after this patch?
I have repeatedly
flinkbot commented on pull request #18915:
URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485301
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
flinkbot commented on pull request #18915:
URL: https://github.com/apache/flink/pull/18915#issuecomment-1050485121
## CI report:
* acc2bffef19cb00ce33dac3330cd0e1b7d692835 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497881#comment-17497881
]
luoyuxia commented on FLINK-26363:
--
There're are some issue like
[
https://issues.apache.org/jira/browse/FLINK-26351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26351:
---
Labels: pull-request-available (was: )
> After scaling a flink task running on k8s, the
[
https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26363:
-
Description:
Using hive dialect, can be reproduced using the following sql
{code:sql}
select if(1=1,
v-qiunan opened a new pull request #18915:
URL: https://github.com/apache/flink/pull/18915
…the flink web ui graph always shows the parallelism of the first deployment.
## What is the purpose of the change
*(After scaling a flink task running on k8s, the flink web ui
[
https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26363:
-
Description:
Using hive dialect, can be reproduced using the following sql
{code:sql}
select if(1=1,
luoyuxia created FLINK-26363:
Summary: Fail to use such expression like if(1= 1, 2, 3)
Key: FLINK-26363
URL: https://issues.apache.org/jira/browse/FLINK-26363
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497878#comment-17497878
]
Yun Tang commented on FLINK-26354:
--
Since the latest version of commons-cli is 1.5.0, which is what we
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* 4324aa57719c8e0f0e408daaa4dd7064109bc5fa Azure:
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* 4324aa57719c8e0f0e408daaa4dd7064109bc5fa Azure:
MrWhiteSike commented on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1050465364
[@RocMarshal](https://github.com/RocMarshal) Thanks for the comments. Please
review it again. Thanks
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26356:
---
Description:
The clusterClient is built as below. The config is mixed up with the
FlinkDeploymentSpec and
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26360:
-
Description:
Currently, we have a support for hive synatax compatibility in flink as
described in
[
https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497857#comment-17497857
]
luoyuxia commented on FLINK-26362:
--
We should add a extra project node when type conversion is
[
https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26362:
-
Description:
With hive dialect, can be reproduced using following code:
{code:java}
flinkbot edited a comment on pull request #18914:
URL: https://github.com/apache/flink/pull/18914#issuecomment-1050372877
## CI report:
* a591d1c40b987902427e7692e208e972b70bcb33 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26362:
-
Description:
With hive dialect, can be reproduced using following code:
{code:java}
flinkbot edited a comment on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 6d23d5651638281b39766cf214cbbb2b111a4da7 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26362:
-
Summary: "IndexOutOfBoundsException" when subquery select all field from
using hive dialect (was:
luoyuxia created FLINK-26362:
Summary: IndexOutOfBoundsException when subquery select all field
from using hive dialect
Key: FLINK-26362
URL: https://issues.apache.org/jira/browse/FLINK-26362
Project:
[
https://issues.apache.org/jira/browse/FLINK-26343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-26343.
Resolution: Duplicate
> IndexOutOfBoundsException when subquery select all field from using hive
>
flinkbot edited a comment on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 6d23d5651638281b39766cf214cbbb2b111a4da7 Azure:
MrWhiteSike commented on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1050452261
[@RocMarshal](https://github.com/RocMarshal) Thanks for the comments.I
updated this pr based on your comments. Please review it again. Thanks
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497850#comment-17497850
]
luoyuxia commented on FLINK-26361:
--
I'll fix it.
> "Unexpected correlate variable $cor0" when using
[
https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26361:
-
Description:
With hive dialect, can be reproduced using such code:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497848#comment-17497848
]
Aitozi commented on FLINK-26356:
I have not make it very clear yet, I will do more investigation first.
luoyuxia created FLINK-26361:
Summary: "Unexpected correlate variable $cor0" when using hive
dialect to write a subquery
Key: FLINK-26361
URL: https://issues.apache.org/jira/browse/FLINK-26361
Project:
[
https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26360:
-
Description:
Currently, we have a support for hive synatax compatibility in flink as
described in
[
https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497847#comment-17497847
]
luoyuxia commented on FLINK-25727:
--
I will fix it in
[
https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497845#comment-17497845
]
luoyuxia commented on FLINK-26355:
--
[~zoucao] The answer is yes. There's a similar issue
luoyuxia created FLINK-26360:
Summary: [Umbrella] Improvement for Hive Query Syntax Compatibility
Key: FLINK-26360
URL: https://issues.apache.org/jira/browse/FLINK-26360
Project: Flink
Issue
zhipeng93 edited a comment on pull request #66:
URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050431249
Not ready..
--
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-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497408#comment-17497408
]
Yuan Mei edited comment on FLINK-26306 at 2/25/22, 1:42 AM:
# Why using a
zhipeng93 commented on pull request #66:
URL: https://github.com/apache/flink-ml/pull/66#issuecomment-1050431249
Hi Dong, Thanks for the review.
> Could you confirm that the flaky test could be reproduced before this
patch but not after this patch?
I have repeatedly run this
flinkbot edited a comment on pull request #18913:
URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597
## CI report:
* 0ba635c5ae44773c15a90e8c668007e744b37251 Azure:
afedulov commented on a change in pull request #18903:
URL: https://github.com/apache/flink/pull/18903#discussion_r814220659
##
File path: docs/content/docs/connectors/datastream/formats/csv.md
##
@@ -0,0 +1,87 @@
+---
+title: "CSV"
+weight: 4
+type: docs
+aliases:
+-
[
https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497832#comment-17497832
]
realdengziqi commented on FLINK-26334:
--
I want to work on this:D
> when the (timestamp - offset +
afedulov commented on a change in pull request #18911:
URL: https://github.com/apache/flink/pull/18911#discussion_r814275794
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java
##
@@ -42,7 +43,17 @@
1 - 100 of 561 matches
Mail list logo