[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-20798:
--
Description:
我这边 部署 flink 到 k8s 使用 PVC 作为 high avalibility storagedir , 我看jobmanager
的日志,选举成功了。但是
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-20798:
--
Description:
我这边 部署 flink 到 k8s 使用 PVC 作为 high avalibility storagedir , 我看jobmanager
的日志,选举成功了。但是
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256365#comment-17256365
]
Yang Wang commented on FLINK-20798:
---
[~hayden zhou] I do not find any suspicious logs in the attached
flinkbot edited a comment on pull request #14464:
URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461
## CI report:
* e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN
* 554e0a2c2ada42836d65397b163bad657806e8c2 Azure:
wuchong commented on pull request #14464:
URL: https://github.com/apache/flink/pull/14464#issuecomment-752361626
I helped to beautify the format. Will merge this once Azure is passed.
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias updated FLINK-20816:
-
Description:
[This
flinkbot edited a comment on pull request #14464:
URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461
## CI report:
* e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN
* 554e0a2c2ada42836d65397b163bad657806e8c2 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256349#comment-17256349
]
hehuiyuan commented on FLINK-20301:
---
Array & Array is not compatible.
> Flink sql 1.10 : Legacy
Matthias created FLINK-20816:
Summary: NotifyCheckpointAbortedITCase failed due to timeout
Key: FLINK-20816
URL: https://issues.apache.org/jira/browse/FLINK-20816
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-20814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256346#comment-17256346
]
huqingwen commented on FLINK-20814:
---
I have the same problem。
> The CEP code is not running properly
[
https://issues.apache.org/jira/browse/FLINK-20815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256344#comment-17256344
]
zlzhang0122 edited comment on FLINK-20815 at 12/30/20, 7:19 AM:
This
[
https://issues.apache.org/jira/browse/FLINK-20815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256344#comment-17256344
]
zlzhang0122 commented on FLINK-20815:
-
This problem maybe relate to
zlzhang0122 created FLINK-20815:
---
Summary: Elasticsearch7DynamicSinkITCase failed caused by pulling
docker image error
Key: FLINK-20815
URL: https://issues.apache.org/jira/browse/FLINK-20815
Project:
flinkbot edited a comment on pull request #14464:
URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461
## CI report:
* e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN
* 554e0a2c2ada42836d65397b163bad657806e8c2 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256341#comment-17256341
]
little-tomato commented on FLINK-20814:
---
my pom file:
org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19635:
---
Fix Version/s: 1.13.0
> HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result
little-tomato created FLINK-20814:
-
Summary: The CEP code is not running properly
Key: FLINK-20814
URL: https://issues.apache.org/jira/browse/FLINK-20814
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256337#comment-17256337
]
jiawen xiao commented on FLINK-20026:
-
SGTM,please a assign , I want to try
> Jdbc connector
[
https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256334#comment-17256334
]
jiawen xiao commented on FLINK-20777:
-
hi , [~renqs] , Maybe we need more people’s opinions
hi
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19635:
---
Fix Version/s: (was: 1.12.0)
1.12.1
>
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19635:
---
Fix Version/s: (was: 1.12.1)
1.12.0
>
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reopened FLINK-19635:
> HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result
> mismatch
>
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256332#comment-17256332
]
Leonard Xu commented on FLINK-19635:
oops, let me reopen this
>
xintongsong commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r549959072
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-20800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256330#comment-17256330
]
zlzhang0122 commented on FLINK-20800:
-
[~chesnay] Thanks for your reply. You are right, the reason
Rui Li created FLINK-20813:
--
Summary: SQL Client should create modules with user class loader
Key: FLINK-20813
URL: https://issues.apache.org/jira/browse/FLINK-20813
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #14512:
URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693
## CI report:
* 655b2992fd97e20ef142287bfd435832c469261d Azure:
[
https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256302#comment-17256302
]
Rui Li commented on FLINK-20809:
Sure I'll take a look.
> Limit push down with Hive table doesn't work
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20812:
---
Assignee: WeiNan Zhao
> flink connector hbase(1.4,2.2) too few control parameters provided
>
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256299#comment-17256299
]
Jark Wu commented on FLINK-20812:
-
Assigned this issue to you [~ZhaoWeiNan].
> flink connector
[
https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256298#comment-17256298
]
zhuxiaoshang commented on FLINK-20348:
--
[~jark],I want to have a try.
> Make
wuchong commented on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-752336588
Hi @V1ncentzzZ , please avoid to use `git pull` or `git merge` in your dev
branch. In order to have lastest master branch in your dev branch, a better way
is to use `git
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256297#comment-17256297
]
WeiNan Zhao commented on FLINK-20812:
-
I agree with your approach
> flink connector hbase(1.4,2.2)
[
https://issues.apache.org/jira/browse/FLINK-20458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20458.
---
Resolution: Fixed
Fixed in master: bd403e2cd33490db7aa5dcde72ae53dc46d304a3
> Translate page
wuchong merged pull request #14437:
URL: https://github.com/apache/flink/pull/14437
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 edited a comment on pull request #14392:
URL: https://github.com/apache/flink/pull/14392#issuecomment-745400662
## CI report:
* a366565d2ef37c57eee2d17f5718b2f0e6f173a8 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20809:
Summary: Limit push down with Hive table doesn't work when using with
filter (was: the limit push down
[
https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256295#comment-17256295
]
Jark Wu commented on FLINK-20809:
-
cc [~lirui], could you help to check this?
> Limit push down with
[
https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20809:
Component/s: (was: Table SQL / API)
Connectors / Hive
> the limit push down invalid
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20812:
Affects Version/s: (was: 1.13.0)
(was: 1.11.3)
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20812:
Component/s: Table SQL / Ecosystem
> flink connector hbase(1.4,2.2) too few control parameters provided
>
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256294#comment-17256294
]
Jark Wu commented on FLINK-20812:
-
I think we can do this like Kafka connector. Kafka connector provides
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20812:
Labels: (was: flink-connector)
> flink connector hbase(1.4,2.2) too few control parameters provided
>
[
https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256293#comment-17256293
]
Yuan Mei edited comment on FLINK-20488 at 12/30/20, 5:37 AM:
-
A bit more
[
https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256293#comment-17256293
]
Yuan Mei commented on FLINK-20488:
--
A bit more details:
On the high-level, people want to
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256291#comment-17256291
]
Yuan Mei edited comment on FLINK-18983 at 12/30/20, 5:34 AM:
-
As [~liuyufei]
[
https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256291#comment-17256291
]
Yuan Mei commented on FLINK-18983:
--
As [~liuyufei] mentioned that they already have an internal
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
WeiNan Zhao updated FLINK-20812:
Labels: flink-connector (was: )
> flink connector hbase(1.4,2.2) too few control parameters
WeiNan Zhao created FLINK-20812:
---
Summary: flink connector hbase(1.4,2.2) too few control parameters
provided
Key: FLINK-20812
URL: https://issues.apache.org/jira/browse/FLINK-20812
Project: Flink
HuangZhenQiu commented on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-752331980
@xintongsong
In the current implementation, I choose to use the class name
TimestampBasedFailureRater rather than ThresholdMeter because there is a
container failure
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r549938770
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256288#comment-17256288
]
Jiangjie Qin commented on FLINK-20777:
--
>From a Kafka user's perspective, I would expect the
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256282#comment-17256282
]
Huang Xingbo edited comment on FLINK-19635 at 12/30/20, 4:42 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256282#comment-17256282
]
Huang Xingbo commented on FLINK-19635:
--
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256280#comment-17256280
]
hayden zhou edited comment on FLINK-20798 at 12/30/20, 4:39 AM:
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256281#comment-17256281
]
hayden zhou commented on FLINK-20798:
-
can we chat on wechat? my wechat account `zmfk2009`
> Using
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256280#comment-17256280
]
hayden zhou commented on FLINK-20798:
-
[^flink.log] this is the log
> Using PVC as
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hayden zhou updated FLINK-20798:
Attachment: flink.log
> Using PVC as high-availability.storageDir could not work
>
[
https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256279#comment-17256279
]
Jark Wu commented on FLINK-20321:
-
I assigned this issue to you [~xwang51].
Welcome contribution
[
https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-18654:
---
Assignee: jiawen xiao
> Correct missleading documentation in "Partitioned Scan" section of JDBC
>
[
https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20321:
---
Assignee: Xue Wang (was: Sampad Kumar Saha)
> Get NPE when using AvroDeserializationSchema to
[
https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20026:
Component/s: Table SQL / Ecosystem
> Jdbc connector support regular expression
>
[
https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256278#comment-17256278
]
Jark Wu commented on FLINK-20026:
-
I'm fine with this feature. But we should make clear some
[
https://issues.apache.org/jira/browse/FLINK-20810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20810:
Component/s: Table SQL / Ecosystem
> abstract JdbcSchema structure and derive it from JdbcDialect.
>
[
https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20386:
Fix Version/s: 1.13.0
> ClassCastException when lookup join a JDBC table on INT UNSIGNED column
>
xintongsong commented on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-752320806
On more thing, we need to update the PR w.r.t. the community's new
formatting rules.
Please check this
xintongsong commented on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-752320177
@HuangZhenQiu,
Sorry for the late response.
I don't think need to split the 100 LoC into `ThresholdMeter`,
`TimestampBasedThresholdMeter`, and `FailureRater`.
On the
xintongsong commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r549927391
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to
xintongsong commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r549927391
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed to
leonardBang commented on pull request #14280:
URL: https://github.com/apache/flink/pull/14280#issuecomment-752319197
Could you help rebase this PR? @wangxlong The master branch merged a big
format PR which caused the conflict
zoucao closed pull request #14479:
URL: https://github.com/apache/flink/pull/14479
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-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-17855:
---
Assignee: Nicholas Jiang
> UDF with parameter Array(Row) can not work
>
[
https://issues.apache.org/jira/browse/FLINK-20800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255878#comment-17255878
]
zlzhang0122 edited comment on FLINK-20800 at 12/30/20, 3:35 AM:
-I think
[
https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-20505.
Resolution: Won't Do
As discussed, we will not support HTTP paths for the shared libs.
Instead,
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-20798:
--
Summary: Using PVC as high-availability.storageDir could not work (was:
Service temporarily
Xintong Song created FLINK-20811:
Summary: Support HTTP paths for yarn ship files/archives
Key: FLINK-20811
URL: https://issues.apache.org/jira/browse/FLINK-20811
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-20797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-20797.
-
Resolution: Duplicate
> can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir
>
[
https://issues.apache.org/jira/browse/FLINK-20797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256256#comment-17256256
]
Yang Wang commented on FLINK-20797:
---
I will close this ticket and let's keep the discussion under
[
https://issues.apache.org/jira/browse/FLINK-20797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256255#comment-17256255
]
Yang Wang commented on FLINK-20797:
---
Mounting a PVC to replace the distributed storage in HA should
[
https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256254#comment-17256254
]
Yang Wang commented on FLINK-20798:
---
Could you share the complete logs for JobManager? From the pieces
[
https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256252#comment-17256252
]
Yang Wang commented on FLINK-15656:
---
[~lublinsky] I just give some examples here. Actually, these two
[
https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256251#comment-17256251
]
Yang Wang commented on FLINK-17598:
---
I notice that you have created some tickets FLINK-20798 and
[
https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256246#comment-17256246
]
hayden zhou commented on FLINK-17598:
-
[~fly_in_gis] I am trying to deploy Flink on k8s with HA
[
https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256246#comment-17256246
]
hayden zhou edited comment on FLINK-17598 at 12/30/20, 3:07 AM:
[
https://issues.apache.org/jira/browse/FLINK-20810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiawen xiao updated FLINK-20810:
Description: related
https://issues.apache.org/jira/browse/FLINK-20386?filter=12349963
>
[
https://issues.apache.org/jira/browse/FLINK-20810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiawen xiao updated FLINK-20810:
Environment: (was: related
https://issues.apache.org/jira/browse/FLINK-20386?filter=12349963)
jiawen xiao created FLINK-20810:
---
Summary: abstract JdbcSchema structure and derive it from
JdbcDialect.
Key: FLINK-20810
URL: https://issues.apache.org/jira/browse/FLINK-20810
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256244#comment-17256244
]
Huang Xingbo commented on FLINK-20329:
--
[
https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256243#comment-17256243
]
jiawen xiao commented on FLINK-20026:
-
cc,[~jark]. WDYT?
> Jdbc connector support regular
[
https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256240#comment-17256240
]
Xue Wang commented on FLINK-20321:
--
Thank you, [~sampadsaha5]. I've worked with Avro Serdes and
[
https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256241#comment-17256241
]
jiawen xiao commented on FLINK-18654:
-
Hi,[~jark],I am happy to solve this problem .i will fix it
Jun Zhang created FLINK-20809:
-
Summary: the limit push down invalid when use filter
Key: FLINK-20809
URL: https://issues.apache.org/jira/browse/FLINK-20809
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256234#comment-17256234
]
jiawen xiao commented on FLINK-15352:
-
hi,[~phoenixjiangnan],I think this is a clear task and I am
flinkbot edited a comment on pull request #14512:
URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693
## CI report:
* ef398a6aca683bb22074d7a72abd6a328981610e Azure:
[
https://issues.apache.org/jira/browse/FLINK-20801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256230#comment-17256230
]
lafeier commented on FLINK-20801:
-
Well, I tried Async IO and it didn't meet my needs.This issue is a
V1ncentzzZ commented on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-752300734
Hi @fsk119, Would you help review this?
This is an automated message from the Apache Git Service.
To respond
flinkbot edited a comment on pull request #14512:
URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693
## CI report:
* ef398a6aca683bb22074d7a72abd6a328981610e Azure:
flinkbot edited a comment on pull request #14392:
URL: https://github.com/apache/flink/pull/14392#issuecomment-745400662
## CI report:
* Unknown: [CANCELED](TBD)
* a366565d2ef37c57eee2d17f5718b2f0e6f173a8 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20693:
Component/s: API / Python
> Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java
>
[
https://issues.apache.org/jira/browse/FLINK-20693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20693.
---
Assignee: Huang Xingbo
Resolution: Fixed
Merged to master via
1 - 100 of 322 matches
Mail list logo