RocMarshal commented on PR #20715:
URL: https://github.com/apache/flink/pull/20715#issuecomment-1236062335
Hi, @snuyanzin Thank you very much for the comments.
I updated based on your suggestions . PTAL.
CC @gaoyunhaii
--
This is an automated message from the Apache Git Service.
To
LadyForest closed pull request #280: [FLINK-29129] Try best to push down value
filters
URL: https://github.com/apache/flink-table-store/pull/280
--
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
LadyForest closed pull request #280: [FLINK-29129] Try best to push down value
filters
URL: https://github.com/apache/flink-table-store/pull/280
--
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
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962107812
##
flink-java/src/test/java/org/apache/flink/api/java/operator/MaxByOperatorTest.java:
##
@@ -65,75 +67,76 @@ public void testMaxByKeyFieldsDataset() {
try {
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962107474
##
flink-java/src/test/java/org/apache/flink/api/java/operator/FirstNOperatorTest.java:
##
@@ -143,34 +140,32 @@ public void testGroupedSortedFirstN() {
try
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962107474
##
flink-java/src/test/java/org/apache/flink/api/java/operator/FirstNOperatorTest.java:
##
@@ -143,34 +140,32 @@ public void testGroupedSortedFirstN() {
try
LadyForest closed pull request #280: [FLINK-29129] Try best to push down value
filters
URL: https://github.com/apache/flink-table-store/pull/280
--
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
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102803
##
flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java:
##
@@ -144,23 +130,24 @@ public void testNestedFileRead() throws IOException {
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102685
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -970,21 +939,21 @@ public void testScanOrder() throws Exception {
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102573
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -699,24 +668,24 @@ public void testReadSparseWithMask() throws Exception {
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102559
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -660,24 +629,24 @@ public void testReadSparseWithPositionSetter() throws
E
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102514
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -547,28 +516,28 @@ public void testDoubleFields() throws Exception {
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102458
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -460,28 +431,26 @@ public void testIntegerFields() throws Exception {
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102253
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -225,22 +213,20 @@ public void ignoreMultiCharPrefixComments() throws
Exce
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962102253
##
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java:
##
@@ -225,22 +213,20 @@ public void ignoreMultiCharPrefixComments() throws
Exce
HarshaR99 commented on PR #20690:
URL: https://github.com/apache/flink/pull/20690#issuecomment-1236042169
> it's not a typo..
@themoah good observation, but if you look for their specific meanings, I
think you might agree that this typo needs to be changed.
--
This is an automated
cun8cun8 commented on code in PR #20742:
URL: https://github.com/apache/flink/pull/20742#discussion_r962093570
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -62,17 +62,17 @@ class StreamingW
cun8cun8 commented on code in PR #20742:
URL: https://github.com/apache/flink/pull/20742#discussion_r962093570
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -62,17 +62,17 @@ class StreamingW
RocMarshal commented on code in PR #20715:
URL: https://github.com/apache/flink/pull/20715#discussion_r962088033
##
flink-java/src/test/java/org/apache/flink/api/java/io/CSVReaderTest.java:
##
@@ -40,258 +40,262 @@
import org.apache.flink.types.StringValue;
import org.apache.f
lincoln-lil commented on PR #20743:
URL: https://github.com/apache/flink/pull/20743#issuecomment-1235977213
@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-25448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25448:
---
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-25452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25452:
---
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27384:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
xuyangzhong commented on PR #20705:
URL: https://github.com/apache/flink/pull/20705#issuecomment-1235706377
@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-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599606#comment-17599606
]
Peleg Tsadok commented on FLINK-28653:
--
[~chesnay] I created a new savepoint after
flinkbot commented on PR #20743:
URL: https://github.com/apache/flink/pull/20743#issuecomment-1235615778
## CI report:
* dbd1c1cf4e0db5b9ed85614c2e0af5afa6b87f42 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil opened a new pull request, #20743:
URL: https://github.com/apache/flink/pull/20743
## What is the purpose of the change
Add two more cases to verify the conflict of multiple LOOKUP hints, which
should be consistent with current join hints (the coming doc by #20513 will
illust
nielsbasjes commented on PR #28:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/28#issuecomment-1235589800
Yes I agree. Let's just close this. And after 1.16.0 has been release do a
"great migration".
@zentl If you guys also agree then please close this one.
--
This
[
https://issues.apache.org/jira/browse/FLINK-29165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599525#comment-17599525
]
Gaurav Miglani commented on FLINK-29165:
[~matyas] can you please have a look i
tisonkun commented on code in PR #20725:
URL: https://github.com/apache/flink/pull/20725#discussion_r961732654
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssigner.java:
##
@@ -34,7 +33,7 @@
* reade
zentol commented on PR #28:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/28#issuecomment-1235566590
Personally I'm inclined to wait until the 1.16.0 feature branch was cut, and
then do the sync. Maybe even until 1.16.0 is released.
--
This is an automated message fro
snuyanzin commented on PR #20742:
URL: https://github.com/apache/flink/pull/20742#issuecomment-1235562818
Please make sure that you use and fill in the PR template.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
snuyanzin commented on code in PR #20742:
URL: https://github.com/apache/flink/pull/20742#discussion_r961734554
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/StreamingWithStateTestBase.scala:
##
@@ -62,17 +62,17 @@ class Streaming
[
https://issues.apache.org/jira/browse/FLINK-29186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rishabh Maurya closed FLINK-29186.
--
Resolution: Abandoned
> Store summarized results in internal nodes of BKD for time series poin
[
https://issues.apache.org/jira/browse/FLINK-29186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rishabh Maurya updated FLINK-29186:
---
Description: (was: Time series points have a timestamp, measurement and
dimensions assoc
tisonkun commented on code in PR #20725:
URL: https://github.com/apache/flink/pull/20725#discussion_r961724761
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumState.java:
##
@@ -36,63 +33,16 @@ public c
tisonkun commented on code in PR #20725:
URL: https://github.com/apache/flink/pull/20725#discussion_r961722004
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumState.java:
##
@@ -36,63 +33,16 @@ public c
[
https://issues.apache.org/jira/browse/FLINK-28968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599507#comment-17599507
]
Godfrey He commented on FLINK-28968:
Thanks for your effort, I will close it.
> Rel
[
https://issues.apache.org/jira/browse/FLINK-28968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-28968.
--
Resolution: Fixed
> Release Testing: Verify FLIP-234 LOOKUP Hint
> ---
[
https://issues.apache.org/jira/browse/FLINK-28968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599506#comment-17599506
]
xuyang commented on FLINK-28968:
Hi, [~godfreyhe] . The test work is finished.
> Releas
fsk119 commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r961701727
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/set-op.md:
##
@@ -0,0 +1,95 @@
+---
+title: "Set Operations"
+weight: 5
+type: docs
+---
+
+
+# Se
Rishabh Maurya created FLINK-29186:
--
Summary: Store summarized results in internal nodes of BKD for
time series points
Key: FLINK-29186
URL: https://issues.apache.org/jira/browse/FLINK-29186
Project:
fsk119 commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r961242871
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/overview.md:
##
@@ -0,0 +1,163 @@
+---
+title: "Overview"
+weight: 1
+type: docs
+aliases:
+- /dev
[
https://issues.apache.org/jira/browse/FLINK-28969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-28969.
---
Resolution: Fixed
> Release Testing: Verify FLIP-229 Join Hints for Flink SQL Batch
> --
ChengkaiYang2022 commented on code in PR #20724:
URL: https://github.com/apache/flink/pull/20724#discussion_r961687243
##
docs/content.zh/docs/dev/table/types.md:
##
@@ -1179,26 +1127,21 @@ DataTypes.MULTISET(t)
{{< /tab >}}
{{< /tabs >}}
-The type can be declared using `MUL
ChengkaiYang2022 commented on code in PR #20724:
URL: https://github.com/apache/flink/pull/20724#discussion_r961662302
##
docs/content.zh/docs/dev/table/types.md:
##
@@ -333,11 +325,11 @@ DataTypes.VARBINARY(n)
DataTypes.BYTES()
```
-**Bridging to JVM Types**
+**JVM Types桥接*
[
https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28981.
---
Resolution: Done
> Release Testing: Verify FLIP-245 sources speculative execution
>
[
https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599499#comment-17599499
]
Zhu Zhu commented on FLINK-28981:
-
Thanks for helping with this release testing! [~33736
[
https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599498#comment-17599498
]
Godfrey He commented on FLINK-28981:
can this issue be closed ? [~zhuzh] [~337361...
Sxnan commented on PR #20534:
URL: https://github.com/apache/flink/pull/20534#issuecomment-1235519026
@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.
To
pnowojski commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r961619833
##
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java:
##
@@ -282,4 +282,21 @@ public enum VertexDescriptionMode {
.with
lindong28 merged PR #148:
URL: https://github.com/apache/flink-ml/pull/148
--
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.apac
zhipeng93 commented on code in PR #148:
URL: https://github.com/apache/flink-ml/pull/148#discussion_r961545453
##
flink-ml-python/pyflink/ml/lib/clustering/agglomerativeclustering.py:
##
@@ -0,0 +1,135 @@
+#
lindong28 commented on code in PR #148:
URL: https://github.com/apache/flink-ml/pull/148#discussion_r961557819
##
flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/agglomerativeclustering/AgglomerativeClusteringParams.java:
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Ap
zhipeng93 commented on code in PR #148:
URL: https://github.com/apache/flink-ml/pull/148#discussion_r961545453
##
flink-ml-python/pyflink/ml/lib/clustering/agglomerativeclustering.py:
##
@@ -0,0 +1,135 @@
+#
godfreyhe commented on code in PR #20705:
URL: https://github.com/apache/flink/pull/20705#discussion_r961527995
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/LookupJoinTest.scala:
##
@@ -752,7 +752,8 @@ class LookupJoinTest
SwimSweet commented on PR #20671:
URL: https://github.com/apache/flink/pull/20671#issuecomment-1235320037
@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.
mxm commented on PR #15675:
URL: https://github.com/apache/flink/pull/15675#issuecomment-1235312010
@yoav-rosenthal AFAIK this has only been ported to Flink 1.14.0 and later.
You can see that in the Fix Version of the associated Jira Ticket:
https://issues.apache.org/jira/browse/FLINK-10052
zhipeng93 commented on code in PR #148:
URL: https://github.com/apache/flink-ml/pull/148#discussion_r961513789
##
flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/agglomerativeclustering/AgglomerativeClustering.java:
##
@@ -0,0 +1,421 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599374#comment-17599374
]
Yunhong Zheng commented on FLINK-28981:
---
Hi, [~zhuzh], [~hxb], [~godfreyhe] . I ha
HuangXingBo commented on PR #20685:
URL: https://github.com/apache/flink/pull/20685#issuecomment-1235304621
https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=2064&view=logs&j=fba17979-6d2e-591d-72f1-97cf42797c11&t=727942b6-6137-54f7-1ef9-e66e706ea068
--
This is an automated
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961478878
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileFormatFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
godfreyhe commented on code in PR #20697:
URL: https://github.com/apache/flink/pull/20697#discussion_r961506252
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala:
##
@@ -193,17 +193,22 @@ class FlinkPlannerImpl(
pr
SmirAlex commented on PR #20734:
URL: https://github.com/apache/flink/pull/20734#issuecomment-1235298416
Successful pipeline -
https://dev.azure.com/asmirnov1/Flink/_build/results?buildId=35&view=results
--
This is an automated message from the Apache Git Service.
To respond to the messag
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961501655
##
flink-table-store-format/src/test/java/org/apache/flink/table/store/format/parquet/ParquetFileFormatTest.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-29175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29175:
---
Labels: pull-request-available (was: )
> Add documents for KBinsDiscretizer, VectorIndexer,
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961501104
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetUtil.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache So
zhipeng93 opened a new pull request, #152:
URL: https://github.com/apache/flink-ml/pull/152
…enizer and VectorIndexer
This PR adds documents for four feature engineering algorithms.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961499971
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetUtil.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache So
lincoln-lil commented on PR #20727:
URL: https://github.com/apache/flink/pull/20727#issuecomment-1235295710
rebase master for the docker name fix
--
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 t
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961498030
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileStatsExtractor.java:
##
@@ -0,0 +1,204 @@
+/*
+ * Licensed t
liyubin117 commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961497413
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileFormatFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to t
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961494794
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileFormat.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apa
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961490822
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileFormat.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-29179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ChunJi updated FLINK-29179:
---
Description:
The page url is
[https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/con
[
https://issues.apache.org/jira/browse/FLINK-29179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ChunJi updated FLINK-29179:
---
Description:
The page url is
[https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/con
liyubin117 commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961481427
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileFormatFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to t
SteNicholas commented on code in PR #134:
URL: https://github.com/apache/flink-table-store/pull/134#discussion_r961478878
##
flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetFileFormatFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-27748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599355#comment-17599355
]
Konstantin Knauf commented on FLINK-27748:
--
[~long jiang] Better late than neve
[
https://issues.apache.org/jira/browse/FLINK-29179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599354#comment-17599354
]
ChunJi commented on FLINK-29179:
hi,[~jark] ,i have done this translation,please assign
[
https://issues.apache.org/jira/browse/FLINK-29180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junhan Yang closed FLINK-29180.
---
Fix Version/s: 1.16.0
Resolution: Fixed
> Show subtask metrics as default in vertex detail
>
[
https://issues.apache.org/jira/browse/FLINK-29185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29185:
--
Component/s: Connectors / Hive
> Failed to execute USING JAR in Hive Dialect
> ---
[
https://issues.apache.org/jira/browse/FLINK-29180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599351#comment-17599351
]
Junhan Yang commented on FLINK-29180:
-
master (1.16): 121e63e8702e449559dc548fc29b4e
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599350#comment-17599350
]
Xingbo Huang commented on FLINK-28941:
--
Thanks for the investigations [~gaoyunhaii]
[
https://issues.apache.org/jira/browse/FLINK-29185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29185:
--
Affects Version/s: 1.16.0
> Failed to execute USING JAR in Hive Dialect
>
Shengkai Fang created FLINK-29185:
-
Summary: Failed to execute USING JAR in Hive Dialect
Key: FLINK-29185
URL: https://issues.apache.org/jira/browse/FLINK-29185
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-29184:
-
Summary: SQL Gateway should remove the downloaded resources
Key: FLINK-29184
URL: https://issues.apache.org/jira/browse/FLINK-29184
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599349#comment-17599349
]
Yun Gao commented on FLINK-28941:
-
[~hxb] I have a double check with [~yunfengzhou] offl
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599349#comment-17599349
]
Yun Gao edited comment on FLINK-28941 at 9/2/22 9:05 AM:
-
[~hxb]
[
https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599348#comment-17599348
]
Shengkai Fang commented on FLINK-28953:
---
Thanks for your great work.
> BEGIN S
ganlute commented on PR #20542:
URL: https://github.com/apache/flink/pull/20542#issuecomment-1235255529
@MartijnVisser could you please help me review the changes？Thank you.😄
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
yangjunhan merged PR #20737:
URL: https://github.com/apache/flink/pull/20737
--
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.ap
yangjunhan commented on PR #20737:
URL: https://github.com/apache/flink/pull/20737#issuecomment-1235254702
> LGTM, +1 for merging.
Thank you for the response. CI passed, so I am merging it now.
--
This is an automated message from the Apache Git Service.
To respond to the messag
[
https://issues.apache.org/jira/browse/FLINK-25325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599340#comment-17599340
]
Matthias Pohl commented on FLINK-25325:
---
[~hxb] I feel like it should be ok to con
Sxnan commented on PR #20534:
URL: https://github.com/apache/flink/pull/20534#issuecomment-1235245765
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599324#comment-17599324
]
Xingbo Huang commented on FLINK-29153:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunfeng Zhou updated FLINK-28941:
-
Priority: Blocker (was: Critical)
> Savepoint ignores MaxConcurrentCheckpoint limit in aligned
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599325#comment-17599325
]
Xingbo Huang commented on FLINK-29153:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599322#comment-17599322
]
Xingbo Huang commented on FLINK-28941:
--
[https://dev.azure.com/apache-flink/apache-
zhipeng93 commented on code in PR #150:
URL: https://github.com/apache/flink-ml/pull/150#discussion_r961445127
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/idf/IDFModel.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ *
1 - 100 of 145 matches
Mail list logo
