gyfora commented on code in PR #342:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/342#discussion_r940969053
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -864,6 +872,23 @@ pu
morhidi commented on PR #342:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/342#issuecomment-1208987995
Thank @gyfora this was indeed missing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
morhidi commented on code in PR #342:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/342#discussion_r940967644
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -864,6 +872,23 @@ p
rkhachatryan commented on code in PR #20421:
URL: https://github.com/apache/flink/pull/20421#discussion_r940964862
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -474,9 +474,10 @@ ttl_config = StateTtlConfig \
For more fine-grained control over some special
hlteoh37 commented on PR #20245:
URL: https://github.com/apache/flink/pull/20245#issuecomment-1208983984
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-28374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao closed FLINK-28374.
---
Resolution: Fixed
> Some further improvements of blocking shuffle
>
gyfora merged PR #340:
URL: https://github.com/apache/flink-kubernetes-operator/pull/340
--
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: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-28373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao resolved FLINK-28373.
-
Resolution: Fixed
Merged into master via d6a47d897a9a4753c800b39adb17c06e154422cc
> Read a full
wsry merged PR #20457:
URL: https://github.com/apache/flink/pull/20457
--
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: issues-unsubscr...@flink.apache.o
[
https://issues.apache.org/jira/browse/FLINK-26413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-26413.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: 6c91cc5999828f0a61f8a54498bc71a581a05dd8
>
[
https://issues.apache.org/jira/browse/FLINK-26413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-26413:
Component/s: Connectors / Hive
> Hive dialect support "LOAD DATA INPATH"
> --
wuchong merged PR #19556:
URL: https://github.com/apache/flink/pull/19556
--
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: issues-unsubscr...@flink.apach
wsry commented on PR #20457:
URL: https://github.com/apache/flink/pull/20457#issuecomment-1208977942
@TanYuxin-tyx Thanks for the change. LGTM. Merging.
--
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-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27338:
-
Summary: Improve spliting file for Hive table with orc format (was:
Improve spliting file for Hive sour
[
https://issues.apache.org/jira/browse/FLINK-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27338:
-
Description:
Currently, for hive source, it'll use the hdfs block size configured with key
dfs.block.si
dependabot[bot] closed pull request #20287: Bump aws-java-sdk-s3 from 1.12.7 to
1.12.261 in /flink-connectors/flink-connector-kinesis
URL: https://github.com/apache/flink/pull/20287
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dependabot[bot] commented on PR #20287:
URL: https://github.com/apache/flink/pull/20287#issuecomment-1208977103
Looks like com.amazonaws:aws-java-sdk-s3 is up-to-date now, so this is no
longer needed.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28027:
---
Labels: pull-request-available (was: )
> Initialise Async Sink maximum number of in flight
dannycranmer merged PR #20476:
URL: https://github.com/apache/flink/pull/20476
--
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: issues-unsubscr...@flink.
sthm opened a new pull request, #20509:
URL: https://github.com/apache/flink/pull/20509
## What is the purpose of the change
Implement slow start strategy for AIMD to avoid overloading destination on
initialization.
## Brief change log
Adapt initialization of the AIMD st
luoyuxia commented on PR #20501:
URL: https://github.com/apache/flink/pull/20501#issuecomment-1208973074
@godfreyhe Thanks for your review. I have addressed all your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
luoyuxia commented on code in PR #20501:
URL: https://github.com/apache/flink/pull/20501#discussion_r940951883
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java:
##
@@ -90,6 +102,257 @@ public static Map
createCat
liming30 commented on code in PR #20405:
URL: https://github.com/apache/flink/pull/20405#discussion_r940950420
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java:
##
@@ -223,4 +223,27 @@ public Stat
[
https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-27155.
-
Resolution: Fixed
Merged as 4a0870229fc20b594eba0bccfad071a4edc3e185.
> Reduce multiple
rkhachatryan merged PR #20152:
URL: https://github.com/apache/flink/pull/20152
--
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: issues-unsubscr...@flink.
rkhachatryan commented on PR #20152:
URL: https://github.com/apache/flink/pull/20152#issuecomment-1208969905
Thank you for the contribution @zoltar9264, great work!
Glad to hear that and no worries :)
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/FLINK-28881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-28881:
-
Description:
{code:java}
2022-08-09T03:14:22.0113691Z Aug 09 03:14:22 [ERROR]
org.apache.flink
liming30 commented on code in PR #20405:
URL: https://github.com/apache/flink/pull/20405#discussion_r940948140
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java:
##
@@ -223,4 +223,27 @@ public Stat
[
https://issues.apache.org/jira/browse/FLINK-28881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-28881:
-
Labels: test-stability (was: )
> PubSubConsumingTest.testStoppingConnectorWhenDeserializationSc
[
https://issues.apache.org/jira/browse/FLINK-27597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-27597.
--
Resolution: Fixed
> Support get column statistic for Hive partition table
> --
[
https://issues.apache.org/jira/browse/FLINK-28306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-28306.
--
Resolution: Fixed
> Support get table statistic for Hive partition table
> ---
[
https://issues.apache.org/jira/browse/FLINK-28848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-28848:
--
Assignee: lincoln lee
> Introduces LOOKUP join hint to support delayed retry for lookup join
yunfengzhou-hub commented on code in PR #20454:
URL: https://github.com/apache/flink/pull/20454#discussion_r940930386
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/RegularOperatorChain.java:
##
@@ -216,24 +248,64 @@ private OperatorSnapshotFuture
yunfengzhou-hub commented on code in PR #20454:
URL: https://github.com/apache/flink/pull/20454#discussion_r940930386
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/RegularOperatorChain.java:
##
@@ -216,24 +248,64 @@ private OperatorSnapshotFuture
PatrickRen commented on code in PR #20495:
URL: https://github.com/apache/flink/pull/20495#discussion_r940929212
##
flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java:
##
@@ -68,54 +65,37 @@ public cl
PatrickRen commented on code in PR #20489:
URL: https://github.com/apache/flink/pull/20489#discussion_r940927210
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java:
##
@@ -181,6 +179,27 @@ private JdbcDmlOpti
xintongsong commented on PR #20456:
URL: https://github.com/apache/flink/pull/20456#issuecomment-1208929966
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific commen
[
https://issues.apache.org/jira/browse/FLINK-18572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577144#comment-17577144
]
Zhanghao Chen commented on FLINK-18572:
---
Verified that this is already included in
lindong28 commented on PR #20275:
URL: https://github.com/apache/flink/pull/20275#issuecomment-1208916714
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
Sxnan commented on PR #20491:
URL: https://github.com/apache/flink/pull/20491#issuecomment-1208908109
@gaoyunhaii Thanks for your comment! The PR has been updated accordingly.
Could you please take another look?
--
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-25592:
Fix Version/s: (was: 1.16.0)
> Improvement of parser, optimizer and execution for Flink Batch SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-27660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27660:
Fix Version/s: (was: 1.16.0)
> Table API support create function using customed jar
>
[
https://issues.apache.org/jira/browse/FLINK-28871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-28871:
--
Assignee: Yun Gao
> Make DPP also works if batch shuffle mode is not ALL_BLOCKING
> -
yunfengzhou-hub commented on PR #20275:
URL: https://github.com/apache/flink/pull/20275#issuecomment-1208903178
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific co
Myasuka commented on code in PR #20405:
URL: https://github.com/apache/flink/pull/20405#discussion_r940884644
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java:
##
@@ -223,4 +223,27 @@ public State
godfreyhe commented on code in PR #20497:
URL: https://github.com/apache/flink/pull/20497#discussion_r940877755
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/DynamicFilteringDependencyProcessor.java:
##
@@ -84,4 +100,10
Luning Wang created FLINK-28882:
---
Summary: ENCODE return error
Key: FLINK-28882
URL: https://issues.apache.org/jira/browse/FLINK-28882
Project: Flink
Issue Type: Improvement
Component
dianfu commented on code in PR #20499:
URL: https://github.com/apache/flink/pull/20499#discussion_r94089
##
flink-python/pyflink/datastream/__init__.py:
##
@@ -225,6 +225,9 @@
- :class:`formats.parquet.ParquetColumnarRowInputFormat`:
A :class:`connectors.file_sys
Myasuka commented on code in PR #20421:
URL: https://github.com/apache/flink/pull/20421#discussion_r940868846
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -474,9 +474,10 @@ ttl_config = StateTtlConfig \
For more fine-grained control over some special clea
Leonard Xu created FLINK-28881:
--
Summary:
PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream
test failure
Key: FLINK-28881
URL: https://issues.apache.org/jira/browse/FLINK-28881
zoltar9264 commented on PR #20152:
URL: https://github.com/apache/flink/pull/20152#issuecomment-1208878901
Thanks @rkhachatryan !
I'm very grateful for your help over the past few weeks, I've learned a lot
in it, and I'm sorry for the trouble I've caused you due to my inexperience.
--
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-27691:
---
Priority: Critical (was: Major)
> RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577122#comment-17577122
]
Leonard Xu commented on FLINK-27691:
https://dev.azure.com/leonardBang/Azure_CI/_bui
JesseAtSZ commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1208875024
@rkhachatryan
--
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
[
https://issues.apache.org/jira/browse/FLINK-28880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577117#comment-17577117
]
Huang Xingbo edited comment on FLINK-28880 at 8/9/22 3:39 AM:
[
https://issues.apache.org/jira/browse/FLINK-28880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-28880:
-
Fix Version/s: 1.15.2
1.14.6
> Fix CEP doc with wrong result of strict contig
[
https://issues.apache.org/jira/browse/FLINK-28880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-28880.
--
Resolution: Fixed
Merged into master via a08b050eb9fbea319275771fd9e95bbb025e2737
> Fix CEP d
HuangXingBo closed pull request #20508: [FLINK-28880][docs][cep] Fix wrong
result of strict contiguity of looping patterns
URL: https://github.com/apache/flink/pull/20508
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
leonardBang commented on code in PR #20495:
URL: https://github.com/apache/flink/pull/20495#discussion_r940855756
##
flink-connectors/flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/HBaseDynamicTableSource.java:
##
@@ -38,23 +39,19 @@ public HBas
flinkbot commented on PR #20508:
URL: https://github.com/apache/flink/pull/20508#issuecomment-1208871012
## CI report:
* f24ce7e938ce1740d9e47d3d620697a9b9d24bcd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28803:
---
Labels: pull-request-available (was: )
> Add Transformer and Estimator for KBinsDiscretizer
[
https://issues.apache.org/jira/browse/FLINK-28838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577116#comment-17577116
]
Qingsheng Ren edited comment on FLINK-28838 at 8/9/22 3:30 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-28838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577116#comment-17577116
]
Qingsheng Ren commented on FLINK-28838:
---
Thanks for the ticket [~aitozi]! Yeah we
zhipeng93 opened a new pull request, #139:
URL: https://github.com/apache/flink-ml/pull/139
## What is the purpose of the change
- Add Transformer and Estimator for KBinsDiscretizer[1] in Flink ML.
## Brief change log
- Added Transformer and Estimator for LinearSVC.
- Added j
[
https://issues.apache.org/jira/browse/FLINK-28699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-28699.
--
Fix Version/s: 1.16.0
Resolution: Fixed
merged in master: d9a067e5e1c8672930b0ea7d76400a1d3020a
fsk119 commented on code in PR #20493:
URL: https://github.com/apache/flink/pull/20493#discussion_r940202528
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/util/OperationExecutorFactory.java:
##
@@ -294,4 +408,64 @@ private static Lis
bgeng777 commented on code in PR #20508:
URL: https://github.com/apache/flink/pull/20508#discussion_r940855754
##
docs/content/docs/libs/cep.md:
##
@@ -754,7 +754,7 @@ The contiguity will be applied between elements accepted
into such a pattern.
To illustrate the above with an
Myasuka closed pull request #20399: [FLINK-28699][StateBackend] Native rocksdb
full snapshot in non-incremental checkpointing
URL: https://github.com/apache/flink/pull/20399
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
reswqa commented on code in PR #20333:
URL: https://github.com/apache/flink/pull/20333#discussion_r940855012
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java:
##
@@ -70,6 +71,17 @@ class SortMergeResultPartit
[
https://issues.apache.org/jira/browse/FLINK-28568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28568.
--
Resolution: Fixed
Fixed in master: 3f18cafa0581613ef9900da0478b3501617dc64f
> Implements a new lookup
[
https://issues.apache.org/jira/browse/FLINK-28568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-28568:
--
Assignee: lincoln lee
> Implements a new lookup join operator (sync mode only) with state to
bgeng777 commented on PR #20508:
URL: https://github.com/apache/flink/pull/20508#issuecomment-1208865870
LGTM
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe
godfreyhe closed pull request #20324: [FLINK-28568][table-runtime] Implements a
new lookup join operator (sync mode only) with state to eliminate the non
determinism
URL: https://github.com/apache/flink/pull/20324
--
This is an automated message from the Apache Git Service.
To respond to the
leonardBang commented on code in PR #20489:
URL: https://github.com/apache/flink/pull/20489#discussion_r940843642
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java:
##
@@ -181,6 +179,27 @@ private JdbcDmlOpt
godfreyhe commented on PR #20324:
URL: https://github.com/apache/flink/pull/20324#issuecomment-1208864940
> An irrelevant failure case of es sink
https://issues.apache.org/jira/browse/FLINK-28877
I will merge it
--
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/FLINK-28880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28880:
---
Labels: pull-request-available (was: )
> Fix CEP doc with wrong result of strict contiguity
Vancior opened a new pull request, #20508:
URL: https://github.com/apache/flink/pull/20508
## What is the purpose of the change
This PR fixes CEP doc.
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
## Does this pu
flinkbot commented on PR #20507:
URL: https://github.com/apache/flink/pull/20507#issuecomment-1208863205
## CI report:
* 9d67f8ac91de12838b909c38e995455983c5d32f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-28843.
--
Fix Version/s: 1.16.0
Resolution: Fixed
merged in master: 7f708d0ba42f727b3f8c3d77cef2108206cad
Myasuka merged PR #20484:
URL: https://github.com/apache/flink/pull/20484
--
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: issues-unsubscr...@flink.apach
Juntao Hu created FLINK-28880:
-
Summary: Fix CEP doc with wrong result of strict contiguity of
looping patterns
Key: FLINK-28880
URL: https://issues.apache.org/jira/browse/FLINK-28880
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28139:
---
Labels: pull-request-available (was: )
> Add documentation for speculative execution
>
zhuzhurk opened a new pull request, #20507:
URL: https://github.com/apache/flink/pull/20507
## What is the purpose of the change
This PR adds documentation for speculative execution.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
HuangXingBo commented on code in PR #20505:
URL: https://github.com/apache/flink/pull/20505#discussion_r940834537
##
flink-python/pyflink/datastream/formats/orc.py:
##
@@ -0,0 +1,104 @@
+
+# License
godfreyhe commented on code in PR #20501:
URL: https://github.com/apache/flink/pull/20501#discussion_r940832517
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java:
##
@@ -90,6 +102,257 @@ public static Map
createCa
gaoyunhaii commented on code in PR #20491:
URL: https://github.com/apache/flink/pull/20491#discussion_r940831093
##
docs/content/docs/dev/datastream/operators/overview.md:
##
@@ -575,6 +575,44 @@ This feature is not yet supported in Python
{{< /tab >}}
{{< /tabs>}}
+### Cach
[
https://issues.apache.org/jira/browse/FLINK-28753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28753.
--
Resolution: Fixed
Fixed in master: 0e6e4198ad84227c20e2c61c2dd8b0616324aa31
> Improve FilterIntoJoinR
libenchao commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1208843267
> I believe JdbcFilterPushdownVisitor needs to produce strings or some
equivalent data, so that it can be used by
JdbcDynamicTableSource::getScanRuntimeProvider, how should I make use
Grypse commented on PR #20467:
URL: https://github.com/apache/flink/pull/20467#issuecomment-1208842402
The scheduler can be setting with schedulerName in podTemplate simply,I
think there is no need to add options to kubernetes config.
`podTemplate:
apiVersion: v1
kin
godfreyhe closed pull request #20432: [FLINK-28753][table-planner] Improve
FilterIntoJoinRule which could push some predicates to another side
URL: https://github.com/apache/flink/pull/20432
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-28183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28183.
---
Resolution: Fixed
Merged to master via 5506930cc79eb131c66c5df0320045ad53437dce
> flink-python is lacking s
[
https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577090#comment-17577090
]
Huang Xingbo edited comment on FLINK-24095 at 8/9/22 2:24 AM:
[
https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-24095:
-
Affects Version/s: 1.16.0
> Elasticsearch7DynamicSinkITCase.testWritingDocuments fails due to so
[
https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577090#comment-17577090
]
Huang Xingbo commented on FLINK-24095:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-28877.
Resolution: Duplicate
> Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey case fail
dianfu closed pull request #20470: [FLINK-28183][python] Model python test
dependencies in Maven
URL: https://github.com/apache/flink/pull/20470
--
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 s
[
https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-28860:
Assignee: Xuannan Su
> CacheITCase.testBatchProduceCacheStreamConsume failed
> --
[
https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577084#comment-17577084
]
Xuannan Su commented on FLINK-28860:
[~hxbks2ks]I will take a look at it. Could you
[
https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577082#comment-17577082
]
Huang Xingbo commented on FLINK-28529:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577080#comment-17577080
]
Huang Xingbo commented on FLINK-28855:
--
https://dev.azure.com/apache-flink/apache-f
1 - 100 of 474 matches
Mail list logo
