Myasuka commented on code in PR #20420:
URL: https://github.com/apache/flink/pull/20420#discussion_r937369884
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescaleCheckpointManuallyITCase.java:
##
@@ -150,54 +137,33 @@ public void
godfreyhe commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937368986
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java:
##
@@ -0,0 +1,184 @@
+/*
+ * Licensed to the Apache
wangqinghuan opened a new pull request, #20448:
URL: https://github.com/apache/flink/pull/20448
This pr introduces an explainLineage function to get field-level lineage
relationship about Flink SQL task.
For example,
```
create table src (a String,b String, c String) with (
[
https://issues.apache.org/jira/browse/FLINK-28796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-28796:
Description:
SQL Gateway supports various clients: sql client, rest, hiveserver2, etc. Given
the
Wencong Liu created FLINK-28796:
---
Summary: Add Statement Completement API for sql gateway rest
endpoint
Key: FLINK-28796
URL: https://issues.apache.org/jira/browse/FLINK-28796
Project: Flink
godfreyhe commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937365940
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java:
##
@@ -26,30 +26,49 @@
import
Tartarus0zm commented on code in PR #20392:
URL: https://github.com/apache/flink/pull/20392#discussion_r937356970
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TableSinkITCase.scala:
##
@@ -192,4 +193,41 @@ class
flinkbot commented on PR #20447:
URL: https://github.com/apache/flink/pull/20447#issuecomment-1204770675
## CI report:
* 76a2792d897bf3f6591ade52756bb8714259a963 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hehuiyuan closed pull request #20425: [FLINK-28750][Hive]Add field comment
parse for hive ddl
URL: https://github.com/apache/flink/pull/20425
--
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
hehuiyuan commented on PR #20425:
URL: https://github.com/apache/flink/pull/20425#issuecomment-1204763509
@luoyuxia thanks. It shoud have been supported.
--
This is
SmirAlex opened a new pull request, #20447:
URL: https://github.com/apache/flink/pull/20447
## What is the purpose of the change
This pull request introduces support of lookup join using
FullCachingLookupProvider that uses InputFormats for data loading. Also it
contains
flinkbot commented on PR #20446:
URL: https://github.com/apache/flink/pull/20446#issuecomment-1204751398
## CI report:
* 791f77044d41d8e6dd0d86412dac383e42a9bb05 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
luoyuxia commented on PR #20060:
URL: https://github.com/apache/flink/pull/20060#issuecomment-1204743277
@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-28795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28795:
---
Labels: pull-request-available (was: )
> Unstable test for
luoyuxia opened a new pull request, #20446:
URL: https://github.com/apache/flink/pull/20446
## What is the purpose of the change
Fix unstable test for HiveDialectQueryITCase#testInsertDirectory
## Brief change log
Wait the inserting finish before querying the table.
luoyuxia created FLINK-28795:
Summary: Unstable test for
HiveDialectQueryITCase#testInsertDirectory
Key: FLINK-28795
URL: https://issues.apache.org/jira/browse/FLINK-28795
Project: Flink
Issue
pltbkd commented on PR #20374:
URL: https://github.com/apache/flink/pull/20374#issuecomment-1204737427
Hi @godfreyhe ,
Thanks for the suggestions!
I suppose I've resolved most of the comments, and the failover case is
coming soon. Would you please take another look?
--
This is an
fsk119 commented on PR #20334:
URL: https://github.com/apache/flink/pull/20334#issuecomment-1204735914
@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.
luoyuxia commented on PR #20394:
URL: https://github.com/apache/flink/pull/20394#issuecomment-1204734039
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
flinkbot commented on PR #20445:
URL: https://github.com/apache/flink/pull/20445#issuecomment-1204732058
## CI report:
* df3eaa0cfc0fd1b65d7ec0b380ea1bc2ab75bd37 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pltbkd commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937324901
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java:
##
@@ -0,0 +1,183
pltbkd commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937326667
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java:
##
@@ -0,0 +1,183
pltbkd commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937325378
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperatorTest.java:
##
@@ -0,0
pltbkd commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937324901
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java:
##
@@ -0,0 +1,183
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-28786:
Description:
I have tested it with 2 m1 machines. i will reproduce the bug 100%.
1.m1 machine
macos
reswqa opened a new pull request, #20445:
URL: https://github.com/apache/flink/pull/20445
## What is the purpose of the change
*HsSubpartitionView calculate backlog no less than true value*
## Brief change log
- *Change logical of calculate backlog in
swuferhong commented on code in PR #20432:
URL: https://github.com/apache/flink/pull/20432#discussion_r937319412
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/JoinITCase.scala:
##
@@ -66,6 +68,29 @@ class JoinITCase(state:
SmirAlex commented on PR #20382:
URL: https://github.com/apache/flink/pull/20382#issuecomment-1204717241
@PatrickRen There were multiple failed pipelines, but they were because of
unrelated issues. Latest pipeline was successful -
pltbkd commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937316474
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java:
##
@@ -0,0 +1,184 @@
+/*
+ * Licensed to the Apache
yunfengzhou-hub commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r937314000
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.java:
##
@@ -0,0
godfreyhe commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937312617
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java:
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-28794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28794:
---
Labels: pull-request-available (was: )
> Publish flink-table-store snapshot artifacts
>
JingsongLi opened a new pull request, #261:
URL: https://github.com/apache/flink-table-store/pull/261
It is better to publish the Maven artifacts, so that downstream Java
projects can use this.
--
This is an automated message from the Apache Git Service.
To respond to the message,
lindong28 commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r937256425
##
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactlyOnceITCase.java:
##
@@ -378,6 +373,10 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-28793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574996#comment-17574996
]
WeiNan Zhao commented on FLINK-28793:
-
hi, [~fsk119]. please assign to me . thanks.
> Allow to
godfreyhe commented on code in PR #20374:
URL: https://github.com/apache/flink/pull/20374#discussion_r937308705
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java:
##
@@ -0,0
Jingsong Lee created FLINK-28794:
Summary: Publish flink-table-store snapshot artifacts
Key: FLINK-28794
URL: https://issues.apache.org/jira/browse/FLINK-28794
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575006#comment-17575006
]
Stephan Weinwurm commented on FLINK-28747:
--
Yes, you're right, that seems like protobuf
gaoyunhaii commented on PR #20374:
URL: https://github.com/apache/flink/pull/20374#issuecomment-1204703556
@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
[
https://issues.apache.org/jira/browse/FLINK-28769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575001#comment-17575001
]
Zhu Zhu commented on FLINK-28769:
-
Loos to me the the specified name does work after checking the code
flinkbot commented on PR #20444:
URL: https://github.com/apache/flink/pull/20444#issuecomment-1204701319
## CI report:
* cc26779be4d6fcd2e160327da83345c72a3c63d0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575004#comment-17575004
]
Yunhong Zheng commented on FLINK-28493:
---
Hi [~godfreyhe] , could you assign this to me. Thanks!
>
[
https://issues.apache.org/jira/browse/FLINK-28793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28793:
---
Labels: pull-request-available (was: )
> Allow to GetInfo for HiveServer2 Endpoint
>
chaozwn opened a new pull request, #20444:
URL: https://github.com/apache/flink/pull/20444
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-28708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28708.
--
Resolution: Fixed
Fixed in master: ae186e8650f137d624812c79f1bc33325e72
> Introduce planner
godfreyhe closed pull request #20388: [FLINK-28708][table-planner] Introduce
planner rules to optimize dpp pattern
URL: https://github.com/apache/flink/pull/20388
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
godfreyhe commented on PR #20388:
URL: https://github.com/apache/flink/pull/20388#issuecomment-1204693707
merged
--
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
xintongsong commented on code in PR #20426:
URL: https://github.com/apache/flink/pull/20426#discussion_r937295256
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionType.java:
##
@@ -196,4 +196,8 @@ public boolean isBounded() {
luoyuxia commented on PR #20425:
URL: https://github.com/apache/flink/pull/20425#issuecomment-1204689351
I haven't checked. But I go through the source code, and I think It should
have been supported.
--
This is an automated message from the Apache Git Service.
To respond to the
Shengkai Fang created FLINK-28793:
-
Summary: Allow to GetInfo for HiveServer2 Endpoint
Key: FLINK-28793
URL: https://issues.apache.org/jira/browse/FLINK-28793
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28492.
--
Resolution: Fixed
Fixed in master: 8236644816a8070499ff4327b7ee71cbb4660afa
> Support "ANALYZE
godfreyhe closed pull request #20363: [FLINK-28492][table-planner] Support
"ANALYZE TABLE" execution
URL: https://github.com/apache/flink/pull/20363
--
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
JasonLeeCoding commented on PR #20327:
URL: https://github.com/apache/flink/pull/20327#issuecomment-1204686180
@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
swuferhong commented on code in PR #20303:
URL: https://github.com/apache/flink/pull/20303#discussion_r937292379
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/MultiJoinOptimizeTest.scala:
##
@@ -0,0 +1,170 @@
+/*
+ *
reswqa commented on PR #20433:
URL: https://github.com/apache/flink/pull/20433#issuecomment-1204683732
@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.
luoyuxia commented on code in PR #20394:
URL: https://github.com/apache/flink/pull/20394#discussion_r937290113
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java:
##
@@ -441,6 +441,61 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-28161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-28161.
Fix Version/s: 1.16.0
Resolution: Done
master (1.16):
xintongsong closed pull request #20418: [FLINK-28161][sql-gateway]Introduce the
session related API for REST endpoint
URL: https://github.com/apache/flink/pull/20418
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
deadwind4 commented on PR #18469:
URL: https://github.com/apache/flink/pull/18469#issuecomment-1204663752
@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
lsyldliu commented on code in PR #20392:
URL: https://github.com/apache/flink/pull/20392#discussion_r937274957
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TableSinkITCase.scala:
##
@@ -192,4 +193,41 @@ class
lsyldliu commented on code in PR #20361:
URL: https://github.com/apache/flink/pull/20361#discussion_r937269900
##
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/AddRemoteJarITCase.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Licensed to
lsyldliu commented on PR #20442:
URL: https://github.com/apache/flink/pull/20442#issuecomment-1204653044
@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-28571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang resolved FLINK-28571.
---
Resolution: Fixed
fixed via df58dbee68131c967ce927825cd710280cfda1ce
> Add AlgoOperator
zhipeng93 merged PR #132:
URL: https://github.com/apache/flink-ml/pull/132
--
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:
zhipeng93 commented on PR #132:
URL: https://github.com/apache/flink-ml/pull/132#issuecomment-1204646476
Thanks for the update @taosiyuan163 . 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
luoyuxia commented on PR #20060:
URL: https://github.com/apache/flink/pull/20060#issuecomment-1204640387
@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.
rkhachatryan commented on PR #20404:
URL: https://github.com/apache/flink/pull/20404#issuecomment-1204559117
Thanks a lot for the fix @fredia
Could you please briefly describe the root cause of the failure in the
ticket?
Besides of changing the source, this PR refactors the
[
https://issues.apache.org/jira/browse/FLINK-24457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24457:
---
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-22741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22741:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-27775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27775:
---
Labels: auto-deprioritized-major features (was: features stale-major)
Priority: Minor
[
https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26465:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-24731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24731:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24482:
---
Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor
test-stability
rkhachatryan commented on code in PR #20103:
URL: https://github.com/apache/flink/pull/20103#discussion_r937093155
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java:
##
@@ -517,7 +527,16 @@ public void failJobDueToTaskFailure(
[
https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28341:
---
Labels: comment pull-request-available starter (was: comment starter)
> Fix comment in
flinkbot commented on PR #20443:
URL: https://github.com/apache/flink/pull/20443#issuecomment-1204429889
## CI report:
* 7dd394348b817468a5f58bdde3c8b93b4c628022 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ravening opened a new pull request, #20443:
URL: https://github.com/apache/flink/pull/20443
The MIN value should be -128 and max value is 127
## What is the purpose of the change
Change the Byte min and max values in the description
## Verifying this
rkhachatryan commented on PR #20103:
URL: https://github.com/apache/flink/pull/20103#issuecomment-1204372419
Sorry for the delay @zoltar9264 .
I still don't see the changes when running locally (commit SHA shown in the
UI: 7259856).
In the logs, I see messages like this:
```
snuyanzin commented on PR #19916:
URL: https://github.com/apache/flink/pull/19916#issuecomment-1204345414
@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
RyanSkraba commented on PR #18133:
URL: https://github.com/apache/flink/pull/18133#issuecomment-1204317676
I'd love to see this in 1.16! I'm currently with limited connection, but
I'll get this updated to 1.11.1 within the week.
--
This is an automated message from the Apache Git
flinkbot commented on PR #20442:
URL: https://github.com/apache/flink/pull/20442#issuecomment-1204291752
## CI report:
* c62d95bef2afa52900c79eb9ffc584c8de0b0d01 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu commented on PR #17654:
URL: https://github.com/apache/flink/pull/17654#issuecomment-1204284975
Continuing this work in https://github.com/apache/flink/pull/20442, this pr
will be closed.
--
This is an automated message from the Apache Git Service.
To respond to the message,
lsyldliu opened a new pull request, #20442:
URL: https://github.com/apache/flink/pull/20442
## What is the purpose of the change
Add array,map,row types support for parquet vectorized reader
## Brief change log
- *Add array,map,row types support for parquet
maver1ck commented on code in PR #20235:
URL: https://github.com/apache/flink/pull/20235#discussion_r936922685
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerDialect.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed
qingwei91 commented on code in PR #20235:
URL: https://github.com/apache/flink/pull/20235#discussion_r936919123
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerDialect.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed
snuyanzin commented on PR #20409:
URL: https://github.com/apache/flink/pull/20409#issuecomment-1204197520
Looks like the issue is with unsused imports (should be removed after
running `mvn spotless:apply`)
After that it compiles ok
--
This is an automated message from the Apache Git
wuchong commented on PR #20060:
URL: https://github.com/apache/flink/pull/20060#issuecomment-1204109772
@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.
wuchong commented on code in PR #20334:
URL: https://github.com/apache/flink/pull/20334#discussion_r936663070
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java:
##
@@ -587,6 +592,20 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27292.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master
[
https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-27292:
--
Assignee: jjiey
> Translate the "Data Type Extraction" section of "Data Types" in to
MartijnVisser merged PR #20316:
URL: https://github.com/apache/flink/pull/20316
--
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:
[
https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574752#comment-17574752
]
Till Rohrmann commented on FLINK-28747:
---
I think this is Protobuf's behaviour. If Protobuf sees
SmirAlex commented on PR #20382:
URL: https://github.com/apache/flink/pull/20382#issuecomment-1204035787
@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-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574747#comment-17574747
]
Rakesh Venkatesh commented on FLINK-28341:
--
[~shenjiaqi] can I work on this?
> Fix comment in
[
https://issues.apache.org/jira/browse/FLINK-28792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28792:
--
Assignee: Gyula Fora
> Upgrade to JOSDK 3.1.0
> --
>
>
swuferhong commented on code in PR #20303:
URL: https://github.com/apache/flink/pull/20303#discussion_r936678209
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRule.java:
##
@@ -0,0 +1,552 @@
+/*
+ *
lincoln-lil commented on code in PR #20393:
URL: https://github.com/apache/flink/pull/20393#discussion_r936658329
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/StreamNonDeterministicUpdatePlanVisitor.java:
##
@@ -0,0 +1,1009 @@
[
https://issues.apache.org/jira/browse/FLINK-28791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28791.
Resolution: Fixed
master: 9efd97e05717181ee9b5489cddc27b6351127e38
>
zentol merged PR #20440:
URL: https://github.com/apache/flink/pull/20440
--
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:
[
https://issues.apache.org/jira/browse/FLINK-24718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24718:
---
Summary: Update AVRO dependency to 1.11.1 (was: Update AVRO dependency to
latest version)
1 - 100 of 277 matches
Mail list logo
