libenchao commented on code in PR #23849:
URL: https://github.com/apache/flink/pull/23849#discussion_r1416754135
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java:
##
@@ -136,6 +158,10 @@ public URLClassLoader
caodizhou commented on PR #23842:
URL: https://github.com/apache/flink/pull/23842#issuecomment-1842266742
@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-33761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Litvak updated FLINK-33761:
-
Description:
Following [https://flink.apache.org/how-to-contribute/contribute-code/,] I
would
[
https://issues.apache.org/jira/browse/FLINK-33761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Litvak updated FLINK-33761:
-
Component/s: Connectors / JDBC
> Snowflake as JDBC source
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Litvak updated FLINK-33761:
-
Description:
Following [https://flink.apache.org/how-to-contribute/contribute-code/,] I can
[
https://issues.apache.org/jira/browse/FLINK-33761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Litvak updated FLINK-33761:
-
Issue Type: New Feature (was: Bug)
> Snowflake as JDBC source
>
>
>
Boris Litvak created FLINK-33761:
Summary: Snowflake as JDBC source
Key: FLINK-33761
URL: https://issues.apache.org/jira/browse/FLINK-33761
Project: Flink
Issue Type: Bug
xiangforever2014 commented on PR #23253:
URL: https://github.com/apache/flink/pull/23253#issuecomment-1842188948
> Hi @xiangforever2014 @masteryhx sorry for jumping in... And I'm wondering
if we could use the capital '-D' for short option? Or I suggest we do not leave
any short option for
xiangforever2014 commented on code in PR #23253:
URL: https://github.com/apache/flink/pull/23253#discussion_r1416745308
##
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java:
##
@@ -188,6 +207,21 @@ CompletableFuture triggerSavepoint(
*/
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1842179446
@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.
flinkbot commented on PR #23882:
URL: https://github.com/apache/flink/pull/23882#issuecomment-1842175348
## CI report:
* bf391fd5e7547df3e574138b264cb7802f150c62 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
swuferhong opened a new pull request, #23882:
URL: https://github.com/apache/flink/pull/23882
## What is the purpose of the change
When reading the code about json format, I found the test classes
`JsonRowDeserializationSchemaTest` and `JsonRowSerializationSchemaTest`
jeyhunkarimov commented on PR #23877:
URL: https://github.com/apache/flink/pull/23877#issuecomment-1842153994
Hi @twalthr could you please review this PR?
--
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
xuyang created FLINK-33760:
--
Summary: Group Window agg has different result when only consuming
-D records while using or not using minibatch
Key: FLINK-33760
URL: https://issues.apache.org/jira/browse/FLINK-33760
flinkbot commented on PR #23881:
URL: https://github.com/apache/flink/pull/23881#issuecomment-1842150254
## CI report:
* beeb17b4d54d2c2ed0ea61df6e07892bc792e2e0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33759:
---
Labels: pull-request-available (was: )
> flink parquet writer support write nested array
LoveHeat opened a new pull request, #23881:
URL: https://github.com/apache/flink/pull/23881
## What is the purpose of the change
see: [FLINK-33759](https://issues.apache.org/jira/browse/FLINK-33759)
## Brief change log
*(for example:)*
- *The TaskInfo is
caodizhou commented on PR #23842:
URL: https://github.com/apache/flink/pull/23842#issuecomment-1842126287
@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-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
[
https://issues.apache.org/jira/browse/FLINK-33752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33752.
-
Resolution: Fixed
> When Duration is greater than or equal to 1 day, the display unit is ms.
>
[
https://issues.apache.org/jira/browse/FLINK-33752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793517#comment-17793517
]
Rui Fan commented on FLINK-33752:
-
Merged to
master<1.19> via: 9b61b137bdc7eff773847b84e5cde116e6280c1d
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description: When we use flink-parquet format wirte Map[]
type (which will be read by spark job),
[
https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33759:
Description:
When we use flink-parquet format wirte Map[] type (which will
be read by spark
Cai Liuyang created FLINK-33759:
---
Summary: flink parquet writer support write nested array or map
type
Key: FLINK-33759
URL: https://issues.apache.org/jira/browse/FLINK-33759
Project: Flink
1996fanrui merged PR #23873:
URL: https://github.com/apache/flink/pull/23873
--
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-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793505#comment-17793505
]
Zakelly Lan commented on FLINK-33734:
-
hi [~Feifan Wang] ,
I'm wondering if this proposal aims
[ https://issues.apache.org/jira/browse/FLINK-27291 ]
hongxu han deleted comment on FLINK-27291:
was (Author: maomao):
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen this issue is created at 18/Apr/22 19:51
and Updated at
[
https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793497#comment-17793497
]
hongxu han commented on FLINK-27291:
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen
[ https://issues.apache.org/jira/browse/FLINK-27291 ]
韩宏旭 deleted comment on FLINK-27291:
-
was (Author: maomao):
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen this issue is created at 18/Apr/22 19:51
and Updated at 27/Mar/23 11:34.
[
https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793496#comment-17793496
]
韩宏旭 commented on FLINK-27291:
-
Hey Chengkai Yang,Cason
I am experienced in flink. I have seen this issue is
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reopened FLINK-25857:
Re-open this per discuss in mail-list.
> Add committer metrics to track the status of committables
>
flinkbot commented on PR #23880:
URL: https://github.com/apache/flink/pull/23880#issuecomment-1842042843
## CI report:
* db9949a710f0dcf6d317053732a0e96b75568944 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JunRuiLee commented on PR #23848:
URL: https://github.com/apache/flink/pull/23848#issuecomment-1842040305
Hi @zhuzhurk , thanks for your feedback. I have updated the pull request
based on your comments. Please take a look when you have a moment.
--
This is an automated message from the
WencongLiu commented on PR #23863:
URL: https://github.com/apache/flink/pull/23863#issuecomment-1842037511
> Thanks for the update, I'm + 1 for this one. Could you please also align
commit message with the title of this PR.
Done.
--
This is an automated message from the Apache Git
zhengzhili333 opened a new pull request, #23880:
URL: https://github.com/apache/flink/pull/23880
## What is the purpose of the change
*Currently, submitting a job starts with storing the JobGraph (in HA setups)
in the JobGraphStore. This includes writing the file to S3 (or some other
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1842032773
@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.
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1842026548
@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-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-32028:
--
Assignee: Peter Schulz
> Error handling for the new Elasticsearch sink
>
[
https://issues.apache.org/jira/browse/FLINK-32028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793492#comment-17793492
]
Weijie Guo commented on FLINK-32028:
Thanks for taking this, I will take a look at this PR.
> Error
[
https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-24819:
-
Fix Version/s: 1.19.0
1.18.1
1.17.3
> Higher APIServer cpu load
[
https://issues.apache.org/jira/browse/FLINK-24819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-24819.
--
Resolution: Fixed
> Higher APIServer cpu load after using SharedIndexInformer replaced naked
>
luoyuxia commented on PR #5:
URL:
https://github.com/apache/flink-connector-hive/pull/5#issuecomment-1842010718
@snuyanzin Hi, I also found some
pages(https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hive-dialect/overview/
,
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793488#comment-17793488
]
Yue Ma commented on FLINK-27681:
[~masteryhx] [~pnowojski] [~fanrui] Thanks for the discussion
So,
luoyuxia commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-hive/pull/5#discussion_r1416565534
##
flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkITCase.java:
##
@@ -0,0 +1,1000 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-31659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-31659.
Fix Version/s: 1.18.0
Resolution: Invalid
Should be fixed after
1996fanrui commented on code in PR #721:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/721#discussion_r1416590912
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizerTest.java:
##
@@ -30,12 +31,23
zoudan commented on code in PR #23849:
URL: https://github.com/apache/flink/pull/23849#discussion_r1416588553
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ResultProvider.java:
##
@@ -59,4 +59,7 @@ public interface ResultProvider {
zoudan commented on code in PR #23849:
URL: https://github.com/apache/flink/pull/23849#discussion_r1416588553
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ResultProvider.java:
##
@@ -59,4 +59,7 @@ public interface ResultProvider {
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1841996519
@cuibo01 thanks, I resolved conflicts and pushed the merge for testing -
will do a rebase after we see tests pass.
--
This is an automated message from the Apache Git Service.
To
swuferhong commented on code in PR #23828:
URL: https://github.com/apache/flink/pull/23828#discussion_r1416573713
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalSortAggWithSortAndCalcIntoScanRule.java:
##
@@
fsk119 commented on code in PR #23868:
URL: https://github.com/apache/flink/pull/23868#discussion_r1416572012
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliTableauResultView.java:
##
@@ -114,6 +108,30 @@ public void displayResults() throws
zhuzhurk commented on code in PR #23848:
URL: https://github.com/apache/flink/pull/23848#discussion_r1416568345
##
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java:
##
@@ -83,10 +86,27 @@ public AbstractRuntimeUDFContext(
}
zhuzhurk commented on code in PR #23848:
URL: https://github.com/apache/flink/pull/23848#discussion_r1416568345
##
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java:
##
@@ -83,10 +86,27 @@ public AbstractRuntimeUDFContext(
}
swuferhong commented on code in PR #23828:
URL: https://github.com/apache/flink/pull/23828#discussion_r1416564050
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalSortAggWithCalcIntoScanRule.java:
##
@@ -74,9
swuferhong commented on code in PR #23828:
URL: https://github.com/apache/flink/pull/23828#discussion_r1416555940
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/PushLocalSortAggWithSortAndCalcIntoScanRule.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-25593.
Resolution: Fixed
> A redundant scan could be skipped if it is an input of join and the other
> input is
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reopened FLINK-25593:
--
> A redundant scan could be skipped if it is an input of join and the other
> input is empty after
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-25593:
-
Fix Version/s: 1.19.0
> A redundant scan could be skipped if it is an input of join and the other
>
[
https://issues.apache.org/jira/browse/FLINK-33724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiaxing Chen closed FLINK-33724.
Resolution: Done
> Application mode doesn't support multiple lines argument
>
[
https://issues.apache.org/jira/browse/FLINK-33724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793478#comment-17793478
]
Jiaxing Chen commented on FLINK-33724:
--
Noticed that this issue has been mentioned in FLIP-366，and
cuibo01 commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1841927134
@tweise , Of course you can, thx
--
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
zhengzhili333 closed pull request #23866: [FLINK-33500][Runtime] Run storing
the JobGraph an asynchronous operation
URL: https://github.com/apache/flink/pull/23866
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793457#comment-17793457
]
Mason Chen edited comment on FLINK-33545 at 12/5/23 11:40 PM:
--
The reason
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793457#comment-17793457
]
Mason Chen commented on FLINK-33545:
The reason why you don't find any synchronization is because
flinkbot commented on PR #23879:
URL: https://github.com/apache/flink/pull/23879#issuecomment-1841777502
## CI report:
* 3a3ae47704eb419e33eb8ffc643c83f83befcb43 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33758:
---
Labels: pull-request-available (was: )
> Implement restore tests for TemporalSort node
>
jnh5y opened a new pull request, #23879:
URL: https://github.com/apache/flink/pull/23879
## What is the purpose of the change
Implement restore tests for TemporalSort node
## Verifying this change
This change added tests and can be verified as follows:
* Added
[
https://issues.apache.org/jira/browse/FLINK-33758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes reassigned FLINK-33758:
--
Assignee: Jim Hughes
> Implement restore tests for TemporalSort node
>
Jim Hughes created FLINK-33758:
--
Summary: Implement restore tests for TemporalSort node
Key: FLINK-33758
URL: https://issues.apache.org/jira/browse/FLINK-33758
Project: Flink
Issue Type:
flinkbot commented on PR #23878:
URL: https://github.com/apache/flink/pull/23878#issuecomment-1841752000
## CI report:
* 0c6402b8f833df3a05a60b4a5d0fbbc15ae55cda UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33757:
---
Labels: pull-request-available (was: )
> Implement restore tests for Rank node
>
jnh5y opened a new pull request, #23878:
URL: https://github.com/apache/flink/pull/23878
## What is the purpose of the change
Implement restore tests for Rank node
## Verifying this change
This change added tests and can be verified as follows:
* Added restore
Jim Hughes created FLINK-33757:
--
Summary: Implement restore tests for Rank node
Key: FLINK-33757
URL: https://issues.apache.org/jira/browse/FLINK-33757
Project: Flink
Issue Type: Sub-task
tweise commented on PR #18304:
URL: https://github.com/apache/flink/pull/18304#issuecomment-1841618310
@cuibo01 @MartijnVisser I just run into this issue (Flink 1.17) and was
happy to find this PR. Any reason this stalled? Can I help get this to the
finish line?
--
This is an automated
dannycranmer merged PR #23839:
URL: https://github.com/apache/flink/pull/23839
--
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:
dannycranmer merged PR #23840:
URL: https://github.com/apache/flink/pull/23840
--
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:
dannycranmer merged PR #23841:
URL: https://github.com/apache/flink/pull/23841
--
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:
gyfora commented on code in PR #712:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/712#discussion_r1416192622
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -1075,4 +1106,59 @@ protected
[
https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes updated FLINK-33756:
---
Description:
I have seen an optimization cause a window fail to emit a record.
With the
Jim Hughes created FLINK-33756:
--
Summary: Missing record with CUMULATE/HOP windows using an
optimization
Key: FLINK-33756
URL: https://issues.apache.org/jira/browse/FLINK-33756
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793381#comment-17793381
]
Salva edited comment on FLINK-24237 at 12/5/23 6:17 PM:
Are there any news? Can
[
https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793381#comment-17793381
]
Salva commented on FLINK-24237:
---
Are there any news? Can someone confirm any plans for working on this?
>
dawidwys commented on code in PR #23869:
URL: https://github.com/apache/flink/pull/23869#discussion_r1416038404
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java:
##
@@ -107,7 +107,7 @@ public class
jnh5y commented on code in PR #23869:
URL: https://github.com/apache/flink/pull/23869#discussion_r1416020844
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java:
##
@@ -0,0 +1,450 @@
+/*
+ * Licensed to
tagarr commented on PR #712:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/712#issuecomment-1841240447
So if you prefer not catching the exception I can just add some info in the
example readme about ensuring ssl location and password are consistent or you
may see
flinkbot commented on PR #23877:
URL: https://github.com/apache/flink/pull/23877#issuecomment-1841235550
## CI report:
* 0fc7e4da09365d5a524a68a715f8c7961d522aac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jeyhunkarimov opened a new pull request, #23877:
URL: https://github.com/apache/flink/pull/23877
## What is the purpose of the change
The purpose of this change is to make the constraint generation mechanism
the same in MergeTableLikeUtil and Schema
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33666:
---
Labels: pull-request-available (was: )
> MergeTableLikeUtil uses different constraint name
[
https://issues.apache.org/jira/browse/FLINK-33755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793352#comment-17793352
]
Sergey Nuyanzin commented on FLINK-33755:
-
Merged to master as
[
https://issues.apache.org/jira/browse/FLINK-33755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33755.
-
Resolution: Fixed
> Cleanup usage of deprecated
snuyanzin merged PR #23875:
URL: https://github.com/apache/flink/pull/23875
--
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-33755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33755.
---
> Cleanup usage of deprecated StreamExecutionEnvironment#generateSequence
>
snuyanzin commented on PR #23875:
URL: https://github.com/apache/flink/pull/23875#issuecomment-1841156149
Thanks for taking a look
--
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
jnh5y commented on code in PR #23869:
URL: https://github.com/apache/flink/pull/23869#discussion_r1415899730
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java:
##
@@ -107,7 +107,7 @@ public class
afedulov commented on PR #83:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/83#issuecomment-1841113426
@schulzp thanks for the contribution. The approach looks solid. I believe
what is missing are some tests that check that the non-default inspector is
actually
tagarr commented on code in PR #712:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/712#discussion_r1415823972
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -1075,4 +1106,59 @@ protected
tagarr commented on code in PR #712:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/712#discussion_r1415815965
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -195,8 +199,25 @@ public void
dawidwys commented on code in PR #23869:
URL: https://github.com/apache/flink/pull/23869#discussion_r1415790788
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java:
##
@@ -107,7 +107,7 @@ public class
1 - 100 of 185 matches
Mail list logo
