tzulitai commented on a change in pull request #114:
URL: https://github.com/apache/flink-statefun/pull/114#discussion_r427724398
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUnixSocketUtils.java
##
@@ -0,0
flinkbot commented on pull request #12274:
URL: https://github.com/apache/flink/pull/12274#issuecomment-631893198
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-17816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112813#comment-17112813
]
Jiayi Liao commented on FLINK-17816:
I guess the change would be simple. We might just need to
JingsongLi opened a new pull request #12274:
URL: https://github.com/apache/flink/pull/12274
## What is the purpose of the change
This is cherry-pick version for https://github.com/apache/flink/pull/12241
Parquet reader should be case insensitive field names for hive
flinkbot edited a comment on pull request #12230:
URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457
## CI report:
* 458ca449de6bb1007cd3e83f81fe09f973e7f6d3 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eui Heo closed FLINK-17077.
---
Resolution: Won't Do
> FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker
> container
flinkbot edited a comment on pull request #12230:
URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457
## CI report:
* 458ca449de6bb1007cd3e83f81fe09f973e7f6d3 Azure:
Jiayi-Liao commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428446972
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -181,6 +181,14 @@ void
yangyichao-mango commented on pull request #12230:
URL: https://github.com/apache/flink/pull/12230#issuecomment-631880357
Thx for your suggestions. I've pushed a new Commits.
@klion26
This is an automated message from
yangyichao-mango edited a comment on pull request #12230:
URL: https://github.com/apache/flink/pull/12230#issuecomment-631880357
Thx for your suggestions. I've pushed a new Commit.
@klion26
This is an automated message
leonardBang commented on a change in pull request #12273:
URL: https://github.com/apache/flink/pull/12273#discussion_r428437365
##
File path:
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogITCase.java
##
@@ -69,18
ChengWei Ye created FLINK-17858:
---
Summary: Yarn mode, windows and linux environment should be
interlinked
Key: FLINK-17858
URL: https://issues.apache.org/jira/browse/FLINK-17858
Project: Flink
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428436876
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -1010,6 +1011,56 @@
cyq89051127 closed pull request #10656:
URL: https://github.com/apache/flink/pull/10656
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-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17474:
-
Priority: Critical (was: Major)
> Test and correct case insensitive for parquet and orc in
wuchong commented on a change in pull request #12199:
URL: https://github.com/apache/flink/pull/12199#discussion_r428432638
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableITCase.scala
##
@@ -104,14 +104,35 @@ class
[
https://issues.apache.org/jira/browse/FLINK-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-17857:
--
Component/s: Tests
Deployment / Kubernetes
> All Kubernetes e2e tests could not run
Yang Wang created FLINK-17857:
-
Summary: All Kubernetes e2e tests could not run on Mac after
migration
Key: FLINK-17857
URL: https://issues.apache.org/jira/browse/FLINK-17857
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112785#comment-17112785
]
Benchao Li commented on FLINK-17847:
Also +1 to what [~Leonard Xu] summarized.
>
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428431678
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -181,6 +181,14 @@ void
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428430651
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -181,6 +181,14 @@ void
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428430651
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -181,6 +181,14 @@ void
zhijiangW commented on a change in pull request #12261:
URL: https://github.com/apache/flink/pull/12261#discussion_r428430651
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -181,6 +181,14 @@ void
[
https://issues.apache.org/jira/browse/FLINK-17856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112778#comment-17112778
]
Jingsong Lee commented on FLINK-17856:
--
+1 we have added this capability to hive source. File
[
https://issues.apache.org/jira/browse/FLINK-17856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17856:
-
Fix Version/s: 1.12.0
> Adds the feature of monitoring directory changes for FileSystem table
[
https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112774#comment-17112774
]
Zhu Zhu commented on FLINK-17814:
-
I have assigned the ticket to you [~caozhen1937].
> Translate native
[
https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112775#comment-17112775
]
Yang Wang commented on FLINK-17814:
---
[~caozhen1937] Great. Thanks a lot for your contribution. Please
[
https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-17814:
---
Assignee: CaoZhen
> Translate native kubernetes document to Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-17817.
Resolution: Fixed
master: 1cf06e198bddfa26bc4899b2ad570926f77a9668
release-1.11:
[
https://issues.apache.org/jira/browse/FLINK-17856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-17856:
Description:
Great thanks to Violeta for report this issue.
sunjincheng created FLINK-17856:
---
Summary: Adds the feature of monitoring directory changes for
FileSystem table source connector
Key: FLINK-17856
URL: https://issues.apache.org/jira/browse/FLINK-17856
JingsongLi merged pull request #12272:
URL: https://github.com/apache/flink/pull/12272
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
TsReaper commented on pull request #12272:
URL: https://github.com/apache/flink/pull/12272#issuecomment-631858940
Azure passed in
https://dev.azure.com/tsreaper96/Flink/_build/results?buildId=32=results
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112771#comment-17112771
]
CaoZhen commented on FLINK-17814:
-
hi,Yang Wang. I have developed flink on k8s. I want to translate
flinkbot edited a comment on pull request #12272:
URL: https://github.com/apache/flink/pull/12272#issuecomment-631841740
## CI report:
* ed5e8c901271495c93ed345f1750e43e6897e7e8 Azure:
becketqin commented on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-631856597
The patch LGTM. I don't think the test failure is relevant.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112761#comment-17112761
]
Jark Wu commented on FLINK-17847:
-
I'm fine with this.
> ArrayIndexOutOfBoundsException happens when
[
https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112759#comment-17112759
]
Leonard Xu commented on FLINK-17847:
Thanks [~libenchao] [~jark] [~lzljs3620320] for involving.
I'm
flinkbot edited a comment on pull request #12273:
URL: https://github.com/apache/flink/pull/12273#issuecomment-631848905
## CI report:
* 9b1c59eda81fd5bd092a6d437d603c88b2450008 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112755#comment-17112755
]
Xintong Song commented on FLINK-17560:
--
I'm not entirely sure about this, but AFAIK this should not
[
https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112753#comment-17112753
]
Jingsong Lee commented on FLINK-17855:
--
When invoke this function:
{code:java}
select
[
https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112751#comment-17112751
]
Jark Wu commented on FLINK-17855:
-
I think this is reasonable, because planner can't infer what's the
[
https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112749#comment-17112749
]
Jingsong Lee commented on FLINK-17847:
--
For a constant index with "<= 0", we can throw exception or
[
https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112748#comment-17112748
]
Jingsong Lee commented on FLINK-17847:
--
Calcite comments:
{code:java}
/**
* The item operator
flinkbot commented on pull request #12273:
URL: https://github.com/apache/flink/pull/12273#issuecomment-631848905
## CI report:
* 9b1c59eda81fd5bd092a6d437d603c88b2450008 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #12272:
URL: https://github.com/apache/flink/pull/12272#issuecomment-631841740
## CI report:
* ed5e8c901271495c93ed345f1750e43e6897e7e8 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112742#comment-17112742
]
Jingsong Lee commented on FLINK-17803:
--
[~zouyunhe] Re-open this, we should throws a better
[
https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112743#comment-17112743
]
Jark Wu commented on FLINK-17847:
-
Thanks for looking into this [~libenchao]. I'm +1 to the #1.
I'm not
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17803:
-
Summary: Should throws a readable exception when group by Map type (was:
Flink batch sql job
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17803:
-
Fix Version/s: 1.11.0
> Should throws a readable exception when group by Map type
>
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reopened FLINK-17803:
--
> Flink batch sql job read hive table which contains map type, raise exception:
> "
klion26 commented on a change in pull request #11978:
URL: https://github.com/apache/flink/pull/11978#discussion_r428414960
##
File path: docs/dev/table/streaming/temporal_tables.zh.md
##
@@ -113,18 +112,20 @@ Euro119
Pounds 108
{% endhighlight %}
-In Flink,
[
https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112740#comment-17112740
]
Xintong Song commented on FLINK-17721:
--
One more comment on option 3.
[
https://issues.apache.org/jira/browse/FLINK-17852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112737#comment-17112737
]
Jark Wu commented on FLINK-17852:
-
This should already be supported in Flink, we have some tests using
[
https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-17826:
Parent: (was: FLINK-17025)
Issue Type: Bug (was: Sub-task)
> Add missing custom query
[
https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-17752:
Parent: (was: FLINK-17025)
Issue Type: Bug (was: Sub-task)
> Align the timestamp format with
flinkbot commented on pull request #12272:
URL: https://github.com/apache/flink/pull/12272#issuecomment-631841740
## CI report:
* ed5e8c901271495c93ed345f1750e43e6897e7e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12273:
URL: https://github.com/apache/flink/pull/12273#issuecomment-631840447
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
Jingsong Lee created FLINK-17855:
Summary: UDF with parameter Array(Row) can not work
Key: FLINK-17855
URL: https://issues.apache.org/jira/browse/FLINK-17855
Project: Flink
Issue Type: Bug
wuchong commented on pull request #12273:
URL: https://github.com/apache/flink/pull/12273#issuecomment-631839829
cc @leonardBang @fpompermaier , could you help to have a look at this?
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17645.
---
Resolution: Fixed
Fixed via
master
9f3a71183ea4b14a396ecf66e4377da07b06a689
release-1.1
[
https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17850:
---
Labels: pull-request-available test-stability (was: test-stability)
>
wuchong opened a new pull request #12273:
URL: https://github.com/apache/flink/pull/12273
## What is the purpose of the change
Sorry for breaking the CI builds. The reason is that #12090 updates the
schema of the base testing table. But I didn't rerun the builds before
mghildiy commented on pull request #12189:
URL: https://github.com/apache/flink/pull/12189#issuecomment-631839252
Sorry for delay. I am stuck with some issues, and plan to work on it this
weekend. If its needed urgently, I am fine with someone else taking it up.
zhuzhurk commented on pull request #12181:
URL: https://github.com/apache/flink/pull/12181#issuecomment-631838808
Merging.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
zhuzhurk merged pull request #12181:
URL: https://github.com/apache/flink/pull/12181
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-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112728#comment-17112728
]
Benchao Li commented on FLINK-17847:
[~Leonard Xu] This problem exists since 1.9 which use are using
[
https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112726#comment-17112726
]
Xintong Song commented on FLINK-17721:
--
The test failure is caused by {{cleanupDirectoryWithRetry}}
klion26 commented on a change in pull request #12230:
URL: https://github.com/apache/flink/pull/12230#discussion_r428406792
##
File path: docs/getting-started/index.zh.md
##
@@ -27,61 +27,27 @@ specific language governing permissions and limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112724#comment-17112724
]
Yang Wang commented on FLINK-17444:
---
[~kkl0u] I am not sure about how difficult is it to make all
[
https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112723#comment-17112723
]
Caizhi Weng commented on FLINK-17817:
-
[~dwysakowicz] no problem
[~sewen] sorry for the delay... I
flinkbot commented on pull request #12272:
URL: https://github.com/apache/flink/pull/12272#issuecomment-631834610
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-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112721#comment-17112721
]
Yang Wang commented on FLINK-17819:
---
Just a side input, we could not just verify the HADOOP_CLASSPATH
TsReaper opened a new pull request #12272:
URL: https://github.com/apache/flink/pull/12272
## What is the purpose of the change
This is a hot fix for `CollectSinkFunction`. `TypeSerializer`s are not
thread safe but currently `CollectSinkFunction` reuses them among two threads.
This
[
https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Echo Lee closed FLINK-17745.
Resolution: Not A Problem
> PackagedProgram' extractedTempLibraries and jarfiles may be duplicate
>
klion26 commented on pull request #12096:
URL: https://github.com/apache/flink/pull/12096#issuecomment-631833147
Rebased the newly master
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112719#comment-17112719
]
Echo Lee commented on FLINK-17745:
--
[~fly_in_gis] Yes, this is not a problem.
[~kkl0u] Ok, i will
[
https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-17850:
---
Assignee: Jark Wu
> PostgresCatalogITCase . testGroupByInsert() fails on CI
>
[
https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112698#comment-17112698
]
lun zhang commented on FLINK-17657:
---
Hi [~JinxinTang]. Sorry I only can reproduce this in sql client.
[
https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112697#comment-17112697
]
lun zhang commented on FLINK-17657:
---
Hi [~danny0405] , I don't know how to fix it.It's need change
[
https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lun zhang updated FLINK-17657:
--
Fix Version/s: (was: 1.11.0)
> jdbc not support read BIGINT UNSIGNED field
>
flinkbot edited a comment on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-631792224
## CI report:
* 195266eaabfc2f554a22cd6c79a553c69dcfea29 Azure:
flinkbot edited a comment on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-631792224
## CI report:
* 195266eaabfc2f554a22cd6c79a553c69dcfea29 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112667#comment-17112667
]
josson paul kalapparambath commented on FLINK-17560:
[~xintongsong]
What are the
flinkbot commented on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-631792224
## CI report:
* 195266eaabfc2f554a22cd6c79a553c69dcfea29 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12271:
URL: https://github.com/apache/flink/pull/12271#issuecomment-631785385
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-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112651#comment-17112651
]
Roman Khachatryan edited comment on FLINK-17820 at 5/20/20, 11:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-17854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17854:
---
Labels: pull-request-available (was: )
> Use InputStatus directly in user-facing async
StephanEwen opened a new pull request #12271:
URL: https://github.com/apache/flink/pull/12271
## What is the purpose of the change
The `flink-runtime` uses the `InputStatus` enum in its
`PushingAsyncDataInput`.
The `SourceReader` in `flink-core` has a separate enum with the same
[
https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112652#comment-17112652
]
Stephan Ewen commented on FLINK-17808:
--
I think this pattern (atomically visible file) may be quite
[
https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112651#comment-17112651
]
Roman Khachatryan commented on FLINK-17820:
---
The data to FsCheckpointStateOutputStream is
Stephan Ewen created FLINK-17854:
Summary: Use InputStatus directly in user-facing async input APIs
(like source readers)
Key: FLINK-17854
URL: https://issues.apache.org/jira/browse/FLINK-17854
[
https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112647#comment-17112647
]
Stephan Ewen commented on FLINK-17808:
--
We need to avoid renaming in checkpoints, because it causes
[
https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112644#comment-17112644
]
Stephan Ewen commented on FLINK-17817:
--
Is the fix going in asap? Otherwise we need to do a
1 - 100 of 497 matches
Mail list logo
